[GitHub] [flink] gaborgsomogyi opened a new pull request, #21870: [FLINK-30928][tests] Change to eclipse-temurin due to openjdk deprecation

2023-02-06 Thread via GitHub
gaborgsomogyi opened a new pull request, #21870: URL: https://github.com/apache/flink/pull/21870 ## Brief change log Migrate from OpenJDK which is announced to be deprecated [here](https://hub.docker.com/_/openjdk). In this PR I've migrated to temurin JRE like we have in

[jira] [Updated] (FLINK-30929) Add helpful message when ElasticsearchSink.Builder.build() throws an IllegalArgumentException.

2023-02-06 Thread Kenny Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenny Wu updated FLINK-30929: - Attachment: image-2023-02-06-21-28-37-835.png Description: When I test

[GitHub] [flink] flinkbot commented on pull request #21869: [FLINK-30910][runtime] Making test wait for stop to be called before finishing the bootstrap operation

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

[GitHub] [flink] snuyanzin commented on pull request #20772: [FLINK-29214][Table API/SQL] Remove usages of deprecated Aggregate#indicator

2023-02-06 Thread via GitHub
snuyanzin commented on PR #20772: URL: https://github.com/apache/flink/pull/20772#issuecomment-1419099032 @lincoln-lil sorry for the poke since you one of the active contributors to table-planner, may I ask you to have a look? -- This is an automated message from the Apache Git

[GitHub] [flink] snuyanzin commented on a diff in pull request #20772: [FLINK-29214][Table API/SQL] Remove usages of deprecated Aggregate#indicator

2023-02-06 Thread via GitHub
snuyanzin commented on code in PR #20772: URL: https://github.com/apache/flink/pull/20772#discussion_r964202368 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalWindowAggregateRuleBase.scala: ## @@ -98,7 +99,7 @@

[jira] [Updated] (FLINK-30930) Automatically determine Flink binary download URL from version

2023-02-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30930: --- Labels: pull-request-available (was: ) > Automatically determine Flink binary download URL

[GitHub] [flink-connector-shared-utils] zentol opened a new pull request, #7: [FLINK-30930][ci] Automatically determine URL/caching

2023-02-06 Thread via GitHub
zentol opened a new pull request, #7: URL: https://github.com/apache/flink-connector-shared-utils/pull/7 Binary URL/caching parameters are now optional. If unset we automatically determine them from the version parameter. This will allow us to centrally switch all repos to different

[jira] [Updated] (FLINK-30930) Automatically determine Flink binary download URL from version

2023-02-06 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30930: - Description: Currently the shared connector CI workflow accepts a binary url and

[jira] [Updated] (FLINK-30910) ApplicationDispatcherBootstrapTest.testApplicationIsStoppedWhenStoppingBootstrap fails with assertion

2023-02-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30910: -- Affects Version/s: 1.15.3 1.17.0 >

[jira] [Updated] (FLINK-30910) ApplicationDispatcherBootstrapTest.testApplicationIsStoppedWhenStoppingBootstrap fails with assertion

2023-02-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30910: --- Labels: pull-request-available test-stability (was: test-stability) >

[jira] [Created] (FLINK-30930) Automatically determine Flink binary download URL from version

2023-02-06 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30930: Summary: Automatically determine Flink binary download URL from version Key: FLINK-30930 URL: https://issues.apache.org/jira/browse/FLINK-30930 Project:

[GitHub] [flink] XComp opened a new pull request, #21869: [FLINK-30910][runtime] Making test wait for stop to be called before finishing the bootstrap operation

2023-02-06 Thread via GitHub
XComp opened a new pull request, #21869: URL: https://github.com/apache/flink/pull/21869 ## What is the purpose of the change This change prevents a race condition where the bootstrap process finishes before the test calls stop which results in an outcome that's not expected in this

[jira] [Comment Edited] (FLINK-29825) Improve benchmark stability

2023-02-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684677#comment-17684677 ] Piotr Nowojski edited comment on FLINK-29825 at 2/6/23 1:29 PM: I have

