[GitHub] [flink] XComp commented on pull request #22380: [FLINK-31773][runtime] Separate DefaultLeaderElectionService.start(LeaderContender) into two separate methods for starting the driver and regis

2023-05-16 Thread via GitHub
XComp commented on PR #22380: URL: https://github.com/apache/flink/pull/22380#issuecomment-1549085766 The e2e test failed due to some (temporary) network connectivity issues within the Docker image (see

[jira] [Commented] (FLINK-32069) jobClient.getJobStatus() can return status RUNNING for finished insert operation

2023-05-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723006#comment-17723006 ] Matthias Pohl commented on FLINK-32069: --- >From the 1.15 finding above the issue might be that

[jira] [Commented] (FLINK-32106) Unstable connection to archive.apache.org on AZP

2023-05-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723015#comment-17723015 ] Sergey Nuyanzin commented on FLINK-32106: -

[jira] [Commented] (FLINK-32106) Unstable connection to archive.apache.org on AZP

2023-05-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723014#comment-17723014 ] Sergey Nuyanzin commented on FLINK-32106: -

[jira] [Commented] (FLINK-32106) Unstable connection to archive.apache.org on AZP

2023-05-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723016#comment-17723016 ] Sergey Nuyanzin commented on FLINK-32106: -

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-16 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1194715570 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-16 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1194715570 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #599: [docs] Update documentation to cover some recent improvements

2023-05-16 Thread via GitHub
gyfora merged PR #599: URL: https://github.com/apache/flink-kubernetes-operator/pull/599 -- 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] [Created] (FLINK-32107) Kubernetes test failed because ofunable to establish ssl connection to github on AZP

2023-05-16 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32107: --- Summary: Kubernetes test failed because ofunable to establish ssl connection to github on AZP Key: FLINK-32107 URL: https://issues.apache.org/jira/browse/FLINK-32107

[GitHub] [flink] flinkbot commented on pull request #22589: [BP][FLINK-31418][network][tests] Fix unstable test case SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout

2023-05-16 Thread via GitHub
flinkbot commented on PR #22589: URL: https://github.com/apache/flink/pull/22589#issuecomment-1549153267 ## CI report: * 196a41ad5f4a8630ecc6a42b7bf63ed6ad495cbd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-connector-aws] PatrickRen commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-16 Thread via GitHub
PatrickRen commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1194559931 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/ShardAssignerFactory.java: ## @@ -0,0

[jira] [Commented] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-05-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723017#comment-17723017 ] Sergey Nuyanzin commented on FLINK-31418: -

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-16 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1194737965 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-16 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1194738322 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/PollingKinesisShardSplitReader.java: ## @@ -0,0 +1,152

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #602: [docs] Update documentation to cover some recent improvements

2023-05-16 Thread via GitHub
gyfora merged PR #602: URL: https://github.com/apache/flink-kubernetes-operator/pull/602 -- 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-31825) Stopping minikube fails with timeout

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-31825: -- Priority: Major (was: Critical) > Stopping minikube fails with timeout >

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-16 Thread via GitHub
TanYuxin-tyx commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1194794966 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/LookupJoinITCase.scala: ## @@ -30,19 +30,15 @@ import

[jira] [Comment Edited] (FLINK-32069) jobClient.getJobStatus() can return status RUNNING for finished insert operation

2023-05-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722998#comment-17722998 ] Matthias Pohl edited comment on FLINK-32069 at 5/16/23 6:18 AM: Ok, I

[jira] [Commented] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-05-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723020#comment-17723020 ] Weijie Guo commented on FLINK-31418: I will try to backport this to 1.16 and see if the problem can

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-16 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1194715570 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-16 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1194716692 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/ShardAssignerFactory.java: ## @@ -0,0

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #601: [hotfix][docs] fix some typos

2023-05-16 Thread via GitHub
gyfora commented on code in PR #601: URL: https://github.com/apache/flink-kubernetes-operator/pull/601#discussion_r1194722354 ## docs/content/docs/custom-resource/autoscaler.md: ## @@ -55,20 +55,20 @@ To disable scaling actions, set:

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scaling down with unaligned checkpoints

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723037#comment-17723037 ] Qingsheng Ren commented on FLINK-31963: --- [~srichter] Is there any updates on this issue? Thanks >

