[jira] [Commented] (FLINK-26726) Remove the unregistered task from readersAwaitingSplit

2022-03-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509611#comment-17509611 ] Jingsong Lee commented on FLINK-26726: -- FLINK-20261 is the Jira to fix this bug in

[GitHub] [flink] ChengkaiYang2022 commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-20 Thread GitBox
ChengkaiYang2022 commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r830772654 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -63,60 +65,57 @@ metrics.reporter.my_other_reporter.host: 192.168.1.1

[GitHub] [flink] ChengkaiYang2022 commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-20 Thread GitBox
ChengkaiYang2022 commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r830772455 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -24,31 +24,33 @@ specific language governing permissions and limitations

[GitHub] [flink] ChengkaiYang2022 commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-20 Thread GitBox
ChengkaiYang2022 commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r830772272 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -63,60 +65,57 @@ metrics.reporter.my_other_reporter.host: 192.168.1.1

[jira] [Commented] (FLINK-26726) Remove the unregistered task from readersAwaitingSplit

2022-03-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509608#comment-17509608 ] Jingsong Lee commented on FLINK-26726: -- I think your analysis is correct. And the

[GitHub] [flink] flinkbot edited a comment on pull request #19112: [FLINK-26678][shell] replace the repeated log4j-console.properties wi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19112: URL: https://github.com/apache/flink/pull/19112#issuecomment-1068959010 ## CI report: * 10e2d2ce4923e1e889f788c5bd94a478fd1e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 40fab1b924f370c0d3bc198edf08b38746d62231 Azure:

[jira] [Assigned] (FLINK-26734) Various usage examples of adding window operation

2022-03-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-26734: --- Assignee: zhangjingcun > Various usage examples of adding window operation >

[GitHub] [flink] flinkbot edited a comment on pull request #19149: [FLINK-26732][runtime] logs key info for DefaultResourceAllocationStr…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19149: URL: https://github.com/apache/flink/pull/19149#issuecomment-1072262288 ## CI report: * 7eb9959542a0172d3b469ee2e6552168f7454918 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flin

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1046819200 ## CI report: * 91a7606c4cc74c8e848073dbf16e400a00910350 Azure:

[jira] [Updated] (FLINK-26664) Improve Python exception messages to be more Pythonic in PyFlink

2022-03-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26664: Fix Version/s: 1.16.0 > Improve Python exception messages to be more Pythonic in PyFlink >

[jira] [Updated] (FLINK-26621) flink-tests failed on azure due to Error occurred in starting fork

2022-03-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26621: Priority: Critical (was: Major) > flink-tests failed on azure due to Error occurred in starting fork >

[jira] [Commented] (FLINK-26621) flink-tests failed on azure due to Error occurred in starting fork

2022-03-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509605#comment-17509605 ] Yun Gao commented on FLINK-26621: - 1.15:

[jira] [Commented] (FLINK-26754) KafkaCommitterTest#testRetryCommittableOnRetriableError stuck

2022-03-20 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509606#comment-17509606 ] Aitozi commented on FLINK-26754: After checking the master branch, I found it has been fixed, closing it

[jira] [Closed] (FLINK-26754) KafkaCommitterTest#testRetryCommittableOnRetriableError stuck

2022-03-20 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-26754. -- Resolution: Duplicate > KafkaCommitterTest#testRetryCommittableOnRetriableError stuck >

[GitHub] [flink] dianfu commented on a change in pull request #19150: [FLINK-26727][python] Fix the implementation of sub-interpreter in Thread Mode

2022-03-20 Thread GitBox
dianfu commented on a change in pull request #19150: URL: https://github.com/apache/flink/pull/19150#discussion_r830760361 ## File path: docs/content.zh/docs/dev/python/python_execution_mode.md ## @@ -31,61 +31,48 @@ defines how to execute your customized Python functions.

[GitHub] [flink] flinkbot edited a comment on pull request #19175: [FLINK-26758][container][JUnit5 Migration] Module: flink-container

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19175: URL: https://github.com/apache/flink/pull/19175#issuecomment-1073483120 ## CI report: * a1a679dcf4415150f8abc5a71d909b04ec8a303b Azure:

[jira] [Created] (FLINK-26759) Legacy source support waiting for recordWriter to be available

2022-03-20 Thread fanrui (Jira)
fanrui created FLINK-26759: -- Summary: Legacy source support waiting for recordWriter to be available Key: FLINK-26759 URL: https://issues.apache.org/jira/browse/FLINK-26759 Project: Flink Issue

