[jira] [Updated] (FLINK-27093) Add Estimator and Transformer for LinearReg

2022-04-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27093: --- Labels: pull-request-available (was: ) > Add Estimator and Transformer for LinearReg >

[GitHub] [flink-ml] zhipeng93 opened a new pull request, #90: [FLINK-27093] Add Transformer and Estimator of LinearRegression

2022-04-24 Thread GitBox
zhipeng93 opened a new pull request, #90: URL: https://github.com/apache/flink-ml/pull/90 ## What is the purpose of the change - Add Transformer and Estimator of LinearRegression in FlinkML. ## Brief change log - Abstracted a base class for general linear models. - Reconstruc

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

2022-04-24 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27369: -- Assignee: godfrey he > COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch >

[GitHub] [flink] XComp commented on pull request #19526: [BP-1.15][FLINK-24491][runtime] Make the job termination wait until the archiv…

2022-04-24 Thread GitBox
XComp commented on PR #19526: URL: https://github.com/apache/flink/pull/19526#issuecomment-1108136406 I actually waited for the 1.15.0 release but I'm gonna rebase the branch and do another ci before merging... -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Created] (FLINK-27380) Failed to get Hive result type from org.apache.hadoop.hive.ql.udf.generic.GenericUDAFPercentileApprox

2022-04-24 Thread tartarus (Jira)
tartarus created FLINK-27380: Summary: Failed to get Hive result type from org.apache.hadoop.hive.ql.udf.generic.GenericUDAFPercentileApprox Key: FLINK-27380 URL: https://issues.apache.org/jira/browse/FLINK-27380

[jira] [Created] (FLINK-27379) CodeGenException: Unable to find common type of

2022-04-24 Thread tartarus (Jira)
tartarus created FLINK-27379: Summary: CodeGenException: Unable to find common type of Key: FLINK-27379 URL: https://issues.apache.org/jira/browse/FLINK-27379 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26793) Flink Cassandra connector performance issue

2022-04-24 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527329#comment-17527329 ] Arvid Heise commented on FLINK-26793: - Just to double-check: Can we optimize anythin

[jira] [Created] (FLINK-27378) Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess

2022-04-24 Thread tartarus (Jira)
tartarus created FLINK-27378: Summary: Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess Key: FLINK-27378 URL: https://issues.apache.org/jira/browse/FLINK-27378 Project: Flink Issue Type

[jira] [Resolved] (FLINK-23252) Support recovery (from checkpoints) after disabling changelog backend

2022-04-24 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23252. -- Resolution: Fixed merged in master: 7b48eae6b448963e0aed2b33d06e105311a48e05 and ece745c39eaee7caaa1a

[GitHub] [flink] Myasuka merged pull request #19142: [FLINK-23252][changelog] Support recovery from checkpoint after disab…

2022-04-24 Thread GitBox
Myasuka merged PR #19142: URL: https://github.com/apache/flink/pull/19142 -- 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: issues-unsubscr...@flink.apach

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

2022-04-24 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527324#comment-17527324 ] Guowei Ma commented on FLINK-27377: --- Hi [~yittg] thanks for your reporting. Afaik the

[GitHub] [flink] luoyuxia closed pull request #18548: [FLINK-25727][hive] fix the UDFArgumentException when call hive `json…

2022-04-24 Thread GitBox
luoyuxia closed pull request #18548: [FLINK-25727][hive] fix the UDFArgumentException when call hive `json… URL: https://github.com/apache/flink/pull/18548 -- 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] 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. T

[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&focusedCommentId=17527303#comment-17527303 ] Yi Tang edited comment on FLINK-27377 at 4/25/22 4:50 AM: -- I th

[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&focusedCommentId=17527303#comment-17527303 ] Yi Tang edited comment on FLINK-27377 at 4/25/22 4:45 AM: -- I th

[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&focusedCommentId=17527303#comment-17527303 ] Yi Tang commented on FLINK-27377: - I think we can fix it by invoking {{schedulerNG#updat

[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 {{FinalizeOnMaster#fin

[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: Sub-tas

[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: S

[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 Flink

[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: Improveme

[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. T

[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 31

[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: issues-un

[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 th

[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: issues-un

[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 per

[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 FlinkConf

[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&focusedCommentId=17527281#comment-17527281 ] Nicholas Jiang commented on FLINK-27364: This issue is deplicated with the FLINK

[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 di

[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&focusedCommentId=17527148#comment-17527148 ] luoyuxia edited comment on FLINK-27304 at 4/25/22 2:10 AM: --- [~

[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 thro

[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: issues-un

[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 spec

[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 f

[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 FlinkConf

[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 d

[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 delete

[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 s

[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, optio

[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 Bot|https://g

[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 Bot|https://g

[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: auto

[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 comment

[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 Co

[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 FlinkConf

[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. T

[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. T

[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 log

[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 Service.

[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 5

[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 ab

[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', cast

[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 I

[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 yet

[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 o

[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 o

[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() { expected=$

[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 upgr

[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: issues-unsubscr

[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&focusedCommentId=17527148#comment-17527148 ] luoyuxia edited comment on FLINK-27304 at 4/24/22 11:28 AM:

[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&focusedCommentId=17527148#comment-17527148 ] luoyuxia commented on FLINK-27304: -- [~tartarus] Thanks for reporting it. The reason is

[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 delete

[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&focusedCommentId=17527147#comment-17527147 ] Aitozi commented on FLINK-27358: Do we need to link the related upstream ticket here ? 

[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 delete

[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 Co

[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&focusedCommentId=17527144#comment-17527144 ] Jark Wu commented on FLINK-27367: - Hi [~matriv], is it on purpose that dropped this feat

[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 Component

[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 - migr

[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

  1   2   >