[GitHub] [flink] reswqa commented on pull request #19560: [FLINK-25550][k8s] Migrate flink-k8s module's test from junit4 to junit5

2022-04-24 Thread GitBox
reswqa commented on PR #19560: URL: https://github.com/apache/flink/pull/19560#issuecomment-1108093311 @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] [Comment Edited] (FLINK-27377) Job manager blocks on marking vertex finished

2022-04-24 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527303#comment-17527303 ] Yi Tang edited comment on FLINK-27377 at 4/25/22 4:50 AM: -- I think we can fix

[jira] [Comment Edited] (FLINK-27377) Job manager blocks on marking vertex finished

2022-04-24 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527303#comment-17527303 ] Yi Tang edited comment on FLINK-27377 at 4/25/22 4:45 AM: -- I think we can fix

[jira] [Commented] (FLINK-27377) Job manager blocks on marking vertex finished

2022-04-24 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527303#comment-17527303 ] Yi Tang commented on FLINK-27377: - I think we can fix it by invoking

[jira] [Updated] (FLINK-27377) Job manager blocks on marking vertex finished

2022-04-24 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-27377: Description: I have a case using FileSystem as batch sink, it will commit files by

[jira] [Created] (FLINK-27377) Job manager blocks on marking vertex finished

2022-04-24 Thread Yi Tang (Jira)
Yi Tang created FLINK-27377: --- Summary: Job manager blocks on marking vertex finished Key: FLINK-27377 URL: https://issues.apache.org/jira/browse/FLINK-27377 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27376) Hive dialect supports "select current_database()"

2022-04-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-27376: Summary: Hive dialect supports "select current_database()" Key: FLINK-27376 URL: https://issues.apache.org/jira/browse/FLINK-27376 Project: Flink Issue Type:

[jira] [Created] (FLINK-27375) Hive dialect support "over() without order keys inside"

2022-04-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-27375: Summary: Hive dialect support "over() without order keys inside" Key: FLINK-27375 URL: https://issues.apache.org/jira/browse/FLINK-27375 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18982) InputFormat should remove unnecessary override methods

2022-04-24 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-18982: Priority: Minor (was: Not a Priority) > InputFormat should remove unnecessary override methods >

[jira] [Updated] (FLINK-27374) Convert Hive's void type to Flink's string type

2022-04-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27374: - Parent: FLINK-26360 Issue Type: Sub-task (was: Improvement) > Convert Hive's void type to

[jira] [Updated] (FLINK-27374) Convert Hive's void type to Flink's string type

2022-04-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27374: - Component/s: Connectors / Hive > Convert Hive's void type to Flink's string type >

[jira] [Created] (FLINK-27374) Convert Hive's void type to Flink's string type

2022-04-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-27374: Summary: Convert Hive's void type to Flink's string type Key: FLINK-27374 URL: https://issues.apache.org/jira/browse/FLINK-27374 Project: Flink Issue Type:

[jira] [Created] (FLINK-27373) Disable installing PyFlink using `python setup.py install`

2022-04-24 Thread Dian Fu (Jira)
Dian Fu created FLINK-27373: --- Summary: Disable installing PyFlink using `python setup.py install` Key: FLINK-27373 URL: https://issues.apache.org/jira/browse/FLINK-27373 Project: Flink Issue Type:

[GitHub] [flink] reswqa commented on pull request #19560: [FLINK-25550][k8s] Migrate flink-k8s module's test from junit4 to junit5

2022-04-24 Thread GitBox
reswqa commented on PR #19560: URL: https://github.com/apache/flink/pull/19560#issuecomment-1108026337 @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] [Closed] (FLINK-27160) Add e2e tests for FlinkSessionJob type

2022-04-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-27160. - Assignee: Aitozi Resolution: Fixed Fixed via: main: 85eacb3afab9ab929945fa0ca71e03e2c39c58c0

[GitHub] [flink-kubernetes-operator] wangyang0918 merged pull request #179: [FLINK-27160] Add e2e tests for session job