[GitHub] [flink] RocMarshal commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-20 Thread GitBox
RocMarshal commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r830757535 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -24,31 +24,33 @@ specific language governing permissions and limitations

[GitHub] [flink] RocMarshal commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-20 Thread GitBox
RocMarshal commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r830757535 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -24,31 +24,33 @@ specific language governing permissions and limitations

[GitHub] [flink] flinkbot edited a comment on pull request #19175: [FLINK-26758][container][JUnit5 Migration] Module: flink-container

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19175: URL: https://github.com/apache/flink/pull/19175#issuecomment-1073483120 ## CI report: * a1a679dcf4415150f8abc5a71d909b04ec8a303b UNKNOWN Bot commands The @flinkbot bot supports the following commands: -

[jira] (FLINK-26448) Disable tests in KafkaSourceLegacyITCase for test stability issues

2022-03-20 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26448 ] Aitozi deleted comment on FLINK-26448: was (Author: aitozi): Hi [~jingge] ,  what's the problem with the kafka test env with 1 broker? Does the https://issues.apache.org/jira/browse/FLINK-26754

[GitHub] [flink] flinkbot commented on pull request #19175: [FLINK-26758][container][JUnit5 Migration] Module: flink-container

2022-03-20 Thread GitBox
flinkbot commented on pull request #19175: URL: https://github.com/apache/flink/pull/19175#issuecomment-1073483120 ## CI report: * bdb7820a61a670c256b81c6a06d8c4b91e9f83ae UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-26758) [JUnit5 Migration] Module: flink-container

2022-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26758: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Module: flink-container >

[GitHub] [flink] RocMarshal opened a new pull request #19175: [FLINK-26758][container][JUnit5 Migration] Module: flink-container

2022-03-20 Thread GitBox
RocMarshal opened a new pull request #19175: URL: https://github.com/apache/flink/pull/19175 ## What is the purpose of the change [JUnit5 Migration] Module: flink-container ## Brief change log [JUnit5 Migration] Module: flink-container ##

[GitHub] [flink] flinkbot edited a comment on pull request #19174: [FLINK-26673][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19174: URL: https://github.com/apache/flink/pull/19174#issuecomment-1073450230 ## CI report: * 3882836ba23eabdc8f33057fcfd9a2cf764ca2af Azure:

[jira] [Created] (FLINK-26758) [JUnit5 Migration] Module: flink-container

2022-03-20 Thread RocMarshal (Jira)
RocMarshal created FLINK-26758: -- Summary: [JUnit5 Migration] Module: flink-container Key: FLINK-26758 URL: https://issues.apache.org/jira/browse/FLINK-26758 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * 796355ca2b22a9485ab2875c2683c01f4f85f014 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19174: [FLINK-26673][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19174: URL: https://github.com/apache/flink/pull/19174#issuecomment-1073450230 ## CI report: * 3882836ba23eabdc8f33057fcfd9a2cf764ca2af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19174: [FLINK-26673][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19174: URL: https://github.com/apache/flink/pull/19174#issuecomment-1073450230 ## CI report: * 3882836ba23eabdc8f33057fcfd9a2cf764ca2af Azure:

[GitHub] [flink] curcur commented on pull request #19062: [FLINK-26592][state/changelog] Use mailbox in FsStateChangelogWriter instead of a lock

2022-03-20 Thread GitBox
curcur commented on pull request #19062: URL: https://github.com/apache/flink/pull/19062#issuecomment-1073473660 Hey Roman, I am a bit confused with the logic of `BatchingStateChangeUploadScheduler#upload` (sorry although not quite related to this fix), but relating to why the deadlock

[GitHub] [flink] flinkbot edited a comment on pull request #19174: [FLINK-26673][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19174: URL: https://github.com/apache/flink/pull/19174#issuecomment-1073450230 ## CI report: * 3882836ba23eabdc8f33057fcfd9a2cf764ca2af Azure:

[jira] [Commented] (FLINK-26754) KafkaCommitterTest#testRetryCommittableOnRetriableError stuck

2022-03-20 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509592#comment-17509592 ] Aitozi commented on FLINK-26754: After looking into this, it's caused by the kafka producer have pending

