[GitHub] [flink] curcur commented on a change in pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

curcur commented on a change in pull request #18431: URL: https://github.com/apache/flink/pull/18431#discussion_r794274595 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,129 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFa

[GitHub] [flink] JingsongLi merged pull request #18549: [FLINK-25861] Move states of AbstractAvroBulkFormat into its reader

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

[GitHub] [flink] XComp commented on a change in pull request #18543: [FLINK-25431] Implement a file-based JobResultStore

XComp commented on a change in pull request #18543: URL: https://github.com/apache/flink/pull/18543#discussion_r794271632 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/JobResultStoreContractTest.java ## @@ -0,0 +1,163 @@ +/* + * Licensed t

[GitHub] [flink] flinkbot edited a comment on pull request #18461: [FLINK-20830][Kubernetes]Add type of Headless_Cluster_IP for external…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18549: [FLINK-25861] Move states of AbstractAvroBulkFormat into its reader

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

[GitHub] [flink] flinkbot edited a comment on pull request #18461: [FLINK-20830][Kubernetes]Add type of Headless_Cluster_IP for external…

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

[jira] [Commented] (FLINK-25847) KubernetesHighAvailabilityRecoverFromSavepointITCase. testRecoverFromSavepoint failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483622#comment-17483622 ] Yang Wang commented on FLINK-25847: --- This might be related with FLINK-24038. I have r

[jira] [Commented] (FLINK-25753) KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483621#comment-17483621 ] Yun Gao commented on FLINK-25753: - Very thanks [~ruanhang1993] for the update! https:/

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483619#comment-17483619 ] Yun Gao commented on FLINK-25825: - Perhaps also cc [~twalthr]~ > MySqlCatalogITCase fa

[GitHub] [flink] wangyang0918 commented on a change in pull request #18461: [FLINK-20830][Kubernetes]Add type of Headless_Cluster_IP for external…

wangyang0918 commented on a change in pull request #18461: URL: https://github.com/apache/flink/pull/18461#discussion_r794258873 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/decorators/ExternalServiceDecoratorTest.java ## @@ -118,5 +119,1

[GitHub] [flink] wangyang0918 commented on a change in pull request #18461: [FLINK-20830][Kubernetes]Add type of Headless_Cluster_IP for external…

wangyang0918 commented on a change in pull request #18461: URL: https://github.com/apache/flink/pull/18461#discussion_r794261375 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/services/ServiceTypeTest.java ## @@ -0,0 +1,45 @@ +/* + * Licens

[GitHub] [flink] flinkbot edited a comment on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

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

[GitHub] [flink] fapaul commented on a change in pull request #18509: [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts

fapaul commented on a change in pull request #18509: URL: https://github.com/apache/flink/pull/18509#discussion_r794264781 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java ## @@

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483617#comment-17483617 ] Yun Gao commented on FLINK-25825: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-25585) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed on the azure

