[jira] [Commented] (FLINK-21406) Add AvroParquetFileRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-21406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409285#comment-17409285 ] Arvid Heise commented on FLINK-21406: - Thank you very much. I assigned it to you. > Add

[jira] [Assigned] (FLINK-21406) Add AvroParquetFileRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-21406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21406: --- Assignee: Jing Ge > Add AvroParquetFileRecordFormat > --- > >

[jira] [Commented] (FLINK-21406) Add AvroParquetFileRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-21406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409283#comment-17409283 ] Jing Ge commented on FLINK-21406: - I'd like to take this task. [~arvid] > Add

[jira] [Updated] (FLINK-21406) Add AvroParquetFileRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-21406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21406: Fix Version/s: (was: 1.14.0) 1.15.0 > Add AvroParquetFileRecordFormat >

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

flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * cfe260b81d988558bb94554c04cf6bb0cd5f7003 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16951: [FLINK-23807][connector/testing-framework] Use numRestarts metric to detect TaskManager termination in MiniClusterTestEnvironment

flinkbot edited a comment on pull request #16951: URL: https://github.com/apache/flink/pull/16951#issuecomment-904302794 ## CI report: * 23fae801fb3e30f167a8d08886ef9a7d199ca55c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * 5240b15bd61f4b040a2f807780b081cab6ab9113 UNKNOWN * 0157b9a476cc31fd3d430ba8fc25d07abcc9f9d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16870: [FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

flinkbot edited a comment on pull request #16870: URL: https://github.com/apache/flink/pull/16870#issuecomment-900905170 ## CI report: * 1e812199f76d734bbd35740ae1a05bcce6424ab5 Azure:

[GitHub] [flink] Airblader commented on pull request #17118: [FLINK-22603][table-planner]The digest can be produced by SourceAbilitySpec.

Airblader commented on pull request #17118: URL: https://github.com/apache/flink/pull/17118#issuecomment-912270245 > However, in classes FilterPushDownSpec and WatermarkPushDownSpec, their digest should be generated by expressions which are not in these classes. Yes, which to me

[jira] [Commented] (FLINK-24063) Reconsider the behavior of ClusterEntrypoint#startCluster failure handler