[jira] [Commented] (FLINK-29825) Improve benchmark stability

2023-02-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684677#comment-17684677 ] Piotr Nowojski commented on FLINK-29825: I have responded on the dev mailing list, but let's

[GitHub] [flink] snuyanzin commented on pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

2023-02-06 Thread via GitHub
snuyanzin commented on PR #21393: URL: https://github.com/apache/flink/pull/21393#issuecomment-1419079063 somehow build doesn't fail however lots of output in tests with generated code The output happens here

[GitHub] [flink] flinkbot commented on pull request #21868: [FLINK-30908] Fix YARNSessionFIFOSecuredITCase#testDetachedMode

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

[GitHub] [flink] kristoffSC commented on pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

2023-02-06 Thread via GitHub
kristoffSC commented on PR #21393: URL: https://github.com/apache/flink/pull/21393#issuecomment-1419069671 @snuyanzin > it looks like it generates methods with same signature for some cases e.g. I will take a look at this one. This was not causing CI build to fail? --

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2023-02-06 Thread via GitHub
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1097361784 ## flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriterITCase.java: ## @@ -0,0 +1,424 @@ +/* + * Licensed to

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2023-02-06 Thread via GitHub
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1097361445 ## flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriterITCase.java: ## @@ -0,0 +1,424 @@ +/* + * Licensed to

[GitHub] [flink] snuyanzin commented on pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

2023-02-06 Thread via GitHub
snuyanzin commented on PR #21393: URL: https://github.com/apache/flink/pull/21393#issuecomment-1419057945 it looks like it generates methods with same signature for some cases e.g. ` org.apache.flink.table.planner.runtime.stream.sql.MatchRecognizeITCase#testUserDefinedFunctions` and it

[jira] [Commented] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

2023-02-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684668#comment-17684668 ] Leonard Xu commented on FLINK-30921: This is an azure mirror crash issue, please see more info here

[jira] [Updated] (FLINK-30908) Fatal error in ResourceManager caused YARNSessionFIFOSecuredITCase.testDetachedMode to fail

2023-02-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30908: --- Labels: pull-request-available test-stability (was: test-stability) > Fatal error in

[GitHub] [flink] xintongsong opened a new pull request, #21868: [FLINK-30908] Fix YARNSessionFIFOSecuredITCase#testDetachedMode

2023-02-06 Thread via GitHub
xintongsong opened a new pull request, #21868: URL: https://github.com/apache/flink/pull/21868 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[jira] [Updated] (FLINK-30929) Add helpful message when ElasticsearchSink.Builder.build() throws a IllegalArgumentException.

2023-02-06 Thread Kenny Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenny Wu updated FLINK-30929: - Description: When I use  flink-connector-elasticsearch on my project. I got an IllegalArgumentException

[jira] [Commented] (FLINK-30910) ApplicationDispatcherBootstrapTest.testApplicationIsStoppedWhenStoppingBootstrap fails with assertion

2023-02-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684666#comment-17684666 ] Matthias Pohl commented on FLINK-30910: --- It looks like the bootstrap code finished faster than the

[jira] [Updated] (FLINK-30929) Add helpful message when ElasticsearchSink.Builder.build() throws a IllegalArgumentException.

2023-02-06 Thread Kenny Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenny Wu updated FLINK-30929: - Description: When I use  flink-connector-elasticsearch on my project. I encounter a

[jira] [Updated] (FLINK-30929) Add helpful message when ElasticsearchSink.Builder.build() throws a IllegalArgumentException.

