[jira] [Commented] (FLINK-32846) [JUnit5 Migration] The metrics, minicluster and net packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759317#comment-17759317 ] Rui Fan commented on FLINK-32846: - Merged * 42f170b192049bc573efddd3f82169bb327b3fe4 > [JUnit5

[GitHub] [flink] 1996fanrui merged pull request #23244: [FLINK-32846][runtime][JUnit5 Migration] The minicluster and net package of flink-runtime module

1996fanrui merged PR #23244: URL: https://github.com/apache/flink/pull/23244 -- 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:

[GitHub] [flink-kubernetes-operator] 1996fanrui closed pull request #635: [WIP] Please ignore this PR, it's for running the CI

1996fanrui closed pull request #635: [WIP] Please ignore this PR, it's for running the CI URL: https://github.com/apache/flink-kubernetes-operator/pull/635 -- 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

[GitHub] [flink-kubernetes-operator] 1996fanrui commented on pull request #635: [WIP] Please ignore this PR, it's for running the CI

1996fanrui commented on PR #635: URL: https://github.com/apache/flink-kubernetes-operator/pull/635#issuecomment-1694566522 Thanks @mbalassi for the reminder, closed! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot commented on pull request #23303: [FLINK-32847][flink-runtime] Removing the deprecated MutableObjectMode and restore related tests

flinkbot commented on PR #23303: URL: https://github.com/apache/flink/pull/23303#issuecomment-1694566304 ## CI report: * dbefa1eb105356ddd5123e11fd2cf62426172b33 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] 1996fanrui commented on pull request #23303: [FLINK-32847][flink-runtime] Removing the deprecated MutableObjectMode and restore related tests

1996fanrui commented on PR #23303: URL: https://github.com/apache/flink/pull/23303#issuecomment-1694566042 Hi @Jiabao-Sun @RocMarshal would you mind helping review this PR in your free time? thanks~ -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] 1996fanrui opened a new pull request, #23303: [FLINK-32847][flink-runtime] Removing the deprecated MutableObjectMode and restore related tests

1996fanrui opened a new pull request, #23303: URL: https://github.com/apache/flink/pull/23303 ## What is the purpose of the change [FLINK-1285](https://issues.apache.org/jira/browse/FLINK-1285) updated the MutableObjectMode to ObjectReuse. The TaskConfig#getMutableObjectMode() is not

[jira] [Resolved] (FLINK-32847) [JUnit5 Migration] The operators package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32847. - Fix Version/s: 1.19.0 Resolution: Fixed > [JUnit5 Migration] The operators package of

[jira] [Commented] (FLINK-32847) [JUnit5 Migration] The operators package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759314#comment-17759314 ] Rui Fan commented on FLINK-32847: - Merged via ac61e83dad8ea7d0fc91ad98315b2987275586dd > [JUnit5

[GitHub] [flink] 1996fanrui merged pull request #23233: [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime

1996fanrui merged PR #23233: URL: https://github.com/apache/flink/pull/23233 -- 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:

[GitHub] [flink] wangzzu commented on a diff in pull request #23265: [FLINK-32853][runtime][JUnit5 Migration] The security, taskmanager an…

wangzzu commented on code in PR #23265: URL: https://github.com/apache/flink/pull/23265#discussion_r1306576699 ## flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerLocationTest.java: ## @@ -26,7 +26,7 @@ import java.net.InetAddress; import static

[jira] [Updated] (FLINK-32683) Update Pekko from 1.0.0 to 1.0.1

