Re: [PR] [FLINK-33704][BP 1.18][Filesytems] Update GCS filesystems to latest available versions [flink]

2023-12-18 Thread via GitHub
MartijnVisser commented on PR #23935: URL: https://github.com/apache/flink/pull/23935#issuecomment-1859729348 > Shall be #23837 Indeed, thanks for that! -- 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

Re: [PR] [FLINK-33704][BP 1.18][Filesytems] Update GCS filesystems to latest available versions [flink]

2023-12-18 Thread via GitHub
MartijnVisser merged PR #23935: URL: https://github.com/apache/flink/pull/23935 -- 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

[jira] [Updated] (FLINK-33704) Update GCS filesystems to latest available versions

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33704: --- Fix Version/s: 1.18.1 > Update GCS filesystems to latest available versions > --

[jira] [Reopened] (FLINK-33704) Update GCS filesystems to latest available versions

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reopened FLINK-33704: > Update GCS filesystems to latest available versions > --

Re: [PR] [FLINK-33603][1.18][Filesystem] Bundle Guava for GCS connector [flink]

2023-12-18 Thread via GitHub
MartijnVisser closed pull request #23920: [FLINK-33603][1.18][Filesystem] Bundle Guava for GCS connector URL: https://github.com/apache/flink/pull/23920 -- 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] [FLINK-33603][1.18][Filesystem] Bundle Guava for GCS connector [flink]

2023-12-18 Thread via GitHub
MartijnVisser commented on PR #23920: URL: https://github.com/apache/flink/pull/23920#issuecomment-1859733229 Superseded by https://issues.apache.org/jira/browse/FLINK-33704 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [ FLINK-33603][FileSystems] shade guava in gs-fs filesystem [flink]

2023-12-18 Thread via GitHub
MartijnVisser commented on PR #23489: URL: https://github.com/apache/flink/pull/23489#issuecomment-1859734539 Superseded by https://issues.apache.org/jira/browse/FLINK-33704 - Thanks for the help/thinking on this @singhravidutt @singhravidutt @cnauroth Do you have any bandwidth to ad

Re: [PR] [ FLINK-33603][FileSystems] shade guava in gs-fs filesystem [flink]

2023-12-18 Thread via GitHub
MartijnVisser closed pull request #23489: [ FLINK-33603][FileSystems] shade guava in gs-fs filesystem URL: https://github.com/apache/flink/pull/23489 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798044#comment-17798044 ] Martijn Visser commented on FLINK-25509: [~ruanhang1993] [~lindong] Both the {{v

[PR] Reduce getTable call for hive client and optimize graph generation time [flink]

2023-12-18 Thread via GitHub
hehuiyuan opened a new pull request, #23945: URL: https://github.com/apache/flink/pull/23945 ## What is the purpose of the change HiveCatalog.getHiveTable method wastes a lot of time when generate graph, because the number of calls is relatively high. I have an sql tas

Re: [PR] [FLINK-21949][table] Support ARRAY_AGG aggregate function [flink]

2023-12-18 Thread via GitHub
Jiabao-Sun commented on PR #23411: URL: https://github.com/apache/flink/pull/23411#issuecomment-1859780440 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

[jira] [Created] (FLINK-33871) Reduce getTable call for hive client and optimize graph generation time

2023-12-18 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-33871: - Summary: Reduce getTable call for hive client and optimize graph generation time Key: FLINK-33871 URL: https://issues.apache.org/jira/browse/FLINK-33871 Project: Flink

[jira] [Updated] (FLINK-33871) Reduce getTable call for hive client and optimize graph generation time

2023-12-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33871: --- Labels: pull-request-available (was: ) > Reduce getTable call for hive client and optimize

Re: [PR] [FLINK-33871][HIVE]Reduce getTable call for hive client and optimize graph generation time [flink]

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

Re: [PR] [FLINK-31650][metrics][rest] Remove transient metrics for subtasks in terminal state [flink]

