[GitHub] [flink] XComp commented on a diff in pull request #22601: [FLINK-31781][runtime] Introduces the contender ID to the LeaderElectionService interface

2023-06-15 Thread via GitHub
XComp commented on code in PR #22601: URL: https://github.com/apache/flink/pull/22601#discussion_r1230500087 ## flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java: ## @@ -247,7 +247,7 @@ private LeaderElection

[GitHub] [flink] XComp merged pull request #22404: [FLINK-31797][runtime] Moves LeaderElection creation into HighAvailabilityServices

2023-06-15 Thread via GitHub
XComp merged PR #22404: URL: https://github.com/apache/flink/pull/22404 -- 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] [Resolved] (FLINK-31797) Move LeaderElectionService out of LeaderContender

2023-06-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-31797. --- Resolution: Fixed master: 55630de18baf6345072113f587006dac94f61c78 > Move

[GitHub] [flink-connector-jdbc] WenDing-Y commented on pull request #49: [FLINK-32068] connector jdbc support clickhouse

2023-06-15 Thread via GitHub
WenDing-Y commented on PR #49: URL: https://github.com/apache/flink-connector-jdbc/pull/49#issuecomment-1592422341 What other tasks are needed for this PR to merge @MartijnVisser -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-32205) Flink Rest Client should support connecting to the server using URLs.

2023-06-15 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32205: -- Description: Currently, Flink Client can only connect to the server via the address:port, which is

[GitHub] [flink] FangYongs commented on a diff in pull request #22758: [FLINK-31549][jdbc-driver] Add jdbc driver docs

2023-06-15 Thread via GitHub
FangYongs commented on code in PR #22758: URL: https://github.com/apache/flink/pull/22758#discussion_r1230560310 ## flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/BaseConnection.java: ## @@ -102,12 +101,6 @@ public int getTransactionIsolation()

[jira] [Created] (FLINK-32343) Fix exception for jdbc tools

2023-06-15 Thread Fang Yong (Jira)
Fang Yong created FLINK-32343: - Summary: Fix exception for jdbc tools Key: FLINK-32343 URL: https://issues.apache.org/jira/browse/FLINK-32343 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-32342) SQL Server container behaves unexpected while testing with several surefire forks

2023-06-15 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32342: --- Summary: SQL Server container behaves unexpected while testing with several surefire forks Key: FLINK-32342 URL: https://issues.apache.org/jira/browse/FLINK-32342

[jira] [Created] (FLINK-32344) MongoDB connector support unbounded streaming read via ChangeStream feature

2023-06-15 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-32344: -- Summary: MongoDB connector support unbounded streaming read via ChangeStream feature Key: FLINK-32344 URL: https://issues.apache.org/jira/browse/FLINK-32344 Project:

[jira] [Comment Edited] (FLINK-32318) [flink-operator] missing s3 plugin in folder plugins

2023-06-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732909#comment-17732909 ] Luís Costa edited comment on FLINK-32318 at 6/15/23 8:03 AM: - Hi [~nateab] 

[GitHub] [flink-connector-aws] MartijnVisser closed pull request #80: [FLINK-31923] Run nightly builds against multiple branches and Flink versions

2023-06-15 Thread via GitHub
MartijnVisser closed pull request #80: [FLINK-31923] Run nightly builds against multiple branches and Flink versions URL: https://github.com/apache/flink-connector-aws/pull/80 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-connector-opensearch] boring-cyborg[bot] commented on pull request #27: [FLINK-31923] Run nightly builds against multiple branches and Flink versions

2023-06-15 Thread via GitHub
boring-cyborg[bot] commented on PR #27: URL: https://github.com/apache/flink-connector-opensearch/pull/27#issuecomment-1592621331 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) --

[jira] [Created] (FLINK-32346) JdbcNumericBetweenParametersProvider Sharding key boundaries large storage long integer overflow, use BigDecimal instead Long

2023-06-15 Thread zhilinli (Jira)
zhilinli created FLINK-32346: Summary: JdbcNumericBetweenParametersProvider Sharding key boundaries large storage long integer overflow, use BigDecimal instead Long Key: FLINK-32346 URL:

[jira] [Updated] (FLINK-32346) JdbcNumericBetweenParametersProvider Sharding key boundaries large storage long integer overflow, use BigDecimal instead Long