[GitHub] [flink] flinkbot edited a comment on pull request #19174: [FLINK-26673][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19174: URL: https://github.com/apache/flink/pull/19174#issuecomment-1073450230 ## CI report: * 3882836ba23eabdc8f33057fcfd9a2cf764ca2af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19174: [FLINK-26673][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19174: URL: https://github.com/apache/flink/pull/19174#issuecomment-1073450230 ## CI report: * 3882836ba23eabdc8f33057fcfd9a2cf764ca2af Azure:

[GitHub] [flink] fredia edited a comment on pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2022-03-20 Thread GitBox
fredia edited a comment on pull request #19033: URL: https://github.com/apache/flink/pull/19033#issuecomment-1073462371 @Aitozi Thank you for your interest. As you mentioned, > we could always choose one as the base db, since the DeleteRange can finish in no time. In theory,

[GitHub] [flink] ZhangChaoming commented on pull request #18241: [hotfix][runtime] Remove unnecessary method.

2022-03-20 Thread GitBox
ZhangChaoming commented on pull request #18241: URL: https://github.com/apache/flink/pull/18241#issuecomment-1073464095 @pnowojski Could you please help to check this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot edited a comment on pull request #19174: [FLINK-26673][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19174: URL: https://github.com/apache/flink/pull/19174#issuecomment-1073450230 ## CI report: * 3882836ba23eabdc8f33057fcfd9a2cf764ca2af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * c53142c8b103fd6da55bb95d600d59a01e1f3198 Azure:

[jira] [Updated] (FLINK-26757) change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold

2022-03-20 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-26757: --- Affects Version/s: 1.16.0 > change the default value of >

[GitHub] [flink] fredia commented on pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2022-03-20 Thread GitBox
fredia commented on pull request #19033: URL: https://github.com/apache/flink/pull/19033#issuecomment-1073462371 @Aitozi Thank you for your interest. As you mentioned, > we could always choose one as the base db, since the DeleteRange can finish in no time. In theory, setting

[jira] [Closed] (FLINK-26715) E2E tests should cover different watchNamespace scenarios

2022-03-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-26715. - Resolution: Fixed > E2E tests should cover different watchNamespace scenarios >

[jira] [Commented] (FLINK-26715) E2E tests should cover different watchNamespace scenarios

2022-03-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509588#comment-17509588 ] Yang Wang commented on FLINK-26715: --- Fixed via: master: aa661776448bd0ae87f3f8d5ddf7d7dd168ae0b1 >

[jira] [Updated] (FLINK-26673) ChangelogPeriodicMaterializationITCase.testNonMaterialization failed on master with IllegalStateException

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

[GitHub] [flink] flinkbot edited a comment on pull request #19174: [FLINK-26673][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19174: URL: https://github.com/apache/flink/pull/19174#issuecomment-1073450230 ## CI report: * 3882836ba23eabdc8f33057fcfd9a2cf764ca2af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * c53142c8b103fd6da55bb95d600d59a01e1f3198 Azure:

[jira] [Commented] (FLINK-26700) Update chinese documentation regarding restore modes

2022-03-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509586#comment-17509586 ] Yun Tang commented on FLINK-26700: -- [~Feifan Wang], I could help you to do this. > Update chinese

[jira] [Created] (FLINK-26757) change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold

2022-03-20 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-26757: -- Summary: change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold Key: FLINK-26757 URL: https://issues.apache.org/jira/browse/FLINK-26757

[GitHub] [flink] flinkbot edited a comment on pull request #19156: decouple-hive-planer

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19156: URL: https://github.com/apache/flink/pull/19156#issuecomment-1072382647 ## CI report: * 63ba72e01880dde4b07267f752898d0658f587a6 Azure:

[jira] [Commented] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

2022-03-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509584#comment-17509584 ] Yun Tang commented on FLINK-26738: -- [~lam167], what kind of NPE will you meet? Once the state

[GitHub] [flink] zhuzhurk commented on a change in pull request #19152: [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source

2022-03-20 Thread GitBox
zhuzhurk commented on a change in pull request #19152: URL: https://github.com/apache/flink/pull/19152#discussion_r830729038 ## File path: flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/TpcdsTestProgram.java ## @@ -157,34 +166,33 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #19174: [FLINK-5151][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19174: URL: https://github.com/apache/flink/pull/19174#issuecomment-1073450230 ## CI report: * 3882836ba23eabdc8f33057fcfd9a2cf764ca2af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19156: decouple-hive-planer

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19156: URL: https://github.com/apache/flink/pull/19156#issuecomment-1072382647 ## CI report: * 63ba72e01880dde4b07267f752898d0658f587a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19007: [FLINK-26495][table-planner] Prohibit hints(dynamic table options) on view

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19007: URL: https://github.com/apache/flink/pull/19007#issuecomment-1061572668 ## CI report: * 0d31d06f83380837c10e07dd1ab8a7c6a2816ea8 Azure:

