[jira] [Updated] (FLINK-28694) Set pipeline.name to resource name by default for Applications

2022-07-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28694: --- Priority: Minor (was: Major) > Set pipeline.name to resource name by default for Applications >

[jira] [Created] (FLINK-28694) Set pipeline.name to resource name by default for Applications

2022-07-26 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-28694: -- Summary: Set pipeline.name to resource name by default for Applications Key: FLINK-28694 URL: https://issues.apache.org/jira/browse/FLINK-28694 Project: Flink

[jira] [Commented] (FLINK-28057) LD_PRELOAD is hardcoded to x64 on flink-docker

2022-07-26 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571422#comment-17571422 ] Yun Tang commented on FLINK-28057: -- Since Flink supports arm image from flink-1.14, [~nferrario]  could

[jira] [Resolved] (FLINK-28057) LD_PRELOAD is hardcoded to x64 on flink-docker

2022-07-26 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-28057. -- Resolution: Fixed merged in master: ed004f8cdac8e5c96b81ec069863a4f836d170d5 > LD_PRELOAD is

[GitHub] [flink-docker] Myasuka merged pull request #117: [FLINK-28057] Fix LD_PRELOAD on ARM images

2022-07-26 Thread GitBox
Myasuka merged PR #117: URL: https://github.com/apache/flink-docker/pull/117 -- 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] beyond1920 commented on a diff in pull request #20252: [FLINK-28463][flink-sql-parser] Flink dialect supports CREATE TABLE AS SELECT(CTAS) syntax

2022-07-26 Thread GitBox
beyond1920 commented on code in PR #20252: URL: https://github.com/apache/flink/pull/20252#discussion_r929938421 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTableLike.java: ## @@ -40,10 +40,10 @@ import static

[jira] [Commented] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571400#comment-17571400 ] Chesnay Schepler commented on FLINK-28680: -- Why no backport to 1.14? > No space left on device

[jira] [Created] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression

2022-07-26 Thread Hongbo (Jira)
Hongbo created FLINK-28693: -- Summary: Codegen failed if the watermark is defined on a columnByExpression Key: FLINK-28693 URL: https://issues.apache.org/jira/browse/FLINK-28693 Project: Flink

[GitHub] [flink] Tartarus0zm commented on pull request #20252: [FLINK-28463][flink-sql-parser] Flink dialect supports CREATE TABLE AS SELECT(CTAS) syntax

2022-07-26 Thread GitBox
Tartarus0zm commented on PR #20252: URL: https://github.com/apache/flink/pull/20252#issuecomment-1195435889 @beyond1920 thanks for your review! I have updated this pr, please take a look again! -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-28680. -- Resolution: Fixed > No space left on device on Azure e2e_2_ci tests >

[jira] [Commented] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571386#comment-17571386 ] Robert Metzger commented on FLINK-28680: Thanks a lot! Merged to master (1.16) in

[GitHub] [flink] rmetzger merged pull request #20364: [FLINK-28680] Revisit 'free_disk_space.sh' to free up more space

2022-07-26 Thread GitBox
rmetzger merged PR #20364: URL: https://github.com/apache/flink/pull/20364 -- 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] rmetzger commented on pull request #20364: [FLINK-28680] Revisit 'free_disk_space.sh' to free up more space

2022-07-26 Thread GitBox
rmetzger commented on PR #20364: URL: https://github.com/apache/flink/pull/20364#issuecomment-1195419343 Thank you for the fast review! Merging ... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] zentol commented on pull request #20355: [FLINK-28634][json] Add simple JsonSerDeSchema

2022-07-26 Thread GitBox
zentol commented on PR #20355: URL: https://github.com/apache/flink/pull/20355#issuecomment-1195415060 @alpinegizmo I added some documentation. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] beyond1920 commented on a diff in pull request #20361: [FLINK-27790][Table SQL / API] Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

2022-07-26 Thread GitBox
beyond1920 commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r929884249 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -461,6 +463,23 @@ public boolean

