[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791738550 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesMultipleComponentLeaderElectionDriverTest.java #

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791735909 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionAndRetrievalITCase.java ## @@ -53,

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791735909 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionAndRetrievalITCase.java ## @@ -53,

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791735024 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesTestFixture.java ## @@ -0,0 +1,236 @@ +/* + * Li

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791733602 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesTestFixture.java ## @@ -0,0 +1,236 @@ +/* + * Li

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791731554 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesHighAvailabilityRecoverFromSavepointITCase.java

[GitHub] [flink] flinkbot edited a comment on pull request #18306: [FLINK-25445] No need to create local recovery dirs when disabled loc…

flinkbot edited a comment on pull request #18306: URL: https://github.com/apache/flink/pull/18306#issuecomment-1008234006 ## CI report: * f8c4b9cfcf8dd3fc85472dac9b8165c7c2c846dc Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791726361 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesHighAvailabilityRecoverFromSavepointITCase.java

[GitHub] [flink] flinkbot edited a comment on pull request #18506: [FLINK-25805][table-planner] Use the DataType compact representation by default when using default conversion classes

flinkbot edited a comment on pull request #18506: URL: https://github.com/apache/flink/pull/18506#issuecomment-1021193813 ## CI report: * 31ecf11d9be5d256921dc0ae5b33e682c671a023 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791726361 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesHighAvailabilityRecoverFromSavepointITCase.java

[GitHub] [flink] flinkbot edited a comment on pull request #18392: [FLINK-25590][metrics] Introduce RequestedMemoryUsage and log warnings if usage exceeds 100%

flinkbot edited a comment on pull request #18392: URL: https://github.com/apache/flink/pull/18392#issuecomment-1015285195 ## CI report: * 8fcd75bc3466edd79726a95f62aa923c31796b2e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791725238 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesHighAvailabilityRecoverFromSavepointITCase.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791723572 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesMultipleComponentLeaderElectionHaServices.java #

[jira] [Closed] (FLINK-25804) Loading and running connector code use separated ClassLoader.

[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25804. -- Resolution: Duplicate > Loading and running connector code use separated ClassLoader. > --

[GitHub] [flink] rkhachatryan commented on pull request #18223: [FLINK-25423][state-processor-api] Enable loading state backend via configuration in state processor api

rkhachatryan commented on pull request #18223: URL: https://github.com/apache/flink/pull/18223#issuecomment-1021195246 No problem @curcur, I'll take a look. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791722429 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesMultipleComponentLeaderElectionDriver.java ## @@

[GitHub] [flink] flinkbot commented on pull request #18506: [FLINK-25805][table-planner] Use the DataType compact representation by default when using default conversion classes

flinkbot commented on pull request #18506: URL: https://github.com/apache/flink/pull/18506#issuecomment-1021193813 ## CI report: * 31ecf11d9be5d256921dc0ae5b33e682c671a023 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18497: [FLINK-25290][tests] add table tests for connector testframe

flinkbot edited a comment on pull request #18497: URL: https://github.com/apache/flink/pull/18497#issuecomment-1020875715 ## CI report: * 85206e64e2a833777a2c346c38202b222674bc75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18495: [hotfix] [docs] Updated doc with flink image name and tag

flinkbot edited a comment on pull request #18495: URL: https://github.com/apache/flink/pull/18495#issuecomment-1020843806 ## CI report: * 52d21ea631d0ff554012d0806e6593eb4e550052 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791720593 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesMultipleComponentLeaderElectionDriver.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18392: [FLINK-25590][metrics] Introduce RequestedMemoryUsage and log warnings if usage exceeds 100%

flinkbot edited a comment on pull request #18392: URL: https://github.com/apache/flink/pull/18392#issuecomment-1015285195 ## CI report: * 8fcd75bc3466edd79726a95f62aa923c31796b2e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] XComp commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

XComp commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r791720372 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobDispatcherFactory.java ## @@ -38,13 +40,21 @@ public MiniDispatcher create

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791720043 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesMultipleComponentLeaderElectionDriver.java ## @@

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791719632 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperMultipleComponentLeaderElectionHaServices.java ##

[GitHub] [flink] flinkbot commented on pull request #18506: [FLINK-25805][table-planner] Use the DataType compact representation by default when using default conversion classes

flinkbot commented on pull request #18506: URL: https://github.com/apache/flink/pull/18506#issuecomment-1021190808 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pr

[jira] [Comment Edited] (FLINK-25154) FLIP-193: Snapshots ownership

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481627#comment-17481627 ] Dawid Wysakowicz edited comment on FLINK-25154 at 1/25/22, 1:35 PM: --

[jira] [Comment Edited] (FLINK-25154) FLIP-193: Snapshots ownership

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481627#comment-17481627 ] Dawid Wysakowicz edited comment on FLINK-25154 at 1/25/22, 1:34 PM: --

[jira] [Comment Edited] (FLINK-25154) FLIP-193: Snapshots ownership

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481627#comment-17481627 ] Dawid Wysakowicz edited comment on FLINK-25154 at 1/25/22, 1:34 PM: --

[jira] [Comment Edited] (FLINK-25154) FLIP-193: Snapshots ownership

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481627#comment-17481627 ] Dawid Wysakowicz edited comment on FLINK-25154 at 1/25/22, 1:34 PM: --

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] pnowojski commented on pull request #18392: [FLINK-25590][metrics] Introduce RequestedMemoryUsage and log warnings if usage exceeds 100%

pnowojski commented on pull request #18392: URL: https://github.com/apache/flink/pull/18392#issuecomment-1021187597 @flinkbot run azure -- 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 go to the specif

[jira] [Updated] (FLINK-25805) Use compact DataType serialization for default classes instead of internal ones

[ https://issues.apache.org/jira/browse/FLINK-25805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25805: --- Labels: pull-request-available (was: ) > Use compact DataType serialization for default cla

[jira] [Assigned] (FLINK-25348) Update release guide to reset japicmp exceptions for every release

[ https://issues.apache.org/jira/browse/FLINK-25348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-25348: Assignee: Chesnay Schepler > Update release guide to reset japicmp exceptions for

[jira] [Updated] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown.

[ https://issues.apache.org/jira/browse/FLINK-21995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21995: --- Priority: Major (was: Not a Priority) > YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.

[jira] [Commented] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown.

[ https://issues.apache.org/jira/browse/FLINK-21995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481811#comment-17481811 ] Piotr Nowojski commented on FLINK-21995: https://dev.azure.com/apache-flink/apac

[GitHub] [flink] slinkydeveloper opened a new pull request #18506: [FLINK-25805][table-planner] Use the DataType compact representation by default when using default conversion classes

slinkydeveloper opened a new pull request #18506: URL: https://github.com/apache/flink/pull/18506 ## What is the purpose of the change For more details https://issues.apache.org/jira/browse/FLINK-25805 ## Brief change log * Use the DataType compact representa

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791709987 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -500,5 +502,49 @@ public static String tr

[GitHub] [flink] flinkbot edited a comment on pull request #18502: [hotfix][docs][kafka] Add explanation how Kafka Source deals with idl…

flinkbot edited a comment on pull request #18502: URL: https://github.com/apache/flink/pull/18502#issuecomment-1021048562 ## CI report: * 1f83802ae2f9a2dfd9700dfb20e39a7756ee0ff2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791708481 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -500,5 +502,49 @@ public static String tr

[GitHub] [flink] flinkbot edited a comment on pull request #18502: [hotfix][docs][kafka] Add explanation how Kafka Source deals with idl…

flinkbot edited a comment on pull request #18502: URL: https://github.com/apache/flink/pull/18502#issuecomment-1021048562 ## CI report: * 1f83802ae2f9a2dfd9700dfb20e39a7756ee0ff2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

flinkbot edited a comment on pull request #18500: URL: https://github.com/apache/flink/pull/18500#issuecomment-1021030168 ## CI report: * 5c2d53d24569ad6f9c346ad087aa33ed5f76ebb1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791701888 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -500,5 +502,49 @@ public static String tr

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791699982 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -500,5 +502,49 @@ public static String tr

[GitHub] [flink] flinkbot edited a comment on pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

flinkbot edited a comment on pull request #18500: URL: https://github.com/apache/flink/pull/18500#issuecomment-1021030168 ## CI report: * 5c2d53d24569ad6f9c346ad087aa33ed5f76ebb1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

slinkydeveloper commented on a change in pull request #18464: URL: https://github.com/apache/flink/pull/18464#discussion_r791698085 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/module/CoreModuleTest.java ## @@ -18,14 +18,56 @@ package or

[GitHub] [flink] MartijnVisser commented on a change in pull request #18502: [hotfix][docs][kafka] Add explanation how Kafka Source deals with idl…

MartijnVisser commented on a change in pull request #18502: URL: https://github.com/apache/flink/pull/18502#discussion_r791699368 ## File path: docs/content.zh/docs/connectors/datastream/kafka.md ## @@ -176,6 +176,15 @@ env.fromSource(kafkaSource, new CustomWatermarkStrategy(),

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] MartijnVisser commented on pull request #18502: [hotfix][docs][kafka] Add explanation how Kafka Source deals with idl…

MartijnVisser commented on pull request #18502: URL: https://github.com/apache/flink/pull/18502#issuecomment-1021173347 > LGTM 👍 @MartijnVisser do you also want to update the Chinese translation or do it separately? I've updated the PR with the provided Chinese translation. -- Th

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791698577 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -500,5 +502,49 @@ public static String tr

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791697770 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/LeaderElectionEvent.java ## @@ -0,0 +1,116 @@ +/* + * Licensed to

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791697464 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/util/ZooKeeperUtilsITCase.java ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791696684 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791696236 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[GitHub] [flink] flinkbot commented on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot commented on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot commented on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021167533 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pr

[GitHub] [flink] xintongsong commented on a change in pull request #18417: [FLINK-15455][network] Enabled tcp connection reuse across multi jobs.

xintongsong commented on a change in pull request #18417: URL: https://github.com/apache/flink/pull/18417#discussion_r791620680 ## File path: flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java ## @@ -286,6 +286,26 @@

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481801#comment-17481801 ] Zichen Liu commented on FLINK-24229: Hi [~Gusev]  Thank you so much for the contrib

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25796) Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

[ https://issues.apache.org/jira/browse/FLINK-25796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25796: --- Labels: pull-request-available (was: ) > Avoid record copy for result partition of sort-shu

[GitHub] [flink] wsry opened a new pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

wsry opened a new pull request #18505: URL: https://github.com/apache/flink/pull/18505 ## What is the purpose of the change Currently, for result partition of sort-shuffle, there is extra record copy overhead Introduced by clustering records by subpartition index. For small records,

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791685670 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[jira] [Updated] (FLINK-25348) Update release guide to reset japicmp exceptions for every release

[ https://issues.apache.org/jira/browse/FLINK-25348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25348: -- Description: I propose to clean up the japicmp maven plugin exclusion for every minor release

[jira] [Commented] (FLINK-25348) Update release guide to reset japicmp exceptions for every release

[ https://issues.apache.org/jira/browse/FLINK-25348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481792#comment-17481792 ] Till Rohrmann commented on FLINK-25348: --- Sounds good [~chesnay]. I've updated the

[GitHub] [flink] fapaul commented on a change in pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

fapaul commented on a change in pull request #18145: URL: https://github.com/apache/flink/pull/18145#discussion_r791678375 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java ## @@ -55

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Closed] (FLINK-11063) Make flink-table Scala-free

[ https://issues.apache.org/jira/browse/FLINK-11063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11063. Resolution: Implemented All subtasks are implemented. > Make flink-table Scala-free > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * d105000a8f900450acefdcd0102331a2aaa72e47 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * b9b29ad0b3697de70c570ee08d4ccf45f1c3e0bf Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18468: [FLINK-24905][connector/kinesis]Adding Kinesis data streams sql uber-jar and end to end test.

flinkbot edited a comment on pull request #18468: URL: https://github.com/apache/flink/pull/18468#issuecomment-1019969068 ## CI report: * 6ac66f07be10e8c320e77b89e41fc6ba17b1571e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * b9b29ad0b3697de70c570ee08d4ccf45f1c3e0bf Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot edited a comment on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * 67371e27c0db6cac957fc34fb8f0104257e28fbc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-25269) Return 503 Service Unavailable if endpoint is not ready yet

[ https://issues.apache.org/jira/browse/FLINK-25269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25269: - Description: If an endpoint (e.g., the RM) has not been started yet when receiving a req

[jira] [Updated] (FLINK-25269) Return 503 Service Unavailable if endpoint is not ready yet

[ https://issues.apache.org/jira/browse/FLINK-25269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25269: - Priority: Minor (was: Major) > Return 503 Service Unavailable if endpoint is not ready

[jira] [Updated] (FLINK-25269) Return 503 Service Unavailable if endpoint is not ready yet

[ https://issues.apache.org/jira/browse/FLINK-25269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25269: - Issue Type: Improvement (was: Bug) > Return 503 Service Unavailable if endpoint is not

[jira] [Updated] (FLINK-25269) Return 503 Service Unavailable if endpoint is not ready yet

[ https://issues.apache.org/jira/browse/FLINK-25269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25269: - Summary: Return 503 Service Unavailable if endpoint is not ready yet (was: Quickstarts

[jira] [Updated] (FLINK-25269) Return 503 Service Unavailable if endpoint is not ready yet

[ https://issues.apache.org/jira/browse/FLINK-25269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25269: - Component/s: Runtime / REST (was: Build System / Azure Pipelines) >

[GitHub] [flink] flinkbot edited a comment on pull request #18468: [FLINK-24905][connector/kinesis]Adding Kinesis data streams sql uber-jar and end to end test.

flinkbot edited a comment on pull request #18468: URL: https://github.com/apache/flink/pull/18468#issuecomment-1019969068 ## CI report: * 6ac66f07be10e8c320e77b89e41fc6ba17b1571e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fapaul commented on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

fapaul commented on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1021113345 @flinkbot run azure -- 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 go to the specific

[GitHub] [flink] flinkbot edited a comment on pull request #18493: [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese.

flinkbot edited a comment on pull request #18493: URL: https://github.com/apache/flink/pull/18493#issuecomment-1020820553 ## CI report: * 05eecb0902812076e561dab93951c625564233bc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791630020 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[GitHub] [flink] rkhachatryan commented on a change in pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

rkhachatryan commented on a change in pull request #18324: URL: https://github.com/apache/flink/pull/18324#discussion_r791624395 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html ## @@ -217,14 +227,26 @@ >

[jira] [Assigned] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25771: -- Assignee: Etienne Chauchot > CassandraConnectorITCase.testRetrialAndDropTables fails

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481755#comment-17481755 ] Piotr Nowojski commented on FLINK-25771: Done [~echauchot] Another instance: ht

[GitHub] [flink] flinkbot edited a comment on pull request #18492: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

flinkbot edited a comment on pull request #18492: URL: https://github.com/apache/flink/pull/18492#issuecomment-1020820488 ## CI report: * e2ce82eee950b512b719e2813f7e75591e32fb69 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-25269) Quickstarts Scala nightly end-to-end test failed on azure due to could not connect to resource manager

[ https://issues.apache.org/jira/browse/FLINK-25269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-25269: Assignee: Chesnay Schepler > Quickstarts Scala nightly end-to-end test failed on

[jira] [Closed] (FLINK-25626) Azure failed due to "Error occurred in starting fork"

[ https://issues.apache.org/jira/browse/FLINK-25626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25626. Resolution: Cannot Reproduce I'm gonna take a wild guess and attribute this to other ongoi

[jira] [Closed] (FLINK-22024) Maven: Entry has not been leased from this pool / fix for release 1.12

[ https://issues.apache.org/jira/browse/FLINK-22024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-22024. Fix Version/s: (was: 1.12.8) Resolution: Won't Fix 1.12 is no longer supported.

[GitHub] [flink] flinkbot edited a comment on pull request #18491: [FLINK-25800][docs] Update wrong links in the datastream/execution_mode.md page.

flinkbot edited a comment on pull request #18491: URL: https://github.com/apache/flink/pull/18491#issuecomment-1020818213 ## CI report: * a072fd8479b34bf48c84b2786b792f7b55f4e841 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25753) KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481749#comment-17481749 ] Hang Ruan commented on FLINK-25753: --- Yes, I will take a look at this error. > KafkaTa

[jira] [Updated] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25374: - Issue Type: Technical Debt (was: Bug) > Azure pipeline get stalled on scanning project

[jira] [Closed] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16720. Fix Version/s: (was: 1.11.0) Resolution: Fixed > Maven gets stuck downloading a

[jira] [Closed] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25374. Fix Version/s: (was: 1.15.0) Resolution: Fixed We haven't seen a new failure in

<    2   3   4   5   6   7   8   9   >