[GitHub] [flink] gaoyunhaii closed pull request #19395: [FLINK-27118][yarn] TM ignores localhost BIND_HOST

2022-04-08 Thread GitBox
gaoyunhaii closed pull request #19395: [FLINK-27118][yarn] TM ignores localhost BIND_HOST URL: https://github.com/apache/flink/pull/19395 -- 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] [Updated] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27148: -- Priority: Blocker (was: Critical) > UnalignedCheckpointITCase fails on AZP >

[jira] [Commented] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519720#comment-17519720 ] Roman Khachatryan commented on FLINK-27148: ---

[GitHub] [flink] ZhangChaoming commented on a diff in pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-04-08 Thread GitBox
ZhangChaoming commented on code in PR #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r846407990 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala: ## @@ -696,15 +695,46 @@ class TableEnvironmentTest {

[GitHub] [flink] ZhangChaoming commented on a diff in pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-04-08 Thread GitBox
ZhangChaoming commented on code in PR #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r846408411 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java: ## @@ -786,6 +786,24 @@ void createFunction( */

[GitHub] [flink] flinkbot commented on pull request #19410: [FLINK-15635][table] Now EnvironmentSettings accepts the user ClassLoader

2022-04-08 Thread GitBox
flinkbot commented on PR #19410: URL: https://github.com/apache/flink/pull/19410#issuecomment-1093008517 ## CI report: * 5819f99906d857d550f5c2ce5ba6793076398fbe UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27148: -- Description:

[jira] [Closed] (FLINK-26995) Enable fork-reuse for all unit tests

2022-04-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-26995. Resolution: Fixed master: 118294385161c9b76511ab6bf1ee999fb843cb77 > Enable fork-reuse

[jira] [Comment Edited] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519697#comment-17519697 ] Roman Khachatryan edited comment on FLINK-26644 at 4/8/22 4:48 PM: ---

[jira] [Commented] (FLINK-27149) KafkaSourceE2ECase.testScaleUp failed on AZP

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519717#comment-17519717 ] Roman Khachatryan commented on FLINK-27149: --- In the logs, I see "Cannot mark for checkpoint

[jira] [Assigned] (FLINK-27141) Improve FlinkService#waitForClusterShutdown logic

2022-04-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-27141: -- Assignee: Nicholas Jiang > Improve FlinkService#waitForClusterShutdown logic >

[jira] [Commented] (FLINK-27141) Improve FlinkService#waitForClusterShutdown logic

2022-04-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519622#comment-17519622 ] Gyula Fora commented on FLINK-27141: go ahead :)  > Improve FlinkService#waitForClusterShutdown

[jira] [Updated] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27148: -- Description:

[jira] [Created] (FLINK-27149) KafkaSourceE2ECase.testScaleUp failed on AZP

2022-04-08 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-27149: - Summary: KafkaSourceE2ECase.testScaleUp failed on AZP Key: FLINK-27149 URL: https://issues.apache.org/jira/browse/FLINK-27149 Project: Flink Issue

[jira] [Closed] (FLINK-27063) Upgrade Hive 2.3 connector to version 2.3.6

2022-04-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27063. -- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] MartijnVisser merged pull request #19364: [FLINK-27063][Connectors/Hive] Upgrade Hive 2.3 connector from 2.3.6 to 2.3.9

2022-04-08 Thread GitBox
MartijnVisser merged PR #19364: URL: https://github.com/apache/flink/pull/19364 -- 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] gaoyunhaii opened a new pull request, #19411: (1.15) [FLINK-27118][yarn] TM ignores localhost BIND_HOST

2022-04-08 Thread GitBox
gaoyunhaii opened a new pull request, #19411: URL: https://github.com/apache/flink/pull/19411 This picks #19395 to 1.15 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[GitHub] [flink] zentol merged pull request #19407: [FLINK-27143][flink-docs] [JUnit5 Migration] Module: flink-docs