[GitHub] [flink] beyond1920 commented on a diff in pull request #20252: [FLINK-28463][flink-sql-parser] Flink dialect supports CREATE TABLE AS SELECT(CTAS) syntax

2022-07-26 Thread GitBox
beyond1920 commented on code in PR #20252: URL: https://github.com/apache/flink/pull/20252#discussion_r929887645 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTableLike.java: ## @@ -0,0 +1,135 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] beyond1920 commented on a diff in pull request #20361: [FLINK-27790][Table SQL / API] Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

2022-07-26 Thread GitBox
beyond1920 commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r929880836 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -461,6 +463,23 @@ public boolean

[GitHub] [flink] beyond1920 commented on a diff in pull request #20361: [FLINK-27790][Table SQL / API] Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

2022-07-26 Thread GitBox
beyond1920 commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r929880836 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -461,6 +463,23 @@ public boolean

[jira] [Updated] (FLINK-28692) Check warehouse path in CatalogFactory

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28692: - Priority: Blocker (was: Major) > Check warehouse path in CatalogFactory >

[jira] [Closed] (FLINK-28686) Spark table with column comment cannot be read/write by Flink

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28686. Resolution: Fixed master: 0dcf21dc1b6c17057083c144f5bda9ec7dbf0324 release-0.2:

[jira] [Assigned] (FLINK-28686) Spark table with column comment cannot be read/write by Flink

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28686: Assignee: Jane Chan > Spark table with column comment cannot be read/write by Flink >

[GitHub] [flink-table-store] JingsongLi merged pull request #242: [FLINK-28686] Spark table with column comment cannot be read/write by Flink

2022-07-26 Thread GitBox
JingsongLi merged PR #242: URL: https://github.com/apache/flink-table-store/pull/242 -- 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] wangyang0918 commented on pull request #19675: [FLINK-27550] The method of checkYarnQueues is compatible with capacity scheduler

2022-07-26 Thread GitBox
wangyang0918 commented on PR #19675: URL: https://github.com/apache/flink/pull/19675#issuecomment-1195378808 I will merge this PR after azure gives a pass. -- 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

[jira] [Commented] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571358#comment-17571358 ] Huang Xingbo commented on FLINK-28680: -- [~rmetzger] Great Job. Thanks a lot for the improvement.(y)

[GitHub] [flink] DavidLiu001 commented on pull request #20360: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

2022-07-26 Thread GitBox
DavidLiu001 commented on PR #20360: URL: https://github.com/apache/flink/pull/20360#issuecomment-1195350709 @flinkbot run azure re-run the last Azure build -- 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

[GitHub] [flink] DavidLiu001 commented on pull request #20360: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

2022-07-26 Thread GitBox
DavidLiu001 commented on PR #20360: URL: https://github.com/apache/flink/pull/20360#issuecomment-1195344731 @dannycranmer Thanks. Built locally with "mvn spotless:apply" and verified this PR with "mvn spotless:check", this PR was updated. -- This is an automated message from the Apache

[jira] [Closed] (FLINK-28644) Support collecting arbitrary number of streams

2022-07-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28644. Resolution: Fixed master: 1b8e776a915fd243e9088fb05be603b446cc663d

[GitHub] [flink] zentol merged pull request #20352: [FLINK-28644][datastream] Add DataStream#collectAsync

2022-07-26 Thread GitBox
zentol merged PR #20352: URL: https://github.com/apache/flink/pull/20352 -- 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-table-store] SteNicholas commented on a diff in pull request #243: [FLINK-28692] Check warehouse path in CatalogFactory

2022-07-26 Thread GitBox
SteNicholas commented on code in PR #243: URL: https://github.com/apache/flink-table-store/pull/243#discussion_r929819943 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/CatalogFactory.java: ## @@ -69,6 +74,21 @@ static Catalog

[jira] [Closed] (FLINK-28624) CsvReaderFormat should accept CsvMapper factory

2022-07-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28624. Fix Version/s: (was: 1.15.2) Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #20332: [FLINK-28624][csv] Accept mapper/schema factories