[jira] [Commented] (FLINK-30596) Multiple POST /jars/:jarid/run requests with the same jobId, runs duplicate jobs

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723038#comment-17723038 ] Qingsheng Ren commented on FLINK-30596: --- [~morezaei00] Any updates on this issue? Thanks >

[jira] [Assigned] (FLINK-30596) Multiple POST /jars/:jarid/run requests with the same jobId, runs duplicate jobs

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-30596: - Assignee: Mohsen Rezaei > Multiple POST /jars/:jarid/run requests with the same jobId,

[jira] [Commented] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-05-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723022#comment-17723022 ] Weijie Guo commented on FLINK-31418: It seems that the commits information has been missed

[jira] [Updated] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-05-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31418: --- Fix Version/s: 1.17.0 > SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-16 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1194739601 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/SourceConfigConstants.java: ## @@ -0,0 +1,371 @@ +/* +

[GitHub] [flink-connector-jdbc] reswqa merged pull request #45: [hotfix] Fix incorrect sql_url in jdbc.yml.

2023-05-16 Thread via GitHub
reswqa merged PR #45: URL: https://github.com/apache/flink-connector-jdbc/pull/45 -- 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] [Comment Edited] (FLINK-32069) jobClient.getJobStatus() can return status RUNNING for finished insert operation

2023-05-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723006#comment-17723006 ] Matthias Pohl edited comment on FLINK-32069 at 5/16/23 6:48 AM: >From

[jira] [Updated] (FLINK-32106) Unstable connection to archive.apache.org on AZP

2023-05-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32106: Description: Azure pipelines fail with {noformat} Using Google mirror Resolving

[jira] [Created] (FLINK-32106) Unstable connection to archive.apache.org on AZP

2023-05-16 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32106: --- Summary: Unstable connection to archive.apache.org on AZP Key: FLINK-32106 URL: https://issues.apache.org/jira/browse/FLINK-32106 Project: Flink Issue

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #602: [docs] Update documentation to cover some recent improvements

2023-05-16 Thread via GitHub
gyfora opened a new pull request, #602: URL: https://github.com/apache/flink-kubernetes-operator/pull/602 (no comment) -- 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

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-16 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1194736683 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0

[jira] [Comment Edited] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-05-16 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723027#comment-17723027 ] Yuxin Tan edited comment on FLINK-31418 at 5/16/23 7:31 AM: [~Sergey

[jira] [Commented] (FLINK-32107) Kubernetes test failed because ofunable to establish ssl connection to github on AZP

2023-05-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723028#comment-17723028 ] Sergey Nuyanzin commented on FLINK-32107: -

[jira] [Commented] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-05-16 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723027#comment-17723027 ] Yuxin Tan commented on FLINK-31418: --- [~Sergey Nuyanzin][~Weijie Guo], The patch is not in

[jira] [Updated] (FLINK-32107) Kubernetes test failed because ofunable to establish ssl connection to github on AZP

2023-05-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32107: Affects Version/s: 1.18.0 > Kubernetes test failed because ofunable to establish ssl

[jira] [Commented] (FLINK-31669) DynamicFilteringITCase failed fataly because of NoClassDefFoundError of akka/actor/SuppressedDeadLetter

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723036#comment-17723036 ] Qingsheng Ren commented on FLINK-31669: --- [~chesnay] Could you take a look at this one? Thanks >

[jira] [Assigned] (FLINK-27131) CastFunctionITCase.test failed on azure

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-27131: - Assignee: Sergey Nuyanzin > CastFunctionITCase.test failed on azure >

[jira] [Commented] (FLINK-31168) JobManagerHAProcessFailureRecoveryITCase failed due to job not being found

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723039#comment-17723039 ] Qingsheng Ren commented on FLINK-31168: --- [~mapohl] are you still working on this issue? Thanks >

[jira] [Commented] (FLINK-31354) NettyClientServerSslTest.testValidSslConnectionAdvanced timed out

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723040#comment-17723040 ] Qingsheng Ren commented on FLINK-31354: --- [~mapohl] Any updates on this one? Thanks  >

[GitHub] [flink] WencongLiu commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-16 Thread via GitHub
WencongLiu commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1194788873 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/agg/AggregateITCaseBase.scala: ## @@ -718,36 +722,39 @@ abstract