2023-12-18 Thread via GitHub
JunRuiLee commented on code in PR #23447: URL: https://github.com/apache/flink/pull/23447#discussion_r1429717030 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java: ## @@ -126,9 +140,14 @@ public synchronized void updateCurrentE

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

2023-12-18 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798047#comment-17798047 ] Dong Lin commented on FLINK-25509: -- [~martijnvisser] Just to make sure that I understan

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798066#comment-17798066 ] Martijn Visser commented on FLINK-25509: [~lindong] Yes, that's what I suggest.

Re: [PR] [FLINK-31650][metrics][rest] Remove transient metrics for subtasks in terminal state [flink]

2023-12-18 Thread via GitHub
X-czh commented on code in PR #23447: URL: https://github.com/apache/flink/pull/23447#discussion_r1429759033 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java: ## @@ -126,9 +140,14 @@ public synchronized void updateCurrentExecu

Re: [PR] test request [flink]

2023-12-18 Thread via GitHub
singhravidutt closed pull request #23933: test request URL: https://github.com/apache/flink/pull/23933 -- 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: i

Re: [PR] [FLINK-33632] Adding custom flink mutator [flink-kubernetes-operator]

2023-12-18 Thread via GitHub
AncyRominus commented on code in PR #733: URL: https://github.com/apache/flink-kubernetes-operator/pull/733#discussion_r1429764133 ## flink-kubernetes-webhook/pom.xml: ## @@ -127,6 +132,11 @@ under the License. +

[jira] [Commented] (FLINK-15571) Create a Redis Streams Connector for Flink

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798078#comment-17798078 ] Martijn Visser commented on FLINK-15571: [~jinsuichen] If there were volunteerin

Re: [PR] [FLINK-33632] Adding custom flink mutator [flink-kubernetes-operator]

2023-12-18 Thread via GitHub
AncyRominus commented on code in PR #733: URL: https://github.com/apache/flink-kubernetes-operator/pull/733#discussion_r1429772463 ## flink-kubernetes-operator/pom.xml: ## @@ -208,6 +208,18 @@ under the License. junit-jupiter-params test + +

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

2023-12-18 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798080#comment-17798080 ] Dong Lin commented on FLINK-25509: -- [~martijnvisser] Cool. I totally agree with your su

Re: [PR] [FLINK-33632] Adding custom flink mutator [flink-kubernetes-operator]

2023-12-18 Thread via GitHub
AncyRominus commented on PR #733: URL: https://github.com/apache/flink-kubernetes-operator/pull/733#issuecomment-1859901718 Thanks for the comments @tagarr and @gyfora !!! The modify labels are set in FlinkMutator.java and the other mutator changes (if any) be added to the default or th

Re: [PR] [FLINK-31481][table] Support enhanced show databases syntax [flink]

2023-12-18 Thread via GitHub
jeyhunkarimov commented on PR #23612: URL: https://github.com/apache/flink/pull/23612#issuecomment-1859901892 Hi @jnh5y could you please check if your comments are addressed? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Updated] (FLINK-31049) Add support for Kafka record headers to KafkaSink

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31049: --- Fix Version/s: kafka-3.1.0 > Add support for Kafka record headers to KafkaSink > ---

[jira] [Commented] (FLINK-31049) Add support for Kafka record headers to KafkaSink

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798082#comment-17798082 ] Martijn Visser commented on FLINK-31049: Merged by [~tzulitai] in apache/flink-c

[jira] [Commented] (FLINK-33819) Support setting CompressType in RocksDBStateBackend

2023-12-18 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798083#comment-17798083 ] Yue Ma commented on FLINK-33819: [~masteryhx] Thanks for replying. {quote}Linked FLINK-2

[jira] [Closed] (FLINK-31049) Add support for Kafka record headers to KafkaSink

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31049. -- Resolution: Fixed > Add support for Kafka record headers to KafkaSink > --