2022-07-26 Thread GitBox
zentol merged PR #20332: URL: https://github.com/apache/flink/pull/20332 -- 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-28267) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

2022-07-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571340#comment-17571340 ] Chesnay Schepler commented on FLINK-28267: -- Disabled in

[jira] [Created] (FLINK-28692) Check warehouse path in CatalogFactory

2022-07-26 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28692: Summary: Check warehouse path in CatalogFactory Key: FLINK-28692 URL: https://issues.apache.org/jira/browse/FLINK-28692 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-28692) Check warehouse path in CatalogFactory

2022-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28692: --- Labels: pull-request-available (was: ) > Check warehouse path in CatalogFactory >

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #243: [FLINK-28692] Check warehouse path in CatalogFactory

2022-07-26 Thread GitBox
JingsongLi opened a new pull request, #243: URL: https://github.com/apache/flink-table-store/pull/243 - Not exist, automatic creating the directory. - Exist but it is not directory, throw exception. - Exist and it is a directory, pass... -- This is an automated message from the

[GitHub] [flink] zentol commented on pull request #20358: [FLINK-28679][hive] Use fixed version for hive-service-rpc

2022-07-26 Thread GitBox
zentol commented on PR #20358: URL: https://github.com/apache/flink/pull/20358#issuecomment-1195317384 When running personal CI, change https://github.com/apache/flink/blob/master/azure-pipelines.yml#L80 to

[GitHub] [flink] wuchong commented on pull request #20298: [FLINK-28152][sql-gateway][hive] Allow executing statement for the HiveServer2Endpoint

2022-07-26 Thread GitBox
wuchong commented on PR #20298: URL: https://github.com/apache/flink/pull/20298#issuecomment-1195317288 Besides, I left some comments on the commit: https://github.com/apache/flink/commit/d067629d4d200f940d0b58759459d7ff5832b292. You can address the comments in this PR. -- This is an

[GitHub] [flink] wuchong commented on a diff in pull request #20298: [FLINK-28152][sql-gateway][hive] Allow executing statement for the HiveServer2Endpoint

2022-07-26 Thread GitBox
wuchong commented on code in PR #20298: URL: https://github.com/apache/flink/pull/20298#discussion_r929707617 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/endpoint/hive/util/ThriftObjectConversionsTest.java: ## @@ -34,4 +110,250 @@ public void

[GitHub] [flink] yunfengzhou-hub commented on pull request #20275: [FLINK-28606][Runtime/Checkpointing] Preserve consistency of OperatorEvent from OperatorCoordinator to subtasks

2022-07-26 Thread GitBox
yunfengzhou-hub commented on PR #20275: URL: https://github.com/apache/flink/pull/20275#issuecomment-1195311943 @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] wangyang0918 commented on pull request #19675: [FLINK-27550] The method of checkYarnQueues is compatible with capacity scheduler

2022-07-26 Thread GitBox
wangyang0918 commented on PR #19675: URL: https://github.com/apache/flink/pull/19675#issuecomment-1195309757 The failed test is not introduced by this PR. To make it more stable, we need to set `checkForProhibitedLogContents` to false for

[jira] [Created] (FLINK-28691) Improve cache hit rate of generated class

2022-07-26 Thread Zou (Jira)
Zou created FLINK-28691: --- Summary: Improve cache hit rate of generated class Key: FLINK-28691 URL: https://issues.apache.org/jira/browse/FLINK-28691 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-28686) Spark table with column comment cannot be read/write by Flink

2022-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28686: --- Labels: pull-request-available (was: ) > Spark table with column comment cannot be

[GitHub] [flink-table-store] LadyForest opened a new pull request, #242: [FLINK-28686] Spark table with column comment cannot be read/write by Flink

2022-07-26 Thread GitBox
LadyForest opened a new pull request, #242: URL: https://github.com/apache/flink-table-store/pull/242 Skip comments comparison when building FileStoreTable -- 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

[jira] [Assigned] (FLINK-28523) LocalRecoveryITCase failed with AssertionError