[ https://issues.apache.org/jira/browse/FLINK-24063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409278#comment-17409278 ] Yang Wang commented on FLINK-24063: --- Exactly, I am in favor of using {{STOP_PROCESS}} when

[GitHub] [flink] tweise commented on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

tweise commented on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-912266459 > @tweise do we need a MiniCluster unit test for the savepoint trigger and restore? I'm going to look into adding that to `HybridSourceITCase`. Probably outside of this

[GitHub] [flink] PatrickRen commented on a change in pull request #16951: [FLINK-23807][connector/testing-framework] Use numRestarts metric to detect TaskManager termination in MiniClusterTestEnvironm

PatrickRen commented on a change in pull request #16951: URL: https://github.com/apache/flink/pull/16951#discussion_r701591943 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java ## @@ -138,7 +138,7 @@ public RestClient(Configuration

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409274#comment-17409274 ] Xintong Song commented on FLINK-22198: --

[jira] [Commented] (FLINK-24131) KafkaSinkITCase "Detected producer leak"

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409273#comment-17409273 ] Xintong Song commented on FLINK-24131: --

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409272#comment-17409272 ] Xintong Song commented on FLINK-23848: --

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

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409271#comment-17409271 ] Xintong Song commented on FLINK-23828: --

[GitHub] [flink] PatrickRen commented on a change in pull request #16951: [FLINK-23807][connector/testing-framework] Use numRestarts metric to detect TaskManager termination in MiniClusterTestEnvironm

PatrickRen commented on a change in pull request #16951: URL: https://github.com/apache/flink/pull/16951#discussion_r701591943 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java ## @@ -138,7 +138,7 @@ public RestClient(Configuration

[jira] [Commented] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409264#comment-17409264 ] Qingsheng Ren commented on FLINK-20655: --- KafkaSourceE2ECase has been added by

[jira] [Resolved] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-20655. --- Fix Version/s: (was: 1.12.6) Resolution: Fixed > Add E2E tests to the new

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

flinkbot edited a comment on pull request #17130: URL: https://github.com/apache/flink/pull/17130#issuecomment-912140775 ## CI report: * Unknown: [CANCELED](TBD) * ec15d9e3bf68e10a3c39b8b44029a19ec288e7b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16951: [FLINK-23807][connector/testing-framework] Use numRestarts metric to detect TaskManager termination in MiniClusterTestEnvironment

flinkbot edited a comment on pull request #16951: URL: https://github.com/apache/flink/pull/16951#issuecomment-904302794 ## CI report: * 23fae801fb3e30f167a8d08886ef9a7d199ca55c Azure:

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

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

[GitHub] [flink] tweise commented on a change in pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

tweise commented on a change in pull request #17111: URL: https://github.com/apache/flink/pull/17111#discussion_r701572276 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/SwitchedSources.java ## @@ -0,0 +1,48 @@

[jira] [Commented] (FLINK-24120) The memory will rise a little after each savepoint ends

[ https://issues.apache.org/jira/browse/FLINK-24120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409257#comment-17409257 ] Jiayi Liao commented on FLINK-24120: [~trohrmann] Okay, will add this today. > The memory will

[GitHub] [flink] Aitozi commented on pull request #17130: [BP-1.14][FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on pull request #17130: URL: https://github.com/apache/flink/pull/17130#issuecomment-912237371 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #16644: [FLINK-23551][Connectors/ORC] Bump ORC to 1.6.10

flinkbot edited a comment on pull request #16644: URL: https://github.com/apache/flink/pull/16644#issuecomment-889635734 ## CI report: * 26bc2f11f27cc400b81fcfaf961d015d18152e65 Azure:

[GitHub] [flink] stevenzwu commented on a change in pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

stevenzwu commented on a change in pull request #17111: URL: https://github.com/apache/flink/pull/17111#discussion_r701565334 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/SwitchedSources.java ## @@ -0,0 +1,48

[GitHub] [flink] flinkbot edited a comment on pull request #17131: [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

flinkbot edited a comment on pull request #17131: URL: https://github.com/apache/flink/pull/17131#issuecomment-912215283 ## CI report: * 7d6995d8f94fe01c45ea479de175f51ff4a64ac5 Azure:

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

flinkbot edited a comment on pull request #17130: URL: https://github.com/apache/flink/pull/17130#issuecomment-912140775 ## CI report: * 24a617df3a74b2786eb6bf8bbcbc2a026813486d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17125: [BP-1.14][FLINK-20427][runtime/checkpointing] Remove prefer-checkpoint-for-recovery setting

flinkbot edited a comment on pull request #17125: URL: https://github.com/apache/flink/pull/17125#issuecomment-911781687 ## CI report: * ea444a69b2f2cc28790a9d31ae7c9c7a3c9da462 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17117: [FLINK-24023][runtime-web] The names of metrics are incomplete

flinkbot edited a comment on pull request #17117: URL: https://github.com/apache/flink/pull/17117#issuecomment-911516830 ## CI report: * f3efff0d0df3652545e98e02ecd1b3dbfd3ba65f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

flinkbot edited a comment on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * f51e8b846e00a7d5269a0689ac6e6d9d458d2bf6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16980: [FLINK-23111][runtime-web] Fix monaco editor async setup

flinkbot edited a comment on pull request #16980: URL: https://github.com/apache/flink/pull/16980#issuecomment-905413099 ## CI report: * b58ae32613a2ad0a818b5821ce592f92a6a64627 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * 5240b15bd61f4b040a2f807780b081cab6ab9113 UNKNOWN * 60fd053ee3917617f82896d0ccdb43af26b3261e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * 61cc9c310c02dea756bc02436d7fab4654caaa1a UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #17131: [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

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

[GitHub] [flink] flinkbot edited a comment on pull request #17123: [FLINK-24096][checkpoint] Skip the complete notification for checkpoints before task startup

flinkbot edited a comment on pull request #17123: URL: https://github.com/apache/flink/pull/17123#issuecomment-911684941 ## CI report: * c51fa298dec3259abd4ffba2e38f3be10e2f9986 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17117: [FLINK-24023][runtime-web] The names of metrics are incomplete

flinkbot edited a comment on pull request #17117: URL: https://github.com/apache/flink/pull/17117#issuecomment-911516830 ## CI report: * f3efff0d0df3652545e98e02ecd1b3dbfd3ba65f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

flinkbot edited a comment on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * f51e8b846e00a7d5269a0689ac6e6d9d458d2bf6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16980: [FLINK-23111][runtime-web] Fix monaco editor async setup

flinkbot edited a comment on pull request #16980: URL: https://github.com/apache/flink/pull/16980#issuecomment-905413099 ## CI report: * b58ae32613a2ad0a818b5821ce592f92a6a64627 Azure:

[GitHub] [flink] amazingJing commented on a change in pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

amazingJing commented on a change in pull request #16969: URL: https://github.com/apache/flink/pull/16969#discussion_r701550055 ## File path:

[GitHub] [flink] amazingJing commented on a change in pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

amazingJing commented on a change in pull request #16969: URL: https://github.com/apache/flink/pull/16969#discussion_r701549957 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * 5240b15bd61f4b040a2f807780b081cab6ab9113 UNKNOWN * 60fd053ee3917617f82896d0ccdb43af26b3261e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * 61cc9c310c02dea756bc02436d7fab4654caaa1a UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16644: [FLINK-23551][Connectors/ORC] Bump ORC to 1.6.10

flinkbot edited a comment on pull request #16644: URL: https://github.com/apache/flink/pull/16644#issuecomment-889635734 ## CI report: * 15e1227b21aee0e756979f7a4a5293c05366d9f4 Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint

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

[GitHub] [flink] flinkbot commented on pull request #17131: [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

flinkbot commented on pull request #17131: URL: https://github.com/apache/flink/pull/17131#issuecomment-912211413 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] xuyangzhong commented on pull request #17118: [FLINK-22603][table-planner]The digest can be produced by SourceAbilitySpec.

xuyangzhong commented on pull request #17118: URL: https://github.com/apache/flink/pull/17118#issuecomment-912210846 @Airblader Hi，thanks to review my immature code, and i want to explain why the implement function _getExtraDigests_ needs an _Optional_ arg. -- In the

[jira] [Updated] (FLINK-24068) CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint

[ https://issues.apache.org/jira/browse/FLINK-24068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24068: --- Labels: pull-request-available (was: ) > CheckpointBarrierHandler may skip the

[jira] [Updated] (FLINK-22859) Wordcount on Docker test (custom fs plugin) fails due to output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-22859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22859: - Affects Version/s: 1.15.0 > Wordcount on Docker test (custom fs plugin) fails due to output

[GitHub] [flink] gaoyunhaii opened a new pull request #17131: [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

gaoyunhaii opened a new pull request #17131: URL: https://github.com/apache/flink/pull/17131 ## What is the purpose of the change This PR fixed that in a special case described in https://issues.apache.org/jira/browse/FLINK-24068, the `markAlignmentStart` method is skipped wrongly.

[jira] [Updated] (FLINK-22859) Wordcount on Docker test (custom fs plugin) fails due to output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-22859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22859: - Fix Version/s: 1.15.0 1.14.0 > Wordcount on Docker test (custom fs plugin)

[jira] [Commented] (FLINK-22859) Wordcount on Docker test (custom fs plugin) fails due to output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-22859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409232#comment-17409232 ] Xintong Song commented on FLINK-22859: --

[jira] [Reopened] (FLINK-22859) Wordcount on Docker test (custom fs plugin) fails due to output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-22859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-22859: -- > Wordcount on Docker test (custom fs plugin) fails due to output hash mismatch >

[jira] [Commented] (FLINK-23242) Translate the page of "Handling Application Parameters" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409231#comment-17409231 ] Jark Wu commented on FLINK-23242: - Fixed in - master: 22f7feb2f390121e0f3d399709a0103651f7a0a3 -

[jira] [Closed] (FLINK-23242) Translate the page of "Handling Application Parameters" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23242. --- Fix Version/s: (was: 1.13.0) 1.15.0 1.14.0 Resolution:

[GitHub] [flink] wuchong merged pull request #16949: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese

wuchong merged pull request #16949: URL: https://github.com/apache/flink/pull/16949 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] wuchong commented on pull request #17117: [FLINK-24023][runtime-web] The names of metrics are incomplete

wuchong commented on pull request #17117: URL: https://github.com/apache/flink/pull/17117#issuecomment-912209101 @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] yangjunhan commented on a change in pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

yangjunhan commented on a change in pull request #16902: URL: https://github.com/apache/flink/pull/16902#discussion_r701543304 ## File path: flink-runtime-web/web-dashboard/package.json ## @@ -6,7 +6,9 @@ "start": "ng serve", "build": "ng build --configuration

[GitHub] [flink] flinkbot edited a comment on pull request #17123: [FLINK-24096][checkpoint] Skip the complete notification for checkpoints before task startup

flinkbot edited a comment on pull request #17123: URL: https://github.com/apache/flink/pull/17123#issuecomment-911684941 ## CI report: * c51fa298dec3259abd4ffba2e38f3be10e2f9986 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * d7e21cf9f605da064358246d716efd8a4f3be7ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16870: [FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

flinkbot edited a comment on pull request #16870: URL: https://github.com/apache/flink/pull/16870#issuecomment-900905170 ## CI report: * 1e812199f76d734bbd35740ae1a05bcce6424ab5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16644: [FLINK-23551][Connectors/ORC] Bump ORC to 1.6.10

flinkbot edited a comment on pull request #16644: URL: https://github.com/apache/flink/pull/16644#issuecomment-889635734 ## CI report: * 15e1227b21aee0e756979f7a4a5293c05366d9f4 Azure:

[GitHub] [flink] vthinkxie commented on pull request #17117: [FLINK-24023][runtime-web] The names of metrics are incomplete

vthinkxie commented on pull request #17117: URL: https://github.com/apache/flink/pull/17117#issuecomment-912197441 cc @yangjunhan -- 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-24136) OverAggregateITCase.testRowTimeBoundedPartitionedRangeOver test failed with NPE

[ https://issues.apache.org/jira/browse/FLINK-24136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24136. --- Resolution: Duplicate > OverAggregateITCase.testRowTimeBoundedPartitionedRangeOver test failed with > NPE

[jira] [Assigned] (FLINK-24068) CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint

[ https://issues.apache.org/jira/browse/FLINK-24068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-24068: --- Assignee: Yun Gao > CheckpointBarrierHandler may skip the markAlignmentStart for alignment >

[jira] [Commented] (FLINK-24024) Support session Window TVF

[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409209#comment-17409209 ] godfrey he commented on FLINK-24024: yes, Only "34d51002796afd800fc99d47e3dd06acbd403531"

[jira] [Assigned] (FLINK-24134) Docker "Enabling Python" documentation results in failed Docker builds

[ https://issues.apache.org/jira/browse/FLINK-24134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-24134: --- Assignee: Dian Fu > Docker "Enabling Python" documentation results in failed Docker builds >

[jira] [Updated] (FLINK-24134) Docker "Enabling Python" documentation results in failed Docker builds

[ https://issues.apache.org/jira/browse/FLINK-24134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24134: Fix Version/s: 1.14.0 > Docker "Enabling Python" documentation results in failed Docker builds >

[jira] [Commented] (FLINK-24134) Docker "Enabling Python" documentation results in failed Docker builds

[ https://issues.apache.org/jira/browse/FLINK-24134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409208#comment-17409208 ] Dian Fu commented on FLINK-24134: - [~adamhp] Good catch, the documentation should be updated as of the

[jira] [Resolved] (FLINK-24105) state TTL might not take effect for pyflink

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

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * d7e21cf9f605da064358246d716efd8a4f3be7ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16870: [FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

flinkbot edited a comment on pull request #16870: URL: https://github.com/apache/flink/pull/16870#issuecomment-900905170 ## CI report: * 1e812199f76d734bbd35740ae1a05bcce6424ab5 Azure:

[GitHub] [flink] HuangXingBo closed pull request #17115: [FLINK-24105][python] Fix the state ttl does not take effect in PyFlink

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

[jira] [Created] (FLINK-24136) OverAggregateITCase.testRowTimeBoundedPartitionedRangeOver test failed with NPE

Huang Xingbo created FLINK-24136: Summary: OverAggregateITCase.testRowTimeBoundedPartitionedRangeOver test failed with NPE Key: FLINK-24136 URL: https://issues.apache.org/jira/browse/FLINK-24136

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

lometheus commented on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-912188983 @pnowojski flinknot seems doesn't work anymore, how can I deal with this condition -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] PatrickRen commented on pull request #16870: [FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

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

[GitHub] [flink] flinkbot edited a comment on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

flinkbot edited a comment on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-911126675 ## CI report: * 8b30569b39cab81ad02bf35d6c6064e8c3cc18b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run travis`

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

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

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

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

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

flinkbot edited a comment on pull request #17130: URL: https://github.com/apache/flink/pull/17130#issuecomment-912140775 ## CI report: * 24a617df3a74b2786eb6bf8bbcbc2a026813486d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

flinkbot edited a comment on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-911126675 ## CI report: * 8b30569b39cab81ad02bf35d6c6064e8c3cc18b3 Azure:

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

flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * cfe260b81d988558bb94554c04cf6bb0cd5f7003 UNKNOWN *

[GitHub] [flink] paul8263 commented on pull request #17117: [FLINK-24023][runtime-web] The names of metrics are incomplete

paul8263 commented on pull request #17117: URL: https://github.com/apache/flink/pull/17117#issuecomment-912162345 Hi @wuchong ， Before change：  After change：

[GitHub] [flink] flinkbot commented on pull request #17130: [BP-1.14][FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

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

[GitHub] [flink] flinkbot edited a comment on pull request #17125: [BP-1.14][FLINK-20427][runtime/checkpointing] Remove prefer-checkpoint-for-recovery setting

flinkbot edited a comment on pull request #17125: URL: https://github.com/apache/flink/pull/17125#issuecomment-911781687 ## CI report: * f1c506bd33f2b6f4e734cfdf4d7874c451155b3f Azure:

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

flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * cfe260b81d988558bb94554c04cf6bb0cd5f7003 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #17129: [WIP][FLINK-23654][runtime] Splitting IO and future threadpools and adding advanced configurations

flinkbot edited a comment on pull request #17129: URL: https://github.com/apache/flink/pull/17129#issuecomment-912007622 ## CI report: * aab2726dba970eb806c76c9b4d84f0a358d41c38 Azure:

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

flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * cfe260b81d988558bb94554c04cf6bb0cd5f7003 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #17130: [BP-1.14][FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

flinkbot commented on pull request #17130: URL: https://github.com/apache/flink/pull/17130#issuecomment-912131901 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] Aitozi commented on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-912131194 -- 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

[GitHub] [flink] Aitozi opened a new pull request #17130: [BP-1.14][FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi opened a new pull request #17130: URL: https://github.com/apache/flink/pull/17130 …andledErrorListener before start zk client Backport of [#17053](https://github.com/apache/flink/pull/17053) to release-1.14. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] Aitozi commented on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-912127341 Having addressed all your concerns, thanks for your review time @tillrohrmann -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] Aitozi commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701483653 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -110,10 +113,18 @@ public String

[GitHub] [flink] Aitozi commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701481899 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java ## @@ -213,7 +234,16 @@ private RestClusterClient(

[GitHub] [flink] Aitozi commented on a change in pull request #17129: [WIP][FLINK-23654][runtime] Splitting IO and future threadpools and adding advanced configurations

Aitozi commented on a change in pull request #17129: URL: https://github.com/apache/flink/pull/17129#discussion_r701472134 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerSharedServices.java ## @@ -147,10 +164,18 @@ public static

[GitHub] [flink] flinkbot edited a comment on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

flinkbot edited a comment on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-911126675 ## CI report: * 8b30569b39cab81ad02bf35d6c6064e8c3cc18b3 Azure:

[GitHub] [flink] nicolasraga1 commented on a change in pull request #16946: [FLINK-23654][runtime] Splitting IO and future threadpools and adding advanced configurations

nicolasraga1 commented on a change in pull request #16946: URL: https://github.com/apache/flink/pull/16946#discussion_r701452922 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerSharedServicesTest.java ## @@ -0,0 +1,161 @@ +/* + *

[GitHub] [flink] nicolasraga1 commented on a change in pull request #16946: [FLINK-23654][runtime] Splitting IO and future threadpools and adding advanced configurations

nicolasraga1 commented on a change in pull request #16946: URL: https://github.com/apache/flink/pull/16946#discussion_r701452922 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerSharedServicesTest.java ## @@ -0,0 +1,161 @@ +/* + *

  1   2   3   4   5   6   7   >