[GitHub] [flink] flinkbot edited a comment on pull request #17041: [release-1.13][FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

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

[GitHub] [flink] flinkbot edited a comment on pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

flinkbot edited a comment on pull request #17050: URL: https://github.com/apache/flink/pull/17050#issuecomment-908295316 ## CI report: * a4c9501964a166055517eeead5bdebe58cb466a8 UNKNOWN * 7c20e7910b5f15eb88d6d2b25733c50a8c214f14 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17051: [FLINK-23978][scala] Move Scala-reliant FieldAccessors to flink-streaming-scala

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

[GitHub] [flink] flinkbot edited a comment on pull request #17052: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

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

[GitHub] [flink] flinkbot commented on pull request #17060: [FLINK-23895][table] Upsert materializer is not inserted for all sink providers

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

[jira] [Commented] (FLINK-23976) Add additional availability timing metrics to Job lifecycle events

[ https://issues.apache.org/jira/browse/FLINK-23976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406835#comment-17406835 ] Seth Wiesman commented on FLINK-23976: -- Hi [~shenzhu0127],    Happy to see you ar

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * e84622d7110a9c3d5423e33c7d277b71235256f9 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17041: [release-1.13][FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

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

[GitHub] [flink] flinkbot edited a comment on pull request #17051: [FLINK-23978][scala] Move Scala-reliant FieldAccessors to flink-streaming-scala

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

[GitHub] [flink] flinkbot edited a comment on pull request #17060: [FLINK-23895][table] Upsert materializer is not inserted for all sink providers

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

[GitHub] [flink] akalash commented on a change in pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

akalash commented on a change in pull request #17024: URL: https://github.com/apache/flink/pull/17024#discussion_r698661266 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionTest.java ## @@ -692,6 +692,17 @@ public void test

[GitHub] [flink] shenzhu commented on pull request #17043: [FLINK-23976] [Runtime / Metrics] Add additional availability timing metrics to Job lifecycle events

shenzhu commented on pull request #17043: URL: https://github.com/apache/flink/pull/17043#issuecomment-908534573 > I appreciate you looking into this, but at the moment I'd prefer to delay the implementation of this ticket. > > There are some issues with the existing availability met

[jira] [Created] (FLINK-24057) Flink SQL client Hadoop is not in the classpath/dependencies error even thugh Hadoop S3 File system plugin was added

James Kim created FLINK-24057: - Summary: Flink SQL client Hadoop is not in the classpath/dependencies error even thugh Hadoop S3 File system plugin was added Key: FLINK-24057 URL: https://issues.apache.org/jira/browse

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17041: [release-1.13][FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

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

[jira] [Updated] (FLINK-24057) Flink SQL client Hadoop is not in the classpath/dependencies error even thugh Hadoop S3 File system plugin was added

[ https://issues.apache.org/jira/browse/FLINK-24057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Kim updated FLINK-24057: -- Environment: VirtualBox Ubuntu 18.04 (was: VirtualBox Ubuntu 18.03 ) > Flink SQL client Hadoop is not

[jira] [Updated] (FLINK-24057) Flink SQL client Hadoop is not in the classpath/dependencies error even thugh Hadoop S3 File system plugin was added

[ https://issues.apache.org/jira/browse/FLINK-24057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Kim updated FLINK-24057: -- Description: I'm trying use a CSV file on an S3 compliant object store and query through Flink SQL cl

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r698686629 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -147,35 +146,34 @@ public

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r698687298 ## File path: flink-clients/src/test/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrapTest.java ## @@ -779,6 +816,22 @@ pub

[GitHub] [flink] fapaul commented on pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

fapaul commented on pull request #17050: URL: https://github.com/apache/flink/pull/17050#issuecomment-908556738 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific c

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

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

[GitHub] [flink] flinkbot edited a comment on pull request #16997: [FLINK-23287][docs][table] Create user document for Window Join in SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #17011: [FLINK-23663][table-planner] Reduce state size of ChangelogNormalize

flinkbot edited a comment on pull request #17011: URL: https://github.com/apache/flink/pull/17011#issuecomment-907015222 ## CI report: * 73c5f356223138fc8c0b0cb74b54772501f8a02e UNKNOWN * 361552cf00e91baf13ecd40ad968f7f95490feea Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

flinkbot edited a comment on pull request #17050: URL: https://github.com/apache/flink/pull/17050#issuecomment-908295316 ## CI report: * a4c9501964a166055517eeead5bdebe58cb466a8 UNKNOWN * 7c20e7910b5f15eb88d6d2b25733c50a8c214f14 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17053: [FLINK-36488942][HA]Handle curator framework start error by register fatalErrorHandler before start zk client

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

[GitHub] [flink] flinkbot edited a comment on pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

flinkbot edited a comment on pull request #17050: URL: https://github.com/apache/flink/pull/17050#issuecomment-908295316 ## CI report: * a4c9501964a166055517eeead5bdebe58cb466a8 UNKNOWN * 7c20e7910b5f15eb88d6d2b25733c50a8c214f14 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink-web] joemoe opened a new pull request #464: announcing the rc0 for 1.14. and asking for help

joemoe opened a new pull request #464: URL: https://github.com/apache/flink-web/pull/464 As we want to stabilise the release, we'd like to ask our users to provide feedback. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r698747330 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationMiniCluster.java ## @@ -0,0 +1,65 @@ +/* + * Licensed to

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r698747330 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationMiniCluster.java ## @@ -0,0 +1,65 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #16966: [FLINK-23875][connectors/kafka] Snapshot reduceBuffer of ReducingUpse…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16963: [FLINK-23582][docs][table] Add documentation for session window tvf.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17055: [FLINK-22367][streaming] Reset syncSavepointId only if it is equal to…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17053: [FLINK-36488942][HA]Handle curator framework start error by register fatalErrorHandler before start zk client

flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * cca9d287789ca6a353b7ffb8652ebc41f92fa20e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * cfcaa03e2180e1e3d8b819b1f2cc615ae2db4b77 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17054: [FLINK-24055][connectors/kafka] Deprecate FlinkKafkaConsumer

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

[GitHub] [flink] flinkbot edited a comment on pull request #17059: [FLINK-24005][coordination] Only return fulfilled requirements for reserved slots

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

[GitHub] [flink] flinkbot edited a comment on pull request #17057: [FLINK-24056][HA]Remove unused ZooKeeperUtilityFactory.java

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

[GitHub] [flink] flinkbot edited a comment on pull request #17058: [FLINK-23664][docs] Add docs for KafkaSink

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

[GitHub] [flink] flinkbot edited a comment on pull request #17056: [FLINK-23748][tests] Testing window TVF session window

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

[GitHub] [flink] zentol merged pull request #17057: [FLINK-24056][HA]Remove unused ZooKeeperUtilityFactory.java

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

[jira] [Closed] (FLINK-24056) Remove unused ZooKeeperUtilityFactory and clean up ZooKeeperUtilTest

[ https://issues.apache.org/jira/browse/FLINK-24056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24056. Fix Version/s: 1.15.0 Resolution: Fixed master: 373b0c0f45715eda40796789569c2379f7c

[jira] [Assigned] (FLINK-24056) Remove unused ZooKeeperUtilityFactory and clean up ZooKeeperUtilTest

[ https://issues.apache.org/jira/browse/FLINK-24056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24056: Assignee: Aitozi > Remove unused ZooKeeperUtilityFactory and clean up ZooKeeperUt

[jira] [Updated] (FLINK-24056) Remove unused ZooKeeperUtilityFactory and clean up ZooKeeperUtilTest

[ https://issues.apache.org/jira/browse/FLINK-24056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24056: - Issue Type: Technical Debt (was: Bug) > Remove unused ZooKeeperUtilityFactory and clean

[jira] [Updated] (FLINK-24056) Remove unused ZooKeeperUtilityFactory and clean up ZooKeeperUtilTest

[ https://issues.apache.org/jira/browse/FLINK-24056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24056: - Priority: Not a Priority (was: Minor) > Remove unused ZooKeeperUtilityFactory and clean

[jira] [Closed] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-23367. - > testKeyGroupedInternalPriorityQueue does not dispose > ChangelogDelegateEmbeddedRocksDB p

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

rionmonster opened a new pull request #17061: URL: https://github.com/apache/flink/pull/17061 ## What is the purpose of the change Currently, the existing `ElasticsearchSink` implementation supports dynamic, index-based routing at runtime however any additional routing to separate ES

[jira] [Updated] (FLINK-23977) Add Support for Dynamic Elastic Cluster/Index Routing

[ https://issues.apache.org/jira/browse/FLINK-23977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23977: --- Labels: elasticsearch pull-request-available (was: elasticsearch) > Add Support for Dynamic

[GitHub] [flink] flinkbot edited a comment on pull request #17022: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17051: [FLINK-23978][scala] Move Scala-reliant FieldAccessors to flink-streaming-scala

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

[GitHub] [flink] flinkbot edited a comment on pull request #17041: [release-1.13][FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

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

[GitHub] [flink] flinkbot edited a comment on pull request #17060: [FLINK-23895][table] Upsert materializer is not inserted for all sink providers

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

[GitHub] [flink] flinkbot edited a comment on pull request #17052: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

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

[GitHub] [flink] dmvk commented on pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-908711529 @tillrohrmann Thanks for the review! I've incorporated your suggestions, PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r698821009 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java ## @@ -247,6 +247,14 @@ public ClusterInformation getCluster

[GitHub] [flink] tweise merged pull request #17041: [release-1.13][FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

tweise merged pull request #17041: URL: https://github.com/apache/flink/pull/17041 -- 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 commented on pull request #17061: [FLINK-23977][elasticsearch] Added DynamicElasticsearchSink for Dynamic ES Cluster Routing

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

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

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

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

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

[jira] [Resolved] (FLINK-24010) HybridSourceReader needs to forward checkpoint notifications

[ https://issues.apache.org/jira/browse/FLINK-24010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-24010. -- Resolution: Fixed > HybridSourceReader needs to forward checkpoint notifications > ---

[jira] [Updated] (FLINK-24010) HybridSource needs to forward checkpoint notifications

[ https://issues.apache.org/jira/browse/FLINK-24010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-24010: - Summary: HybridSource needs to forward checkpoint notifications (was: HybridSourceReader needs

[jira] [Updated] (FLINK-21511) Flink connector elasticsearch 6.x has a bug about BulkProcessor hangs for threads deadlocked

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

[jira] [Updated] (FLINK-21456) TableResult#print() should correctly stringify values of all data types in SQL format

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

[jira] [Updated] (FLINK-20791) Support local aggregate push down for Blink batch planner

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

[jira] [Updated] (FLINK-23210) Running HA per-job cluster (hashmap, sync) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-23210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23210: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[GitHub] [flink-training] alpinegizmo commented on a change in pull request #31: [FLINK-23653] exercise and test rework

alpinegizmo commented on a change in pull request #31: URL: https://github.com/apache/flink-training/pull/31#discussion_r698855269 ## File path: rides-and-fares/src/main/scala/org/apache/flink/training/exercises/ridesandfares/scala/RidesAndFaresExercise.scala ## @@ -18,55 +18,

[GitHub] [flink] flinkbot edited a comment on pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * cfcaa03e2180e1e3d8b819b1f2cc615ae2db4b77 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17061: [FLINK-23977][elasticsearch] Added DynamicElasticsearchSink for Dynamic ES Cluster Routing

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

[GitHub] [flink-training] alpinegizmo commented on a change in pull request #31: [FLINK-23653] exercise and test rework

alpinegizmo commented on a change in pull request #31: URL: https://github.com/apache/flink-training/pull/31#discussion_r698865364 ## File path: common/src/test/java/org/apache/flink/training/exercises/testing/ComposedRichCoFlatMapFunction.java ## @@ -0,0 +1,70 @@ +package org

[GitHub] [flink] hililiwei commented on pull request #17056: [FLINK-23748][tests] Testing window TVF session window

hililiwei commented on pull request #17056: URL: https://github.com/apache/flink/pull/17056#issuecomment-908772017 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specifi

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * cfcaa03e2180e1e3d8b819b1f2cc615ae2db4b77 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17056: [FLINK-23748][tests] Testing window TVF session window

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

[GitHub] [flink-training] alpinegizmo commented on a change in pull request #31: [FLINK-23653] exercise and test rework

alpinegizmo commented on a change in pull request #31: URL: https://github.com/apache/flink-training/pull/31#discussion_r698872951 ## File path: hourly-tips/src/main/scala/org/apache/flink/training/exercises/hourlytips/scala/HourlyTipsExercise.scala ## @@ -18,36 +18,47 @@ p

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406992#comment-17406992 ] liwei li commented on FLINK-23747: -- Hi [~xtsong], Yes, I will try to finish it as soon

[GitHub] [flink] flinkbot edited a comment on pull request #17056: [FLINK-23748][tests] Testing window TVF session window

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

[GitHub] [flink] flinkbot edited a comment on pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

flinkbot edited a comment on pull request #17050: URL: https://github.com/apache/flink/pull/17050#issuecomment-908295316 ## CI report: * a4c9501964a166055517eeead5bdebe58cb466a8 UNKNOWN * 7c20e7910b5f15eb88d6d2b25733c50a8c214f14 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorHandler before start zk client

flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * cca9d287789ca6a353b7ffb8652ebc41f92fa20e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-24021) Potential job unrecoverable due to Network failure

[ https://issues.apache.org/jira/browse/FLINK-24021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24021: --- Labels: pull-request-available (was: ) > Potential job unrecoverable due to Network failure

[GitHub] [flink-training] alpinegizmo opened a new pull request #36: Flink 23926 one timestamp

alpinegizmo opened a new pull request #36: URL: https://github.com/apache/flink-training/pull/36 This PR is layered on top of https://github.com/apache/flink-training/pull/31. The objective is to replace the startTime and endTime fields with a single eventTime field. This is more na

[jira] [Assigned] (FLINK-23747) Testing Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-23747: Assignee: liwei li > Testing Window TVF offset > - > >

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407008#comment-17407008 ] Xintong Song commented on FLINK-23747: -- Thanks [~liliwei], you are assigned. Please

[jira] [Updated] (FLINK-24010) HybridSource needs to forward checkpoint notifications

[ https://issues.apache.org/jira/browse/FLINK-24010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24010: - Fix Version/s: 1.15.0 > HybridSource needs to forward checkpoint notifications > ---

[GitHub] [flink] flinkbot edited a comment on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorHandler before start zk client

flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * cca9d287789ca6a353b7ffb8652ebc41f92fa20e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Assigned] (FLINK-23748) Testing window TVF session window

[ https://issues.apache.org/jira/browse/FLINK-23748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-23748: Assignee: liwei li > Testing window TVF session window >

[jira] [Commented] (FLINK-23748) Testing window TVF session window

[ https://issues.apache.org/jira/browse/FLINK-23748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407010#comment-17407010 ] Xintong Song commented on FLINK-23748: -- Thanks [~liliwei], you're assigned. > Test

[jira] [Created] (FLINK-24058) TaskSlotTableImplTest.testMarkSlotActiveDeactivatesSlotTimeout fails on azure

Xintong Song created FLINK-24058: Summary: TaskSlotTableImplTest.testMarkSlotActiveDeactivatesSlotTimeout fails on azure Key: FLINK-24058 URL: https://issues.apache.org/jira/browse/FLINK-24058 Project

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407014#comment-17407014 ] Xintong Song commented on FLINK-20329: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407015#comment-17407015 ] Xintong Song commented on FLINK-20928: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] dianfu closed pull request #17046: [FLINK-24049][python] Handle properly for field types need conversion in TupleTypeInfo

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

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407016#comment-17407016 ] Xintong Song commented on FLINK-22889: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (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:all-tabpanel ] Xintong Song updated FLINK-18634: - Affects Version/s: 1.15.0 1.14.0 > FlinkKafkaProducerITCase.testRecoverCo

[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=17407017#comment-17407017 ] Xintong Song commented on FLINK-18634: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (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:all-tabpanel ] Xintong Song updated FLINK-18634: - Labels: auto-unassigned test-stability (was: auto-deprioritized-blocker auto-deprioritized-crit

[jira] [Updated] (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:all-tabpanel ] Xintong Song updated FLINK-18634: - Fix Version/s: 1.15.0 1.14.0 > FlinkKafkaProducerITCase.testRecoverCommittedT

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407018#comment-17407018 ] Xintong Song commented on FLINK-23828: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Comment Edited] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406350#comment-17406350 ] Xintong Song edited comment on FLINK-24038 at 8/31/21, 1:54 AM: --

[jira] [Created] (FLINK-24059) SourceReaderTestBase should allow NUM_SPLITS to be overridden in implementation

Brian Zhou created FLINK-24059: -- Summary: SourceReaderTestBase should allow NUM_SPLITS to be overridden in implementation Key: FLINK-24059 URL: https://issues.apache.org/jira/browse/FLINK-24059 Project:

[jira] [Closed] (FLINK-24049) TupleTypeInfo doesn't handle correctly for data types need conversion

[ https://issues.apache.org/jira/browse/FLINK-24049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24049. --- Resolution: Fixed Merged to - master via 117c40cef96a5cc8dcaaee5029deb6ca718c7eb1 - release-1.14 via 024877b

<    1   2   3   4   5   6   >