2022-07-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-28523: Assignee: Chesnay Schepler > LocalRecoveryITCase failed with AssertionError >

[jira] [Commented] (FLINK-28523) LocalRecoveryITCase failed with AssertionError

2022-07-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571329#comment-17571329 ] Chesnay Schepler commented on FLINK-28523: -- It looks like ZK is not responsive while syncing

[GitHub] [flink] fsk119 commented on pull request #20358: [FLINK-28679][hive] Use fixed version for hive-service-rpc

2022-07-26 Thread GitBox
fsk119 commented on PR #20358: URL: https://github.com/apache/flink/pull/20358#issuecomment-1195288057 Thanks for pointing it out. But I find I can not run the nightlies script in my azure pipeline. It reports ``` Variables: SECRET_S3_BUCKET: Parsing expression:

[GitHub] [flink] pltbkd commented on a diff in pull request #20296: [FLINK-28588] Enhance REST API for Speculative Execution

2022-07-26 Thread GitBox
pltbkd commented on code in PR #20296: URL: https://github.com/apache/flink/pull/20296#discussion_r929780673 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java: ## @@ -64,6 +66,7 @@ public TaskManagerDetailsInfo(

[GitHub] [flink] pltbkd commented on a diff in pull request #20296: [FLINK-28588] Enhance REST API for Speculative Execution

2022-07-26 Thread GitBox
pltbkd commented on code in PR #20296: URL: https://github.com/apache/flink/pull/20296#discussion_r929778622 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersionTest.java: ## @@ -31,6 +31,6 @@ protected Class

[jira] [Assigned] (FLINK-28690) UpdateSchema#fromCatalogTable lost column comment

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28690: Assignee: Jane Chan > UpdateSchema#fromCatalogTable lost column comment >

[jira] [Updated] (FLINK-28690) UpdateSchema#fromCatalogTable lost column comment

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28690: - Priority: Blocker (was: Major) > UpdateSchema#fromCatalogTable lost column comment >

[jira] [Closed] (FLINK-28689) Optimize Spark documentation to Catalog and Dataset

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28689. Resolution: Fixed master: c62d721865e08d4f119b118461829261c8f4819b release-0.2:

[GitHub] [flink-table-store] JingsongLi merged pull request #241: [FLINK-28689] Optimize Spark documentation to Catalog and Dataset

2022-07-26 Thread GitBox
JingsongLi merged PR #241: URL: https://github.com/apache/flink-table-store/pull/241 -- 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] yunfengzhou-hub commented on a diff in pull request #20275: [FLINK-28606][Runtime/Checkpointing] Preserve consistency of OperatorEvent from OperatorCoordinator to subtasks

2022-07-26 Thread GitBox
yunfengzhou-hub commented on code in PR #20275: URL: https://github.com/apache/flink/pull/20275#discussion_r929775009 ## flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java: ## @@ -308,6 +337,24 @@ private void

[GitHub] [flink] flinkbot commented on pull request #20366: [FLINK-28651] [Runtime / REST] JarRunHandler gets restore mode from configuration when it is missing in the request

2022-07-26 Thread GitBox
flinkbot commented on PR #20366: URL: https://github.com/apache/flink/pull/20366#issuecomment-1195278269 ## CI report: * 8882df7f56e312de8d90dfc1f76e5ca16b58d558 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-28690) UpdateSchema#fromCatalogTable lost column comment

2022-07-26 Thread Jane Chan (Jira)
Jane Chan created FLINK-28690: - Summary: UpdateSchema#fromCatalogTable lost column comment Key: FLINK-28690 URL: https://issues.apache.org/jira/browse/FLINK-28690 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-28690) UpdateSchema#fromCatalogTable lost column comment

2022-07-26 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-28690: -- Description: The reason is that org.apache.flink.table.api.TableSchema#toPhysicalRowDataType lost

[jira] [Updated] (FLINK-28651) JarRunHandler ignores restore mode set in the configuration

2022-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28651: --- Labels: pull-request-available (was: ) > JarRunHandler ignores restore mode set in the