[jira] [Resolved] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-05-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-31759. Resolution: Fixed > Update some external connectors to use sql_connector_download_table and >

[GitHub] [flink] XComp commented on pull request #22380: [FLINK-31773][runtime] Separate DefaultLeaderElectionService.start(LeaderContender) into two separate methods for starting the driver and regis

2023-05-16 Thread via GitHub
XComp commented on PR #22380: URL: https://github.com/apache/flink/pull/22380#issuecomment-1549084955 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Assigned] (FLINK-32105) Add apache/flink-training release to docs about creating a Flink release

2023-05-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-32105: - Assignee: David Anderson > Add apache/flink-training release to docs about creating a

[jira] [Created] (FLINK-32105) Add apache/flink-training release to docs about creating a Flink release

2023-05-16 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32105: - Summary: Add apache/flink-training release to docs about creating a Flink release Key: FLINK-32105 URL: https://issues.apache.org/jira/browse/FLINK-32105 Project:

[jira] [Updated] (FLINK-32107) Kubernetes test failed because ofunable to establish ssl connection to github on AZP

2023-05-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32107: Affects Version/s: 1.17.1 > Kubernetes test failed because ofunable to establish ssl

[GitHub] [flink] TanYuxin-tyx opened a new pull request, #22589: [BP][FLINK-31418][network][tests] Fix unstable test case SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout

2023-05-16 Thread via GitHub
TanYuxin-tyx opened a new pull request, #22589: URL: https://github.com/apache/flink/pull/22589 ## What is the purpose of the change Backport to release-1.16. *Fix buffer request timeout for sort merge result partition read test* ## Brief change log

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-16 Thread via GitHub
TanYuxin-tyx commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1194769979 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/agg/GroupWindowITCase.scala: ## @@ -743,23 +744,27 @@ class

[jira] [Assigned] (FLINK-31669) DynamicFilteringITCase failed fataly because of NoClassDefFoundError of akka/actor/SuppressedDeadLetter

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-31669: - Assignee: Chesnay Schepler > DynamicFilteringITCase failed fataly because of

[jira] [Assigned] (FLINK-31731) No suitable constructor found for DebeziumAvroSerializationSchema

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-31731: - Assignee: Tzu-Li (Gordon) Tai > No suitable constructor found for

[jira] [Updated] (FLINK-31802) Python py37-cython: commands failed, error at setup of ProcessWindowTests.test_count_sliding_window

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-31802: -- Priority: Major (was: Critical) > Python py37-cython: commands failed, error at setup of >

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scaling down with unaligned checkpoints

2023-05-16 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723051#comment-17723051 ] Stefan Richter commented on FLINK-31963: Yes, PR is currently in review here:

[jira] [Commented] (FLINK-31810) RocksDBException: Bad table magic number on checkpoint rescale

2023-05-16 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723056#comment-17723056 ] Yun Tang commented on FLINK-31810: -- To be honest, I doubt that this problem might be related with

[GitHub] [flink] fsk119 commented on a diff in pull request #22525: [FLINK-32001][table] Row-level update should support returning partial columns

2023-05-16 Thread via GitHub
fsk119 commented on code in PR #22525: URL: https://github.com/apache/flink/pull/22525#discussion_r1194926178 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java: ## @@ -647,15 +649,51 @@ private

[jira] [Closed] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-05-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31418. -- Resolution: Fixed Feel free to reopen this If it can still reproduce. >

[jira] [Resolved] (FLINK-32104) stop-with-savepoint fails and times out with simple reproducible example