2023-06-15 Thread zhilinli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhilinli updated FLINK-32346: - Description: Sharding key boundaries large storage long integer overflow, use BigDecimal instead Long,

[jira] [Updated] (FLINK-32346) JdbcNumericBetweenParametersProvider Sharding key boundaries large storage long integer overflow, use BigDecimal instead Long

2023-06-15 Thread zhilinli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhilinli updated FLINK-32346: - Attachment: image-2023-06-15-16-46-13-188.png > JdbcNumericBetweenParametersProvider Sharding key

[jira] [Updated] (FLINK-32346) JdbcNumericBetweenParametersProvider Sharding key boundaries large storage long integer overflow, use BigDecimal instead Long

2023-06-15 Thread zhilinli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhilinli updated FLINK-32346: - Description: *JdbcNumericBetweenParametersProvider.class* Sharding key boundaries large storage long

[GitHub] [flink] StefanRRichter opened a new pull request, #22788: [FLINK-32345][state] Improve parallel download of RocksDB incremental state.

2023-06-15 Thread via GitHub
StefanRRichter opened a new pull request, #22788: URL: https://github.com/apache/flink/pull/22788 This commit improves RocksDBStateDownloader to support parallelized state download across multiple state types and across multiple state handles. This can improve our download times for

[GitHub] [flink] FangYongs commented on a diff in pull request #22583: [FLINK-31673][jdbc-driver] Add e2e test for flink jdbc driver

2023-06-15 Thread via GitHub
FangYongs commented on code in PR #22583: URL: https://github.com/apache/flink/pull/22583#discussion_r1230700575 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/SqlGateway.java: ## @@ -168,7 +168,6 @@ public ShutdownThread(SqlGateway gateway) {

[jira] [Closed] (FLINK-31673) Add E2E tests for flink jdbc driver

2023-06-15 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li closed FLINK-31673. -- Fix Version/s: 1.18.0 Resolution: Fixed Implemented via

[GitHub] [flink-connector-elasticsearch] MartijnVisser merged pull request #68: [FLINK-31923] Run nightly builds against multiple branches and Flink versions

2023-06-15 Thread via GitHub
MartijnVisser merged PR #68: URL: https://github.com/apache/flink-connector-elasticsearch/pull/68 -- 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] [Closed] (FLINK-26041) AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure hang on azure

2023-06-15 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang closed FLINK-26041. -- Resolution: Cannot Reproduce >

[jira] [Commented] (FLINK-26041) AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure hang on azure

2023-06-15 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732964#comment-17732964 ] Lijie Wang commented on FLINK-26041: Close this ticket as it cannot be reproduced >

[GitHub] [flink-connector-mongodb] MartijnVisser merged pull request #10: [FLINK-31923] Run nightly builds against multiple branches and Flink versions

2023-06-15 Thread via GitHub
MartijnVisser merged PR #10: URL: https://github.com/apache/flink-connector-mongodb/pull/10 -- 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] [Commented] (FLINK-32348) MongoDB tests are flaky and time out

2023-06-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732967#comment-17732967 ] Martijn Visser commented on FLINK-32348: A full run with thread dumps can be found at

[jira] [Commented] (FLINK-19830) Properly implements processing-time temporal table join

2023-06-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732976#comment-17732976 ] Jark Wu commented on FLINK-19830: - Hi [~rmetzger], sorry for the late reply. Yes, your understanding of

[jira] [Created] (FLINK-32349) Support atomic for CREATE TABLE AS SELECT(CTAS) statement

2023-06-15 Thread tartarus (Jira)
tartarus created FLINK-32349: Summary: Support atomic for CREATE TABLE AS SELECT(CTAS) statement Key: FLINK-32349 URL: https://issues.apache.org/jira/browse/FLINK-32349 Project: Flink Issue

[jira] [Updated] (FLINK-32325) SqlServerDynamicTableSourceITCase is flaky

2023-06-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-32325: --- Fix Version/s: jdbc-3.1.1 > SqlServerDynamicTableSourceITCase is flaky >

[jira] [Created] (FLINK-32350) FLIP-311: Support Call Stored Procedure

2023-06-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-32350: Summary: FLIP-311: Support Call Stored Procedure Key: FLINK-32350 URL: https://issues.apache.org/jira/browse/FLINK-32350 Project: Flink Issue Type: New Feature

[GitHub] [flink] reswqa opened a new pull request, #22790: [hotfix][state] Fix incorrect comments of channel input state redistribution.

