[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503364#comment-17503364 ] Yang Wang commented on FLINK-26528: --- Why this ticket could not be covered by {{{}gener

[GitHub] [flink] flinkbot edited a comment on pull request #19012: [FLINK-26540][hive] Support handle join involving complex types in on…

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19012: URL: https://github.com/apache/flink/pull/19012#issuecomment-1062506833 ## CI report: * cf54b7ac732a75a38f7c87c6a2a525a3f2186a88 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

2022-03-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503355#comment-17503355 ] Dawid Wysakowicz commented on FLINK-25819: -- Hey [~akalashnikov], do you mind cr

[jira] [Reopened] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000)

2022-03-08 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reopened FLINK-24586: - {{JSON_VALUE}} is not changed. > SQL functions should return STRING instead of VARCHAR(2000) >

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

2022-03-08 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503348#comment-17503348 ] hehuiyuan edited comment on FLINK-26498 at 3/9/22, 7:50 AM:

[jira] [Closed] (FLINK-26441) Overwrite commit kind should not be APPEND

2022-03-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26441. Assignee: Caizhi Weng Resolution: Fixed master: a3014f57c901767bd8ff5fbbc28f782112130499 >

[GitHub] [flink-table-store] JingsongLi merged pull request #37: [FLINK-26441] Add a new OVERWRITE snapshot commit kind

2022-03-08 Thread GitBox
JingsongLi merged pull request #37: URL: https://github.com/apache/flink-table-store/pull/37 -- 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: issue

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

2022-03-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503350#comment-17503350 ] Dawid Wysakowicz commented on FLINK-25256: -- All Flink versions are affected. It

[jira] [Updated] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

2022-03-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25256: - Affects Version/s: 1.12.7 > Savepoints do not work with ExternallyInducedSources > -

[GitHub] [flink] ZhangChaoming commented on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-08 Thread GitBox
ZhangChaoming commented on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1062640010 @RocMarshal I am glad to imrpove it, I think the syntax should be : ``` SHOW DATABASES [ ( FROM | IN ) catalog ] [ [NOT] LIKE regex_pattern ] ``` -- This is

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * e16cd0c86367b6c1f83b3c3246372913d6ebb559 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

2022-03-08 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503348#comment-17503348 ] hehuiyuan edited comment on FLINK-26498 at 3/9/22, 7:42 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19011: [FLINK-26506][python] Support StreamExecutionEnvironment.registerCachedFile in Python DataStream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19011: URL: https://github.com/apache/flink/pull/19011#issuecomment-1061774915 ## CI report: * 6afdb2c3d283bcc4874f5489c1daeffafa135a43 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * e16cd0c86367b6c1f83b3c3246372913d6ebb559 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

2022-03-08 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503348#comment-17503348 ] hehuiyuan commented on FLINK-26498: --- [~jark] , It is time for cleanupTimer but laterTr

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Created] (FLINK-26545) Ingress rules should be created in the same namespace with FlinkDeployment CR

2022-03-08 Thread Yang Wang (Jira)
Yang Wang created FLINK-26545: - Summary: Ingress rules should be created in the same namespace with FlinkDeployment CR Key: FLINK-26545 URL: https://issues.apache.org/jira/browse/FLINK-26545 Project: Flin

[GitHub] [flink] imaffe edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

2022-03-08 Thread GitBox
imaffe edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1060703762 > Looks mostly good. Can you quickly share with me how many runs did you do with the test code enabled? We are very close to the branch cut off and want to avoid introduc

[jira] [Commented] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

2022-03-08 Thread Arindam Bhattacharjee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503347#comment-17503347 ] Arindam Bhattacharjee commented on FLINK-26437: --- Thanks [~straw]  and [~ja

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * e16cd0c86367b6c1f83b3c3246372913d6ebb559 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26544) Apply key & value filter in FileStoreScanImpl

2022-03-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26544: --- Labels: pull-request-available (was: ) > Apply key & value filter in FileStoreScanImpl > --

[GitHub] [flink-table-store] tsreaper opened a new pull request #38: [FLINK-26544] Apply key & value filter in FileStoreScanImpl

2022-03-08 Thread GitBox
tsreaper opened a new pull request #38: URL: https://github.com/apache/flink-table-store/pull/38 Now that we've implemented sst file statistics in [FLINK-26346](https://issues.apache.org/jira/browse/FLINK-26346), we can apply key & value filter in `FileStoreScanImpl`. -- This is an auto

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18722: [FLINK-26086][docs]fixed some causing ambiguities including the 'shit' comment

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18722: URL: https://github.com/apache/flink/pull/18722#issuecomment-1036015215 ## CI report: * 9f73efd9c5ff602ea50dbd1a3629c888cea05825 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26544) Apply key & value filter in FileStoreScanImpl

2022-03-08 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-26544: --- Summary: Apply key & value filter in FileStoreScanImpl Key: FLINK-26544 URL: https://issues.apache.org/jira/browse/FLINK-26544 Project: Flink Issue Type: Sub-t

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-26445) Unified Sink cannot restore committer state

