[GitHub] [flink] flinkbot commented on pull request #18498: [FLINK-25801][ metrics]add cpu processor metric of taskmanager

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

[GitHub] [flink] deadwind4 commented on pull request #18454: [hotfix][connector/pulsar] Fix typo in JavaDocs example.

deadwind4 commented on pull request #18454: URL: https://github.com/apache/flink/pull/18454#issuecomment-1020906388 @syhily Could you review this? Thanks a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-25154) FLIP-193: Snapshots ownership

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481627#comment-17481627 ] Dawid Wysakowicz commented on FLINK-25154: -- Sorry, [~monster#12] I missed the n

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

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

[jira] [Created] (FLINK-25803) Implement partition and bucket filter of FileStoreScanImpl

Caizhi Weng created FLINK-25803: --- Summary: Implement partition and bucket filter of FileStoreScanImpl Key: FLINK-25803 URL: https://issues.apache.org/jira/browse/FLINK-25803 Project: Flink Issu

[GitHub] [flink] flinkbot edited a comment on pull request #18498: [FLINK-25801][ metrics]add cpu processor metric of taskmanager

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

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

tsreaper opened a new pull request #14: URL: https://github.com/apache/flink-table-store/pull/14 This PR implements partition and bucket filter in `FileStoreScanImpl`. It also perform some small optimizations such as concurrent reads in `FileStoreScanImpl`. -- This is an automated messa

[jira] [Updated] (FLINK-25803) Implement partition and bucket filter of FileStoreScanImpl

