[jira] [Commented] (FLINK-18255) Add API annotations to RocksDB user-facing classes

2024-03-13 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826962#comment-17826962 ] Jinzhong Li commented on FLINK-18255: - I don't have permission to change the fix ver

[jira] [Updated] (FLINK-18255) Add API annotations to RocksDB user-facing classes

2024-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18255: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was: auto

[PR] [FLINK-18255][state] Add API annotations to RocksDB user-facing classes [flink]

2024-03-13 Thread via GitHub
ljz2051 opened a new pull request, #24496: URL: https://github.com/apache/flink/pull/24496 ## What is the purpose of the change This pull request adds API annotations for Rocksdb StateBackend user-facing classes ## Brief change log - add PublicEvolving annotation for Conf

Re: [PR] [FLINK-34654] Add Special Thanks Page on the Flink Website [flink-web]

2024-03-13 Thread via GitHub
wuchong merged PR #725: URL: https://github.com/apache/flink-web/pull/725 -- 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.apach

Re: [PR] [FLINK-34654] Add Special Thanks Page on the Flink Website [flink-web]

2024-03-13 Thread via GitHub
wuchong commented on PR #725: URL: https://github.com/apache/flink-web/pull/725#issuecomment-1996658345 Thank you all for the reviewing. I will merge the pull request. We can add patches if content needs to be updated. -- This is an automated message from the Apache Git Service. To respo

Re: [PR] [FLINK-34648] add waitChangeResultRequest and WaitChangeResultResponse to avoid RPC timeout. [flink-cdc]

2024-03-13 Thread via GitHub
lvyanquan commented on code in PR #3128: URL: https://github.com/apache/flink-cdc/pull/3128#discussion_r1524312973 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistryRequestHandler.java: ## @@ -70,6 +81,8 @@ public SchemaRe