2022-03-08 Thread J Y (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503342#comment-17503342 ] J Y commented on FLINK-26445: - does this affect all versions after 1.14? > Unified Sink can

[jira] [Commented] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

2022-03-08 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503341#comment-17503341 ] Yun Gao commented on FLINK-25819: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Updated] (FLINK-23399) Add a performance benchmark for statebackend rescaling

2022-03-08 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23399: - Fix Version/s: 1.16.0 > Add a performance benchmark for statebackend rescaling > ---

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-26490) Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary.

2022-03-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503340#comment-17503340 ] 刘方奇 commented on FLINK-26490: - [~yunta] Actually, setting the max parallelism very large fro

[jira] [Commented] (FLINK-25292) Azure failed due to unable to fetch some archives

2022-03-08 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503339#comment-17503339 ] Yun Gao commented on FLINK-25292: - 1.14: https://dev.azure.com/apache-flink/apache-flin

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 78a062db4ee80f7e29f6d30170354eadad1f504a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Updated] (FLINK-26099) Table connector proctime attributes has syntax error

2022-03-08 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-26099: --- Release Note: (was: Fixed in master(1.15): 38cfda517b7dfe42d3eaa2ecacdec64809e71e9f) > Table conn

[jira] [Commented] (FLINK-26099) Table connector proctime attributes has syntax error

2022-03-08 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503335#comment-17503335 ] Leonard Xu commented on FLINK-26099: Fixed in master(1.15): 38cfda517b7dfe42d3eaa2ec

[GitHub] [flink] flinkbot edited a comment on pull request #19013: [FLINK-26543][python] Fix the issue that exceptions generated during startup are lost in Python loopback mode

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19013: URL: https://github.com/apache/flink/pull/19013#issuecomment-1062612339 ## CI report: * 886b091a8c7e1b23a17bc87f714d3fc9bb5e3bec Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * d412278f22b0f79c0af6481398cb697a82da0ad5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #19013: [FLINK-26543][python] Fix the issue that exceptions generated in startup are missed in Python loopback mode

2022-03-08 Thread GitBox
flinkbot commented on pull request #19013: URL: https://github.com/apache/flink/pull/19013#issuecomment-1062612339 ## CI report: * 886b091a8c7e1b23a17bc87f714d3fc9bb5e3bec UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * d412278f22b0f79c0af6481398cb697a82da0ad5 Azure: [SUCCESS](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 #37: [FLINK-26441] Add a new OVERWRITE snapshot commit kind

2022-03-08 Thread GitBox
JingsongLi commented on a change in pull request #37: URL: https://github.com/apache/flink-table-store/pull/37#discussion_r822339013 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreCommitImpl.java ## @@ -194,7 +194,7 @@ p

[jira] [Updated] (FLINK-26543) Fix the issue that exceptions generated in startup are missed in Python loopback mode

2022-03-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26543: --- Labels: pull-request-available (was: ) > Fix the issue that exceptions generated in startup

[GitHub] [flink] HuangXingBo opened a new pull request #19013: [FLINK-26543][python] Fix the issue that exceptions generated in startup are missed in Python loopback mode

2022-03-08 Thread GitBox
HuangXingBo opened a new pull request #19013: URL: https://github.com/apache/flink/pull/19013 ## What is the purpose of the change *This pull request will fix the issue that exceptions generated in startup are missed in Python loopback mode* ## Brief change log -

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * d412278f22b0f79c0af6481398cb697a82da0ad5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] imaffe edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

2022-03-08 Thread GitBox
imaffe edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1060703762 > Looks mostly good. Can you quickly share with me how many runs did you do with the test code enabled? We are very close to the branch cut off and want to avoid introduc

[jira] [Updated] (FLINK-26543) Fix the issue that exceptions generated in startup are missed in Python loopback mode

2022-03-08 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-26543: - Summary: Fix the issue that exceptions generated in startup are missed in Python loopback mode

[jira] [Updated] (FLINK-26441) Overwrite commit kind should not be APPEND

2022-03-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26441: --- Labels: pull-request-available (was: ) > Overwrite commit kind should not be APPEND > -

[GitHub] [flink] wanglijie95 commented on a change in pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
wanglijie95 commented on a change in pull request #19003: URL: https://github.com/apache/flink/pull/19003#discussion_r822336297 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java ## @@ -109,54 +112,85

[GitHub] [flink-table-store] tsreaper opened a new pull request #37: [FLINK-26441] Add a new OVERWRITE snapshot commit kind

2022-03-08 Thread GitBox
tsreaper opened a new pull request #37: URL: https://github.com/apache/flink-table-store/pull/37 Overwriting a snapshot is different from the normal commit. It firstly clears up the whole partition then append new entries. So we need a new snapshot commit kind to describe it. -- This is

[GitHub] [flink] wanglijie95 commented on a change in pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
wanglijie95 commented on a change in pull request #19003: URL: https://github.com/apache/flink/pull/19003#discussion_r822336229 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -556,14 +560,16 @@ Documentation.Sections

[jira] [Created] (FLINK-26543) Fix the issue that exceptions generated in startup is missed in Python loopback mode

