[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=17423106#comment-17423106 ] ZhuoYu Chen commented on FLINK-24351: - Hi [~liliwei] , I am very interested in this，and I want do

[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=17423105#comment-17423105 ] ZhuoYu Chen commented on FLINK-24370: - Hi [~CrynetLogistics] , I am very interested in this，and I

[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=17423104#comment-17423104 ] ZhuoYu Chen commented on FLINK-22644: - Hi [~rudeigerc] , I am very interested in this，and I want do

[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=17423102#comment-17423102 ] ZhuoYu Chen commented on FLINK-22797: - Hi [~Nicolaus Weidner] , I am very interested in this，and I

[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=17423101#comment-17423101 ] ZhuoYu Chen commented on FLINK-23427: - Hi [~Aiden Gong] , I am very interested in this，and I want do

[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=17423100#comment-17423100 ] ZhuoYu Chen commented on FLINK-24345: - Hi [~Liebing] , I am very interested in this，and I want do

[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:

[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:

[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

[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

[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

[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

[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 

[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:

[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:

[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:

[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

[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:

[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:

[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=17423039#comment-17423039 ] Seth Wiesman edited comment on FLINK-24427 at 9/30/21, 11:01 PM: - Hi

[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=17423039#comment-17423039 ] Seth Wiesman commented on FLINK-24427: -- Hi [~eloisant],    The goal is to hide the planner from

[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:

[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

[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

[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

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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=17422979#comment-17422979 ] Erwan Loisant edited comment on FLINK-24427 at 9/30/21, 7:08 PM: - I'm

[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=17422981#comment-17422981 ] Nick Burkard commented on FLINK-13414: -- Looks like the two tickets are now assigned, if there's

[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=17422979#comment-17422979 ] Erwan Loisant commented on FLINK-24427: --- I'm not sure what's the proposed solution here, I don't

[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=17422974#comment-17422974 ] Erwan Loisant commented on FLINK-13414: --- Hi [~MartijnVisser] , I'll give a try to hiding Scala

[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:

[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:

[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=17422943#comment-17422943 ] Martijn Visser commented on FLINK-13414: With the help of [~NickBurkard] we managed to drop

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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

[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

[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

[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

[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

[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:

[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:

[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:

[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:

[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:

[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:

[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

[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

[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

[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,

[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}" }

[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

[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:

[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:

[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) >

[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:

[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

[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-931432461 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] tillrohrmann commented on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

tillrohrmann commented on pull request #15229: URL: https://github.com/apache/flink/pull/15229#issuecomment-931431652 Are you working on this problem @zhuzhurk? If not, then we should maybe close this PR and reopen it once you resume working on it. -- This is an automated message from

[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 ] Till Rohrmann updated FLINK-24357: -- Labels: test-stability (was: pull-request-available) >

[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 (was: ) >

[GitHub] [flink] tillrohrmann opened a new pull request #17399: [BP-1.14][FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest

tillrohrmann opened a new pull request #17399: URL: https://github.com/apache/flink/pull/17399 Backport of #17398 to `release-1.14`. -- 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] 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-931429813 To open it to more use cases, we pretty much just need to replace the lower bounds with a more generic interface. You are not using much from the ESSink directly. However, we

[GitHub] [flink] tillrohrmann opened a new pull request #17398: [FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest

tillrohrmann opened a new pull request #17398: URL: https://github.com/apache/flink/pull/17398 This commit hardens ZooKeeperLeaderElectionConnectionHandlingTest.testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled by allowing that exceptions can occur if the

[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 ] Till Rohrmann updated FLINK-24357: -- Fix Version/s: 1.14.1 1.15.0 >

[jira] [Assigned] (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 ] Till Rohrmann reassigned FLINK-24357: - Assignee: Till Rohrmann >

[GitHub] [flink] rmetzger commented on pull request #16166: [FLINK-23000] Add log bundler to collect and compress logs

rmetzger commented on pull request #16166: URL: https://github.com/apache/flink/pull/16166#issuecomment-931423456 FYI: I was hoping to find some time to address the last outstanding comments before my parental leave, but I won't be able to. Maybe I find time in December to look into

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate

slinkydeveloper commented on a change in pull request #17369: URL: https://github.com/apache/flink/pull/17369#discussion_r719517375 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest.java

[jira] [Commented] (FLINK-24387) Support a JSON_STRING

[ https://issues.apache.org/jira/browse/FLINK-24387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422843#comment-17422843 ] Timo Walther commented on FLINK-24387: -- +1 to JSON_STRING > Support a JSON_STRING >

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

[ https://issues.apache.org/jira/browse/FLINK-24357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422838#comment-17422838 ] Till Rohrmann commented on FLINK-24357: --- I think the problem is a test instability. In the test we

[GitHub] [flink] twalthr closed pull request #10838: [hotfix][table-common] Simplify formatted exceptions

twalthr closed pull request #10838: URL: https://github.com/apache/flink/pull/10838 -- 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] twalthr commented on pull request #10838: [hotfix][table-common] Simplify formatted exceptions

twalthr commented on pull request #10838: URL: https://github.com/apache/flink/pull/10838#issuecomment-931414163 Closing this as it has never got enough attention. -- 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] twalthr commented on a change in pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate

twalthr commented on a change in pull request #17369: URL: https://github.com/apache/flink/pull/17369#discussion_r719504153 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest.java ## @@

[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-931406025 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] akalash commented on a change in pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value

akalash commented on a change in pull request #17354: URL: https://github.com/apache/flink/pull/17354#discussion_r719499492 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierTrackerTest.java ## @@ -607,13 +606,26 @@ public

  1   2   3   4   >