Re: [PR] [FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter [flink-cdc]

2024-05-13 Thread via GitHub
loserwang1024 commented on code in PR #3319: URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599417206 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtil.java: ## @@ -0,0

Re: [PR] [FLINK-33986][runtime] Extend ShuffleMaster to support snapshot and restore state. [flink]

2024-05-13 Thread via GitHub
zhuzhurk commented on code in PR #24774: URL: https://github.com/apache/flink/pull/24774#discussion_r1599414778 ## flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java: ## @@ -121,4 +122,21 @@ default CompletableFuture> getAllPartitionWithM

Re: [PR] [FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter [flink-cdc]

2024-05-13 Thread via GitHub
loserwang1024 commented on code in PR #3319: URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599410767 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtil.java: ## @@ -0,0

Re: [PR] [FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter [flink-cdc]

2024-05-13 Thread via GitHub
loserwang1024 commented on code in PR #3319: URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599410084 ##

[jira] [Commented] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource

2024-05-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846177#comment-17846177 ] Zhu Zhu commented on FLINK-35293: - The change is merged. Could you add release notes for it and close

[jira] [Assigned] (FLINK-35348) Implement materialized table refresh rest api

2024-05-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35348: - Assignee: Feng Jin > Implement materialized table refresh rest api >

[jira] [Assigned] (FLINK-35347) Implement InMemory workflow scheduler service and plugin to support materialized table

2024-05-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35347: - Assignee: dalongliu > Implement InMemory workflow scheduler service and plugin to support >

[jira] [Created] (FLINK-35348) Implement materialized table refresh rest api

2024-05-13 Thread dalongliu (Jira)
dalongliu created FLINK-35348: - Summary: Implement materialized table refresh rest api Key: FLINK-35348 URL: https://issues.apache.org/jira/browse/FLINK-35348 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-35346) Introduce pluggable workflow scheduler interface for materialized table

2024-05-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35346: - Assignee: dalongliu > Introduce pluggable workflow scheduler interface for materialized table

[jira] [Created] (FLINK-35347) Implement InMemory workflow scheduler service and plugin to support materialized table

2024-05-13 Thread dalongliu (Jira)
dalongliu created FLINK-35347: - Summary: Implement InMemory workflow scheduler service and plugin to support materialized table Key: FLINK-35347 URL: https://issues.apache.org/jira/browse/FLINK-35347

[jira] [Created] (FLINK-35346) Introduce pluggable workflow scheduler interface for materialized table

2024-05-13 Thread dalongliu (Jira)
dalongliu created FLINK-35346: - Summary: Introduce pluggable workflow scheduler interface for materialized table Key: FLINK-35346 URL: https://issues.apache.org/jira/browse/FLINK-35346 Project: Flink

[jira] [Assigned] (FLINK-35345) FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

2024-05-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35345: - Assignee: dalongliu > FLIP-448: Introduce Pluggable Workflow Scheduler Interface for

Re: [PR] [FLINK-35153][State] Internal async list/map state and corresponding state descriptor [flink]

2024-05-13 Thread via GitHub
flinkbot commented on PR #24781: URL: https://github.com/apache/flink/pull/24781#issuecomment-2109314883 ## CI report: * 2f5f8598627c98bfa1bf88e7a6e0de51319748f2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35153) Internal Async State Implementation and StateDescriptor for Map/List State

2024-05-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35153: --- Labels: pull-request-available (was: ) > Internal Async State Implementation and

[PR] [FLINK-35153][State] Internal async list/map state and corresponding state descriptor [flink]

2024-05-13 Thread via GitHub
Zakelly opened a new pull request, #24781: URL: https://github.com/apache/flink/pull/24781 ## What is the purpose of the change This PR provides the definition of `StateDescriptor` and simple implementation for `List` and `Map` state in `State V2`. ## Brief change log -

[jira] [Updated] (FLINK-35334) Code generation: init method exceeds 64 KB when there is a long array field with Table API

2024-05-13 Thread Simon Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Lee updated FLINK-35334: -- Priority: Blocker (was: Major) > Code generation: init method exceeds 64 KB when there is a long

Re: [PR] [FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter [flink-cdc]

2024-05-13 Thread via GitHub
whhe commented on code in PR #3319: URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599378513 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtil.java: ## @@ -0,0 +1,132 @@

[jira] [Closed] (FLINK-32443) Translate "State Processor API" page into Chinese

2024-05-13 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-32443. -- > Translate "State Processor API" page into Chinese > - >

[jira] [Resolved] (FLINK-32443) Translate "State Processor API" page into Chinese

2024-05-13 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-32443. Resolution: Resolved Merged into master via 26817092 > Translate "State Processor API" page into

Re: [PR] [FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter [flink-cdc]

2024-05-13 Thread via GitHub
yuxiqian commented on code in PR #3319: URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599352772 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:

Re: [PR] [FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter [flink-cdc]

2024-05-13 Thread via GitHub
yuxiqian commented on code in PR #3319: URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599352772 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:

[jira] [Created] (FLINK-35345) FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

2024-05-13 Thread dalongliu (Jira)
dalongliu created FLINK-35345: - Summary: FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table Key: FLINK-35345 URL: https://issues.apache.org/jira/browse/FLINK-35345 Project:

Re: [PR] [FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter [flink-cdc]

2024-05-13 Thread via GitHub
yuxiqian commented on code in PR #3319: URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599352772 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:

[jira] [Updated] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter

2024-05-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35344: --- Labels: pull-request-available (was: ) > Move same code from multiple subclasses to

[PR] [FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter [flink-cdc]

2024-05-13 Thread via GitHub
loserwang1024 opened a new pull request, #3319: URL: https://github.com/apache/flink-cdc/pull/3319 Current, subclasses of JdbcSourceChunkSplitter almost share same code, but each have one copy. It's hard for later maintenance. Thus, this Jira aim to move same code from multiple

[jira] [Commented] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter

2024-05-13 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846167#comment-17846167 ] Hongshun Wang commented on FLINK-35344: --- I'd like to do it. > Move same code from multiple

Re: [PR] [FLINK-35253][docs-zh]Translate "State Processor API "page into Chinese [flink]

2024-05-13 Thread via GitHub
fredia commented on PR #24780: URL: https://github.com/apache/flink/pull/24780#issuecomment-2109222070 Hi @drymatini, thanks for your contribution, "State Processor API" was already translated in master, I think documents do not need to be backported to the historical release branch,

[jira] [Created] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter

2024-05-13 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-35344: - Summary: Move same code from multiple subclasses to JdbcSourceChunkSplitter Key: FLINK-35344 URL: https://issues.apache.org/jira/browse/FLINK-35344 Project: Flink

[jira] [Commented] (FLINK-34756) [MySQL-CDC] serverId parameter out of Integer range

2024-05-13 Thread chenyunde (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846161#comment-17846161 ] chenyunde commented on FLINK-34756: --- The range of server-id should be between 1 to 2 ^ 32-1 >

[jira] [Comment Edited] (FLINK-35296) Flink mysql-cdc connector stops reading data

2024-05-13 Thread Gang Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846157#comment-17846157 ] Gang Yang edited comment on FLINK-35296 at 5/14/24 3:28 AM: This abnormal

[jira] [Commented] (FLINK-35296) Flink mysql-cdc connector stops reading data

2024-05-13 Thread Gang Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846157#comment-17846157 ] Gang Yang commented on FLINK-35296: --- This abnormal situation occurs not only in sub-databases and

[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

2024-05-13 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846156#comment-17846156 ] Feng Jin commented on FLINK-35342: -- {color:#00}This issue will be fixed in this PR.{color} 

[jira] [Updated] (FLINK-35296) Flink mysql-cdc connector stops reading data

2024-05-13 Thread Gang Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Attachment: image-2024-05-14-11-25-55-565.png > Flink mysql-cdc connector stops reading data >

[jira] [Commented] (FLINK-35296) Flink mysql-cdc connector stops reading data

2024-05-13 Thread Gang Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846153#comment-17846153 ] Gang Yang commented on FLINK-35296: --- Yes, I have checked it. The maximum data volume of a sub-table is

[jira] (FLINK-35296) Flink mysql-cdc connector stops reading data

2024-05-13 Thread Gang Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35296 ] Gang Yang deleted comment on FLINK-35296: --- was (Author: 清月): 是的,已经检查过,分表最大数据量是1315883,最小是443151,差距不超过三倍 > Flink mysql-cdc connector stops reading data >

[jira] [Commented] (FLINK-35296) Flink mysql-cdc connector stops reading data

2024-05-13 Thread Gang Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846152#comment-17846152 ] Gang Yang commented on FLINK-35296: --- 是的,已经检查过,分表最大数据量是1315883,最小是443151,差距不超过三倍 > Flink mysql-cdc

Re: [PR] [FLINK-32087][checkpoint] Introduce space amplification statistics of file merging [flink]

2024-05-13 Thread via GitHub
fredia commented on PR #24762: URL: https://github.com/apache/flink/pull/24762#issuecomment-2109196919 > Thanks for the update! Overall LGTM. And will this `SpaceStat` report to metrics? Currently no, will report to metric in FLINK-32091. -- This is an automated message from the

Re: [PR] [FLINK-32087][checkpoint] Introduce space amplification statistics of file merging [flink]

2024-05-13 Thread via GitHub
Zakelly commented on code in PR #24762: URL: https://github.com/apache/flink/pull/24762#discussion_r1599318520 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/PhysicalFile.java: ## @@ -88,18 +88,34 @@ PhysicalFile perform( */ private

[jira] [Updated] (FLINK-35343) NullPointerException in SourceReaderBase

2024-05-13 Thread zyh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zyh updated FLINK-35343: Environment: * flink(1.17.2), local mode and deploy on k8s * doris-flink-connector-1.17(1.6.0) * Doris(2.1)

[jira] [Created] (FLINK-35343) NullPointerException in SourceReaderBase

2024-05-13 Thread zyh (Jira)
zyh created FLINK-35343: --- Summary: NullPointerException in SourceReaderBase Key: FLINK-35343 URL: https://issues.apache.org/jira/browse/FLINK-35343 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

2024-05-13 Thread Roman Boyko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846141#comment-17846141 ] Roman Boyko commented on FLINK-34380: - [~xu_shuai_] , [~xuyangzhong] , could you please take a look?

[jira] [Commented] (FLINK-34694) Delete num of associations for streaming outer join

2024-05-13 Thread Roman Boyko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846140#comment-17846140 ] Roman Boyko commented on FLINK-34694: - [~xu_shuai_] , please take a look. > Delete num of

[jira] [Commented] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource

2024-05-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846137#comment-17846137 ] Zhu Zhu commented on FLINK-35293: - master: ddb5a5355f9aca3d223f1fff6581d83dd317c2de > FLIP-445: Support

Re: [PR] [FLINK-35293][hive] Hive source supports dynamic parallelism inference [flink]

2024-05-13 Thread via GitHub
zhuzhurk merged PR #24764: URL: https://github.com/apache/flink/pull/24764 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

2024-05-13 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846135#comment-17846135 ] Feng Jin commented on FLINK-35342: -- [~rskraba] {color:#00}Thank you for reporting this issue, I

[jira] [Commented] (FLINK-35109) Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and drop support for 1.17 and 1.18

2024-05-13 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846129#comment-17846129 ] Hang Ruan commented on FLINK-35109: --- [~fpaul] Thanks for your quick reply. I will work on it later. >

[jira] [Updated] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody

2024-05-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-35302: Fix Version/s: 1.20.0 (was: 1.19.1) > Flink REST server throws exception on

Re: [PR] [FLINK-35165][runtime/coordination] AdaptiveBatch Scheduler should not restrict the default source parall… [flink]

2024-05-13 Thread via GitHub
JunRuiLee commented on PR #24736: URL: https://github.com/apache/flink/pull/24736#issuecomment-2109128178 > > Thanks, @venkata91, for your contribution! After reviewing this PR, I'm concerned that it entirely removes limit that source parallelism should lower than source jobVertex's max

[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846007#comment-17846007 ] Ryan Skraba commented on FLINK-35342: - [~hackergin] I found this failure in this new test, from a

[jira] [Updated] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Skraba updated FLINK-35342: Affects Version/s: 1.20.0 > MaterializedTableStatementITCase test can check for wrong status >

[jira] [Created] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

2024-05-13 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35342: --- Summary: MaterializedTableStatementITCase test can check for wrong status Key: FLINK-35342 URL: https://issues.apache.org/jira/browse/FLINK-35342 Project: Flink

Re: [PR] [FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish [flink]

2024-05-13 Thread via GitHub
elon-X commented on code in PR #24757: URL: https://github.com/apache/flink/pull/24757#discussion_r1598735613 ## flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java: ## @@ -201,8 +201,11 @@ void announceCombinedWatermark() {

Re: [PR] [FLINK-35098][ORC] Fix incorrect results with literal first expressions [flink]

2024-05-13 Thread via GitHub
empathy87 commented on PR #24659: URL: https://github.com/apache/flink/pull/24659#issuecomment-2108124573 > @empathy87 please let me know once backports are ready, then we can merge all of them @snuyanzin, backport PRs are done, CI succeeded.

Re: [PR] [FLINK-35165][runtime/coordination] AdaptiveBatch Scheduler should not restrict the default source parall… [flink]

2024-05-13 Thread via GitHub
venkata91 commented on PR #24736: URL: https://github.com/apache/flink/pull/24736#issuecomment-2108098806 > Thanks, @venkata91, for your contribution! After reviewing this PR, I'm concerned that it entirely removes limit that source parallelism should lower than source jobVertex's max

[jira] [Created] (FLINK-35341) Retraction stop working with Clock dependent function in Filter

2024-05-13 Thread Lim Qing Wei (Jira)
Lim Qing Wei created FLINK-35341: Summary: Retraction stop working with Clock dependent function in Filter Key: FLINK-35341 URL: https://issues.apache.org/jira/browse/FLINK-35341 Project: Flink

Re: [PR] [FLINK-30481][FLIP-277] GlueCatalog Implementation [flink-connector-aws]

2024-05-13 Thread via GitHub
vikramsinghchandel commented on PR #47: URL: https://github.com/apache/flink-connector-aws/pull/47#issuecomment-2107813052 any updates here? This is a feature that is already available on Flink EMR would be great to have it here too. -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845948#comment-17845948 ] Ryan Skraba commented on FLINK-35335: - * 1.19 test_cron_adaptive_scheduler tests

[jira] [Commented] (FLINK-35254) build_wheels_on_macos failed

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845946#comment-17845946 ] Ryan Skraba commented on FLINK-35254: - * 1.20 build_wheels_on_macos

[jira] [Commented] (FLINK-35284) Streaming File Sink end-to-end test times out

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845947#comment-17845947 ] Ryan Skraba commented on FLINK-35284: - * 1.20 AdaptiveScheduler / E2E (group 2)

[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845945#comment-17845945 ] Ryan Skraba commented on FLINK-35041: - Thanks so much! I've verified that I can no longer reproduce

[jira] [Commented] (FLINK-35002) GitHub action request timeout to ArtifactService

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845943#comment-17845943 ] Ryan Skraba commented on FLINK-35002: - * 1.18 AdaptiveScheduler / Compile

[jira] [Created] (FLINK-35340) Flink Kubernetes Operator CRDs not applying correctly

2024-05-13 Thread Neil Prasad (Jira)
Neil Prasad created FLINK-35340: --- Summary: Flink Kubernetes Operator CRDs not applying correctly Key: FLINK-35340 URL: https://issues.apache.org/jira/browse/FLINK-35340 Project: Flink Issue

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845942#comment-17845942 ] Ryan Skraba commented on FLINK-34227: - * 1.19 AdaptiveScheduler / Test (module: table)

[jira] [Commented] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845940#comment-17845940 ] Ryan Skraba commented on FLINK-30644: - * 1.19 test_cron_jdk17 tests

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845939#comment-17845939 ] Ryan Skraba commented on FLINK-28440: - * 1.18 Default (Java 8) / Test (module: tests)

[jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845938#comment-17845938 ] Ryan Skraba commented on FLINK-26644: - * 1.18 Java 11 / Test (module: python)

[jira] [Commented] (FLINK-23577) CoordinatedSourceRescaleITCase.testUpscaling fails with NoSuchFileException

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845937#comment-17845937 ] Ryan Skraba commented on FLINK-23577: - Looks like this flaky test has made a reappearance! * 1.19

[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails

2024-05-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845936#comment-17845936 ] Ryan Skraba commented on FLINK-18476: - * 1.19 test_cron_hadoop313 misc

Re: [PR] [FLINK-35253][docs-zh]Translate "State Processor API "page into Chinese [flink]

2024-05-13 Thread via GitHub
flinkbot commented on PR #24780: URL: https://github.com/apache/flink/pull/24780#issuecomment-2107606610 ## CI report: * 557dcaa7bda5fd1b76e446f643012dc4d47a563c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-35339) Compilation timeout while building flink-dist

2024-05-13 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35339: --- Summary: Compilation timeout while building flink-dist Key: FLINK-35339 URL: https://issues.apache.org/jira/browse/FLINK-35339 Project: Flink Issue Type: Bug

Re: [PR] [FLINK-35253][docs-zh]Translate "State Processor API "page into Chinese [flink]

2024-05-13 Thread via GitHub
drymatini commented on PR #24780: URL: https://github.com/apache/flink/pull/24780#issuecomment-2107594814 @wuchong @reswqa Hi, I have finished the translation of the page.Could you please verify my pull request? -- This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-35253) Translate "State Processor API "page into Chinese

2024-05-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35253: --- Labels: pull-request-available (was: ) > Translate "State Processor API "page into Chinese

[PR] [FLINK-35253][docs-zh]Translate "State Processor API "page into Chinese [flink]

2024-05-13 Thread via GitHub
drymatini opened a new pull request, #24780: URL: https://github.com/apache/flink/pull/24780 ## What is the purpose of the change "State Processor API "page was newly released and it should be translated into Chineses ## Brief change log translate

Re: [PR] [FLINK-35193][table] Support drop materialized table syntax and execution in continuous refresh mode [flink]

2024-05-13 Thread via GitHub
lsyldliu commented on code in PR #24777: URL: https://github.com/apache/flink/pull/24777#discussion_r1598351419 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlDropMaterializedTable.java: ## @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]

2024-05-13 Thread via GitHub
superdiaodiao commented on PR #24773: URL: https://github.com/apache/flink/pull/24773#issuecomment-2107498923 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [BP-1.18][FLINK-35098][ORC] Fix incorrect results with literal first expressions [flink]

2024-05-13 Thread via GitHub
flinkbot commented on PR #24779: URL: https://github.com/apache/flink/pull/24779#issuecomment-2107496417 ## CI report: * 87c26627c5431157f1e85d35b3ce466ff708ff40 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [BP-1.19][FLINK-35098][ORC] Fix incorrect results with literal first expressions [flink]

2024-05-13 Thread via GitHub
flinkbot commented on PR #24778: URL: https://github.com/apache/flink/pull/24778#issuecomment-2107479208 ## CI report: * d9dddcd7c6613169b95193b85fdefa29c726996b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

2024-05-13 Thread yazgoo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845909#comment-17845909 ] yazgoo commented on FLINK-35138: Hello, do you have an update on this ticket ? Looks like the vote was

[jira] [Commented] (FLINK-35168) Basic State Iterator for async processing

2024-05-13 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845908#comment-17845908 ] Zakelly Lan commented on FLINK-35168: - Merged into master via 01586780 > Basic State Iterator for

[jira] [Resolved] (FLINK-35168) Basic State Iterator for async processing

2024-05-13 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-35168. - Resolution: Fixed > Basic State Iterator for async processing >

Re: [PR] [FLINK-35168][State] Basic State Iterator for async processing [flink]

2024-05-13 Thread via GitHub
Zakelly merged PR #24690: URL: https://github.com/apache/flink/pull/24690 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelism

2024-05-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-35336: --- Issue Type: New Feature (was: Bug) > SQL failed to restore from savepoint after change in

[jira] [Commented] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelism

2024-05-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845901#comment-17845901 ] Martijn Visser commented on FLINK-35336: That's not a bug: changing the parallelism is generates

Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]

2024-05-13 Thread via GitHub
superdiaodiao commented on PR #24773: URL: https://github.com/apache/flink/pull/24773#issuecomment-2107400121 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Commented] (FLINK-16528) Support Limit push down for Kafka streaming sources

2024-05-13 Thread Lorenzo Affetti (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845894#comment-17845894 ] Lorenzo Affetti commented on FLINK-16528: - [~jark] is this issue still valuable and open

Re: [PR] [FLINK-35193][table] Support drop materialized table syntax and execution in continuous refresh mode [flink]

2024-05-13 Thread via GitHub
flinkbot commented on PR #24777: URL: https://github.com/apache/flink/pull/24777#issuecomment-2107395878 ## CI report: * 67ef2ca47615d5b36424af7bc12712071369e358 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-35168][State] Basic State Iterator for async processing [flink]

2024-05-13 Thread via GitHub
Zakelly commented on PR #24690: URL: https://github.com/apache/flink/pull/24690#issuecomment-2107381572 > @Zakelly Thanks for the PR, I have a question about the overall design. It seems that an iterator can actually be split into several executions. If other UPDATE are inserted in the

[jira] [Assigned] (FLINK-35126) Improve checkpoint progress health check config and enable by default

2024-05-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-35126: -- Assignee: Gyula Fora > Improve checkpoint progress health check config and enable by default

[jira] [Updated] (FLINK-35338) Enable FS Plugins as non-root

2024-05-13 Thread Rasmus Thygesen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rasmus Thygesen updated FLINK-35338: Description: [This pull

[jira] [Updated] (FLINK-35338) Enable FS Plugins as non-root

2024-05-13 Thread Rasmus Thygesen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rasmus Thygesen updated FLINK-35338: Description: [This pull

[jira] [Updated] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails

2024-05-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5193: -- Labels: pull-request-available (was: ) > Recovering all jobs fails completely if a single

[jira] [Updated] (FLINK-35338) Enable FS Plugins as non-root

2024-05-13 Thread Rasmus Thygesen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rasmus Thygesen updated FLINK-35338: Description: [This pull

[PR] [FLINK-5193][table] Support drop materialized table syntax and execution in continuous refresh mode [flink]

2024-05-13 Thread via GitHub
hackergin opened a new pull request, #24777: URL: https://github.com/apache/flink/pull/24777 ## What is the purpose of the change *Support drop materialized table syntax and execution in continuous refresh mode* ## Brief change log - *Support parser drop

[jira] [Updated] (FLINK-35338) Enable FS Plugins as non-root

2024-05-13 Thread Rasmus Thygesen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rasmus Thygesen updated FLINK-35338: Description: [This pull

[jira] [Commented] (FLINK-35337) Keep up with the latest version of tikv client

2024-05-13 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845887#comment-17845887 ] ouyangwulin commented on FLINK-35337: - [~Leonard], Our production environment has been updated  tikv

[jira] [Updated] (FLINK-35338) Enable FS Plugins as non-root

2024-05-13 Thread Rasmus Thygesen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rasmus Thygesen updated FLINK-35338: Description: [This pull

[jira] [Updated] (FLINK-35337) Keep up with the latest version of tikv client

2024-05-13 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-35337: Component/s: Flink CDC > Keep up with the latest version of tikv client >

[jira] [Updated] (FLINK-35337) Keep up with the latest version of tikv client

2024-05-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35337: --- Labels: pull-request-available (was: ) > Keep up with the latest version of tikv client >

[jira] [Updated] (FLINK-35338) Enable FS Plugins as non-root

2024-05-13 Thread Rasmus Thygesen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rasmus Thygesen updated FLINK-35338: Affects Version/s: 1.8.0 > Enable FS Plugins as non-root > -

[jira] [Created] (FLINK-35338) Enable FS Plugins as non-root

2024-05-13 Thread Rasmus Thygesen (Jira)
Rasmus Thygesen created FLINK-35338: --- Summary: Enable FS Plugins as non-root Key: FLINK-35338 URL: https://issues.apache.org/jira/browse/FLINK-35338 Project: Flink Issue Type: New Feature

  1   2   >