[jira] [Updated] (FLINK-33153) Kafka using latest-offset maybe missing data

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33153: --- Affects Version/s: (was: kafka-4.1.0) > Kafka using latest-offset maybe missing data > -

Re: [PR] [FLINK-31650][metrics][rest] Remove transient metrics for subtasks in terminal state [flink]

2023-12-18 Thread via GitHub
JunRuiLee commented on code in PR #23447: URL: https://github.com/apache/flink/pull/23447#discussion_r1429785675 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java: ## @@ -126,9 +140,14 @@ public synchronized void updateCurrentE

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-12-18 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798091#comment-17798091 ] david radley commented on FLINK-33365: -- [~libenchao] [~Sergey Nuyanzin] Bringing ba

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798092#comment-17798092 ] Sergey Nuyanzin commented on FLINK-22765: - https://dev.azure.com/apache-flink/ap

Re: [PR] [FLINK-30593][autoscaler] Improve restart time tracking [flink-kubernetes-operator]

2023-12-18 Thread via GitHub
mxm commented on code in PR #735: URL: https://github.com/apache/flink-kubernetes-operator/pull/735#discussion_r1429815765 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -182,22 +182,22 @@ private void runScalingLogic(Context ctx, A

Re: [PR] [FLINK-30593][autoscaler] Improve restart time tracking [flink-kubernetes-operator]

2023-12-18 Thread via GitHub
mxm commented on code in PR #735: URL: https://github.com/apache/flink-kubernetes-operator/pull/735#discussion_r1429815765 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -182,22 +182,22 @@ private void runScalingLogic(Context ctx, A

Re: [PR] [FLINK-30593][autoscaler] Improve restart time tracking [flink-kubernetes-operator]

2023-12-18 Thread via GitHub
mxm commented on PR #735: URL: https://github.com/apache/flink-kubernetes-operator/pull/735#issuecomment-1859964401 This needs a rebase. I'll run the tests afterwards. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[jira] [Commented] (FLINK-33706) Build_wheels_on_macos fails on AZP

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798093#comment-17798093 ] Sergey Nuyanzin commented on FLINK-33706: - https://dev.azure.com/apache-flink/ap

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798094#comment-17798094 ] Sergey Nuyanzin commented on FLINK-31472: - https://dev.azure.com/apache-flink/ap

[jira] [Updated] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-31472: Description: when run mvn clean test, this case failed occasionally. {noformat} [ERROR] Te

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798095#comment-17798095 ] Sergey Nuyanzin commented on FLINK-22765: - https://dev.azure.com/apache-flink/ap

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798096#comment-17798096 ] Sergey Nuyanzin commented on FLINK-31472: - https://dev.azure.com/apache-flink/ap

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

2023-12-18 Thread via GitHub
mxm commented on code in PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1426756716 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/AutoScalerUtils.java: ## @@ -94,4 +99,106 @@ public static boolean excludeVerticesFromS

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798098#comment-17798098 ] Sergey Nuyanzin commented on FLINK-32523: - https://dev.azure.com/apache-flink/ap

[jira] [Comment Edited] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798098#comment-17798098 ] Sergey Nuyanzin edited comment on FLINK-32523 at 12/18/23 9:59 AM: ---

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

2023-12-18 Thread via GitHub
mxm commented on code in PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1429838068 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java: ## @@ -143,7 +145,11 @@ public CollectedMetricHistory updateMetr

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

2023-12-18 Thread via GitHub
mxm commented on PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#issuecomment-1859986239 Thanks @flashJd! Changes look great. -- 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] [FLINK-32877][Filesystem]add HTTP options to gcs-cloud-storage client [flink]

2023-12-18 Thread via GitHub
singhravidutt commented on PR #23226: URL: https://github.com/apache/flink/pull/23226#issuecomment-1859988955 > Also @singhravidutt what's your Jira user name, so I can assign this ticket to you? I don't have a Jira account. @cnauroth can you take the ownership of jira ticket? --