2022-04-24 Thread GitBox
wangyang0918 merged PR #179: URL: https://github.com/apache/flink-kubernetes-operator/pull/179 -- 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-27372) Make SstFileMeta and ManifestFileMeta schemaless

2022-04-24 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27372: Summary: Make SstFileMeta and ManifestFileMeta schemaless Key: FLINK-27372 URL: https://issues.apache.org/jira/browse/FLINK-27372 Project: Flink Issue Type:

[jira] [Closed] (FLINK-27334) Support auto generate the doc for the KubernetesOperatorConfigOptions

2022-04-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-27334. - Resolution: Fixed Fixed via: main: 5a81a09bd664728449cdb2574853a28309e3465e > Support auto generate

[GitHub] [flink-kubernetes-operator] wangyang0918 merged pull request #178: [FLINK-27334] Support auto generate the doc for the `KubernetesOperatorConfigOptions`

2022-04-24 Thread GitBox
wangyang0918 merged PR #178: URL: https://github.com/apache/flink-kubernetes-operator/pull/178 -- 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] (FLINK-27183) Optimize CepOperator by using temporal state

2022-04-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27183 ] Nicholas Jiang deleted comment on FLINK-27183: was (Author: nicholasjiang): [~danderson], I mainly maintain Flink CEP. How much improvement can the use of temporal state bring to the

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #177: [FLINK-27303][FLINK-27309] Introduce FlinkConfigManager for efficient config management

2022-04-24 Thread GitBox
Aitozi commented on code in PR #177: URL: https://github.com/apache/flink-kubernetes-operator/pull/177#discussion_r857214801 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java: ## @@ -177,19 +192,21 @@ public

[GitHub] [flink] luoyuxia commented on pull request #19556: [FLINK-26413][hive] Hive dialect supports "LOAD DATA INPATH"

2022-04-24 Thread GitBox
luoyuxia commented on PR #19556: URL: https://github.com/apache/flink/pull/19556#issuecomment-1108000930 @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] [Commented] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

2022-04-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527281#comment-17527281 ] Nicholas Jiang commented on FLINK-27364: This issue is deplicated with the FLINK-25177. >

[GitHub] [flink] luoyuxia commented on pull request #19562: [FLINK-27304][hive] Calcite's varbinary type should be converted to Hive's binary type.

2022-04-24 Thread GitBox
luoyuxia commented on PR #19562: URL: https://github.com/apache/flink/pull/19562#issuecomment-1107993210 @beyond1920 Could you please help review? -- 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

[jira] [Created] (FLINK-27371) Record schema id in snapshot and manifestFileMeta and SstFileMeta

2022-04-24 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27371: Summary: Record schema id in snapshot and manifestFileMeta and SstFileMeta Key: FLINK-27371 URL: https://issues.apache.org/jira/browse/FLINK-27371 Project: Flink

[GitHub] [flink-kubernetes-operator] SteNicholas commented on a diff in pull request #178: [FLINK-27334] Support auto generate the doc for the `KubernetesOperatorConfigOptions`

2022-04-24 Thread GitBox
SteNicholas commented on code in PR #178: URL: https://github.com/apache/flink-kubernetes-operator/pull/178#discussion_r857216254 ## flink-kubernetes-docs/README.md: ## @@ -0,0 +1,35 @@ + + +# Documentation generators + +This module contains generators that create HTML files

[jira] [Comment Edited] (FLINK-27304) Flink doesn't support Hive primitive type void yet

2022-04-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527148#comment-17527148 ] luoyuxia edited comment on FLINK-27304 at 4/25/22 2:10 AM: --- [~tartarus] Thanks

[jira] [Closed] (FLINK-27358) Kubernetes operator throws NPE when testing with Flink 1.15

2022-04-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-27358. - Resolution: Fixed Fixed via: main: 707102be6c0af3964a2c9f105639042fc0f2a34d > Kubernetes operator

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a diff in pull request #181: [FLINK-27358] Fix NPE and avoid unnecessary configmap update

