Re: [PR] [FLINK-30064] Move existing Hive connector code from Flink repo to dedicated Hive repo [flink-connector-hive]

2023-12-01 Thread via GitHub
luoyuxia commented on PR #5: URL: https://github.com/apache/flink-connector-hive/pull/5#issuecomment-1837025511 Cool! @snuyanzin Thanks for the pr. Sorry for the late response for I'm busy with other things. I'll definitely have a look in next week. -- This is an automated message from

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
gyfora commented on PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#issuecomment-1837021377 @mxm i would like to take a look tomorrow or Monday morning because today I’m traveling. -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] [FLINK-33711] Fix numbers of field of the taxi event / Fix broken link [flink-training]

2023-12-01 Thread via GitHub
alpinegizmo merged PR #66: URL: https://github.com/apache/flink-training/pull/66 -- 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:

Re: [PR] [FLINK-33711] Fix numbers of field of the taxi event / Fix broken link [flink-training]

2023-12-01 Thread via GitHub
alpinegizmo commented on PR #66: URL: https://github.com/apache/flink-training/pull/66#issuecomment-1837007643 Thanks for the update! -- 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] [Closed] (FLINK-33698) Fix the backoff time calculation in ExponentialBackoffDelayRetryStrategy

2023-12-01 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-33698. --- Fix Version/s: 1.19.0 Resolution: Fixed fixed in master:

Re: [PR] [FLINK-33698][datastream] Fix the backoff time calculation in ExponentialBackoffDelayRetryStrategy [flink]

2023-12-01 Thread via GitHub
lincoln-lil merged PR #23830: URL: https://github.com/apache/flink/pull/23830 -- 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:

Re: [PR] Add Kafka connector v3.0.2 release [flink-web]

2023-12-01 Thread via GitHub
tzulitai closed pull request #700: Add Kafka connector v3.0.2 release URL: https://github.com/apache/flink-web/pull/700 -- 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

[jira] [Closed] (FLINK-33638) Support variable-length data generation for variable-length data types

2023-12-01 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-33638. --- Resolution: Fixed > Support variable-length data generation for variable-length data types >

[jira] [Updated] (FLINK-33638) Support variable-length data generation for variable-length data types

2023-12-01 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33638: Component/s: (was: Connectors / Common) > Support variable-length data generation for

[jira] [Updated] (FLINK-33638) Support variable-length data generation for variable-length data types

2023-12-01 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33638: Component/s: Table SQL / Ecosystem > Support variable-length data generation for variable-length

[jira] [Commented] (FLINK-33638) Support variable-length data generation for variable-length data types

2023-12-01 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17792277#comment-17792277 ] lincoln lee commented on FLINK-33638: - fixed in master: ac707cfeb24585ec4d68ee3dee22b64e42c454b2 >

[jira] [Updated] (FLINK-33638) Support variable-length data generation for variable-length data types

2023-12-01 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33638: Fix Version/s: 1.19.0 > Support variable-length data generation for variable-length data types >

Re: [PR] [FLINK-33638][table] Support variable-length data generation for variable-length data types [flink]

2023-12-01 Thread via GitHub
lincoln-lil merged PR #23810: URL: https://github.com/apache/flink/pull/23810 -- 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:

Re: [PR] [FLINK-33638][table] Support variable-length data generation for variable-length data types [flink]

2023-12-01 Thread via GitHub
lincoln-lil commented on PR #23810: URL: https://github.com/apache/flink/pull/23810#issuecomment-1836961492 looks good, merging. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-33667] Implement restore tests for MatchRecognize node [flink]

2023-12-01 Thread via GitHub
jnh5y commented on code in PR #23821: URL: https://github.com/apache/flink/pull/23821#discussion_r1412552616 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeTestPrograms.java: ## @@ -0,0 +1,221 @@ +/* + *

[PR] Bump org.opensearch:opensearch from 1.3.0 to 2.11.1 in /flink-connector-opensearch [flink-connector-opensearch]

2023-12-01 Thread via GitHub
dependabot[bot] opened a new pull request, #37: URL: https://github.com/apache/flink-connector-opensearch/pull/37 Bumps [org.opensearch:opensearch](https://github.com/opensearch-project/OpenSearch) from 1.3.0 to 2.11.1. Release notes Sourced from

Re: [PR] [FLINK-33672] Use MapState.entries() instead of keys() and get() in over window [flink]