Re: [PR] [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. [flink]

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

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

2024-03-13 Thread via GitHub
Jiabao-Sun commented on PR #24483: URL: https://github.com/apache/flink/pull/24483#issuecomment-1996603321 Thanks @ferenc-csaky for the hard review. PTAL again when you have time. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

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

2024-03-13 Thread via GitHub
Jiabao-Sun commented on code in PR #24483: URL: https://github.com/apache/flink/pull/24483#discussion_r1524281053 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/MergingWindowSetTest.java: ## @@ -227,97 +220,92 @@ public void testLate

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

2024-03-13 Thread via GitHub
lincoln-lil commented on PR #24394: URL: https://github.com/apache/flink/pull/24394#issuecomment-1996585352 @Myasuka I've updated all doc links to use `flink-docs-release-1.19`. Thanks for revewing. -- This is an automated message from the Apache Git Service. To respond to the message, pl

Re: [PR] [FLINK-34648] add waitChangeResultRequest and WaitChangeResultResponse to avoid RPC timeout. [flink-cdc]

2024-03-13 Thread via GitHub
ruanhang1993 commented on code in PR #3128: URL: https://github.com/apache/flink-cdc/pull/3128#discussion_r1524276055 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistryRequestHandler.java: ## @@ -70,6 +81,8 @@ public Schem

[jira] [Resolved] (FLINK-34664) Add .asf.yaml for Flink CDC

2024-03-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-34664. Resolution: Resolved Resolved in flink-cdc(master) via: 88c23b59a016d7b023992d2a8fb1865f46fed00d

[jira] [Updated] (FLINK-34664) Add .asf.yaml for Flink CDC

2024-03-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34664: --- Fix Version/s: cdc-3.1.0 > Add .asf.yaml for Flink CDC > --- > >

[jira] [Resolved] (FLINK-32076) Add file pool for concurrent file reusing

2024-03-13 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32076. -- Assignee: Hangxiang Yu (was: Hangxiang Yu) Resolution: Fixed merged 583722e7 and 3b9623

Re: [PR] [FLINK-32076][checkpoint] Introduce file pool to reuse files [flink]

2024-03-13 Thread via GitHub
masteryhx closed pull request #24418: [FLINK-32076][checkpoint] Introduce file pool to reuse files URL: https://github.com/apache/flink/pull/24418 -- 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-25544][streaming][JUnit5 Migration] The runtime package of module flink-stream-java [flink]

2024-03-13 Thread via GitHub
Jiabao-Sun commented on code in PR #24483: URL: https://github.com/apache/flink/pull/24483#discussion_r1524267664 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTest.java: ## @@ -895,39 +890,38 @@ public TaskMetricGroup getMetric

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

2024-03-13 Thread via GitHub
Jiabao-Sun commented on code in PR #24483: URL: https://github.com/apache/flink/pull/24483#discussion_r1524262573 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TumblingProcessingTimeWindowsTest.java: ## @@ -151,53 +132,44 @@ public

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

2024-03-13 Thread via GitHub
Jiabao-Sun commented on code in PR #24483: URL: https://github.com/apache/flink/pull/24483#discussion_r1524259645 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TumblingProcessingTimeWindowsTest.java: ## @@ -151,53 +132,44 @@ public

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

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

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

2024-03-13 Thread via GitHub
Jiabao-Sun commented on code in PR #24483: URL: https://github.com/apache/flink/pull/24483#discussion_r1524256772 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/StreamPartitionerTest.java: ## @@ -21,33 +21,32 @@ import org.apache.flink.runt

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

2024-03-13 Thread via GitHub
ferenc-csaky commented on code in PR #24483: URL: https://github.com/apache/flink/pull/24483#discussion_r1523230235 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/MergingWindowSetTest.java: ## @@ -227,97 +220,92 @@ public void testLa

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

2024-03-13 Thread via GitHub
ferenc-csaky commented on code in PR #24483: URL: https://github.com/apache/flink/pull/24483#discussion_r1521029537 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/StreamPartitionerTest.java: ## @@ -21,33 +21,32 @@ import org.apache.flink.ru

Re: [PR] [FLINK-34516] Move CheckpointingMode to flink-core [flink]

2024-03-13 Thread via GitHub
Zakelly commented on PR #24381: URL: https://github.com/apache/flink/pull/24381#issuecomment-1996356653 @masteryhx I have transformed to the new CheckpointMode everywhere, and rebased master. Would you please take a look? -- This is an automated message from the Apache Git Service. To re

Re: [PR] [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. [flink]

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

Re: [PR] [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. [flink]

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

Re: [PR] [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. [flink]

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

Re: [PR] [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. [flink]

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

[PR] [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. [flink]

2024-03-13 Thread via GitHub
liming30 opened a new pull request, #24494: URL: https://github.com/apache/flink/pull/24494 Backporting https://github.com/apache/flink/pull/23922 to release-1.18 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[PR] [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. [flink]

2024-03-13 Thread via GitHub
liming30 opened a new pull request, #24493: URL: https://github.com/apache/flink/pull/24493 Backporting #23922 to release-1.17 -- 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

[PR] [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. [flink]

2024-03-13 Thread via GitHub
liming30 opened a new pull request, #24495: URL: https://github.com/apache/flink/pull/24495 Backporting https://github.com/apache/flink/pull/23922 to release-1.19 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Closed] (FLINK-33925) Extended failure handling for bulk requests (elasticsearch back port)

2024-03-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33925. -- Resolution: Done main via 9e161cc097b34d3ea0d32787f337e630250547d3. > Extended failure handling for b

[jira] [Updated] (FLINK-33925) Extended failure handling for bulk requests (elasticsearch back port)

2024-03-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33925: --- Fix Version/s: opensearch-1.2.0 > Extended failure handling for bulk requests (elasticsearch back po

Re: [PR] [FLINK-33925][connectors/opensearch] Allow customising bulk failure handling [flink-connector-opensearch]

2024-03-13 Thread via GitHub
reswqa merged PR #39: URL: https://github.com/apache/flink-connector-opensearch/pull/39 -- 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] [FLINK-33925][connectors/opensearch] Allow customising bulk failure handling [flink-connector-opensearch]

2024-03-13 Thread via GitHub
boring-cyborg[bot] commented on PR #39: URL: https://github.com/apache/flink-connector-opensearch/pull/39#issuecomment-1996317097 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Closed] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

2024-03-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-34543. -- Resolution: Done master(1.20) via a021db68a8545b4183e935beccd9b0d62329ee67. > Support Full Partition

[jira] [Assigned] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

2024-03-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-34543: -- Assignee: Wencong Liu > Support Full Partition Processing On Non-keyed DataStream > -

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

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

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

2024-03-13 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826925#comment-17826925 ] Jane Chan commented on FLINK-29114: --- Thanks [~mapohl], I've opened a cherry-pick [PR|

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-13 Thread via GitHub
flinkbot commented on PR #24492: URL: https://github.com/apache/flink/pull/24492#issuecomment-1996302414 ## CI report: * 63db84c3fb1d069c48e0efe8733e63d4dd912777 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34655) Autoscaler standalone doesn't work for flink 1.15

2024-03-13 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34655: Summary: Autoscaler standalone doesn't work for flink 1.15 (was: Autoscaler doesn't work for flink 1.15)

[jira] [Commented] (FLINK-34655) Autoscaler doesn't work for flink 1.15

2024-03-13 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826924#comment-17826924 ] Rui Fan commented on FLINK-34655: - Merged to main(1.8.0) via: ab41083f38cbe27c7d0ee3d8ba

[jira] [Commented] (FLINK-34655) Autoscaler doesn't work for flink 1.15

2024-03-13 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826923#comment-17826923 ] Rui Fan commented on FLINK-34655: - {quote}I understand the idea behind providing suggest

[jira] [Resolved] (FLINK-34655) Autoscaler doesn't work for flink 1.15

2024-03-13 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34655. - Resolution: Fixed > Autoscaler doesn't work for flink 1.15 > -- > >

[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-13 Thread via GitHub
LadyForest opened a new pull request, #24492: URL: https://github.com/apache/flink/pull/24492 ## What is the purpose of the change This PR is cherry-picked from #24390 ## Brief change log * Fix unstable TableSourceITCase#testTableHintWithLogicalTableScanReuse * Mov

Re: [PR] [FLINK-34655] Copy IOMetricsInfo to flink-autoscaler-standalone module [flink-kubernetes-operator]

2024-03-13 Thread via GitHub
1996fanrui merged PR #797: URL: https://github.com/apache/flink-kubernetes-operator/pull/797 -- 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-unsu

[jira] [Commented] (FLINK-34529) Projection cannot be pushed down through rank operator.

2024-03-13 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826918#comment-17826918 ] Benchao Li commented on FLINK-34529: [~nilerzhou] Thanks for the update. For #1, i

Re: [PR] [FLINK-34180][docs] Migrate doc website from ververica to flink [flink-web]

2024-03-13 Thread via GitHub
PatrickRen merged PR #722: URL: https://github.com/apache/flink-web/pull/722 -- 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.ap

[jira] [Updated] (FLINK-34664) Add .asf.yaml for Flink CDC

2024-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34664: --- Labels: pull-request-available (was: ) > Add .asf.yaml for Flink CDC >

[jira] [Created] (FLINK-34664) Add .asf.yaml for Flink CDC

2024-03-13 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34664: - Summary: Add .asf.yaml for Flink CDC Key: FLINK-34664 URL: https://issues.apache.org/jira/browse/FLINK-34664 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-34656) Generated code for `ITEM` operator should return null when getting element of a null map/array/row

2024-03-13 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826917#comment-17826917 ] Benchao Li commented on FLINK-34656: Although the {{resultTerm}} is a default value

[jira] [Resolved] (FLINK-34662) Add new issue template for Flink CDC repo

2024-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34662. --- Resolution: Fixed > Add new issue template for Flink CDC repo >

[jira] [Commented] (FLINK-34662) Add new issue template for Flink CDC repo

2024-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826913#comment-17826913 ] Qingsheng Ren commented on FLINK-34662: --- flink-cdc master: dba00625b11e77539794346

[jira] [Resolved] (FLINK-34660) AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError

2024-03-13 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34660. -- Fix Version/s: 1.20.0 Assignee: Hangxiang Yu Resolution: Fixed merged aa71589

Re: [PR] [FLINK-34660][checkpoint] Avoid randomizing changelog-related config when it's pre-defined [flink]

2024-03-13 Thread via GitHub
masteryhx merged PR #24488: URL: https://github.com/apache/flink/pull/24488 -- 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] [Updated] (FLINK-34651) The HiveTableSink of Flink does not support writing to S3

2024-03-13 Thread shizhengchao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhengchao updated FLINK-34651: - Priority: Blocker (was: Major) > The HiveTableSink of Flink does not support writing to S3 > --

Re: [PR] [FLINK-34640][metrics] Replace DummyMetricGroup usage with UnregisteredMetricsGroup [flink]

2024-03-13 Thread via GitHub
JingGe commented on PR #24490: URL: https://github.com/apache/flink/pull/24490#issuecomment-1996136921 The PR is fine. Let's wait until the CI is passed. -- 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

Re: [PR] [FLINK-34640][metrics] Replace DummyMetricGroup usage with UnregisteredMetricsGroup [flink]

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

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

2024-03-13 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-34640: --- Assignee: Jeyhun Karimov > Replace DummyMetricGroup usage with UnregisteredMetricsGroup > -

Re: [PR] [Flink 34569][e2e] fail fast if AWS cli container fails to start [flink]

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

Re: [PR] [Flink 34569][e2e] fail fast if AWS cli container fails to start [flink]

2024-03-13 Thread via GitHub
robobario commented on code in PR #24491: URL: https://github.com/apache/flink/pull/24491#discussion_r1524015981 ## flink-end-to-end-tests/test-scripts/common_s3_operations.sh: ## @@ -29,12 +29,18 @@ # AWSCLI_CONTAINER_ID ### function aws_cli

[PR] [Flink 34569][e2e] fail fast if AWS cli container fails to start [flink]

2024-03-13 Thread via GitHub
robobario opened a new pull request, #24491: URL: https://github.com/apache/flink/pull/24491 ## What is the purpose of the change This pull request aims to make end-to-end test scripts that source `common_s3_operations.sh` fail fast if the aws cli container fails to start. It also ad

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

2024-03-13 Thread via GitHub
JingGe commented on PR #24483: URL: https://github.com/apache/flink/pull/24483#issuecomment-199548 > Brief change log @Jiabao-Sun Thanks for the excellent summary! I have added it as the reference example in the description of [FLINK-25325](https://issues.apache.org/jira/browse/F

Re: [PR] [FLINK-34640][metrics] Replace DummyMetricGroup usage with UnregisteredMetricsGroup [flink]

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

[jira] [Updated] (FLINK-25325) Migration Flink from Junit4 to Junit5

2024-03-13 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-25325: Description: Based on the consensus from the mailing list discussion[1][2], we have been starting working

[jira] [Commented] (FLINK-34663) flink-opensearch connector Unable to parse response body for Response

2024-03-13 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826884#comment-17826884 ] Andriy Redko commented on FLINK-34663: -- Thanks for trying it out, [~wgendy] , the p

[jira] [Commented] (FLINK-34663) flink-opensearch connector Unable to parse response body for Response

2024-03-13 Thread wael shehata (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826883#comment-17826883 ] wael shehata commented on FLINK-34663: -- knowing that after building the codebase ([

[jira] [Updated] (FLINK-34663) flink-opensearch connector Unable to parse response body for Response

2024-03-13 Thread wael shehata (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wael shehata updated FLINK-34663: - Attachment: image-2024-03-14-00-10-40-982.png > flink-opensearch connector Unable to parse respo

[jira] [Commented] (FLINK-34663) flink-opensearch connector Unable to parse response body for Response

2024-03-13 Thread wael shehata (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826880#comment-17826880 ] wael shehata commented on FLINK-34663: -- Dear Andriy ,I sincerely appreciate your va

Re: [PR] [FLINK-34640][metrics] Replace DummyMetricGroup usage with UnregisteredMetricsGroup [flink]

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

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

2024-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34640: --- Labels: pull-request-available (was: ) > Replace DummyMetricGroup usage with UnregisteredMe

[PR] [FLINK-34640][metrics] Replace DummyMetricGroup usage with UnregisteredMetricsGroup [flink]

2024-03-13 Thread via GitHub
jeyhunkarimov opened a new pull request, #24490: URL: https://github.com/apache/flink/pull/24490 ## What is the purpose of the change Replace DummyMetricGroup usage with UnregisteredMetricsGroup ## Brief change log *(for example:)* - Remove DummyMetricGroup and repla

[jira] [Commented] (FLINK-34663) flink-opensearch connector Unable to parse response body for Response

2024-03-13 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826845#comment-17826845 ] Andriy Redko commented on FLINK-34663: -- [https://github.com/apache/flink-connector-

[jira] [Created] (FLINK-34663) flink-opensearch connector Unable to parse response body for Response

2024-03-13 Thread wael shehata (Jira)
wael shehata created FLINK-34663: Summary: flink-opensearch connector Unable to parse response body for Response Key: FLINK-34663 URL: https://issues.apache.org/jira/browse/FLINK-34663 Project: Flink

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

2024-03-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826803#comment-17826803 ] Ryan Skraba commented on FLINK-18476: - https://dev.azure.com/apache-flink/apache-fli

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

2024-03-13 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826800#comment-17826800 ] Ryan Skraba commented on FLINK-34643: - https://dev.azure.com/apache-flink/apache-fli

[jira] [Commented] (FLINK-34659) How to implement global sort in latest flink datastream API

2024-03-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826788#comment-17826788 ] Martijn Visser commented on FLINK-34659: {quote}If you ever search on hive/spark

[jira] [Commented] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed

2024-03-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826779#comment-17826779 ] Piotr Nowojski commented on FLINK-26990: I've just encountered the same issue in

[jira] [Updated] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed

2024-03-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-26990: --- Priority: Major (was: Minor) > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.tes

[jira] [Updated] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed

2024-03-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-26990: --- Affects Version/s: 1.18.1 > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFin

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

2024-03-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29114: --- Priority: Blocker (was: Major) > TableSourceITCase#testTableHintWithLogicalTableScanReuse s

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

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

[jira] [Comment Edited] (FLINK-34569) 'Streaming File Sink s3 end-to-end test' failed

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

[jira] [Assigned] (FLINK-34569) 'Streaming File Sink s3 end-to-end test' failed

2024-03-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-34569: - Assignee: Rob Young > 'Streaming File Sink s3 end-to-end test' failed > ---

[jira] [Commented] (FLINK-34569) 'Streaming File Sink s3 end-to-end test' failed

2024-03-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826766#comment-17826766 ] Matthias Pohl commented on FLINK-34569: --- Sure, go ahead. I assigned the ticket to

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

2024-03-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826763#comment-17826763 ] Matthias Pohl commented on FLINK-29114: --- It shouldn't be a problem as far as I see

[jira] [Resolved] (FLINK-29122) Improve robustness of FileUtils.expandDirectory()

2024-03-13 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-29122. Resolution: Fixed > Improve robustness of FileUtils.expandDirectory() > -

[jira] [Commented] (FLINK-29122) Improve robustness of FileUtils.expandDirectory()

2024-03-13 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826762#comment-17826762 ] Robert Metzger commented on FLINK-29122: Merged to master in https://github.com

[jira] [Updated] (FLINK-29122) Improve robustness of FileUtils.expandDirectory()

2024-03-13 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-29122: --- Fix Version/s: 1.20.0 > Improve robustness of FileUtils.expandDirectory() > ---

Re: [PR] [FLINK-29122][core] Improve robustness of FileUtils.expandDirectory() [flink]

2024-03-13 Thread via GitHub
rmetzger merged PR #24307: URL: https://github.com/apache/flink/pull/24307 -- 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.apac

[jira] [Comment Edited] (FLINK-34659) How to implement global sort in latest flink datastream API

2024-03-13 Thread Junyao Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826086#comment-17826086 ] Junyao Huang edited comment on FLINK-34659 at 3/13/24 2:51 PM: ---

[jira] [Comment Edited] (FLINK-34659) How to implement global sort in latest flink datastream API

2024-03-13 Thread Junyao Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826086#comment-17826086 ] Junyao Huang edited comment on FLINK-34659 at 3/13/24 2:50 PM: ---

[jira] [Commented] (FLINK-34659) How to implement global sort in latest flink datastream API

2024-03-13 Thread Junyao Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826086#comment-17826086 ] Junyao Huang commented on FLINK-34659: -- If you ever search on hive/spark SQL/Datafr

Re: [PR] [FLINK-34227][runtime] Fixes concurrency issue in JobMaster shutdown [flink]

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

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

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

[PR] [FLINK-34227][runtime] Fixes concurrency issue in JobMaster shutdown [flink]

2024-03-13 Thread via GitHub
XComp opened a new pull request, #24489: URL: https://github.com/apache/flink/pull/24489 ## What is the purpose of the change tba ## Brief change log tba ## Verifying this change This change is a trivial rework / code cleanup without any test coverage.

[jira] [Commented] (FLINK-34655) Autoscaler doesn't work for flink 1.15

2024-03-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826054#comment-17826054 ] Gyula Fora commented on FLINK-34655: [~mxm] I would be hesitant to try to backport t

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

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

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

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

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

2024-03-13 Thread via GitHub
lincoln-lil commented on PR #24394: URL: https://github.com/apache/flink/pull/24394#issuecomment-1994381592 @PatrickRen Thanks for reviewing this! I've addressed your comments and updated the pr. -- This is an automated message from the Apache Git Service. To respond to the message, pleas

Re: [PR] [FLINK-34516] Move CheckpointingMode to flink-core [flink]

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

  1   2   >