[GitHub] [flink] flinkbot edited a comment on pull request #18570: [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts. Backport to 1.13

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

[GitHub] [flink] flinkbot commented on pull request #18571: [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts. Backport to 1.14

flinkbot commented on pull request #18571: URL: https://github.com/apache/flink/pull/18571#issuecomment-1025758210 ## CI report: * 542569f0995ffb3bff3c184594bd8344d5b69410 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] tillrohrmann commented on a change in pull request #18542: [FLINK-25855] Allow JobMaster to accept excess slots when restarting the job

tillrohrmann commented on a change in pull request #18542: URL: https://github.com/apache/flink/pull/18542#discussion_r795687450 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java ## @@ -1816,6 +1819,60 @@ public void testJobMaster

[jira] [Commented] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484694#comment-17484694 ] Etienne Chauchot commented on FLINK-24844: -- Thanks for the tip [~gaoyunhaii], I

[GitHub] [flink] flinkbot edited a comment on pull request #18571: [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts. Backport to 1.14

flinkbot edited a comment on pull request #18571: URL: https://github.com/apache/flink/pull/18571#issuecomment-1025758210 ## CI report: * 542569f0995ffb3bff3c184594bd8344d5b69410 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 #18569: [FLINK-25847] Fix deadlock in DefaultMultipleComponentLeaderElectionService

XComp commented on a change in pull request #18569: URL: https://github.com/apache/flink/pull/18569#discussion_r795688448 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesHighAvailabilityRecoverFromSavepointITCase.java ## @@ -

[GitHub] [flink] flinkbot edited a comment on pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

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

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

fapaul commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r795698138 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java ## @@ -19,250 +19,237 @@

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

fapaul commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r795698138 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java ## @@ -19,250 +19,237 @@

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

fapaul commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r795704693 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/committables/CommittableCollector.java ## @@ -0,0 +1,24

[GitHub] [flink] flinkbot edited a comment on pull request #18569: [FLINK-25847] Fix deadlock in DefaultMultipleComponentLeaderElectionService

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

[GitHub] [flink] dawidwys commented on a change in pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

dawidwys commented on a change in pull request #18539: URL: https://github.com/apache/flink/pull/18539#discussion_r795706462 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -203,10 +204,37 @@ public long getStateSize

[GitHub] [flink] dawidwys commented on a change in pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

dawidwys commented on a change in pull request #18539: URL: https://github.com/apache/flink/pull/18539#discussion_r795709706 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java ## @@ -224,19 +289,27 @@ public void close() {

[GitHub] [flink] flinkbot edited a comment on pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

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

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

fapaul commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r795715352 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/committables/CommittableCollector.java ## @@ -0,0 +1,24

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #18538: [FLINK-25728][task] Solve potential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18542: [FLINK-25855] Allow JobMaster to accept excess slots when restarting the job

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

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

fapaul commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r795720433 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/CommitterOperator.java ## @@ -17,95 +17,173 @@ packa

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

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

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

fapaul commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r795720433 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/CommitterOperator.java ## @@ -17,95 +17,173 @@ packa

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

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

[GitHub] [flink] flinkbot edited a comment on pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

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

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

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

[GitHub] [flink] flinkbot edited a comment on pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

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

[GitHub] [flink] flinkbot edited a comment on pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

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

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

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

[jira] [Created] (FLINK-25894) Explicitly configure japicmp oldVersion for flink-streaming-java

Chesnay Schepler created FLINK-25894: Summary: Explicitly configure japicmp oldVersion for flink-streaming-java Key: FLINK-25894 URL: https://issues.apache.org/jira/browse/FLINK-25894 Project: Fli

[GitHub] [flink] flinkbot edited a comment on pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

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

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

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

[GitHub] [flink] flinkbot edited a comment on pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

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

[GitHub] [flink] flinkbot edited a comment on pull request #18568: [hotfix][docs] Fix the java example of `Interval Join`

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

[jira] [Created] (FLINK-25895) Add ExecNodeGraph ser/de

Francesco Guardiani created FLINK-25895: --- Summary: Add ExecNodeGraph ser/de Key: FLINK-25895 URL: https://issues.apache.org/jira/browse/FLINK-25895 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-25812) Show Plan in Ui doesn't show.