2023-05-16 Thread Kurt Ostfeld (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Ostfeld resolved FLINK-32104. -- Resolution: Invalid [~Weijie Guo] , thank you so much for your help. If I move the sleep

[GitHub] [flink] LadyForest opened a new pull request, #22593: [FLINK-32053][table-planner] Introduce StateMetadata to ExecNode to support configure operator-level state TTL via CompiledPlan

2023-05-16 Thread via GitHub
LadyForest opened a new pull request, #22593: URL: https://github.com/apache/flink/pull/22593 ## What is the purpose of the change This PR is a subtask of FLIP-292 to enable operator-level state TTL configuration via `CompiledPlan`. ## Brief change log Introduce

[jira] [Updated] (FLINK-31678) NonHAQueryableStateFsBackendITCase.testAggregatingState: Query did no succeed

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-31678: -- Priority: Major (was: Critical) > NonHAQueryableStateFsBackendITCase.testAggregatingState:

[jira] [Commented] (FLINK-31810) RocksDBException: Bad table magic number on checkpoint rescale

2023-05-16 Thread David Artiga (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723060#comment-17723060 ] David Artiga commented on FLINK-31810: -- I will if it happens again > RocksDBException: Bad table

[jira] [Updated] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-05-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31418: --- Fix Version/s: 1.16.2 > SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed

[GitHub] [flink] XComp opened a new pull request, #22591: [FLINK-31354][tests] Increased timeout for NettyClientServerSslTest to improve test stability

2023-05-16 Thread via GitHub
XComp opened a new pull request, #22591: URL: https://github.com/apache/flink/pull/22591 ## What is the purpose of the change We see the test occassionally fail due to slow CI machines (see further details in FLINK-31354). Increasing the timeouts should solve the issue. ##

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22584: [FLINK-31963][state] Fix rescaling bug in recovery from unaligned checkpoints.

2023-05-16 Thread via GitHub
rkhachatryan commented on code in PR #22584: URL: https://github.com/apache/flink/pull/22584#discussion_r1194862690 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java: ## @@ -136,19 +136,24 @@ public void assignStates() {

[jira] [Updated] (FLINK-32108) KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message

2023-05-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32108: -- Priority: Minor (was: Major) > KubernetesExtension calls assumeThat in @BeforeAll callback

[GitHub] [flink] reswqa commented on a diff in pull request #22246: [FLINK-31498][runtime] Only request redundant task manager when all pending slots registered.

2023-05-16 Thread via GitHub
reswqa commented on code in PR #22246: URL: https://github.com/apache/flink/pull/22246#discussion_r1194839931 ## flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/TaskExecutorManagerTest.java: ## @@ -176,22 +170,25 @@ public void

[jira] [Created] (FLINK-32108) KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message

2023-05-16 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32108: - Summary: KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message Key: FLINK-32108 URL:

[GitHub] [flink-kubernetes-operator] mbalassi commented on pull request #600: FLINK-32103 Update RBAC for OpenShift Deployment

2023-05-16 Thread via GitHub
mbalassi commented on PR #600: URL: https://github.com/apache/flink-kubernetes-operator/pull/600#issuecomment-1549343760 Thanks, @jbusche. Could you please also add `flinksessionjobs/finalizers` for the sake of completeness then? -- This is an automated message from the Apache Git

[GitHub] [flink] XComp commented on pull request #22380: [FLINK-31773][runtime] Separate DefaultLeaderElectionService.start(LeaderContender) into two separate methods for starting the driver and regis

2023-05-16 Thread via GitHub
XComp commented on PR #22380: URL: https://github.com/apache/flink/pull/22380#issuecomment-1549377590 @reswqa anything to add from your side? I squashed the changes into a single commit now. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #601: [hotfix][docs] fix some typos

2023-05-16 Thread via GitHub
mxm commented on code in PR #601: URL: https://github.com/apache/flink-kubernetes-operator/pull/601#discussion_r1194990546 ## docs/content/docs/custom-resource/autoscaler.md: ## @@ -55,20 +55,20 @@ To disable scaling actions, set:

[GitHub] [flink] reswqa merged pull request #22589: [BP-1.16][FLINK-31418][network][tests] Fix unstable test case SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout

2023-05-16 Thread via GitHub
reswqa merged PR #22589: URL: https://github.com/apache/flink/pull/22589 -- 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] [Comment Edited] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-05-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723022#comment-17723022 ] Weijie Guo edited comment on FLINK-31418 at 5/16/23 11:44 AM: -- It seems

[jira] [Comment Edited] (FLINK-32047) Fix args in JobSpec not being passed through to Flink in Standalone mode - 1.4.0

2023-05-16 Thread Gil Shmaya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722785#comment-17722785 ] Gil Shmaya edited comment on FLINK-32047 at 5/16/23 12:15 PM: -- [~usamj] We

[GitHub] [flink] flinkbot commented on pull request #22593: [FLINK-32053][table-planner] Introduce StateMetadata to ExecNode to support configure operator-level state TTL via CompiledPlan

2023-05-16 Thread via GitHub
flinkbot commented on PR #22593: URL: https://github.com/apache/flink/pull/22593#issuecomment-1549574905 ## CI report: * 1351fed7f6d70f7972fc9f88aa455a1f55cc3fa2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] snuyanzin commented on a diff in pull request #22573: [FLINK-32058][tests] Migrate the subclasses of BatchAbstractTestBase in runtime.batch.sql to JUnit5

2023-05-16 Thread via GitHub
snuyanzin commented on code in PR #22573: URL: https://github.com/apache/flink/pull/22573#discussion_r1195104019 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/MiscITCase.scala: ## @@ -528,82 +527,97 @@ class MiscITCase

[GitHub] [flink] snuyanzin commented on a diff in pull request #22573: [FLINK-32058][tests] Migrate the subclasses of BatchAbstractTestBase in runtime.batch.sql to JUnit5

2023-05-16 Thread via GitHub
snuyanzin commented on code in PR #22573: URL: https://github.com/apache/flink/pull/22573#discussion_r1195103455 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/MiscITCase.scala: ## @@ -528,82 +527,97 @@ class MiscITCase

[jira] [Assigned] (FLINK-31724) SqlClientITCase.testMatchRecognize fails with "bash -c rm -rf /opt/flink/checkpoint/*" returned non-zero exit code 1

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-31724: - Assignee: Qingsheng Ren > SqlClientITCase.testMatchRecognize fails with "bash -c rm

[jira] [Commented] (FLINK-31661) Add parity between `ROW` value function and it's type declaration

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723043#comment-17723043 ] Qingsheng Ren commented on FLINK-31661: --- As this is a new feature, we'd like to downgrade it to

[jira] [Assigned] (FLINK-31141) CreateTableAsITCase.testCreateTableAs fails

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-31141: - Assignee: dalongliu > CreateTableAsITCase.testCreateTableAs fails >

[GitHub] [flink] WencongLiu commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-16 Thread via GitHub
WencongLiu commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1194803521 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/agg/HashAggITCase.scala: ## @@ -80,8 +80,20 @@ class

[GitHub] [flink] XComp commented on pull request #22591: [FLINK-31354][tests] Increased timeout for NettyClientServerSslTest to improve test stability

2023-05-16 Thread via GitHub
XComp commented on PR #22591: URL: https://github.com/apache/flink/pull/22591#issuecomment-1549240399 @zentol I guess, increasing the timeout should not cause any problems?! The test usually runs in milliseconds but occasionally runs into the 1000ms limit. -- This is an automated message

[jira] [Commented] (FLINK-31802) Python py37-cython: commands failed, error at setup of ProcessWindowTests.test_count_sliding_window

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723052#comment-17723052 ] Qingsheng Ren commented on FLINK-31802: --- Downgraded to major as this issue only appeared once.  >

[GitHub] [flink] dawidwys commented on a diff in pull request #22483: [FLINK-31118][table] Add ARRAY_UNION function.

2023-05-16 Thread via GitHub
dawidwys commented on code in PR #22483: URL: https://github.com/apache/flink/pull/22483#discussion_r1194882563 ## docs/data/sql_functions.yml: ## @@ -643,6 +643,9 @@ collection: - sql: ARRAY_REVERSE(haystack) table: haystack.arrayReverse() description: Returns an

[jira] [Resolved] (FLINK-31118) Add ARRAY_UNION supported in SQL & Table API

2023-05-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-31118. -- Resolution: Implemented Implemented in 1957ef5fabed0622b1d3e4b542f1df0ee070fc33 >

[GitHub] [flink] gyfora opened a new pull request, #22592: [FLINK-23190][runtime] Make schedulers allocate slots more evenly

2023-05-16 Thread via GitHub
gyfora opened a new pull request, #22592: URL: https://github.com/apache/flink/pull/22592 ## What is the purpose of the change Flink does not really do a good job at distributing the tasks uniformly across the taskmanagers of the cluster. The reason is that there is no strategy

[GitHub] [flink] liuyongvs commented on pull request #22312: [FLINK-31677][table] Add built-in MAP_ENTRIES function.

2023-05-16 Thread via GitHub
liuyongvs commented on PR #22312: URL: https://github.com/apache/flink/pull/22312#issuecomment-1549370329 hi @dawidwys could you have a look this ,it is long time no one to review and merge? -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #601: [hotfix][docs] fix some typos

2023-05-16 Thread via GitHub
mxm commented on code in PR #601: URL: https://github.com/apache/flink-kubernetes-operator/pull/601#discussion_r1194989758 ## docs/content/docs/custom-resource/autoscaler.md: ## @@ -55,20 +55,20 @@ To disable scaling actions, set:

[jira] [Updated] (FLINK-32100) Max parallelism is incorrectly calculated with multiple topics

2023-05-16 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-32100: --- Fix Version/s: kubernetes-operator-1.6.0

[jira] [Updated] (FLINK-32102) Aggregate multiple pendingRecords metric per source if present

2023-05-16 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-32102: --- Fix Version/s: kubernetes-operator-1.5.1 (was:

[jira] [Commented] (FLINK-32060) Migrate subclasses of BatchAbstractTestBase in table and other modules to JUnit5

2023-05-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723118#comment-17723118 ] Weijie Guo commented on FLINK-32060: master(1.18) via ce286c969a5b3914cdb993e94bff4f42e0c6599b. >

[GitHub] [flink] snuyanzin commented on a diff in pull request #22573: [FLINK-32058][tests] Migrate the subclasses of BatchAbstractTestBase in runtime.batch.sql to JUnit5

2023-05-16 Thread via GitHub
snuyanzin commented on code in PR #22573: URL: https://github.com/apache/flink/pull/22573#discussion_r1195102962 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/MiscITCase.scala: ## @@ -528,82 +527,97 @@ class MiscITCase

[jira] [Comment Edited] (FLINK-32069) jobClient.getJobStatus() can return status RUNNING for finished insert operation

2023-05-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722998#comment-17722998 ] Matthias Pohl edited comment on FLINK-32069 at 5/16/23 12:39 PM: - Ok, I

[jira] [Resolved] (FLINK-32060) Migrate subclasses of BatchAbstractTestBase in table and other modules to JUnit5

2023-05-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-32060. Fix Version/s: 1.18.0 Resolution: Fixed > Migrate subclasses of BatchAbstractTestBase in

[jira] [Updated] (FLINK-31661) Add parity between `ROW` value function and it's type declaration

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-31661: -- Priority: Major (was: Critical) > Add parity between `ROW` value function and it's type

[jira] [Assigned] (FLINK-31806) Prod architecture tests didn't detect non-public API usage

2023-05-16 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-31806: - Assignee: Etienne Chauchot > Prod architecture tests didn't detect non-public API

[GitHub] [flink] flinkbot commented on pull request #22591: [FLINK-31354][tests] Increased timeout for NettyClientServerSslTest to improve test stability

2023-05-16 Thread via GitHub
flinkbot commented on PR #22591: URL: https://github.com/apache/flink/pull/22591#issuecomment-1549253676 ## CI report: * ebb3338701efd7faa1b53eaa6955659e99e43391 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #22590: [FLINK-32071] Implement the snapshot manager for merged checkpoint files in TM

2023-05-16 Thread via GitHub
flinkbot commented on PR #22590: URL: https://github.com/apache/flink/pull/22590#issuecomment-1549253370 ## CI report: * 79b35ef79acef66f60a05c58c9fa43f00a6546c4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-31118) Add ARRAY_UNION supported in SQL & Table API

2023-05-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-31118: Assignee: jackylau > Add ARRAY_UNION supported in SQL & Table API >

[GitHub] [flink] dawidwys merged pull request #22483: [FLINK-31118][table] Add ARRAY_UNION function.

2023-05-16 Thread via GitHub
dawidwys merged PR #22483: URL: https://github.com/apache/flink/pull/22483 -- 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] rkhachatryan commented on a diff in pull request #22584: [FLINK-31963][state] Fix rescaling bug in recovery from unaligned checkpoints.

2023-05-16 Thread via GitHub
rkhachatryan commented on code in PR #22584: URL: https://github.com/apache/flink/pull/22584#discussion_r1194923077 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleITCase.java: ## @@ -459,46 +478,61 @@ public void

  1   2   3   >