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

gaoyunhaii commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r797347655 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java ## @@ -20,249

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

gaoyunhaii edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1027672049 For the parallelism issue, is it possible that 1. Before call pre-committer topology, we first modify the default parallelism of env to -1 2. After the call

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

gaoyunhaii edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1027672049 For the parallelism issue, is it possible that 1. Before call pre-committer topology, we first modify the default parallelism of env to -1 2. After the call

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

gaoyunhaii commented on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1027672049 For the parallelism issue, is it possible that 1. Before call pre-committer, first modify the default parallelism of env to -1 2. After the call finished, change the

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * e13fe4771f44859fcc986bb868bdb3d56537ec5a Azure:

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

gaoyunhaii commented on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1027668111 Hi Fabian~ > I am not really familiar with this part of the code base but so far I did not see any failing tests regarding the TableOperatorWrapperGenerator can you

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * e13fe4771f44859fcc986bb868bdb3d56537ec5a Azure:

[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_r797342100 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java ## @@ -20,249 +20,258

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 6854b5ae7209cd2edc56ac525f462292f85efd9c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * e13fe4771f44859fcc986bb868bdb3d56537ec5a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 3bdbb660a027c49a1fed5c8b77ccf5174c16c85d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18395: [FLINK-25685][rest] RestClusterClient supports uploading local file path with scheme

flinkbot edited a comment on pull request #18395: URL: https://github.com/apache/flink/pull/18395#issuecomment-1015461969 ## CI report: * 4b6abbb068246fd6640062b90036c306c194d454 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18395: [FLINK-25685][rest] RestClusterClient supports uploading local file path with scheme

flinkbot edited a comment on pull request #18395: URL: https://github.com/apache/flink/pull/18395#issuecomment-1015461969 ## CI report: * 4b6abbb068246fd6640062b90036c306c194d454 Azure:

[GitHub] [flink] Sxnan commented on a change in pull request #18395: [FLINK-25685][rest] RestClusterClient supports uploading local file path with scheme

Sxnan commented on a change in pull request #18395: URL: https://github.com/apache/flink/pull/18395#discussion_r797221404 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java ## @@ -357,7 +357,8 @@ public void close() {

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * 0321a661fff58fa8feac5463096b4d5fe4e401b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * 0321a661fff58fa8feac5463096b4d5fe4e401b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[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: * e16a9d25a524114b579f05e2872949068588f720 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * fd17477ec2fe5d60ac8ae5c365023ad9352d6855 Azure:

[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: * 1845471184d68e8edd89fd19a591030290695cf3 Azure:

[jira] [Created] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

Corey Shaw created FLINK-25916: -- Summary: Using upsert-kafka with a flush buffer results in Null Pointer Exception Key: FLINK-25916 URL: https://issues.apache.org/jira/browse/FLINK-25916 Project: Flink

[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-1027285397 > Hi Fabian @fapaul ~ Very thanks for the update! As a whole I'm also agree with that we could move some issues to separate PRs to unblock the following tasks, especially those

[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: * b9f6be0cce9e650cc6593ebcdd0fc300df32a2dd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18598: [FLINK-25041][BP 1.13][e2e] Improve error handling for missing environment variables in E2E tests

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

[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: * b9f6be0cce9e650cc6593ebcdd0fc300df32a2dd Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * 79fab9dc03652671ebc8fded5a35a63ea317a6c0 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18599: [FLINK-25041][BP 1.14][e2e] Improve error handling for missing environment variables in E2E tests

flinkbot edited a comment on pull request #18599: URL: https://github.com/apache/flink/pull/18599#issuecomment-1027048501 ## CI report: * 471768076cd0bd84746e06cf24f07c721ad60254 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * 3de39d65f624fb6cf075e9e5ddfe005c197ee3dc Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * 3de39d65f624fb6cf075e9e5ddfe005c197ee3dc Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * c61bb6784f84b31703df0b809297208484433922 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 9789386d73504b5b4e803555cdbca18ecb17b977 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 9789386d73504b5b4e803555cdbca18ecb17b977 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * f0eff1a5012b3560d22c1d0d74bdf4fd7ee60ad1 Azure:

[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: * b9f6be0cce9e650cc6593ebcdd0fc300df32a2dd Azure:

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

gaoyunhaii commented on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1027188780 Hi Fabian @fapaul ~ Very thanks for the update! As a whole I'm also agree with that we could move some issues to separate PRs to unblock the following tasks, especially

[GitHub] [flink-statefun] MartijnVisser opened a new pull request #296: [FLINK-25915][BP 2.0][Docs] Implement Matomo on Statefun website

MartijnVisser opened a new pull request #296: URL: https://github.com/apache/flink-statefun/pull/296 Initial backport of #290, using the unchanged backport of #294 -- 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-statefun] MartijnVisser opened a new pull request #295: [FLINK-25915][BP 2.1][Docs] Implement Matomo on Statefun website

MartijnVisser opened a new pull request #295: URL: https://github.com/apache/flink-statefun/pull/295 Initial backport of https://github.com/apache/flink-statefun/pull/290, using the unchanged backport of https://github.com/apache/flink-statefun/pull/294 -- This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0c8c26e1f9b39c058f39ae6d0caa23f04518e835 Azure:

[GitHub] [flink-statefun] MartijnVisser opened a new pull request #294: [FLINK-25915][BP 2.2][Docs] Implement Matomo on Statefun website

MartijnVisser opened a new pull request #294: URL: https://github.com/apache/flink-statefun/pull/294 Backport of https://github.com/apache/flink-statefun/pull/290 - Had to re-implement the changes due to this version and the ones before that were using Jekyll instead of Hugo -- This is

[GitHub] [flink-statefun] MartijnVisser opened a new pull request #293: [FLINK-25915][BP 3.0][Docs] Implement Matomo on Statefun website

MartijnVisser opened a new pull request #293: URL: https://github.com/apache/flink-statefun/pull/293 Untouched backport of #290 -- 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-statefun] MartijnVisser opened a new pull request #292: [FLINK-25915][BP 3.1][Docs] Implement Matomo on Statefun website

MartijnVisser opened a new pull request #292: URL: https://github.com/apache/flink-statefun/pull/292 Untouched backport of #290 -- 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-statefun] MartijnVisser opened a new pull request #291: [FLINK-25915][BP 3.2][Docs] Implement Matomo on Statefun website

MartijnVisser opened a new pull request #291: URL: https://github.com/apache/flink-statefun/pull/291 Untouched backport of https://github.com/apache/flink-statefun/pull/290 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-statefun] MartijnVisser opened a new pull request #290: [FLINK-25915][Docs] Implement Matomo on Statefun website

MartijnVisser opened a new pull request #290: URL: https://github.com/apache/flink-statefun/pull/290 Like https://github.com/apache/flink/pull/18577, this PR removes the current Google Analytics web analytics tracking from the Flink documentation and replaces it with the ASF hosted Matomo

[jira] [Updated] (FLINK-25915) Implement Matomo on Statefun website

[ https://issues.apache.org/jira/browse/FLINK-25915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25915: --- Labels: pull-request-available (was: ) > Implement Matomo on Statefun website >

[jira] [Assigned] (FLINK-25915) Implement Matomo on Statefun website

[ https://issues.apache.org/jira/browse/FLINK-25915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25915: -- Assignee: Martijn Visser > Implement Matomo on Statefun website >

[jira] [Created] (FLINK-25915) Implement Matomo on Statefun website

Martijn Visser created FLINK-25915: -- Summary: Implement Matomo on Statefun website Key: FLINK-25915 URL: https://issues.apache.org/jira/browse/FLINK-25915 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18586: [FLINK-25880][BP 1.11][Docs] Implement Matomo in Flink documentation

flinkbot edited a comment on pull request #18586: URL: https://github.com/apache/flink/pull/18586#issuecomment-1027030306 ## CI report: * bd100ee0b122a071f8ff8f95f15d5bd567a467e8 Azure:

[jira] [Commented] (FLINK-25117) NoSuchMethodError getCatalog()

[ https://issues.apache.org/jira/browse/FLINK-25117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17485407#comment-17485407 ] Elkhan Dadashov commented on FLINK-25117: - [~zzt] I faced the same issue. It happens in Flink

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

gaoyunhaii commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r796878192 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java ## @@ -20,249

[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: * e31965ace729bae675a07d6cdb3582dcfd5b9ffe Azure:

[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: * e31965ace729bae675a07d6cdb3582dcfd5b9ffe Azure:

[jira] [Updated] (FLINK-24208) Allow idempotent savepoint triggering

[ https://issues.apache.org/jira/browse/FLINK-24208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24208: -- Fix Version/s: 1.15.0 > Allow idempotent savepoint triggering >

[jira] [Updated] (FLINK-24208) Allow idempotent savepoint triggering

[ https://issues.apache.org/jira/browse/FLINK-24208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24208: -- Affects Version/s: 1.15.0 > Allow idempotent savepoint triggering >

[GitHub] [flink] flinkbot edited a comment on pull request #18583: [FLINK-25880][BP 1.14][Docs] Implement Matomo in Flink documentation

flinkbot edited a comment on pull request #18583: URL: https://github.com/apache/flink/pull/18583#issuecomment-1026959776 ## CI report: * c4654bd3219666d16e7a0d154364f1bcd60f9649 Azure:

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

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

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

gaoyunhaii commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r796849334 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/committables/CommittableManager.java ## @@ -0,0

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

gaoyunhaii commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r796849334 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/committables/CommittableManager.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #18585: [FLINK-25880][BP 1.12][Docs] Implement Matomo in Flink documentation

flinkbot edited a comment on pull request #18585: URL: https://github.com/apache/flink/pull/18585#issuecomment-1026976242 ## CI report: * 52df9304ba0449deb2905de23a58db27f8f64294 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18584: [FLINK-25880][BP 1.13][Docs] Implement Matomo in Flink documentation

flinkbot edited a comment on pull request #18584: URL: https://github.com/apache/flink/pull/18584#issuecomment-1026965011 ## CI report: * 19653facb3b5775d777abcecd8475c20f6851e93 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18582: [FLINK-24780][table-planner] Port time/date/timestamp casts to new structure

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

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 9789386d73504b5b4e803555cdbca18ecb17b977 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-25154. -- Release Note: When restoring from a savepoint or retained externalized checkpoint you

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

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reopened FLINK-25154: -- > FLIP-193: Snapshots ownership > - > > Key:

[GitHub] [flink] dawidwys commented on a change in pull request #18575: [FLINK-25827][task] Fix potential memory leak in SourceOperator when using CompletableFuture.anyOf

dawidwys commented on a change in pull request #18575: URL: https://github.com/apache/flink/pull/18575#discussion_r796836332 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/MultipleFuturesAvailabilityHelper.java ## @@ -0,0 +1,77 @@ +/* +

[GitHub] [flink] RyanSkraba commented on a change in pull request #18304: [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp

RyanSkraba commented on a change in pull request #18304: URL: https://github.com/apache/flink/pull/18304#discussion_r796767156 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetFileFormatFactory.java ## @@ -62,6 +62,21 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18575: [FLINK-25827][task] Fix potential memory leak in SourceOperator when using CompletableFuture.anyOf

flinkbot edited a comment on pull request #18575: URL: https://github.com/apache/flink/pull/18575#issuecomment-1025993745 ## CI report: * 7829141285dc11e44799080155ab037f18d76b7b Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 9789386d73504b5b4e803555cdbca18ecb17b977 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 4147879cfa225f6c84eaee64e64c5149408e7bec Azure:

[GitHub] [flink-statefun-playground] igalshilman commented on a change in pull request #19: [FLINK-25899] Add connected components example

igalshilman commented on a change in pull request #19: URL: https://github.com/apache/flink-statefun-playground/pull/19#discussion_r796789576 ## File path: java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/JavaType.java

[GitHub] [flink] flinkbot edited a comment on pull request #18581: [FLINK-25879][Docs] Track used search terms in Matomo

flinkbot edited a comment on pull request #18581: URL: https://github.com/apache/flink/pull/18581#issuecomment-1026744697 ## CI report: * d4d24abb6b43e6771a9d7f152cb853c2033a0512 Azure:

[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: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 4147879cfa225f6c84eaee64e64c5149408e7bec Azure:

  1   2   3   4   5   >