[jira] [Commented] (FLINK-33449) Support array_contains_seq function

2023-12-18 Thread leo cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798100#comment-17798100 ] leo cheng commented on FLINK-33449: --- Hi [~xuyangzhong] Thank you Pls do it. > Suppor

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2023-12-18 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798101#comment-17798101 ] Ahmed Hamdy commented on FLINK-31472: - hi [~Sergey Nuyanzin] could you assign me the

[jira] [Commented] (FLINK-33858) CI fails with No space left on device

2023-12-18 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798102#comment-17798102 ] Jing Ge commented on FLINK-33858: - Does anyone know if we could just delete /home/agent

[jira] [Comment Edited] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798105#comment-17798105 ] Sergey Nuyanzin edited comment on FLINK-33365 at 12/18/23 10:25 AM: --

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798105#comment-17798105 ] Sergey Nuyanzin commented on FLINK-33365: - Since 1. predicate push down from on

[jira] [Commented] (FLINK-33858) CI fails with No space left on device

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798108#comment-17798108 ] Sergey Nuyanzin commented on FLINK-33858: - zip would be the safest otherwise if

[jira] [Commented] (FLINK-33704) Update GCS filesystems to latest available versions

2023-12-18 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798109#comment-17798109 ] Jing Ge commented on FLINK-33704: - Thanks [~martijnvisser] for fixing it! Can we resolve

[jira] [Assigned] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-31472: --- Assignee: Ahmed Hamdy > AsyncSinkWriterThrottlingTest failed with Illegal mailbox t

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2023-12-18 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798112#comment-17798112 ] Sergey Nuyanzin commented on FLINK-31472: - [~chalixar], thanks for volunteering,

Re: [PR] [FLINK-33588][Flink-Runtime] Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics [flink]

2023-12-18 Thread via GitHub
JingGe merged PR #23931: URL: https://github.com/apache/flink/pull/23931 -- 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

[jira] [Commented] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-18 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798114#comment-17798114 ] Jing Ge commented on FLINK-33588: - master: 5e1deeea19c2e73f3bc6f1f9881a778d13abf6a4 > F

[jira] [Updated] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2023-12-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31472: --- Labels: pull-request-available test-stability (was: test-stability) > AsyncSinkWriterThrott

[PR] [FLINK-31472][Connectors/Base] Update AsyncSink Throttling test to use concurrent mailbox [flink]

2023-12-18 Thread via GitHub
vahmed-hamdy opened a new pull request, #23946: URL: https://github.com/apache/flink/pull/23946 ## What is the purpose of the change This pull request updates `AsyncSinkThrottlingTest` to use concurrent `TestSinkInitContextAnyThreadMailbox` due the concurrent nature of the

[jira] [Commented] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-18 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798115#comment-17798115 ] Jing Ge commented on FLINK-33588: - [~zhutong66] could you please cp the change to 1.18?

Re: [PR] [FLINK-31472][Connectors/Base] Update AsyncSink Throttling test to use concurrent mailbox [flink]

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

[jira] [Commented] (FLINK-33704) Update GCS filesystems to latest available versions

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798124#comment-17798124 ] Martijn Visser commented on FLINK-33704: [~jingge] I'm trying to confirm if this

[jira] [Commented] (FLINK-33704) Update GCS filesystems to latest available versions

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798126#comment-17798126 ] Martijn Visser commented on FLINK-33704: [~jingge] Closing this issue, it doesn'

[jira] [Updated] (FLINK-33704) Update GCS filesystems to latest available versions

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33704: --- Attachment: screenshot-1.png > Update GCS filesystems to latest available versions > ---

[jira] [Closed] (FLINK-33603) Fix guava shading for GCS connector

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33603. -- Resolution: Resolved FLINK-33704 > Fix guava shading for GCS connector >