2023-02-06 Thread Kenny Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenny Wu updated FLINK-30929: - Description: When I use  (was: Recently, I'm trying to use flink-connector-elasticsearch on my

[jira] [Updated] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

2023-02-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-30921: --- Priority: Critical (was: Major) > Too many CI failed due to "Could not connect to

[jira] [Commented] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

2023-02-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684662#comment-17684662 ] Leonard Xu commented on FLINK-30921:

[jira] [Created] (FLINK-30929) Add helpful message when ElasticsearchSink.Builder.build() throws a IllegalArgumentException.

2023-02-06 Thread Kenny Wu (Jira)
Kenny Wu created FLINK-30929: Summary: Add helpful message when ElasticsearchSink.Builder.build() throws a IllegalArgumentException. Key: FLINK-30929 URL: https://issues.apache.org/jira/browse/FLINK-30929

[jira] [Commented] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

2023-02-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684648#comment-17684648 ] Leonard Xu commented on FLINK-30921:

[jira] [Commented] (FLINK-30843) Add Notifier For Autoscaler

2023-02-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684646#comment-17684646 ] Gyula Fora commented on FLINK-30843: Thanks [~gaurav726] , I think you can provide a prototype

[jira] [Commented] (FLINK-30920) K8 cluster autoscaler | exclude operator ids from scaler

2023-02-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684645#comment-17684645 ] Gyula Fora commented on FLINK-30920: Could you please explain why it is a problem to downscale the

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #527: [FLINK-30594] Fix JDK-8221218 + change to eclipse-temurin due to openjdk deprecation

2023-02-06 Thread via GitHub
gaborgsomogyi commented on PR #527: URL: https://github.com/apache/flink-kubernetes-operator/pull/527#issuecomment-1419031980 Just for the reference Flink uses the same:

[jira] [Comment Edited] (FLINK-30887) CI workflow for externalized connectors doesn't cache Flink's binary download

2023-02-06 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17683414#comment-17683414 ] Chesnay Schepler edited comment on FLINK-30887 at 2/6/23 12:50 PM: ---

[GitHub] [flink-connector-shared-utils] zentol merged pull request #6: [FLINK-30887][ci] Fix caching conditions

2023-02-06 Thread via GitHub
zentol merged PR #6: URL: https://github.com/apache/flink-connector-shared-utils/pull/6 -- 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] 1996fanrui commented on pull request #21853: [bp-1.16][FLINK-30461][checkpoint] Fix the bug that the shared files will remain forever after the rocksdb incremental checkpoint exceptio

2023-02-06 Thread via GitHub
1996fanrui commented on PR #21853: URL: https://github.com/apache/flink/pull/21853#issuecomment-1419030159 @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

[GitHub] [flink-benchmarks] pnowojski commented on pull request #63: [FLINK-27571][benchmark] Recognize 'less is better' benchmarks in regression detection script

2023-02-06 Thread via GitHub
pnowojski commented on PR #63: URL: https://github.com/apache/flink-benchmarks/pull/63#issuecomment-1419030149 Nice find. What's the issue with the cache? I've checked the report visible on your second screen and it seems to be working properly. Anyway, I presume that if

[jira] [Assigned] (FLINK-30928) Use temurin JRE in test hadoop docker image

2023-02-06 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-30928: - Assignee: Gabor Somogyi > Use temurin JRE in test hadoop docker image >

[jira] [Created] (FLINK-30928) Use temurin JRE in test hadoop docker image

2023-02-06 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-30928: - Summary: Use temurin JRE in test hadoop docker image Key: FLINK-30928 URL: https://issues.apache.org/jira/browse/FLINK-30928 Project: Flink Issue Type:

[GitHub] [flink] 1996fanrui commented on pull request #21855: [bp-1.15][FLINK-30461][checkpoint] Fix the bug that the shared files will remain forever after the rocksdb incremental checkpoint exceptio

2023-02-06 Thread via GitHub
1996fanrui commented on PR #21855: URL: https://github.com/apache/flink/pull/21855#issuecomment-1419029695 @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

[jira] [Updated] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

2023-02-06 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-30927: Summary: Several tests started generate output with two non-abstract methods have the

[jira] [Closed] (FLINK-30594) Update Java version because of JDK bug in the operator

2023-02-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30594. -- Resolution: Fixed merged to main f9024a7fe09492957d3708079bf28227af54f5c6 > Update Java version

[jira] [Commented] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

2023-02-06 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684641#comment-17684641 ] Qingsheng Ren commented on FLINK-30921: ---

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #527: [FLINK-30594] Fix JDK-8221218 + change to eclipse-temurin due to openjdk deprecation

2023-02-06 Thread via GitHub
gyfora merged PR #527: URL: https://github.com/apache/flink-kubernetes-operator/pull/527 -- 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-30927) Several tests fail with two non-abstract methods have the same parameter types, declaring type and return type

2023-02-06 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-30927: --- Summary: Several tests fail with two non-abstract methods have the same parameter types, declaring type and return type Key: FLINK-30927 URL:

[GitHub] [flink-connector-aws] karthitect commented on a diff in pull request #52: [FLINK 30777] [Connectors/Kinesis] Allow Kinesis Table API Connector to specify shard assigner

2023-02-06 Thread via GitHub
karthitect commented on code in PR #52: URL: https://github.com/apache/flink-connector-aws/pull/52#discussion_r1097331807 ## flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java: ## @@ -242,6 +244,8 @@ public

[GitHub] [flink-connector-aws] karthitect commented on a diff in pull request #52: [FLINK 30777] [Connectors/Kinesis] Allow Kinesis Table API Connector to specify shard assigner

2023-02-06 Thread via GitHub
karthitect commented on code in PR #52: URL: https://github.com/apache/flink-connector-aws/pull/52#discussion_r1097331232 ## flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java: ## @@ -242,6 +244,8 @@ public

[GitHub] [flink-connector-aws] karthitect commented on a diff in pull request #52: [FLINK 30777] [Connectors/Kinesis] Allow Kinesis Table API Connector to specify shard assigner

2023-02-06 Thread via GitHub
karthitect commented on code in PR #52: URL: https://github.com/apache/flink-connector-aws/pull/52#discussion_r1097330879 ## flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java: ## @@ -242,6 +244,8 @@ public

[GitHub] [flink] flinkbot commented on pull request #21867: [FLINK-30914][runtime] Hardens tests against ConnectionLossExceptions

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

[jira] [Commented] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

2023-02-06 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684640#comment-17684640 ] Qingsheng Ren commented on FLINK-30921: ---

[jira] [Comment Edited] (FLINK-30910) ApplicationDispatcherBootstrapTest.testApplicationIsStoppedWhenStoppingBootstrap fails with assertion

2023-02-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684638#comment-17684638 ] Matthias Pohl edited comment on FLINK-30910 at 2/6/23 12:42 PM: {quote}

[jira] [Commented] (FLINK-30910) ApplicationDispatcherBootstrapTest.testApplicationIsStoppedWhenStoppingBootstrap fails with assertion

2023-02-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684638#comment-17684638 ] Matthias Pohl commented on FLINK-30910: --- > Chesnay Schepler do you have capacity to look into this

[GitHub] [flink-connector-aws] karthitect commented on a diff in pull request #52: [FLINK 30777] [Connectors/Kinesis] Allow Kinesis Table API Connector to specify shard assigner

2023-02-06 Thread via GitHub
karthitect commented on code in PR #52: URL: https://github.com/apache/flink-connector-aws/pull/52#discussion_r1097330378 ## flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java: ## @@ -242,6 +244,8 @@ public

[jira] [Commented] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

2023-02-06 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684637#comment-17684637 ] Qingsheng Ren commented on FLINK-30921: ---

[jira] [Assigned] (FLINK-30910) ApplicationDispatcherBootstrapTest.testApplicationIsStoppedWhenStoppingBootstrap fails with assertion

2023-02-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-30910: - Assignee: Matthias Pohl >

[GitHub] [flink] flinkbot commented on pull request #21866: [FLINK-30864][FLINK-30885][CEP] Fix wrong NFA related to optional decoration and group pattern

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

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #527: [FLINK-30594] Fix JDK-8221218 + change to eclipse-temurin due to openjdk deprecation

2023-02-06 Thread via GitHub
gaborgsomogyi commented on PR #527: URL: https://github.com/apache/flink-kubernetes-operator/pull/527#issuecomment-1419018899 Seems like the `apt-get upgrade` timed out previously. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-30914) ZooKeeperLeaderElectionTest.testUnExpectedErrorForwarding failed

2023-02-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30914: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] XComp opened a new pull request, #21867: [FLINK-30914][runtime] Hardens tests against ConnectionLossExceptions