2022-04-08 Thread GitBox
zentol merged PR #19407: URL: https://github.com/apache/flink/pull/19407 -- 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-27031) ChangelogRescalingITCase.test failed due to IllegalStateException

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519687#comment-17519687 ] Roman Khachatryan commented on FLINK-27031: ---

[GitHub] [flink] MartijnVisser merged pull request #19402: [FLINK-27111][BP 1.15][table][docs] Update docs regarding TableEnvironment con…

2022-04-08 Thread GitBox
MartijnVisser merged PR #19402: URL: https://github.com/apache/flink/pull/19402 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] rkhachatryan merged pull request #19331: [FLINK-26985][runtime] Don't discard shared state of restored checkpoints

2022-04-08 Thread GitBox
rkhachatryan merged PR #19331: URL: https://github.com/apache/flink/pull/19331 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] rkhachatryan commented on pull request #19331: [FLINK-26985][runtime] Don't discard shared state of restored checkpoints

2022-04-08 Thread GitBox
rkhachatryan commented on PR #19331: URL: https://github.com/apache/flink/pull/19331#issuecomment-1093257789 Build succeeded, 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 to the

[GitHub] [flink] rkhachatryan opened a new pull request, #19412: [BP-1.15][FLINK-26985][runtime] Don't discard shared state of restored checkpoints

2022-04-08 Thread GitBox
rkhachatryan opened a new pull request, #19412: URL: https://github.com/apache/flink/pull/19412 Backport of #19331 to 1.15. -- 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] flinkbot commented on pull request #19412: [BP-1.15][FLINK-26985][runtime] Don't discard shared state of restored checkpoints

2022-04-08 Thread GitBox
flinkbot commented on PR #19412: URL: https://github.com/apache/flink/pull/19412#issuecomment-1093300685 ## CI report: * 2ddb5ea77256a466f9339479e23c923feceaf6f6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zentol merged pull request #19404: [FLINK-26995][build] Enable fork-reuse for all unit tests

2022-04-08 Thread GitBox
zentol merged PR #19404: URL: https://github.com/apache/flink/pull/19404 -- 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] flinkbot commented on pull request #19411: (1.15) [FLINK-27118][yarn] TM ignores localhost BIND_HOST

2022-04-08 Thread GitBox
flinkbot commented on PR #19411: URL: https://github.com/apache/flink/pull/19411#issuecomment-1093104202 ## CI report: * bb1d3fc731dbb92a3743d1de722ec85040c12c4b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-16835) Replace TableConfig with Configuration

2022-04-08 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519754#comment-17519754 ] Marios Trivyzas commented on FLINK-16835: - [~twalthr] Can we close this issue now, as all of the

[jira] [Commented] (FLINK-27141) Improve FlinkService#waitForClusterShutdown logic

2022-04-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519617#comment-17519617 ] Nicholas Jiang commented on FLINK-27141: [~gyfora], are you working for this ticket? If no, I

[GitHub] [flink] slinkydeveloper opened a new pull request, #19410: [FLINK-15635][table] Now EnvironmentSettings accepts the user ClassLoader

2022-04-08 Thread GitBox
slinkydeveloper opened a new pull request, #19410: URL: https://github.com/apache/flink/pull/19410 This PR solves the issue of allowing the user to provide its own classloader for UDFs and at other places where it's more appropriate than the current Thread context classloader. The

[jira] [Updated] (FLINK-15635) Allow passing a ClassLoader to EnvironmentSettings

2022-04-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15635: --- Labels: pull-request-available (was: ) > Allow passing a ClassLoader to

[GitHub] [flink] matriv commented on a diff in pull request #19410: [FLINK-15635][table] Now EnvironmentSettings accepts the user ClassLoader

2022-04-08 Thread GitBox
matriv commented on code in PR #19410: URL: https://github.com/apache/flink/pull/19410#discussion_r846285936 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionCatalog.java: ## @@ -621,7 +626,7 @@ public void

[jira] [Created] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-08 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-27148: - Summary: UnalignedCheckpointITCase fails on AZP Key: FLINK-27148 URL: https://issues.apache.org/jira/browse/FLINK-27148 Project: Flink Issue Type:

