[jira] [Updated] (FLINK-32701) Potential Memory Leak in Flink CEP due to Persistent Starting States in NFAState

[ https://issues.apache.org/jira/browse/FLINK-32701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Puneet Duggal updated FLINK-32701: -- Description: Our team has encountered a potential memory leak issue while working with the Co

[GitHub] [flink] WencongLiu commented on a diff in pull request #23000: [FLINK-32594][runtime] FLIP-331: Support EndOfStreamWindows and isOutputOnEOF operator attribute to optimize task deployment

WencongLiu commented on code in PR #23000: URL: https://github.com/apache/flink/pull/23000#discussion_r1321042128 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java: ## @@ -1014,7 +1014,7 @@ public void resumeConsumption(In

[jira] [Commented] (FLINK-12869) Add yarn acls capability to flink containers

[ https://issues.apache.org/jira/browse/FLINK-12869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763559#comment-17763559 ] Archit Goyal commented on FLINK-12869: -- https://issues.apache.org/jira/browse/FLINK

[jira] [Updated] (FLINK-32701) Potential Memory Leak in Flink CEP due to Persistent Starting States in NFAState

[ https://issues.apache.org/jira/browse/FLINK-32701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Puneet Duggal updated FLINK-32701: -- Flags: Patch > Potential Memory Leak in Flink CEP due to Persistent Starting States in > NFAS

[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-1713216273 @mxm I have updated the PR based on the comments, also simplified wording for the retry related configs. PTAL -- This is an automated message from the Apache Git Service

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #668: Give cluster/job role access to k8s services API

gyfora commented on PR #668: URL: https://github.com/apache/flink-kubernetes-operator/pull/668#issuecomment-1713204232 Could you please open aJIRA ticket to track this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-33069) Mysql and Postgre catalog support url extra parameters

[ https://issues.apache.org/jira/browse/FLINK-33069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-33069: - External issue URL: (was: https://github.com/apache/flink-connector-jdbc/pull/74) > Mysql and Postgre

[jira] [Updated] (FLINK-33069) Mysql and Postgre catalog support url extra parameters

[ https://issues.apache.org/jira/browse/FLINK-33069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-33069: - External issue URL: https://github.com/apache/flink-connector-jdbc/pull/74 > Mysql and Postgre catalog s

[jira] [Created] (FLINK-33069) Mysql and Postgre catalog support url extra parameters

waywtdcc created FLINK-33069: Summary: Mysql and Postgre catalog support url extra parameters Key: FLINK-33069 URL: https://issues.apache.org/jira/browse/FLINK-33069 Project: Flink Issue Type: Ne

[GitHub] [flink-connector-jdbc] boring-cyborg[bot] commented on pull request #74: Mysql and Postgres catalog support url extra parameters

boring-cyborg[bot] commented on PR #74: URL: https://github.com/apache/flink-connector-jdbc/pull/74#issuecomment-1713197374 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-connector-jdbc] waywtdcc opened a new pull request, #74: Mysql and Postgres catalog support url extra parameters

waywtdcc opened a new pull request, #74: URL: https://github.com/apache/flink-connector-jdbc/pull/74 Mysql and Postgres catalog support url extra parameters CREATE CATALOG mymysql WITH( 'type' = 'jdbc', 'username' = 'root', 'password' = 'xxx', 'base-url' = 'jdbc:mysql://xxx

[jira] [Closed] (FLINK-33054) Align the job execution result fetching timeout in CollectResultFetcher with akka timeout

[ https://issues.apache.org/jira/browse/FLINK-33054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-33054. -- Resolution: Fixed > Align the job execution result fetching timeout in CollectResultFetcher with > ak

[jira] [Commented] (FLINK-33054) Align the job execution result fetching timeout in CollectResultFetcher with akka timeout

[ https://issues.apache.org/jira/browse/FLINK-33054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763550#comment-17763550 ] Yangze Guo commented on FLINK-33054: master: 9c91ea3d35528ddc6a5d5be08407d5b0c71f2e7

[GitHub] [flink] KarmaGYZ merged pull request #23368: [FLINK-33054][datastream] Align the execution result fetching timeout…

KarmaGYZ merged PR #23368: URL: https://github.com/apache/flink/pull/23368 -- 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] KarmaGYZ commented on a diff in pull request #23368: [FLINK-33054][datastream] Align the execution result fetching timeout…

KarmaGYZ commented on code in PR #23368: URL: https://github.com/apache/flink/pull/23368#discussion_r1320969792 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java: ## @@ -67,20 +66,23 @@ public class CollectResultFetc

[GitHub] [flink] X-czh commented on pull request #23264: Refactor @Test(expected) with assertThrows

X-czh commented on PR #23264: URL: https://github.com/apache/flink/pull/23264#issuecomment-1713117559 Got it, thanks @Taher-Ghaleb for raising the discussion here. Seems like consensus is already reached, can we close this MR then? -- This is an automated message from the Apache Git Servi

[jira] [Updated] (FLINK-33054) Align the job execution result fetching timeout in CollectResultFetcher with akka timeout

[ https://issues.apache.org/jira/browse/FLINK-33054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33054: --- Labels: pull-request-available (was: ) > Align the job execution result fetching timeout in

[GitHub] [flink] huwh commented on a diff in pull request #23368: [FLINK-33054][datastream] Align the execution result fetching timeout…

huwh commented on code in PR #23368: URL: https://github.com/apache/flink/pull/23368#discussion_r1320962443 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java: ## @@ -67,20 +66,23 @@ public class CollectResultFetcher

[GitHub] [flink-kubernetes-operator] sbrother opened a new pull request, #668: Give cluster/job role access to k8s services API

sbrother opened a new pull request, #668: URL: https://github.com/apache/flink-kubernetes-operator/pull/668 The current RBAC configuration does not give the cluster/job role (i.e. `flink`) access to the `services` API. This means that if you connect to a Flink Session Cluster and run `flink

[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.

[jira] [Commented] (FLINK-32895) Introduce the max attempts for Exponential Delay Restart Strategy

[ https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763530#comment-17763530 ] Zhu Zhu commented on FLINK-32895: - Either option sounds good to me. Feel free to start t

[GitHub] [flink] wangzzu commented on pull request #23243: [FLINK-32846][runtime][JUnit5 Migration] The metrics package of flink-runtime module

wangzzu commented on PR #23243: URL: https://github.com/apache/flink/pull/23243#issuecomment-1713074757 @1996fanrui kindly remind if you have time -- 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] [Assigned] (FLINK-31895) End-to-end integration tests for failure labels

[ https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-31895: - Assignee: Matt Wang (was: Matt Wang) > End-to-end integration tests for failure labels > -

[jira] [Assigned] (FLINK-33061) Translate failure-enricher documentation to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33061: - Assignee: Matt Wang (was: Matt Wang) > Translate failure-enricher documentation to Chinese > -

[jira] [Comment Edited] (FLINK-32906) Release Testing: Verify FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

[ https://issues.apache.org/jira/browse/FLINK-32906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763523#comment-17763523 ] Yubin Li edited comment on FLINK-32906 at 9/11/23 2:37 AM: --- [~

[jira] [Commented] (FLINK-32906) Release Testing: Verify FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

[ https://issues.apache.org/jira/browse/FLINK-32906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763523#comment-17763523 ] Yubin Li commented on FLINK-32906: -- [~jingge] (y) > Release Testing: Verify FLIP-279 U

[GitHub] [flink] wangzzu commented on a diff in pull request #23386: [FLINK-33022] Log an error when enrichers defined as part of the configuration can not be found/loaded

wangzzu commented on code in PR #23386: URL: https://github.com/apache/flink/pull/23386#discussion_r1320928205 ## flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java: ## @@ -106,23 +108,34 @@ static Collection getFailureEnrichers(

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

JunRuiLee closed pull request #23181: W.I.P only used to run ci. URL: https://github.com/apache/flink/pull/23181 -- 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,

[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-1713048629 @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] flinkbot commented on pull request #23388: [FLINK-33063][table-runtime] Fix udaf with complex user defined pojo object throw error while generate record equaliser

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

[GitHub] [flink] swuferhong opened a new pull request, #23388: [FLINK-33063][table-runtime] Fix udaf with complex user defined pojo object throw error while generate record equaliser

swuferhong opened a new pull request, #23388: URL: https://github.com/apache/flink/pull/23388 ## What is the purpose of the change cherry-pick from master ## Brief change log cp pr ## Verifying this change ## Does this pull request potentiall

[GitHub] [flink] swuferhong commented on pull request #23374: [FLINK-33063][table-runtime] Fix udaf with complex user defined pojo object throw error while generate record equaliser

swuferhong commented on PR #23374: URL: https://github.com/apache/flink/pull/23374#issuecomment-1713001257 > @swuferhong could you open a cherry-pick pull request for release-1.18 branch? Sure! -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-32525) Update commons-beanutils to 1.9.4

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

[jira] [Updated] (FLINK-32044) Improve catalog name check to keep consistent about human-readable exception log in FunctionCatalog

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

[jira] [Updated] (FLINK-26115) Multiple Kafka connector tests failed due to The topic metadata failed to propagate to Kafka broker

[ https://issues.apache.org/jira/browse/FLINK-26115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26115: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor test

[jira] [Updated] (FLINK-28881) PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream test failure

[ https://issues.apache.org/jira/browse/FLINK-28881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28881: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability) Pri

[jira] [Updated] (FLINK-30935) Add KafkaSerializer deserialize check when using SimpleVersionedSerializer

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

[jira] [Updated] (FLINK-32344) MongoDB connector support unbounded streaming read via ChangeStream feature

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

[jira] [Updated] (FLINK-32512) SHOW JARS should not show the jars for temporary function

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

[jira] [Commented] (FLINK-32796) Release Testing: Verify FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations

[ https://issues.apache.org/jira/browse/FLINK-32796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763491#comment-17763491 ] Sergey Nuyanzin commented on FLINK-32796: - Since mentioned PRs are merged and it

[jira] [Resolved] (FLINK-32796) Release Testing: Verify FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations

[ https://issues.apache.org/jira/browse/FLINK-32796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-32796. - Resolution: Done > Release Testing: Verify FLIP-295: Support lazy initialization of cata

[jira] [Commented] (FLINK-32796) Release Testing: Verify FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations

[ https://issues.apache.org/jira/browse/FLINK-32796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763490#comment-17763490 ] Sergey Nuyanzin commented on FLINK-32796: - Merged to master [034a60a60897c0cf9a

[GitHub] [flink] snuyanzin merged pull request #23367: [FLINK-32796][docs] Extend catalog store documentation

snuyanzin merged PR #23367: URL: https://github.com/apache/flink/pull/23367 -- 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 #23367: [FLINK-32796][docs] Extend catalog store documentation

snuyanzin commented on PR #23367: URL: https://github.com/apache/flink/pull/23367#issuecomment-1712944986 Since it was revied at https://github.com/apache/flink/pull/23294 LGTM -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] snuyanzin merged pull request #23294: [BP-1.18][FLINK-32796][docs] Extend catalog store documentation

snuyanzin merged PR #23294: URL: https://github.com/apache/flink/pull/23294 -- 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 #23294: [BP-1.18][FLINK-32796][docs] Extend catalog store documentation

snuyanzin commented on PR #23294: URL: https://github.com/apache/flink/pull/23294#issuecomment-1712944550 Thanks for the contribution @ferenc-csaky Thanks for taking a look @hackergin LGTM -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] snuyanzin merged pull request #23366: [FLINK-32796][table] Try to create catalog store path if not exists

snuyanzin merged PR #23366: URL: https://github.com/apache/flink/pull/23366 -- 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 merged pull request #23293: [BP-1.18][FLINK-32796][table] Try to create catalog store path if not exists

snuyanzin merged PR #23293: URL: https://github.com/apache/flink/pull/23293 -- 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] [Resolved] (FLINK-33010) NPE when using GREATEST() in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33010. - Fix Version/s: 1.19.0 Resolution: Fixed > NPE when using GREATEST() in Flink SQL

[jira] [Commented] (FLINK-33010) NPE when using GREATEST() in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763486#comment-17763486 ] Sergey Nuyanzin commented on FLINK-33010: - Merged as [5775fbbf02b962243d3fbe2d7

[jira] [Commented] (FLINK-31619) Upgrade Stateful Functions to Flink 1.16.1

[ https://issues.apache.org/jira/browse/FLINK-31619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763461#comment-17763461 ] Martijn Visser commented on FLINK-31619: If the vote on the release gets accepte

[GitHub] [flink] flinkbot commented on pull request #23387: [FLINK-32488][REST] Introduce configuration for web cache TTL

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

[GitHub] [flink] hejufang opened a new pull request, #23387: [FLINK-32488][REST] Introduce configuration for web cache TTL

hejufang opened a new pull request, #23387: URL: https://github.com/apache/flink/pull/23387 ## What is the purpose of the change Introduce a new configuration for web cache TTL. This should be separate from the web.refresh-interval, which controls the refresh rate of the Flink

[GitHub] [flink] Jiabao-Sun commented on pull request #23218: [FLINK-32854][flink-runtime][JUnit5 Migration] The state package of flink-runtime module

Jiabao-Sun commented on PR #23218: URL: https://github.com/apache/flink/pull/23218#issuecomment-1712816006 Thanks @1996fanrui for the continuous help. Please help with it again when you have time. -- This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23218: [FLINK-32854][flink-runtime][JUnit5 Migration] The state package of flink-runtime module

Jiabao-Sun commented on code in PR #23218: URL: https://github.com/apache/flink/pull/23218#discussion_r1320770848 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/SnapshotDirectoryTest.java: ## @@ -19,180 +19,167 @@ package org.apache.flink.runtime.state; import

[jira] [Commented] (FLINK-31619) Upgrade Stateful Functions to Flink 1.16.1

[ https://issues.apache.org/jira/browse/FLINK-31619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763401#comment-17763401 ] Frans King commented on FLINK-31619: Will there be a 3.3.0 build published to maven?