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

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

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

[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

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

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

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

[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

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

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

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

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

[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

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

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`

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

[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

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

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

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

[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

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-

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

[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

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

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()

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

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

[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

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

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

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

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

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

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 @@ +/

[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

[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

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

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

[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

[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] [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] [Closed] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-25068. --- Resolution: Fixed > Show the maximum parallelism (number of key groups) of a job in Web UI > ---

[jira] [Updated] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25068: Fix Version/s: 1.18.0 (was: 1.20.0) > Show the maximum parallelism (number

[jira] [Commented] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825377#comment-17825377 ] lincoln lee commented on FLINK-25068: - [~Zhanghao Chen] Thanks for the updates. Clos

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

2024-03-11 Thread via GitHub
gyfora commented on code in PR #796: URL: https://github.com/apache/flink-kubernetes-operator/pull/796#discussion_r1520023441 ## flink-autoscaler/src/test/java/org/apache/flink/autoscaler/ScalingExecutorTest.java: ## @@ -146,6 +150,55 @@ op1, evaluated(1, 70, 100), as

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

2024-03-11 Thread via GitHub
lincoln-lil commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1520017882 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- Review Comment: @MartijnVisser Thanks for reviewing this! Yes, these changes need

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

2024-03-11 Thread via GitHub
lincoln-lil commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1520017882 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- Review Comment: @MartijnVisser Thanks for reviewing this! Yes, these changes need

[jira] [Comment Edited] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825369#comment-17825369 ] Zhanghao Chen edited comment on FLINK-25068 at 3/11/24 4:04 PM: --

[jira] [Commented] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825369#comment-17825369 ] Zhanghao Chen commented on FLINK-25068: --- Hi [~zlzhang0122][~lincoln.86xy], given t

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

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

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

2024-03-11 Thread via GitHub
rmoff commented on PR #721: URL: https://github.com/apache/flink-web/pull/721#issuecomment-1988775115 FWIW on [the question of inline examples](https://github.com/apache/flink-web/pull/721#discussion_r1519951825) I would be in favour of including some light-weight content. Definitely not r

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

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

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

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

[jira] [Updated] (FLINK-34643) JobIDLoggingITCase failed

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

[PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-11 Thread via GitHub
rkhachatryan opened a new pull request, #24484: URL: https://github.com/apache/flink/pull/24484 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring th

Re: [PR] [FLINK-33132] Flink Connector Redshift TableSink Implementation [flink-connector-aws]

2024-03-11 Thread via GitHub
vahmed-hamdy commented on code in PR #114: URL: https://github.com/apache/flink-connector-aws/pull/114#discussion_r1519868784 ## flink-connector-aws/flink-connector-redshift/src/main/java/org/apache/flink/connector/redshift/table/RedshiftDynamicTableFactory.java: ## @@ -0,0 +1,

[jira] [Updated] (FLINK-34641) Possibility to add Python Files from http/https sources in PythonDriver

2024-03-11 Thread Aleksei Perminov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksei Perminov updated FLINK-34641: - Component/s: API / Python (was: flink-contrib) > Possibility to add

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825347#comment-17825347 ] Matthias Pohl commented on FLINK-34643: --- Thanks. * https://github.com/apache/fli

[jira] [Comment Edited] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825329#comment-17825329 ] Matthias Pohl edited comment on FLINK-29114 at 3/11/24 3:01 PM: --

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

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825345#comment-17825345 ] Matthias Pohl commented on FLINK-34227: --- https://github.com/apache/flink/actions/r

Re: [PR] [FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework [flink]

2024-03-11 Thread via GitHub
affo commented on PR #24471: URL: https://github.com/apache/flink/pull/24471#issuecomment-1988639429 @wuchong @XComp Hi guys, here is the PR for https://issues.apache.org/jira/browse/FLINK-20398. I decided to go for `LocalStandaloneFlinkResourceFactory` as it is already used

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

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825344#comment-17825344 ] Matthias Pohl commented on FLINK-34227: --- AggregateITCase: https://github.com/apach

[jira] [Created] (FLINK-34646) AggregateITCase.testDistinctWithRetract timed out

2024-03-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34646: - Summary: AggregateITCase.testDistinctWithRetract timed out Key: FLINK-34646 URL: https://issues.apache.org/jira/browse/FLINK-34646 Project: Flink Issue Typ

[jira] [Closed] (FLINK-24333) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredOnCheckpoint fails on azure

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-24333. - Resolution: Cannot Reproduce I'm closing this one as not reproducible. The GHA workflow failures

[jira] [Commented] (FLINK-34645) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825342#comment-17825342 ] Matthias Pohl commented on FLINK-34645: --- https://github.com/apache/flink/actions/r

[jira] [Created] (FLINK-34645) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails

2024-03-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34645: - Summary: StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails Key: FLINK-34645 URL: https://issues.apache.org/jira/browse/FLINK-3464

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

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

[jira] [Commented] (FLINK-34645) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825341#comment-17825341 ] Matthias Pohl commented on FLINK-34645: --- https://github.com/XComp/flink/actions/ru

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825339#comment-17825339 ] Matthias Pohl commented on FLINK-31472: --- https://github.com/apache/flink/actions/r

[jira] [Comment Edited] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825329#comment-17825329 ] Matthias Pohl edited comment on FLINK-29114 at 3/11/24 2:43 PM: --

[jira] [Comment Edited] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825329#comment-17825329 ] Matthias Pohl edited comment on FLINK-29114 at 3/11/24 2:43 PM: --

[jira] [Commented] (FLINK-34404) GroupWindowAggregateProcTimeRestoreTest#testRestore times out

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825338#comment-17825338 ] Matthias Pohl commented on FLINK-34404: --- {{WindowTableFunctionProcTimeRestoreTest}

[jira] [Comment Edited] (FLINK-34404) GroupWindowAggregateProcTimeRestoreTest#testRestore times out

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825338#comment-17825338 ] Matthias Pohl edited comment on FLINK-34404 at 3/11/24 2:42 PM: --

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

2024-03-11 Thread via GitHub
Jiabao-Sun opened a new pull request, #24483: URL: https://github.com/apache/flink/pull/24483 ## What is the purpose of the change [FLINK-25544][streaming][JUnit5 Migration] The runtime package of module flink-stream-java ## Brief change log [JUnit5 Migration] Th

[jira] [Comment Edited] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825329#comment-17825329 ] Matthias Pohl edited comment on FLINK-29114 at 3/11/24 2:36 PM: --

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

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34227: -- Affects Version/s: 1.19.0 > Job doesn't disconnect from ResourceManager >

  1   2   3   4   5   6   7   8   9   10   >