2023-06-15 Thread via GitHub
reswqa opened a new pull request, #22790: URL: https://github.com/apache/flink/pull/22790 ## What is the purpose of the change *Fix incorrect comments of channel input state redistribution.* ## Brief change log - *Fix incorrect comments of channel

[jira] [Created] (FLINK-32352) Support convert call procedure statement to correpsonding operation

2023-06-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-32352: Summary: Support convert call procedure statement to correpsonding operation Key: FLINK-32352 URL: https://issues.apache.org/jira/browse/FLINK-32352 Project: Flink

[jira] [Created] (FLINK-32354) Support to execute the call procedure operation

2023-06-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-32354: Summary: Support to execute the call procedure operation Key: FLINK-32354 URL: https://issues.apache.org/jira/browse/FLINK-32354 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-32357) Elasticsearch v3.0 won't compile when testing against Flink 1.17.1

2023-06-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733022#comment-17733022 ] Sergey Nuyanzin commented on FLINK-32357: - I remember something like that, I will have a look >

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on a diff in pull request #614: [FLINK-32057] Support 1.18 rescale api for applying parallelism overrides

2023-06-15 Thread via GitHub
gaborgsomogyi commented on code in PR #614: URL: https://github.com/apache/flink-kubernetes-operator/pull/614#discussion_r1230837995 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/NativeFlinkService.java: ## @@ -132,4 +165,153 @@

[GitHub] [flink] Tartarus0zm commented on pull request #22344: [FLINK-31721][core] Move JobStatusHook to flink-core module

2023-06-15 Thread via GitHub
Tartarus0zm commented on PR #22344: URL: https://github.com/apache/flink/pull/22344#issuecomment-1592937653 @gaoyunhaii hello, FLIP-305 has been accepted, please take a look at this pr -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] XComp commented on pull request #22601: [FLINK-31781][runtime] Introduces the contender ID to the LeaderElectionService interface

2023-06-15 Thread via GitHub
XComp commented on PR #22601: URL: https://github.com/apache/flink/pull/22601#issuecomment-1592971299 Thanks. I squashed the commits for a final CI run (even though I realized after the push that I could have just used the squash & merge in this case :facepalm: ). -- This is an

[GitHub] [flink] XComp commented on pull request #22642: [FLINK-32177][runtime] Refactors MultipleComponentLeaderElectionDriver.Listener.notifyAllKnownLeaderInformation signature

2023-06-15 Thread via GitHub
XComp commented on PR #22642: URL: https://github.com/apache/flink/pull/22642#issuecomment-1592975146 I rebased on most recent version of FLINK-31781 after that was approved to fix the conflicts. > e LeaderInformationWithComponentId is more expressive though ("What is that

[GitHub] [flink] flinkbot commented on pull request #22792: [FLINK-25000][build] Java 17 uses Scala 2.12.15

2023-06-15 Thread via GitHub
flinkbot commented on PR #22792: URL: https://github.com/apache/flink/pull/22792#issuecomment-1593041863 ## CI report: * baea61f3e55e790e63f5e84d02a58c9fc5174291 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] XComp commented on pull request #22656: [FLINK-32180][runtime] Moves error handling from DefaultMultipleComponentLeaderElectionService into the MultipleComponentLeaderElectionDriver i

2023-06-15 Thread via GitHub
XComp commented on PR #22656: URL: https://github.com/apache/flink/pull/22656#issuecomment-1593052042 Rebased to the most-recent version of FLINK-31782 (to fix the conflicts). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-32347) Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager

2023-06-15 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733059#comment-17733059 ] Stefan Richter commented on FLINK-32347: Hey, I've already opened a PR. The issue was still

[GitHub] [flink] flinkbot commented on pull request #22793: [FLINK-32347][checkpoint] Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager.

2023-06-15 Thread via GitHub
flinkbot commented on PR #22793: URL: https://github.com/apache/flink/pull/22793#issuecomment-1593052850 ## CI report: * a5ce6c4cd7ffdaef79381f91bb1fcc8f5a1ac83e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zentol commented on a diff in pull request #22794: [FLINK-25002][build] Add java 17 add-opens/add-exports JVM arguments

2023-06-15 Thread via GitHub
zentol commented on code in PR #22794: URL: https://github.com/apache/flink/pull/22794#discussion_r1231022699 ## flink-end-to-end-tests/flink-queryable-state-test/pom.xml: ## @@ -107,6 +107,9 @@