[GitHub] [flink] rkhachatryan commented on pull request #19331: [FLINK-26985][runtime] Don't discard shared state of restored checkpoints

2022-04-08 Thread GitBox
rkhachatryan commented on PR #19331: URL: https://github.com/apache/flink/pull/19331#issuecomment-1093074453 Build failures unrelated: - PR: FLINK-27148 - private branch: FLINK-27148, FLINK-27031 However, `finegrained_resource_management` phase failed in both builds. I"ve restarted

[GitHub] [flink] rkhachatryan commented on pull request #19331: [FLINK-26985][runtime] Don't discard shared state of restored checkpoints

2022-04-08 Thread GitBox
rkhachatryan commented on PR #19331: URL: https://github.com/apache/flink/pull/19331#issuecomment-1093074703 @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] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519697#comment-17519697 ] Roman Khachatryan commented on FLINK-26644: ---

[jira] [Commented] (FLINK-27111) Update docs regarding EnvironmentSettings / TableConfig

2022-04-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519716#comment-17519716 ] Martijn Visser commented on FLINK-27111: Fixed in release-1.15:

[jira] [Closed] (FLINK-27111) Update docs regarding EnvironmentSettings / TableConfig

2022-04-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27111. -- Fix Version/s: 1.15.0 Resolution: Fixed > Update docs regarding EnvironmentSettings /

[GitHub] [flink] MartijnVisser commented on pull request #19401: [FLINK-25716][docs-zh] Translate "Streaming Concepts" page of "Applic…

2022-04-08 Thread GitBox
MartijnVisser commented on PR #19401: URL: https://github.com/apache/flink/pull/19401#issuecomment-1093086962 @RocMarshal Could you help with a review here? -- 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-27137) Remove usage of AdminClient from KafkaSource logic

2022-04-08 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519674#comment-17519674 ] Arvid Heise commented on FLINK-27137: - Hi [~gyfora], sorry if you perceived my message as unfriendly

[jira] [Commented] (FLINK-27137) Remove usage of AdminClient from KafkaSource logic

2022-04-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519679#comment-17519679 ] Gyula Fora commented on FLINK-27137: Even KafkaConsumer 2.0.0 supports all these APIs that I

[jira] [Commented] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519681#comment-17519681 ] Roman Khachatryan commented on FLINK-27148: --- So far I've only seen it on master (1.16), but it

[jira] [Updated] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26644: -- Affects Version/s: 1.14.4 > python >

[GitHub] [flink-kubernetes-operator] SteNicholas opened a new pull request, #161: [FLINK-27141] Improve FlinkService#waitForClusterShutdown logic

2022-04-08 Thread GitBox
SteNicholas opened a new pull request, #161: URL: https://github.com/apache/flink-kubernetes-operator/pull/161 The current `waitForClusterShutdown` logic has a hardcoded 60 second timeout and prints a log message after every second, which should be improved to make the max timeout

[jira] [Closed] (FLINK-27143) [JUnit5 Migration] Module: flink-docs

2022-04-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27143. Fix Version/s: 1.16.0 Assignee: RocMarshal Resolution: Fixed master:

[GitHub] [flink] gaborgsomogyi commented on pull request #19372: [FLINK-26043][runtime][security] Add periodic kerberos relogin to KerberosDelegationTokenManager

2022-04-08 Thread GitBox
gaborgsomogyi commented on PR #19372: URL: https://github.com/apache/flink/pull/19372#issuecomment-1093068781 @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] [Comment Edited] (FLINK-26995) Enable fork-reuse for all unit tests

2022-04-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519689#comment-17519689 ] Chesnay Schepler edited comment on FLINK-26995 at 4/8/22 4:34 PM: --

[jira] [Commented] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519691#comment-17519691 ] Roman Khachatryan commented on FLINK-27148: --- Here's KafkaSourceE2ECase.testScaleDown failure

[GitHub] [flink] JingGe commented on a diff in pull request #19377: [FLINK-27048][test] Add ArchUnit rule that connectors should only depend on public API

