[GitHub] [flink] flinkbot commented on pull request #23385: Test

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

[GitHub] [flink] JunRuiLee opened a new pull request, #23385: Test

JunRuiLee opened a new pull request, #23385: URL: https://github.com/apache/flink/pull/23385 A test pr which used to trigger ci. -- 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 comme

[jira] [Updated] (FLINK-33065) Optimize the exception message when the program plan could not be fetched

[ https://issues.apache.org/jira/browse/FLINK-33065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33065: --- Labels: pull-request-available (was: ) > Optimize the exception message when the program pl

[GitHub] [flink] 1996fanrui commented on pull request #23379: [FLINK-33065][client] Add possible root cause to the exception message when the program plan could not be fetched

1996fanrui commented on PR #23379: URL: https://github.com/apache/flink/pull/23379#issuecomment-1712408406 cc @RocMarshal -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. T

[GitHub] [flink] flinkbot commented on pull request #23384: [FLINK-32962][python] Remove pip version check on installing dependencies.

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

[GitHub] [flink] z3d1k opened a new pull request, #23384: [FLINK-32962][python] Remove pip version check on installing dependencies.

z3d1k opened a new pull request, #23384: URL: https://github.com/apache/flink/pull/23384 ## What is the purpose of the change Removing `pip` version check when installing job python dependencies from requirements file. ## Verifying this change This change is already cove

[jira] [Updated] (FLINK-32522) Kafka connector should depend on commons-collections instead of inherit from flink

[ https://issues.apache.org/jira/browse/FLINK-32522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32522: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-32396) Support timestamp for jdbc driver and gateway

[ https://issues.apache.org/jira/browse/FLINK-32396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32396: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available stal

[jira] [Updated] (FLINK-32706) Add SPLIT(STRING) support in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-32706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32706: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-31335) using sql-gateway to submit job to yarn cluster, sql-gateway don't support kerberos

[ https://issues.apache.org/jira/browse/FLINK-31335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31335: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Commented] (FLINK-33068) Handle DNS errors in AWS connectors as recoverable

[ https://issues.apache.org/jira/browse/FLINK-33068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763272#comment-17763272 ] Elphas Toringepi commented on FLINK-33068: -- [~danny.cranmer] could you please a

[jira] [Created] (FLINK-33068) Handle DNS errors in AWS connectors as recoverable

Elphas Toringepi created FLINK-33068: Summary: Handle DNS errors in AWS connectors as recoverable Key: FLINK-33068 URL: https://issues.apache.org/jira/browse/FLINK-33068 Project: Flink Is

[GitHub] [flink] flinkbot commented on pull request #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for PyFlink

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

[jira] [Updated] (FLINK-32885) Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for PyFlink remote execution

[ https://issues.apache.org/jira/browse/FLINK-32885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32885: --- Labels: pull-request-available (was: ) > Refactoring: Moving UrlPrefixDecorator into flink-

[GitHub] [flink] elkhand opened a new pull request, #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for PyFlink

elkhand opened a new pull request, #23383: URL: https://github.com/apache/flink/pull/23383 [FLINK-32885](https://issues.apache.org/jira/browse/FLINK-32885) Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for PyFlink remote execution ##

[jira] [Updated] (FLINK-33052) codespeed server is down

[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33052: Description: No update in #flink-dev-benchmarks slack channel since 25th August. It was a EC2 running in

[GitHub] [flink-docker] daniel-packard closed pull request #158: [ADD-SYMLINKS] Add symlinks for FLINK_VERSION to FLINK_RELEASE jars

daniel-packard closed pull request #158: [ADD-SYMLINKS] Add symlinks for FLINK_VERSION to FLINK_RELEASE jars URL: https://github.com/apache/flink-docker/pull/158 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[GitHub] [flink-kubernetes-operator] HuangZhenQiu opened a new pull request, #667: [FLINK-32777] add doc for supporting IPV6 env

HuangZhenQiu opened a new pull request, #667: URL: https://github.com/apache/flink-kubernetes-operator/pull/667 ## What is the purpose of the change Add doc for run Flink Operator in IPV6 env ## Brief change log Add config needed as a workaround for supporting IPV6 env

[jira] [Updated] (FLINK-32777) Upgrade Okhttp version to support IPV6

[ https://issues.apache.org/jira/browse/FLINK-32777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32777: --- Labels: pull-request-available (was: ) > Upgrade Okhttp version to support IPV6 > -

[GitHub] [flink-web] foxus commented on pull request #673: Fix the search bar on Flink website

foxus commented on PR #673: URL: https://github.com/apache/flink-web/pull/673#issuecomment-1711933413 @MartijnVisser, I spent some time with @dannycranmer attempting to debug the behaviour of the Content filter to no avail. Whilst the filter and counter implementation is verbose, it is perf

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

gyfora commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1320062795 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -365,22 +365,45 @@ pu

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

gyfora commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1320061447 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -365,22 +365,45 @@ pu

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

gyfora commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1320058746 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -365,22 +365,45 @@ pu

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

gyfora commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1320053768 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorConfiguration.java: ## @@ -220,8 +227,14 @@ private

[jira] [Commented] (FLINK-24943) SequenceNumber class is not POJO type

[ https://issues.apache.org/jira/browse/FLINK-24943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763138#comment-17763138 ] Alexander Egorov commented on FLINK-24943: -- [~martijnvisser] [~dannycranmer] PR

[jira] [Resolved] (FLINK-33038) remove getMinRetentionTime in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-33038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33038. - Resolution: Fixed > remove getMinRetentionTime in StreamExecDeduplicate > --

[jira] [Commented] (FLINK-33038) remove getMinRetentionTime in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-33038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763134#comment-17763134 ] Sergey Nuyanzin commented on FLINK-33038: - Merged to main as [e4deaf4356b316dbc

[GitHub] [flink-connector-aws] Cyberness opened a new pull request, #93: [FLINK-24943][Connectors / Kinesis] Explicitly create KryoSerializer for SequenceNumber class in Kinesis Consumer

Cyberness opened a new pull request, #93: URL: https://github.com/apache/flink-connector-aws/pull/93 ## Purpose of the change Create KryoSerializer for SequenceNumber class explicitly to allow disabling of Generic Types via disableGenericTypes() call. ## Brief change log

[GitHub] [flink-connector-aws] boring-cyborg[bot] commented on pull request #93: [FLINK-24943][Connectors / Kinesis] Explicitly create KryoSerializer for SequenceNumber class in Kinesis Consumer

boring-cyborg[bot] commented on PR #93: URL: https://github.com/apache/flink-connector-aws/pull/93#issuecomment-1711840964 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is an

[GitHub] [flink] snuyanzin merged pull request #23360: [FLINK-33038][table-planner] remove getMinRetentionTime in StreamExec…

snuyanzin merged PR #23360: URL: https://github.com/apache/flink/pull/23360 -- 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.apa

[jira] [Updated] (FLINK-33038) remove getMinRetentionTime in StreamExecDeduplicate

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

[GitHub] [flink] snuyanzin merged pull request #23342: [FLINK-32999][connectors/hbase] Remove HBase connector code from main repo

snuyanzin merged PR #23342: URL: https://github.com/apache/flink/pull/23342 -- 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.apa

[GitHub] [flink] snuyanzin commented on pull request #23342: [FLINK-32999][connectors/hbase] Remove HBase connector code from main repo

snuyanzin commented on PR #23342: URL: https://github.com/apache/flink/pull/23342#issuecomment-1711836901 @ferenc-csaky thanks a lot for the contribution @RyanSkraba thanks a lot for having another look As it was discussed during release meeting with @knaufk it is ok to merge it

[GitHub] [flink] snuyanzin commented on pull request #23360: [FLINK-33038][table-planner] remove getMinRetentionTime in StreamExec…

snuyanzin commented on PR #23360: URL: https://github.com/apache/flink/pull/23360#issuecomment-1711839164 Thanks for the contribution @zhougit86 Thanks for taking a look @LadyForest -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] Jiabao-Sun commented on pull request #23358: [FLINK-33032][table-planner][JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

Jiabao-Sun commented on PR #23358: URL: https://github.com/apache/flink/pull/23358#issuecomment-1711816645 Thanks @luoyuxia for detailed review. Could you help review it again when you have time? Thanks again! -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23358: [FLINK-33032][table-planner][JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

Jiabao-Sun commented on code in PR #23358: URL: https://github.com/apache/flink/pull/23358#discussion_r1319988195 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/utils/ExpressionTestBase.scala: ## @@ -329,9 +317,7 @@ abstract class Ex

[GitHub] [flink] czy006 commented on pull request #23263: [FLINK-32671][docs] Document Externalized Declarative Resource Management

czy006 commented on PR #23263: URL: https://github.com/apache/flink/pull/23263#issuecomment-1711814556 @dmvk PLAT -- 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 unsubsc

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23358: [FLINK-33032][table-planner][JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

Jiabao-Sun commented on code in PR #23358: URL: https://github.com/apache/flink/pull/23358#discussion_r1319987872 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/ArrayTypeTest.scala: ## @@ -21,7 +21,8 @@ import org.apache.flink.table.

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23358: [FLINK-33032][table-planner][JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

Jiabao-Sun commented on code in PR #23358: URL: https://github.com/apache/flink/pull/23358#discussion_r1319983416 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/utils/ExpressionTestBase.scala: ## @@ -138,33 +131,28 @@ abstract class

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

mxm commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1319971456 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -365,22 +365,45 @@ publi

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

mxm commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1319970534 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -365,22 +365,45 @@ publi

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

mxm commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1319954969 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorConfiguration.java: ## @@ -220,8 +227,14 @@ private sta

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

mxm commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1319954233 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorConfiguration.java: ## @@ -220,8 +227,14 @@ private sta

[jira] [Closed] (FLINK-33062) Deserialization creates multiple instances of case objects in Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-33062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33062. -- Resolution: Won't Fix > Deserialization creates multiple instances of case objects in Scala 2.

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

mxm commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1319917846 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -365,22 +365,45 @@ publi

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

mxm commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1319917059 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -365,22 +365,45 @@ publi

[jira] [Updated] (FLINK-33032) [JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

[ https://issues.apache.org/jira/browse/FLINK-33032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33032: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Module: flink-table-planner (Ex

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23358: [FLINK-33032][table-planner][JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

Jiabao-Sun commented on code in PR #23358: URL: https://github.com/apache/flink/pull/23358#discussion_r1319909589 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/DecimalTypeTest.scala: ## @@ -385,11 +385,11 @@ class DecimalTypeTest ex

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23358: [FLINK-33032][table-planner][JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

Jiabao-Sun commented on code in PR #23358: URL: https://github.com/apache/flink/pull/23358#discussion_r1319908902 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/DecimalTypeTest.scala: ## @@ -385,11 +385,11 @@ class DecimalTypeTest ex

[GitHub] [flink] snuyanzin commented on a diff in pull request #23345: [FLINK-33010][table] GREATEST/LEAST should work with other functions as input

snuyanzin commented on code in PR #23345: URL: https://github.com/apache/flink/pull/23345#discussion_r1319874688 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala: ## @@ -1369,11 +1369,12 @@ object ScalarOpera

[GitHub] [flink] RyanSkraba commented on a diff in pull request #23345: [FLINK-33010][table] GREATEST/LEAST should work with other functions as input

RyanSkraba commented on code in PR #23345: URL: https://github.com/apache/flink/pull/23345#discussion_r1319870722 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala: ## @@ -1369,11 +1369,12 @@ object ScalarOper

[GitHub] [flink] RyanSkraba commented on a diff in pull request #23345: [FLINK-33010][table] GREATEST/LEAST should work with other functions as input

RyanSkraba commented on code in PR #23345: URL: https://github.com/apache/flink/pull/23345#discussion_r1319870722 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala: ## @@ -1369,11 +1369,12 @@ object ScalarOper

[jira] [Comment Edited] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762793#comment-17762793 ] Ryan Skraba edited comment on FLINK-33018 at 9/8/23 1:16 PM: -

[GitHub] [flink] flinkbot commented on pull request #23382: Bump com.github.tomakehurst:wiremock-jre8 from 2.32.0 to 2.35.1 in /flink-metrics/flink-metrics-influxdb

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

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

gyfora commented on PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#issuecomment-1711596705 > Thanks, great. Could you please explain the default behavior in plain English now given the default values you propose? (How many request would we send/resources/sec)

[jira] [Updated] (FLINK-33031) [JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase)

[ https://issues.apache.org/jira/browse/FLINK-33031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33031: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Module: flink-table-planner (Ag

[jira] [Resolved] (FLINK-33031) [JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase)

[ https://issues.apache.org/jira/browse/FLINK-33031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-33031. -- Resolution: Fixed master:da69cc7ca3b25fd133e22f2e6b6b0c6471753a20 > [JUnit5 Migration] Module: flink-

[GitHub] [flink] luoyuxia merged pull request #23354: [FLINK-33031][table-planner][JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase)

luoyuxia merged PR #23354: URL: https://github.com/apache/flink/pull/23354 -- 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.apac

[GitHub] [flink] dependabot[bot] opened a new pull request, #23382: Bump com.github.tomakehurst:wiremock-jre8 from 2.32.0 to 2.35.1 in /flink-metrics/flink-metrics-influxdb

dependabot[bot] opened a new pull request, #23382: URL: https://github.com/apache/flink/pull/23382 Bumps [com.github.tomakehurst:wiremock-jre8](https://github.com/wiremock/wiremock) from 2.32.0 to 2.35.1. Release notes Sourced from https://github.com/wiremock/wiremock/releases";>c

[GitHub] [flink-kubernetes-operator] mbalassi commented on a diff in pull request #666: [FLINK-33067] Expose rate limiter config and enable by default

mbalassi commented on code in PR #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666#discussion_r1319796729 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -365,22 +365,45 @@

[jira] [Commented] (FLINK-30025) Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

[ https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763065#comment-17763065 ] Jing Ge commented on FLINK-30025: - merged into master: 3b9fcb5fd1060abd02d761eff767c6e2b

[GitHub] [flink] flinkbot commented on pull request #23381: [FLINK-30025][doc] improve the option description with more precise content

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

[GitHub] [flink-statefun-docker] MartijnVisser opened a new pull request, #20: Update Dockerfiles for 3.3.0 release

MartijnVisser opened a new pull request, #20: URL: https://github.com/apache/flink-statefun-docker/pull/20 (no comment) -- 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 u

[jira] [Updated] (FLINK-33067) Expose JODK rate limiter config and enable by default

[ https://issues.apache.org/jira/browse/FLINK-33067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33067: --- Labels: pull-request-available (was: ) > Expose JODK rate limiter config and enable by defa

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #666: [FLINK-33067] Expose rate limiter config and enable by default

gyfora opened a new pull request, #666: URL: https://github.com/apache/flink-kubernetes-operator/pull/666 ## What is the purpose of the change There are certain cases currently when the operator can stuck in an infinite no wait retry loop under certain circumstances (see https://gith

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1319719593 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/PartitionFileReader.java: ## @@ -78,4 +87,79 @@ long getPriority(

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1319722535 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/ProducerMergedPartitionFileReader.java: ## @@ -176,91 +162,179 @@ p

[jira] [Updated] (FLINK-32962) Failure to install python dependencies from requirements file

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-32962: Fix Version/s: 1.17.2 > Failure to install python dependencies from requirements file > --

[jira] [Commented] (FLINK-32962) Failure to install python dependencies from requirements file

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763052#comment-17763052 ] Hong Liang Teoh commented on FLINK-32962: - merged commit  [{{7f99a27}}|https://g

[jira] [Updated] (FLINK-32962) Failure to install python dependencies from requirements file

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-32962: Fix Version/s: 1.18.0 1.19.0 > Failure to install python dependencies f

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1319720134 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/ProducerMergedPartitionFileIndex.java: ## @@ -257,20 +266,28 @@ pub

[GitHub] [flink] hlteoh37 merged pull request #23337: [FLINK-32962][python] Remove pip version check on installing dependencies.

hlteoh37 merged PR #23337: URL: https://github.com/apache/flink/pull/23337 -- 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.apac

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1319719593 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/PartitionFileReader.java: ## @@ -78,4 +87,79 @@ long getPriority(

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1319716759 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/PartitionFileReader.java: ## @@ -78,4 +87,79 @@ long getPriority(

[jira] [Commented] (FLINK-33000) SqlGatewayServiceITCase should utilize TestExecutorExtension instead of using a ThreadFactory

[ https://issues.apache.org/jira/browse/FLINK-33000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763013#comment-17763013 ] Haode Du commented on FLINK-33000: -- Thanks for the quick reply. In terms of the fixed n

[GitHub] [flink-web] MartijnVisser opened a new pull request, #674: Add Statefun v3.3.0

MartijnVisser opened a new pull request, #674: URL: https://github.com/apache/flink-web/pull/674 (no comment) -- 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

[jira] [Created] (FLINK-33067) Expose JODK rate limiter config and enable by default

Gyula Fora created FLINK-33067: -- Summary: Expose JODK rate limiter config and enable by default Key: FLINK-33067 URL: https://issues.apache.org/jira/browse/FLINK-33067 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #23380: Readme.md changes according to [FLINK-25002]

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

[GitHub] [flink] 911432 opened a new pull request, #23380: Readme.md changes according to [FLINK-25002]

911432 opened a new pull request, #23380: URL: https://github.com/apache/flink/pull/23380 Readme.md changes according to FLINK-25002 -- 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 c

[GitHub] [flink] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

JunRuiLee commented on PR #23181: URL: https://github.com/apache/flink/pull/23181#issuecomment-1711342675 @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.

[GitHub] [flink] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

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

[jira] [Commented] (FLINK-33000) SqlGatewayServiceITCase should utilize TestExecutorExtension instead of using a ThreadFactory

[ https://issues.apache.org/jira/browse/FLINK-33000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762993#comment-17762993 ] Matthias Pohl commented on FLINK-33000: --- Thanks for looking into it more closely.

[GitHub] [flink] FangYongs commented on pull request #22832: [FLINK-32396][jdbc-driver] Support timestamp and timestamp_ltz for jdbc driver and sql gateway

FangYongs commented on PR #22832: URL: https://github.com/apache/flink/pull/22832#issuecomment-1711277119 @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.

[GitHub] [flink] FangYongs commented on pull request #22832: [FLINK-32396][jdbc-driver] Support timestamp and timestamp_ltz for jdbc driver and sql gateway

FangYongs commented on PR #22832: URL: https://github.com/apache/flink/pull/22832#issuecomment-1711276704 Thanks @libenchao , the e2e test `Run Kubernetes test` failed which is not caused by this PR, I'll rerun the ci -- This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-33066) Enable to inject environment variable from secret/configmap to operatorPod

[ https://issues.apache.org/jira/browse/FLINK-33066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dongwoo.kim updated FLINK-33066: Description: Hello, I've been working with the Flink Kubernetes operator and noticed that the {{o

[jira] [Created] (FLINK-33066) Enable to inject environment variable from secret/configmap to operatorPod

dongwoo.kim created FLINK-33066: --- Summary: Enable to inject environment variable from secret/configmap to operatorPod Key: FLINK-33066 URL: https://issues.apache.org/jira/browse/FLINK-33066 Project: Fli

[jira] [Updated] (FLINK-33066) Enable to inject environment variable from secret/configmap to operatorPod

[ https://issues.apache.org/jira/browse/FLINK-33066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dongwoo.kim updated FLINK-33066: Description: Hello, I've been working with the Flink Kubernetes operator and noticed that the {{o

[jira] [Resolved] (FLINK-33055) Correct the error value about 'state.backend.type' in the document

[ https://issues.apache.org/jira/browse/FLINK-33055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-33055. -- Fix Version/s: 1.19.0 Resolution: Fixed merged 53ccb93cfb3b6f2befdb13cdeb9d96acbef44932

[jira] [Commented] (FLINK-33000) SqlGatewayServiceITCase should utilize TestExecutorExtension instead of using a ThreadFactory

[ https://issues.apache.org/jira/browse/FLINK-33000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762987#comment-17762987 ] Haode Du commented on FLINK-33000: -- [~mapohl], I have 2 questions on concrete implement

[GitHub] [flink] flinkbot commented on pull request #23379: [FLINK-33065][client] Add possible root cause to the exception message when the program plan could not be fetched

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

[GitHub] [flink] 1996fanrui opened a new pull request, #23379: [FLINK-33065][client] Add possible root cause to the exception message when the program plan could not be fetched

1996fanrui opened a new pull request, #23379: URL: https://github.com/apache/flink/pull/23379 ## What is the purpose of the change When the program plan could not be fetched, the root cause may be: the main method doesn't call the `env.execute()`. We can optimize the message to help

[GitHub] [flink] zentol commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

zentol commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1319494494 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,112 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[GitHub] [flink] zentol commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

zentol commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1319493242 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,112 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[jira] [Created] (FLINK-33065) Optimize the exception message when the program plan could not be fetched

Rui Fan created FLINK-33065: --- Summary: Optimize the exception message when the program plan could not be fetched Key: FLINK-33065 URL: https://issues.apache.org/jira/browse/FLINK-33065 Project: Flink

[GitHub] [flink] luoyuxia commented on a diff in pull request #23358: [FLINK-33032][table-planner][JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

luoyuxia commented on code in PR #23358: URL: https://github.com/apache/flink/pull/23358#discussion_r1319321344 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/DecimalTypeTest.scala: ## @@ -385,11 +385,11 @@ class DecimalTypeTest exte