[GitHub] [flink] zentol commented on a diff in pull request #22794: [FLINK-25002][build] Add java 17 add-opens/add-exports JVM arguments

2023-06-15 Thread via GitHub
zentol commented on code in PR #22794: URL: https://github.com/apache/flink/pull/22794#discussion_r1231023922 ## pom.xml: ## @@ -196,6 +196,12 @@ under the License. */ + Review Comment: > [-]{2}add This looks as weird as it does

[GitHub] [flink] flinkbot commented on pull request #22789: [FLINK-27146] [Filesystem] Migrate to Junit5 and Assertj

2023-06-15 Thread via GitHub
flinkbot commented on PR #22789: URL: https://github.com/apache/flink/pull/22789#issuecomment-1592845381 ## CI report: * 980d7e4495fe2aa0406674f860e16112f91b32d3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32342) SQL Server container behaves unexpected while testing with several surefire forks

2023-06-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-32342: --- Affects Version/s: jdbc-3.1.1 > SQL Server container behaves unexpected while testing with

[jira] [Updated] (FLINK-31923) Connector weekly runs are only testing main branches instead of all supported branches

2023-06-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31923: --- Fix Version/s: elasticsearch-4.0.0 cassandra-4.0.0

[jira] [Assigned] (FLINK-32351) Introduce base interfaces for call procedure

2023-06-15 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-32351: Assignee: luoyuxia > Introduce base interfaces for call procedure >

[jira] [Commented] (FLINK-32357) Elasticsearch v3.0 won't compile when testing against Flink 1.17.1

2023-06-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733019#comment-17733019 ] Martijn Visser commented on FLINK-32357: [~snuyanzin] [~reta] Haven't we seen this issue before

[jira] [Updated] (FLINK-32357) Elasticsearch v3.0 won't compile when testing against Flink 1.17.1

2023-06-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-32357: --- Description: {code:java} [INFO]

[jira] [Created] (FLINK-32357) Elasticsearch v3.0 won't compile when testing against Flink 1.17.1

2023-06-15 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-32357: -- Summary: Elasticsearch v3.0 won't compile when testing against Flink 1.17.1 Key: FLINK-32357 URL: https://issues.apache.org/jira/browse/FLINK-32357 Project:

[jira] [Assigned] (FLINK-32347) Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager

2023-06-15 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-32347: -- Assignee: Stefan Richter > Exceptions from the CompletedCheckpointStore are not

[jira] [Updated] (FLINK-32205) Support Flink client to access REST API through K8s Ingress

2023-06-15 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32205: -- Description: Currently, Flink Client can only connect to the server through the address:port, which

[jira] [Comment Edited] (FLINK-32316) Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover

2023-06-15 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732993#comment-17732993 ] Rui Fan edited comment on FLINK-32316 at 6/15/23 11:56 AM: --- Hi [~cailiuyang] ,

[jira] [Resolved] (FLINK-32311) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement and DefaultLeaderElectionService.onGrantLeadership fell into dead lock

2023-06-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-32311. --- Fix Version/s: 1.18.0 Resolution: Fixed master:

[GitHub] [flink] XComp merged pull request #22769: [FLINK-32311][runtime] Moves driver cleanup out of lock monitoring to prevent deadlocks

2023-06-15 Thread via GitHub
XComp merged PR #22769: URL: https://github.com/apache/flink/pull/22769 -- 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-shaded] MartijnVisser commented on a diff in pull request #119: Update Flink Shaded dependencies to the latest versions

2023-06-15 Thread via GitHub
MartijnVisser commented on code in PR #119: URL: https://github.com/apache/flink-shaded/pull/119#discussion_r1230931941 ## flink-shaded-jackson-parent/flink-shaded-jackson-2/src/main/resources/META-INF/NOTICE: ## @@ -6,11 +6,11 @@ The Apache Software Foundation

[jira] [Commented] (FLINK-32357) Elasticsearch v3.0 won't compile when testing against Flink 1.17.1

2023-06-15 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733046#comment-17733046 ] Andriy Redko commented on FLINK-32357: -- Yes, we certainly had it ! > Elasticsearch v3.0 won't

[GitHub] [flink] zentol commented on pull request #22780: [FLINK-32338][build] Add FailsOnJava17 annotation

