[GitHub] [flink] flinkbot edited a comment on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

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

[jira] [Commented] (FLINK-25483) When FlinkSQL writes ES, it will not write and update the null value field

[ https://issues.apache.org/jira/browse/FLINK-25483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471000#comment-17471000 ] 陈磊 commented on FLINK-25483: [~MartijnVisser] In fact, I don't understand why after doing th

[GitHub] [flink] zuston removed a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston removed a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1007545984 @tillrohrmann Thanks! Updated. Could you help review again? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] liufangqi commented on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

liufangqi commented on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-1007857608 @dmvk THX for your review, I have squashed the commit history and resolved the conficts. Could you help the merge work when you are free? THX! If there are still other proble

[GitHub] [flink] flinkbot edited a comment on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

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

[GitHub] [flink] flinkbot edited a comment on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

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

[jira] [Updated] (FLINK-5156) Consolidate streaming FieldAccessor functionality

[ https://issues.apache.org/jira/browse/FLINK-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5156: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[jira] [Updated] (FLINK-5230) Safety nets against leaving dysfunctional JobManagers

[ https://issues.apache.org/jira/browse/FLINK-5230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5230: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[jira] [Updated] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations

[ https://issues.apache.org/jira/browse/FLINK-5127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5127: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-deprior

[jira] [Updated] (FLINK-5139) consum kafka can set offset

[ https://issues.apache.org/jira/browse/FLINK-5139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5139: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[jira] [Updated] (FLINK-5177) Improve nullability handling

[ https://issues.apache.org/jira/browse/FLINK-5177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5177: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-deprior

[jira] [Updated] (FLINK-5178) allow BlobCache to use a distributed file system irrespective of the HA mode

[ https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5178: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-deprior

[jira] [Updated] (FLINK-5260) Add docs about how to react to cancellation

[ https://issues.apache.org/jira/browse/FLINK-5260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5260: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[jira] [Updated] (FLINK-5264) Improve error message when assigning uid to intermediate operator

[ https://issues.apache.org/jira/browse/FLINK-5264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5264: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[jira] [Updated] (FLINK-5279) Improve error message when trying to access keyed state in non-keyed operator

[ https://issues.apache.org/jira/browse/FLINK-5279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5279: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[jira] [Updated] (FLINK-5263) Add docs about JVM sharing between tasks

[ https://issues.apache.org/jira/browse/FLINK-5263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5263: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[GitHub] [flink] snuyanzin commented on a change in pull request #18287: [FLINK-17321][table] Add support casting of map to map and multiset to multiset

snuyanzin commented on a change in pull request #18287: URL: https://github.com/apache/flink/pull/18287#discussion_r780465918 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CastFunctionITCase.java ## @@ -1142,14 +1146,27 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

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

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

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

[GitHub] [flink] flinkbot edited a comment on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

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

[GitHub] [flink] MartijnVisser commented on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

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

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

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

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * e089768e55137235bd5b85a0b6b97b00dd0d23f9 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] gaoyunhaii commented on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

gaoyunhaii commented on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007585748 Very thanks @fapaul for drafting the PR! I'll also have a look soon~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[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_r780397929 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServicesTest.java ## @@ -235,8 +235,7 @@ private v

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] afedulov edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-1007555875 @fapaul I addressed all of the comments. The only remaining open points from my perspective: - clarify if imposing a strict `Serializable` requirement on the `Con

[GitHub] [flink] afedulov commented on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-1007555875 @fapaul I addressed all of the comments. The only remaining open points from my perspective: - clarify if imposing a strict `Serializable` requirement on the `Converter`

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

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

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-25564) TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470741#comment-17470741 ] Junfan Zhang commented on FLINK-25564: -- I can't reproduce this in my local machine,

[GitHub] [flink] flinkbot commented on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

flinkbot commented on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007552617 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 commented on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-25569) Introduce decomposed Sink V2 interfaces

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

[GitHub] [flink] fapaul commented on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

fapaul commented on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007548874 @gaoyunhaii do you also want to have a look at this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] fapaul opened a new pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

fapaul opened a new pull request #18302: URL: https://github.com/apache/flink/pull/18302 ## What is the purpose of the change This is the first PR of FLIP-191 (https://issues.apache.org/jira/browse/FLINK-2) it introduces the basic decomposed interfaces that are the repla

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r780379983 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/TableCsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r780378774 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterClientProviderTest.java ## @@ -0,0 +1,135 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r780378665 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java ## @@ -87,6 +87,6 @@ private YarnClusterDescriptor getClusterD

[GitHub] [flink] zuston commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1007546966 @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] 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_r780378061 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/TestingDispatcher.java ## @@ -65,7 +68,14 @@ public void onStart() throws Exc

[GitHub] [flink] zuston commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1007545984 @tillrohrmann Thanks! Updated. Could you help review again? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18298: [FLINK-25307][Test] Print the curl logs is querying dispatcher startup failed

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

[jira] [Commented] (FLINK-25577) Update GCS documentation not to use no longer supported flink-shaded-hadoop artifacts

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470731#comment-17470731 ] David Morávek commented on FLINK-25577: --- Sounds good, thanks for taking care of th

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

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

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

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

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

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

[GitHub] [flink] flinkbot edited a comment on pull request #18105: [FLINK-25266][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

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

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 718ea97838ff10191544cc7460d3c18380b0e119 Azure: [FAILURE](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_r780354067 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobPersistenceComponentFactory.java ## @@ -18,13 +18,22 @@ package org.apa

[jira] [Commented] (FLINK-25577) Update GCS documentation not to use no longer supported flink-shaded-hadoop artifacts

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470705#comment-17470705 ] Galen Warren commented on FLINK-25577: -- Why don't we leave it open, just so that it

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

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

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

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

[jira] [Commented] (FLINK-25577) Update GCS documentation not to use no longer supported flink-shaded-hadoop artifacts

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470702#comment-17470702 ] David Morávek commented on FLINK-25577: --- That's a great news [~galenwarren], I've

[GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1007508085 I'm assuming that we'll need some docs here as well. [Here](https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/filesystems/s3/) are the similar docs for S

[jira] [Commented] (FLINK-25577) Update GCS documentation not to use no longer supported flink-shaded-hadoop artifacts

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470701#comment-17470701 ] Galen Warren commented on FLINK-25577: -- I just wanted to mention that it's likely t

[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_r780344263 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java ## @@ -244,11 +244,13 @@ public void cleanupJob

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

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

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

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

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

dmvk commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r780341370 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcess.java ## @@ -92,34 +99,61 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

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

[GitHub] [flink] flinkbot edited a comment on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

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

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

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

[GitHub] [flink] twalthr commented on a change in pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

twalthr commented on a change in pull request #18283: URL: https://github.com/apache/flink/pull/18283#discussion_r780333584 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

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

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470684#comment-17470684 ] Timo Walther commented on FLINK-25471: -- Thanks for the explanation [~paul8263] . I

[jira] [Assigned] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25471: Assignee: Yao Zhang > wrong result if table transfrom to DataStream then keyby sum in Ba

[GitHub] [flink] Chromico commented on pull request #18300: Update H2 to 2.0.206 to address CVE-2021-42392.

Chromico commented on pull request #18300: URL: https://github.com/apache/flink/pull/18300#issuecomment-1007489335 Done :) -- 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.

[GitHub] [flink] Chromico closed pull request #18300: Update H2 to 2.0.206 to address CVE-2021-42392.

Chromico closed pull request #18300: URL: https://github.com/apache/flink/pull/18300 -- 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-unsubs

[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_r780327971 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java ## @@ -130,11 +130,11 @@ public JobGraphStore g

[jira] [Updated] (FLINK-25578) Graduate Sink V1 interfaces to PublicEvolving and deprecate them

[ https://issues.apache.org/jira/browse/FLINK-25578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25578: Description: In the discussion of FLIP-191 we decided to not break existing sinks and give them t

[GitHub] [flink] twalthr commented on a change in pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

twalthr commented on a change in pull request #18274: URL: https://github.com/apache/flink/pull/18274#discussion_r780327690 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/LogicalTypeJsonSerdeTest.java ## @@ -249

  1   2   3   4   5   >