2023-02-06 Thread via GitHub
XComp opened a new pull request, #21867: URL: https://github.com/apache/flink/pull/21867 ## What is the purpose of the change We experienced a test failure where the fatal error was not caused by the injected expected exception but a `ConnectionLossException`. The connection was

[GitHub] [flink] lincoln-lil commented on pull request #21507: [FLINK-30386] Fix the issue that column constraint lacks primary key not enforced check

2023-02-06 Thread via GitHub
lincoln-lil commented on PR #21507: URL: https://github.com/apache/flink/pull/21507#issuecomment-1419010310 @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

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2023-02-06 Thread via GitHub
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1097315407 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoScanSplitAssigner.java: ## @@ -0,0 +1,143 @@

[jira] [Closed] (FLINK-30006) Cannot remove columns that are incorrectly considered constants from an Aggregate In Streaming

2023-02-06 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-30006. --- Resolution: Fixed fixed in master: 01743000c10720598dfb6f27d849da2283772e50 > Cannot remove

[jira] [Commented] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

2023-02-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684628#comment-17684628 ] Leonard Xu commented on FLINK-30921:

[jira] [Updated] (FLINK-30864) Optional pattern at the start of a group pattern not working

2023-02-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30864: --- Labels: pull-request-available (was: ) > Optional pattern at the start of a group pattern

