[jira] [Updated] (FLINK-32115) json_value support cache

2023-05-21 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-32115: -- Description: [https://github.com/apache/hive/blob/storage-branch-2.3/ql/src/java/org/apache/ha

[jira] [Assigned] (FLINK-30559) May get wrong result for `if` expression if it's string data type

2023-05-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30559: -- Assignee: luoyuxia (was: miamiaoxyz) > May get wrong result for `if` expression if i

[jira] [Assigned] (FLINK-32132) Cast function CODEGEN does not work as expected when nullOnFailure enabled

2023-05-21 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-32132: Assignee: xiaogang zhou > Cast function CODEGEN does not work as expected when nullOnFailure enab

[jira] [Commented] (FLINK-32132) Cast function CODEGEN does not work as expected when nullOnFailure enabled

2023-05-21 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724780#comment-17724780 ] xiaogang zhou commented on FLINK-32132: --- [~luoyuxia] yes, please assign to me > C

[jira] [Resolved] (FLINK-31498) DeclartiveSlotManager always request redundant task manager when resource is not enough

2023-05-21 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-31498. Fix Version/s: 1.18.0 Resolution: Done master(1.18) via abe0fbf433f66bb94f5b42ab46a00348ea9

[GitHub] [flink] reswqa merged pull request #22246: [FLINK-31498][runtime] Only request redundant task manager when all pending slots registered.

2023-05-21 Thread via GitHub
reswqa merged PR #22246: URL: https://github.com/apache/flink/pull/22246 -- 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.apache

[GitHub] [flink] reswqa commented on pull request #22246: [FLINK-31498][runtime] Only request redundant task manager when all pending slots registered.

2023-05-21 Thread via GitHub
reswqa commented on PR #22246: URL: https://github.com/apache/flink/pull/22246#issuecomment-1556577992 @huwh Sure, It seems that CI has passed. -- 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] huwh commented on pull request #22246: [FLINK-31498][runtime] Only request redundant task manager when all pending slots registered.

2023-05-21 Thread via GitHub
huwh commented on PR #22246: URL: https://github.com/apache/flink/pull/22246#issuecomment-1556566868 @reswqa I think this PR is mergeable, could you please help merge it in your free time? -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink] lzshlzsh commented on a diff in pull request #22612: [FLINK-32139][connector/hbase] Using strongly increasing nanosecond timestamp and DeleteColumn type to fix data accidental deletio

2023-05-21 Thread via GitHub
lzshlzsh commented on code in PR #22612: URL: https://github.com/apache/flink/pull/22612#discussion_r1199953412 ## flink-connectors/flink-connector-hbase-base/src/test/java/org/apache/flink/connector/hbase/util/HBaseTimestampGeneratorTest.java: ## @@ -0,0 +1,51 @@ +/* + * Licens

[GitHub] [flink] lzshlzsh commented on a diff in pull request #22612: [FLINK-32139][connector/hbase] Using strongly increasing nanosecond timestamp and DeleteColumn type to fix data accidental deletio

2023-05-21 Thread via GitHub
lzshlzsh commented on code in PR #22612: URL: https://github.com/apache/flink/pull/22612#discussion_r1199953156 ## flink-connectors/flink-connector-hbase-base/src/test/java/org/apache/flink/connector/hbase/util/HBaseTimestampGeneratorTest.java: ## @@ -0,0 +1,51 @@ +/* + * Licens

[GitHub] [flink] lzshlzsh commented on a diff in pull request #22612: [FLINK-32139][connector/hbase] Using strongly increasing nanosecond timestamp and DeleteColumn type to fix data accidental deletio

2023-05-21 Thread via GitHub
lzshlzsh commented on code in PR #22612: URL: https://github.com/apache/flink/pull/22612#discussion_r1199952569 ## flink-connectors/flink-connector-hbase-base/src/test/java/org/apache/flink/connector/hbase/util/HBaseTimestampGeneratorTest.java: ## @@ -0,0 +1,51 @@ +/* + * Licens

[GitHub] [flink] lzshlzsh commented on a diff in pull request #22612: [FLINK-32139][connector/hbase] Using strongly increasing nanosecond timestamp and DeleteColumn type to fix data accidental deletio

2023-05-21 Thread via GitHub
lzshlzsh commented on code in PR #22612: URL: https://github.com/apache/flink/pull/22612#discussion_r1199952919 ## flink-connectors/flink-connector-hbase-base/src/test/java/org/apache/flink/connector/hbase/util/HBaseTimestampGeneratorTest.java: ## @@ -0,0 +1,51 @@ +/* + * Licens

[GitHub] [flink] lzshlzsh commented on a diff in pull request #22612: [FLINK-32139][connector/hbase] Using strongly increasing nanosecond timestamp and DeleteColumn type to fix data accidental deletio

2023-05-21 Thread via GitHub
lzshlzsh commented on code in PR #22612: URL: https://github.com/apache/flink/pull/22612#discussion_r1199951039 ## flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/util/HBaseTimestampGenerator.java: ## @@ -0,0 +1,54 @@ +/* + * Licensed t

[GitHub] [flink] kylemeow commented on a diff in pull request #22612: [FLINK-32139][connector/hbase] Using strongly increasing nanosecond timestamp and DeleteColumn type to fix data accidental deletio

2023-05-21 Thread via GitHub
kylemeow commented on code in PR #22612: URL: https://github.com/apache/flink/pull/22612#discussion_r1199948064 ## flink-connectors/flink-connector-hbase-base/src/test/java/org/apache/flink/connector/hbase/util/HBaseTimestampGeneratorTest.java: ## @@ -0,0 +1,51 @@ +/* + * Licens

[jira] [Created] (FLINK-32143) Automatic cleanup of terminated flinkdeployments

2023-05-21 Thread Paul Lin (Jira)
Paul Lin created FLINK-32143: Summary: Automatic cleanup of terminated flinkdeployments Key: FLINK-32143 URL: https://issues.apache.org/jira/browse/FLINK-32143 Project: Flink Issue Type: New Feat

[jira] [Commented] (FLINK-32133) Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers

2023-05-21 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724754#comment-17724754 ] Weihua Hu commented on FLINK-32133: --- As you said, this problem is caused by the YARN A

[jira] [Updated] (FLINK-32133) Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers

2023-05-21 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32133: --- Description: h1. Problem When the initial job requests many containers from yarn, it is easy to get

[jira] [Assigned] (FLINK-32141) SharedStateRegistry print too much info log

2023-05-21 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32141: -- Assignee: Feifan Wang > SharedStateRegistry print too much info log > ---

[jira] [Updated] (FLINK-32141) SharedStateRegistry print too much info log

2023-05-21 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32141: --- Fix Version/s: 1.17.2 (was: 1.17.1) > SharedStateRegistry print too much info

[GitHub] [flink] reswqa commented on pull request #22573: [FLINK-32058][tests] Migrate the subclasses of BatchAbstractTestBase in runtime.batch.sql to JUnit5

2023-05-21 Thread via GitHub
reswqa commented on PR #22573: URL: https://github.com/apache/flink/pull/22573#issuecomment-1556459827 Thanks @TanYuxin-tyx for the update and thanks @snuyanzin for the review! Do you have any other comments? If not, I will merge this tomorrow because this will block other migrations. --

[GitHub] [flink-ml] lindong28 opened a new pull request, #238: [hotfix] Update quickstart to require a given Flink version

2023-05-21 Thread via GitHub
lindong28 opened a new pull request, #238: URL: https://github.com/apache/flink-ml/pull/238 ## What is the purpose of the change Update the quickstart to require a given Flink version. This is because we can not guarantee that a given Flink ML version can work with multiple Flink ver

[jira] [Updated] (FLINK-31967) SQL with LAG function NullPointerException

2023-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31967: --- Labels: pull-request-available (was: ) > SQL with LAG function NullPointerException > -

[GitHub] [flink] whjshj commented on a diff in pull request #22599: [FLINK-31967][table-runner] Solving the Initial Value Problem of LagA…

2023-05-21 Thread via GitHub
whjshj commented on code in PR #22599: URL: https://github.com/apache/flink/pull/22599#discussion_r1199901204 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/LagAggFunction.java: ## @@ -44,6 +44,11 @@ public LagAggFunction(Logi

[jira] [Commented] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

2023-05-21 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724739#comment-17724739 ] LiuZeshan commented on FLINK-32139: --- [~liyu] Would you also help to take a look at thi

[jira] [Commented] (FLINK-32132) Cast function CODEGEN does not work as expected when nullOnFailure enabled

2023-05-21 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724738#comment-17724738 ] luoyuxia commented on FLINK-32132: -- [~zhoujira86] Thanks for reporting. Would you like

[GitHub] [flink] flinkbot commented on pull request #22615: fix: analyze.md SQL sample syntax error

2023-05-21 Thread via GitHub
flinkbot commented on PR #22615: URL: https://github.com/apache/flink/pull/22615#issuecomment-1556427001 ## CI report: * 5e50d9b947ddb87cd8e7e700fce8c8af750ec2b9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] luoyuxia commented on a diff in pull request #21927: [FLINK-30966][table-planner] Optimize type inference for Character type and fix result type casting in IfCallGen

2023-05-21 Thread via GitHub
luoyuxia commented on code in PR #21927: URL: https://github.com/apache/flink/pull/21927#discussion_r1199884283 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/IfCallGen.scala: ## @@ -52,19 +52,19 @@ class IfCallGen() extends CallGe

[GitHub] [flink] luoyuxia commented on a diff in pull request #21927: [FLINK-30966][table-planner] Optimize type inference for Character type and fix result type casting in IfCallGen

2023-05-21 Thread via GitHub
luoyuxia commented on code in PR #21927: URL: https://github.com/apache/flink/pull/21927#discussion_r1106550718 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/type/NumericOrDefaultReturnTypeInference.java: ## @@ -56,7 +56,7 @@ public RelData

[jira] [Commented] (FLINK-30559) May get wrong result for `if` expression if it's string data type

2023-05-21 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724730#comment-17724730 ] luoyuxia commented on FLINK-30559: -- [~yunta] Thanks for reminder. Haven't been awared o

[jira] [Updated] (FLINK-32131) Support specifying hadoop config dir for Python HiveCatalog

2023-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32131: --- Labels: pull-request-available (was: ) > Support specifying hadoop config dir for Python Hi

[jira] [Closed] (FLINK-32131) Support specifying hadoop config dir for Python HiveCatalog

2023-05-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-32131. --- Resolution: Fixed Merged to master via 5a89d22c146f451f12fd0c6de64804d315e1f4b6 > Support specifying hadoop

[GitHub] [flink] dianfu closed pull request #22607: [FLINK-32131][python] Support specifying hadoop config directory for HiveCatalog

2023-05-21 Thread via GitHub
dianfu closed pull request #22607: [FLINK-32131][python] Support specifying hadoop config directory for HiveCatalog URL: https://github.com/apache/flink/pull/22607 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[jira] [Commented] (FLINK-32142) Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error

2023-05-21 Thread Elphas Toringepi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724699#comment-17724699 ] Elphas Toringepi commented on FLINK-32142: -- Thanks, could you please take a loo

[jira] [Commented] (FLINK-31822) Support configure maxRows when fetch result

2023-05-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724692#comment-17724692 ] Jark Wu commented on FLINK-31822: - Sounds good to me. What do you think [~fsk119] > Sup

[jira] [Commented] (FLINK-31985) The currentDate() get transformed to TIMESTAMP_LTZ(3) instead of DATE()

2023-05-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724681#comment-17724681 ] Jark Wu commented on FLINK-31985: - Do you mean the return type of Table API {{currentDat

[jira] [Commented] (FLINK-31960) SQL OverBy. Error on a code that does not exist

2023-05-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724680#comment-17724680 ] Jark Wu commented on FLINK-31960: - [~padavan], ROW/RANGE clause is not allowed for the L

[jira] [Comment Edited] (FLINK-31960) SQL OverBy. Error on a code that does not exist

2023-05-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724680#comment-17724680 ] Jark Wu edited comment on FLINK-31960 at 5/21/23 3:29 PM: -- [~pa

[jira] [Assigned] (FLINK-32142) Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error

2023-05-21 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-32142: - Assignee: Elphas Toringepi > Apple Silicon Support: Unable to Build Flink Project due t

[jira] [Commented] (FLINK-32142) Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error

2023-05-21 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724656#comment-17724656 ] Danny Cranmer commented on FLINK-32142: --- Done > Apple Silicon Support: Unable to

[GitHub] [flink] flinkbot commented on pull request #22614: [FLINK-32142][build][flink-runtime-web] Upgrade frontend-maven-plugin...

2023-05-21 Thread via GitHub
flinkbot commented on PR #22614: URL: https://github.com/apache/flink/pull/22614#issuecomment-1556174049 ## CI report: * 44a185b626a46dd38e1ecdd72a21f303598f582e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-32142) Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error

2023-05-21 Thread Elphas Toringepi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724648#comment-17724648 ] Elphas Toringepi commented on FLINK-32142: -- [~danny.cranmer] could you please a

[jira] [Updated] (FLINK-32142) Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error

2023-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32142: --- Labels: pull-request-available (was: ) > Apple Silicon Support: Unable to Build Flink Proje

[GitHub] [flink] elphastori opened a new pull request, #22614: [FLINK-32142][build][flink-runtime-web] Upgrade frontend-maven-plugin...

2023-05-21 Thread via GitHub
elphastori opened a new pull request, #22614: URL: https://github.com/apache/flink/pull/22614 … to 1.12.1 ## What is the purpose of the change This pull request fixes the build for Apple Silicon which breaks while attempting to run nodejs for flink-runtime-web. The issue is

[jira] [Updated] (FLINK-32142) Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error

2023-05-21 Thread Elphas Toringepi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elphas Toringepi updated FLINK-32142: - Description: Attempting to build the Flink project on Apple Silicon architecture results

[jira] [Updated] (FLINK-32142) Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error

2023-05-21 Thread Elphas Toringepi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elphas Toringepi updated FLINK-32142: - Description: Attempting to build the Flink project on Apple Silicon architecture results

[jira] [Created] (FLINK-32142) Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error

2023-05-21 Thread Elphas Toringepi (Jira)
Elphas Toringepi created FLINK-32142: Summary: Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error Key: FLINK-32142 URL: https://issues.apache.org/jira/browse/FLINK-32142

[jira] [Commented] (FLINK-32047) Fix args in JobSpec not being passed through to Flink in Standalone mode - 1.4.0

2023-05-21 Thread Gil Shmaya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724587#comment-17724587 ] Gil Shmaya commented on FLINK-32047: [~gyfora] [~usamj]  > Fix args in JobSpec not