[jira] [Commented] (FLINK-25950) Delete retry mechanism from ZooKeeperUtils.deleteZNode

[ https://issues.apache.org/jira/browse/FLINK-25950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486511#comment-17486511 ] Matthias Pohl commented on FLINK-25950: --- I linked FLINK-25018 where we updated curator to 5.2.0 >

[jira] [Created] (FLINK-25950) Delete retry mechanism from ZooKeeperUtils.deleteZNode

Matthias Pohl created FLINK-25950: - Summary: Delete retry mechanism from ZooKeeperUtils.deleteZNode Key: FLINK-25950 URL: https://issues.apache.org/jira/browse/FLINK-25950 Project: Flink

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

flinkbot edited a comment on pull request #18620: URL: https://github.com/apache/flink/pull/18620#issuecomment-1029017598 ## CI report: * 048f5b514a1e5f9526a8c6d8db661f1bbbe2f722 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18545: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

flinkbot edited a comment on pull request #18545: URL: https://github.com/apache/flink/pull/18545#issuecomment-1023486118 ## CI report: * 2742f93c4bf89dfdb27ac0b965df8bf72d23e8d3 Azure:

[GitHub] [flink] flinkbot commented on pull request #18620: [FLINK-25879][BP 1.13][Docs] Track used search terms in Matomo

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

[GitHub] [flink] flinkbot commented on pull request #18619: [FLINK-25879][BP 1.14][Docs] Track used search terms in Matomo

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

[GitHub] [flink] flinkbot edited a comment on pull request #18614: [hotfix][table-planner] Remove org.reflections from NOTICE

flinkbot edited a comment on pull request #18614: URL: https://github.com/apache/flink/pull/18614#issuecomment-1028836450 ## CI report: * 42d0a1016429586d9b4db7a599c057d164144906 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18545: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

flinkbot edited a comment on pull request #18545: URL: https://github.com/apache/flink/pull/18545#issuecomment-1023486118 ## CI report: * 2742f93c4bf89dfdb27ac0b965df8bf72d23e8d3 Azure:

[GitHub] [flink] flinkbot commented on pull request #18619: [FLINK-25879][BP 1.14][Docs] Track used search terms in Matomo

flinkbot commented on pull request #18619: URL: https://github.com/apache/flink/pull/18619#issuecomment-1029016359 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 commented on pull request #18620: [FLINK-25879][BP 1.13][Docs] Track used search terms in Matomo

flinkbot commented on pull request #18620: URL: https://github.com/apache/flink/pull/18620#issuecomment-1029016331 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] MartijnVisser opened a new pull request #18620: [FLINK-25879][BP 1.13][Docs] Track used search terms in Matomo

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

[GitHub] [flink] MartijnVisser opened a new pull request #18619: [FLINK-25879][BP 1.14][Docs] Track used search terms in Matomo

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

[GitHub] [flink] flinkbot edited a comment on pull request #18618: [hotfix][table-planner] Fix Jackson annotations

flinkbot edited a comment on pull request #18618: URL: https://github.com/apache/flink/pull/18618#issuecomment-1029006133 ## CI report: * aef708611c8f2a48eed1f011ddf666cca4597e74 Azure:

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18353: [FLINK-25129][docs]project configuation changes in docs

slinkydeveloper commented on a change in pull request #18353: URL: https://github.com/apache/flink/pull/18353#discussion_r798580117 ## File path: docs/content/docs/dev/configuration/maven.md ## @@ -0,0 +1,175 @@ +--- +title: "Using Maven" +weight: 2 +type: docs +--- + + +# How

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

[GitHub] [flink] flinkbot commented on pull request #18618: [hotfix][table-planner] Fix Jackson annotations

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

[jira] [Resolved] (FLINK-25879) Track used search terms in Matomo

[ https://issues.apache.org/jira/browse/FLINK-25879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk resolved FLINK-25879. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed on master commit

[GitHub] [flink] flinkbot commented on pull request #18618: [hotfix][table-planner] Fix Jackson annotations

flinkbot commented on pull request #18618: URL: https://github.com/apache/flink/pull/18618#issuecomment-1029005627 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 #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: * 9c7419bc5c568b597078f497da41d1039c994bf3 Azure:

[GitHub] [flink] Airblader merged pull request #18581: [FLINK-25879][Docs] Track used search terms in Matomo

Airblader merged pull request #18581: URL: https://github.com/apache/flink/pull/18581 -- 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 #18539: [FLINK-25745] Support RocksDB incremental native savepoints

flinkbot edited a comment on pull request #18539: URL: https://github.com/apache/flink/pull/18539#issuecomment-1023172522 ## CI report: * ed5d5d894e019177d00af8193653c69c21ccc725 Azure:

[GitHub] [flink] matriv opened a new pull request #18618: [hotfix][table-planner] Fix Jackson annotations

matriv opened a new pull request #18618: URL: https://github.com/apache/flink/pull/18618 Following: #18574 Make use of `JsonIgnoreProperties` where ever possible and protect from future fields to be added by mistake to the json plans. Move the `JsonInclude` next to the

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 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: * 13661dd7bffb42e347031615fd1eb9036771b901 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 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: * 13661dd7bffb42e347031615fd1eb9036771b901 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18606: [FLINK-25924][connectors/firehose] Adding a timeout for the Localstac…

flinkbot edited a comment on pull request #18606: URL: https://github.com/apache/flink/pull/18606#issuecomment-1027976880 ## CI report: * 19a163b2c9d281336f36fccf0a8ba51e13ef46d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 Azure:

[GitHub] [flink] XComp commented on a change in pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

XComp commented on a change in pull request #18536: URL: https://github.com/apache/flink/pull/18536#discussion_r798556847 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java ## @@ -873,69 +878,96 @@ public boolean deletePermanent(JobID

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18540: [hotfix][table-planner][table-api-java][docs] Move topn cache config option

flinkbot edited a comment on pull request #18540: URL: https://github.com/apache/flink/pull/18540#issuecomment-1023208881 ## CI report: * 75f4a34a011be059d5af2412764bdd5d7b49253e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 Azure:

[GitHub] [flink] XComp commented on a change in pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

XComp commented on a change in pull request #18536: URL: https://github.com/apache/flink/pull/18536#discussion_r798552405 ## File path: flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/concurrent/RunningInMainThreadAssert.java ## @@ -0,0 +1,30 @@ +/* + *

[GitHub] [flink] fapaul commented on a change in pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

fapaul commented on a change in pull request #18616: URL: https://github.com/apache/flink/pull/18616#discussion_r798550619 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializer.java ## @@ -163,25 +164,42 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18614: [hotfix][table-planner] Remove org.reflections from NOTICE

flinkbot edited a comment on pull request #18614: URL: https://github.com/apache/flink/pull/18614#issuecomment-1028836450 ## CI report: * 36afd145b2ccde21a860fb8ad9b11ca16ad371de Azure:

[jira] [Updated] (FLINK-21752) NullPointerException on restore in PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-21752: - Fix Version/s: 1.15.0 1.14.4 1.13.7 >

[GitHub] [flink] dmvk commented on a change in pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

dmvk commented on a change in pull request #18536: URL: https://github.com/apache/flink/pull/18536#discussion_r798548080 ## File path: flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/concurrent/RunningInMainThreadAssert.java ## @@ -0,0 +1,30 @@ +/* + *

[GitHub] [flink] dawidwys commented on a change in pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

dawidwys commented on a change in pull request #18616: URL: https://github.com/apache/flink/pull/18616#discussion_r798546630 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializer.java ## @@ -163,25 +164,42 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 Azure:

[jira] [Updated] (FLINK-25885) ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicationCompletes failed on azure

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

[jira] [Closed] (FLINK-25885) ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicationCompletes failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25885. - Fix Version/s: 1.15.0 Resolution: Fixed Fixed via

[GitHub] [flink] tillrohrmann closed pull request #18567: [FLINK-25885] Suppress error reporting for ResourceManagerServiceImpl.deregisterApplication

tillrohrmann closed pull request #18567: URL: https://github.com/apache/flink/pull/18567 -- 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] dawidwys commented on a change in pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

dawidwys commented on a change in pull request #18616: URL: https://github.com/apache/flink/pull/18616#discussion_r798545141 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializer.java ## @@ -163,25 +164,42 @@ public boolean

[GitHub] [flink] tillrohrmann commented on pull request #18567: [FLINK-25893] Suppress error reporting for ResourceManagerServiceImpl.deregisterApplication

tillrohrmann commented on pull request #18567: URL: https://github.com/apache/flink/pull/18567#issuecomment-1028969201 Thanks for the review @zentol. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Comment Edited] (FLINK-21752) NullPointerException on restore in PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486454#comment-17486454 ] Till Rohrmann edited comment on FLINK-21752 at 2/3/22, 1:03 PM: Yes, I

[jira] [Commented] (FLINK-21752) NullPointerException on restore in PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486454#comment-17486454 ] Till Rohrmann commented on FLINK-21752: --- Yes, I agree. This is quite bad given that we provide

[GitHub] [flink] flinkbot edited a comment on pull request #18617: [FLINK-25949][connector/firehose] Fixing wrong Http protocol default value for kinesisfirehoseSinkBuilder

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

[GitHub] [flink] flinkbot commented on pull request #18617: [FLINK-25949][connector/firehose] Fixing wrong Http protocol default value for kinesisfirehoseSinkBuilder

flinkbot commented on pull request #18617: URL: https://github.com/apache/flink/pull/18617#issuecomment-1028964878 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] afedulov edited a comment on pull request #18545: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

afedulov edited a comment on pull request #18545: URL: https://github.com/apache/flink/pull/18545#issuecomment-1028964410 @zentol this branch passed CI successfully yesterday [(link)](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30637=results), I am currently

[GitHub] [flink] afedulov commented on pull request #18545: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

afedulov commented on pull request #18545: URL: https://github.com/apache/flink/pull/18545#issuecomment-1028964410 @zentol this branch passed CI successfully yesterday [(link)](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30637=results), I am currently checking

[GitHub] [flink] flinkbot commented on pull request #18617: [FLINK-25949][connector/firehose] Fixing wrong Http protocol default value for kinesisfirehoseSinkBuilder

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

[jira] [Updated] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

[ https://issues.apache.org/jira/browse/FLINK-25949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25949: --- Labels: pull-request-available (was: ) > [FLIP-171] Kinesis Firehose sink builder falls

[GitHub] [flink] fapaul commented on a change in pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

fapaul commented on a change in pull request #18616: URL: https://github.com/apache/flink/pull/18616#discussion_r798531176 ## File path: flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java ## @@ -421,7 +421,7 @@ public void

[GitHub] [flink] vahmed-hamdy opened a new pull request #18617: [FLINK-25949][connector/firehose] Fixing wrong Http protocol default value for kinesisfirehoseSinkBuilder

vahmed-hamdy opened a new pull request #18617: URL: https://github.com/apache/flink/pull/18617 ## What is the purpose of the change KinesiFirehoseSinkBuilder inserts wrong http protocol format. ## Brief change log - change default protocol inserted

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

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486438#comment-17486438 ] Francesco Guardiani commented on FLINK-25916: - Everything seems correct to me. [~heaje] are

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

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486438#comment-17486438 ] Francesco Guardiani edited comment on FLINK-25916 at 2/3/22, 12:50 PM:

[GitHub] [flink] XComp commented on a change in pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

XComp commented on a change in pull request #18536: URL: https://github.com/apache/flink/pull/18536#discussion_r798527257 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultJobGraphStore.java ## @@ -252,9 +255,11 @@ public void

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

flinkbot edited a comment on pull request #18539: URL: https://github.com/apache/flink/pull/18539#issuecomment-1023172522 ## CI report: * 08906ab9a71f021c125f27122419a89a07be8ee3 Azure:

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

flinkbot edited a comment on pull request #18539: URL: https://github.com/apache/flink/pull/18539#issuecomment-1023172522 ## CI report: * 08906ab9a71f021c125f27122419a89a07be8ee3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18439: [hotfix][table-planner][test] Test fromValues() watermark propagation

flinkbot edited a comment on pull request #18439: URL: https://github.com/apache/flink/pull/18439#issuecomment-1018359750 ## CI report: * ef3a4f559335916ebd9b98903f717651cfc48c41 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: * 78c5075dd300c8e74705afbb13b10377da61865a Azure:

[GitHub] [flink] XComp commented on a change in pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

XComp commented on a change in pull request #18536: URL: https://github.com/apache/flink/pull/18536#discussion_r798520259 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleaner.java ## @@ -32,29 +34,37 @@ public class

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18615: [FLINK-25578][core] Graduate and deprecate unified Sink API V1

flinkbot edited a comment on pull request #18615: URL: https://github.com/apache/flink/pull/18615#issuecomment-1028921414 ## CI report: * 820f4dd3c957a659514148690c942c551ec5946a Azure:

[GitHub] [flink] flinkbot commented on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot commented on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028945622 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 commented on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

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

[jira] [Updated] (FLINK-21752) NullPointerException on restore in PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21752: --- Labels: pull-request-available (was: ) > NullPointerException on restore in PojoSerializer

[GitHub] [flink] dawidwys opened a new pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

dawidwys opened a new pull request #18616: URL: https://github.com/apache/flink/pull/18616 ## What is the purpose of the change In order to support Pojo schema migration, we added a new ctor to the PojoSerializer, which uses data extracted from a snapshot. However the duplicate

[GitHub] [flink] flinkbot edited a comment on pull request #18606: [FLINK-25924][connectors/firehose] Adding a timeout for the Localstac…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18545: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

flinkbot edited a comment on pull request #18545: URL: https://github.com/apache/flink/pull/18545#issuecomment-1023486118 ## CI report: * 2742f93c4bf89dfdb27ac0b965df8bf72d23e8d3 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486428#comment-17486428 ] Fabian Paul commented on FLINK-25916: - [~heaje] I think your problems lays somewhere different. We

[GitHub] [flink] flinkbot edited a comment on pull request #18606: [FLINK-25924][connectors/firehose] Adding a timeout for the Localstac…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18545: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

flinkbot edited a comment on pull request #18545: URL: https://github.com/apache/flink/pull/18545#issuecomment-1023486118 ## CI report: * 2742f93c4bf89dfdb27ac0b965df8bf72d23e8d3 Azure:

[jira] [Created] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

Ahmed Hamdy created FLINK-25949: --- Summary: [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol. Key: FLINK-25949 URL: https://issues.apache.org/jira/browse/FLINK-25949 Project:

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

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25916: Affects Version/s: 1.15.0 > Using upsert-kafka with a flush buffer results in Null Pointer

[jira] [Resolved] (FLINK-25942) Use jackson jdk8/time modules for Duration ser/de

[ https://issues.apache.org/jira/browse/FLINK-25942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-25942. - Fix Version/s: 1.15.0 Resolution: Fixed > Use jackson jdk8/time modules for Duration

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

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25916: Priority: Critical (was: Major) > Using upsert-kafka with a flush buffer results in Null Pointer

[jira] [Updated] (FLINK-25942) Use jackson jdk8/time modules for Duration ser/de

[ https://issues.apache.org/jira/browse/FLINK-25942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25942: Affects Version/s: 1.15.0 > Use jackson jdk8/time modules for Duration ser/de >

[jira] [Updated] (FLINK-25942) Use jackson jdk8/time modules for Duration ser/de

[ https://issues.apache.org/jira/browse/FLINK-25942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25942: Component/s: Table SQL / Planner > Use jackson jdk8/time modules for Duration ser/de >

[jira] [Commented] (FLINK-25942) Use jackson jdk8/time modules for Duration ser/de

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

[GitHub] [flink] fapaul merged pull request #18574: [FLINK-25942][table-planner] Use jdk 8 and java time modules for duration and optional ser/de

fapaul merged pull request #18574: URL: https://github.com/apache/flink/pull/18574 -- 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] fapaul commented on pull request #18574: [FLINK-25942][table-planner] Use jdk 8 and java time modules for duration and optional ser/de

fapaul commented on pull request #18574: URL: https://github.com/apache/flink/pull/18574#issuecomment-1028933687 @slinkydeveloper thanks for the clarification. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] fapaul commented on pull request #18545: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

fapaul commented on pull request #18545: URL: https://github.com/apache/flink/pull/18545#issuecomment-1028932831 @zentol can you also have a look at this. The idea behind the PR is rather simple but I would like to get a second opinion not that we miss something simple. -- This is an

[GitHub] [flink] matriv commented on a change in pull request #18353: [FLINK-25129][docs]project configuation changes in docs

matriv commented on a change in pull request #18353: URL: https://github.com/apache/flink/pull/18353#discussion_r798503652 ## File path: docs/content/docs/dev/configuration/overview.md ## @@ -0,0 +1,219 @@ +--- +title: "Overview" +weight: 1 +type: docs +aliases: +-

[GitHub] [flink] zentol commented on a change in pull request #18353: [FLINK-25129][docs]project configuation changes in docs

zentol commented on a change in pull request #18353: URL: https://github.com/apache/flink/pull/18353#discussion_r798502467 ## File path: docs/content/docs/dev/configuration/overview.md ## @@ -0,0 +1,219 @@ +--- +title: "Overview" +weight: 1 +type: docs +aliases: +-

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

flinkbot edited a comment on pull request #18572: URL: https://github.com/apache/flink/pull/18572#issuecomment-1025854469 ## CI report: * c1357301d91600e02d3b62dcd6c0aeb1ae961ba9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18615: [FLINK-25578][core] Graduate and deprecate unified Sink API V1

flinkbot edited a comment on pull request #18615: URL: https://github.com/apache/flink/pull/18615#issuecomment-1028921414 ## CI report: * 820f4dd3c957a659514148690c942c551ec5946a Azure:

[GitHub] [flink] flinkbot commented on pull request #18615: [FLINK-25578][core] Graduate and deprecate unified Sink API V1

flinkbot commented on pull request #18615: URL: https://github.com/apache/flink/pull/18615#issuecomment-1028922332 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 commented on pull request #18615: [FLINK-25578][core] Graduate and deprecate unified Sink API V1

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

[jira] [Updated] (FLINK-25948) KDS / KDF Sink should call .close() to clean up resources

[ https://issues.apache.org/jira/browse/FLINK-25948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-25948: --- Description: Add .close() BOTH the KDSAsyncClient and the underlying HTTPClient for BOTH KDS & KDF

[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 ] ASF GitHub Bot updated FLINK-25578: --- Labels: pull-request-available (was: ) > Graduate Sink V1 interfaces to PublicEvolving and

[jira] [Created] (FLINK-25948) KDS / KDF Sink should call .close() to clean up resources

Zichen Liu created FLINK-25948: -- Summary: KDS / KDF Sink should call .close() to clean up resources Key: FLINK-25948 URL: https://issues.apache.org/jira/browse/FLINK-25948 Project: Flink Issue

[GitHub] [flink] fapaul opened a new pull request #18615: [FLINK-25578][core] Graduate and deprecate unified Sink API V1

fapaul opened a new pull request #18615: URL: https://github.com/apache/flink/pull/18615 ## What is the purpose of the change This PR graduates the unified Sink API V1 and deprecates it. We have already introduced the successor with

[jira] [Assigned] (FLINK-21752) NullPointerException on restore in PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-21752: Assignee: Dawid Wysakowicz > NullPointerException on restore in PojoSerializer >

[GitHub] [flink] dmvk commented on a change in pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

dmvk commented on a change in pull request #18536: URL: https://github.com/apache/flink/pull/18536#discussion_r798483128 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java ## @@ -873,69 +878,96 @@ public boolean deletePermanent(JobID

[GitHub] [flink] dmvk commented on a change in pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

dmvk commented on a change in pull request #18536: URL: https://github.com/apache/flink/pull/18536#discussion_r798479815 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultJobGraphStore.java ## @@ -252,9 +255,11 @@ public void

[GitHub] [flink] matriv commented on a change in pull request #18353: [FLINK-25129][docs]project configuation changes in docs

matriv commented on a change in pull request #18353: URL: https://github.com/apache/flink/pull/18353#discussion_r798478483 ## File path: docs/content/docs/dev/configuration/overview.md ## @@ -0,0 +1,219 @@ +--- +title: "Overview" +weight: 1 +type: docs +aliases: +-

<    1   2   3   4   5   >