[GitHub] [flink] godfreyhe commented on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

godfreyhe commented on pull request #18785: URL: https://github.com/apache/flink/pull/18785#issuecomment-1041345782 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 318d5650f14a51a9f1aee5fe5f97a14d5d54bef6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * 2ffd741d316346745bd8fe754bb02a73cbf0d0ba Azure:

[jira] [Commented] (FLINK-26148) Change the format of adaptive batch scheduler config option to "jobmanager.adaptive-batch-scheduler.XXX"

[ https://issues.apache.org/jira/browse/FLINK-26148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493156#comment-17493156 ] Lijie Wang commented on FLINK-26148: Yes, I will update it soon. > Change the format of adaptive

[jira] [Commented] (FLINK-26148) Change the format of adaptive batch scheduler config option to "jobmanager.adaptive-batch-scheduler.XXX"

[ https://issues.apache.org/jira/browse/FLINK-26148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493154#comment-17493154 ] Zhu Zhu commented on FLINK-26148: - [~wanglijie95] would you update FLIP-187 for the configuration name

[jira] [Commented] (FLINK-26121) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493153#comment-17493153 ] Matthias Pohl commented on FLINK-26121: --- There seems to be a gap of 10s in processing time while

[GitHub] [flink] flinkbot edited a comment on pull request #18786: [hotfix][test] add support for field assignability

flinkbot edited a comment on pull request #18786: URL: https://github.com/apache/flink/pull/18786#issuecomment-1040539589 ## CI report: * 199d94fca6df52f120633c8202b40409e1d7e794 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * Unknown: [CANCELED](TBD) * 2ffd741d316346745bd8fe754bb02a73cbf0d0ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18786: [hotfix][test] add support for field assignability

flinkbot edited a comment on pull request #18786: URL: https://github.com/apache/flink/pull/18786#issuecomment-1040539589 ## CI report: * 6fa8c290984d253ef7408abb6d23d49370c0f4b8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18799: [FLINK-26145][docs] fix a kubernetes image that does not exist in the…

flinkbot edited a comment on pull request #18799: URL: https://github.com/apache/flink/pull/18799#issuecomment-1041334465 ## CI report: * 73640cb14e6a68cacc27b281f8d5508a5ffa21ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 318d5650f14a51a9f1aee5fe5f97a14d5d54bef6 Azure:

[jira] [Updated] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17

[ https://issues.apache.org/jira/browse/FLINK-25000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25000: - Description: Fails with "fails with /packages cannot be represented as URI" during

[GitHub] [flink] wanglijie95 commented on a change in pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

wanglijie95 commented on a change in pull request #18757: URL: https://github.com/apache/flink/pull/18757#discussion_r807768428 ## File path: docs/content/docs/deployment/adaptive_batch_scheduler.md ## @@ -0,0 +1,63 @@ +--- +title: Adaptive Batch Scheduler +weight: 5 +type:

[GitHub] [flink] flinkbot commented on pull request #18799: [FLINK-26145][docs] fix a kubernetes image that does not exist in the…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

flinkbot edited a comment on pull request #18798: URL: https://github.com/apache/flink/pull/18798#issuecomment-1041265347 ## CI report: * 7b3b53570a9ac3f4b7159e7b1bf24eb7d29b2649 Azure:

[jira] [Created] (FLINK-26185) E2E Elasticsearch Tests should use the new Sink interface

Alexander Preuss created FLINK-26185: Summary: E2E Elasticsearch Tests should use the new Sink interface Key: FLINK-26185 URL: https://issues.apache.org/jira/browse/FLINK-26185 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 318d5650f14a51a9f1aee5fe5f97a14d5d54bef6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18756: [FLINK-26075][table-api][table-planner] Persist node configuration

flinkbot edited a comment on pull request #18756: URL: https://github.com/apache/flink/pull/18756#issuecomment-1039112190 ## CI report: * c7c123b2541e931272beb18f619bf8d8a418e471 Azure:

[GitHub] [flink] flinkbot commented on pull request #18799: [FLINK-26145][docs] fix a kubernetes image that does not exist in the…

flinkbot commented on pull request #18799: URL: https://github.com/apache/flink/pull/18799#issuecomment-1041332368 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

[GitHub] [flink] flinkbot edited a comment on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

flinkbot edited a comment on pull request #18798: URL: https://github.com/apache/flink/pull/18798#issuecomment-1041265347 ## CI report: * 7b3b53570a9ac3f4b7159e7b1bf24eb7d29b2649 Azure:

[jira] [Resolved] (FLINK-25532) Provide Flink SQL CLI as Docker image

[ https://issues.apache.org/jira/browse/FLINK-25532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf resolved FLINK-25532. -- Resolution: Fixed Fixed via Documentation. > Provide Flink SQL CLI as Docker image >

[jira] [Updated] (FLINK-25532) Provide Flink SQL CLI as Docker image

[ https://issues.apache.org/jira/browse/FLINK-25532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25532: - Fix Version/s: 1.15.0 > Provide Flink SQL CLI as Docker image >

[jira] [Assigned] (FLINK-25532) Provide Flink SQL CLI as Docker image

[ https://issues.apache.org/jira/browse/FLINK-25532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-25532: Assignee: Konstantin Knauf > Provide Flink SQL CLI as Docker image >

[GitHub] [flink] flinkbot edited a comment on pull request #18756: [FLINK-26075][table-api][table-planner] Persist node configuration

flinkbot edited a comment on pull request #18756: URL: https://github.com/apache/flink/pull/18756#issuecomment-1039112190 ## CI report: * c7c123b2541e931272beb18f619bf8d8a418e471 Azure:

[jira] [Updated] (FLINK-26145) k8s docs jobmanager-pod-template artifacts-fetcher:latest image is not exist, we can use busybox to replace it

[ https://issues.apache.org/jira/browse/FLINK-26145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26145: --- Labels: pull-request-available (was: ) > k8s docs jobmanager-pod-template

[GitHub] [flink] knaufk merged pull request #18725: [FLINK-25532] Improve Documentation of Flink Docker-Compose

knaufk merged pull request #18725: URL: https://github.com/apache/flink/pull/18725 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 318d5650f14a51a9f1aee5fe5f97a14d5d54bef6 Azure:

[GitHub] [flink] liuyongvs opened a new pull request #18799: [FLINK-26145][docs] fix a kubernetes image that does not exist in the…

liuyongvs opened a new pull request #18799: URL: https://github.com/apache/flink/pull/18799 ## What is the purpose of the change * fix docs* -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot edited a comment on pull request #18611: [FLINK-24385][table] Introduce TRY_CAST

flinkbot edited a comment on pull request #18611: URL: https://github.com/apache/flink/pull/18611#issuecomment-1028155639 ## CI report: * f369013d63f0d367eab9744112e56bd7a8987177 Azure:

[jira] [Resolved] (FLINK-25980) remove unnecessary condition in IntervalJoinOperator

[ https://issues.apache.org/jira/browse/FLINK-25980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-25980. - Fix Version/s: 1.15.0 Resolution: Fixed > remove unnecessary condition in

[GitHub] [flink] flinkbot edited a comment on pull request #18611: [FLINK-24385][table] Introduce TRY_CAST

flinkbot edited a comment on pull request #18611: URL: https://github.com/apache/flink/pull/18611#issuecomment-1028155639 ## CI report: * f369013d63f0d367eab9744112e56bd7a8987177 Azure:

[jira] [Commented] (FLINK-25980) remove unnecessary condition in IntervalJoinOperator

[ https://issues.apache.org/jira/browse/FLINK-25980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493139#comment-17493139 ] Fabian Paul commented on FLINK-25980: - Merged in master: ebfc7c8d599d561a7d18a9ebea23a3c8297d2e0c >

[GitHub] [flink] fapaul merged pull request #18647: [FLINK-25980][datastream] remove unnecessary condition

fapaul merged pull request #18647: URL: https://github.com/apache/flink/pull/18647 -- 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:

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18611: [FLINK-24385][table] Introduce TRY_CAST

slinkydeveloper commented on a change in pull request #18611: URL: https://github.com/apache/flink/pull/18611#discussion_r807755945 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/CastRuleProvider.java ## @@ -107,6

[jira] [Closed] (FLINK-25946) table-planner-loader jar NOTICE should list Scala

[ https://issues.apache.org/jira/browse/FLINK-25946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25946. Resolution: Fixed > table-planner-loader jar NOTICE should list Scala >

[GitHub] [flink] flinkbot edited a comment on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

flinkbot edited a comment on pull request #18798: URL: https://github.com/apache/flink/pull/18798#issuecomment-1041265347 ## CI report: * 7b3b53570a9ac3f4b7159e7b1bf24eb7d29b2649 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 9b9e4dc96990436cb5684646ed801b84f2357848 Azure:

[jira] [Assigned] (FLINK-25958) OOME Checkpoints & Savepoints were shown as COMPLETE in Flink UI

[ https://issues.apache.org/jira/browse/FLINK-25958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25958: -- Assignee: Anton Kalashnikov > OOME Checkpoints & Savepoints were shown as COMPLETE

[GitHub] [flink] flinkbot edited a comment on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

flinkbot edited a comment on pull request #18798: URL: https://github.com/apache/flink/pull/18798#issuecomment-1041265347 ## CI report: * 7b3b53570a9ac3f4b7159e7b1bf24eb7d29b2649 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

flinkbot edited a comment on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1040944258 ## CI report: * cdab9f7d140989714263bc2a4e1a0908bb444a12 Azure:

[jira] [Commented] (FLINK-25571) Update Elasticsearch Sink to use decomposed interfaces

[ https://issues.apache.org/jira/browse/FLINK-25571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493133#comment-17493133 ] Fabian Paul commented on FLINK-25571: - Merged in master: 2d517950a9ae4a58b25f59fb6048f4c1a15225ac >

[jira] [Resolved] (FLINK-25571) Update Elasticsearch Sink to use decomposed interfaces

[ https://issues.apache.org/jira/browse/FLINK-25571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-25571. - Fix Version/s: 1.15.0 Resolution: Fixed > Update Elasticsearch Sink to use decomposed

[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

flinkbot edited a comment on pull request #18785: URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147 ## CI report: * 50789f74f16c2bd3e42a61754f426877a3376056 Azure:

[jira] [Updated] (FLINK-26183) Support kubernetes-operator metrics using the Flink metric system

[ https://issues.apache.org/jira/browse/FLINK-26183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26183: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Support

[jira] [Updated] (FLINK-26181) Support manual savepoint triggering in the operator

[ https://issues.apache.org/jira/browse/FLINK-26181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26181: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Support

[GitHub] [flink] wanglijie95 commented on a change in pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

wanglijie95 commented on a change in pull request #18757: URL: https://github.com/apache/flink/pull/18757#discussion_r807748519 ## File path: docs/content/docs/deployment/adaptive_batch_scheduler.md ## @@ -0,0 +1,63 @@ +--- +title: Adaptive Batch Scheduler +weight: 5 +type:

[GitHub] [flink] fapaul merged pull request #18666: [FLINK-25571] Update Elasticsearch Sink to use decomposed interfaces

fapaul merged pull request #18666: URL: https://github.com/apache/flink/pull/18666 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

flinkbot edited a comment on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1027886359 ## CI report: * 948f554e347ff5cb332d3273372718012d5b14fb Azure:

[GitHub] [flink] wanglijie95 commented on a change in pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

wanglijie95 commented on a change in pull request #18757: URL: https://github.com/apache/flink/pull/18757#discussion_r807748121 ## File path: docs/content/docs/deployment/adaptive_batch_scheduler.md ## @@ -0,0 +1,63 @@ +--- +title: Adaptive Batch Scheduler +weight: 5 +type:

[jira] [Updated] (FLINK-26141) Support last-state upgrade mode

[ https://issues.apache.org/jira/browse/FLINK-26141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26141: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Support

[jira] [Updated] (FLINK-26142) Integrate flink-kubernetes-operator repo with CI/CD

[ https://issues.apache.org/jira/browse/FLINK-26142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26142: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Integrate

[jira] [Updated] (FLINK-26157) Containers Should Not Run As Root

[ https://issues.apache.org/jira/browse/FLINK-26157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26157: --- Component/s: Kubernetes Operator > Containers Should Not Run As Root >

[jira] [Updated] (FLINK-26179) Support periodic savepointing in the operator

[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26179: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Support

[jira] [Updated] (FLINK-26163) Refactor FlinkUtils#getEffectiveConfig into smaller pieces

[ https://issues.apache.org/jira/browse/FLINK-26163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26163: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Refactor

[jira] [Updated] (FLINK-26140) Add basic handling mechanism to deal with job upgrade errors

[ https://issues.apache.org/jira/browse/FLINK-26140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26140: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Add basic

[jira] [Updated] (FLINK-26139) Improve JobStatus tracking and handle different job states

[ https://issues.apache.org/jira/browse/FLINK-26139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26139: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Improve

[jira] [Updated] (FLINK-26138) Create controller test

[ https://issues.apache.org/jira/browse/FLINK-26138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26138: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Create

[jira] [Updated] (FLINK-26137) Create webhook REST api test

[ https://issues.apache.org/jira/browse/FLINK-26137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26137: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Create

[jira] [Updated] (FLINK-26135) Separate job and deployment errors in FlinkDeployment status

[ https://issues.apache.org/jira/browse/FLINK-26135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26135: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Separate job

[jira] [Updated] (FLINK-26136) Implement shared validation logic for FlinkDeployment objects

[ https://issues.apache.org/jira/browse/FLINK-26136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26136: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Implement

[jira] [Updated] (FLINK-26078) Initial Kubernetes Operator Prototype contribution

[ https://issues.apache.org/jira/browse/FLINK-26078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26078: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Initial

[GitHub] [flink] dawidwys commented on a change in pull request #18745: [FLINK-24607] Make OperatorCoordinator closing sequence more robust.

dawidwys commented on a change in pull request #18745: URL: https://github.com/apache/flink/pull/18745#discussion_r807684936 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/ComponentClosingUtils.java ## @@ -95,8 +100,94 @@ private

[jira] [Commented] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

[ https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493129#comment-17493129 ] Gyula Fora commented on FLINK-26178: Done, thanks, will update all the tickets here > Use the same

[jira] [Updated] (FLINK-25963) FLIP-212: Introduce Flink Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-25963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-25963: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > FLIP-212:

[jira] [Updated] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

[ https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26178: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Use the same

[GitHub] [flink] flinkbot edited a comment on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

flinkbot edited a comment on pull request #18798: URL: https://github.com/apache/flink/pull/18798#issuecomment-1041265347 ## CI report: * 7b3b53570a9ac3f4b7159e7b1bf24eb7d29b2649 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

flinkbot edited a comment on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1040944258 ## CI report: * cdab9f7d140989714263bc2a4e1a0908bb444a12 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

flinkbot edited a comment on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1027886359 ## CI report: * 948f554e347ff5cb332d3273372718012d5b14fb Azure:

[GitHub] [flink] MartijnVisser commented on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

MartijnVisser commented on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1041308638 @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

[jira] [Updated] (FLINK-26184) Migrate StoreSink to Sink V2

[ https://issues.apache.org/jira/browse/FLINK-26184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26184: --- Labels: pull-request-available (was: ) > Migrate StoreSink to Sink V2 >

[jira] [Commented] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

[ https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493126#comment-17493126 ] Chesnay Schepler commented on FLINK-26178: -- You should be able to add it here:

[GitHub] [flink-table-store] JingsongLi opened a new pull request #22: [FLINK-26184] Migrate StoreSink to Sink V2

JingsongLi opened a new pull request #22: URL: https://github.com/apache/flink-table-store/pull/22 This PR creates a new Sink interface: `GlobalCommittingSink`. ``` /** * The {@code GlobalCommitter} is responsible for creating and committing an aggregated committable, * which

[GitHub] [flink] flinkbot edited a comment on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

flinkbot edited a comment on pull request #18798: URL: https://github.com/apache/flink/pull/18798#issuecomment-1041265347 ## CI report: * 7b3b53570a9ac3f4b7159e7b1bf24eb7d29b2649 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 8dbb8256563d48a7bdb13489d6670ae6215eebe1 Azure:

[jira] [Resolved] (FLINK-24246) Bump PulsarClient to 2.9.1 with better transaction management

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-24246. - Fix Version/s: 1.15.0 Resolution: Fixed > Bump PulsarClient to 2.9.1 with better

[jira] [Commented] (FLINK-24246) Bump PulsarClient to 2.9.1 with better transaction management

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493125#comment-17493125 ] Fabian Paul commented on FLINK-24246: - Merged in master: 1602e4b7d26cf52cea993c410769b7b15a672aff >

[jira] [Commented] (FLINK-26020) Unified Pulsar Connector config model

[ https://issues.apache.org/jira/browse/FLINK-26020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493124#comment-17493124 ] Fabian Paul commented on FLINK-26020: - Merged in master: 36de46dc9cf3144a02a4f99c973bfb6b0db60c7e >

[jira] [Updated] (FLINK-26020) Unified Pulsar Connector config model

[ https://issues.apache.org/jira/browse/FLINK-26020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26020: Affects Version/s: 1.15.0 > Unified Pulsar Connector config model >

[jira] [Resolved] (FLINK-26020) Unified Pulsar Connector config model

[ https://issues.apache.org/jira/browse/FLINK-26020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-26020. - Fix Version/s: 1.15.0 Resolution: Fixed > Unified Pulsar Connector config model >

[jira] [Resolved] (FLINK-26021) Pulsar topic deduplicated in both sink and source connector

[ https://issues.apache.org/jira/browse/FLINK-26021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-26021. - Fix Version/s: 1.15.0 Resolution: Fixed > Pulsar topic deduplicated in both sink and

[GitHub] [flink] wanglijie95 commented on a change in pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

wanglijie95 commented on a change in pull request #18757: URL: https://github.com/apache/flink/pull/18757#discussion_r807733497 ## File path: docs/content/docs/deployment/adaptive_batch_scheduler.md ## @@ -0,0 +1,63 @@ +--- +title: Adaptive Batch Scheduler +weight: 5 +type:

[GitHub] [flink] flinkbot edited a comment on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

flinkbot edited a comment on pull request #18798: URL: https://github.com/apache/flink/pull/18798#issuecomment-1041265347 ## CI report: * 7b3b53570a9ac3f4b7159e7b1bf24eb7d29b2649 Azure:

[jira] [Commented] (FLINK-26021) Pulsar topic deduplicated in both sink and source connector

[ https://issues.apache.org/jira/browse/FLINK-26021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493123#comment-17493123 ] Fabian Paul commented on FLINK-26021: - Merged in master: a195f729ba4d1ffe657d82888b26ab9db9121ab8 >

[jira] [Commented] (FLINK-26023) Create a Pulsar sink config model for matching ProducerConfigurationData

[ https://issues.apache.org/jira/browse/FLINK-26023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493121#comment-17493121 ] Fabian Paul commented on FLINK-26023: - Merged in master: 9bc8b0f37bec419bcdc4b8cdee3abf5320df5399 >

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 5abd99fbc044163e5ca8b4ddfb6c33e55df06b44 Azure:

[jira] [Resolved] (FLINK-26023) Create a Pulsar sink config model for matching ProducerConfigurationData

[ https://issues.apache.org/jira/browse/FLINK-26023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-26023. - Resolution: Fixed > Create a Pulsar sink config model for matching ProducerConfigurationData >

[jira] [Commented] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

[ https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493122#comment-17493122 ] Gyula Fora commented on FLINK-26178: [~chesnay] thank you for jumping in, I was going to propose

[jira] [Updated] (FLINK-26023) Create a Pulsar sink config model for matching ProducerConfigurationData

[ https://issues.apache.org/jira/browse/FLINK-26023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26023: Affects Version/s: 1.15.0 > Create a Pulsar sink config model for matching

[jira] [Updated] (FLINK-26021) Pulsar topic deduplicated in both sink and source connector

[ https://issues.apache.org/jira/browse/FLINK-26021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26021: Affects Version/s: 1.15.0 > Pulsar topic deduplicated in both sink and source connector >

[jira] [Updated] (FLINK-26023) Create a Pulsar sink config model for matching ProducerConfigurationData

[ https://issues.apache.org/jira/browse/FLINK-26023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26023: Fix Version/s: 1.15.0 > Create a Pulsar sink config model for matching ProducerConfigurationData

[jira] [Updated] (FLINK-26024) Create a PulsarSerializationSchema for better records serialization

[ https://issues.apache.org/jira/browse/FLINK-26024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26024: Affects Version/s: 1.15.0 > Create a PulsarSerializationSchema for better records serialization >

[jira] [Commented] (FLINK-26163) Refactor FlinkUtils#getEffectiveConfig into smaller pieces

[ https://issues.apache.org/jira/browse/FLINK-26163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493120#comment-17493120 ] Gyula Fora commented on FLINK-26163: Awesome, thanks [~bgeng777]  > Refactor

[GitHub] [flink] flinkbot edited a comment on pull request #18725: [FLINK-25532] Improve Documentation of Flink Docker-Compose

flinkbot edited a comment on pull request #18725: URL: https://github.com/apache/flink/pull/18725#issuecomment-1036065440 ## CI report: * b97354da0a65cd807b532a083f53c1c90b0c8a08 Azure:

[jira] [Resolved] (FLINK-26024) Create a PulsarSerializationSchema for better records serialization

[ https://issues.apache.org/jira/browse/FLINK-26024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-26024. - Fix Version/s: 1.15.0 Resolution: Fixed > Create a PulsarSerializationSchema for better

[jira] [Assigned] (FLINK-26184) Migrate StoreSink to Sink V2

[ https://issues.apache.org/jira/browse/FLINK-26184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26184: Assignee: Jingsong Lee > Migrate StoreSink to Sink V2 > > >

[jira] [Commented] (FLINK-26024) Create a PulsarSerializationSchema for better records serialization

[ https://issues.apache.org/jira/browse/FLINK-26024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493119#comment-17493119 ] Fabian Paul commented on FLINK-26024: - Merged in master: 0e72bfede70a00146f466b3e7491fc0f83eb6c41 >

[jira] [Updated] (FLINK-26022) Implement at-least-once and exactly-once Pulsar Sink

[ https://issues.apache.org/jira/browse/FLINK-26022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26022: Affects Version/s: 1.15.0 > Implement at-least-once and exactly-once Pulsar Sink >

[jira] [Assigned] (FLINK-26163) Refactor FlinkUtils#getEffectiveConfig into smaller pieces

[ https://issues.apache.org/jira/browse/FLINK-26163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26163: -- Assignee: Biao Geng > Refactor FlinkUtils#getEffectiveConfig into smaller pieces >

[jira] [Resolved] (FLINK-26022) Implement at-least-once and exactly-once Pulsar Sink

[ https://issues.apache.org/jira/browse/FLINK-26022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-26022. - Fix Version/s: 1.15.0 Resolution: Fixed > Implement at-least-once and exactly-once

[jira] [Commented] (FLINK-26022) Implement at-least-once and exactly-once Pulsar Sink

[ https://issues.apache.org/jira/browse/FLINK-26022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493118#comment-17493118 ] Fabian Paul commented on FLINK-26022: - Merged in master: 136add5d0c9c5b9b2869a9ee194f78449065b18e >

<    2   3   4   5   6   7   8   9   >