[ https://issues.apache.org/jira/browse/FLINK-25803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25803: --- Labels: pull-request-available (was: ) > Implement partition and bucket filter of FileStore

[jira] [Assigned] (FLINK-25803) Implement partition and bucket filter of FileStoreScanImpl

[ https://issues.apache.org/jira/browse/FLINK-25803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-25803: Assignee: Caizhi Weng > Implement partition and bucket filter of FileStoreScanImpl >

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

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

[jira] [Updated] (FLINK-25803) Implement partition and bucket filter of FileStoreScanImpl

[ https://issues.apache.org/jira/browse/FLINK-25803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-25803: Description: Implements partition and bucket filter in FileStoreScanImpl. Also perform some small

[jira] [Updated] (FLINK-25803) Implement partition and bucket filter of FileStoreScanImpl

[ https://issues.apache.org/jira/browse/FLINK-25803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-25803: Description: Implement partition and bucket filter in FileStoreScanImpl. Also perform some small

[GitHub] [flink] flinkbot edited a comment on pull request #18460: [FLINK-25767][doc] Totally translated state.md into Chinese

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

[GitHub] [flink] renxiaoyao opened a new pull request #18499: [hotfix][docs] Fixed error for Hive ZH docs.

renxiaoyao opened a new pull request #18499: URL: https://github.com/apache/flink/pull/18499 ## What is the purpose of the change *Fixed error for Hive ZH docs.* ## Brief change log - *"一下"* updated to *"以下"* ## Verifying this change ## Does t

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

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

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

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

[GitHub] [flink] flinkbot commented on pull request #18499: [hotfix][docs] Fixed error for Hive ZH docs.

flinkbot commented on pull request #18499: URL: https://github.com/apache/flink/pull/18499#issuecomment-1020917616 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 #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

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

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

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

[GitHub] [flink] flinkbot commented on pull request #18499: [hotfix][docs] Fixed error for Hive ZH docs.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #18499: [hotfix][docs] Fixed error for Hive ZH docs.

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

[GitHub] [flink] twalthr closed pull request #18290: [FLINK-25391][connectors][formats] Update existing table factories/format factories for catalog table options forwarding

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

[jira] [Closed] (FLINK-25391) Updating existing table factories for mutable table options

[ https://issues.apache.org/jira/browse/FLINK-25391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25391. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: commit fa161d3c5636370f5129320a9c

[GitHub] [flink] dianfu commented on a change in pull request #18418: [FLINK-25719][python] Support General Python UDF in Thread Mode

dianfu commented on a change in pull request #18418: URL: https://github.com/apache/flink/pull/18418#discussion_r790681717 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/utils/CommonPythonUtil.java ## @@ -158,6 +158,2

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

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

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

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

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

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

[GitHub] [flink] zjureel commented on pull request #18490: [FLINK-25794][sql-runtime] Clean cache after memory segments in it after they are released to MemoryManager

zjureel commented on pull request #18490: URL: https://github.com/apache/flink/pull/18490#issuecomment-1020930174 Thanks @JingsongLi , I think I miss the operations in `MemoryManager` :( And another issue is in `BinaryHashTableTest.testBinaryHashBucketAreaNotEnoughMem`, there's no `tabl

[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 ] Yun Gao reassigned FLINK-25753: --- Assignee: Fabian Paul > KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP > ---

[jira] [Assigned] (FLINK-25673) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-25673: --- Assignee: David Morávek > AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedO

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

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

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

HuangXingBo commented on a change in pull request #18418: URL: https://github.com/apache/flink/pull/18418#discussion_r791473431 ## File path: flink-python/src/main/java/org/apache/flink/python/PythonOptions.java ## @@ -214,4 +214,25 @@ + "in

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17481648#comment-17481648 ] Martijn Visser commented on FLINK-25795: [~ana4] We need to take the recent deci

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * de880af98f24b8a8195f65bca492883ce4c05846 Azure: [FAILURE](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_r791468220 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScanImpl.java ## @@ -18,62 +18,129 @@

[jira] [Updated] (FLINK-25802) OverWindow in batch mode failed

[ https://issues.apache.org/jira/browse/FLINK-25802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25802: --- Component/s: Table SQL / Planner Table SQL / Runtime > OverWindow in batch

[GitHub] [flink] XComp commented on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

XComp commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1020945550 Thanks for the update @KarmaGYZ. I brought it up in today's release call mentioning that FLINK-25433 (which is a subtask of the efforts around introducing the `JobResultStore`;

[GitHub] [flink] KarmaGYZ commented on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

KarmaGYZ commented on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1020946947 @zjureel I think we need also ignore the `maximumCacheSizeBytes` in this case. However, there might be a lot of "if...else" in `FileExecutionGraphInfoStore`. Maybe we should r

[jira] [Commented] (FLINK-16222) Use plugins mechanism for initializing MetricReporters

[ https://issues.apache.org/jira/browse/FLINK-16222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481658#comment-17481658 ] Ada Wong commented on FLINK-16222: -- [~ana4]  > Use plugins mechanism for initializing

[jira] (FLINK-16222) Use plugins mechanism for initializing MetricReporters

[ https://issues.apache.org/jira/browse/FLINK-16222 ] Ada Wong deleted comment on FLINK-16222: -- was (Author: ana4): [~ana4]  > Use plugins mechanism for initializing MetricReporters > -- > >

[GitHub] [flink] twalthr closed pull request #18485: [FLINK-25791][table-planner] Compact ObjectIdentifier json representation

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

[GitHub] [flink] JingGe commented on pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

JingGe commented on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1020958184 Many thanks for the review! -- 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

[GitHub] [flink] JingGe commented on pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

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

[jira] [Closed] (FLINK-25791) Make ObjectIdentifier json representation simpler

[ https://issues.apache.org/jira/browse/FLINK-25791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25791. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:  commit 04f8724d088e791f0515f4ee0

[jira] [Commented] (FLINK-25794) Memory pages in LazyMemorySegmentPool should be clear after they are released to MemoryManager

[ https://issues.apache.org/jira/browse/FLINK-25794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481666#comment-17481666 ] Shammon commented on FLINK-25794: - Thanks [~lzljs3620320], I think I ignored the operati

[GitHub] [flink] flinkbot edited a comment on pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

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

[GitHub] [flink-statefun] tillrohrmann commented on a change in pull request #284: [FLINK-25775] Add Javascript SDK documentation

tillrohrmann commented on a change in pull request #284: URL: https://github.com/apache/flink-statefun/pull/284#discussion_r791504850 ## File path: docs/content/docs/sdk/js.md ## @@ -0,0 +1,267 @@ +--- +title: JavaScript +weight: 2 +type: docs +aliases: + - /sdk/js.html +--- +

[GitHub] [flink] flinkbot edited a comment on pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791509668 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/AbstractZooKeeperHaServices.java ## @@ -0,0 +1,152 @@

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481671#comment-17481671 ] Chesnay Schepler commented on FLINK-18356: -- ??the maximum memory required is 4G

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791511623 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperMultipleComponentLeaderElectionHaServices.java ##

[GitHub] [flink] dmvk commented on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

dmvk commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1020976719 Hi @zjureel, thanks for the PR. One question on the approach, why do we need to create a new implementation of the `ScheduledExecutor` instead of reusing the `ComponentMainThreadE

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791514100 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperMultipleComponentLeaderElectionHaServices.java ##

[GitHub] [flink] zentol merged pull request #17498: [FLINK-14954][rest] Add OpenAPI spec generator

zentol merged pull request #17498: URL: https://github.com/apache/flink/pull/17498 -- 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-14954) Publish OpenAPI specification of REST Monitoring API

[ https://issues.apache.org/jira/browse/FLINK-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-14954. Resolution: Fixed master: 9ab8dbd2cb25a8e11221071ed20712df2d9bf691 > Publish OpenAPI spec

[jira] [Updated] (FLINK-14954) Publish OpenAPI specification of REST Monitoring API

[ https://issues.apache.org/jira/browse/FLINK-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14954: - Issue Type: New Feature (was: Improvement) > Publish OpenAPI specification of REST Moni

[GitHub] [flink] flinkbot edited a comment on pull request #18476: [FLINK-25726][streaming] Add Global Committer as post commit topology

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

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481676#comment-17481676 ] Etienne Chauchot commented on FLINK-25771: -- [~trohrmann] thanks for pointing ou

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791518309 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -96,13 +106,17 @@ /** The prefix of the compl

[GitHub] [flink] wanglijie95 commented on pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

wanglijie95 commented on pull request #18376: URL: https://github.com/apache/flink/pull/18376#issuecomment-1020983443 Squashed commits. -- 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 specif

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 96c787f1dd4b373c00d1acb03b918c823a0

[GitHub] [flink] flinkbot edited a comment on pull request #18476: [FLINK-25726][streaming] Add Global Committer as post commit topology

flinkbot edited a comment on pull request #18476: URL: https://github.com/apache/flink/pull/18476#issuecomment-1020132926 ## CI report: * 9c24ac788a7b5c48ce690a43212bcd25d68cf667 Azure: [FAILURE](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_r791523758 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/GSFileSystem.java ## @@ -39,17 +45,67 @@ GSFileSystem(

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791524500 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -96,13 +106,17 @@ /** The prefix of the compl

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 96c787f1dd4b373c00d1acb03b918c823a0

[GitHub] [flink] flinkbot edited a comment on pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791527216 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperMultipleComponentLeaderElectionHaServices.java ##

[GitHub] [flink] KarmaGYZ commented on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

KarmaGYZ commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1020991108 @dmvk That's what we did in #18007. In this PR, we try to find which method has some specific logic and cannot use the new `schedule`. However, once we ensure that this PR is

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791529865 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperMultipleComponentLeaderElectionHaServices.java ##

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791530279 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -96,13 +106,17 @@ /** The prefix of the compl

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 96c787f1dd4b373c00d1acb03b918c823a0

[GitHub] [flink] flinkbot edited a comment on pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791531251 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -137,17 +155,37 @@ public static String getCheckpo

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

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

[GitHub] [flink] lindong28 closed pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791532138 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -555,6 +668,10 @@ public static String generateZoo

[GitHub] [flink] dannycranmer commented on pull request #18488: [FLINK-24041][connector] Fixing reversed insertion of failed requests

dannycranmer commented on pull request #18488: URL: https://github.com/apache/flink/pull/18488#issuecomment-1020996381 LGTM, 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

[GitHub] [flink] dannycranmer merged pull request #18488: [FLINK-24041][connector] Fixing reversed insertion of failed requests

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791534467 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriver.java ## @@ -0,0 +1,

[jira] [Commented] (FLINK-25794) Memory pages in LazyMemorySegmentPool should be clear after they are released to MemoryManager

[ https://issues.apache.org/jira/browse/FLINK-25794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481690#comment-17481690 ] Jingsong Lee commented on FLINK-25794: -- [~zjureel] What do you mean? Memory leak in

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 96c787f1dd4b373c00d1acb03b918c823a0

[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_r791535456 ## File path: flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/FileStoreCommitTestBase.java ## @@ -71,7 +67,7 @@ p

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](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_r791536162 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileStorePathFactory.java ## @@ -106,10 +115,12 @@ publ

[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_r791536943 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScanImpl.java ## @@ -109,34 +176,72 @@ pub

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791540131 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriver.java ## @@ -0,0 +1,

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 96c787f1dd4b373c00d1acb03b918c823a0

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

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

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

shouzuo1 commented on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1021003850 thanks -- 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. T

[GitHub] [flink] shouzuo1 removed a comment on pull request #18358: [FLINK-25651][docs] Update kafka.md

shouzuo1 removed a comment on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1021003850 thanks -- 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 com

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481697#comment-17481697 ] Yangze Guo commented on FLINK-18356: Thanks for the investigation [~gaoyunhaii]. I w

[jira] [Created] (FLINK-25804) Loading and running connector code use separated ClassLoader.

Ada Wong created FLINK-25804: Summary: Loading and running connector code use separated ClassLoader. Key: FLINK-25804 URL: https://issues.apache.org/jira/browse/FLINK-25804 Project: Flink Issue

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Priority: Blocker (was: Major) > Loading and running connector code use separated ClassLoader. > --

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Issue Type: Bug (was: New Feature) > Loading and running connector code use separated ClassLoader. > --

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Description: When we use multiple connectors could have class conflicts. This class conflict can not be

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Description: When we use multiple connectors could have class conflicts. This class conflict can not be

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 96c787f1dd4b373c00d1acb03b918c823a0

[jira] [Assigned] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-18356: Assignee: (was: Dawid Wysakowicz) > Exit code 137 returned from process > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

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

  1   2   3   4   5   6   7   8   9   >