2023-06-15 Thread via GitHub
zentol commented on PR #22780: URL: https://github.com/apache/flink/pull/22780#issuecomment-1592959070 yes -- 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,

[GitHub] [flink] zentol opened a new pull request, #22792: [FLINK-25000][build] Java 17 uses Scala 2.12.15

2023-06-15 Thread via GitHub
zentol opened a new pull request, #22792: URL: https://github.com/apache/flink/pull/22792 Based on #22780. Since Scala 2.12.7 doesn't compile we will run the build with a later version of Scala when running on Java 17. This breaks various compatibility tests which are now disable in

[jira] [Updated] (FLINK-32347) Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager

2023-06-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32347: --- Labels: pull-request-available (was: ) > Exceptions from the CompletedCheckpointStore are

[jira] [Updated] (FLINK-25002) Setup required --add-opens/--add-exports

2023-06-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25002: --- Labels: pull-request-available (was: ) > Setup required --add-opens/--add-exports >

[GitHub] [flink] zentol opened a new pull request, #22794: [FLINK-25002][build] Add java 17 add-opens/add-exports JVM arguments

2023-06-15 Thread via GitHub
zentol opened a new pull request, #22794: URL: https://github.com/apache/flink/pull/22794 This PR sets of all required add-opens/add-exports statements for Maven, surefire, test-internal JVMs and flink-dist. If a module requires such a statement for surefire/testing then it must

[jira] [Commented] (FLINK-31923) Connector weekly runs are only testing main branches instead of all supported branches

2023-06-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733002#comment-17733002 ] Martijn Visser commented on FLINK-31923: Fixed in: apache/flink-connector-gcp-pubsub@main:

[GitHub] [flink] liuyongvs commented on pull request #22143: [FLINK-31377][table] Fix array_contains ArrayData.ElementGetter shoul…

2023-06-15 Thread via GitHub
liuyongvs commented on PR #22143: URL: https://github.com/apache/flink/pull/22143#issuecomment-1592862067 hi @snuyanzin do you have time to have a look again? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-21883) Introduce cooldown period into adaptive scheduler

2023-06-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733007#comment-17733007 ] Robert Metzger commented on FLINK-21883: There's FLIP for this Jira:

[jira] [Closed] (FLINK-32343) Fix exception for jdbc tools

2023-06-15 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li closed FLINK-32343. -- Fix Version/s: 1.18.0 Assignee: Fang Yong Resolution: Fixed Fixed via

[jira] [Commented] (FLINK-32136) Pyflink gateway server launch fails when purelib != platlib

2023-06-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733017#comment-17733017 ] Dian Fu commented on FLINK-32136: - [~wash] Good catch! This seems like a critical problem. Would you

[jira] [Created] (FLINK-32351) Introduce base interfaces for call procedure

2023-06-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-32351: Summary: Introduce base interfaces for call procedure Key: FLINK-32351 URL: https://issues.apache.org/jira/browse/FLINK-32351 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on pull request #22790: [hotfix][state] Fix incorrect comments of channel input state redistribution.

2023-06-15 Thread via GitHub
flinkbot commented on PR #22790: URL: https://github.com/apache/flink/pull/22790#issuecomment-1592888738 ## CI report: * fbab9c3cd3e147cb887fa92acea26b090cad1bb2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-32353) Make Cassandra connector compatible with Flink 1.18

2023-06-15 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-32353: -- Summary: Make Cassandra connector compatible with Flink 1.18 Key: FLINK-32353 URL: https://issues.apache.org/jira/browse/FLINK-32353 Project: Flink

[jira] [Updated] (FLINK-32354) Support to execute the call procedure operation

2023-06-15 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-32354: - Component/s: Table SQL / Runtime > Support to execute the call procedure operation >

[jira] [Created] (FLINK-32355) Support to list procedure

2023-06-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-32355: Summary: Support to list procedure Key: FLINK-32355 URL: https://issues.apache.org/jira/browse/FLINK-32355 Project: Flink Issue Type: Sub-task Components:

[jira] [Updated] (FLINK-32352) Support to convert call procedure statement to correpsonding operation