2022-03-08 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26543: Summary: Fix the issue that exceptions generated in startup is missed in Python loopback mode Key: FLINK-26543 URL: https://issues.apache.org/jira/browse/FLINK-26543

[jira] [Commented] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

2022-03-08 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503331#comment-17503331 ] Yuan Zhu commented on FLINK-26437: -- [~jark] Thanks for your advice. [~arindbha], you ca

[jira] [Commented] (FLINK-26538) Ability to restart deployment w/o spec change

2022-03-08 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503330#comment-17503330 ] Thomas Weise commented on FLINK-26538: -- That's an interesting idea although from us

[GitHub] [flink] Myasuka commented on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-08 Thread GitBox
Myasuka commented on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1062605753 @liufangqi Your PR is broken due to tests, please make all tests could pass firstly. -- This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Commented] (FLINK-26490) Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary.

2022-03-08 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503328#comment-17503328 ] Yun Tang commented on FLINK-26490: -- [~liufangqi] Since the check is so fundamental for

[jira] [Commented] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

2022-03-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503325#comment-17503325 ] Jark Wu commented on FLINK-26437: - [~straw] please just put the flink-hadoop-uber jar[1]

[GitHub] [flink-table-store] JingsongLi commented on pull request #36: [FLINK-26530] Introduce TableStore API

2022-03-08 Thread GitBox
JingsongLi commented on pull request #36: URL: https://github.com/apache/flink-table-store/pull/36#issuecomment-1062600574 TODO refactor itcases based on new API. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[jira] [Commented] (FLINK-25381) JdbcExactlyOnceSinkE2eTest.testInsert fails on AZP

2022-03-08 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503324#comment-17503324 ] Matthias Pohl commented on FLINK-25381: --- timeout again: https://dev.azure.com/map

[jira] [Updated] (FLINK-26530) Introduce TableStore API

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

[GitHub] [flink-table-store] JingsongLi opened a new pull request #36: [FLINK-26530] Introduce TableStore API

2022-03-08 Thread GitBox
JingsongLi opened a new pull request #36: URL: https://github.com/apache/flink-table-store/pull/36 Introduce TableStore API to provide a clear and simple API for the upper level: - Create a TableStore source. - Create a TableStore sink. The TableStore API automatically handles:

[jira] [Commented] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239

2022-03-08 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503323#comment-17503323 ] Matthias Pohl commented on FLINK-26106: --- https://dev.azure.com/mapohl/flink/_build

[jira] [Assigned] (FLINK-26530) Introduce TableStore API

2022-03-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26530: Assignee: Jingsong Lee > Introduce TableStore API > > >

[jira] [Updated] (FLINK-26530) Introduce TableStore API

2022-03-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-26530: - Summary: Introduce TableStore API (was: Refactor the FileStoreITCase and StoreSink) > Introduc

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

2022-03-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503321#comment-17503321 ] Jark Wu commented on FLINK-26498: - I don't think we should emit window result when clean

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 4a7b1aabd62ed4165f39ce499a2d9696fb4bef0d Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 4a7b1aabd62ed4165f39ce499a2d9696fb4bef0d Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 4a7b1aabd62ed4165f39ce499a2d9696fb4bef0d Azure: [CANCELED](https://dev.azure.com/apache-

[jira] [Commented] (FLINK-26457) Introduce Join Accumulator for Wide table

2022-03-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503313#comment-17503313 ] Jingsong Lee commented on FLINK-26457: -- [~jark] Yes, it is partial update. > Intro

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 4a7b1aabd62ed4165f39ce499a2d9696fb4bef0d Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 4a7b1aabd62ed4165f39ce499a2d9696fb4bef0d Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

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

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1020905745 ## CI report: * 7a66c874c1621b7fa03abdc8a22157a63cfef6f9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-ml] mumuhhh edited a comment on pull request #68: [FLINK-26404] support non-local file systems

2022-03-08 Thread GitBox
mumuhhh edited a comment on pull request #68: URL: https://github.com/apache/flink-ml/pull/68#issuecomment-1062534288 Thank you. By running GitHub actions, I determined the cause of the problem. It is a problem caused by the introduction of dependency on hadoop-minicluster. I fixed it -

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

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

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1020905745 ## CI report: * 30359d12dcb7787630b0dd3c03d0288013b2447d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

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

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1020905745 ## CI report: * 30359d12dcb7787630b0dd3c03d0288013b2447d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-25684) Support enhanced show databases syntax

2022-03-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503297#comment-17503297 ] Jark Wu commented on FLINK-25684: - Sure. I will review it. > Support enhanced show dat

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

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

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1020905745 ## CI report: * 30359d12dcb7787630b0dd3c03d0288013b2447d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

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

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1020905745 ## CI report: * 30359d12dcb7787630b0dd3c03d0288013b2447d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 1240d4313817b4ae0bfca21090eb6f1cbd40f78e Azure: [FAILURE](https://dev.azure.com/apache-f

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

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1020905745 ## CI report: * 30359d12dcb7787630b0dd3c03d0288013b2447d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

  1   2   3   4   >