2022-04-08 Thread GitBox
JingGe commented on code in PR #19377: URL: https://github.com/apache/flink/pull/19377#discussion_r846309162 ## flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java: ## @@ -0,0 +1,64 @@ +/* + *

[jira] [Updated] (FLINK-27141) Improve FlinkService#waitForClusterShutdown logic

2022-04-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27141: --- Labels: Starter pull-request-available (was: Starter) > Improve

[GitHub] [flink] lsyldliu commented on a diff in pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-04-08 Thread GitBox
lsyldliu commented on code in PR #19329: URL: https://github.com/apache/flink/pull/19329#discussion_r845763835 ## flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl: ## @@ -548,6 +551,18 @@ SqlAlterTable SqlAlterTable() :

[GitHub] [flink] Myasuka commented on a diff in pull request #19331: [FLINK-26985][runtime] Don't discard shared state of restored checkpoints

2022-04-08 Thread GitBox
Myasuka commented on code in PR #19331: URL: https://github.com/apache/flink/pull/19331#discussion_r845767465 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/EmbeddedCompletedCheckpointStore.java: ## @@ -62,7 +63,7 @@ public EmbeddedCompletedCheckpointStore(

[GitHub] [flink] Thesharing commented on a diff in pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-04-08 Thread GitBox
Thesharing commented on code in PR #19275: URL: https://github.com/apache/flink/pull/19275#discussion_r845254295 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -1103,23 +1096,64 @@ private void archiveExecutionGraph(ExecutionGraphInfo

[jira] [Commented] (FLINK-26621) flink-tests failed on azure due to Error occurred in starting fork

2022-04-08 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519347#comment-17519347 ] Yun Gao commented on FLINK-26621: - 1.16:

[GitHub] [flink] MartijnVisser merged pull request #19393: [FLINK-24940][docs] Correct usage about how to create Hive catalog via Flink SQL CLI

2022-04-08 Thread GitBox
MartijnVisser merged PR #19393: URL: https://github.com/apache/flink/pull/19393 -- 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-27111) Update docs regarding EnvironmentSettings / TableConfig

2022-04-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519351#comment-17519351 ] Martijn Visser commented on FLINK-27111: Fixed in master:

[GitHub] [flink] twalthr closed pull request #19379: [FLINK-27089][table-planner] Fix bug with TRY_CAST in batch mode

2022-04-08 Thread GitBox
twalthr closed pull request #19379: [FLINK-27089][table-planner] Fix bug with TRY_CAST in batch mode URL: https://github.com/apache/flink/pull/19379 -- 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] MartijnVisser opened a new pull request, #19402: [FLINK-27111][BP 1.15][table][docs] Update docs regarding TableEnvironment con…

2022-04-08 Thread GitBox
MartijnVisser opened a new pull request, #19402: URL: https://github.com/apache/flink/pull/19402 …figuration (#19387) * [FLINK-27111][table][docs] Update docs regarding TableEnvironment configuration Unchanged backport of https://github.com/apache/flink/pull/19387 -- This

[GitHub] [flink] flinkbot commented on pull request #19402: [FLINK-27111][BP 1.15][table][docs] Update docs regarding TableEnvironment con…

2022-04-08 Thread GitBox
flinkbot commented on PR #19402: URL: https://github.com/apache/flink/pull/19402#issuecomment-1092544643 ## CI report: * f9efd46b54b1dd73f2fd404b46620e8e84f00c9e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] lsyldliu commented on a diff in pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-04-08 Thread GitBox
lsyldliu commented on code in PR #19329: URL: https://github.com/apache/flink/pull/19329#discussion_r845772580 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java: ## @@ -144,6 +147,146 @@ public static Operation

[GitHub] [flink] masteryhx commented on a diff in pull request #19399: [FLINK-26852][state] Avoid RocksDBMapState#clear swallowing related e…