2023-06-15 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-32352: - Summary: Support to convert call procedure statement to correpsonding operation (was: Support convert

[jira] [Assigned] (FLINK-32357) Elasticsearch v3.0 won't compile when testing against Flink 1.17.1

2023-06-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-32357: --- Assignee: Sergey Nuyanzin > Elasticsearch v3.0 won't compile when testing against

[GitHub] [flink] XComp commented on pull request #22601: [FLINK-31781][runtime] Introduces the contender ID to the LeaderElectionService interface

2023-06-15 Thread via GitHub
XComp commented on PR #22601: URL: https://github.com/apache/flink/pull/22601#issuecomment-1592916372 Rebased PR after merging FLINK-31797 to master fixing the conflict -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] dianfu closed pull request #22782: [FLINK-32034][python] Updated GET_SITE_PACKAGES_SCRIPT to remove distutils dependency

2023-06-15 Thread via GitHub
dianfu closed pull request #22782: [FLINK-32034][python] Updated GET_SITE_PACKAGES_SCRIPT to remove distutils dependency URL: https://github.com/apache/flink/pull/22782 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-32347) Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager

2023-06-15 Thread Tigran Manasyan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733034#comment-17733034 ] Tigran Manasyan commented on FLINK-32347: - Hi, [~srichter] ! I've already fixed this issue in

[jira] [Closed] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

2023-06-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-32034. --- Fix Version/s: 1.18.0 1.17.2 Assignee: Colten Pilgreen Resolution: Fixed

[GitHub] [flink-shaded] MartijnVisser commented on a diff in pull request #119: Update Flink Shaded dependencies to the latest versions

2023-06-15 Thread via GitHub
MartijnVisser commented on code in PR #119: URL: https://github.com/apache/flink-shaded/pull/119#discussion_r1230931941 ## flink-shaded-jackson-parent/flink-shaded-jackson-2/src/main/resources/META-INF/NOTICE: ## @@ -6,11 +6,11 @@ The Apache Software Foundation

[jira] [Created] (FLINK-32358) CI may unintentionally use fallback akka loader

2023-06-15 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32358: Summary: CI may unintentionally use fallback akka loader Key: FLINK-32358 URL: https://issues.apache.org/jira/browse/FLINK-32358 Project: Flink

[GitHub] [flink-connector-jdbc] eskabetxe commented on a diff in pull request #49: [FLINK-32068] connector jdbc support clickhouse

2023-06-15 Thread via GitHub
eskabetxe commented on code in PR #49: URL: https://github.com/apache/flink-connector-jdbc/pull/49#discussion_r1230973150 ## flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/tables/TableBuilder.java: ## @@ -51,4 +52,8 @@ private static TableField

[GitHub] [flink] zentol opened a new pull request, #22791: [FLINK-32358][rpc] Add rpc system loading priority

2023-06-15 Thread via GitHub
zentol opened a new pull request, #22791: URL: https://github.com/apache/flink/pull/22791 This PR ensures that, if the main and fallback akka rpc system loaders are both on the classpath, the main loader gets priority. This avoids cases on CI where the fallback loader was used because it

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #614: [FLINK-32057] Support 1.18 rescale api for applying parallelism overrides

2023-06-15 Thread via GitHub
gyfora commented on code in PR #614: URL: https://github.com/apache/flink-kubernetes-operator/pull/614#discussion_r1230988179 ## examples/autoscaling/Dockerfile: ## @@ -16,5 +16,5 @@ # limitations under the License.

[GitHub] [flink] StefanRRichter opened a new pull request, #22793: [FLINK-32347][checkpoint] Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager.

2023-06-15 Thread via GitHub
StefanRRichter opened a new pull request, #22793: URL: https://github.com/apache/flink/pull/22793 ## What is the purpose of the change Currently if an error occurs while saving a completed checkpoint in the CompletedCheckpointStore, CheckpointCoordinator doesn't call

[GitHub] [flink] XComp commented on pull request #22656: [FLINK-32180][runtime] Moves error handling from DefaultMultipleComponentLeaderElectionService into the MultipleComponentLeaderElectionDriver i

2023-06-15 Thread via GitHub
XComp commented on PR #22656: URL: https://github.com/apache/flink/pull/22656#issuecomment-1593046291 > Why wouldn't the service be able to forward errors to the contender? Is it because the driver is doing stuff internally that the service doesn't even know about? The k8s

[jira] [Updated] (FLINK-32180) Move error handling into MultipleComponentLeaderElectionDriverFactory

2023-06-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32180: --- Labels: pull-request-available (was: ) > Move error handling into

[GitHub] [flink] flinkbot commented on pull request #22794: [FLINK-25002][build] Add java 17 add-opens/add-exports JVM arguments

2023-06-15 Thread via GitHub
flinkbot commented on PR #22794: URL: https://github.com/apache/flink/pull/22794#issuecomment-1593081332 ## CI report: * ad4624f02ec3bb8b3dab9d121abd88d4027f42e8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-32136) Pyflink gateway server launch fails when purelib != platlib

2023-06-15 Thread William Ashley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733064#comment-17733064 ] William Ashley commented on FLINK-32136: I doubt I'll have the time anytime soon to study the

[GitHub] [flink] kottmann opened a new pull request, #22789: [FLINK-27146] [Filesystem] Migrate to Junit5 and Assertj

2023-06-15 Thread via GitHub
kottmann opened a new pull request, #22789: URL: https://github.com/apache/flink/pull/22789 ## What is the purpose of the change This migrates the Filesystem test code to use Junit5 and Assertj. ## Brief change log - Migrated the test code to use Junit5 according to

[jira] [Commented] (FLINK-28460) Flink SQL supports atomic CREATE TABLE AS SELECT(CTAS)

2023-06-15 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732998#comment-17732998 ] tartarus commented on FLINK-28460: -- Resolved in FLIP-305, for details see

[jira] [Updated] (FLINK-27146) [JUnit5 Migration] Module: flink-filesystems

2023-06-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27146: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Module: flink-filesystems >

[jira] [Closed] (FLINK-32340) NPE in K8s operator which brakes current and subsequent deployments

2023-06-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32340. -- Resolution: Duplicate This is fixed already in FLINK-32111 > NPE in K8s operator which brakes

[jira] [Assigned] (FLINK-32354) Support to execute the call procedure operation

2023-06-15 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-32354: Assignee: luoyuxia > Support to execute the call procedure operation >

[jira] [Assigned] (FLINK-32352) Support to convert call procedure statement to correpsonding operation

2023-06-15 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-32352: Assignee: luoyuxia > Support to convert call procedure statement to correpsonding operation >

[jira] [Created] (FLINK-32356) Add document for calling procedure

2023-06-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-32356: Summary: Add document for calling procedure Key: FLINK-32356 URL: https://issues.apache.org/jira/browse/FLINK-32356 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-32353) Make Cassandra connector compatible with Flink 1.18

2023-06-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733018#comment-17733018 ] Martijn Visser commented on FLINK-32353: [~echauchot] Want to take a look? > Make Cassandra

[GitHub] [flink-docker] zentol commented on pull request #158: [ADD-SYMLINKS] Add symlinks for FLINK_VERSION to FLINK_RELEASE jars

2023-06-15 Thread via GitHub
zentol commented on PR #158: URL: https://github.com/apache/flink-docker/pull/158#issuecomment-1592912361 > But then I might ask why flink:1.16 is even an option for a base image if we still have to worry about patch version changes? That's an interesting line of thought. To be

[GitHub] [flink-connector-jdbc] MartijnVisser commented on pull request #42: [FLINK-31820] Support data source sub-database and sub-table

2023-06-15 Thread via GitHub
MartijnVisser commented on PR #42: URL: https://github.com/apache/flink-connector-jdbc/pull/42#issuecomment-1592942865 No consensus yet in ticket, closing 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

[GitHub] [flink-connector-jdbc] MartijnVisser closed pull request #42: [FLINK-31820] Support data source sub-database and sub-table

2023-06-15 Thread via GitHub
MartijnVisser closed pull request #42: [FLINK-31820] Support data source sub-database and sub-table URL: https://github.com/apache/flink-connector-jdbc/pull/42 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink-connector-jdbc] MartijnVisser commented on pull request #49: [FLINK-32068] connector jdbc support clickhouse

2023-06-15 Thread via GitHub
MartijnVisser commented on PR #49: URL: https://github.com/apache/flink-connector-jdbc/pull/49#issuecomment-1592940408 > What other tasks are needed for this PR to merge Please mark review items as resolved, if you really have resolved them. Right now, it looks like there are still

[GitHub] [flink-connector-jdbc] MartijnVisser closed pull request #44: Fix duplicated data on retrying

2023-06-15 Thread via GitHub
MartijnVisser closed pull request #44: Fix duplicated data on retrying URL: https://github.com/apache/flink-connector-jdbc/pull/44 -- 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

  1   2   3   4   >