2022-04-24 Thread GitBox
wangyang0918 commented on code in PR #181: URL: https://github.com/apache/flink-kubernetes-operator/pull/181#discussion_r857215453 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -243,22 +244,21 @@ public static void

[GitHub] [flink-kubernetes-operator] wangyang0918 merged pull request #181: [FLINK-27358] Fix NPE and avoid unnecessary configmap update

2022-04-24 Thread GitBox
wangyang0918 merged PR #181: URL: https://github.com/apache/flink-kubernetes-operator/pull/181 -- 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-kubernetes-operator] wangyang0918 commented on pull request #181: [FLINK-27358] Fix NPE and avoid unnecessary configmap update

2022-04-24 Thread GitBox
wangyang0918 commented on PR #181: URL: https://github.com/apache/flink-kubernetes-operator/pull/181#issuecomment-1107989903 Merging now. -- 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-kubernetes-operator] SteNicholas commented on pull request #178: [FLINK-27334] Support auto generate the doc for the `KubernetesOperatorConfigOptions`

2022-04-24 Thread GitBox
SteNicholas commented on PR #178: URL: https://github.com/apache/flink-kubernetes-operator/pull/178#issuecomment-1107989002 > @SteNicholas Just to be sure, do you have verified that the CI will fail when the docs are not generated properly? @wangyang0918 , I'm sure that the CI will

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #177: [FLINK-27303][FLINK-27309] Introduce FlinkConfigManager for efficient config management

2022-04-24 Thread GitBox
Aitozi commented on code in PR #177: URL: https://github.com/apache/flink-kubernetes-operator/pull/177#discussion_r857214801 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java: ## @@ -177,19 +192,21 @@ public

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a diff in pull request #178: [FLINK-27334] Support auto generate the doc for the `KubernetesOperatorConfigOptions`

2022-04-24 Thread GitBox
wangyang0918 commented on code in PR #178: URL: https://github.com/apache/flink-kubernetes-operator/pull/178#discussion_r857214600 ## flink-kubernetes-docs/README.md: ## @@ -0,0 +1,35 @@ + + +# Documentation generators + +This module contains generators that create HTML files

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #181: [FLINK-27358] Fix NPE and avoid unnecessary configmap update

2022-04-24 Thread GitBox
Aitozi commented on code in PR #181: URL: https://github.com/apache/flink-kubernetes-operator/pull/181#discussion_r857214425 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -243,22 +244,21 @@ public static void

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #178: [FLINK-27334] Support auto generate the doc for the `KubernetesOperatorConfigOptions`

2022-04-24 Thread GitBox
wangyang0918 commented on PR #178: URL: https://github.com/apache/flink-kubernetes-operator/pull/178#issuecomment-1107987860 @SteNicholas Just to be sure, do you have verified that the CI will fail when the docs are not generated properly? -- This is an automated message from the Apache

[jira] [Updated] (FLINK-27366) Record schema on filesystem path

2022-04-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-27366: - Summary: Record schema on filesystem path (was: Record metadata on filesystem path) > Record

[jira] [Updated] (FLINK-27366) Record schema on filesystem path

2022-04-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-27366: - Description: We can store the schema on the path of the table store, which includes type,

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a diff in pull request #181: [FLINK-27358] Fix NPE and avoid unnecessary configmap update

2022-04-24 Thread GitBox
wangyang0918 commented on code in PR #181: URL: https://github.com/apache/flink-kubernetes-operator/pull/181#discussion_r857213487 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -243,22 +244,21 @@ public static void

[jira] [Updated] (FLINK-26323) PerJobMiniClusterFactoryTest.testJobClient failed on azure

2022-04-24 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26323: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-26341) ZooKeeperTestEnvironment does not allow for repeated test execution