[jira] [Commented] (FLINK-26756) Failed to deserialize for match recognize

2022-03-20 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509583#comment-17509583 ] godfrey he commented on FLINK-26756: cc [~twalthr] > Failed to deserialize for match recognize >

[jira] [Commented] (FLINK-26683) Terminate the job anyway if savepoint finished when stop-with-savepoint

2022-03-20 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509582#comment-17509582 ] Liu commented on FLINK-26683: - Hi, [~dwysakowicz]. Can you have a look at this question? Thank you. >

[jira] [Updated] (FLINK-26756) Failed to deserialize for match recognize

2022-03-20 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-26756: --- Fix Version/s: 1.15.0 > Failed to deserialize for match recognize >

[jira] [Created] (FLINK-26756) Failed to deserialize for match recognize

2022-03-20 Thread godfrey he (Jira)
godfrey he created FLINK-26756: -- Summary: Failed to deserialize for match recognize Key: FLINK-26756 URL: https://issues.apache.org/jira/browse/FLINK-26756 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #19174: [FLINK-5151][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
flinkbot commented on pull request #19174: URL: https://github.com/apache/flink/pull/19174#issuecomment-1073450230 ## CI report: * 3882836ba23eabdc8f33057fcfd9a2cf764ca2af UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19007: [FLINK-26495][table-planner] Prohibit hints(dynamic table options) on view

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19007: URL: https://github.com/apache/flink/pull/19007#issuecomment-1061572668 ## CI report: * 0d31d06f83380837c10e07dd1ab8a7c6a2816ea8 Azure:

[GitHub] [flink] masteryhx opened a new pull request #19174: [FLINK-5151][changelog] Disable periodic materialization when periodi…

2022-03-20 Thread GitBox
masteryhx opened a new pull request #19174: URL: https://github.com/apache/flink/pull/19174 ## What is the purpose of the change Do not start periodic materialization when periodicMaterializeDelay is negative. ## Brief change log - check

[jira] [Commented] (FLINK-26689) Replace TableConfig with ReadableConfig where possible

2022-03-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509578#comment-17509578 ] Jingsong Lee commented on FLINK-26689: -- Can we do this in release-1.15 too? > Replace TableConfig

[jira] [Commented] (FLINK-24892) FLIP-187: Adaptive Batch Scheduler

2022-03-20 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509577#comment-17509577 ] Lijie Wang commented on FLINK-24892: [~zhuzh] Yes, I've added it   > FLIP-187: Adaptive Batch

[GitHub] [flink] flinkbot edited a comment on pull request #19150: [FLINK-26727][python] Fix the implementation of sub-interpreter in Thread Mode

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19150: URL: https://github.com/apache/flink/pull/19150#issuecomment-1072276017 ## CI report: * e582f0f456cfa5d3848dd95bf6a9793f79151ab8 Azure:

[jira] [Created] (FLINK-26755) Cleanup inprogressfileRecoverable for FileSink on restoring

2022-03-20 Thread Yun Gao (Jira)
Yun Gao created FLINK-26755: --- Summary: Cleanup inprogressfileRecoverable for FileSink on restoring Key: FLINK-26755 URL: https://issues.apache.org/jira/browse/FLINK-26755 Project: Flink Issue

[jira] [Closed] (FLINK-26151) inprogressfileRecoverable not be clean up after restoring the bucket

2022-03-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26151. --- Fix Version/s: 1.16.0 Resolution: Fixed > inprogressfileRecoverable not be clean up after restoring

[jira] [Assigned] (FLINK-26151) inprogressfileRecoverable not be clean up after restoring the bucket

2022-03-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-26151: --- Assignee: WangXiaoyong > inprogressfileRecoverable not be clean up after restoring the bucket >

[jira] [Commented] (FLINK-26151) inprogressfileRecoverable not be clean up after restoring the bucket

2022-03-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509576#comment-17509576 ] Yun Gao commented on FLINK-26151: - Merged on master via 1fa91ba6ab515aa0e7ab88cc165fe571b60ee37f Merged