[ https://issues.apache.org/jira/browse/FLINK-25812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] None none updated FLINK-25812: -- Attachment: Screen Shot 2022-01-31 at 9.55.26 AM.png > Show Plan in Ui doesn't show. > ---

[jira] [Commented] (FLINK-25812) Show Plan in Ui doesn't show.

[ https://issues.apache.org/jira/browse/FLINK-25812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484723#comment-17484723 ] None none commented on FLINK-25812: --- Ok looked into it further. The error above is unr

[GitHub] [flink] tillrohrmann commented on a change in pull request #18569: [FLINK-25847] Fix deadlock in DefaultMultipleComponentLeaderElectionService

tillrohrmann commented on a change in pull request #18569: URL: https://github.com/apache/flink/pull/18569#discussion_r795748839 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/DefaultMultipleComponentLeaderElectionServiceTest.java ## @@ -203,

[jira] [Commented] (FLINK-25812) Show Plan in Ui doesn't show.

[ https://issues.apache.org/jira/browse/FLINK-25812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484725#comment-17484725 ] None none commented on FLINK-25812: --- The UI looks like this:   !Screen Shot 2022-01-

[GitHub] [flink] tillrohrmann commented on a change in pull request #18569: [FLINK-25847] Fix deadlock in DefaultMultipleComponentLeaderElectionService

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

[jira] [Commented] (FLINK-25812) Show Plan in Ui doesn't show.

[ https://issues.apache.org/jira/browse/FLINK-25812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484728#comment-17484728 ] None none commented on FLINK-25812: --- And this is the Javascript error I see in browser

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * 176a27c492a14373848921916e7ab64dcabf 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 #18569: [FLINK-25847] Fix deadlock in DefaultMultipleComponentLeaderElectionService

tillrohrmann commented on a change in pull request #18569: URL: https://github.com/apache/flink/pull/18569#discussion_r795753158 ## File path: flink-core/src/test/java/org/apache/flink/testutils/TestingUtils.java ## @@ -56,4 +56,9 @@ public static ScheduledExecutor defaultSched

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

slinkydeveloper commented on a change in pull request #18572: URL: https://github.com/apache/flink/pull/18572#discussion_r79577 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeGraphValidator.java ## @@ -0,0

[GitHub] [flink] slinkydeveloper opened a new pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

slinkydeveloper opened a new pull request #18572: URL: https://github.com/apache/flink/pull/18572 ## What is the purpose of the change This PR reorganizes a bit the code that was previously in `ExecNodeGraphJsonPlanGenerator`. It introduces `ExecNodeGraph` ser/de to handle the inter

[jira] [Updated] (FLINK-25895) Add ExecNodeGraph ser/de

[ https://issues.apache.org/jira/browse/FLINK-25895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25895: --- Labels: pull-request-available (was: ) > Add ExecNodeGraph ser/de > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

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

[GitHub] [flink] flinkbot commented on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

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

[GitHub] [flink] flinkbot edited a comment on pull request #18569: [FLINK-25847] Fix deadlock in DefaultMultipleComponentLeaderElectionService

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

[GitHub] [flink] flinkbot commented on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

flinkbot commented on pull request #18572: URL: https://github.com/apache/flink/pull/18572#issuecomment-1025855579 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] fapaul commented on a change in pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

fapaul commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r795698138 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java ## @@ -19,250 +19,237 @@

[GitHub] [flink] slinkydeveloper opened a new pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

slinkydeveloper opened a new pull request #18573: URL: https://github.com/apache/flink/pull/18573 ## What is the purpose of the change This PR is the first step towards exposing the persisted plan feature to the users. It features 5 new APIs in `TableEnvironment` plus 2 new types:

[GitHub] [flink] flinkbot edited a comment on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

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

[GitHub] [flink] flinkbot edited a comment on pull request #18569: [FLINK-25847] Fix deadlock in DefaultMultipleComponentLeaderElectionService

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

[jira] [Updated] (FLINK-25841) Expose plan via TableEnvironment.compilePlanSql/executePlan

[ https://issues.apache.org/jira/browse/FLINK-25841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25841: --- Labels: pull-request-available (was: ) > Expose plan via TableEnvironment.compilePlanSql/ex

[GitHub] [flink] flinkbot commented on pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

flinkbot commented on pull request #18573: URL: https://github.com/apache/flink/pull/18573#issuecomment-1025873751 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] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

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

[GitHub] [flink] flinkbot commented on pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

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

[GitHub] [flink] slinkydeveloper commented on pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

slinkydeveloper commented on pull request #18573: URL: https://github.com/apache/flink/pull/18573#issuecomment-1025884523 Please note that the second commit of this PR _Splitted ExecNodeGraphJsonPlanGenerator[...]_ has been extracted to a separate PR: https://github.com/apache/flink/pull/1

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

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

[GitHub] [flink] flinkbot edited a comment on pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

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

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * 176a27c492a14373848921916e7ab64dcabf 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-1025891089 > For the `execute` method, sorry I has some misunderstandings initially that the clear happens before compile happens, but it should indeed be happen after the generate() is ca

[jira] [Updated] (FLINK-25276) FLIP-203: Support native and incremental savepoints

[ https://issues.apache.org/jira/browse/FLINK-25276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25276: --- Summary: FLIP-203: Support native and incremental savepoints (was: FLIP-182: Support native

[GitHub] [flink] matriv commented on a change in pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

matriv commented on a change in pull request #18572: URL: https://github.com/apache/flink/pull/18572#discussion_r795782895 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeGraphValidator.java ## @@ -0,0 +1,50 @@

[GitHub] [flink] matriv commented on a change in pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

matriv commented on a change in pull request #18572: URL: https://github.com/apache/flink/pull/18572#discussion_r795784977 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeGraphValidator.java ## @@ -0,0 +1,50 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

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

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

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

[GitHub] [flink] matriv commented on a change in pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

matriv commented on a change in pull request #18572: URL: https://github.com/apache/flink/pull/18572#discussion_r795782895 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeGraphValidator.java ## @@ -0,0 +1,50 @@

[jira] [Created] (FLINK-25896) Buffer debloating issues with high parallelism

Piotr Nowojski created FLINK-25896: -- Summary: Buffer debloating issues with high parallelism Key: FLINK-25896 URL: https://issues.apache.org/jira/browse/FLINK-25896 Project: Flink Issue Type

[jira] [Updated] (FLINK-25896) Buffer debloating issues with high parallelism

[ https://issues.apache.org/jira/browse/FLINK-25896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25896: --- Description: As described in FLINK-25646, currently buffer debloating has performance issues

[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: * e135c4f6208fb5efe5c0c0640f90d82f588e244d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

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

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

flinkbot edited a comment on pull request #18541: URL: https://github.com/apache/flink/pull/18541#issuecomment-1023343281 ## CI report: * 95b34f9a3ff26cdbb2edc4250e494614287f5b5b 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: * e135c4f6208fb5efe5c0c0640f90d82f588e244d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

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

[GitHub] [flink] flinkbot edited a comment on pull request #18524: [FLINK-25428][table-common][table-planner] Expose string casting for map, multiset, structured, row and raw

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

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

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

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

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

[GitHub] [flink] flinkbot edited a comment on pull request #18524: [FLINK-25428][table-common][table-planner] Expose string casting for map, multiset, structured, row and raw

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

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

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

[jira] [Created] (FLINK-25897) Update project configuration gradle doc to 7.x version

Francesco Guardiani created FLINK-25897: --- Summary: Update project configuration gradle doc to 7.x version Key: FLINK-25897 URL: https://issues.apache.org/jira/browse/FLINK-25897 Project: Flink

[jira] [Updated] (FLINK-25897) Update project configuration gradle doc to 7.x version

[ https://issues.apache.org/jira/browse/FLINK-25897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-25897: Component/s: Documentation > Update project configuration gradle doc to 7.x versio

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

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

[GitHub] [flink] slinkydeveloper commented on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

slinkydeveloper commented on pull request #18572: URL: https://github.com/apache/flink/pull/18572#issuecomment-1025941687 @matriv given your two comments, does it makes sense to just go ahead and remove this validator? -- This is an automated message from the Apache Git Service. To respo

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

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

[jira] [Created] (FLINK-25898) Add README.md to flink-statefun/statefun-sdk-js

Till Rohrmann created FLINK-25898: - Summary: Add README.md to flink-statefun/statefun-sdk-js Key: FLINK-25898 URL: https://issues.apache.org/jira/browse/FLINK-25898 Project: Flink Issue Type:

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

fapaul edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1025891089 > For the `execute` method, sorry I has some misunderstandings initially that the clear happens before compile happens, but it should indeed be happen after the generate(

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

flinkbot edited a comment on pull request #18353: URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377 ## CI report: * 50e221c6373f2774eeb8ec134df27caef83b2d40 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: * e135c4f6208fb5efe5c0c0640f90d82f588e244d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

flinkbot edited a comment on pull request #18353: URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377 ## CI report: * 50e221c6373f2774eeb8ec134df27caef83b2d40 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: * e135c4f6208fb5efe5c0c0640f90d82f588e244d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] pnowojski merged pull request #18538: [FLINK-25728][task] Solve potential memory leaks in StreamMultipleInputProcessor

pnowojski merged pull request #18538: URL: https://github.com/apache/flink/pull/18538 -- 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 comment. To unsubscribe, e-mail: issues-unsub

[GitHub] [flink] pnowojski commented on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

pnowojski commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1025964209 Merged to master as cb8c6567d205e21d844679220d727379409c6b24 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] pnowojski closed pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

pnowojski closed pull request #18475: URL: https://github.com/apache/flink/pull/18475 -- 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 comment. To unsubscribe, e-mail: issues-unsub

[jira] [Commented] (FLINK-25891) NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark

[ https://issues.apache.org/jira/browse/FLINK-25891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484768#comment-17484768 ] Anton Kalashnikov commented on FLINK-25891: --- merged to flink-benchmarks master

[jira] [Closed] (FLINK-25891) NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark

[ https://issues.apache.org/jira/browse/FLINK-25891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-25891. - Resolution: Fixed > NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark > ---

[jira] [Assigned] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25728: -- Assignee: pc wang > Potential memory leaks in StreamMultipleInputProcessor >

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

flinkbot edited a comment on pull request #18353: URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377 ## CI report: * 50e221c6373f2774eeb8ec134df27caef83b2d40 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: * e135c4f6208fb5efe5c0c0640f90d82f588e244d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

<    1   2   3   4   >