[jira] [Updated] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32905: --- Labels: pull-request-available (was: ) > Fix the bug of broadcast hash join doesn't support

[GitHub] [flink] lsyldliu opened a new pull request, #23251: [FLINK-32905][table-runtime] Fix the bug of broadcast hash join doesn't support spill to disk when enabling operator fusion codegen

lsyldliu opened a new pull request, #23251: URL: https://github.com/apache/flink/pull/23251 ## What is the purpose of the change In the predecessor PR, for the purpose of delayed computation, for Broadcast HashJoin, we strongly assume that the build side won' spill to disk because

[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&focusedCommentId=17757219#comment-17757219 ] Zhu Zhu commented on FLINK-32895: - Sure I will ping you in time. [~fanrui] > Introduce

[jira] [Updated] (FLINK-21126) Reconsider FLINK_PROPERTIES

[ https://issues.apache.org/jira/browse/FLINK-21126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-21126: Fix Version/s: 2.0.0 > Reconsider FLINK_PROPERTIES > --- > > Key:

[jira] [Resolved] (FLINK-32793) Release Testing: Verify FLINK-31535 - Extend watermark-related features for SQL

[ https://issues.apache.org/jira/browse/FLINK-32793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-32793. -- Resolution: Fixed > Release Testing: Verify FLINK-31535 - Extend watermark-related features for > SQL

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #252: [FLINK-32889] Fix calcuation of weighted areaUnderROC and areaUnderPRC in BinaryClassificationEvaluator

Fanoid commented on code in PR #252: URL: https://github.com/apache/flink-ml/pull/252#discussion_r1301008956 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryclassification/BinaryClassificationEvaluator.java: ## @@ -520,13 +354,16 @@ private static long[] redu

[GitHub] [flink-ml] Fanoid commented on pull request #252: [FLINK-32889] Fix calcuation of weighted areaUnderROC and areaUnderPRC in BinaryClassificationEvaluator

Fanoid commented on PR #252: URL: https://github.com/apache/flink-ml/pull/252#issuecomment-1687498107 @weibozhao Thanks for your comments. Would you please take another look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #252: [FLINK-32889] Fix calcuation of weighted areaUnderROC and areaUnderPRC in BinaryClassificationEvaluator

Fanoid commented on code in PR #252: URL: https://github.com/apache/flink-ml/pull/252#discussion_r1301006602 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryclassification/BinaryClassificationEvaluator.java: ## @@ -673,25 +510,26 @@ public static class BinaryS

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #252: [FLINK-32889] Fix calcuation of weighted areaUnderROC and areaUnderPRC in BinaryClassificationEvaluator

Fanoid commented on code in PR #252: URL: https://github.com/apache/flink-ml/pull/252#discussion_r1301004383 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryclassification/BinaryClassificationEvaluator.java: ## @@ -362,7 +234,7 @@ public void mapPartition(

[jira] [Updated] (FLINK-32906) Release Testing: Verify FLINK-30025 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

[ https://issues.apache.org/jira/browse/FLINK-32906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-32906: Summary: Release Testing: Verify FLINK-30025 Unified the max display column width for SqlClient and Table

[jira] [Updated] (FLINK-32906) Release Testing: Verify FLINK-30025

[ https://issues.apache.org/jira/browse/FLINK-32906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-32906: Description: more info could be found at  FLIP-279  [https://cwiki.apache.org/confluence/display/FLINK/FL

[jira] [Updated] (FLINK-32906) Release Testing: Verify FLINK-30025

[ https://issues.apache.org/jira/browse/FLINK-32906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-32906: Component/s: Tests (was: Table SQL / API) > Release Testing: Verify FLINK-30025 > ---

[jira] [Created] (FLINK-32906) Release Testing: Verify FLINK-30025

Jing Ge created FLINK-32906: --- Summary: Release Testing: Verify FLINK-30025 Key: FLINK-32906 URL: https://issues.apache.org/jira/browse/FLINK-32906 Project: Flink Issue Type: Sub-task Comp

[GitHub] [flink-connector-elasticsearch] reswqa commented on pull request #53: [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support

reswqa commented on PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1687418291 What's the progress of this? -- 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

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1300892311 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -515,7 +516,7 @@ public CompletableFuture submitJob(JobGraph jobGraph, Tim

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1300891908 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java: ## Review Comment: Sorry for the mistake.😐 Fixed. ##

[jira] [Created] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

dalongliu created FLINK-32905: - Summary: Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn Key: FLINK-32905 URL: https://issues.apache.org/jira/browse/FLINK-32905

[GitHub] [flink] fredia commented on a diff in pull request #22890: [FLINK-32072][checkpoint] Create and wire FileMergingSnapshotManager with TaskManagerServices

fredia commented on code in PR #22890: URL: https://github.com/apache/flink/pull/22890#discussion_r1300855088 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorFileMergingManager.java: ## @@ -0,0 +1,163 @@ +/* + * Licensed to the Apache Software Foundatio

[GitHub] [flink] fredia commented on a diff in pull request #22890: [FLINK-32072][checkpoint] Create and wire FileMergingSnapshotManager with TaskManagerServices

fredia commented on code in PR #22890: URL: https://github.com/apache/flink/pull/22890#discussion_r1300853718 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorFileMergingManager.java: ## @@ -0,0 +1,163 @@ +/* + * Licensed to the Apache Software Foundatio

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

wangzzu commented on PR #23244: URL: https://github.com/apache/flink/pull/23244#issuecomment-1687319371 @Jiabao-Sun thanks, i have fixed these -- 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

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

wangzzu commented on code in PR #23244: URL: https://github.com/apache/flink/pull/23244#discussion_r1300834641 ## flink-runtime/src/test/java/org/apache/flink/runtime/net/ConnectionUtilsTest.java: ## @@ -33,16 +30,14 @@ import java.net.ServerSocket; import java.net.UnknownHost

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

wangzzu commented on code in PR #23244: URL: https://github.com/apache/flink/pull/23244#discussion_r1300834532 ## flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java: ## @@ -628,19 +631,20 @@ public void testOutOfMemoryErrorMessageEnrichmentI

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

wangzzu commented on code in PR #23244: URL: https://github.com/apache/flink/pull/23244#discussion_r1300834374 ## flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java: ## @@ -498,15 +501,15 @@ public void testJobWithAllVerticesFailingDuringIns

[GitHub] [flink] flinkbot commented on pull request #23250: [FLINK-32897][table-runtime]Fix RowToRowCastRule get wrong result error while cast Array(Row()) type

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

[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_r1300832684 ## flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml: ## @@ -71,15 +71,16 @@ under the License.

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

wangzzu commented on code in PR #23244: URL: https://github.com/apache/flink/pull/23244#discussion_r1300834163 ## flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java: ## @@ -422,14 +425,14 @@ public void testJobWithAnOccasionallyFailingSender

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

wangzzu commented on code in PR #23244: URL: https://github.com/apache/flink/pull/23244#discussion_r1300833923 ## flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java: ## @@ -127,8 +125,13 @@ public void testHandleStreamingJobsWhenNotEnoughSlot

[jira] [Updated] (FLINK-32897) RowToRowCastRule will get wrong result while cast Array(Row()) type

[ https://issues.apache.org/jira/browse/FLINK-32897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32897: --- Labels: pull-request-available (was: ) > RowToRowCastRule will get wrong result while cast

[GitHub] [flink] swuferhong opened a new pull request, #23250: [FLINK-32897][table-runtime]Fix RowToRowCastRule get wrong result error while cast Array(Row()) type

swuferhong opened a new pull request, #23250: URL: https://github.com/apache/flink/pull/23250 ## What is the purpose of the change This pr is aims to fix RowToRowCastRule get wrong result error while cast Array(Row()) type. For the below case: `CREATE TABLE print_sink ( a

[jira] [Updated] (FLINK-32897) RowToRowCastRule will get wrong result while cast Array(Row()) type

[ https://issues.apache.org/jira/browse/FLINK-32897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-32897: -- Summary: RowToRowCastRule will get wrong result while cast Array(Row()) type (was: Kafka with

[jira] [Comment Edited] (FLINK-32900) Flink SQL doesn't find any built-in SQL functions

[ https://issues.apache.org/jira/browse/FLINK-32900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756924#comment-17756924 ] Tan Kim edited comment on FLINK-32900 at 8/22/23 1:52 AM: -- Than

[jira] [Comment Edited] (FLINK-32900) Flink SQL doesn't find any built-in SQL functions

[ https://issues.apache.org/jira/browse/FLINK-32900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756924#comment-17756924 ] Tan Kim edited comment on FLINK-32900 at 8/22/23 1:51 AM: -- Than

[jira] [Comment Edited] (FLINK-32900) Flink SQL doesn't find any built-in SQL functions

[ https://issues.apache.org/jira/browse/FLINK-32900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756924#comment-17756924 ] Tan Kim edited comment on FLINK-32900 at 8/22/23 1:50 AM: -- Than

[jira] [Comment Edited] (FLINK-32900) Flink SQL doesn't find any built-in SQL functions

[ https://issues.apache.org/jira/browse/FLINK-32900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756924#comment-17756924 ] Tan Kim edited comment on FLINK-32900 at 8/22/23 1:50 AM: -- Than

[jira] [Commented] (FLINK-28866) Use DDL instead of legacy method to register the test source in JoinITCase

[ https://issues.apache.org/jira/browse/FLINK-28866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757169#comment-17757169 ] Shuai Xu commented on FLINK-28866: -- Hi, I would like to fix this issue. Could it be ass

[jira] [Commented] (FLINK-32817) Supports running jar file names with Spaces

[ https://issues.apache.org/jira/browse/FLINK-32817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757168#comment-17757168 ] Xianxun Ye commented on FLINK-32817: [~xtsong] WDYT? If it is reasonable, I want to

[jira] [Updated] (FLINK-31180) Fail early when installing minikube and check whether we can retry

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

[jira] [Updated] (FLINK-26635) KafkaSourceE2ECase.testMultipleSplits failed on azure with Correlation id for response does not match request

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

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

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

[jira] [Updated] (FLINK-28503) Fix invalid link in Python FAQ Document

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

[jira] [Updated] (FLINK-30540) DataSinkTaskTest failed with a 134 exit code

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

[jira] [Updated] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

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

[jira] [Updated] (FLINK-25939) PyFlink YARN per-job on Docker test fails on AZP because it could not acquire all required slots

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

[jira] [Updated] (FLINK-25442) HBaseConnectorITCase.testTableSink failed on azure

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

[jira] [Updated] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

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

[jira] [Updated] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown

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

[jira] [Updated] (FLINK-27883) KafkaSubscriberTest failed with NPC

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

[jira] [Updated] (FLINK-27952) Table UDF fails when using Double.POSITIVE_INFINITY as parameters

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

[jira] [Updated] (FLINK-28319) ResumeCheckpointManuallyITCase gets stuck

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

[jira] [Updated] (FLINK-30899) FileSystemTableSource with CSV format incorrectly selects fields if filtering for partition

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

[jira] [Updated] (FLINK-28395) Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi fails with Elasticsearch exception [type=index_not_found_exception, reason=no such index]

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

[jira] [Updated] (FLINK-28424) JdbcExactlyOnceSinkE2eTest hangs on Azure

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

[jira] [Updated] (FLINK-28455) pyflink tableResult collect result to local timeout

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

[jira] [Updated] (FLINK-28530) Improvement of extraction of conditions that can be pushed into join inputs

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

[jira] [Updated] (FLINK-29671) Kubernetes e2e test fails during test initialization

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

[jira] [Updated] (FLINK-28545) FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool failed with TimeoutException: Topic flink-kafka-producer-fail-before-notify not present in m

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

[jira] [Updated] (FLINK-25736) Chinese Translation - Update documentation for Kinesis Table Api

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

[jira] [Updated] (FLINK-28741) Unexpected result if insert 'false' to boolean column

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

[jira] [Updated] (FLINK-25765) Kubernetes: flink's configmap and flink's actual config are out of sync

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

[jira] [Updated] (FLINK-25665) DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure

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

[jira] [Updated] (FLINK-25730) Fix chaining strategy (and typo?) in RowTimeMiniBatchAssginerOperator

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

[jira] [Updated] (FLINK-30768) flink-web version cleanup

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

[jira] [Updated] (FLINK-25768) Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks failed on azure

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

[jira] [Updated] (FLINK-30136) ElasticsearchSinkITCase.testElasticsearchSink failed on azure due to ES service unavailable

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

[jira] [Updated] (FLINK-30484) ZooKeeperLeaderElectionTest.testZooKeeperReelection timed out

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

[jira] [Updated] (FLINK-25814) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond failed due to stop-with-savepoint failed

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

[jira] [Updated] (FLINK-25737) Chinese Translation - Add documentation for Firehose Async Sink

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

[jira] [Updated] (FLINK-26341) ZooKeeperTestEnvironment does not allow for repeated test execution

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

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23211: [FLINK-32835][runtime] Migrate unit tests in "accumulators" and "blob" packages to JUnit5

ferenc-csaky commented on code in PR #23211: URL: https://github.com/apache/flink/pull/23211#discussion_r1300644670 ## flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobCachePutTest.java: ## @@ -582,57 +545,47 @@ public void testPutBufferFailsForJobHa() throws IOExc

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23211: [FLINK-32835][runtime] Migrate unit tests in "accumulators" and "blob" packages to JUnit5

ferenc-csaky commented on code in PR #23211: URL: https://github.com/apache/flink/pull/23211#discussion_r1300638014 ## flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobKeyTest.java: ## @@ -235,8 +228,8 @@ private void testStreams(BlobKey.BlobType blobType) throws I

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23211: [FLINK-32835][runtime] Migrate unit tests in "accumulators" and "blob" packages to JUnit5

ferenc-csaky commented on code in PR #23211: URL: https://github.com/apache/flink/pull/23211#discussion_r1300624234 ## flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobCacheRecoveryTest.java: ## @@ -18,135 +18,41 @@ package org.apache.flink.runtime.blob; -impor

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23211: [FLINK-32835][runtime] Migrate unit tests in "accumulators" and "blob" packages to JUnit5

ferenc-csaky commented on code in PR #23211: URL: https://github.com/apache/flink/pull/23211#discussion_r1300622354 ## flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobCacheCorruptionTest.java: ## @@ -92,118 +78,24 @@ private void testGetFailsFromCorruptFile(

[GitHub] [flink] architgyl commented on pull request #23164: [FLINK- 32775]Add parent dir of files to classpath using yarn.provided.lib.dirs

architgyl commented on PR #23164: URL: https://github.com/apache/flink/pull/23164#issuecomment-1686681635 @GJL can you please help review this PR. -- 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

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

X-czh commented on PR #23212: URL: https://github.com/apache/flink/pull/23212#issuecomment-1686614821 Thanks @huwh for the comments. I've updated a new commit that did the following: 1. No longer package `flink-examples-streaming` and `flink-connector-datagen` into a uber-jar, as there a

[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_r1300285624 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientMultipartTest.java: ## @@ -48,7 +48,7 @@ class RestClientMultipartTest { @TempDir public

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

Jiabao-Sun commented on code in PR #23244: URL: https://github.com/apache/flink/pull/23244#discussion_r1300257983 ## flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java: ## @@ -127,8 +125,13 @@ public void testHandleStreamingJobsWhenNotEnoughS

[GitHub] [flink] flinkbot commented on pull request #23249: [FLINK-32710][runtime/coordination]prefixed the component name of LeaderElection with `job-`

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

[jira] [Updated] (FLINK-32710) The LeaderElection component IDs for running is only the JobID which might be confusing in the log output

[ https://issues.apache.org/jira/browse/FLINK-32710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32710: --- Labels: pull-request-available starter (was: starter) > The LeaderElection component IDs fo

[GitHub] [flink] archzi opened a new pull request, #23249: [FLINK-32710][runtime/coordination]prefixed the component name of LeaderElection with `job-`

archzi opened a new pull request, #23249: URL: https://github.com/apache/flink/pull/23249 ## What is the purpose of the change Only prefixed the component name of LeaderElection with `job-`, as the ticket described. ## Verifying this change This change is already covered by exis

[jira] [Closed] (FLINK-19418) Inline PRIMARY KEY constraint should be invalid

[ https://issues.apache.org/jira/browse/FLINK-19418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-19418. --- Fix Version/s: 1.17.0 Resolution: Fixed > Inline PRIMARY KEY constraint should be invalid > -

[jira] [Commented] (FLINK-19418) Inline PRIMARY KEY constraint should be invalid

[ https://issues.apache.org/jira/browse/FLINK-19418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756956#comment-17756956 ] lincoln lee commented on FLINK-19418: - Inline PRIMARY KEY constraint (not ENFORCED m

[jira] [Updated] (FLINK-32904) Support cron expressions for periodic snapshots triggering

[ https://issues.apache.org/jira/browse/FLINK-32904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32904: -- Description: Current functionality to trigger savepoints and checkpoints is based on s

[jira] [Created] (FLINK-32904) Support cron expressions for periodic snapshots triggering

Alexander Fedulov created FLINK-32904: - Summary: Support cron expressions for periodic snapshots triggering Key: FLINK-32904 URL: https://issues.apache.org/jira/browse/FLINK-32904 Project: Flink

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #655: [FLINK-32903] Add a load simulation example pipeline for canary testing

gyfora commented on code in PR #655: URL: https://github.com/apache/flink-kubernetes-operator/pull/655#discussion_r1300192479 ## examples/autoscaling/src/main/java/autoscaling/LoadSimulationPipeline.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache Software Foundation (

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #655: [FLINK-32903] Add a load simulation example pipeline for canary testing

gyfora commented on code in PR #655: URL: https://github.com/apache/flink-kubernetes-operator/pull/655#discussion_r1300191845 ## examples/autoscaling/src/main/java/autoscaling/LoadSimulationPipeline.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache Software Foundation (

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #655: [FLINK-32903] Add a load simulation example pipeline for canary testing

mxm commented on code in PR #655: URL: https://github.com/apache/flink-kubernetes-operator/pull/655#discussion_r1300144619 ## examples/autoscaling/autoscaling-canary.yaml: ## @@ -0,0 +1,56 @@ + +#

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #655: [FLINK-32903] Add a load simulation example pipeline for canary testing

mxm commented on code in PR #655: URL: https://github.com/apache/flink-kubernetes-operator/pull/655#discussion_r1300144156 ## examples/autoscaling/autoscaling-canary.yaml: ## @@ -0,0 +1,56 @@ + +#

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #655: [FLINK-32903] Add a load simulation example pipeline for canary testing

mxm commented on code in PR #655: URL: https://github.com/apache/flink-kubernetes-operator/pull/655#discussion_r1300143301 ## examples/autoscaling/src/main/java/autoscaling/LoadSimulationPipeline.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #655: [FLINK-32903] Add a load simulation example pipeline for canary testing

mxm commented on code in PR #655: URL: https://github.com/apache/flink-kubernetes-operator/pull/655#discussion_r1300142231 ## examples/autoscaling/src/main/java/autoscaling/LoadSimulationPipeline.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[jira] [Comment Edited] (FLINK-32900) Flink SQL doesn't find any built-in SQL functions

[ https://issues.apache.org/jira/browse/FLINK-32900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756927#comment-17756927 ] Tan Kim edited comment on FLINK-32900 at 8/21/23 1:48 PM: -- [~Se

[jira] [Commented] (FLINK-32900) Flink SQL doesn't find any built-in SQL functions

[ https://issues.apache.org/jira/browse/FLINK-32900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756927#comment-17756927 ] Tan Kim commented on FLINK-32900: - [~Sergey Nuyanzin]  I just used REGEXP_EXTRACT funct

[jira] [Commented] (FLINK-32900) Flink SQL doesn't find any built-in SQL functions

[ https://issues.apache.org/jira/browse/FLINK-32900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756924#comment-17756924 ] Tan Kim commented on FLINK-32900: - Thank you for the reply! I will share the stacktrace

[jira] [Commented] (FLINK-32900) Flink SQL doesn't find any built-in SQL functions

[ https://issues.apache.org/jira/browse/FLINK-32900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756918#comment-17756918 ] Sergey Nuyanzin commented on FLINK-32900: - Hi [~tanee.kim]could you please share

[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&focusedCommentId=17756913#comment-17756913 ] Alexander Fedulov commented on FLINK-32821: --- [~huweihua] Oh, I see, good catch

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

wangzzu commented on code in PR #23242: URL: https://github.com/apache/flink/pull/23242#discussion_r1300087671 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestServerEndpointConfigurationTest.java: ## @@ -22,42 +22,38 @@ import org.apache.flink.configuration.Res

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #655: [FLINK-32903] Add a load simulation example pipeline for canary testing

gyfora commented on code in PR #655: URL: https://github.com/apache/flink-kubernetes-operator/pull/655#discussion_r1300080706 ## examples/autoscaling/src/main/java/autoscaling/LoadSimulationPipeline.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache Software Foundation (

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

wangzzu commented on code in PR #23242: URL: https://github.com/apache/flink/pull/23242#discussion_r1300073868 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestServerEndpointITCase.java: ## @@ -109,34 +108,26 @@ import static java.util.Objects.requireNonNull;

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

wangzzu commented on code in PR #23242: URL: https://github.com/apache/flink/pull/23242#discussion_r1300073633 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestExternalHandlersITCase.java: ## @@ -128,29 +124,27 @@ void teardown() throws Exception { void test

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

wangzzu commented on code in PR #23242: URL: https://github.com/apache/flink/pull/23242#discussion_r1300071546 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestServerEndpointITCase.java: ## @@ -340,60 +331,52 @@ public void testBadHandlerRequest() throws Exceptio

[jira] [Updated] (FLINK-32799) Release Testing: Verify FLINK-26603 -Decouple Hive with Flink planner

[ https://issues.apache.org/jira/browse/FLINK-32799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32799: -- Attachment: lib.png > Release Testing: Verify FLINK-26603 -Decouple Hive with Flink planner >

  1   2   3   >