[GitHub] [flink-connector-shared-utils] zentol opened a new pull request, #6: [FLINK-30887][ci] Fix caching conditions

2023-02-06 Thread via GitHub
zentol opened a new pull request, #6: URL: https://github.com/apache/flink-connector-shared-utils/pull/6 * fix wrong id of the caching restore step * fix boolean conditions; `cache_flink_binary` is a boolean, and thus not equal to the _string_ `true` * (the cache-hit output is still

[GitHub] [flink] Vancior opened a new pull request, #21866: [FLINK-30864][FLINK-30865][CEP] Fix wrong NFA related to optional decoration at the beginning of group pattern

2023-02-06 Thread via GitHub
Vancior opened a new pull request, #21866: URL: https://github.com/apache/flink/pull/21866 ## What is the purpose of the change This PR fixes generating wrong NFA related to optional & followed-by semantics at the beginning of group pattern, e.g. optional pattern in a

[GitHub] [flink] lincoln-lil merged pull request #21641: [FLINK-30006][table-planner] Make all pure dynamic functions non-deterministic in streaming mode to avoid wrong plans

2023-02-06 Thread via GitHub
lincoln-lil merged PR #21641: URL: https://github.com/apache/flink/pull/21641 -- 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] lincoln-lil commented on pull request #21641: [FLINK-30006][table-planner] Make all pure dynamic functions non-deterministic in streaming mode to avoid wrong plans

2023-02-06 Thread via GitHub
lincoln-lil commented on PR #21641: URL: https://github.com/apache/flink/pull/21641#issuecomment-1418997535 The e2e ci failed cause by unstable connection(FLINK-30921) in flink ci env(https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=45753=results), but in my private

[GitHub] [flink] flinkbot commented on pull request #21865: [FLINK-30919][docs] fix typo in the document of User-defined Sources & Sinks

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

[jira] [Updated] (FLINK-30640) Unstable test in CliClientITCase

2023-02-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-30640: --- Priority: Critical (was: Major) > Unstable test in CliClientITCase >

[jira] [Assigned] (FLINK-30640) Unstable test in CliClientITCase

2023-02-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-30640: -- Assignee: dalongliu (was: tartarus) > Unstable test in CliClientITCase >

[jira] [Commented] (FLINK-30914) ZooKeeperLeaderElectionTest.testUnExpectedErrorForwarding failed

2023-02-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684622#comment-17684622 ] Matthias Pohl commented on FLINK-30914: --- I'm gonna harden the test by accepting