[jira] [Comment Edited] (FLINK-33704) Update GCS filesystems to latest available versions

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798126#comment-17798126 ] Martijn Visser edited comment on FLINK-33704 at 12/18/23 10:48 AM: ---

[jira] [Closed] (FLINK-33704) Update GCS filesystems to latest available versions

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33704. -- Resolution: Fixed > Update GCS filesystems to latest available versions >

[jira] [Commented] (FLINK-33704) Update GCS filesystems to latest available versions

2023-12-18 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798130#comment-17798130 ] Jing Ge commented on FLINK-33704: - [~martijnvisser] thanks for letting us know. > Updat

[jira] [Closed] (FLINK-33793) java.lang.NoSuchMethodError when checkpointing in Google Cloud Storage

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33793. -- Resolution: Fixed Fixed via FLINK-33704 > java.lang.NoSuchMethodError when checkpointing in G

[jira] [Updated] (FLINK-33603) Fix guava shading for GCS connector

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33603: --- Affects Version/s: 1.18.0 (was: 1.17.1) > Fix guava shading for G

[jira] [Comment Edited] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-18 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798115#comment-17798115 ] Jing Ge edited comment on FLINK-33588 at 12/18/23 10:54 AM:

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-12-18 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798131#comment-17798131 ] Benchao Li commented on FLINK-33365: [~davidradl] I didn't see a problem in the exam

Re: [PR] [FLINK-27876][table-planner] Choose the right side as build side when using default shuffle hash strategy if left size is equal with right [flink]

2023-12-18 Thread via GitHub
xuyangzhong commented on PR #19866: URL: https://github.com/apache/flink/pull/19866#issuecomment-1860163668 > @xuyangzhong Do you think we should pick this fix to release-1.18? I feel that cp is not needed because it changes the plan and will cause compatibility issues. WDYT? -- Th

[jira] [Updated] (FLINK-33560) Externalize Kinesis Python connector code

2023-12-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33560: -- Fix Version/s: aws-connector-4.3.0 > Externalize Kinesis Python connector code > -

[jira] [Updated] (FLINK-33560) Externalize Kinesis Python connector code

2023-12-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33560: -- Affects Version/s: aws-connector-4.2.0 > Externalize Kinesis Python connector code > -

[jira] [Commented] (FLINK-33449) Support array_contains_seq function

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798135#comment-17798135 ] Martijn Visser commented on FLINK-33449: I think a Dev ML discussion makes sense

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

2023-12-18 Thread via GitHub
MartijnVisser commented on PR #23226: URL: https://github.com/apache/flink/pull/23226#issuecomment-1860175028 > I don't have a Jira account. @cnauroth can you take the ownership of jira ticket? @singhravidutt Please request one via https://selfserve.apache.org/jira-account.html

[PR] Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics [flink]

2023-12-18 Thread via GitHub
JingGe opened a new pull request, #23947: URL: https://github.com/apache/flink/pull/23947 BP of #23931 with no change -- 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] [Commented] (FLINK-33804) Add Option to disable showing metrics in JobMananger UI

2023-12-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798136#comment-17798136 ] Martijn Visser commented on FLINK-33804: [~qqibrow]  Please open a discussion wi

[jira] [Comment Edited] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-12-18 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798131#comment-17798131 ] Benchao Li edited comment on FLINK-33365 at 12/18/23 11:09 AM: ---

[jira] [Updated] (FLINK-32007) Implement Python Wrappers for DynamoDB Connector

2023-12-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32007: -- Fix Version/s: aws-connector-4.3.0 (was: 1.19.0) > Implement Python Wra

Re: [PR] Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics [flink]

2023-12-18 Thread via GitHub
JingGe commented on PR #23947: URL: https://github.com/apache/flink/pull/23947#issuecomment-1860197970 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. T

Re: [PR] Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics [flink]

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

[PR] [FLINK-33823] Make PlannerQueryOperation SQL serializable [flink]