2022-04-08 Thread GitBox
masteryhx commented on code in PR #19399: URL: https://github.com/apache/flink/pull/19399#discussion_r845783236 ## flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackendTest.java: ## @@ -89,9 +93,9 @@

[GitHub] [flink] MartijnVisser merged pull request #19387: [FLINK-27111][table][docs] Update docs regarding TableEnvironment configuration

2022-04-08 Thread GitBox
MartijnVisser merged PR #19387: URL: https://github.com/apache/flink/pull/19387 -- 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-26621) flink-tests failed on azure due to Error occurred in starting fork

2022-04-08 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519360#comment-17519360 ] Yun Gao commented on FLINK-26621: - 1.16:

[GitHub] [flink] zentol commented on pull request #19395: [FLINK-27118][yarn] TM ignores localhost BIND_HOST

2022-04-08 Thread GitBox
zentol commented on PR #19395: URL: https://github.com/apache/flink/pull/19395#issuecomment-1092539768 > Perhaps we could still change it before printing the configuration This isn't possible since the printing is done when the config file is loaded, so any modifications must

[GitHub] [flink] slinkydeveloper commented on a diff in pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-04-08 Thread GitBox
slinkydeveloper commented on code in PR #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r845819045 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala: ## @@ -717,21 +717,21 @@ class TableEnvironmentTest {

[jira] [Commented] (FLINK-27120) Translate "Gradle" tab of "Application Development > Project Configuration > Overview" to Chinese

2022-04-08 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519372#comment-17519372 ] Feifan Wang commented on FLINK-27120: - Hi [~martijnvisser] , I had open a PR to do this, can you

[GitHub] [flink] flinkbot commented on pull request #19403: [FLINK-27120][docs-zh] Translate "Gradle" tab of development > conf > overview

2022-04-08 Thread GitBox
flinkbot commented on PR #19403: URL: https://github.com/apache/flink/pull/19403#issuecomment-1092549521 ## CI report: * a5ff1dc57aadd336d87652cd877b68333a3b5a45 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-27100) Support parquet format in FileStore

2022-04-08 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519327#comment-17519327 ] Yubin Li commented on FLINK-27100: -- Thank [~lzljs3620320] very much, I will create some sub task. >

[jira] [Closed] (FLINK-27126) Respect the state cache size configurations in Python DataStream API operators

2022-04-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-27126. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in: - master via

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #159: [FLINK-27005][FLINK-27065] Bump api version + store last spec as string

2022-04-08 Thread GitBox
gyfora commented on PR #159: URL: https://github.com/apache/flink-kubernetes-operator/pull/159#issuecomment-1092487022 @tweise that makes sense, I will try to see how to add the extra version field -- This is an automated message from the Apache Git Service. To respond to the message,

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

2022-04-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519353#comment-17519353 ] Martijn Visser commented on FLINK-27131: CC [~slinkydeveloper] [~matriv] >

[jira] [Commented] (FLINK-26190) Remove getTableConfig from ExecNodeConfiguration

2022-04-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519362#comment-17519362 ] Dian Fu commented on FLINK-26190: - [~gaoyunhaii] Oh, sorry for that. Have fixed it via

[GitHub] [flink] snailHumming opened a new pull request, #19401: [FLINK-25716][docs-zh] Translate "Streaming Concepts" page of "Applic…

2022-04-08 Thread GitBox
snailHumming opened a new pull request, #19401: URL: https://github.com/apache/flink/pull/19401 …ation Development > Table API & SQL" to Chinese ## What is the purpose of the change After https://github.com/apache/flink/pull/18316 is merged, we need to update the

[GitHub] [flink] mas-chen commented on a diff in pull request #19366: [FLINK-24660][Connectors / Kafka] allow setting KafkaSubscriber in KafkaSourceBuilder

2022-04-08 Thread GitBox
mas-chen commented on code in PR #19366: URL: https://github.com/apache/flink/pull/19366#discussion_r845808245 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java: ## @@ -38,9 +38,11 @@ *

