[GitHub] [flink-ml] becketqin commented on pull request #5: [FLINK-1][iteration] Adds the iteration module and API

becketqin commented on pull request #5: URL: https://github.com/apache/flink-ml/pull/5#issuecomment-931958024 @tisonkun I think this is just a placeholder. FLIP-176 has not been voted yet so there is no JIRA ticket opened for the subtasks of it. It should be replaced with the actual ticket

[jira] [Commented] (FLINK-24427) Hide Scala in flink-table-planner from API

[ https://issues.apache.org/jira/browse/FLINK-24427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423130#comment-17423130 ] Martijn Visser commented on FLINK-24427: [~eloisant] That is great! It would be

[GitHub] [flink] flinkbot commented on pull request #17401: [FLINK-24409][connectors] Fix metrics errors with topics names with periods

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

[GitHub] [flink] fapaul commented on pull request #17061: [FLINK-23977][elasticsearch] Added DynamicElasticsearchSink for Dynamic ES Cluster Routing

fapaul commented on pull request #17061: URL: https://github.com/apache/flink/pull/17061#issuecomment-931955519 I like the name `DemultiplexingSink`. I am not sure whether the `DynamicSink` is the correct way to start because it implies that the sink will only be available with the Table A

[jira] [Commented] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423123#comment-17423123 ] Dawid Wysakowicz commented on FLINK-23493: -- https://dev.azure.com/apache-flink/

[GitHub] [flink] flinkbot commented on pull request #17401: [FLINK-24409][connectors] Fix metrics errors with topics names with periods

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

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423122#comment-17423122 ] Dawid Wysakowicz commented on FLINK-18634: -- https://dev.azure.com/apache-flink/

[jira] [Updated] (FLINK-24409) Kafka topics with periods in their names generate a constant stream of errors

[ https://issues.apache.org/jira/browse/FLINK-24409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24409: --- Labels: pull-request-available (was: ) > Kafka topics with periods in their names generate

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423121#comment-17423121 ] Dawid Wysakowicz commented on FLINK-23944: -- https://dev.azure.com/apache-flink/

[GitHub] [flink] jherico opened a new pull request #17401: [FLINK-24409][connectors] Fix metrics errors with topics names with periods

jherico opened a new pull request #17401: URL: https://github.com/apache/flink/pull/17401 ## What is the purpose of the change * Fix the errors generated by the metrics code when reading from a Kafka topic that includes periods in the names. The filter for the metric tries to compar

[jira] [Commented] (FLINK-23431) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails with "The topic metadata failed to propagate to Kafka broker."

[ https://issues.apache.org/jira/browse/FLINK-23431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423120#comment-17423120 ] Dawid Wysakowicz commented on FLINK-23431: -- https://dev.azure.com/apache-flink/

[jira] [Updated] (FLINK-23431) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails with "The topic metadata failed to propagate to Kafka broker."

[ https://issues.apache.org/jira/browse/FLINK-23431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23431: - Affects Version/s: 1.15.0 > KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fai

[jira] [Commented] (FLINK-24390) Python 'build_wheels mac' fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423119#comment-17423119 ] Dawid Wysakowicz commented on FLINK-24390: -- https://dev.azure.com/apache-flink/

[jira] [Created] (FLINK-24434) PyFlink YARN per-job on Docker test fails on Azure

Dawid Wysakowicz created FLINK-24434: Summary: PyFlink YARN per-job on Docker test fails on Azure Key: FLINK-24434 URL: https://issues.apache.org/jira/browse/FLINK-24434 Project: Flink Is

[jira] [Updated] (FLINK-24433) "No space left on device" in Azure e2e tests

[ https://issues.apache.org/jira/browse/FLINK-24433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24433: - Component/s: (was: Build System) Build System / Azure Pipelines > "

[jira] [Created] (FLINK-24433) "No space left on device" in Azure e2e tests

Dawid Wysakowicz created FLINK-24433: Summary: "No space left on device" in Azure e2e tests Key: FLINK-24433 URL: https://issues.apache.org/jira/browse/FLINK-24433 Project: Flink Issue Ty

[jira] [Commented] (FLINK-24427) Hide Scala in flink-table-planner from API

[ https://issues.apache.org/jira/browse/FLINK-24427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423117#comment-17423117 ] Erwan Loisant commented on FLINK-24427: --- Thanks, I'll look how it was done for Akk

[jira] [Commented] (FLINK-24259) Exception message when Kafka topic is null in FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-24259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423108#comment-17423108 ] ZhuoYu Chen commented on FLINK-24259: - Hi [~mans2singh] , I am very interested in th

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423106#comment-17423106 ] ZhuoYu Chen commented on FLINK-24351: - Hi [~liliwei] , I am very interested in this，

[jira] [Commented] (FLINK-24370) [FLIP-171] Documentation for Generic AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423105#comment-17423105 ] ZhuoYu Chen commented on FLINK-24370: - Hi [~CrynetLogistics] , I am very interested

[jira] [Commented] (FLINK-22644) Translate "Native Kubernetes" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-22644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423104#comment-17423104 ] ZhuoYu Chen commented on FLINK-22644: - Hi [~rudeigerc] , I am very interested in thi

[jira] [Commented] (FLINK-22797) Improve incremental checkpoints documentation

[ https://issues.apache.org/jira/browse/FLINK-22797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423102#comment-17423102 ] ZhuoYu Chen commented on FLINK-22797: - Hi [~Nicolaus Weidner] , I am very interested

[jira] [Commented] (FLINK-23427) Translate the page of "Blocking Shuffle" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423101#comment-17423101 ] ZhuoYu Chen commented on FLINK-23427: - Hi [~Aiden Gong] , I am very interested in th

[jira] [Commented] (FLINK-24345) Translate "File Systems" page of "Internals" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423100#comment-17423100 ] ZhuoYu Chen commented on FLINK-24345: - Hi [~Liebing] , I am very interested in this，

[GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

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

[GitHub] [flink] flinkbot edited a comment on pull request #17400: [FLINK-24432][rocksdb] RocksIteratorWrapper.seekToLast() logic typo

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

[GitHub] [flink-ml] tisonkun commented on pull request #5: [FLINK-1][iteration] Adds the iteration module and API

tisonkun commented on pull request #5: URL: https://github.com/apache/flink-ml/pull/5#issuecomment-931855039 @gaoyunhaii how this PR can be "FLINK-1"? -- 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 g

[GitHub] [flink-ml] becketqin commented on a change in pull request #5: [FLINK-1][iteration] Adds the iteration module and API

becketqin commented on a change in pull request #5: URL: https://github.com/apache/flink-ml/pull/5#discussion_r719903195 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/Iterations.java ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [flink-ml] becketqin commented on a change in pull request #5: [FLINK-1][iteration] Adds the iteration module and API

becketqin commented on a change in pull request #5: URL: https://github.com/apache/flink-ml/pull/5#discussion_r719859647 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/Iterations.java ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [flink-ml] becketqin commented on a change in pull request #6: [FLINK-2][iteration] Add broadcast output to broadcast events to all the downstream tasks

becketqin commented on a change in pull request #6: URL: https://github.com/apache/flink-ml/pull/6#discussion_r719874290 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/broadcast/OutputReflectionContext.java ## @@ -0,0 +1,104 @@ +/* + * Licensed to

[jira] [Resolved] (FLINK-24200) CheckpointBarrierTrackerTest.testTwoLastBarriersOneByOne fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei resolved FLINK-24200. -- Resolution: Fixed merged commit  [{{1a9d782}}|https://github.com/apache/flink/commit/1a9d78259668f3d9c

[GitHub] [flink] curcur merged pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value

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

[GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

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

[GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

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

[GitHub] [flink-ml] becketqin commented on a change in pull request #5: [FLINK-1][iteration] Adds the iteration module and API

becketqin commented on a change in pull request #5: URL: https://github.com/apache/flink-ml/pull/5#discussion_r719152625 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/DataStreamList.java ## @@ -0,0 +1,54 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] jherico commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

jherico commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r719847453 ## File path: docs/content/docs/connectors/table/formats/avro-glue.md ## @@ -0,0 +1,191 @@ +--- +title: AWS Glue Avro +weight: 4 +type: docs +aliases: +

[GitHub] [flink] jherico commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

jherico commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r719847389 ## File path: flink-formats/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroFormatFactory.

[GitHub] [flink] jherico commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

jherico commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r719846371 ## File path: docs/data/sql_connectors.yml ## @@ -48,6 +48,12 @@ avro-confluent: category: format sql_url: https://repo.maven.apache.org/maven2

[GitHub] [flink] jherico commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

jherico commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r719845596 ## File path: docs/content/docs/connectors/table/formats/avro-glue.md ## @@ -0,0 +1,191 @@ +--- +title: AWS Glue Avro +weight: 4 +type: docs +aliases: +

[jira] [Comment Edited] (FLINK-24427) Hide Scala in flink-table-planner from API

[ https://issues.apache.org/jira/browse/FLINK-24427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423039#comment-17423039 ] Seth Wiesman edited comment on FLINK-24427 at 9/30/21, 11:01 PM: -

[jira] [Commented] (FLINK-24427) Hide Scala in flink-table-planner from API

[ https://issues.apache.org/jira/browse/FLINK-24427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423039#comment-17423039 ] Seth Wiesman commented on FLINK-24427: -- Hi [~eloisant],    The goal is to hide th

[GitHub] [flink] flinkbot edited a comment on pull request #17400: [FLINK-24432][rocksdb] RocksIteratorWrapper.seekToLast() logic typo

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

[GitHub] [flink] flinkbot commented on pull request #17400: [FLINK-24432][rocksdb] RocksIteratorWrapper.seekToLast() logic typo

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

[GitHub] [flink] flinkbot commented on pull request #17400: [FLINK-24432][rocksdb] RocksIteratorWrapper.seekToLast() logic typo

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

[jira] [Updated] (FLINK-24432) RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method

[ https://issues.apache.org/jira/browse/FLINK-24432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24432: --- Labels: pull-request-available (was: ) > RocksIteratorWrapper.seekToLast() calls the wrong

[GitHub] [flink] victorunique opened a new pull request #17400: [FLINK-24432][rocksdb] RocksIteratorWrapper.seekToLast() logic typo

victorunique opened a new pull request #17400: URL: https://github.com/apache/flink/pull/17400 ## What is the purpose of the change The RocksIteratorWrapper is a wrapper of RocksIterator to do additional status check for all the methods. However, there's a typo that RocksIteratorWra

[jira] [Created] (FLINK-24432) RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method

Victor Xu created FLINK-24432: - Summary: RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method Key: FLINK-24432 URL: https://issues.apache.org/jira/browse/FLINK-24432 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17139: [BP-1.13][FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

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

[GitHub] [flink] flinkbot edited a comment on pull request #17138: [BP-1.14][FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

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

[GitHub] [flink] flinkbot edited a comment on pull request #17137: [FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

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

[GitHub] [flink] flinkbot edited a comment on pull request #17399: [BP-1.14][FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest

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

[GitHub] [flink] flinkbot edited a comment on pull request #17398: [FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest

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

[GitHub] [flink] flinkbot edited a comment on pull request #17397: [BP-1.14][FLINK-24117][HA]Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver

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

[GitHub] [flink] flinkbot edited a comment on pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers

flinkbot edited a comment on pull request #17381: URL: https://github.com/apache/flink/pull/17381#issuecomment-930061717 ## CI report: * a986056b7d9cb08a4807e588865cacf3376259ee UNKNOWN * a9124ed79554c32c3f8c5c785b3369bf1a49cfe6 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17150: [FLINK-24117][HA]Remove unHandledErrorListener in ZooKeeperLeaderElec…

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

[jira] [Comment Edited] (FLINK-24427) Hide Scala in flink-table-planner from API

[ https://issues.apache.org/jira/browse/FLINK-24427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17422979#comment-17422979 ] Erwan Loisant edited comment on FLINK-24427 at 9/30/21, 7:08 PM: -

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17422981#comment-17422981 ] Nick Burkard commented on FLINK-13414: -- Looks like the two tickets are now assigned

[jira] [Commented] (FLINK-24427) Hide Scala in flink-table-planner from API

[ https://issues.apache.org/jira/browse/FLINK-24427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17422979#comment-17422979 ] Erwan Loisant commented on FLINK-24427: --- I'm not sure what's the proposed solution

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17422974#comment-17422974 ] Erwan Loisant commented on FLINK-13414: --- Hi [~MartijnVisser] , I'll give a try to

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

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

[GitHub] [flink] flinkbot edited a comment on pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate

flinkbot edited a comment on pull request #17369: URL: https://github.com/apache/flink/pull/17369#issuecomment-929030154 ## CI report: * ae309e02fd4e8221ce56b848934ab700b6a9c304 UNKNOWN * 54c6684aff5bce94116153d15145e6fd43c754bb Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17422943#comment-17422943 ] Martijn Visser commented on FLINK-13414: With the help of [~NickBurkard] we mana

[GitHub] [flink] flinkbot edited a comment on pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate

flinkbot edited a comment on pull request #17369: URL: https://github.com/apache/flink/pull/17369#issuecomment-929030154 ## CI report: * ae309e02fd4e8221ce56b848934ab700b6a9c304 UNKNOWN * 25cdb2478665779912631293636547e4b73b Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

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

[GitHub] [flink] flinkbot edited a comment on pull request #17138: [BP-1.14][FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

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

[GitHub] [flink] flinkbot edited a comment on pull request #17139: [BP-1.13][FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

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

[GitHub] [flink] flinkbot edited a comment on pull request #17137: [FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

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

[GitHub] [flink] flinkbot edited a comment on pull request #17398: [FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest

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

[GitHub] [flink] flinkbot edited a comment on pull request #17399: [BP-1.14][FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest

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

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

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

[GitHub] [flink] flinkbot edited a comment on pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate

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

[GitHub] [flink] flinkbot edited a comment on pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers

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

[GitHub] [flink] flinkbot edited a comment on pull request #17139: [BP-1.13][FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

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

[GitHub] [flink] flinkbot edited a comment on pull request #17138: [BP-1.14][FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

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

[GitHub] [flink] flinkbot edited a comment on pull request #17137: [FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

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

[jira] [Resolved] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions

[ https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24148. -- Resolution: Fixed merged in release-1.14: 7882d5e5e7d6c6bd0c12f659b4c92829703a2b29 > Add bloom filter

[jira] [Updated] (FLINK-24279) Support withBroadcast with DataStream API in Flink ML Library

[ https://issues.apache.org/jira/browse/FLINK-24279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24279: --- Labels: pull-request-available (was: ) > Support withBroadcast with DataStream API in Flin

[GitHub] [flink-ml] zhipeng93 opened a new pull request #15: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

zhipeng93 opened a new pull request #15: URL: https://github.com/apache/flink-ml/pull/15 This PR supports withBroadcast() function in DataStream by caching the broadcastInputs in static variables. Note that this PR is based on [[FLINK-5][iteration]](https://github.com/apache/flink-m

[jira] [Resolved] (FLINK-23519) Aggregate State Backend Latency by State Level

[ https://issues.apache.org/jira/browse/FLINK-23519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23519. -- Resolution: Fixed Merged in release-1.14: b5fab64432c9839f956c9c169f617edf1026669f > Aggregate State

[GitHub] [flink] flinkbot commented on pull request #17399: [BP-1.14][FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest

flinkbot commented on pull request #17399: URL: https://github.com/apache/flink/pull/17399#issuecomment-931472290 ## CI report: * 238bb66a8a84f1545c971b0a9eb87b65fec835bc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #17398: [FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest

flinkbot commented on pull request #17398: URL: https://github.com/apache/flink/pull/17398#issuecomment-931472187 ## CI report: * 665b7b1db2c9d0c83329fe3d0ce66e0178c3becc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

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

[GitHub] [flink] flinkbot edited a comment on pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers

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

[GitHub] [flink] flinkbot edited a comment on pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests

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

[GitHub] [flink] flinkbot edited a comment on pull request #17397: [BP-1.14][FLINK-24117][HA]Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver

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

[GitHub] [flink] flinkbot edited a comment on pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate

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

[GitHub] [flink] flinkbot edited a comment on pull request #17150: [FLINK-24117][HA]Remove unHandledErrorListener in ZooKeeperLeaderElec…

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

[GitHub] [flink] AHeise commented on pull request #17061: [FLINK-23977][elasticsearch] Added DynamicElasticsearchSink for Dynamic ES Cluster Routing

AHeise commented on pull request #17061: URL: https://github.com/apache/flink/pull/17061#issuecomment-931463319 It's very similar to [HybridSource](https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/H

[jira] [Assigned] (FLINK-24431) [Kinesis][EFO] EAGER registration strategy does not work when job fails over

[ https://issues.apache.org/jira/browse/FLINK-24431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-24431: - Assignee: Rudi Kershaw > [Kinesis][EFO] EAGER registration strategy does not work when

[jira] [Updated] (FLINK-24431) [Kinesis][EFO] EAGER registration strategy does not work when job fails over

[ https://issues.apache.org/jira/browse/FLINK-24431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-24431: -- Description: *Background* The EFO Kinesis connector will register and de-register stream consu

[jira] [Created] (FLINK-24431) [Kinesis][EFO] EAGER registration strategy does not work when job fails over

Danny Cranmer created FLINK-24431: - Summary: [Kinesis][EFO] EAGER registration strategy does not work when job fails over Key: FLINK-24431 URL: https://issues.apache.org/jira/browse/FLINK-24431 Projec

[GitHub] [flink] rionmonster commented on pull request #17061: [FLINK-23977][elasticsearch] Added DynamicElasticsearchSink for Dynamic ES Cluster Routing

rionmonster commented on pull request #17061: URL: https://github.com/apache/flink/pull/17061#issuecomment-931445551 @AHeise Yeah, I think I much prefer that. I can adjust the JIRA ticket to reflect the more generic approach and remove this effort as it doesn't make a ton of sense

[GitHub] [flink] tillrohrmann commented on pull request #17137: [FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

tillrohrmann commented on pull request #17137: URL: https://github.com/apache/flink/pull/17137#issuecomment-931443588 Thanks for the review @dmvk. I've addressed your comment and rebased the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] tillrohrmann commented on a change in pull request #17137: [FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

tillrohrmann commented on a change in pull request #17137: URL: https://github.com/apache/flink/pull/17137#discussion_r719536807 ## File path: flink-end-to-end-tests/test-scripts/common_ha.sh ## @@ -127,6 +127,18 @@ function kill_single { echo "Killed JM @ ${PID}" } +fu

[GitHub] [flink] flinkbot commented on pull request #17397: [BP-1.14][FLINK-24117][HA]Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver

flinkbot commented on pull request #17397: URL: https://github.com/apache/flink/pull/17397#issuecomment-931434206 ## CI report: * 958ebb4485f9e0f45c65a362542fcb9c56c063de UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

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

[GitHub] [flink] flinkbot edited a comment on pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers

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

[jira] [Updated] (FLINK-24357) ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled fails with an Unhandled error

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

[GitHub] [flink] flinkbot edited a comment on pull request #17150: [FLINK-24117][HA]Remove unHandledErrorListener in ZooKeeperLeaderElec…

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

[GitHub] [flink] flinkbot commented on pull request #17399: [BP-1.14][FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest

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

  1   2   3   4   >