2022-04-24 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26341: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-7151) Support function DDL

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

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #177: [FLINK-27303][FLINK-27309] Introduce FlinkConfigManager for efficient config management

2022-04-24 Thread GitBox
gyfora commented on code in PR #177: URL: https://github.com/apache/flink-kubernetes-operator/pull/177#discussion_r857172750 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java: ## @@ -0,0 +1,214 @@ +/* + * Licensed to

[GitHub] [flink] reswqa commented on pull request #19560: [FLINK-25550][k8s] Migrate flink-k8s module's test from junit4 to junit5

2022-04-24 Thread GitBox
reswqa commented on PR #19560: URL: https://github.com/apache/flink/pull/19560#issuecomment-1107875325 @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] [Created] (FLINK-27370) Add a new SessionJobState - Failed

2022-04-24 Thread Xin Hao (Jira)
Xin Hao created FLINK-27370: --- Summary: Add a new SessionJobState - Failed Key: FLINK-27370 URL: https://issues.apache.org/jira/browse/FLINK-27370 Project: Flink Issue Type: Improvement

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #177: [FLINK-27303][FLINK-27309] Introduce FlinkConfigManager for efficient config management

2022-04-24 Thread GitBox
gyfora commented on code in PR #177: URL: https://github.com/apache/flink-kubernetes-operator/pull/177#discussion_r857135960 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java: ## @@ -0,0 +1,214 @@ +/* + * Licensed to

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #177: [FLINK-27303][FLINK-27309] Introduce FlinkConfigManager for efficient config management

2022-04-24 Thread GitBox
Aitozi commented on code in PR #177: URL: https://github.com/apache/flink-kubernetes-operator/pull/177#discussion_r857135596 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java: ## @@ -0,0 +1,214 @@ +/* + * Licensed to

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #177: [FLINK-27303][FLINK-27309] Introduce FlinkConfigManager for efficient config management

2022-04-24 Thread GitBox
gyfora commented on code in PR #177: URL: https://github.com/apache/flink-kubernetes-operator/pull/177#discussion_r857135110 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java: ## @@ -0,0 +1,214 @@ +/* + * Licensed to

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #177: [FLINK-27303][FLINK-27309] Introduce FlinkConfigManager for efficient config management

2022-04-24 Thread GitBox
gyfora commented on code in PR #177: URL: https://github.com/apache/flink-kubernetes-operator/pull/177#discussion_r857134764 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java: ## @@ -177,19 +192,21 @@ public

[GitHub] [flink-kubernetes-operator] haoxins closed pull request #182: chore: update the examples

2022-04-24 Thread GitBox
haoxins closed pull request #182: chore: update the examples URL: https://github.com/apache/flink-kubernetes-operator/pull/182 -- 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-kubernetes-operator] Aitozi commented on a diff in pull request #177: [FLINK-27303][FLINK-27309] Introduce FlinkConfigManager for efficient config management

2022-04-24 Thread GitBox
Aitozi commented on code in PR #177: URL: https://github.com/apache/flink-kubernetes-operator/pull/177#discussion_r857133548 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java: ## @@ -0,0 +1,214 @@ +/* + * Licensed to

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #177: [FLINK-27303][FLINK-27309] Introduce FlinkConfigManager for efficient config management

2022-04-24 Thread GitBox
Aitozi commented on code in PR #177: URL: https://github.com/apache/flink-kubernetes-operator/pull/177#discussion_r857132299 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java: ## @@ -55,31 +54,45 @@ /** Builder to

[GitHub] [flink] reswqa commented on a diff in pull request #19563: [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core

2022-04-24 Thread GitBox
reswqa commented on code in PR #19563: URL: https://github.com/apache/flink/pull/19563#discussion_r857131608 ## flink-core/src/test/java/org/apache/flink/api/common/accumulators/AverageAccumulatorTest.java: ## @@ -94,20 +93,20 @@ public void testMergeSuccess() { }

[GitHub] [flink] reswqa commented on pull request #19560: [FLINK-25550][k8s] Migrate flink-k8s module's test from junit4 to junit5