[GitHub] [flink] XComp commented on a diff in pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-04-08 Thread GitBox
XComp commented on code in PR #19275: URL: https://github.com/apache/flink/pull/19275#discussion_r845831177 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -1103,23 +1096,64 @@ private void archiveExecutionGraph(ExecutionGraphInfo

[GitHub] [flink] zentol commented on pull request #19395: [FLINK-27118][yarn] TM ignores localhost BIND_HOST

2022-04-08 Thread GitBox
zentol commented on PR #19395: URL: https://github.com/apache/flink/pull/19395#issuecomment-1092552100 I've tried another approach where we remove the options on the client instead. This should work for both JM/TM processes and prevent any settings that aren't actually applied from being

[GitHub] [flink] Tartarus0zm opened a new pull request, #19400: [FLINK-25142][Connectors / Hive]Fix user-defined hive udtf initialize exception in hive dialect

2022-04-08 Thread GitBox
Tartarus0zm opened a new pull request, #19400: URL: https://github.com/apache/flink/pull/19400 ## What is the purpose of the change Fix user-defined hive udtf initialize exception in hive dialect ## Brief change log HiveGenericUDTF Compatible with new udtf

[GitHub] [flink] flinkbot commented on pull request #19400: [FLINK-25142][Connectors / Hive]Fix user-defined hive udtf initialize exception in hive dialect

2022-04-08 Thread GitBox
flinkbot commented on PR #19400: URL: https://github.com/apache/flink/pull/19400#issuecomment-1092487853 ## CI report: * 101c68ac3cec7cfb03e6dd5eb3349672edfc5035 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] masteryhx commented on a diff in pull request #19399: [FLINK-26852][state] Avoid RocksDBMapState#clear swallowing related e…

2022-04-08 Thread GitBox
masteryhx commented on code in PR #19399: URL: https://github.com/apache/flink/pull/19399#discussion_r845784809 ## flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackendTest.java: ## @@ -619,6 +623,25

[jira] [Comment Edited] (FLINK-26190) Remove getTableConfig from ExecNodeConfiguration

2022-04-08 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519343#comment-17519343 ] Yun Gao edited comment on FLINK-26190 at 4/8/22 6:49 AM: - Hi [~dianfu] it seems

[jira] [Commented] (FLINK-24940) Docs about create Hive catalog via SQL CLI is out of date

2022-04-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519348#comment-17519348 ] Martijn Visser commented on FLINK-24940: Fixed in release-1.15:

[jira] [Closed] (FLINK-24940) Docs about create Hive catalog via SQL CLI is out of date

2022-04-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-24940. -- Fix Version/s: 1.15.0 Resolution: Fixed > Docs about create Hive catalog via SQL CLI

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

2022-04-08 Thread Yun Gao (Jira)
Yun Gao created FLINK-27131: --- Summary: CastFunctionITCase.test failed on azure Key: FLINK-27131 URL: https://issues.apache.org/jira/browse/FLINK-27131 Project: Flink Issue Type: Bug

[GitHub] [flink] lsyldliu commented on pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-04-08 Thread GitBox
lsyldliu commented on PR #19329: URL: https://github.com/apache/flink/pull/19329#issuecomment-1092505042 @luoyuxia Thanks for your review, I have fixed the comment. -- 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-25716) Translate "Streaming Concepts" page of "Application Development > Table API & SQL" to Chinese

2022-04-08 Thread Tianjun Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519365#comment-17519365 ] Tianjun Weng commented on FLINK-25716: -- The backport to the {{release-1.15}} branch is created,

[GitHub] [flink] flinkbot commented on pull request #19401: [FLINK-25716][docs-zh] Translate "Streaming Concepts" page of "Applic…

2022-04-08 Thread GitBox
flinkbot commented on PR #19401: URL: https://github.com/apache/flink/pull/19401#issuecomment-1092524551 ## CI report: * 9589d1e1ad03ca9c6780939ddb8c8dc6762e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zoltar9264 opened a new pull request, #19403: [FLINK-27120][docs-zh] Translate "Gradle" tab of development > conf > overview