[jira] [Commented] (FLINK-26448) Disable tests in KafkaSourceLegacyITCase for test stability issues

2022-03-20 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509575#comment-17509575 ] Aitozi commented on FLINK-26448: Hi [~jingge] ,  what's the problem with the kafka test env with 1

[jira] [Closed] (FLINK-24892) FLIP-187: Adaptive Batch Scheduler

2022-03-20 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang closed FLINK-24892. -- Release Note: In 1.15, we introduced a new scheduler to Flink: Adaptive Batch Scheduler. The new

[GitHub] [flink] gaoyunhaii commented on pull request #18776: [FLINK-26151][streaming]Avoid inprogressfileRecoverable not be clean up after restoring the bucket

2022-03-20 Thread GitBox
gaoyunhaii commented on pull request #18776: URL: https://github.com/apache/flink/pull/18776#issuecomment-1073443106 @lovewin99 The PR is now merged on master / release-1.15, thus it is closed. Thanks for the PR! -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #19173: [FLINK-26536][python] Fix RemoteKeyedStateBackend#merge_namespaces to handle properly for the timerservice

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19173: URL: https://github.com/apache/flink/pull/19173#issuecomment-1073438378 ## CI report: * 4e3d338d9e385eaa39ff75a8757193476527bbe2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19150: [FLINK-26727][python] Fix the implementation of sub-interpreter in Thread Mode

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19150: URL: https://github.com/apache/flink/pull/19150#issuecomment-1072276017 ## CI report: * 84b9b34a4e070b391b7c11d022ba985dd71b3db9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19171: [BP-1.14][FLINK-26381][docs] Wrong document order of Chinese version

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19171: URL: https://github.com/apache/flink/pull/19171#issuecomment-1073395169 ## CI report: * 4a7a8f95af51cd77b31fbaaa4d108c392e89336c Azure:

[jira] [Resolved] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

2022-03-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-21321. -- Resolution: Fixed merged in master: b6822f293e24263752419e49f8b7910f4e0464a8 and

[jira] [Comment Edited] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2022-03-20 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509569#comment-17509569 ] dalongliu edited comment on FLINK-22315 at 3/21/22, 3:13 AM: - The column

[GitHub] [flink] Myasuka closed pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2022-03-20 Thread GitBox
Myasuka closed pull request #19033: URL: https://github.com/apache/flink/pull/19033 -- 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] Myasuka commented on pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2022-03-20 Thread GitBox
Myasuka commented on pull request #19033: URL: https://github.com/apache/flink/pull/19033#issuecomment-1073440855 Megred in master with b6822f293e24263752419e49f8b7910f4e0464a8 and 1bf45b25791cc3fad8b7d0d863caa9b0eef9a87b -- This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-26754) KafkaCommitterTest#testRetryCommittableOnRetriableError stuck

2022-03-20 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509570#comment-17509570 ] Aitozi commented on FLINK-26754: It seems have sth to do with the

[GitHub] [flink] lovewin99 commented on pull request #18776: [FLINK-26151][streaming]Avoid inprogressfileRecoverable not be clean up after restoring the bucket

2022-03-20 Thread GitBox
lovewin99 commented on pull request #18776: URL: https://github.com/apache/flink/pull/18776#issuecomment-1073440471 @gaoyunhaii Why closed this pr, and what problems will it cause? -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2022-03-20 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509569#comment-17509569 ] dalongliu commented on FLINK-22315: --- The column position is only used in ADD column syntax, we should

[jira] [Created] (FLINK-26754) KafkaCommitterTest#testRetryCommittableOnRetriableError stuck

2022-03-20 Thread Aitozi (Jira)
Aitozi created FLINK-26754: -- Summary: KafkaCommitterTest#testRetryCommittableOnRetriableError stuck Key: FLINK-26754 URL: https://issues.apache.org/jira/browse/FLINK-26754 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #19173: [FLINK-26536][python] Fix RemoteKeyedStateBackend#merge_namespaces to handle properly for the timerservice

2022-03-20 Thread GitBox
flinkbot commented on pull request #19173: URL: https://github.com/apache/flink/pull/19173#issuecomment-1073438378 ## CI report: * 4e3d338d9e385eaa39ff75a8757193476527bbe2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19172: [FLINK-24528]Flink HBase Async Lookup throw NPE if rowkey is null

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19172: URL: https://github.com/apache/flink/pull/19172#issuecomment-1073434590 ## CI report: * ad54922bc380ddd6cd3c8213c0bd0da35e7c071d Azure:

