[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

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:

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

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

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

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

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

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

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

[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=17825490#comment-17825490 ] Hongshun Wang edited comment on FLINK-34648 at 3/12/24 2:11 AM: During

[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=17825490#comment-17825490 ] Hongshun Wang commented on FLINK-34648: --- During the process of task recovery,  will the enumerator

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:

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

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

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

[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=17825486#comment-17825486 ] Jacky Lau commented on FLINK-34556: --- hi [~snuyanzin]  will you also help review this pr ? > Migrate

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

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

[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

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

[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

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

[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

[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=17825453#comment-17825453 ] Sergey Nuyanzin commented on FLINK-32261: - Merged as

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

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

[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=17825438#comment-17825438 ] Sergey Nuyanzin commented on FLINK-34494: - Merged as

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:

[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

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:

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=17825414#comment-17825414 ] Gyula Fora commented on FLINK-31860: I don’t really know how that would be possible but I welcome

[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=17825409#comment-17825409 ] Kevin Lam commented on FLINK-31860: --- Thanks [~gyfora]! Is there any consideration for putting a

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

[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=17825380#comment-17825380 ] Gyula Fora commented on FLINK-34563: Copying over my comment from GitHub for completeness: I have

[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=17825379#comment-17825379 ] Gyula Fora commented on FLINK-31860: I am not aware of any solution from the kubernetes / josdk side

[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=17825377#comment-17825377 ] lincoln lee commented on FLINK-25068: - [~Zhanghao Chen] Thanks for the updates. Closing this with

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

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=17825369#comment-17825369 ] Zhanghao Chen edited comment on FLINK-25068 at 3/11/24 4:04 PM: Hi

[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=17825369#comment-17825369 ] Zhanghao Chen commented on FLINK-25068: --- Hi [~zlzhang0122][~lincoln.86xy], given that

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:

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

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:

[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

[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

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

[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

[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=17825347#comment-17825347 ] Matthias Pohl commented on FLINK-34643: --- Thanks. *

[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=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=17825345#comment-17825345 ] Matthias Pohl commented on FLINK-34227: ---

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=17825344#comment-17825344 ] Matthias Pohl commented on FLINK-34227: --- AggregateITCase:

[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

[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

[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=17825342#comment-17825342 ] Matthias Pohl commented on FLINK-34645: ---

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

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=17825341#comment-17825341 ] Matthias Pohl commented on FLINK-34645: ---

[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=17825339#comment-17825339 ] Matthias Pohl commented on FLINK-31472: ---

[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=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=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=17825338#comment-17825338 ] Matthias Pohl commented on FLINK-34404: --- {{WindowTableFunctionProcTimeRestoreTest}} timed out (I'm

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

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

[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=17825329#comment-17825329 ] Matthias Pohl edited comment on FLINK-29114 at 3/11/24 2:35 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=17825337#comment-17825337 ] Matthias Pohl commented on FLINK-34227: --- This one is a 1.19 workflow run:

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

2024-03-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-34643: - Assignee: Roman Khachatryan > JobIDLoggingITCase failed >

[jira] [Created] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException

2024-03-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34644: - Summary: RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException Key: FLINK-34644 URL:

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

2024-03-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825334#comment-17825334 ] Roman Khachatryan commented on FLINK-34643: --- Sure [~mapohl] , will take a look. >

[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=17825330#comment-17825330 ] Matthias Pohl commented on FLINK-34643: --- *

[jira] [Commented] (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=17825329#comment-17825329 ] Matthias Pohl commented on FLINK-29114: --- *

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825328#comment-17825328 ] Matthias Pohl commented on FLINK-17274: ---

[jira] [Commented] (FLINK-34273) git fetch fails

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825327#comment-17825327 ] Matthias Pohl commented on FLINK-34273: ---

[jira] [Updated] (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:all-tabpanel ] Matthias Pohl updated FLINK-34643: -- Description:

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

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

[jira] [Comment Edited] (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=17825326#comment-17825326 ] Matthias Pohl edited comment on FLINK-34643 at 3/11/24 2:13 PM:

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

2024-03-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34643: - Summary: JobIDLoggingITCase failed Key: FLINK-34643 URL: https://issues.apache.org/jira/browse/FLINK-34643 Project: Flink Issue Type: Bug

[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=17825326#comment-17825326 ] Matthias Pohl commented on FLINK-34643: --- FLINK-34417 introduced this test. @roman can you have a

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

2024-03-11 Thread via GitHub
mxm commented on PR #791: URL: https://github.com/apache/flink-kubernetes-operator/pull/791#issuecomment-1988538289 @gyfora Nice! LGTM -- 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

  1   2   3   4   5   6   7   8   9   10   >