[jira] [Updated] (FLINK-31860) FlinkDeployments never finalize when namespace is deleted

2024-03-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-31860: --- Priority: Major (was: Blocker) > FlinkDeployments never finalize when namespace is deleted > --

[jira] [Commented] (FLINK-31860) FlinkDeployments never finalize when namespace is deleted

2024-03-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825379#comment-17825379 ] Gyula Fora commented on FLINK-31860: I am not aware of any solution from the kuberne

[jira] [Commented] (FLINK-34563) Autoscaling decision improvement

2024-03-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825380#comment-17825380 ] Gyula Fora commented on FLINK-34563: Copying over my comment from GitHub for complet

Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]

2024-03-11 Thread via GitHub
rmetzger commented on code in PR #24482: URL: https://github.com/apache/flink/pull/24482#discussion_r1520055438 ## flink-formats/flink-protobuf-confluent-registry/pom.xml: ## @@ -0,0 +1,171 @@ + + +http://maven.apache.org/POM/4.0.0"; +xmlns:xsi="http://www.w3.org

Re: [PR] [FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2024-03-11 Thread via GitHub
hanyuzheng7 commented on PR #22842: URL: https://github.com/apache/flink/pull/22842#issuecomment-1989110545 Ok, Thank you @snuyanzin -- 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-31860) FlinkDeployments never finalize when namespace is deleted

2024-03-11 Thread Kevin Lam (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825409#comment-17825409 ] Kevin Lam commented on FLINK-31860: --- Thanks [~gyfora]! Is there any consideration for

[jira] [Commented] (FLINK-31860) FlinkDeployments never finalize when namespace is deleted

2024-03-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825414#comment-17825414 ] Gyula Fora commented on FLINK-31860: I don’t really know how that would be possible

Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]

2024-03-11 Thread via GitHub
klam-shop commented on code in PR #24482: URL: https://github.com/apache/flink/pull/24482#discussion_r1520345251 ## flink-formats/flink-protobuf-confluent-registry/src/main/java/org/apache/flink/formats/protobuf/registry/confluent/SchemaRegistryCoder.java: ## @@ -0,0 +1,74 @@ +/

Re: [PR] [FLINK-34642] Add a test for zero lower utilization boundary [flink-kubernetes-operator]

2024-03-11 Thread via GitHub
mxm merged PR #796: URL: https://github.com/apache/flink-kubernetes-operator/pull/796 -- 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: issues-unsubscr...

[jira] [Closed] (FLINK-34524) Scale down JobManager deployment to 0 before deletion

2024-03-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-34524. -- Fix Version/s: kubernetes-operator-1.8.0 Resolution: Fixed merged to main ede1a610b3375d31a2e82

Re: [PR] [FLINK-34524] Scale down JM deployment to 0 before deletion [flink-kubernetes-operator]

2024-03-11 Thread via GitHub
gyfora merged PR #791: URL: https://github.com/apache/flink-kubernetes-operator/pull/791 -- 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: issues-unsubscr

[jira] [Commented] (FLINK-34494) Migrate ReplaceIntersectWithSemiJoinRule

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825438#comment-17825438 ] Sergey Nuyanzin commented on FLINK-34494: - Merged as [5f38a5702fc3629e29cae0d53

Re: [PR] [FLINK-34494][table] Migrate ReplaceIntersectWithSemiJoinRule to java. [flink]

2024-03-11 Thread via GitHub
snuyanzin merged PR #24423: URL: https://github.com/apache/flink/pull/24423 -- 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: issues-unsubscr...@flink.apa

[jira] [Resolved] (FLINK-34494) Migrate ReplaceIntersectWithSemiJoinRule

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-34494. - Resolution: Fixed > Migrate ReplaceIntersectWithSemiJoinRule > -

[jira] [Closed] (FLINK-34494) Migrate ReplaceIntersectWithSemiJoinRule

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-34494. --- > Migrate ReplaceIntersectWithSemiJoinRule > > >

Re: [PR] [FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2024-03-11 Thread via GitHub
snuyanzin merged PR #22842: URL: https://github.com/apache/flink/pull/22842 -- 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: issues-unsubscr...@flink.apa

[jira] [Closed] (FLINK-32261) Add MAP_UNION support in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-32261. --- > Add MAP_UNION support in SQL & Table API > > >

[jira] [Commented] (FLINK-32261) Add MAP_UNION support in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825453#comment-17825453 ] Sergey Nuyanzin commented on FLINK-32261: - Merged as [c2a6feee16c5a547ccfd30f00

[jira] [Resolved] (FLINK-32261) Add MAP_UNION support in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-32261. - Fix Version/s: 1.20.0 Resolution: Fixed > Add MAP_UNION support in SQL & Table AP

Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]

2024-03-11 Thread via GitHub
jeremyb-ps commented on code in PR #24482: URL: https://github.com/apache/flink/pull/24482#discussion_r1520484664 ## flink-formats/flink-protobuf-confluent-registry/src/main/java/org/apache/flink/formats/protobuf/registry/confluent/ProtoToRowDataConverters.java: ## @@ -0,0 +1,66

[jira] [Created] (FLINK-34647) Path normalization is allocation intensive

2024-03-11 Thread David Schlosnagle (Jira)
David Schlosnagle created FLINK-34647: - Summary: Path normalization is allocation intensive Key: FLINK-34647 URL: https://issues.apache.org/jira/browse/FLINK-34647 Project: Flink Issue Ty

[jira] [Updated] (FLINK-34647) Path normalization is allocation intensive

2024-03-11 Thread David Schlosnagle (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Schlosnagle updated FLINK-34647: -- Flags: Patch > Path normalization is allocation intensive > --

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
xintongsong commented on PR #721: URL: https://github.com/apache/flink-web/pull/721#issuecomment-1989726878 @lincoln-lil, thanks for the quick reply. Regarding the examples, it's just a suggestion to remove them but I'd not insist. There's no more concerns from my side. -- This is an aut

[jira] [Created] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system

2024-03-11 Thread LvYanquan (Jira)
LvYanquan created FLINK-34648: - Summary: Avoid RPC time when apply SchemaChangeEvent to external system Key: FLINK-34648 URL: https://issues.apache.org/jira/browse/FLINK-34648 Project: Flink Iss

Re: [PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-11 Thread via GitHub
LadyForest commented on code in PR #24390: URL: https://github.com/apache/flink/pull/24390#discussion_r1520688625 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemOutputFormat.java: ## @@ -197,13 +200,37 @@ public void close

Re: [PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-11 Thread via GitHub
LadyForest commented on code in PR #24390: URL: https://github.com/apache/flink/pull/24390#discussion_r1520696809 ## flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/table/FileSystemOutputFormatTest.java: ## @@ -83,153 +103,175 @@ void after()

[jira] [Commented] (FLINK-34556) Migrate EnumerableToLogicalTableScan

2024-03-11 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825486#comment-17825486 ] Jacky Lau commented on FLINK-34556: --- hi [~snuyanzin]  will you also help review this p

[jira] [Created] (FLINK-34649) Migrate PushFilterIntoLegacyTableSourceScanRule

2024-03-11 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-34649: - Summary: Migrate PushFilterIntoLegacyTableSourceScanRule Key: FLINK-34649 URL: https://issues.apache.org/jira/browse/FLINK-34649 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-34650) Migrate PushProjectIntoLegacyTableSourceScanRule

2024-03-11 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-34650: - Summary: Migrate PushProjectIntoLegacyTableSourceScanRule Key: FLINK-34650 URL: https://issues.apache.org/jira/browse/FLINK-34650 Project: Flink Issue Type: Sub-ta

Re: [PR] [FLINK-25544][streaming][JUnit5 Migration] The runtime package of module flink-stream-java [flink]

2024-03-11 Thread via GitHub
Jiabao-Sun commented on PR #24483: URL: https://github.com/apache/flink/pull/24483#issuecomment-1989802033 Hi @ferenc-csaky, @GOODBOY008. Could you help review this when you have time? This is the last PR of flink-stream-java module. -- This is an automated message from the Apache Gi

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
JunRuiLee commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1520726747 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date: "2024-

[jira] [Commented] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system

2024-03-11 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825490#comment-17825490 ] Hongshun Wang commented on FLINK-34648: --- During the process of task recovery,  wil

[jira] [Comment Edited] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system

2024-03-11 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825490#comment-17825490 ] Hongshun Wang edited comment on FLINK-34648 at 3/12/24 2:11 AM: --

Re: [PR] [FLINK-34152][autoscaler] Refactor the MemoryTuning to avoid the huge method [flink-kubernetes-operator]

2024-03-11 Thread via GitHub
1996fanrui closed pull request #795: [FLINK-34152][autoscaler] Refactor the MemoryTuning to avoid the huge method URL: https://github.com/apache/flink-kubernetes-operator/pull/795 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

Re: [PR] [FLINK-34152][autoscaler] Refactor the MemoryTuning to avoid the huge method [flink-kubernetes-operator]

2024-03-11 Thread via GitHub
1996fanrui commented on code in PR #795: URL: https://github.com/apache/flink-kubernetes-operator/pull/795#discussion_r1520737667 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java: ## @@ -92,24 +99,51 @@ public static ConfigChanges tuneTaskM

Re: [PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-11 Thread via GitHub
LadyForest commented on code in PR #24390: URL: https://github.com/apache/flink/pull/24390#discussion_r1520757091 ## flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/table/FileSystemOutputFormatTest.java: ## @@ -70,6 +85,11 @@ private static M

Re: [PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-11 Thread via GitHub
LadyForest commented on code in PR #24390: URL: https://github.com/apache/flink/pull/24390#discussion_r1520768668 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemOutputFormat.java: ## @@ -286,10 +302,21 @@ public Builder se

[PR] [FLINK-34649][table] Migrate PushFilterIntoLegacyTableSourceScanRule … [flink]

2024-03-11 Thread via GitHub
liuyongvs opened a new pull request, #24485: URL: https://github.com/apache/flink/pull/24485 ## What is the purpose of the change The PR migrates PushFilterIntoLegacyTableSourceScanRule to java it doesn't touch PushFilterIntoLegacyTableSourceScanRuleTest to be sure that java versio

[jira] [Updated] (FLINK-34649) Migrate PushFilterIntoLegacyTableSourceScanRule

2024-03-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34649: --- Labels: pull-request-available (was: ) > Migrate PushFilterIntoLegacyTableSourceScanRule >

Re: [PR] [FLINK-34649][table] Migrate PushFilterIntoLegacyTableSourceScanRule … [flink]

2024-03-11 Thread via GitHub
flinkbot commented on PR #24485: URL: https://github.com/apache/flink/pull/24485#issuecomment-1990031118 ## CI report: * 8b74ea8ed4a34f3bfdc687c6f48cebab9be93028 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34624][state/changelog] Enable local recovery in ChangelogRescalingITCase [flink]

2024-03-11 Thread via GitHub
fredia merged PR #24470: URL: https://github.com/apache/flink/pull/24470 -- 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: issues-unsubscr...@flink.apache

[jira] [Resolved] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase

2024-03-11 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-34624. Resolution: Fixed > Enable local recovery in ChangelogRescalingITCase > --

[jira] [Commented] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase

2024-03-11 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825503#comment-17825503 ] Yanfei Lei commented on FLINK-34624: Merged via 94b55d1. > Enable local recovery in

[jira] [Closed] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase

2024-03-11 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-34624. -- > Enable local recovery in ChangelogRescalingITCase > - >

Re: [PR] [FLINK-34484][state] Split 'state.backend.local-recovery' into two options for checkpointing and recovery [flink]

2024-03-11 Thread via GitHub
fredia commented on PR #24402: URL: https://github.com/apache/flink/pull/24402#issuecomment-1990052953 FYI, https://github.com/apache/flink/pull/24470 has been merged, could you please help to rebase this PR? -- This is an automated message from the Apache Git Service. To respond to the m

Re: [PR] [FLINK-25544][streaming][JUnit5 Migration] The runtime package of module flink-stream-java [flink]

2024-03-11 Thread via GitHub
Jiabao-Sun commented on PR #24483: URL: https://github.com/apache/flink/pull/24483#issuecomment-1990107108 Tests count verified. master Tests run: 2353, Failures: 0, Errors: 0, Skipped: 132 IT Tests run: 64, Failures: 0, Errors: 0, Skipped: 0 PR Tests run: 2

[jira] [Created] (FLINK-34651) The HiveTableSink of Flink does not support writing to S3

2024-03-11 Thread shizhengchao (Jira)
shizhengchao created FLINK-34651: Summary: The HiveTableSink of Flink does not support writing to S3 Key: FLINK-34651 URL: https://issues.apache.org/jira/browse/FLINK-34651 Project: Flink Iss

[jira] [Closed] (FLINK-34277) Triage release-blocking issues in JIRA

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34277. --- Resolution: Fixed > Triage release-blocking issues in JIRA > --

[jira] [Closed] (FLINK-34281) Select executing Release Manager

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34281. --- Resolution: Fixed > Select executing Release Manager > > >

[jira] [Assigned] (FLINK-34281) Select executing Release Manager

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34281: --- Assignee: lincoln lee > Select executing Release Manager >

[jira] [Commented] (FLINK-34592) CLONE - Stage source and binary releases on dist.apache.org

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825526#comment-17825526 ] lincoln lee commented on FLINK-34592: - [https://dist.apache.org/repos/dist/dev/flink

[jira] [Commented] (FLINK-34594) CLONE - Vote on the release candidate

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825525#comment-17825525 ] lincoln lee commented on FLINK-34594: - Voting thread: https://lists.apache.org/threa

[jira] [Closed] (FLINK-34591) CLONE - Build and stage Java and Python artifacts

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34591. --- Resolution: Fixed > CLONE - Build and stage Java and Python artifacts >

[jira] [Closed] (FLINK-34592) CLONE - Stage source and binary releases on dist.apache.org

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34592. --- Resolution: Fixed > CLONE - Stage source and binary releases on dist.apache.org > --

[jira] [Commented] (FLINK-34591) CLONE - Build and stage Java and Python artifacts

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825527#comment-17825527 ] lincoln lee commented on FLINK-34591: - [https://dist.apache.org/repos/dist/dev/flink

Re: [PR] [FLINK-32513][core] Add predecessor caching [flink]

2024-03-11 Thread via GitHub
jeyhunkarimov commented on PR #24475: URL: https://github.com/apache/flink/pull/24475#issuecomment-1990782761 Thanks @zhuzhurk for the review. I addressed them. Could you please check again? -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [FLINK-34533][release] Add release note for version 1.19 [flink]

2024-03-11 Thread via GitHub
ruanhang1993 commented on code in PR #24394: URL: https://github.com/apache/flink/pull/24394#discussion_r1520901797 ## docs/content.zh/release-notes/flink-1.19.md: ## @@ -0,0 +1,354 @@ +--- +title: "Release Notes - Flink 1.19" +--- + + +# Release notes - Flink 1.19 + +These rele

[jira] [Updated] (FLINK-34652) Use CheckpointStreamFactory for StateChangeFsUploader

2024-03-11 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34652: - Description: As discussed before, we may consider supporting CheckpointStreamFactory for StateC

[jira] [Created] (FLINK-34652) Use CheckpointStreamFactory for StateChangeFsUploader

2024-03-11 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-34652: Summary: Use CheckpointStreamFactory for StateChangeFsUploader Key: FLINK-34652 URL: https://issues.apache.org/jira/browse/FLINK-34652 Project: Flink Issue T

[jira] [Commented] (FLINK-32085) Implement and migrate batch uploading in changelog files into the file merging framework

2024-03-11 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825532#comment-17825532 ] Hangxiang Yu commented on FLINK-32085: -- Maybe we could discuss about FLINK-34652 fi

Re: [PR] [FLINK-34533][release] Add release note for version 1.19 [flink]

2024-03-11 Thread via GitHub
snuyanzin commented on code in PR #24394: URL: https://github.com/apache/flink/pull/24394#discussion_r1520924056 ## docs/content.zh/release-notes/flink-1.19.md: ## @@ -0,0 +1,354 @@ +--- +title: "Release Notes - Flink 1.19" +--- + + +# Release notes - Flink 1.19 + +These release

Re: [PR] [FLINK-34533][release] Add release note for version 1.19 [flink]

2024-03-11 Thread via GitHub
snuyanzin commented on code in PR #24394: URL: https://github.com/apache/flink/pull/24394#discussion_r1520927966 ## docs/content.zh/release-notes/flink-1.19.md: ## @@ -0,0 +1,354 @@ +--- +title: "Release Notes - Flink 1.19" +--- + + +# Release notes - Flink 1.19 + +These release

Re: [PR] [FLINK-34533][release] Add release note for version 1.19 [flink]

2024-03-11 Thread via GitHub
snuyanzin commented on code in PR #24394: URL: https://github.com/apache/flink/pull/24394#discussion_r1520928982 ## docs/content.zh/release-notes/flink-1.19.md: ## @@ -0,0 +1,354 @@ +--- +title: "Release Notes - Flink 1.19" +--- + + +# Release notes - Flink 1.19 + +These release

Re: [PR] [FLINK-34533][release] Add release note for version 1.19 [flink]

2024-03-11 Thread via GitHub
lincoln-lil commented on code in PR #24394: URL: https://github.com/apache/flink/pull/24394#discussion_r1520929020 ## docs/content.zh/release-notes/flink-1.19.md: ## @@ -0,0 +1,354 @@ +--- +title: "Release Notes - Flink 1.19" +--- + + +# Release notes - Flink 1.19 + +These relea

[jira] [Commented] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system

2024-03-11 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825538#comment-17825538 ] LvYanquan commented on FLINK-34648: --- Enumerator will not restart but add splits back.

<    6   7   8   9   10   11