[ https://issues.apache.org/jira/browse/FLINK-32683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32683: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

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

[ https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32261: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-24438) Port Kinesis Source to new Source API (FLIP-27)

[ https://issues.apache.org/jira/browse/FLINK-24438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24438: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30371: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-32604) PyFlink end-to-end fails with kafka-server-stop.sh: No such file or directory

[ https://issues.apache.org/jira/browse/FLINK-32604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32604: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-31242) Correct the definition of creating functions in the SQL client documentation

[ https://issues.apache.org/jira/browse/FLINK-31242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31242: --- Labels: pull-request-available stale-minor (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-32442) DownloadPipelineArtifact fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32442: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-32445) BlobStore.closeAndCleanupAllData doesn't do any close action

[ https://issues.apache.org/jira/browse/FLINK-32445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32445: --- Labels: stale-major starter (was: starter) I am the [Flink Jira

[GitHub] [flink] mbalassi commented on a diff in pull request #23183: [FLINK-32811][runtime] Add port range support for "taskmanager.data.bind-port"

mbalassi commented on code in PR #23183: URL: https://github.com/apache/flink/pull/23183#discussion_r1306538023 ## flink-core/src/main/java/org/apache/flink/util/NetUtils.java: ## @@ -431,6 +431,13 @@ public static Iterator getPortRangeFromString(String rangeDefinition)

[GitHub] [flink-kubernetes-operator] mbalassi commented on pull request #635: [WIP] Please ignore this PR, it's for running the CI

mbalassi commented on PR #635: URL: https://github.com/apache/flink-kubernetes-operator/pull/635#issuecomment-1694480594 Hi @1996fanrui, are we good to close this or are you still using it? -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-32965) Remove the deprecated MutableObjectMode

[ https://issues.apache.org/jira/browse/FLINK-32965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32965: Description: FLINK-1285 updated the MutableObjectMode to ObjectReuse. The

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23233: [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime

1996fanrui commented on code in PR #23233: URL: https://github.com/apache/flink/pull/23233#discussion_r1306493807 ## flink-runtime/src/test/java/org/apache/flink/runtime/operators/drivers/GroupReduceDriverTest.java: ## @@ -235,22 +237,16 @@ public void

[jira] [Updated] (FLINK-32965) Remove the deprecated MutableObjectMode

[ https://issues.apache.org/jira/browse/FLINK-32965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32965: Component/s: Runtime / Configuration > Remove the deprecated MutableObjectMode >

[jira] [Created] (FLINK-32965) Remove the deprecated MutableObjectMode

Rui Fan created FLINK-32965: --- Summary: Remove the deprecated MutableObjectMode Key: FLINK-32965 URL: https://issues.apache.org/jira/browse/FLINK-32965 Project: Flink Issue Type: Technical Debt

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23233: [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime

Jiabao-Sun commented on code in PR #23233: URL: https://github.com/apache/flink/pull/23233#discussion_r1306477513 ## flink-runtime/src/test/java/org/apache/flink/runtime/operators/drivers/GroupReduceDriverTest.java: ## @@ -235,22 +237,16 @@ public void

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23295: [FLINK-26341][zookeeper] Upgrade all tests related to ZooKeeperTestEnvironment to junit5 and removing the ZooKeeperTestEnvironme

1996fanrui commented on code in PR #23295: URL: https://github.com/apache/flink/pull/23295#discussion_r1306474662 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStoreTest.java: ## @@ -162,16 +160,16 @@ public void testGetAllCheckpoints()

[jira] [Created] (FLINK-32964) KinesisStreamsSink cant renew credentials with WebIdentityTokenFileCredentialsProvider

PhilippeB created FLINK-32964: - Summary: KinesisStreamsSink cant renew credentials with WebIdentityTokenFileCredentialsProvider Key: FLINK-32964 URL: https://issues.apache.org/jira/browse/FLINK-32964

[GitHub] [flink] X-czh commented on a diff in pull request #23212: [FLINK-32821][examples] Include flink-connector-datagen for streaming examples

X-czh commented on code in PR #23212: URL: https://github.com/apache/flink/pull/23212#discussion_r1306429776 ## flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml: ## @@ -71,15 +71,16 @@ under the License.

[GitHub] [flink] huwh commented on a diff in pull request #23212: [FLINK-32821][examples] Include flink-connector-datagen for streaming examples

huwh commented on code in PR #23212: URL: https://github.com/apache/flink/pull/23212#discussion_r1306428985 ## flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml: ## @@ -71,15 +71,16 @@ under the License.

[GitHub] [flink] X-czh commented on a diff in pull request #23212: [FLINK-32821][examples] Include flink-connector-datagen for streaming examples

X-czh commented on code in PR #23212: URL: https://github.com/apache/flink/pull/23212#discussion_r1306422537 ## flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml: ## @@ -71,15 +71,16 @@ under the License.

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23295: [FLINK-26341][zookeeper] Upgrade all tests related to ZooKeeperTestEnvironment to junit5 and removing the ZooKeeperTestEnvironme

Jiabao-Sun commented on code in PR #23295: URL: https://github.com/apache/flink/pull/23295#discussion_r1306414698 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStoreTest.java: ## @@ -162,16 +160,16 @@ public void testGetAllCheckpoints()

[GitHub] [flink] Jiabao-Sun commented on pull request #23233: [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime

Jiabao-Sun commented on PR #23233: URL: https://github.com/apache/flink/pull/23233#issuecomment-1694268494 Thanks @1996fanrui for the hard review again. Please help take a look again when you have time. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-32821: -- Description: 6 out of the 8 streaming examples failed to run: * Iteration & SessionWindowing

[jira] [Commented] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759239#comment-17759239 ] Zhanghao Chen commented on FLINK-32821: --- Hi [~afedulov], there's already a test on StateMachine

[GitHub] [flink] flinkbot commented on pull request #23302: [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/shuffle tests to JUnit5

flinkbot commented on PR #23302: URL: https://github.com/apache/flink/pull/23302#issuecomment-1694263230 ## CI report: * 2f83d772df64c9ae4fc94f642f01d7f3450e01b6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-32848) [JUnit5 Migration] The persistence, query, registration, rpc and shuffle packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759238#comment-17759238 ] Zhanghao Chen commented on FLINK-32848: --- Hi [~fanrui], to simplify the code review, I've created 4

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23233: [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime

Jiabao-Sun commented on code in PR #23233: URL: https://github.com/apache/flink/pull/23233#discussion_r1306402848 ## flink-runtime/src/test/java/org/apache/flink/runtime/operators/sort/ExternalSortLargeRecordsITCase.java: ## @@ -402,11 +400,11 @@ public Tuple2 next() {

[GitHub] [flink] X-czh opened a new pull request, #23302: [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/shuffle tests to JUnit5

X-czh opened a new pull request, #23302: URL: https://github.com/apache/flink/pull/23302 ## What is the purpose of the change Migrate flink-runtime/shuffle tests to JUnit5. ## Verifying this change The change itself is for migrating UT. ## Does this pull

[GitHub] [flink] flinkbot commented on pull request #23301: [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/rpc tests to JUnit5

flinkbot commented on PR #23301: URL: https://github.com/apache/flink/pull/23301#issuecomment-1694255945 ## CI report: * 0356e02393c94fb71ad4ca69a02cd45f75b8b946 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] X-czh opened a new pull request, #23301: [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/rpc tests to JUnit5

X-czh opened a new pull request, #23301: URL: https://github.com/apache/flink/pull/23301 ## What is the purpose of the change Migrate flink-runtime/rpc tests to JUnit5. ## Verifying this change The change itself is for migrating UT. ## Does this pull

[GitHub] [flink] flinkbot commented on pull request #23300: [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/registration tests to JUnit5.

flinkbot commented on PR #23300: URL: https://github.com/apache/flink/pull/23300#issuecomment-1694240588 ## CI report: * 0ca9747729481976f098e28a1dfb818792910acf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #23299: [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/query tests to JUnit5

flinkbot commented on PR #23299: URL: https://github.com/apache/flink/pull/23299#issuecomment-1694240567 ## CI report: * 877dab0eda8ab2d4ec9563986a5f5c869b2b51af UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] X-czh opened a new pull request, #23300: [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/registration tests to JUnit5.

X-czh opened a new pull request, #23300: URL: https://github.com/apache/flink/pull/23300 ## What is the purpose of the change Migrate flink-runtime/registration tests to JUnit5. ## Verifying this change The change itself is for migrating UT. ## Does this

[jira] [Updated] (FLINK-32848) [JUnit5 Migration] The persistence, query, registration, rpc and shuffle packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32848: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] The persistence, query,

[GitHub] [flink] X-czh opened a new pull request, #23299: [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/query tests to JUnit5

X-czh opened a new pull request, #23299: URL: https://github.com/apache/flink/pull/23299 ## What is the purpose of the change Migrate flink-runtime/query tests to JUnit5. ## Verifying this change The change itself is for migrating UT. ## Does this pull

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23233: [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime

1996fanrui commented on code in PR #23233: URL: https://github.com/apache/flink/pull/23233#discussion_r1306383828 ## flink-runtime/src/test/java/org/apache/flink/runtime/operators/sort/ExternalSortLargeRecordsITCase.java: ## @@ -402,11 +400,11 @@ public Tuple2 next() {