boring-cyborg[bot] commented on PR #55:
URL:
https://github.com/apache/flink-connector-kafka/pull/55#issuecomment-1749891731
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is a
qbx2 opened a new pull request, #55:
URL: https://github.com/apache/flink-connector-kafka/pull/55
# What is the purpose of the change
In the CachingTopicSelector, there is possibility to cause memory leak when
the internal logic fails to check cache size by race condition.
(https://g
srpraneeth commented on code in PR #682:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/682#discussion_r1348082819
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/validation/AutoScalerValidator.java:
##
@@ -0,
srpraneeth commented on code in PR #682:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/682#discussion_r1348082441
##
e2e-tests/data/autoscaler.yaml:
##
@@ -41,6 +41,13 @@ spec:
kubernetes.operator.job.autoscaler.stabilization.interval: "5s"
kubernetes.
srpraneeth commented on code in PR #682:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/682#discussion_r1348082332
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/validation/AutoScalerValidator.java:
##
@@ -0,
srpraneeth commented on code in PR #682:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/682#discussion_r1348079066
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/validation/AutoScalerValidator.java:
##
@@ -0,
srpraneeth commented on code in PR #682:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/682#discussion_r1348078891
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/validation/AutoScalerValidator.java:
##
@@ -0,
[
https://issues.apache.org/jira/browse/FLINK-33020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-33020:
---
Labels: pull-request-available stale-blocker (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32667:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772399#comment-17772399
]
Zhenqiu Huang commented on FLINK-31275:
---
[~jark]
This JIRA is mentioned in FLIP-31
tzulitai commented on PR #19:
URL:
https://github.com/apache/flink-connector-cassandra/pull/19#issuecomment-1749692586
Hey @echauchot I'm trying to fix the same thing for the Kafka connector, but
I could use your help on understanding the change here.
What exactly is the change that
yigress commented on PR #22281:
URL: https://github.com/apache/flink/pull/22281#issuecomment-1749662460
> There is now a patch available here at #23469.
will it fix this issue?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772385#comment-17772385
]
Tzu-Li (Gordon) Tai commented on FLINK-33104:
-
[~echauchot] this seems to be
[
https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772385#comment-17772385
]
Tzu-Li (Gordon) Tai edited comment on FLINK-33104 at 10/5/23 9:10 PM:
[
https://issues.apache.org/jira/browse/FLINK-33082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-33082.
---
Resolution: Won't Fix
> Azure Pipelines 4 is not responding on AZP
> ---
[
https://issues.apache.org/jira/browse/FLINK-33082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772384#comment-17772384
]
Sergey Nuyanzin commented on FLINK-33082:
-
yes, probably you are right, let's cl
ferenc-csaky commented on code in PR #23469:
URL: https://github.com/apache/flink/pull/23469#discussion_r1347925648
##
flink-walkthroughs/flink-walkthrough-datastream-java/src/main/resources/archetype-resources/pom.xml:
##
@@ -31,7 +31,6 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-33187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33187:
---
Labels: pull-request-available (was: )
> Don't record duplicate event if no change
> --
clarax opened a new pull request, #683:
URL: https://github.com/apache/flink-kubernetes-operator/pull/683
## What is the purpose of the change
https://issues.apache.org/jira/browse/FLINK-33187
Suppress duplicate event for scaling report within the interval defined by a
new operator
[
https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772350#comment-17772350
]
Mason Chen commented on FLINK-33011:
[~gyfora] could you backport this to 1.6? We ar
[
https://issues.apache.org/jira/browse/FLINK-33188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772336#comment-17772336
]
Elkhan Dadashov commented on FLINK-33188:
-
After digging into the flink-python c
flinkbot commented on PR #23490:
URL: https://github.com/apache/flink/pull/23490#issuecomment-1749244900
## CI report:
* c49cdfbb3c297b076c752605f5ea9052390bafd5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora opened a new pull request, #23490:
URL: https://github.com/apache/flink/pull/23490
## What is the purpose of the change
Extend the current TypeExtraction + PojoSerializer logic to support handling
Java Record classes.
The main difference is the extra codepath needed to insta
[
https://issues.apache.org/jira/browse/FLINK-32380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32380:
---
Labels: pull-request-available (was: )
> Support Java records
>
>
>
cnauroth commented on PR #22281:
URL: https://github.com/apache/flink/pull/22281#issuecomment-1749192664
There is now a patch available here at #23469.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to g
davidradl commented on PR #23469:
URL: https://github.com/apache/flink/pull/23469#issuecomment-1749146500
@ferenc-csaky
> In general I believe if we change these props it would worth to explore
the whole codebase, so we do not leave any loose ends.
I could not see any other places in
JingGe commented on PR #23482:
URL: https://github.com/apache/flink/pull/23482#issuecomment-1749134264
@rmoff would you please rebase to solve the conflicts? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-33187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Clara Xiong updated FLINK-33187:
Description:
Problem:
Some events are recorded repeatedly such as ScalingReport when autoscaling i
[
https://issues.apache.org/jira/browse/FLINK-33187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Clara Xiong updated FLINK-33187:
Summary: Don't record duplicate event if no change (was: Don't send
duplicate event to Kafka if n
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772246#comment-17772246
]
Jiang Xin commented on FLINK-33186:
---
I'll take a look at it.
> CheckpointAfterAllTas
arthurlee commented on code in PR #23240:
URL: https://github.com/apache/flink/pull/23240#discussion_r1347477555
##
docs/content/docs/try-flink/local_installation.md:
##
@@ -46,6 +46,8 @@ to have __Java 11__ installed. To check the Java version
installed, type in your
$ java -
davidradl commented on code in PR #23469:
URL: https://github.com/apache/flink/pull/23469#discussion_r1347443841
##
pom.xml:
##
@@ -1334,7 +1338,7 @@ under the License.
-
davidradl commented on code in PR #23488:
URL: https://github.com/apache/flink/pull/23488#discussion_r1347416170
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeContext.java:
##
@@ -167,12 +170,19 @@ public ExecNodeContext
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772212#comment-17772212
]
Dong Lin commented on FLINK-33186:
--
cc [~xtsong]
> CheckpointAfterAllTasksFinishedIT
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-33186:
Assignee: Jiang Xin
> CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished
>
flinkbot commented on PR #23489:
URL: https://github.com/apache/flink/pull/23489#issuecomment-1748737680
## CI report:
* e8dd8ed7b93dec3e9d810be86dfbbe53345a6c54 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
singhravidutt opened a new pull request, #23489:
URL: https://github.com/apache/flink/pull/23489
## What is the purpose of the change
Shade the guava version required specifically by google-cloud-storage.
## Brief change log
Introduced dependency on guava version(`31.1-jr
[
https://issues.apache.org/jira/browse/FLINK-28518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-28518:
---
Fix Version/s: 1.18.0
> Exception: AssertionError: Cannot add expression of different type t
[
https://issues.apache.org/jira/browse/FLINK-28518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-28518.
--
Resolution: Fixed
> Exception: AssertionError: Cannot add expression of different type to set
[
https://issues.apache.org/jira/browse/FLINK-28518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772179#comment-17772179
]
Robert Metzger commented on FLINK-28518:
This is the ticket for the calcite upgr
[
https://issues.apache.org/jira/browse/FLINK-33184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772159#comment-17772159
]
Matthias Pohl commented on FLINK-33184:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772158#comment-17772158
]
Matthias Pohl commented on FLINK-28440:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772150#comment-17772150
]
Matthias Pohl edited comment on FLINK-33175 at 10/5/23 10:03 AM:
-
dannycranmer commented on PR #676:
URL: https://github.com/apache/flink-web/pull/676#issuecomment-1748518714
> Thank you for addressing my feedback.
>
> > Would you prefer it in both locations, or just under About?
>
> This is a very subjective question, there's no right or wron
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31278:
--
Affects Version/s: 1.19.0
> exit code 137 (i.e. OutOfMemoryError) in core module
> ---
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772152#comment-17772152
]
Matthias Pohl commented on FLINK-31278:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772150#comment-17772150
]
Matthias Pohl commented on FLINK-33175:
---
I looked into the issue with [~Sergey Nuy
Jing Ge created FLINK-33195:
---
Summary: ElasticSearch Connector should directly depend on
3rd-party libs instead of flink-shaded repo
Key: FLINK-33195
URL: https://issues.apache.org/jira/browse/FLINK-33195
P
[
https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771788#comment-17771788
]
Emre Kartoglu edited comment on FLINK-33178 at 10/5/23 9:06 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772120#comment-17772120
]
Emre Kartoglu commented on FLINK-33178:
---
Adding 1.17.1 to affected versions based
[
https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Emre Kartoglu updated FLINK-33178:
--
Affects Version/s: 1.17.1
> Highly parallel apps suffer from bottleneck in NativePRNG
> -
surendralilhore commented on code in PR #23428:
URL: https://github.com/apache/flink/pull/23428#discussion_r1346953716
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java:
##
@@ -242,8 +242,14 @@ private CompletableFuture handleException(
surendralilhore commented on code in PR #23428:
URL: https://github.com/apache/flink/pull/23428#discussion_r1346953716
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java:
##
@@ -242,8 +242,14 @@ private CompletableFuture handleException(
rmetzger commented on PR #676:
URL: https://github.com/apache/flink-web/pull/676#issuecomment-1748220121
I am ready to soft-approve this pull request, but would feel more
comfortable if another committer would take a look as well, given that this PR
is changing the "face" of Flink pretty si
rmetzger commented on PR #676:
URL: https://github.com/apache/flink-web/pull/676#issuecomment-1748210083
Thank you for addressing my feedback.
> Would you prefer it in both locations, or just under About?
This is a very subjective question, there's no right or wrong here. But I
55 matches
Mail list logo
