[GitHub] [flink] flinkbot commented on pull request #23245: [FLINK-32881] support triggering savepoint in detach mode for CLI

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

[jira] [Updated] (FLINK-32881) Client supports making savepoints in detach mode

[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32881: --- Labels: detach-savepoint pull-request-available (was: detach-savepoint) > Client supports

[GitHub] [flink] xiangforever2014 opened a new pull request, #23245: [FLINK-32881] support triggering savepoint in detach mode for CLI

xiangforever2014 opened a new pull request, #23245: URL: https://github.com/apache/flink/pull/23245 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[GitHub] [flink] singhravidutt commented on a diff in pull request #23226: [FLINK-32877]add HTTP options to gcs-cloud-storage client

singhravidutt commented on code in PR #23226: URL: https://github.com/apache/flink/pull/23226#discussion_r1299604745 ## docs/content/docs/deployment/filesystems/gcs.md: ## @@ -80,6 +80,8 @@ You can also set `gcs-connector` options directly in the Hadoop `core-site.xml`

[jira] [Commented] (FLINK-32418) ClassNotFoundException when using flink-protobuf with sql-client

[ https://issues.apache.org/jira/browse/FLINK-32418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756671#comment-17756671 ] Benchao Li commented on FLINK-32418: [~m-kay] Sorry that I missed this one, I'll try to give it a

[jira] [Commented] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756669#comment-17756669 ] Benchao Li commented on FLINK-32871: I don't think they are the same thing, and I believe

[GitHub] [flink] dongwoo6kim commented on a diff in pull request #23166: [FLINK-32760][Connectors/Hive] Reshade parquet in flink-sql-connector-hive

dongwoo6kim commented on code in PR #23166: URL: https://github.com/apache/flink/pull/23166#discussion_r1299594649 ## flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml: ## @@ -223,6 +223,10 @@ under the License.

[jira] [Commented] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756663#comment-17756663 ] xy commented on FLINK-32871: other engines have no functions named to_timestamps，but have function like

[GitHub] [flink] dongwoo6kim commented on a diff in pull request #23166: [FLINK-32760][Connectors/Hive] Reshade parquet in flink-sql-connector-hive

dongwoo6kim commented on code in PR #23166: URL: https://github.com/apache/flink/pull/23166#discussion_r1299594649 ## flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml: ## @@ -223,6 +223,10 @@ under the License.

[jira] [Commented] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756662#comment-17756662 ] Benchao Li commented on FLINK-32871: {{timestamp '2012-10-31 01:00 UTC' AT TIME ZONE

[jira] [Commented] (FLINK-32418) ClassNotFoundException when using flink-protobuf with sql-client

[ https://issues.apache.org/jira/browse/FLINK-32418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756660#comment-17756660 ] Michael Kreis commented on FLINK-32418: --- [~libenchao] Could you may have a look at the

[jira] [Updated] (FLINK-32418) ClassNotFoundException when using flink-protobuf with sql-client

[ https://issues.apache.org/jira/browse/FLINK-32418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Kreis updated FLINK-32418: -- Labels: pull-request-available (was: pull-request-available stale-assigned) >

[jira] [Created] (FLINK-32898) Improvement of usability for Flink OLAP

xiangyu feng created FLINK-32898: Summary: Improvement of usability for Flink OLAP Key: FLINK-32898 URL: https://issues.apache.org/jira/browse/FLINK-32898 Project: Flink Issue Type:

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #250: [FLINK-32810] Improve memory allocation in ListStateWithCache

Fanoid commented on code in PR #250: URL: https://github.com/apache/flink-ml/pull/250#discussion_r1299581271 ## flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/OperatorScopeManagedMemoryManager.java: ## @@ -0,0 +1,56 @@

[jira] [Updated] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xy updated FLINK-32871: --- Description: Support BuiltInMethod TO_TIMESTAMP with timezone options，TO_TIMESTAMPS now only use utc timezone，but

[jira] [Assigned] (FLINK-32770) Fix the inaccurate backlog number of Hybrid Shuffle

[ https://issues.apache.org/jira/browse/FLINK-32770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32770: -- Assignee: Wencong Liu > Fix the inaccurate backlog number of Hybrid Shuffle >

[jira] [Closed] (FLINK-32770) Fix the inaccurate backlog number of Hybrid Shuffle

[ https://issues.apache.org/jira/browse/FLINK-32770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-32770. -- Resolution: Fixed master(1.18) via ed4937cbc0ee73e08856cc59bfbf788682c70a09. > Fix the inaccurate

[jira] [Updated] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xy updated FLINK-32871: --- Description: Support BuiltInMethod TO_TIMESTAMP with timezone options，TO_TIMESTAMP now only use utc timezone，but

[GitHub] [flink] reswqa merged pull request #23179: [FLINK-32770][network] Fix the inaccurate backlog number of Hybrid Shuffle

reswqa merged PR #23179: URL: https://github.com/apache/flink/pull/23179 -- 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] [Updated] (FLINK-32841) [JUnit5 Migration] The failure, filecache, hadoop, heartbeat, highavailability and instance packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32841: Summary: [JUnit5 Migration] The failure, filecache, hadoop, heartbeat, highavailability and instance

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #248: [FLINK-32704] Supports spilling to disk when feedback channel memory buffer is full

lindong28 commented on code in PR #248: URL: https://github.com/apache/flink-ml/pull/248#discussion_r1299531846 ## flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/feedback/SpillableFeedbackQueue.java: ## @@ -0,0 +1,115 @@ +/* + *

[GitHub] [flink] luoyuxia commented on a diff in pull request #23109: [FLINK-32475][docs] Add doc for time travel

luoyuxia commented on code in PR #23109: URL: https://github.com/apache/flink/pull/23109#discussion_r1299508111 ## docs/content/docs/dev/table/sql/queries/time-travel.md: ## @@ -0,0 +1,65 @@ +--- +title: Time Travel +weight: 18 +type: docs +--- + + +# Time Travel + +{{< label

[jira] [Commented] (FLINK-32895) Introduce the max attempts for Exponential Delay Restart Strategy

[ https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756636#comment-17756636 ] Rui Fan commented on FLINK-32895: - Hi [~zhuzh][~wanglijie], would you mind helping take a look this JIRA

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23218: [FLINK-32854][flink-runtime][JUnit5 Migration] The state package of flink-runtime module

Jiabao-Sun commented on code in PR #23218: URL: https://github.com/apache/flink/pull/23218#discussion_r1299507064 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java: ## @@ -136,7 +136,7 @@ void testPeekPollOrder() {

[GitHub] [flink] loserwang1024 commented on a diff in pull request #23234: [FLINK-32668][e2e] fix up watchdog timeout error msg in common.sh

loserwang1024 commented on code in PR #23234: URL: https://github.com/apache/flink/pull/23234#discussion_r1299502919 ## flink-end-to-end-tests/test-scripts/common.sh: ## @@ -934,9 +934,13 @@ function extract_job_id_from_job_submission_return() { } kill_test_watchdog() { -

[GitHub] [flink] luoyuxia commented on a diff in pull request #23166: [FLINK-32760][Connectors/Hive] Reshade parquet in flink-sql-connector-hive

luoyuxia commented on code in PR #23166: URL: https://github.com/apache/flink/pull/23166#discussion_r1299495861 ## flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml: ## @@ -223,6 +223,10 @@ under the License.

[jira] [Created] (FLINK-32897) Kafka with nested array row type will get wrong result

Yunhong Zheng created FLINK-32897: - Summary: Kafka with nested array row type will get wrong result Key: FLINK-32897 URL: https://issues.apache.org/jira/browse/FLINK-32897 Project: Flink

[jira] [Updated] (FLINK-29579) Flink parquet reader cannot read fully optional elements in a repeated list

[ https://issues.apache.org/jira/browse/FLINK-29579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29579: --- Labels: SchemaValidation auto-deprioritized-major parquet parquetReader (was:

[jira] [Updated] (FLINK-29737) Support DataGen on waveform function

[ https://issues.apache.org/jira/browse/FLINK-29737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29737: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-29333) Flink SQL Planner Module doesn't read config from flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-29333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29333: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-29952) Using DROP TABLE XXX to drop a temporary table （or view） in sql-client can get an exception with incomplete explaination.

[ https://issues.apache.org/jira/browse/FLINK-29952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29952: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-29770) hbase connector supports out-of-order data

[ https://issues.apache.org/jira/browse/FLINK-29770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29770: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-30036) Force delete pod when k8s node is not ready

[ https://issues.apache.org/jira/browse/FLINK-30036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30036: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-26315) Stream job which have multily region would not recover when connection with zookeeper/hbase lost.

[ https://issues.apache.org/jira/browse/FLINK-26315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26315: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor

[jira] [Updated] (FLINK-26499) Azure hang due to unable to download akka artifact

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

[jira] [Updated] (FLINK-29956) Kafka-related test infrastructure code is scattered over multiple classes/environments

[ https://issues.apache.org/jira/browse/FLINK-29956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29956: --- Labels: auto-deprioritized-major starter (was: stale-major starter) Priority: Minor

[jira] [Updated] (FLINK-29980) Wrap the HiveSource's bulkFormat to handle the partition keys

[ https://issues.apache.org/jira/browse/FLINK-29980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29980: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-29432) Replace GenericUDFNvl with GenericUDFCoalesce

[ https://issues.apache.org/jira/browse/FLINK-29432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29432: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-29553) Support UNIX_TIMESTAMP in Table API

[ https://issues.apache.org/jira/browse/FLINK-29553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29553: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-26490) Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary.

[ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26490: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-26091) SafetyNetCloseableRegistryTest.testNonBlockingClose failed on azure

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

[jira] [Updated] (FLINK-29587) Fail to generate code for SearchOperator

[ https://issues.apache.org/jira/browse/FLINK-29587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29587: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-29623) Bump Prometheus Java Client to 0.16.0

[ https://issues.apache.org/jira/browse/FLINK-29623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29623: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-26386) CassandraConnectorITCase.testCassandraTableSink failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26386: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor

[jira] [Updated] (FLINK-29594) RMQSourceITCase.testMessageDelivery timed out

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

[jira] [Updated] (FLINK-32305) History Server is slow at starting

[ https://issues.apache.org/jira/browse/FLINK-32305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32305: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-26459) Streaming File Sink s3 end-to-end test failed on azure due to not enough resource

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

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26498: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26565: --- Labels: auto-deprioritized-minor pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-26563) HadoopS3RecoverableWriterITCase hang on azure

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

[jira] [Updated] (FLINK-26358) Operator maxParallelism is lost during chaining

[ https://issues.apache.org/jira/browse/FLINK-26358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26358: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor

[jira] [Updated] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

[ https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30081: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-26533) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee failed on azure due to delete topic timeout

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

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23218: [FLINK-32854][flink-runtime][JUnit5 Migration] The state package of flink-runtime module

ferenc-csaky commented on code in PR #23218: URL: https://github.com/apache/flink/pull/23218#discussion_r1299397142 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java: ## @@ -136,7 +136,7 @@ void testPeekPollOrder() {

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23242: [FLINK-32851][runtime][JUnit5 Migration] The rest package of flink-runtime module

Jiabao-Sun commented on code in PR #23242: URL: https://github.com/apache/flink/pull/23242#discussion_r1299393443 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java: ## @@ -87,14 +79,19 @@ public void testConnectionTimeout() throws Exception {

[GitHub] [flink] flinkbot commented on pull request #23244: [FLINK-32846][runtime][JUnit5 Migration] The minicluster and net package of flink-runtime module

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

[jira] [Updated] (FLINK-32895) Introduce the max attempts for Exponential Delay Restart Strategy

[ https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32895: Description: Currently, Flink has 3 restart strategies, they are: fixed-delay, failure-rate and

[GitHub] [flink] wangzzu opened a new pull request, #23244: [FLINK-32846][runtime][JUnit5 Migration] The minicluster and net package of flink-runtime module

wangzzu opened a new pull request, #23244: URL: https://github.com/apache/flink/pull/23244 ## What is the purpose of the change Migrate minicluster and net related tests under flink-runtime module to junit5 ## Brief change log Migrate minicluster and net

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23242: [FLINK-32851][runtime][JUnit5 Migration] The rest package of flink-runtime module

Jiabao-Sun commented on code in PR #23242: URL: https://github.com/apache/flink/pull/23242#discussion_r1299392539 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/RestResponseUnmarshallingTestBase.java: ## @@ -0,0 +1,59 @@ +/* + * Licensed to the Apache

[GitHub] [flink-web] wuchong opened a new pull request, #672: Update Flink Roadmap

wuchong opened a new pull request, #672: URL: https://github.com/apache/flink-web/pull/672 This updates the roadmap of the website, as discussed in this thread: https://lists.apache.org/thread/szdr4ngrfcmo7zko4917393zbqhgw0v5 Note: The Chinese language version of the page needs to

[jira] [Updated] (FLINK-32877) Support for HTTP connect and timeout options while writes in GCS connector

[ https://issues.apache.org/jira/browse/FLINK-32877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32877: --- Labels: pull-request-available (was: ) > Support for HTTP connect and timeout options

[GitHub] [flink] jayadeep-jayaraman commented on a diff in pull request #23226: [FLINK-32877]add HTTP options to gcs-cloud-storage client

jayadeep-jayaraman commented on code in PR #23226: URL: https://github.com/apache/flink/pull/23226#discussion_r1296172529 ## docs/content/docs/deployment/filesystems/gcs.md: ## @@ -80,6 +80,8 @@ You can also set `gcs-connector` options directly in the Hadoop `core-site.xml`

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

1996fanrui commented on code in PR #23204: URL: https://github.com/apache/flink/pull/23204#discussion_r1299387216 ## flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java: ## @@ -38,42 +38,50 @@ import

[GitHub] [flink] flinkbot commented on pull request #23243: [FLINK-32846][runtime][JUnit5 Migration] The metrics package of flink-runtime module

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

[jira] [Updated] (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:all-tabpanel ] ASF GitHub Bot updated FLINK-32846: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] The metrics, minicluster and

[GitHub] [flink] wangzzu opened a new pull request, #23243: [FLINK-32846][runtime][JUnit5 Migration] The metrics package of flink-runtime module

wangzzu opened a new pull request, #23243: URL: https://github.com/apache/flink/pull/23243 ## What is the purpose of the change Migrate metrics related tests under flink-runtime module to junit5 ## Brief change log Migrate metrics related tests under

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23241: [FLINK-32837][JUnit5 Migration] Migrate the client and clusterframework packages of flink-runtime module to junit5

Jiabao-Sun commented on code in PR #23241: URL: https://github.com/apache/flink/pull/23241#discussion_r1299383184 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtilsTest.java: ## @@ -37,23 +38,21 @@ import static

[jira] [Updated] (FLINK-32895) Introduce the max attempts for Exponential Delay Restart Strategy

[ https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32895: Description: Currently, Flink has 3 restart strategies, they are: fixed-delay, failure-rate and

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23241: [FLINK-32837][JUnit5 Migration] Migrate the client and clusterframework packages of flink-runtime module to junit5

1996fanrui commented on code in PR #23241: URL: https://github.com/apache/flink/pull/23241#discussion_r1299380633 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtilsTest.java: ## @@ -37,23 +38,21 @@ import static

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

1996fanrui commented on PR #23233: URL: https://github.com/apache/flink/pull/23233#issuecomment-1685287085 Hi @wangzzu , would you mind helping review this PR in your free time? thanks~ There are too many test migration PRs are waiting for my review, and I don't have enough time to

[GitHub] [flink] lsyldliu commented on a diff in pull request #23216: [FLINK-32831][table-planner] RuntimeFilterProgram should aware join type when looking for the build side

lsyldliu commented on code in PR #23216: URL: https://github.com/apache/flink/pull/23216#discussion_r1299354403 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/optimize/program/FlinkRuntimeFilterProgramTest.xml: ## @@ -430,6 +430,104 @@

[jira] [Updated] (FLINK-30108) ZooKeeperLeaderElectionConnectionHandlingTest.testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled times out

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

[jira] [Updated] (FLINK-26624) Running HA (hashmap, async) end-to-end test failed on azure due to unable to find master logs

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

[jira] [Updated] (FLINK-29926) File source continuous monitoring mode ignoring files during savepoint upgrade mode

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

[jira] [Updated] (FLINK-27285) CassandraConnectorITCase failed on azure due to NoHostAvailableException

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

[jira] [Updated] (FLINK-30196) Replace usage of deprecated Mockito's methods with advised by Mockito

[ https://issues.apache.org/jira/browse/FLINK-30196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30196: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-28076) StreamFaultToleranceTestBase runs into timeout

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

[jira] [Updated] (FLINK-30262) UpsertKafkaTableITCase failed when starting the container because waiting for a port timed out

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

[jira] [Updated] (FLINK-30309) Add the ability to supply custom SslContexts for netty client/servers.

[ https://issues.apache.org/jira/browse/FLINK-30309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30309: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-30514) HybridSource savepoint recovery sequence

[ https://issues.apache.org/jira/browse/FLINK-30514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30514: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-28321) HiveDialectQueryITCase fails with error code 137

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

[jira] [Updated] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29545: --- Labels: auto-deprioritized-critical pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-30218) [Kafka Connector] java.lang.OutOfMemoryError: Metaspace

[ https://issues.apache.org/jira/browse/FLINK-30218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30218: --- Labels: auto-deprioritized-major bug (was: bug stale-major) Priority: Minor (was:

[jira] [Updated] (FLINK-26581) Job supports the HADOOP_USER_NAME

[ https://issues.apache.org/jira/browse/FLINK-26581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26581: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-30242) Push localHashAggregate pass the union node

[ https://issues.apache.org/jira/browse/FLINK-30242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30242: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-30475) Improved speed of RocksDBMapState clear() using rocksDB.deleteRange

[ https://issues.apache.org/jira/browse/FLINK-30475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30475: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-30488) OpenSearch implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-30488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30488: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-30327) Adding a values.schema.json to the Helm chart source to support schema validation on Helm chart configuration

[ https://issues.apache.org/jira/browse/FLINK-30327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30327: --- Labels: auto-deprioritized-major starter (was: stale-major starter) Priority: Minor

[jira] [Updated] (FLINK-26566) FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed on azure

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

[jira] [Updated] (FLINK-30479) Document flink-connector-files for local execution

[ https://issues.apache.org/jira/browse/FLINK-30479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30479: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-26601) Flink HBase HBaseRowDataAsyncLookupFunction threadPool not close cause container has so many 'hbase-async-lookup-worker' thread

[ https://issues.apache.org/jira/browse/FLINK-26601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26601: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-27164) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper failed on azure

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

[jira] [Updated] (FLINK-27210) StateFun example link on datastream integration page is broken

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

[jira] [Updated] (FLINK-26837) KafkaSinkE2ECase.testMetrics failed on azure

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

[jira] [Updated] (FLINK-26614) Upsert Kafka SQL Connector:Support startup mode of timestamp and specific offsets

[ https://issues.apache.org/jira/browse/FLINK-26614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26614: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-26625) KinesisFirehoseSinkITCase failed on azure due to Could not find a valid Docker environment

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

[jira] [Updated] (FLINK-26678) make flink-console.sh script clean

[ https://issues.apache.org/jira/browse/FLINK-26678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26678: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-27107) Typo in Task

[ https://issues.apache.org/jira/browse/FLINK-27107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27107: --- Labels: auto-deprioritized-minor pull-request-available (was: pull-request-available

[GitHub] [flink] lsyldliu commented on a diff in pull request #23216: [FLINK-32831][table-planner] RuntimeFilterProgram should aware join type when looking for the build side

lsyldliu commented on code in PR #23216: URL: https://github.com/apache/flink/pull/23216#discussion_r1299334468 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/optimize/program/FlinkRuntimeFilterProgramTest.java: ## @@ -202,6 +202,64 @@

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23241: [FLINK-32837][JUnit5 Migration] Migrate the client and clusterframework packages of flink-runtime module to junit5

Jiabao-Sun commented on code in PR #23241: URL: https://github.com/apache/flink/pull/23241#discussion_r1299315926 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtilsTest.java: ## @@ -37,23 +38,21 @@ import static

  1   2   >