2023-12-01 Thread via GitHub
flinkbot commented on PR #23855: URL: https://github.com/apache/flink/pull/23855#issuecomment-1836512337 ## CI report: * ef1b449c5654fb6430d486a5e16a00cbe7d93101 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33672) Use MapState.entries() instead of keys() and get() in over window

2023-12-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33672: --- Labels: pull-request-available (was: ) > Use MapState.entries() instead of keys() and

[PR] [FLINK-33672] Use MapState.entries() instead of keys() and get() in over window [flink]

2023-12-01 Thread via GitHub
Zakelly opened a new pull request, #23855: URL: https://github.com/apache/flink/pull/23855 ## What is the purpose of the change This PR replaces any combination of key iteration and getting the value for iterated key from MapState with a entry iteration followed by getKey() and

Re: [PR] [FLINK-33584][Filesystems] Update Hadoop Filesystem dependencies to 3.3.6 [flink]

2023-12-01 Thread via GitHub
snuyanzin commented on code in PR #23844: URL: https://github.com/apache/flink/pull/23844#discussion_r1412350731 ## flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/HadoopS3AccessHelper.java: ## @@ -68,7 +68,7 @@ public

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
afedulov commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412305985 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
mxm commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412287210 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@ -180,13

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
mxm commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412278454 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@ -180,13

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
mxm commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412274565 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@ -137,7

[jira] [Closed] (FLINK-33470) Implement restore tests for Join node

2023-12-01 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-33470. Resolution: Implemented Implemented in

Re: [PR] [FLINK-33470] Implement restore tests for Join node [flink]

2023-12-01 Thread via GitHub
dawidwys merged PR #23680: URL: https://github.com/apache/flink/pull/23680 -- 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] [Closed] (FLINK-32878) Add entropy to gcs path for better scalability

2023-12-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32878. -- Resolution: Fixed > Add entropy to gcs path for better scalability >

[jira] [Commented] (FLINK-32878) Add entropy to gcs path for better scalability

2023-12-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17792115#comment-17792115 ] Martijn Visser commented on FLINK-32878: I reverted this change via

Re: [PR] Clarity And Impact: Revamped Flink Feature Descriptions [flink]

2023-12-01 Thread via GitHub
flinkbot commented on PR #23854: URL: https://github.com/apache/flink/pull/23854#issuecomment-1836316123 ## CI report: * 6fee7e7286b062c51a2153322fab684baadfd813 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33702) Add IncrementalDelayRetryStrategy implementation of RetryStrategy