[ https://issues.apache.org/jira/browse/FLINK-25585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483615#comment-17483615 ] Yun Gao commented on FLINK-25585: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-25523) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483614#comment-17483614 ] Yun Gao commented on FLINK-25523: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

[ https://issues.apache.org/jira/browse/FLINK-22194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483613#comment-17483613 ] Yun Gao commented on FLINK-22194: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] wpc009 commented on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1023958486 Here is some benchmark results (From my laptop) | Benchmark | Mode | Cnt | Score| Error | Units

[GitHub] [flink] flinkbot edited a comment on pull request #18548: [FLINK-25727][hive] fix the UDFArgumentException when call hive `json…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18515: [FLINK-21788][network] Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

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

[GitHub] [flink] flinkbot edited a comment on pull request #18331: [FLINK-25614][table/runtime] Let LocalWindowAggregate be chained with upstream

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

[GitHub] [flink] flinkbot edited a comment on pull request #18515: [FLINK-21788][network] Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

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

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

ruanhang1993 commented on a change in pull request #18496: URL: https://github.com/apache/flink/pull/18496#discussion_r794258656 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SinkTestSuiteBase.java ##

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

ruanhang1993 commented on a change in pull request #18496: URL: https://github.com/apache/flink/pull/18496#discussion_r794256568 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SinkTestSuiteBase.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18550: 根据英文文档结合技术知识翻译

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot commented on pull request #18550: 根据英文文档结合技术知识翻译

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

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

[GitHub] [flink] flinkbot commented on pull request #18550: 根据英文文档结合技术知识翻译

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

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

[GitHub] [flink] xugejian opened a new pull request #18550: 根据英文文档结合技术知识翻译

xugejian opened a new pull request #18550: URL: https://github.com/apache/flink/pull/18550 ## What is the purpose of the change 原中文版动态表部分为翻译软件硬翻，其中描述内容比较生硬，故根据结合自身技术储备，对英文文档重新翻译 ## Brief change log - 根据英文文档结合技术知识翻译 ## Verifying this change

[GitHub] [flink] wpc009 commented on a change in pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 commented on a change in pull request #18475: URL: https://github.com/apache/flink/pull/18475#discussion_r792294286 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessor.java ## @@ -55,17 +77,24 @@ public Str

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] wpc009 edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 edited a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1023885086 > Good find @wpc009, but unfortunately we have to support JDK8 for at least a couple of more releases. > > I'm testing another approach to solve this problem here:

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18513: [FLINK-25753][tests] Fix KafkaTableITCase.testStartFromGroupOffsetsLatest

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18513: [FLINK-25753][tests] Fix KafkaTableITCase.testStartFromGroupOffsetsLatest

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

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

[jira] [Commented] (FLINK-25753) KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483591#comment-17483591 ] Hang Ruan commented on FLINK-25753: --- Thanks, [~gaoyunhaii] ~ Using sleep is not a good

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18513: [FLINK-25753][tests] Fix KafkaTableITCase.testStartFromGroupOffsetsLatest

ruanhang1993 commented on a change in pull request #18513: URL: https://github.com/apache/flink/pull/18513#discussion_r794231443 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java ## @@ -85

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

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

[GitHub] [flink] Myracle commented on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

Myracle commented on pull request #18296: URL: https://github.com/apache/flink/pull/18296#issuecomment-1023921156 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18515: [FLINK-21788][network] Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18515: [FLINK-21788][network] Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] wpc009 edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 edited a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1023885086 > Good find @wpc009, but unfortunately we have to support JDK8 for at least a couple of more releases. > > I'm testing another approach to solve this problem here:

[GitHub] [flink] Myasuka commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r794224233 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/SharedStateRegistryTest.java ## @@ -143,4 +222,87 @@ public boolean isDiscarded(

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[GitHub] [flink] Myasuka commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r794223409 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java ## @@ -130,14 +155,51 @@ public Strin

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

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

[jira] [Comment Edited] (FLINK-25839) 'Run kubernetes application HA test' failed on azure due to could not get 3 completed checkpoints in 120 sec

[ https://issues.apache.org/jira/browse/FLINK-25839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483519#comment-17483519 ] Yang Wang edited comment on FLINK-25839 at 1/28/22, 5:48 AM: -

[GitHub] [flink] curcur commented on a change in pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

curcur commented on a change in pull request #18431: URL: https://github.com/apache/flink/pull/18431#discussion_r794202114 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,129 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFa

[GitHub] [flink] wpc009 commented on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1023885086 I have a fix. Tested on the `flink-benchmark`. I'm preparing some end-to-end test. I can push it at the end of today. -- This is an automated message from the Apache Git Se

[GitHub] [flink] flinkbot edited a comment on pull request #18549: [FLINK-25861] Move states of AbstractAvroBulkFormat into its reader

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

[GitHub] [flink] flinkbot commented on pull request #18549: [FLINK-25861] Move states of AbstractAvroBulkFormat into its reader

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

[GitHub] [flink] flinkbot commented on pull request #18549: [FLINK-25861] Move states of AbstractAvroBulkFormat into its reader

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

[jira] [Updated] (FLINK-25861) Move states of AbstractAvroBulkFormat into its reader

[ https://issues.apache.org/jira/browse/FLINK-25861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25861: --- Labels: pull-request-available (was: ) > Move states of AbstractAvroBulkFormat into its rea

[GitHub] [flink] tsreaper opened a new pull request #18549: [FLINK-25861] Move states of AbstractAvroBulkFormat into its reader

tsreaper opened a new pull request #18549: URL: https://github.com/apache/flink/pull/18549 ## What is the purpose of the change FLINK-24565 ports avro format to BulkReaderFormatFactory. However the implementation leaves some states into the format factory itself. These states should

[GitHub] [flink] flinkbot edited a comment on pull request #18548: [FLINK-25727][hive] fix the UDFArgumentException when call hive `json…

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

[GitHub] [flink] flinkbot commented on pull request #18548: [FLINK-25727][hive] fix the UDFArgumentException when call hive `json…

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

[GitHub] [flink] flinkbot commented on pull request #18548: [FLINK-25727][hive] fix the UDFArgumentException when call hive `json…

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

[jira] [Commented] (FLINK-25727) Flink SQL convert constant string to char type which cause hive udtf json_tuple not work

[ https://issues.apache.org/jira/browse/FLINK-25727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483543#comment-17483543 ] luoyuxia commented on FLINK-25727: -- I have opened a pr to fix it. > Flink SQL convert

[jira] [Updated] (FLINK-25727) Flink SQL convert constant string to char type which cause hive udtf json_tuple not work

[ https://issues.apache.org/jira/browse/FLINK-25727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25727: --- Labels: features pull-request-available (was: features) > Flink SQL convert constant string

[GitHub] [flink] luoyuxia opened a new pull request #18548: [FLINK-25727][hive] fix the UDFArgumentException when call hive `json…

luoyuxia opened a new pull request #18548: URL: https://github.com/apache/flink/pull/18548 …_tuple` function in Flink SQl using string literal ## What is the purpose of the change *To fix the UDFArgumentException when call hive `json_tuple` function in Flink SQl using

[jira] [Updated] (FLINK-25860) Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoid blocking main thread

[ https://issues.apache.org/jira/browse/FLINK-25860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-25860: Summary: Move read buffer allocation and output file creation to setup method for sort-shuffle res

[jira] [Updated] (FLINK-25860) Move read buffer allocation to setup method for sort-shuffle result partition to avoid blocking main thread

[ https://issues.apache.org/jira/browse/FLINK-25860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-25860: Summary: Move read buffer allocation to setup method for sort-shuffle result partition to avoid bl

[GitHub] [flink] flinkbot edited a comment on pull request #18546: [FLINK-25479][rpc] Always use RemoteRPCInvocation

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

[jira] [Comment Edited] (FLINK-25839) 'Run kubernetes application HA test' failed on azure due to could not get 3 completed checkpoints in 120 sec

[ https://issues.apache.org/jira/browse/FLINK-25839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483519#comment-17483519 ] Yang Wang edited comment on FLINK-25839 at 1/28/22, 3:40 AM: -

[jira] [Created] (FLINK-25861) Move states of AbstractAvroBulkFormat into its reader

Caizhi Weng created FLINK-25861: --- Summary: Move states of AbstractAvroBulkFormat into its reader Key: FLINK-25861 URL: https://issues.apache.org/jira/browse/FLINK-25861 Project: Flink Issue Typ

[jira] [Commented] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483535#comment-17483535 ] Xintong Song commented on FLINK-25577: -- [~galenwarren], I believe we can finally cl

[jira] [Created] (FLINK-25860) Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoid blocking main thread

Yingjie Cao created FLINK-25860: --- Summary: Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoid blocking main thread Key: FLINK-25860 URL: https://issues.ap

[GitHub] [flink] flinkbot edited a comment on pull request #18331: [FLINK-25614][table/runtime] Let LocalWindowAggregate be chained with upstream

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

[GitHub] [flink] Myasuka edited a comment on pull request #18546: [FLINK-25479][rpc] Always use RemoteRPCInvocation

Myasuka edited a comment on pull request #18546: URL: https://github.com/apache/flink/pull/18546#issuecomment-1023841288 @rkhachatryan How do you think of my idea below: 1. Introdue a new option in `AkkaOptions`, such as `akka.invocation.force-remote` as `false` by default. 2. `AkkaRp

[GitHub] [flink] Myasuka commented on pull request #18546: [FLINK-25479][rpc] Always use RemoteRPCInvocation

Myasuka commented on pull request #18546: URL: https://github.com/apache/flink/pull/18546#issuecomment-1023841288 @rkhachatryan How do you think of my idea below: 1. Introdue a new option in `AkkaOptions`, such as `akka.invocation.force-remote` as `false` by default. 2. `AkkaRpcServic

[GitHub] [flink] flinkbot edited a comment on pull request #18331: [FLINK-25614][table/runtime] Let LocalWindowAggregate be chained with upstream

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

[jira] [Closed] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-25577. Release Note: The `flink-gs-fs-hadoop` FileSystem plugin for Google Cloud Storage (GCS) has been

[jira] [Closed] (FLINK-25790) Support authentication via core-site.xml in GCS FileSystem plugin

[ https://issues.apache.org/jira/browse/FLINK-25790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-25790. Fix Version/s: 1.15.0 Resolution: Done Merged via - master (1.15): fb634aa050f65f43d24d98fd

[GitHub] [flink] xintongsong closed pull request #18430: [FLINK-25577][docs] Update GCS documentation

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

[GitHub] [flink] xintongsong closed pull request #18489: [FLINK-25790][flink-gs-fs-hadoop] Support authentication via core-site.xml in GCS FileSystem plugin

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

[GitHub] [flink] xintongsong commented on a change in pull request #18489: [FLINK-25790][flink-gs-fs-hadoop] Support authentication via core-site.xml in GCS FileSystem plugin

xintongsong commented on a change in pull request #18489: URL: https://github.com/apache/flink/pull/18489#discussion_r794158133 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/utils/ConfigUtils.java ## @@ -0,0 +1,208 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot commented on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot commented on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[jira] [Commented] (FLINK-25849) Differentiate TaskManager sessions when registering at the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-25849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483526#comment-17483526 ] Yang Wang commented on FLINK-25849: --- Does this mean that Flink could now support TaskM

[GitHub] [flink] lmagic233 commented on a change in pull request #18331: [FLINK-25614][table/runtime] Let LocalWindowAggregate be chained with upstream

lmagic233 commented on a change in pull request #18331: URL: https://github.com/apache/flink/pull/18331#discussion_r794161669 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SliceAssigners.java ## @@ -401,7 +4

  1   2   3   4   5   6   7   8   9   >