[GitHub] [flink] nuno-c-afonso opened a new pull request, #20366: [FLINK-28651] [Runtime / REST] JarRunHandler gets restore mode from configuration when it is missing in the request

2022-07-26 Thread GitBox
nuno-c-afonso opened a new pull request, #20366: URL: https://github.com/apache/flink/pull/20366 ## What is the purpose of the change This pull request updates `JarRunHandler` to get the restore mode from the configuration when it is missing from the run request. ## Brief

[GitHub] [flink] WencongLiu commented on a diff in pull request #20236: [FLINK-27769][sql-gateway]Introduce the REST endpoint framework

2022-07-26 Thread GitBox
WencongLiu commented on code in PR #20236: URL: https://github.com/apache/flink/pull/20236#discussion_r929749590 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/util/SqlGatewayRestAPIVersion.java: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the

[jira] [Assigned] (FLINK-28651) JarRunHandler ignores restore mode set in the configuration

2022-07-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-28651: Assignee: Nuno Afonso > JarRunHandler ignores restore mode set in the

[GitHub] [flink] pltbkd commented on pull request #20296: [FLINK-28588] Enhance REST API for Speculative Execution

2022-07-26 Thread GitBox
pltbkd commented on PR #20296: URL: https://github.com/apache/flink/pull/20296#issuecomment-1195245339 @zhuzhurk Thanks a lot for the reviewing! I have split the pr into more meaning commits, and most of your suggestions have been taken, except for the jackson one, which I have

[jira] [Commented] (FLINK-28651) JarRunHandler ignores restore mode set in the configuration

