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

[ 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

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

[ 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] [Assigned] (FLINK-26530) Introduce TableStore API

[ 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] [Commented] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239

[ 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

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

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] [Updated] (FLINK-26530) Introduce TableStore API

[ 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 > ---

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

[ 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

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

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-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ 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]

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

[ 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

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

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-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ 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

[ 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

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

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

[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

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

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

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

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

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

[ 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 > -

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

[ 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

[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

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…

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

[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

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 -

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

[ 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-table-store] JingsongLi commented on a change in pull request #37: [FLINK-26441] Add a new OVERWRITE snapshot commit kind

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

[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

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

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

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 edited a comment on pull request #19013: [FLINK-26543][python] Fix the issue that exceptions generated during startup are lost in Python loopback mode

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

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

[ 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

[ 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 #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

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

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

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-25292) Azure failed due to unable to fetch some archives

[ 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

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

[ 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

[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

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-23399) Add a performance benchmark for statebackend rescaling

[ 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 > ---

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

[ 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] [Commented] (FLINK-26445) Unified Sink cannot restore committer state

[ 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

[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

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-26544) Apply key & value filter in FileStoreScanImpl

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 #18722: [FLINK-26086][docs]fixed some causing ambiguities including the 'shit' comment

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

[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

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-table-store] tsreaper opened a new pull request #38: [FLINK-26544] Apply key & value filter in FileStoreScanImpl

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

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

[ 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] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

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

[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

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-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ 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] imaffe edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

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] [Created] (FLINK-26545) Ingress rules should be created in the same namespace with FlinkDeployment CR

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] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

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-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ 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 #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

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

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

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 #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

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] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ 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 #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

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

[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

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] ZhangChaoming commented on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

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

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

[ 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

[ 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] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

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-table-store] JingsongLi merged pull request #37: [FLINK-26441] Add a new OVERWRITE snapshot commit kind

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

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

[ 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 >

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

[ 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] [Reopened] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000)

[ 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] [Commented] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

[ 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

[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

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 #19012: [FLINK-26540][hive] Support handle join involving complex types in on…

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

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

[ 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

<    1   2   3   4