2023-12-01 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-33702: - Summary: Add IncrementalDelayRetryStrategy implementation of RetryStrategy (was: Add

[jira] [Updated] (FLINK-33702) Add IncrementalDelayRetryStrategy in AsyncRetryStrategies

2023-12-01 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-33702: - Description: RetryStrategy now supports FixedRetryStrategy and

[jira] [Reopened] (FLINK-33702) Add IncrementalDelayRetryStrategy in AsyncRetryStrategies

2023-12-01 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng reopened FLINK-33702: -- `RetryStrategy` in org.apache.flink.util.concurrent can be used in `CollectResultFetcher`. >

Re: [PR] [FLINK-33667] Implement restore tests for MatchRecognize node [flink]

2023-12-01 Thread via GitHub
dawidwys commented on code in PR #23821: URL: https://github.com/apache/flink/pull/23821#discussion_r1412233154 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeTestPrograms.java: ## @@ -0,0 +1,221 @@ +/* + *

[jira] [Reopened] (FLINK-32878) Add entropy to gcs path for better scalability

2023-12-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reopened FLINK-32878: > Add entropy to gcs path for better scalability >

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
1996fanrui commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412210561 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@

Re: [PR] [FLINK-33638][table] Support variable-length data generation for variable-length data types [flink]

2023-12-01 Thread via GitHub
liyubin117 commented on PR #23810: URL: https://github.com/apache/flink/pull/23810#issuecomment-1836237987 @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

Re: [PR] [BP-1.17][FLINK-32815][table] Add HASHCODE function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23184: URL: https://github.com/apache/flink/pull/23184#issuecomment-1836233132 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
gyfora commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412198646 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@

Re: [PR] [BP-1.17][FLINK-32815][table] Add HASHCODE function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23184: [BP-1.17][FLINK-32815][table] Add HASHCODE function. URL: https://github.com/apache/flink/pull/23184 -- 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

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
1996fanrui commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412192687 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@

Re: [PR] [BP1.17][FLINK-32720][table] Add built-in GENERATE_SERIES function [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23190: URL: https://github.com/apache/flink/pull/23190#issuecomment-1836227462 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17][FLINK-32565][table] Support Cast From NUMBER to BYTES [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23189: URL: https://github.com/apache/flink/pull/23189#issuecomment-1836227280 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17][FLINK-32264][table] Add-built-in FIELD-function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23176: [BP-1.17][FLINK-32264][table] Add-built-in FIELD-function. URL: https://github.com/apache/flink/pull/23176 -- 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

Re: [PR] [BP-1.17][FLINK-32564][table] Support Cast From BYTES to NUMBER [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23188: URL: https://github.com/apache/flink/pull/23188#issuecomment-1836227209 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17][FLINK-32264][table] Add-built-in FIELD-function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23176: URL: https://github.com/apache/flink/pull/23176#issuecomment-1836226643 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17][FLINK-32263][table]Add-ELT-function [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23175: URL: https://github.com/apache/flink/pull/23175#issuecomment-1836226568 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17][FLINK-32263][table]Add-ELT-function [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23175: [BP-1.17][FLINK-32263][table]Add-ELT-function URL: https://github.com/apache/flink/pull/23175 -- 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

Re: [PR] [BP-1.17][FLINK-31664][table]Add ARRAY_INTERSECT function [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23186: URL: https://github.com/apache/flink/pull/23186#issuecomment-1836226201 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP1.17][FLINK-32720][table] Add built-in GENERATE_SERIES function [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23190: [BP1.17][FLINK-32720][table] Add built-in GENERATE_SERIES function URL: https://github.com/apache/flink/pull/23190 -- 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

Re: [PR] [BP-1.17][FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23177: [BP-1.17][FLINK-32706][table] Add built-in SPLIT_STRING function URL: https://github.com/apache/flink/pull/23177 -- 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

Re: [PR] [BP-1.17][FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23177: URL: https://github.com/apache/flink/pull/23177#issuecomment-1836227367 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17][FLINK-32565][table] Support Cast From NUMBER to BYTES [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23189: [BP-1.17][FLINK-32565][table] Support Cast From NUMBER to BYTES URL: https://github.com/apache/flink/pull/23189 -- 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

Re: [PR] [BP-1.17][FLINK-32564][table] Support Cast From BYTES to NUMBER [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23188: [BP-1.17][FLINK-32564][table] Support Cast From BYTES to NUMBER URL: https://github.com/apache/flink/pull/23188 -- 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

Re: [PR] [BP-1.17][FLINK-32256][table] Add built-in ARRAY_ MIN function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23151: URL: https://github.com/apache/flink/pull/23151#issuecomment-1836225820 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17][FLINK-32256][table] Add built-in ARRAY_ MIN function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23151: [BP-1.17][FLINK-32256][table] Add built-in ARRAY_ MIN function. URL: https://github.com/apache/flink/pull/23151 -- 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

Re: [PR] [BP-1.17]historgram [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23194: URL: https://github.com/apache/flink/pull/23194#issuecomment-1836225515 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17][FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23144: URL: https://github.com/apache/flink/pull/23144#issuecomment-1836226481 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17][FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23144: [BP-1.17][FLINK-32261][table] Add built-in MAP_UNION function. URL: https://github.com/apache/flink/pull/23144 -- 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

Re: [PR] [BP-1.17][FLINK-31664][table]Add ARRAY_INTERSECT function [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23186: [BP-1.17][FLINK-31664][table]Add ARRAY_INTERSECT function URL: https://github.com/apache/flink/pull/23186 -- 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

Re: [PR] [BP-1.17][FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23185: URL: https://github.com/apache/flink/pull/23185#issuecomment-1836226100 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17][FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23185: [BP-1.17][FLINK-31663][table] Add-ARRAY_EXCEPT-function. URL: https://github.com/apache/flink/pull/23185 -- 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

Re: [PR] [BP-1.17] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23158: URL: https://github.com/apache/flink/pull/23158#issuecomment-1836225967 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23158: [BP-1.17] [FLINK-26948][table] Add-ARRAY_SORT-function. URL: https://github.com/apache/flink/pull/23158 -- 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

Re: [PR] [BP-1.17][FLINK-32257][table] Add built-in ARRAY_MAX function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23149: URL: https://github.com/apache/flink/pull/23149#issuecomment-1836225680 Closing this PR since we don't backport new features into existing releases -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [BP-1.17]historgram [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23194: [BP-1.17]historgram URL: https://github.com/apache/flink/pull/23194 -- 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,

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
mxm commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412183304 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@ -180,13

Re: [PR] [BP-1.17][FLINK-32257][table] Add built-in ARRAY_MAX function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23149: URL: https://github.com/apache/flink/pull/23149#issuecomment-1836221184 Closing since we don't backport new functions into existing releases, only into new ones -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [BP-1.17][FLINK-32257][table] Add built-in ARRAY_MAX function. [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23149: [BP-1.17][FLINK-32257][table] Add built-in ARRAY_MAX function. URL: https://github.com/apache/flink/pull/23149 -- 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

Re: [PR] [BP-1.17][FLINK-31665] [table] Add ARRAY_CONCAT function [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23145: URL: https://github.com/apache/flink/pull/23145#issuecomment-1836220874 Closing since we don't backport new functions into existing releases, only into new ones -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [BP-1.17][FLINK-31665] [table] Add ARRAY_CONCAT function [flink]

2023-12-01 Thread via GitHub
MartijnVisser closed pull request #23145: [BP-1.17][FLINK-31665] [table] Add ARRAY_CONCAT function URL: https://github.com/apache/flink/pull/23145 -- 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

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
mxm commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412176016 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@ -180,13

Re: [PR] [FLINK-33667] Implement restore tests for MatchRecognize node [flink]

2023-12-01 Thread via GitHub
jnh5y commented on code in PR #23821: URL: https://github.com/apache/flink/pull/23821#discussion_r1412167278 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeTestPrograms.java: ## @@ -0,0 +1,221 @@ +/* + *

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
gyfora commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412164693 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
gyfora commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412161793 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@

Re: [PR] [FLINK-33638][table] Support variable-length data generation for variable-length data types [flink]

2023-12-01 Thread via GitHub
liyubin117 commented on code in PR #23810: URL: https://github.com/apache/flink/pull/23810#discussion_r1412149258 ## docs/content.zh/docs/connectors/table/datagen.md: ## @@ -29,51 +29,202 @@ under the License. {{< label "Scan Source: 有界" >}} {{< label "Scan Source: 无界" >}}

Re: [PR] [FLINK-33638][table] Support variable-length data generation for variable-length data types [flink]

2023-12-01 Thread via GitHub
liyubin117 commented on code in PR #23810: URL: https://github.com/apache/flink/pull/23810#discussion_r1412147094 ## docs/content.zh/docs/connectors/table/datagen.md: ## @@ -29,51 +29,202 @@ under the License. {{< label "Scan Source: 有界" >}} {{< label "Scan Source: 无界" >}}

[jira] [Closed] (FLINK-33702) Add IncrementalDelayRetryStrategy in AsyncRetryStrategies

2023-12-01 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng closed FLINK-33702. Resolution: Not A Problem `AsyncRetryStrategy` is designed for AsyncWaitOperator to use. It may

Re: [PR] [FLINK-33638][table] Support variable-length data generation for variable-length data types [flink]

2023-12-01 Thread via GitHub
lincoln-lil commented on code in PR #23810: URL: https://github.com/apache/flink/pull/23810#discussion_r1412107586 ## docs/content.zh/docs/connectors/table/datagen.md: ## @@ -29,51 +29,202 @@ under the License. {{< label "Scan Source: 有界" >}} {{< label "Scan Source: 无界" >}}

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
afedulov commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412106299 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
afedulov commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412106299 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@

Re: [PR] [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
afedulov commented on code in PR #721: URL: https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412106299 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@

Re: [PR] [FLINK-32877]add HTTP options to gcs-cloud-storage client [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23226: URL: https://github.com/apache/flink/pull/23226#issuecomment-1836116534 Also @singhravidutt what's your Jira user name, so I can assign this ticket to you? -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] [FLINK-32877]add HTTP options to gcs-cloud-storage client [flink]

2023-12-01 Thread via GitHub
MartijnVisser commented on PR #23226: URL: https://github.com/apache/flink/pull/23226#issuecomment-1836115444 @singhravidutt Could you please squash your commits and rebase? Your commit message should start `[FLINK-32877][Filesystem]` as well. -- This is an automated message from the

[jira] [Closed] (FLINK-32878) Add entropy to gcs path for better scalability

2023-12-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32878. -- Fix Version/s: 1.19.0 Resolution: Fixed Fixed in apache/flink:master

[jira] [Assigned] (FLINK-32878) Add entropy to gcs path for better scalability

2023-12-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-32878: -- Assignee: Cheena (was: Jayadeep Jayaraman) > Add entropy to gcs path for better

Re: [PR] [FLINK-32878] [FileSystems] Add entropy in temporary object name in flink gcs filesystem [flink]

2023-12-01 Thread via GitHub
MartijnVisser merged PR #23729: URL: https://github.com/apache/flink/pull/23729 -- 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-32878) Add entropy to gcs path for better scalability

2023-12-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-32878: -- Assignee: Jayadeep Jayaraman > Add entropy to gcs path for better scalability >

[jira] [Assigned] (FLINK-33508) Support for wildcard paths in Flink History Server for multi cluster environment

2023-12-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-33508: -- Assignee: Jayadeep Jayaraman > Support for wildcard paths in Flink History Server

Re: [PR] [FLINK-33667] Implement restore tests for MatchRecognize node [flink]

2023-12-01 Thread via GitHub
dawidwys commented on code in PR #23821: URL: https://github.com/apache/flink/pull/23821#discussion_r1412092205 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeTestPrograms.java: ## @@ -0,0 +1,221 @@ +/* + *

[jira] [Commented] (FLINK-33694) GCS filesystem does not respect gs.storage.root.url config option

2023-12-01 Thread Patrick Lucas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17792050#comment-17792050 ] Patrick Lucas commented on FLINK-33694: --- [~martijnvisser] my comment is perhaps not precise, in

Re: [PR] [FLINK-33710] Prevent NOOP spec updates from the autoscaler parallelism override map [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
mxm commented on PR #720: URL: https://github.com/apache/flink-kubernetes-operator/pull/720#issuecomment-1836099166 No harm done @1996fanrui! Thanks for the quick review! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [Flink 31966] Flink Kubernetes operator lacks TLS support [flink-kubernetes-operator]

2023-12-01 Thread via GitHub
tagarr commented on PR #712: URL: https://github.com/apache/flink-kubernetes-operator/pull/712#issuecomment-1836094102 @gaborgsomogyi are my changes what you expected ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] [FLINK-33433][rest] Introduce async-profiler to support profiling Job… [flink]

2023-12-01 Thread via GitHub
Myasuka commented on code in PR #23820: URL: https://github.com/apache/flink/pull/23820#discussion_r1412050762 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/ProfilingService.java: ## @@ -0,0 +1,194 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Commented] (FLINK-32028) Error handling for the new Elasticsearch sink

2023-12-01 Thread Peter Schulz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17792024#comment-17792024 ] Peter Schulz commented on FLINK-32028: -- I gave it [a

Re: [PR] [FLINK-33305] Allow to customize arg line for connector's surefire plugin [flink-connector-shared-utils]

2023-12-01 Thread via GitHub
echauchot commented on code in PR #25: URL: https://github.com/apache/flink-connector-shared-utils/pull/25#discussion_r1412014261 ## pom.xml: ## @@ -558,6 +563,8 @@ under the License. US en

Re: [PR] [FLINK-33305] Allow to customize arg line for connector's surefire plugin [flink-connector-shared-utils]

2023-12-01 Thread via GitHub
echauchot commented on PR #25: URL: https://github.com/apache/flink-connector-shared-utils/pull/25#issuecomment-1835994166 >> @snuyanzin can you elaborate on the use cases you have in mind for systemPropertyVariable surefire.module.config ? > The use case is testing against jdk17/21

[jira] [Updated] (FLINK-32028) Error handling for the new Elasticsearch sink

2023-12-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32028: --- Labels: pull-request-available (was: ) > Error handling for the new Elasticsearch sink >

Re: [PR] [FLINK-32028][connectors/elasticsearch] Allow customising bulk failure handling [flink-connector-elasticsearch]

2023-12-01 Thread via GitHub
boring-cyborg[bot] commented on PR #83: URL: https://github.com/apache/flink-connector-elasticsearch/pull/83#issuecomment-1835980923 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) --

[PR] [FLINK-32028][connectors/elasticsearch] Allow customising bulk failure handling [flink-connector-elasticsearch]

2023-12-01 Thread via GitHub
schulzp opened a new pull request, #83: URL: https://github.com/apache/flink-connector-elasticsearch/pull/83 Extracted `BulkResponseInspector` interface to allow custom handling of (partially) failed bulk requests. If not overridden, default behaviour remains unchanged and partial failures

[jira] [Created] (FLINK-33725) MathUtils.isPowerOf2 does not cover the case of value=0

2023-12-01 Thread Jes Cok (Jira)
Jes Cok created FLINK-33725: --- Summary: MathUtils.isPowerOf2 does not cover the case of value=0 Key: FLINK-33725 URL: https://issues.apache.org/jira/browse/FLINK-33725 Project: Flink Issue Type:

  1   2   >