2022-07-26 Thread Nuno Afonso (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571306#comment-17571306 ] Nuno Afonso commented on FLINK-28651: - Hi [~chesnay], Yes, I'm planning to open a PR soon. >

[GitHub] [flink] flinkbot commented on pull request #20365: [FLINK-26929][table-runtime] [FLINK-26929][table-runtime] Introduce adaptive hash join for batch hash join

2022-07-26 Thread GitBox
flinkbot commented on PR #20365: URL: https://github.com/apache/flink/pull/20365#issuecomment-1195236972 ## CI report: * 00ffaa6e76cefd1e5a6225fbd74f8da16a3e2ca0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

2022-07-26 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571302#comment-17571302 ] Yang Wang commented on FLINK-27579: --- Thanks [~paul8263] and [~Jiangang] for your contribution. > The

[jira] [Closed] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

2022-07-26 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-27579. - Fix Version/s: 1.16.0 Resolution: Fixed Fixed via: master:

[jira] [Updated] (FLINK-28689) Optimize Spark documentation to Catalog and Dataset

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28689: - Priority: Blocker (was: Major) > Optimize Spark documentation to Catalog and Dataset >

[GitHub] [flink] wangyang0918 merged pull request #19772: [FLINK-27579][client] The param client.timeout can not be set by dyna…

2022-07-26 Thread GitBox
wangyang0918 merged PR #19772: URL: https://github.com/apache/flink/pull/19772 -- 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-table-store] LadyForest commented on a diff in pull request #241: [FLINK-28689] Optimize Spark documentation to Catalog and Dataset

2022-07-26 Thread GitBox
LadyForest commented on code in PR #241: URL: https://github.com/apache/flink-table-store/pull/241#discussion_r929725419 ## docs/content/docs/engines/spark.md: ## @@ -50,42 +50,37 @@ Alternatively, you can copy `flink-table-store-spark-{{< version >}}.jar` under ## Catalog

[jira] [Closed] (FLINK-28683) Modify changelog-file to changelog-producer

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28683. Resolution: Fixed master: f85ba571fb3aa87d1e619b091c17a8657b9a2d16 release-0.2:

[GitHub] [flink-table-store] JingsongLi merged pull request #238: [FLINK-28683] Modify changelog-file to changelog-producer

2022-07-26 Thread GitBox
JingsongLi merged PR #238: URL: https://github.com/apache/flink-table-store/pull/238 -- 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-26929) Introduce adaptive hash join for batch sql optimization

2022-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26929: --- Labels: pull-request-available (was: ) > Introduce adaptive hash join for batch sql

[GitHub] [flink] lsyldliu opened a new pull request, #20365: [FLINK-26929][table-runtime] [FLINK-26929][table-runtime] Introduce adaptive hash join for batch hash join

2022-07-26 Thread GitBox
lsyldliu opened a new pull request, #20365: URL: https://github.com/apache/flink/pull/20365 ## What is the purpose of the change Introducing adaptive hash join for batch sql hash join. Adaptive hash join integrates the advantages of hash join and sorted-merge join according to the

[jira] [Updated] (FLINK-28689) Optimize Spark documentation to Catalog and Dataset

2022-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28689: --- Labels: pull-request-available (was: ) > Optimize Spark documentation to Catalog and

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #241: [FLINK-28689] Optimize Spark documentation to Catalog and Dataset

2022-07-26 Thread GitBox
JingsongLi opened a new pull request, #241: URL: https://github.com/apache/flink-table-store/pull/241 - Introduce Dataset API. - Unify table_store and tablestore. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-28689) Optimize Spark documentation to Catalog and Dataset

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28689: - Description: * Introduce Dataset API. * Unify table_store and tablestore. > Optimize Spark

[jira] [Created] (FLINK-28689) Optimize Spark documentation to Catalog and Dataset

2022-07-26 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28689: Summary: Optimize Spark documentation to Catalog and Dataset Key: FLINK-28689 URL: https://issues.apache.org/jira/browse/FLINK-28689 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #20364: [FLINK-28680] Revisit 'free_disk_space.sh' to free up more space

2022-07-26 Thread GitBox
flinkbot commented on PR #20364: URL: https://github.com/apache/flink/pull/20364#issuecomment-1195213494 ## CI report: * 14315eb6fd56af5a54304b85b0d7823d0f430d69 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] wsry closed pull request #20203: [FLINK-28448][test] fix bug in BoundedDataTestBase when enable compression

2022-07-26 Thread GitBox
wsry closed pull request #20203: [FLINK-28448][test] fix bug in BoundedDataTestBase when enable compression URL: https://github.com/apache/flink/pull/20203 -- 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

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #20147: [FLINK-27524][datastream] Introduce cache API to DataStream

2022-07-26 Thread GitBox
gaoyunhaii commented on code in PR #20147: URL: https://github.com/apache/flink/pull/20147#discussion_r929639303 ## flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java: ## @@ -184,4 +188,24 @@ CompletableFuture triggerSavepoint( */

[jira] [Assigned] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-28680: -- Assignee: Robert Metzger > No space left on device on Azure e2e_2_ci tests >

[jira] [Updated] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28680: --- Labels: pull-request-available test-stability (was: test-stability) > No space left on

[GitHub] [flink] zentol commented on pull request #20332: [FLINK-28624][csv] Accept mapper/schema factories

2022-07-26 Thread GitBox
zentol commented on PR #20332: URL: https://github.com/apache/flink/pull/20332#issuecomment-1195206311 @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.

[GitHub] [flink] rmetzger opened a new pull request, #20364: [FLINK-28680] Revisit 'free_disk_space.sh' to free up more space

2022-07-26 Thread GitBox
rmetzger opened a new pull request, #20364: URL: https://github.com/apache/flink/pull/20364 ## What is the purpose of the change Tests are running out of disk space. With this PR we'll have 53 instead of 24GB available. -- This is an automated message from the Apache Git

[GitHub] [flink] zentol commented on pull request #20358: [FLINK-28679][hive] Use fixed version for hive-service-rpc

2022-07-26 Thread GitBox
zentol commented on PR #20358: URL: https://github.com/apache/flink/pull/20358#issuecomment-1195205405 Please link a build with the hadoop3 profile active to verify that this works. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571291#comment-17571291 ] Robert Metzger commented on FLINK-28680: I'm able to make 53G available. Opening a PR. > No

[jira] [Closed] (FLINK-28669) FileStoreExpireTest.testExpireWithTime failed

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28669. Assignee: Caizhi Weng Resolution: Fixed master: 11053c16b3fd9fc75287f386f2baf19bca112db1

[jira] [Updated] (FLINK-28669) FileStoreExpireTest.testExpireWithTime failed

2022-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28669: --- Labels: pull-request-available (was: ) > FileStoreExpireTest.testExpireWithTime failed >

[GitHub] [flink] fredia commented on pull request #20313: [FLINK-28597][state] Discard initial checkpoints without a delay in common cases

2022-07-26 Thread GitBox
fredia commented on PR #20313: URL: https://github.com/apache/flink/pull/20313#issuecomment-1195202098 Except for [`testUnregisterNonInitialCheckpoint`](https://github.com/apache/flink/pull/20313#discussion_r927001242), this PR looks good to me. @curcur would you like to take a

[GitHub] [flink-table-store] JingsongLi merged pull request #240: [FLINK-28669] Fix unstable FileStoreExpireTest.testExpireWithTime

2022-07-26 Thread GitBox
JingsongLi merged PR #240: URL: https://github.com/apache/flink-table-store/pull/240 -- 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] [Assigned] (FLINK-28626) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with FileNotFoundException

2022-07-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-28626: Assignee: Chesnay Schepler >

[GitHub] [flink] fredia commented on a diff in pull request #20313: [FLINK-28597][state] Discard initial checkpoints without a delay in common cases

2022-07-26 Thread GitBox
fredia commented on code in PR #20313: URL: https://github.com/apache/flink/pull/20313#discussion_r929700808 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java: ## @@ -365,4 +401,19 @@ public String toString() { return

[jira] [Commented] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS

2022-07-26 Thread Moshe Elisha (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571289#comment-17571289 ] Moshe Elisha commented on FLINK-28171: -- Great! Thank you both. > Adjust Job and Task manager port

[jira] [Closed] (FLINK-28628) Introduce operation execution plugin

2022-07-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28628. --- Resolution: Fixed Fixed in master: c7af66be7cb5c8148dd8bd258267bb7d2550f10e > Introduce operation

[GitHub] [flink] wuchong merged pull request #20247: [FLINK-28628][hive] Introduce operation execution plugin

2022-07-26 Thread GitBox
wuchong merged PR #20247: URL: https://github.com/apache/flink/pull/20247 -- 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-28687) BucketSelector is wrong when hashcode is negative

2022-07-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28687. Resolution: Fixed master: ff697ba12a80f51702a5412c2deb6d4f89a966ff release-0.2:

[GitHub] [flink-table-store] JingsongLi merged pull request #239: [FLINK-28687] BucketSelector is wrong when hashcode is negative

2022-07-26 Thread GitBox
JingsongLi merged PR #239: URL: https://github.com/apache/flink-table-store/pull/239 -- 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-28636) Add utility to test POJO compliance

2022-07-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28636. Resolution: Fixed master: 94c3daac4a96a68009a22825fb1fd4ac0bb92195 > Add utility to test

[GitHub] [flink] zentol merged pull request #20353: [FLINK-28636][tests] Add utility for checking POJO compliance

2022-07-26 Thread GitBox
zentol merged PR #20353: URL: https://github.com/apache/flink/pull/20353 -- 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] wsry commented on pull request #20203: [FLINK-28448][test] fix bug in BoundedDataTestBase when enable compression

2022-07-26 Thread GitBox
wsry commented on PR #20203: URL: https://github.com/apache/flink/pull/20203#issuecomment-1195175987 @reswqa Thanks for the change. LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot commented on pull request #20363: [FLINK-28492][table-planner] Support "ANALYZE TABLE" execution

2022-07-26 Thread GitBox
flinkbot commented on PR #20363: URL: https://github.com/apache/flink/pull/20363#issuecomment-1195162996 ## CI report: * f1729b318978bf07d0fee899f730b5b35e51b586 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

<    1   2   3   >