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

[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

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:

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

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:

[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

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

[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

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

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

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

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

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

[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

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

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

[jira] [Commented] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time class

2024-03-11 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825162#comment-17825162 ] Rui Fan commented on FLINK-34522: - merged in master(1.20): * eb9bcfa5893374093d3add272ca698dcb262c4fd *

[jira] [Resolved] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time class

2024-03-11 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34522. - Resolution: Fixed > StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time >

[jira] [Commented] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825176#comment-17825176 ] Sergey Nuyanzin commented on FLINK-31663: - {quote} Since the behavior of array_union is already

[jira] [Updated] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32483: -- Affects Version/s: 1.20.0 >

[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=17825197#comment-17825197 ] Matthias Pohl commented on FLINK-34227: --- Same issue was observed for

[PR] [BP-1.19][FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError [flink]

2024-03-11 Thread via GitHub
reswqa opened a new pull request, #24479: URL: https://github.com/apache/flink/pull/24479 Backport FLINK-34571 to release-1.19 branch. -- 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

[jira] [Updated] (FLINK-34571) SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError failed due an assertion

2024-03-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34571: --- Fix Version/s: 1.20.0 > SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError

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

2024-03-11 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825202#comment-17825202 ] Ahmed Hamdy commented on FLINK-31472: - [~mapohl] Sorry I was out of office, Since I am back now I am

[PR] update flink architecture url for text [Flinks's Architecture] [flink-web]

2024-03-11 Thread via GitHub
shashikumarec088 opened a new pull request, #724: URL: https://github.com/apache/flink-web/pull/724 updated the url which was not found before, i feel even this fix is not permanent as version 1.18 might change in the future -- This is an automated message from the Apache Git

Re: [PR] [FLINK-31472] Disable Intermittently failing throttling test [flink]

2024-03-11 Thread via GitHub
XComp closed pull request #24175: [FLINK-31472] Disable Intermittently failing throttling test URL: https://github.com/apache/flink/pull/24175 -- 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

Re: [PR] [FLINK-31472] Disable Intermittently failing throttling test [flink]

2024-03-11 Thread via GitHub
XComp commented on PR #24175: URL: https://github.com/apache/flink/pull/24175#issuecomment-1987866921 According to [this comment in

[jira] [Commented] (FLINK-34152) Tune TaskManager memory

2024-03-11 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825218#comment-17825218 ] Rui Fan commented on FLINK-34152: - Merged to main(1.8.0) via: * 48692b7243086a2ccf2cb4c64a6b00306fa1d65f

Re: [PR] [FLINK-34522][core] Changing the Time to Duration for StateTtlConfig.Builder.cleanupInRocksdbCompactFilter [flink]

2024-03-11 Thread via GitHub
1996fanrui merged PR #24387: URL: https://github.com/apache/flink/pull/24387 -- 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-34571][test] Fix flaky test `SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError` [flink]

2024-03-11 Thread via GitHub
reswqa commented on PR #24469: URL: https://github.com/apache/flink/pull/24469#issuecomment-1987838887 Thanks for the quick review! -- 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] [FLINK-34571][test] Fix flaky test `SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError` [flink]

2024-03-11 Thread via GitHub
reswqa merged PR #24469: URL: https://github.com/apache/flink/pull/24469 -- 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-34571) SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError failed due an assertion

2024-03-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825198#comment-17825198 ] Weijie Guo commented on FLINK-34571: master(1.20) via fcf61b9108942a892aa93765178a81f2c0e787c5. >

[jira] [Closed] (FLINK-34627) Pulsar source lost topic subscribe

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-34627. - Resolution: Duplicate I'm closing this one as well in favor of the reopened duplicate

[jira] [Reopened] (FLINK-34629) Pulsar source lost topic subscribe

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-34629: --- Assignee: WangMinChao I re-opened that one in favor of FLINK-34627 because it appears to

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_r1519353312 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/TuningSimpleMemorySpec.java: ## @@ -0,0 +1,58 @@ +/* + * Licensed to the

[jira] [Comment Edited] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825176#comment-17825176 ] Sergey Nuyanzin edited comment on FLINK-31663 at 3/11/24 7:25 AM: --

[jira] [Comment Edited] (FLINK-34571) SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError failed due an assertion

2024-03-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825198#comment-17825198 ] Weijie Guo edited comment on FLINK-34571 at 3/11/24 8:21 AM: - master(1.20)

Re: [PR] [BP-1.19][FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError [flink]

2024-03-11 Thread via GitHub
flinkbot commented on PR #24479: URL: https://github.com/apache/flink/pull/24479#issuecomment-1987859634 ## CI report: * 7207cdb3f47f5470ce49c343b4b7c302a75ef1e7 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
xintongsong commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519286951 ## 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] [Comment Edited] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825251#comment-17825251 ] Sergey Nuyanzin edited comment on FLINK-31663 at 3/11/24 10:36 AM: ---

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_r1519522297 ## 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-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
XComp commented on code in PR #24390: URL: https://github.com/apache/flink/pull/24390#discussion_r1519417563 ## flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/table/FileSystemOutputFormatTest.java: ## @@ -83,153 +103,175 @@ void after() {

[jira] [Created] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

2024-03-11 Thread He Wang (Jira)
He Wang created FLINK-34639: --- Summary: Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector Key: FLINK-34639 URL: https://issues.apache.org/jira/browse/FLINK-34639 Project: Flink

Re: [PR] [FLINK-34632][runtime/checkpointing] Log checkpoint Id when logging delay [flink]

2024-03-11 Thread via GitHub
masteryhx closed pull request #24474: [FLINK-34632][runtime/checkpointing] Log checkpoint Id when logging delay URL: https://github.com/apache/flink/pull/24474 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [hotfix] A couple of hotfixes related to e2e tests [flink]

2024-03-11 Thread via GitHub
pnowojski merged PR #24472: URL: https://github.com/apache/flink/pull/24472 -- 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-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825244#comment-17825244 ] Jacky Lau commented on FLINK-31663: --- [~Sergey Nuyanzin] in Flink, array_contains returns true if the

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_r1519522297 ## 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-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-03-11 Thread via GitHub
Zakelly commented on code in PR #24322: URL: https://github.com/apache/flink/pull/24322#discussion_r1519549762 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBProperty.java: ## @@ -31,55 +31,92 @@ */ @Internal

[jira] [Commented] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825260#comment-17825260 ] Jacky Lau commented on FLINK-31663: --- [~Sergey Nuyanzin] ok. if the array_except and array_concat have

Re: [PR] [FLINK-34543][datastream]Support Full Partition Processing On Non-keyed DataStream [flink]

2024-03-11 Thread via GitHub
reswqa commented on code in PR #24398: URL: https://github.com/apache/flink/pull/24398#discussion_r1519327670 ## flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/KeyedPartitionWindowedStreamITCase.java: ## @@ -0,0 +1,521 @@ +/* + * Licensed to the Apache

[jira] [Closed] (FLINK-34632) Log checkpoint Id when logging checkpoint processing delay

2024-03-11 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-34632. Fix Version/s: 1.20.0 Assignee: Mingliang Liu Resolution: Fixed merged 22309fdc

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

2024-03-11 Thread via GitHub
MartijnVisser commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519461611 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- Review Comment: @lincoln-lil I think we're missing something on the changes to

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

2024-03-11 Thread via GitHub
Sxnan commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519464357 ## 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] [Commented] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825251#comment-17825251 ] Sergey Nuyanzin commented on FLINK-31663: - let's no mix everything in one place This is a jira

[jira] [Comment Edited] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825251#comment-17825251 ] Sergey Nuyanzin edited comment on FLINK-31663 at 3/11/24 10:41 AM: ---

[jira] [Created] (FLINK-34640) Replace DummyMetricGroup usage with UnregisteredMetricsGroup

2024-03-11 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-34640: Summary: Replace DummyMetricGroup usage with UnregisteredMetricsGroup Key: FLINK-34640 URL: https://issues.apache.org/jira/browse/FLINK-34640 Project: Flink

[jira] [Commented] (FLINK-34588) FineGrainedSlotManager checks whether resources need to reconcile but doesn't act on the result

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825261#comment-17825261 ] Matthias Pohl commented on FLINK-34588: --- Ok, thanks for clarification. I might add this

Re: [PR] [FLINK-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-03-11 Thread via GitHub
masteryhx commented on code in PR #24322: URL: https://github.com/apache/flink/pull/24322#discussion_r1519609456 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBProperty.java: ## @@ -31,55 +31,92 @@ */

[jira] [Updated] (FLINK-30292) Better support for conversion between DataType and TypeInformation

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30292: Fix Version/s: 1.20.0 > Better support for conversion between DataType and TypeInformation >

[jira] [Updated] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19432: Fix Version/s: 1.20.0 > Whether to capture the updates which don't change any monitored columns >

[jira] [Updated] (FLINK-29941) Support SQL Client connects to SQL Gateway

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29941: Fix Version/s: 1.20.0 > Support SQL Client connects to SQL Gateway >

[jira] [Updated] (FLINK-29355) Sql parse failed because of Desc catalog.database.table is incorrectly parsed to desc catalog

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29355: Fix Version/s: 1.20.0 > Sql parse failed because of Desc catalog.database.table is incorrectly

[jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22418: Fix Version/s: 1.20.0 > The currently activated tab in the same page isn't consistent >

[jira] [Updated] (FLINK-19034) Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetries

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19034: Fix Version/s: 1.20.0 > Remove deprecated

[jira] [Updated] (FLINK-30959) Improve the documentation of UNIX_TIMESTAMP for different argument format

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30959: Fix Version/s: 1.20.0 > Improve the documentation of UNIX_TIMESTAMP for different argument format

[jira] [Updated] (FLINK-27593) Parquet/Orc format reader optimization

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27593: Fix Version/s: 1.20.0 > Parquet/Orc format reader optimization >

[jira] [Updated] (FLINK-33951) should use aggCallNeedRetractions instead of needRetraction to check retract method, orelse throw not implement retract method

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33951: Fix Version/s: 1.20.0 > should use aggCallNeedRetractions instead of needRetraction to check

[jira] [Updated] (FLINK-27455) [JUnit5 Migration] SnapshotMigrationTestBase

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27455: Fix Version/s: 1.20.0 > [JUnit5 Migration] SnapshotMigrationTestBase >

[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

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

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20788: Fix Version/s: 1.20.0 > It doesn't support to use cube/rollup/grouping sets in the Table API >

  1   2   3   4   5   6   7   8   9   10   >