[jira] [Updated] (FLINK-30914) ZooKeeperLeaderElectionTest.testUnExpectedErrorForwarding failed

2023-02-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30914: -- Affects Version/s: 1.16.1 1.17.0 >

[GitHub] [flink] luoyuxia commented on a diff in pull request #21789: [FLINK-30824][hive] Add document for option table.exec.hive.native-agg-function.enabled

2023-02-06 Thread via GitHub
luoyuxia commented on code in PR #21789: URL: https://github.com/apache/flink/pull/21789#discussion_r1097303357 ## docs/content.zh/docs/connectors/table/hive/hive_functions.md: ## @@ -73,6 +73,34 @@ Some Hive built-in functions in older versions have [thread safety

[jira] [Commented] (FLINK-30914) ZooKeeperLeaderElectionTest.testUnExpectedErrorForwarding failed

2023-02-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684621#comment-17684621 ] Matthias Pohl commented on FLINK-30914: --- The fsync took longer (29858ms) than the configured

[GitHub] [flink] flinkbot commented on pull request #21864: [JUnit5 Migration] Module: flink-table-planner: Introduce new test base class for ITCase and migrate partial java ITCase

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

[GitHub] [flink] JunRuiLee commented on pull request #21801: [FLINK-30838][doc] Update documentation about the AdaptiveBatchScheduler

2023-02-06 Thread via GitHub
JunRuiLee commented on PR #21801: URL: https://github.com/apache/flink/pull/21801#issuecomment-1418972576 @zhuzhurk Thanks for CR and I've addressed all comments, PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink-connector-mongodb] zentol commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2023-02-06 Thread via GitHub
zentol commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1097291736 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoScanSplitAssigner.java: ## @@ -0,0 +1,143 @@ +/*

[jira] [Updated] (FLINK-30919) Fix typo in the document of User-defined Sources & Sinks

2023-02-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30919: --- Labels: pull-request-available (was: ) > Fix typo in the document of User-defined Sources

[GitHub] [flink] luoyuxia opened a new pull request, #21865: [FLINK-30919][docs] fix typo in the document of User-defined Sources & Sinks

2023-02-06 Thread via GitHub
luoyuxia opened a new pull request, #21865: URL: https://github.com/apache/flink/pull/21865 ## What is the purpose of the change To fix the typo in the document of User-defined Sources & Sinks ## Brief change log ## Verifying this change Verify it

[GitHub] [flink] 1996fanrui commented on pull request #21859: [FLINK-30916][checkpoint] Set the number of rocksdb uploader threads to 1 to solve the unstable bug of unit test

2023-02-06 Thread via GitHub
1996fanrui commented on PR #21859: URL: https://github.com/apache/flink/pull/21859#issuecomment-1418969337 @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

[jira] [Updated] (FLINK-30926) [Umbrella] Test Flink Release 1.17

2023-02-06 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-30926: -- Description: This is an umbrella ticket for the Flink 1.17 testing efforts. Please prepare

[GitHub] [flink-connector-mongodb] zentol commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2023-02-06 Thread via GitHub
zentol commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1097287484 ## flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriterITCase.java: ## @@ -0,0 +1,424 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-30926) [Umbrella] Test Flink Release 1.17

2023-02-06 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-30926: -- Description: This is an umbrella ticket for the Flink 1.17 testing efforts. Please prepare

[jira] [Created] (FLINK-30926) [Umbrella] Test Flink Release 1.17

2023-02-06 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-30926: - Summary: [Umbrella] Test Flink Release 1.17 Key: FLINK-30926 URL: https://issues.apache.org/jira/browse/FLINK-30926 Project: Flink Issue Type: Improvement

[GitHub] [flink] swuferhong opened a new pull request, #21864: [JUnit5 Migration] Module: flink-table-planner: Introduce new test base class for ITCase and migrate partial java ITCase