2023-12-18 Thread via GitHub
dawidwys opened a new pull request, #23948: URL: https://github.com/apache/flink/pull/23948 ## What is the purpose of the change Make PlannerQueryOperation SQL serializable ## Verifying this change Added tests in: * org.apache.flink.table.api.QueryOperationSqlS

[jira] [Updated] (FLINK-33823) Serialize PlannerQueryOperation into SQL

2023-12-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33823: --- Labels: pull-request-available (was: ) > Serialize PlannerQueryOperation into SQL > ---

[jira] [Comment Edited] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-18 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798115#comment-17798115 ] Jing Ge edited comment on FLINK-33588 at 12/18/23 11:22 AM:

[jira] [Commented] (FLINK-32346) JdbcNumericBetweenParametersProvider Sharding key boundaries large storage long integer overflow, use BigDecimal instead Long

2023-12-18 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798139#comment-17798139 ] Benchao Li commented on FLINK-32346: [~sunnny] I agree the partition columns can/sho

Re: [PR] [FLINK-33823] Make PlannerQueryOperation SQL serializable [flink]

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

[jira] [Updated] (FLINK-33865) exponential-delay.attempts-before-reset-backoff doesn't work when it's set in Job Configuration

2023-12-18 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33865: Description: exponential-delay.attempts-before-reset-backoff doesn't work when it's set in Job Configurat

[jira] [Commented] (FLINK-33862) Flink Unit Test Failures on 1.18.0

2023-12-18 Thread Prabhu Joseph (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798143#comment-17798143 ] Prabhu Joseph commented on FLINK-33862: --- [FLINK-28203|https://issues.apache.org/ji

[jira] [Commented] (FLINK-33793) java.lang.NoSuchMethodError when checkpointing in Google Cloud Storage

2023-12-18 Thread Jun Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798144#comment-17798144 ] Jun Qin commented on FLINK-33793: - Could we update the Fix versions field such that ever

[jira] [Updated] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-18 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33872: Description: Prior to https://issues.apache.org/jira/browse/FLINK-32469, we see checkpoint

[jira] [Updated] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-18 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33872: Description: Prior to https://issues.apache.org/jira/browse/FLINK-32469, we see checkpoint

[jira] [Created] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-18 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33872: --- Summary: Checkpoint history does not display for completed jobs Key: FLINK-33872 URL: https://issues.apache.org/jira/browse/FLINK-33872 Project: Flink

Re: [PR] [FLINK-33778][table] Cleanup usage of deprecated TableConfig#setIdleS… [flink]

2023-12-18 Thread via GitHub
liuyongvs commented on PR #23894: URL: https://github.com/apache/flink/pull/23894#issuecomment-1860241060 > LTGM. BTW, should we also update this function in pyflink? cc @HuangXingBo Further more, please modify the description of this pr. the python code of has no use, we do not need

[jira] [Assigned] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-18 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33872: --- Assignee: Hong Liang Teoh > Checkpoint history does not display for completed jobs

Re: [PR] [FLINK-33778][table] Cleanup usage of deprecated TableConfig#setIdleS… [flink]

2023-12-18 Thread via GitHub
HuangXingBo merged PR #23894: URL: https://github.com/apache/flink/pull/23894 -- 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.a

[jira] [Commented] (FLINK-33778) Cleanup usage of deprecated TableConfig#setIdleStateRetentionTime(Time, Time)

2023-12-18 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798149#comment-17798149 ] Jacky Lau commented on FLINK-33778: --- merged 3c86dcadf5366fa0026125051d69b0a8913d5e61

[jira] [Closed] (FLINK-33778) Cleanup usage of deprecated TableConfig#setIdleStateRetentionTime(Time, Time)

2023-12-18 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jacky Lau closed FLINK-33778. - Resolution: Fixed > Cleanup usage of deprecated TableConfig#setIdleStateRetentionTime(Time, Time) >

  1   2   3   >