[GitHub] [flink] lindong28 commented on pull request #22929: [hotfix] Improve error message when config serialization fails

lindong28 commented on PR #22929: URL: https://github.com/apache/flink/pull/22929#issuecomment-1672592059 @becketqin Do you have time to review this PR? -- 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

[jira] [Commented] (FLINK-32824) Port Calcite's fix for the sql like operator

[ https://issues.apache.org/jira/browse/FLINK-32824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752628#comment-17752628 ] lincoln lee commented on FLINK-32824: - [~xu_shuai_] assigned to you. > Port Calcite's fix for the

[jira] [Resolved] (FLINK-32816) Remove the local recovery limitation for adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-32816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32816. - Resolution: Fixed > Remove the local recovery limitation for adaptive scheduler >

[jira] [Updated] (FLINK-32816) Remove the local recovery limitation for adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-32816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32816: Fix Version/s: 1.18.0 > Remove the local recovery limitation for adaptive scheduler >

[jira] [Commented] (FLINK-32816) Remove the local recovery limitation for adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-32816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752621#comment-17752621 ] Rui Fan commented on FLINK-32816: - Merged via dbaab1056f10442de6ca3fd44c61fc10c2892ef9 > Remove the

[jira] [Assigned] (FLINK-32824) Port Calcite's fix for the sql like operator

[ https://issues.apache.org/jira/browse/FLINK-32824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-32824: --- Assignee: Shuai Xu > Port Calcite's fix for the sql like operator >

[jira] [Created] (FLINK-32824) Port Calcite's fix for the sql like operator

lincoln lee created FLINK-32824: --- Summary: Port Calcite's fix for the sql like operator Key: FLINK-32824 URL: https://issues.apache.org/jira/browse/FLINK-32824 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-32824) Port Calcite's fix for the sql like operator

[ https://issues.apache.org/jira/browse/FLINK-32824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752618#comment-17752618 ] Shuai Xu commented on FLINK-32824: -- Hi, lincoln. I‘d like to fix this issue, could you assign it to me?

[GitHub] [flink] WencongLiu commented on a diff in pull request #23058: Remove parameter in RichFunction#open

WencongLiu commented on code in PR #23058: URL: https://github.com/apache/flink/pull/23058#discussion_r1289525904 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/AbstractRowTimeUnboundedPrecedingOver.java: ## @@ -96,7 +96,7 @@

[GitHub] [flink] JunRuiLee commented on pull request #23167: [FLINK-32788][runtime] Support the handling of allocation errors when SpeculativeScheduler schedule speculative tasks by trigger fatal erro

JunRuiLee commented on PR #23167: URL: https://github.com/apache/flink/pull/23167#issuecomment-1672519548 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Commented] (FLINK-32747) Fix ddl operations for catalog from CatalogStore

[ https://issues.apache.org/jira/browse/FLINK-32747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752610#comment-17752610 ] Fang Yong commented on FLINK-32747: --- Fixed with 76554d186ad198384ff783e3e3f040dd738b7571 > Fix ddl

[jira] [Closed] (FLINK-32747) Fix ddl operations for catalog from CatalogStore

[ https://issues.apache.org/jira/browse/FLINK-32747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32747. - Fix Version/s: 1.18.0 Resolution: Fixed > Fix ddl operations for catalog from CatalogStore >

[GitHub] [flink] FangYongs merged pull request #23133: [FLINK-32747][table] Fix ddl operation for catalog which is loaded from CatalogStore

FangYongs merged PR #23133: URL: https://github.com/apache/flink/pull/23133 -- 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] FangYongs commented on pull request #23133: [FLINK-32747][table] Fix ddl operation for catalog which is loaded from CatalogStore

FangYongs commented on PR #23133: URL: https://github.com/apache/flink/pull/23133#issuecomment-1672515492 @leonardBang OK, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] lsyldliu commented on a diff in pull request #23058: Remove parameter in RichFunction#open

lsyldliu commented on code in PR #23058: URL: https://github.com/apache/flink/pull/23058#discussion_r1289501467 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/AbstractRowTimeUnboundedPrecedingOver.java: ## @@ -96,7 +96,7 @@ public

[jira] [Commented] (FLINK-32740) Introduce literal null value for flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-32740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752603#comment-17752603 ] Yao Zhang commented on FLINK-32740: --- After further investigation Configuration only provides one-way

[GitHub] [flink] flinkbot commented on pull request #23190: [BP1.17][FLINK-32720][table] Add built-in GENERATE_SERIES function

flinkbot commented on PR #23190: URL: https://github.com/apache/flink/pull/23190#issuecomment-1672499157 ## CI report: * 3dbc6234bc3a5a26400e717c3c3aeb1686430dbb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23190: [BP1.17][FLINK-32720][table] Add built-in GENERATE_SERIES function

hanyuzheng7 opened a new pull request, #23190: URL: https://github.com/apache/flink/pull/23190 ## What is the purpose of the change This is an implementation of GENERATE_SERIES ## Brief change log Constructs an array of values between start and end, inclusive. Parameters

[jira] [Updated] (FLINK-32812) HBaseRowDataLookupFunction HTable instantiation of thread safety problems

[ https://issues.apache.org/jira/browse/FLINK-32812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32812: --- Labels: pull-request-available security (was: security) > HBaseRowDataLookupFunction

[GitHub] [flink] SunShine-1204 commented on pull request #23170: [FLINK-32812]Fix HBaseRowDataLookupFunction HTable instantiation of thread safety problems

SunShine-1204 commented on PR #23170: URL: https://github.com/apache/flink/pull/23170#issuecomment-1672494032 @zentol @tillrohrmann @StephanEwen @aljoscha -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [flink] JunRuiLee commented on pull request #23187: [FLINK-32823][doc] Update the adaptive scheduler fall back strategy doc for batch jobs

JunRuiLee commented on PR #23187: URL: https://github.com/apache/flink/pull/23187#issuecomment-1672489556 @1996fanrui Thanks for looking into and fix this problem! LGTM! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #23189: [BP-1.17][FLINK-32565][table] Support Cast From NUMBER to BYTES

flinkbot commented on PR #23189: URL: https://github.com/apache/flink/pull/23189#issuecomment-1672479169 ## CI report: * 8d49d911ef188394f030ffd9c567f44da2e93f9f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Closed] (FLINK-32768) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource times out

[ https://issues.apache.org/jira/browse/FLINK-32768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-32768. --- Fix Version/s: 1.18.0 Resolution: Fixed Fixed via 6806f30fe234790f25b5ca83e6d2910286a76aeb >

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23189: [BP-1.17][FLINK-32565][table] Support Cast From NUMBER to BYTES

hanyuzheng7 opened a new pull request, #23189: URL: https://github.com/apache/flink/pull/23189 ### What is the purpose of the change Implement` CAST` from `NUMBER` to `BINARY`/`VARBINART`/`BYTES ` ### Brief change log ` CAST` from `NUMBER` to `BINARY`/`VARBINART`/`BYTES ` for

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23187: [FLINK-32823][doc] Update the adaptive scheduler fall back strategy doc for batch jobs

1996fanrui commented on code in PR #23187: URL: https://github.com/apache/flink/pull/23187#discussion_r1289481433 ## docs/content.zh/docs/deployment/elastic_scaling.md: ## @@ -141,7 +141,7 @@ Adaptive 调度器可以通过[所有在名字包含 `adaptive-scheduler` 的配 ### 局限性 -- **只支持流式

[GitHub] [flink] flinkbot commented on pull request #23188: [BP-1.17][FLINK-32564][table] Support Cast From BYTES to NUMBER

flinkbot commented on PR #23188: URL: https://github.com/apache/flink/pull/23188#issuecomment-1672475445 ## CI report: * ec2410bcc8084d7bc3078a031e822b675bfc7c5e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zhuzhurk closed pull request #23165: [FLINK-32768][runtime] Change ExecutionSlotAllocator#allocateSlotsFor return type to allow the order of execution and assignments to be inconsiste

zhuzhurk closed pull request #23165: [FLINK-32768][runtime] Change ExecutionSlotAllocator#allocateSlotsFor return type to allow the order of execution and assignments to be inconsistent. URL: https://github.com/apache/flink/pull/23165 -- This is an automated message from the Apache Git

[GitHub] [flink] lsyldliu commented on a diff in pull request #23187: [FLINK-32823][doc] Update the adaptive scheduler fall back strategy doc for batch jobs

lsyldliu commented on code in PR #23187: URL: https://github.com/apache/flink/pull/23187#discussion_r1289479342 ## docs/content.zh/docs/deployment/elastic_scaling.md: ## @@ -141,7 +141,7 @@ Adaptive 调度器可以通过[所有在名字包含 `adaptive-scheduler` 的配 ### 局限性 -- **只支持流式 Job**：Adaptive

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23188: [BP-1.17][FLINK-32564][table] Support Cast From BYTES to NUMBER

hanyuzheng7 opened a new pull request, #23188: URL: https://github.com/apache/flink/pull/23188 ### What is the purpose of the change Implement` CAST` from `BINARY`/`VARBINART`/`BYTES `to `NUMBER` ### Brief change log ` CAST` from `BINARY`/`VARBINART`/`BYTES `to `NUMBER` for

[GitHub] [flink] flinkbot commented on pull request #23187: [FLINK-32823][doc] Update the adaptive scheduler fall back strategy doc for batch jobs

flinkbot commented on PR #23187: URL: https://github.com/apache/flink/pull/23187#issuecomment-1672471690 ## CI report: * e63ef3f91b8bbbefe8ea02c47a66b8b3a3f71668 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #23186: [BP-1.17][FLINK-31664][table]Add ARRAY_INTERSECT function

flinkbot commented on PR #23186: URL: https://github.com/apache/flink/pull/23186#issuecomment-1672468071 ## CI report: * f124ada7434896f42cd490676c9833519b45d5ce UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32823) Update the adaptive scheduler doc about batch job limitation

[ https://issues.apache.org/jira/browse/FLINK-32823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32823: --- Labels: pull-request-available (was: ) > Update the adaptive scheduler doc about batch job

[GitHub] [flink] 1996fanrui opened a new pull request, #23187: [FLINK-32823][doc] Update the adaptive scheduler fall back strategy doc for batch jobs

1996fanrui opened a new pull request, #23187: URL: https://github.com/apache/flink/pull/23187 ## What is the purpose of the change [FLINK-30846](https://issues.apache.org/jira/browse/FLINK-30846) [1] updated the fall back strategy from default Scheduler to AdaptiveBatch Scheduler

[jira] [Closed] (FLINK-32819) flink can not parse the param `#` correctly in k8s application mode

[ https://issues.apache.org/jira/browse/FLINK-32819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-32819. -- Fix Version/s: (was: 1.18.0) Resolution: Duplicate > flink can not parse the param `#`

[jira] [Updated] (FLINK-32823) Update the adaptive scheduler doc about batch job limitation

[ https://issues.apache.org/jira/browse/FLINK-32823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32823: Description: FLINK-30846 [1] updated the fall back strategy from default Scheduler to AdaptiveBatch

[jira] [Updated] (FLINK-32823) Update the adaptive scheduler doc about batch job limitation

[ https://issues.apache.org/jira/browse/FLINK-32823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32823: Attachment: screenshot-1.png > Update the adaptive scheduler doc about batch job limitation >

[jira] [Created] (FLINK-32823) Update the adaptive scheduler doc about batch job limitation

Rui Fan created FLINK-32823: --- Summary: Update the adaptive scheduler doc about batch job limitation Key: FLINK-32823 URL: https://issues.apache.org/jira/browse/FLINK-32823 Project: Flink Issue

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23186: [BP-1.17][FLINK-31664][table]Add ARRAY_INTERSECT function

hanyuzheng7 opened a new pull request, #23186: URL: https://github.com/apache/flink/pull/23186 ## What is the purpose of the change This is an implementation of ARRAY_INTERSECT function Returns an array of the elements in the intersection of array1 and array2, without duplicates.

[jira] [Commented] (FLINK-32819) flink can not parse the param `#` correctly in k8s application mode

[ https://issues.apache.org/jira/browse/FLINK-32819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752587#comment-17752587 ] Junrui Li commented on FLINK-32819: --- This issue duplicates FLINK-27299 and also should be subsumed by

[GitHub] [flink] flinkbot commented on pull request #23185: [BP-1.17][FLINK-31663][table] Add-ARRAY_EXCEPT-function.

flinkbot commented on PR #23185: URL: https://github.com/apache/flink/pull/23185#issuecomment-1672445728 ## CI report: * 722f2ec5cd9b82844e08ad206cdb5ae8642d9681 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23185: [BP-1.17][FLINK-31663][table] Add-ARRAY_EXCEPT-function.

hanyuzheng7 opened a new pull request, #23185: URL: https://github.com/apache/flink/pull/23185 ## What is the purpose of the change This is an implementation of ARRAY_EXCEPT function ARRAY_EXCEPT(array1, array2) - Returns an array of the elements in array1 but not in array2, without

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1289452304 ## flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStoreFileOperationsTest.java: ## @@ -116,46 +123,80 @@ public void

[jira] [Commented] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752579#comment-17752579 ] Yangze Guo commented on FLINK-15959: [~xiangyu0xf] I think it will benefit the OLAP users. Assigned

[jira] [Assigned] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-15959: -- Assignee: xiangyu feng > Add min number of slots configuration to limit total number of

[jira] [Closed] (FLINK-32764) SlotManager supports pulling up all TaskManagers at initialization

[ https://issues.apache.org/jira/browse/FLINK-32764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-32764. -- Resolution: Duplicate > SlotManager supports pulling up all TaskManagers at initialization >

[jira] [Updated] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15959: --- Priority: Major (was: Not a Priority) > Add min number of slots configuration to limit total

[jira] [Updated] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15959: --- Parent: FLINK-25318 Issue Type: Sub-task (was: Improvement) > Add min number of slots

[jira] [Commented] (FLINK-32760) Version Conflict in flink-sql-connector-hive for shaded.parquet prefix packages

[ https://issues.apache.org/jira/browse/FLINK-32760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752577#comment-17752577 ] dongwoo.kim commented on FLINK-32760: - Hi [~luoyuxia], I have opened the pr.  I'd greatly appreciate

[GitHub] [flink] dongwoo6kim commented on a diff in pull request #23166: [FLINK-32760][Connectors/Hive] Reshade parquet in flink-sql-connector-hive

dongwoo6kim commented on code in PR #23166: URL: https://github.com/apache/flink/pull/23166#discussion_r1289443353 ## flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml: ## @@ -223,6 +223,10 @@ under the License.

[jira] [Updated] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks

[ https://issues.apache.org/jira/browse/FLINK-25447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-25447: -- Fix Version/s: 1.17.2 1.19.0 > batch query cannot generate plan when a

[jira] [Commented] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks

[ https://issues.apache.org/jira/browse/FLINK-25447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752573#comment-17752573 ] Shengkai Fang commented on FLINK-25447: --- Merged into master:

[GitHub] [flink] fsk119 merged pull request #20822: [FLINK-25447][table-planner] Fix batch query cannot generate plan when a sorted view into multi sinks

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

[jira] [Assigned] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-32821: Assignee: Zhanghao Chen > Streaming examples failed to execute due to error in packaging

[jira] [Commented] (FLINK-32820) ParameterTool is mistakenly marked as deprecated

[ https://issues.apache.org/jira/browse/FLINK-32820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752567#comment-17752567 ] Xintong Song commented on FLINK-32820: -- And thanks for volunteering. You are assigned. Please go

[jira] [Assigned] (FLINK-32820) ParameterTool is mistakenly marked as deprecated

[ https://issues.apache.org/jira/browse/FLINK-32820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-32820: Assignee: Zhanghao Chen > ParameterTool is mistakenly marked as deprecated >

[jira] [Commented] (FLINK-32820) ParameterTool is mistakenly marked as deprecated

[ https://issues.apache.org/jira/browse/FLINK-32820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752566#comment-17752566 ] Xintong Song commented on FLINK-32820: -- [~Zhanghao Chen], thanks for reporting this. I wasn't aware

[jira] [Resolved] (FLINK-31874) Support truncate table statement in batch mode

[ https://issues.apache.org/jira/browse/FLINK-31874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-31874. -- Resolution: Fixed > Support truncate table statement in batch mode >

[jira] [Resolved] (FLINK-32287) Add doc for truncate table statement

[ https://issues.apache.org/jira/browse/FLINK-32287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-32287. -- Fix Version/s: 1.18.0 Resolution: Fixed 2eb88b4115f0a4df9290b6f0c81bf18b41cd594a > Add doc

[GitHub] [flink] luoyuxia merged pull request #23046: [FLINK-32287][docs] Add doc for truncate table statement

luoyuxia merged PR #23046: URL: https://github.com/apache/flink/pull/23046 -- 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] venkata91 commented on pull request #23164: [FLINK- 32775]Add parent dir of files to classpath using yarn.provided.lib.dirs

venkata91 commented on PR #23164: URL: https://github.com/apache/flink/pull/23164#issuecomment-1672162309 > > @architgyl Could you please clarify the description a bit? It is not quite clear why it doesn't for `hive-site.xml` alone. > > Updated the description. In this case,

[GitHub] [flink] flinkbot commented on pull request #23184: [BP-1.17][FLINK-32815][table] Add HASHCODE function.

flinkbot commented on PR #23184: URL: https://github.com/apache/flink/pull/23184#issuecomment-1672090531 ## CI report: * f62252dca6af19e122953ca24e5570083e5076b1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23184: [BP-1.17][FLINK-32815][table] Add HASHCODE function.

hanyuzheng7 opened a new pull request, #23184: URL: https://github.com/apache/flink/pull/23184 ## What is the purpose of the change The hashcode function generates a hash code for a given input value, including support for computing hash values of binary data types. It creates a unique

[GitHub] [flink] architgyl commented on pull request #23164: [FLINK- 32775]Add parent dir of files to classpath using yarn.provided.lib.dirs

architgyl commented on PR #23164: URL: https://github.com/apache/flink/pull/23164#issuecomment-1671986387 > @architgyl Could you please clarify the description a bit? It is not quite clear why it doesn't for `hive-site.xml` alone. Updated the description. -- This is an automated

[GitHub] [flink] venkata91 commented on pull request #23164: [FLINK- 32775]Add parent dir of files to classpath using yarn.provided.lib.dirs

venkata91 commented on PR #23164: URL: https://github.com/apache/flink/pull/23164#issuecomment-1671934870 @architgyl Could you please clarify the description a bit? It is not quite clear why it doesn't for `hive-site.xml` alone. -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-32822) Add connector option to control whether to enable auto-commit of offsets when checkpoints is enabled

[ https://issues.apache.org/jira/browse/FLINK-32822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752494#comment-17752494 ] Mason Chen commented on FLINK-32822: This auto-commit is disabled for conscious reasons as it would

[jira] [Commented] (FLINK-32814) Support disabling failed JM shutdown in the operator

[ https://issues.apache.org/jira/browse/FLINK-32814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752493#comment-17752493 ] Yaroslav Tkachenko commented on FLINK-32814: It's your call :) It is a niche feature indeed

[jira] [Updated] (FLINK-32822) Add connector option to control whether to enable auto-commit of offsets when checkpoints is enabled

[ https://issues.apache.org/jira/browse/FLINK-32822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-32822: -- Description: When checkpointing is enabled, Flink Kafka connector commits the current

[jira] [Created] (FLINK-32822) Add connector option to control whether to enable auto-commit of offsets when checkpoints is enabled

Zhanghao Chen created FLINK-32822: - Summary: Add connector option to control whether to enable auto-commit of offsets when checkpoints is enabled Key: FLINK-32822 URL:

[GitHub] [flink] X-czh commented on pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

X-czh commented on PR #20232: URL: https://github.com/apache/flink/pull/20232#issuecomment-1671770972 @huwh Could you help review it again when you are free? Much appreciated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-32820) ParameterTool is mistakenly marked as deprecated

[ https://issues.apache.org/jira/browse/FLINK-32820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-32820: -- Issue Type: Bug (was: Improvement) > ParameterTool is mistakenly marked as deprecated >

[jira] [Updated] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-32821: -- Issue Type: Bug (was: Improvement) > Streaming examples failed to execute due to error in

[jira] [Commented] (FLINK-32820) ParameterTool is mistakenly marked as deprecated

[ https://issues.apache.org/jira/browse/FLINK-32820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752472#comment-17752472 ] Zhanghao Chen commented on FLINK-32820: --- This is also related to the fix of [FLINK-32821]

[jira] [Created] (FLINK-32821) Streaming examples failed to execute due to error in packaging

Zhanghao Chen created FLINK-32821: - Summary: Streaming examples failed to execute due to error in packaging Key: FLINK-32821 URL: https://issues.apache.org/jira/browse/FLINK-32821 Project: Flink

[jira] [Created] (FLINK-32820) ParameterTool is mistakenly marked as deprecated

Zhanghao Chen created FLINK-32820: - Summary: ParameterTool is mistakenly marked as deprecated Key: FLINK-32820 URL: https://issues.apache.org/jira/browse/FLINK-32820 Project: Flink Issue

[GitHub] [flink] XComp commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

XComp commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1288764461 ## flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStoreFileOperationsTest.java: ## @@ -116,46 +123,80 @@ public void

[jira] [Closed] (FLINK-32774) Reconciliation for autoscaling overrides gets stuck after cancel-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-32774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32774. -- Fix Version/s: kubernetes-operator-1.7.0 Assignee: Gyula Fora (was: Maximilian Michels)

[GitHub] [flink] XComp commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

XComp commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1284435068 ## flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractThreadsafeJobResultStore.java: ## @@ -43,66 +46,92 @@ public abstract class

[jira] [Assigned] (FLINK-32811) Add port range support for taskmanager.data.bind-port

[ https://issues.apache.org/jira/browse/FLINK-32811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-32811: -- Assignee: Ferenc Csaky > Add port range support for taskmanager.data.bind-port >

[jira] [Comment Edited] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP

[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752444#comment-17752444 ] Matthias Pohl edited comment on FLINK-32751 at 8/9/23 3:13 PM: --- I checked

[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP

[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752444#comment-17752444 ] Matthias Pohl commented on FLINK-32751: --- I checked whether {{Socket#connect}} (see

[GitHub] [flink] Aitozi commented on pull request #23107: [FLINK-32711][planner] Fix the type mismatch when proctime() used as …

Aitozi commented on PR #23107: URL: https://github.com/apache/flink/pull/23107#issuecomment-1671538711 Hi, @dawidwys @twalthr Could you help review this fix ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on pull request #23183: [FLINK-32811][runtime] Add port range support for "taskmanager.data.bind-port"

flinkbot commented on PR #23183: URL: https://github.com/apache/flink/pull/23183#issuecomment-1671488638 ## CI report: * 60a91779e40859940047c1cfded364c0ff56d781 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32811) Add port range support for taskmanager.data.bind-port

[ https://issues.apache.org/jira/browse/FLINK-32811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32811: --- Labels: pull-request-available (was: ) > Add port range support for

[GitHub] [flink] ferenc-csaky opened a new pull request, #23183: [FLINK-32811][runtime] Add port range support for "taskmanager.data.bind-port"

ferenc-csaky opened a new pull request, #23183: URL: https://github.com/apache/flink/pull/23183 ## What is the purpose of the change Adds port range support for `taskmanager.data.bind-port`, which can be helpful in a restrictive network setup. ## Brief change log -

[GitHub] [flink] hanyuzheng7 commented on pull request #23098: [BP-1.17][FLINK-32262] Add MAP_ENTRIES support

hanyuzheng7 commented on PR #23098: URL: https://github.com/apache/flink/pull/23098#issuecomment-1671389766 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] hanyuzheng7 commented on pull request #23151: [BP-1.17][FLINK-32256][table] Add built-in ARRAY_ MIN function.

hanyuzheng7 commented on PR #23151: URL: https://github.com/apache/flink/pull/23151#issuecomment-1671385062 @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] [Updated] (FLINK-32815) Add HASHCODE support in Table API

[ https://issues.apache.org/jira/browse/FLINK-32815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32815: Description: *This is an implementation of HASHCODE internal function* The {{hashcode}} function

[jira] [Updated] (FLINK-32815) Add HASHCODE support in Table API

[ https://issues.apache.org/jira/browse/FLINK-32815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32815: Summary: Add HASHCODE support in Table API (was: Add HASHCODE support in SQL & Table API) > Add

[jira] [Commented] (FLINK-32815) Add HASHCODE support in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-32815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752419#comment-17752419 ] Hanyu Zheng commented on FLINK-32815: - [~twalthr] Ok, I will change it to internal function. > Add

[jira] [Created] (FLINK-32819) flink can not parse the param `#` correctly in k8s application mode

Jun Zhang created FLINK-32819: - Summary: flink can not parse the param `#` correctly in k8s application mode Key: FLINK-32819 URL: https://issues.apache.org/jira/browse/FLINK-32819 Project: Flink

[GitHub] [flink] ferenc-csaky closed pull request #21195: [IN_PROGRESS] Remove "flink-sql-parser-hive" from "flink-table"

ferenc-csaky closed pull request #21195: [IN_PROGRESS] Remove "flink-sql-parser-hive" from "flink-table" URL: https://github.com/apache/flink/pull/21195 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23063: [FLINK-32660][table] Introduce external FS compatible FileCatalogStore implementation

ferenc-csaky commented on code in PR #23063: URL: https://github.com/apache/flink/pull/23063#discussion_r1288436597 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FileCatalogStore.java: ## @@ -97,25 +114,29 @@ public void storeCatalog(String

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #649: [backport][FLINK-32774] Improve checking for already upgraded deployments

gyfora opened a new pull request, #649: URL: https://github.com/apache/flink-kubernetes-operator/pull/649 ## What is the purpose of the change *(For example: This pull request adds a new feature to periodically create and maintain savepoints through the `FlinkDeployment`

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23063: [FLINK-32660][table] Introduce external FS compatible FileCatalogStore implementation

ferenc-csaky commented on code in PR #23063: URL: https://github.com/apache/flink/pull/23063#discussion_r1288436597 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FileCatalogStore.java: ## @@ -97,25 +114,29 @@ public void storeCatalog(String

[GitHub] [flink] luoyuxia commented on a diff in pull request #23116: [FLINK-32581][docs] Add docs for atomic CTAS and RTAS

luoyuxia commented on code in PR #23116: URL: https://github.com/apache/flink/pull/23116#discussion_r1288417299 ## docs/content/docs/dev/table/sourcesSinks.md: ## @@ -344,6 +344,11 @@ that a sink can still work on common data structures and perform a conversion at and

[jira] [Comment Edited] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP

[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752373#comment-17752373 ] Matthias Pohl edited comment on FLINK-32751 at 8/9/23 11:51 AM: I played

[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP

[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752393#comment-17752393 ] Matthias Pohl commented on FLINK-32751: --- Some other findings: * The thread dump doesn't contain

[jira] [Updated] (FLINK-32817) Supports running jar file names with Spaces

[ https://issues.apache.org/jira/browse/FLINK-32817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xianxun Ye updated FLINK-32817: --- Description: When submitting a flink jar to a yarn cluster, if the jar filename has spaces in it,

[jira] [Comment Edited] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP

[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752373#comment-17752373 ] Matthias Pohl edited comment on FLINK-32751 at 8/9/23 11:21 AM: I played

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23108: [FLINK-32706][table] Add built-in SPLIT_STRING function

ferenc-csaky commented on code in PR #23108: URL: https://github.com/apache/flink/pull/23108#discussion_r1288332845 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/SplitFunction.java: ## @@ -0,0 +1,82 @@ +/* + * Licensed to the

  1   2   >