2022-04-24 Thread GitBox
reswqa commented on PR #19560: URL: https://github.com/apache/flink/pull/19560#issuecomment-1107846789 @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-kubernetes-operator] Aitozi commented on pull request #179: [FLINK-27160] Add e2e tests for session job

2022-04-24 Thread GitBox
Aitozi commented on PR #179: URL: https://github.com/apache/flink-kubernetes-operator/pull/179#issuecomment-1107846194 I have addressed your comments, please take a look again @wangyang0918 -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-kubernetes-operator] Aitozi commented on pull request #182: chore: update the examples

2022-04-24 Thread GitBox
Aitozi commented on PR #182: URL: https://github.com/apache/flink-kubernetes-operator/pull/182#issuecomment-1107846089 Hi @haoxins , It has heen fixed in this https://github.com/apache/flink-kubernetes-operator/pull/179/commits -- This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #19563: [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core

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

[jira] [Updated] (FLINK-25537) [JUnit5 Migration] Module: flink-core

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

[GitHub] [flink] GOODBOY008 opened a new pull request, #19563: [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core

2022-04-24 Thread GitBox
GOODBOY008 opened a new pull request, #19563: URL: https://github.com/apache/flink/pull/19563 ## What is the purpose of the change *Update the flink-core module to AssertJ and JUnit 5 following the [JUnit

[GitHub] [flink] ChengkaiYang2022 commented on pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

2022-04-24 Thread GitBox
ChengkaiYang2022 commented on PR #19498: URL: https://github.com/apache/flink/pull/19498#issuecomment-1107839815 Hi,@fsk119 would you mind help to review this? -- 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] [Updated] (FLINK-27369) COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch

2022-04-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27369: Description: {code} Flink SQL> SELECT > COALESCE('1', cast(NULL as varchar)), > COALESCE('4',

[jira] [Created] (FLINK-27369) COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch

2022-04-24 Thread Jark Wu (Jira)
Jark Wu created FLINK-27369: --- Summary: COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch Key: FLINK-27369 URL: https://issues.apache.org/jira/browse/FLINK-27369 Project: Flink

[jira] [Updated] (FLINK-26414) Hive dialect supports "Marco"

2022-04-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26414: --- Labels: pull-request-available (was: ) > Hive dialect supports "Marco" >

[GitHub] [flink] flinkbot commented on pull request #19562: [FLINK-27304][hive] Hive's BINARY type should be converted to Flink's BINARY type instead of BYTES

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

[GitHub] [flink] flinkbot commented on pull request #19561: [FLINK-26414][hive] Hive dialect supports macro

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

[jira] [Updated] (FLINK-27368) CAST(' 1 ' as BIGINT) reutrns wrong result

2022-04-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27368: Description: {code:sql} Flink SQL> select > cast(' 1 ' as tinyint), >

[jira] [Updated] (FLINK-27368) CAST(' 1 ' as BIGINT) reutrns wrong result

2022-04-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27368: Description: {code:sql} Flink SQL> select > cast(' 1 ' as tinyint), >

[jira] [Updated] (FLINK-27304) Flink doesn't support Hive primitive type void yet

2022-04-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27304: --- Labels: pull-request-available (was: ) > Flink doesn't support Hive primitive type void

[GitHub] [flink] luoyuxia opened a new pull request, #19562: [FLINK-27304][hive] Hive's BINARY type should be converted to Flink's BINARY type instead of BYTES

2022-04-24 Thread GitBox
luoyuxia opened a new pull request, #19562: URL: https://github.com/apache/flink/pull/19562 ## 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 them

[GitHub] [flink] luoyuxia opened a new pull request, #19561: [FLINK-26366][hive] Hive dialect supports macro

2022-04-24 Thread GitBox
luoyuxia opened a new pull request, #19561: URL: https://github.com/apache/flink/pull/19561 ## 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 them

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #179: [FLINK-27160] Add e2e tests for session job

2022-04-24 Thread GitBox
Aitozi commented on code in PR #179: URL: https://github.com/apache/flink-kubernetes-operator/pull/179#discussion_r857113510 ## e2e-tests/test_last_state_upgrade.sh: ## @@ -47,6 +48,7 @@ function wait_for_jobmanager_running() { function assert_available_slots() {

[jira] [Updated] (FLINK-27036) Do not build and push images on final release tags

2022-04-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27036: --- Priority: Blocker (was: Major) > Do not build and push images on final release tags >

[jira] [Closed] (FLINK-26926) Allow users to force upgrade even if savepoint is in progress

2022-04-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26926. -- Resolution: Fixed merged to main d1b20f1a500c75b54b34a86c6d09bf92e300a9fd > Allow users to force

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #175: [FLINK-26926] Allow users to force upgrade even if savepoint is in progress

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

[jira] [Comment Edited] (FLINK-27304) Flink doesn't support Hive primitive type void yet

2022-04-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527148#comment-17527148 ] luoyuxia edited comment on FLINK-27304 at 4/24/22 11:28 AM: [~tartarus]

[jira] [Commented] (FLINK-27304) Flink doesn't support Hive primitive type void yet

2022-04-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527148#comment-17527148 ] luoyuxia commented on FLINK-27304: -- [~tartarus] Thanks for reporting it. The reason is that binary will

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #181: [FLINK-27358] Fix NPE and avoid unnecessary configmap update

2022-04-24 Thread GitBox
Aitozi commented on code in PR #181: URL: https://github.com/apache/flink-kubernetes-operator/pull/181#discussion_r857102946 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -243,22 +244,21 @@ public static void

[jira] [Commented] (FLINK-27358) Kubernetes operator throws NPE when testing with Flink 1.15

2022-04-24 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527147#comment-17527147 ] Aitozi commented on FLINK-27358: Do we need to link the related upstream ticket here ?  > Kubernetes

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #181: [FLINK-27358] Fix NPE and avoid unnecessary configmap update

2022-04-24 Thread GitBox
Aitozi commented on code in PR #181: URL: https://github.com/apache/flink-kubernetes-operator/pull/181#discussion_r857102946 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -243,22 +244,21 @@ public static void

[jira] [Created] (FLINK-27368) CAST(' 1 ' as BIGINT) reutrns wrong result

2022-04-24 Thread Jark Wu (Jira)
Jark Wu created FLINK-27368: --- Summary: CAST(' 1 ' as BIGINT) reutrns wrong result Key: FLINK-27368 URL: https://issues.apache.org/jira/browse/FLINK-27368 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-27367) CAST between INT and DATE is broken

2022-04-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527144#comment-17527144 ] Jark Wu commented on FLINK-27367: - Hi [~matriv], is it on purpose that dropped this feature in

[jira] [Created] (FLINK-27367) CAST between INT and DATE is broken

2022-04-24 Thread Jark Wu (Jira)
Jark Wu created FLINK-27367: --- Summary: CAST between INT and DATE is broken Key: FLINK-27367 URL: https://issues.apache.org/jira/browse/FLINK-27367 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #19560: [FLINK-25550][k8s] Migrate flink-k8s module's test from junit4 to junit5

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

[jira] [Updated] (FLINK-25550) [JUnit5 Migration] Module: flink-kuberbetes

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

[GitHub] [flink] reswqa opened a new pull request, #19560: [FLINK-25550][k8s] Migrate flink-k8s module's test from junit4 to junit5

2022-04-24 Thread GitBox
reswqa opened a new pull request, #19560: URL: https://github.com/apache/flink/pull/19560 ## What is the purpose of the change Migrate flink-k8s module's test from junit4 to junit5. ## Brief change log - migrate tests from junit assert to AssertJ -

[GitHub] [flink-table-store] JingsongLi commented on pull request #101: [FLINK-27366] Record metadata on filesystem path

2022-04-24 Thread GitBox
JingsongLi commented on PR #101: URL: https://github.com/apache/flink-table-store/pull/101#issuecomment-1107800479 This is only a rough draft, please do not review. -- 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-27366) Record metadata on filesystem path

2022-04-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27366: --- Labels: pull-request-available (was: ) > Record metadata on filesystem path >

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #101: [FLINK-27366] Record metadata on filesystem path

2022-04-24 Thread GitBox
JingsongLi opened a new pull request, #101: URL: https://github.com/apache/flink-table-store/pull/101 We can store the metadata on the path of the table store, which includes schema, options, etc. This schema should be in a format that supports evolution, which means that the fields

[jira] [Created] (FLINK-27366) Record metadata on filesystem path

2022-04-24 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27366: Summary: Record metadata on filesystem path Key: FLINK-27366 URL: https://issues.apache.org/jira/browse/FLINK-27366 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27365) [umbrella] Schema evolution on table store

2022-04-24 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27365: Summary: [umbrella] Schema evolution on table store Key: FLINK-27365 URL: https://issues.apache.org/jira/browse/FLINK-27365 Project: Flink Issue Type: New

[jira] [Assigned] (FLINK-27262) Enrich validator for FlinkSesionJob

2022-04-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-27262: - Assignee: Aitozi > Enrich validator for FlinkSesionJob > --- >

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #181: [FLINK-27358] Fix NPE and avoid unnecessary configmap update

2022-04-24 Thread GitBox
wangyang0918 commented on PR #181: URL: https://github.com/apache/flink-kubernetes-operator/pull/181#issuecomment-1107796757 cc @gyfora @Aitozi Could you like have a look on this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a diff in pull request #179: [FLINK-27160] Add e2e tests for session job

2022-04-24 Thread GitBox
wangyang0918 commented on code in PR #179: URL: https://github.com/apache/flink-kubernetes-operator/pull/179#discussion_r857092762 ## e2e-tests/test_sessionjob_ha.sh: ## @@ -0,0 +1,68 @@ +#!/usr/bin/env bash +# +# Licensed to the Apache Software Foundation (ASF) under one or

[jira] [Updated] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes

2022-04-24 Thread bo zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bo zhao updated FLINK-26559: Description: This is an umbrella issue for tracking the work for supporting Volcano on FLink Kubernetes.

[jira] [Closed] (FLINK-27360) Rename clusterId field of FlinkSessionJobSpec to deploymentName

2022-04-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-27360. - Resolution: Fixed Fixed via: main: 4559495fc554595c03f4569fa5fd52ff214967e3 > Rename clusterId field

[GitHub] [flink-kubernetes-operator] wangyang0918 merged pull request #180: [FLINK-27360] Rename clusterId field of FlinkSessionJobSpec to deploy…

2022-04-24 Thread GitBox
wangyang0918 merged PR #180: URL: https://github.com/apache/flink-kubernetes-operator/pull/180 -- 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-kubernetes-operator] wangyang0918 commented on pull request #180: [FLINK-27360] Rename clusterId field of FlinkSessionJobSpec to deploy…

2022-04-24 Thread GitBox
wangyang0918 commented on PR #180: URL: https://github.com/apache/flink-kubernetes-operator/pull/180#issuecomment-1107792483 Merging now. -- 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] [Closed] (FLINK-27361) Introduce retry mechanism for SnapshotFinder

2022-04-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27361. Resolution: Fixed master: 0f62e3585226a04be5802886982dfd6b3828b7e3 release-0.1:

[jira] [Updated] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

2022-04-24 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27364: -- Description: DESCRIBE [EXTENDED] [db_name.]table_name \{ [PARTITION partition_spec]  | [col_name ] };

[jira] [Updated] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

2022-04-24 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27364: -- Description: DESCRIBE [EXTENDED] [db_name.]table_name { [PARTITION partition_spec]  | [col_name ] };

  1   2   >