[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_r793338475 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,129 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFa

[GitHub] [flink] flinkbot edited a comment on pull request #18527: [FLINK-25835][Runtime]The task initialization duration is recorded in logs

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

[GitHub] [flink] zhuzhurk commented on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

zhuzhurk commented on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-1022942186 Merging. -- 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.

[GitHub] [flink] gaoyunhaii closed pull request #18470: [FLINK-25774][network] Restrict the maximum number of buffers can be used per result partition for sort-shuffle

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

[jira] [Commented] (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=17482943#comment-17482943 ] Yun Gao commented on FLINK-25839: - Perhaps cc [~wangyang0918]~ > 'Run kubernetes applic

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

Yun Gao created FLINK-25839: --- Summary: 'Run kubernetes application HA test' failed on azure due to could not get 3 completed checkpoints in 120 sec Key: FLINK-25839 URL: https://issues.apache.org/jira/browse/FLINK-25839

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

[ https://issues.apache.org/jira/browse/FLINK-25753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-25753: --- Assignee: Hang Ruan (was: Fabian Paul) > KafkaTableITCase.testStartFromGroupOffsetsLatest

[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=17482941#comment-17482941 ] Yun Gao commented on FLINK-25825: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Comment Edited] (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=17482935#comment-17482935 ] Yun Gao edited comment on FLINK-25753 at 1/27/22, 7:49 AM: --- ht

[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=17482939#comment-17482939 ] Yun Gao commented on FLINK-25753: - Hi [~ruanhang1993] ~ If possible we'd better not use

[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-25753) KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP

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

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482933#comment-17482933 ] Yun Gao commented on FLINK-24119: - KafkaShuffleITCase.testSerDeProcessingTime on 1.13:

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482932#comment-17482932 ] Yun Gao commented on FLINK-24119: - FlinkKafkaInternalProducerITCase.testProducerWhenComm

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

Myracle edited a comment on pull request #18296: URL: https://github.com/apache/flink/pull/18296#issuecomment-1022786201 @tillrohrmann Sorry for late reply. I have written the most code and will finish it soon. -- This is an automated message from the Apache Git Service. To respond to th

[GitHub] [flink] lichang-bd commented on pull request #18359: [FLINK-25484][connectors/filesystem] Support inactivityInterval config in table api

lichang-bd commented on pull request #18359: URL: https://github.com/apache/flink/pull/18359#issuecomment-1022929085 please have a look @JingsongLi -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

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

[GitHub] [flink] wangyang0918 commented on a change in pull request #18450: [FLINK-25053][docs] Document how to use the usrlib to load code in the user code class loader

wangyang0918 commented on a change in pull request #18450: URL: https://github.com/apache/flink/pull/18450#discussion_r793307538 ## File path: docs/content.zh/docs/ops/debugging/debugging_classloading.md ## @@ -61,22 +61,18 @@ created for an job/application and will contain the

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

curcur commented on pull request #18431: URL: https://github.com/apache/flink/pull/18431#issuecomment-1022921395 > Thanks a lot @infoverload, I've accepted your suggestions. FYI @curcur, the PR was updated. thanks a lot @rkhachatryan and @infoverload , I will take a look! -- This

[GitHub] [flink] flinkbot edited a comment on pull request #18504: [hotfix][azure] fix ArchUnit flag

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

[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_r793315064 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,126 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFa

[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_r793315064 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,126 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFa

[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: * 6ffad613830a3d192c5f522b520c540a656698cd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18504: [hotfix][azure] fix ArchUnit flag

flinkbot edited a comment on pull request #18504: URL: https://github.com/apache/flink/pull/18504#issuecomment-1021053731 ## CI report: * 80f5673c618447af48a98fb315cdf88cbb9453d8 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-table-store] tsreaper commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

tsreaper commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r793305142 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreWriteImpl.java ## @@ -0,0 +1,107 @@ +/* +

[GitHub] [flink] imaffe commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

imaffe commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r793300636 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java ## @@ -97,16 +94,14 @@

[jira] [Reopened] (FLINK-24407) Pulsar connector chinese document link to Pulsar document location incorrectly.

[ https://issues.apache.org/jira/browse/FLINK-24407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aiden Gong reopened FLINK-24407: > Pulsar connector chinese document link to Pulsar document location > incorrectly. > ---

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

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

[jira] [Resolved] (FLINK-25836) test_keyed_process_function_with_state of BatchModeDataStreamTests faild in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-25836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-25836. -- Resolution: Fixed Merged into master via 13c8d4d4e5a210df63f08507d342bde57d32d690 > test_keye

[GitHub] [flink] HuangXingBo closed pull request #18528: [FLINK-25836][python] Fix the unstable test test_keyed_process_function_with_state in PyFlink

HuangXingBo closed pull request #18528: URL: https://github.com/apache/flink/pull/18528 -- 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_r793223972 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/utils/ConfigUtils.java ## @@ -0,0 +1,202 @@ +/* + * Licensed

[GitHub] [flink] imaffe commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

imaffe commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r793289032 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer/PulsarSchemaWrapper.java ## @

[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_r793223972 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/utils/ConfigUtils.java ## @@ -0,0 +1,202 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

flinkbot edited a comment on pull request #18523: URL: https://github.com/apache/flink/pull/18523#issuecomment-1022181601 ## CI report: * Unknown: [CANCELED](TBD) * 4b856c2a3dd4404b0f4a5a5146b87d705cc21bc0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-462

[GitHub] [flink] flinkbot edited a comment on pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

flinkbot edited a comment on pull request #18523: URL: https://github.com/apache/flink/pull/18523#issuecomment-1022181601 ## CI report: * Unknown: [CANCELED](TBD) * 4b856c2a3dd4404b0f4a5a5146b87d705cc21bc0 UNKNOWN Bot commands The @flinkbot bot supports the fo

[GitHub] [flink] zlzhang0122 commented on pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

zlzhang0122 commented on pull request #18523: URL: https://github.com/apache/flink/pull/18523#issuecomment-1022891819 @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 spec

[GitHub] [flink] Myasuka commented on a change in pull request #18460: [FLINK-25767][doc] Totally translated state.md into Chinese

Myasuka commented on a change in pull request #18460: URL: https://github.com/apache/flink/pull/18460#discussion_r793284042 ## File path: docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## @@ -85,15 +76,12 @@ keyed = words.key_by(lambda row: row[0]) {{< /tab >}}

[jira] [Created] (FLINK-25838) BatchArrowPythonOverWindowAggregateFunctionOperatorTest. testFinishBundleTriggeredByTime failed in Azure

Huang Xingbo created FLINK-25838: Summary: BatchArrowPythonOverWindowAggregateFunctionOperatorTest. testFinishBundleTriggeredByTime failed in Azure Key: FLINK-25838 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Updated] (FLINK-25837) RPC Serialization failure when multiple job managers

[ https://issues.apache.org/jira/browse/FLINK-25837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew McMahon updated FLINK-25837: Description: I'm using 1.14.3 with the Lyft FlinkK8sOperator to run the cluster. Previous

[jira] [Updated] (FLINK-25837) RPC Serialization failure when multiple job managers

[ https://issues.apache.org/jira/browse/FLINK-25837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew McMahon updated FLINK-25837: Description: I'm using 1.14.3 with the Lyft FlinkK8sOperator to run the cluster. Previous

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482881#comment-17482881 ] Yang Wang commented on FLINK-25649: --- This might be related with FLINK-22006. When the

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

JingsongLi commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r793271957 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileUtils.java ## @@ -51,6 +52,8 @@ DEFAULT

[GitHub] [flink-table-store] JingsongLi commented on pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

JingsongLi commented on pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#issuecomment-1022865817 We need think about how to reduced the cost of FileFormat. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Updated] (FLINK-25837) RPC Serialization failure when multiple job managers

[ https://issues.apache.org/jira/browse/FLINK-25837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew McMahon updated FLINK-25837: Description: I'm using 1.14.3 with the Lyft FlinkK8sOperator to run the cluster. Previous

[jira] [Created] (FLINK-25837) RPC Serialization failure when multiple job managers

Matthew McMahon created FLINK-25837: --- Summary: RPC Serialization failure when multiple job managers Key: FLINK-25837 URL: https://issues.apache.org/jira/browse/FLINK-25837 Project: Flink Is

[GitHub] [flink] flinkbot edited a comment on pull request #18528: [FLINK-25836][python] Fix the unstable test test_keyed_process_function_with_state in PyFlink

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

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

JingsongLi commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r793265462 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreWriteImpl.java ## @@ -0,0 +1,107 @@ +/*

[GitHub] [flink] flinkbot commented on pull request #18528: [FLINK-25836][python] Fix the unstable test test_keyed_process_function_with_state in PyFlink

flinkbot commented on pull request #18528: URL: https://github.com/apache/flink/pull/18528#issuecomment-1022863764 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 #18528: [FLINK-25836][python] Fix the unstable test test_keyed_process_function_with_state in PyFlink

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

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

JingsongLi commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r793263919 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScanImpl.java ## @@ -109,34 +172,77 @@ p

[jira] [Updated] (FLINK-25836) test_keyed_process_function_with_state of BatchModeDataStreamTests faild in PyFlink

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

[GitHub] [flink] HuangXingBo opened a new pull request #18528: [FLINK-25836][python] Fix the unstable test test_keyed_process_function_with_state in PyFlink

HuangXingBo opened a new pull request #18528: URL: https://github.com/apache/flink/pull/18528 ## What is the purpose of the change *This pull request will fix the unstable test test_keyed_process_function_with_state in PyFlink* ## Verifying this change This change a

[jira] [Created] (FLINK-25836) test_keyed_process_function_with_state of BatchModeDataStreamTests faild in PyFlink

Huang Xingbo created FLINK-25836: Summary: test_keyed_process_function_with_state of BatchModeDataStreamTests faild in PyFlink Key: FLINK-25836 URL: https://issues.apache.org/jira/browse/FLINK-25836

[GitHub] [flink] flinkbot edited a comment on pull request #18527: [FLINK-25835][Runtime]The task initialization duration is recorded in logs

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

[GitHub] [flink] flinkbot commented on pull request #18527: [FLINK-25835][Runtime]The task initialization duration is recorded in logs

flinkbot commented on pull request #18527: URL: https://github.com/apache/flink/pull/18527#issuecomment-1022845188 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 #18527: [FLINK-25835][Runtime]The task initialization duration is recorded in logs

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

[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: * 6ffad613830a3d192c5f522b520c540a656698cd Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25835) The task initialization duration is recorded in logs

[ https://issues.apache.org/jira/browse/FLINK-25835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25835: --- Labels: pull-request-available (was: ) > The task initialization duration is recorded in lo

[GitHub] [flink] cuibo01 opened a new pull request #18527: [FLINK-25835][Runtime]The task initialization duration is recorded in logs

cuibo01 opened a new pull request #18527: URL: https://github.com/apache/flink/pull/18527 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[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: * 6ffad613830a3d192c5f522b520c540a656698cd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-25835) The task initialization duration is recorded in logs

Bo Cui created FLINK-25835: -- Summary: The task initialization duration is recorded in logs Key: FLINK-25835 URL: https://issues.apache.org/jira/browse/FLINK-25835 Project: Flink Issue Type: Improvem

[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: * 6ffad613830a3d192c5f522b520c540a656698cd Azure: [PENDING](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: * 6ffad613830a3d192c5f522b520c540a656698cd 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-1022813985 It seems like newer JDK release have already fixed the memory issue of `CompletableFuture.anyOf`. Saddly, this issue is still exists in jdk8. May be it's time to a

[jira] [Updated] (FLINK-25834) 'flink run' command can not use 'pipeline.classpaths' in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-25834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25834: - Description: When we use 'flink run' or CliFrontend class to submit job. If not set -C/-classpaths, it

[jira] [Commented] (FLINK-25834) 'flink run' command can not use 'pipeline.classpaths' in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-25834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482860#comment-17482860 ] Ada Wong commented on FLINK-25834: -- I want to fix this. > 'flink run' command can not

[jira] [Created] (FLINK-25834) 'flink run' command can not use 'pipeline.classpaths' in flink-conf.yaml

Ada Wong created FLINK-25834: Summary: 'flink run' command can not use 'pipeline.classpaths' in flink-conf.yaml Key: FLINK-25834 URL: https://issues.apache.org/jira/browse/FLINK-25834 Project: Flink

[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: * d1b89b6f6e2a065fa456d804c185e23fc596f2be 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: * d1b89b6f6e2a065fa456d804c185e23fc596f2be Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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_r793223972 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/utils/ConfigUtils.java ## @@ -0,0 +1,202 @@ +/* + * Licensed

[jira] [Created] (FLINK-25833) FlinkUserCodeClassLoader is not registered as parallel capable

nicolasyang created FLINK-25833: --- Summary: FlinkUserCodeClassLoader is not registered as parallel capable Key: FLINK-25833 URL: https://issues.apache.org/jira/browse/FLINK-25833 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

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

[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-1022813985 It seems like newer JDK release have already fixed the memory issue of `CompletableFuture.anyOf`. Saddly, this issue is still exists in jdk8. It's time to abandon this old t

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

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

[GitHub] [flink] KarmaGYZ commented on a change in pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

KarmaGYZ commented on a change in pull request #18434: URL: https://github.com/apache/flink/pull/18434#discussion_r793223927 ## File path: flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/rpc/akka/MessageSerializationTest.java ## @@ -139,32 +139,6 @@ public void

[GitHub] [flink] jelly-1203 commented on pull request #18358: [FLINK-25651][docs] Update kafka.md

jelly-1203 commented on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1022805317 anyone? -- 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.

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482848#comment-17482848 ] Zhu Zhu commented on FLINK-25649: - Yes, your Flink session uses kubernetes to serve as i

[jira] [Closed] (FLINK-25312) Hive supports managed table

[ https://issues.apache.org/jira/browse/FLINK-25312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25312. Resolution: Fixed master: a543e658acfbc22c1579df0d043654037b9ec4b0 > Hive supports managed table

[GitHub] [flink] KarmaGYZ edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

KarmaGYZ edited a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1022775069 @zentol This PR is an improvement of the job execution for Flink OLAP. In the OLAP scenario, most jobs can be finished within 1s(in our internal benchmark, a 1000*1000

[jira] [Updated] (FLINK-25832) When the TaskManager is closed, its associated slot is not set to the released state.

[ https://issues.apache.org/jira/browse/FLINK-25832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] john updated FLINK-25832: - Description: I deployed a standalone flink cluster on k8s and enabled scheduler-mode=reactive. When Taskmanager

[GitHub] [flink] JingsongLi merged pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

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

[jira] [Created] (FLINK-25832) When the TaskManager is closed, its associated slot is not set to the released state.

john created FLINK-25832: Summary: When the TaskManager is closed, its associated slot is not set to the released state. Key: FLINK-25832 URL: https://issues.apache.org/jira/browse/FLINK-25832 Project: Flink

[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-1022786201 @tillrohrmann @dmvk I have just updated the code. Hope to merge it soon. Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, pl

[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: * ac842b597501d4f7d53967fb3f12e5288ea65674 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

Aitozi commented on pull request #18461: URL: https://github.com/apache/flink/pull/18461#issuecomment-1022785158 @wangyang0918 PTAL, when you are free -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to g

[GitHub] [flink] 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: * ac842b597501d4f7d53967fb3f12e5288ea65674 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

tsreaper commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r793202205 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreWriteImpl.java ## @@ -0,0 +1,107 @@ +/* +

[jira] [Closed] (FLINK-25719) Support General Python UDF in Thread Mode

[ https://issues.apache.org/jira/browse/FLINK-25719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-25719. Resolution: Done Merged into master via 51eb386048484502f88d8806b75c17b04b91a613 > Support Genera

[GitHub] [flink] HuangXingBo closed pull request #18418: [FLINK-25719][python] Support General Python UDF in Thread Mode

HuangXingBo closed pull request #18418: URL: https://github.com/apache/flink/pull/18418 -- 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-table-store] tsreaper commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

tsreaper commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r793200709 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreWriteImpl.java ## @@ -0,0 +1,107 @@ +/* +

[GitHub] [flink] Myasuka commented on a change in pull request #18514: [FLINK-25816][changelog] Refactor the logic of notifying materialization id to nested state backend

Myasuka commented on a change in pull request #18514: URL: https://github.com/apache/flink/pull/18514#discussion_r793197286 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -526

[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: * 0e551fb613f335e648b28aeb0205e29bfa41c64f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] KarmaGYZ commented on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

KarmaGYZ commented on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1022775069 @zentol This PR is an improvement of the job execution for Flink OLAP. In our internal benchmark, the serialization of the `RemoteRpcInvocation` at the Flink side will increas

[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: * 0e551fb613f335e648b28aeb0205e29bfa41c64f 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_r793194839 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/SharedStateRegistryTest.java ## @@ -98,6 +106,77 @@ public void testUnregisterWi

[jira] [Commented] (FLINK-18887) Add ElasticSearch connector for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482834#comment-17482834 ] Dian Fu commented on FLINK-18887: - [~ana4] Thanks. Have assigned it to you~ > Add Elast

[jira] [Assigned] (FLINK-18887) Add ElasticSearch connector for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-18887: --- Assignee: Ada Wong > Add ElasticSearch connector for Python DataStream API > --

[jira] [Assigned] (FLINK-25795) Support Pulsar sink connector in Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-25795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-25795: --- Assignee: Ada Wong > Support Pulsar sink connector in Python DataStream API. >

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

Myasuka removed a comment on pull request #18391: URL: https://github.com/apache/flink/pull/18391#issuecomment-1022758418 @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

  1   2   3   4   5   6   >