2022-04-08 Thread GitBox
zoltar9264 opened a new pull request, #19403: URL: https://github.com/apache/flink/pull/19403 ## What is the purpose of the change [FLINK-27120](https://issues.apache.org/jira/browse/FLINK-27120) "Gradle" tab of "Application Development > Project Configuration > Overview" to

[jira] [Updated] (FLINK-27120) Translate "Gradle" tab of "Application Development > Project Configuration > Overview" to Chinese

2022-04-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27120: --- Labels: chinese-translation pull-request-available (was: chinese-translation) > Translate

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

2022-04-08 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519376#comment-17519376 ] Francesco Guardiani commented on FLINK-27131: - Sounds like a duplicate of

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

2022-04-08 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-27131: --- Assignee: Francesco Guardiani > CastFunctionITCase.test failed on azure >

[GitHub] [flink-table-store] dependabot[bot] opened a new pull request, #80: Bump checkstyle from 8.14 to 8.29

2022-04-08 Thread GitBox
dependabot[bot] opened a new pull request, #80: URL: https://github.com/apache/flink-table-store/pull/80 Bumps [checkstyle](https://github.com/checkstyle/checkstyle) from 8.14 to 8.29. Release notes Sourced from https://github.com/checkstyle/checkstyle/releases;>checkstyle's

[GitHub] [flink] Myasuka commented on a diff in pull request #19399: [FLINK-26852][state] Avoid RocksDBMapState#clear swallowing related e…

2022-04-08 Thread GitBox
Myasuka commented on code in PR #19399: URL: https://github.com/apache/flink/pull/19399#discussion_r845764781 ## flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackendTest.java: ## @@ -619,6 +623,25 @@

[GitHub] [flink] dianfu closed pull request #19394: [FLINK-27126][python] Respect the state cache size configuration for Python DataStream operators

2022-04-08 Thread GitBox
dianfu closed pull request #19394: [FLINK-27126][python] Respect the state cache size configuration for Python DataStream operators URL: https://github.com/apache/flink/pull/19394 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] Tartarus0zm commented on pull request #19400: [FLINK-25142][Connectors / Hive]Fix user-defined hive udtf initialize exception in hive dialect

2022-04-08 Thread GitBox
Tartarus0zm commented on PR #19400: URL: https://github.com/apache/flink/pull/19400#issuecomment-1092485935 @wuchong @luoyuxia I resubmitted a PR, please take a look. thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-26190) Remove getTableConfig from ExecNodeConfiguration

2022-04-08 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519343#comment-17519343 ] Yun Gao commented on FLINK-26190: - [~dianfu] it seems the code could not be compiled now. > Remove

[GitHub] [flink] MartijnVisser commented on pull request #19364: [FLINK-27063][Connectors/Hive] Upgrade Hive 2.3 connector from 2.3.6 to 2.3.9

2022-04-08 Thread GitBox
MartijnVisser commented on PR #19364: URL: https://github.com/apache/flink/pull/19364#issuecomment-1092510526 @luoyuxia Your help would be much appreciated :) -- 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-table-store] JingsongLi merged pull request #79: [hotfix] Value field should be named in value count mode

2022-04-08 Thread GitBox
JingsongLi merged PR #79: URL: https://github.com/apache/flink-table-store/pull/79 -- 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] JingsongLi merged pull request #78: [hotfix] Fix junit4 dependency version

2022-04-08 Thread GitBox
JingsongLi merged PR #78: URL: https://github.com/apache/flink-table-store/pull/78 -- 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-27120) Translate "Gradle" tab of "Application Development > Project Configuration > Overview" to Chinese

2022-04-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519380#comment-17519380 ] Martijn Visser commented on FLINK-27120: [~Feifan Wang] I'll find a reviewer for you :) >

[jira] [Updated] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2022-04-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23391: --- Labels: pull-request-available stale-assigned test-stability (was: pull-request-available

[jira] [Updated] (FLINK-19028) Translate the "application_parameters.zh.md" into Chinese

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

  1   2   3   >