[GitHub] [flink] gaoyunhaii closed pull request #18776: [FLINK-26151][streaming]Avoid inprogressfileRecoverable not be clean up after restoring the bucket

2022-03-20 Thread GitBox
gaoyunhaii closed pull request #18776: URL: https://github.com/apache/flink/pull/18776 -- 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] flinkbot commented on pull request #19172: [FLINK-24528]Flink HBase Async Lookup throw NPE if rowkey is null

2022-03-20 Thread GitBox
flinkbot commented on pull request #19172: URL: https://github.com/apache/flink/pull/19172#issuecomment-1073434590 ## CI report: * ad54922bc380ddd6cd3c8213c0bd0da35e7c071d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19112: [FLINK-26678][shell] replace the repeated log4j-console.properties wi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19112: URL: https://github.com/apache/flink/pull/19112#issuecomment-1068959010 ## CI report: * 1747e156e7d1070f29c4e6f9c219ac74d2bc58b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 2afdfb156b4309bf1f3b36ad98870d18abcace38 Azure:

[GitHub] [flink] Vancior opened a new pull request #19173: [FLINK-26536][python] Fix RemoteKeyedStateBackend#merge_namespaces to handle properly for the timerservice

2022-03-20 Thread GitBox
Vancior opened a new pull request #19173: URL: https://github.com/apache/flink/pull/19173 ## What is the purpose of the change This closes #19008. (cherry picked from commit a54c11040dd0103ffce5146a09a2ab6103134906) ## Verifying this change This

[GitHub] [flink] bzhaoopenstack closed pull request #17514: [FLINK-24581][Tests]compatible uname command with multiple OS on ARM …

2022-03-20 Thread GitBox
bzhaoopenstack closed pull request #17514: URL: https://github.com/apache/flink/pull/17514 -- 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] flinkbot edited a comment on pull request #19149: [FLINK-26732][runtime] logs key info for DefaultResourceAllocationStr…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19149: URL: https://github.com/apache/flink/pull/19149#issuecomment-1072262288 ## CI report: * da123d6c2598eae555ee34b0e53a83e3f4093c54 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19112: [FLINK-26678][shell] replace the repeated log4j-console.properties wi…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19112: URL: https://github.com/apache/flink/pull/19112#issuecomment-1068959010 ## CI report: * 1747e156e7d1070f29c4e6f9c219ac74d2bc58b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 2afdfb156b4309bf1f3b36ad98870d18abcace38 Azure:

[jira] [Updated] (FLINK-24528) Flink HBase Asyc Lookup throw NPE if rowkey is null

2022-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24528: --- Labels: pull-request-available (was: ) > Flink HBase Asyc Lookup throw NPE if rowkey is

[GitHub] [flink] cuibo01 opened a new pull request #19172: [FLINK-24528]Flink HBase Async Lookup throw NPE if rowkey is null

2022-03-20 Thread GitBox
cuibo01 opened a new pull request #19172: URL: https://github.com/apache/flink/pull/19172 ## 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

[GitHub] [flink] flinkbot edited a comment on pull request #19149: [FLINK-26732][runtime] logs key info for DefaultResourceAllocationStr…

2022-03-20 Thread GitBox
flinkbot edited a comment on pull request #19149: URL: https://github.com/apache/flink/pull/19149#issuecomment-1072262288 ## CI report: * da123d6c2598eae555ee34b0e53a83e3f4093c54 Azure:

[GitHub] [flink-ml] weibozhao commented on a change in pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler in FlinkML

2022-03-20 Thread GitBox
weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r830722471 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScalerModel.java ## @@ -0,0 +1,181 @@ +/* + * Licensed to the

[jira] [Reopened] (FLINK-24892) FLIP-187: Adaptive Batch Scheduler

2022-03-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reopened FLINK-24892: - Would you add a release note for this feature? [~wanglijie95] > FLIP-187: Adaptive Batch Scheduler >

[GitHub] [flink] ZhangChaoming commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

2022-03-20 Thread GitBox
ZhangChaoming commented on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-1073430585 @MartijnVisser I can not find any CI progress for this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-ml] weibozhao commented on a change in pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler in FlinkML

2022-03-20 Thread GitBox
weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r830722471 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScalerModel.java ## @@ -0,0 +1,181 @@ +/* + * Licensed to the

  1   2   3   >