2023-02-06 Thread via GitHub
swuferhong opened a new pull request, #21864: URL: https://github.com/apache/flink/pull/21864 ## What is the purpose of the change This pr is aims to migrate `Junit4` to `Junit5` for flink-table-planner module. However, there are so many tests in this module, which it's

[jira] [Updated] (FLINK-30908) Fatal error in ResourceManager caused YARNSessionFIFOSecuredITCase.testDetachedMode to fail

2023-02-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30908: - Priority: Blocker (was: Critical) > Fatal error in ResourceManager caused >

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #527: [FLINK-30594] Fix JDK-8221218 + change to eclipse-temurin due to openjdk deprecation

2023-02-06 Thread via GitHub
gaborgsomogyi commented on PR #527: URL: https://github.com/apache/flink-kubernetes-operator/pull/527#issuecomment-1418960004 ``` $ docker run -it eclipse-temurin:11-jre-jammy java -version openjdk version "11.0.18" 2023-01-17 OpenJDK Runtime Environment Temurin-11.0.18+10 (build

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #527: [FLINK-30594] Fix JDK-8221218 + change to eclipse-temurin due to openjdk deprecation

2023-02-06 Thread via GitHub
gaborgsomogyi commented on PR #527: URL: https://github.com/apache/flink-kubernetes-operator/pull/527#issuecomment-1418959060 cc @gyfora -- 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

[jira] [Assigned] (FLINK-30594) Update Java version because of JDK bug in the operator

2023-02-06 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-30594: - Assignee: Gabor Somogyi > Update Java version because of JDK bug in the operator >

[jira] [Commented] (FLINK-30594) Update Java version because of JDK bug in the operator

2023-02-06 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684617#comment-17684617 ] Gabor Somogyi commented on FLINK-30594: --- [~xxxinli1] it makes sense, opened a PR. > Update Java

[GitHub] [flink] JunRuiLee commented on pull request #21854: [FLINK-30901][runtime] Fix the jobVertex's parallelismConfigured is incorrect when chaining with source operators

2023-02-06 Thread via GitHub
JunRuiLee commented on PR #21854: URL: https://github.com/apache/flink/pull/21854#issuecomment-1418956112 @zhuzhurk Thanks for CR and I've addressed all comments, PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-30594) Update Java version because of JDK bug in the operator

2023-02-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30594: --- Labels: pull-request-available (was: ) > Update Java version because of JDK bug in the

[jira] [Assigned] (FLINK-30925) Add docs for the SQL Client gateway mode

2023-02-06 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-30925: - Assignee: Shengkai Fang > Add docs for the SQL Client gateway mode >

[GitHub] [flink-kubernetes-operator] gaborgsomogyi opened a new pull request, #527: [FLINK-30594] Fix JDK-8221218 + change to eclipse-temurin due to openjdk deprecation

2023-02-06 Thread via GitHub
gaborgsomogyi opened a new pull request, #527: URL: https://github.com/apache/flink-kubernetes-operator/pull/527 ## Brief change log The main intention is the following: * Fix the following JDK bug which is solved in `11.0.18`:

[GitHub] [flink] JingGe commented on pull request #21322: [FLINK-30025][table] Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

2023-02-06 Thread via GitHub
JingGe commented on PR #21322: URL: https://github.com/apache/flink/pull/21322#issuecomment-1418955650 @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] [Created] (FLINK-30925) Add docs for the SQL Client gateway mode

2023-02-06 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-30925: - Summary: Add docs for the SQL Client gateway mode Key: FLINK-30925 URL: https://issues.apache.org/jira/browse/FLINK-30925 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-30908) Fatal error in ResourceManager caused YARNSessionFIFOSecuredITCase.testDetachedMode to fail

2023-02-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-30908: Assignee: Xintong Song > Fatal error in ResourceManager caused >

[jira] [Commented] (FLINK-30908) Fatal error in ResourceManager caused YARNSessionFIFOSecuredITCase.testDetachedMode to fail

2023-02-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684615#comment-17684615 ] Xintong Song commented on FLINK-30908: -- This is indeed related to FLINK_20988. The

<    1   2   3   4   5   >