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

2023-09-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763394#comment-17763394 ] Rui Fan commented on FLINK-32895: - Hi [~zhuzh] , I created the FLIP-364 in advance due t

[jira] [Updated] (FLINK-32818) Support region failover for adaptive scheduler

2023-09-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32818: Component/s: Runtime / Coordination > Support region failover for adaptive scheduler > ---

[jira] [Commented] (FLINK-32818) Support region failover for adaptive scheduler

2023-09-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763391#comment-17763391 ] Rui Fan commented on FLINK-32818: - Hi, [~talat] , thanks for your interest in Adaptive S

[jira] [Updated] (FLINK-32575) Unified the Cpu of JobManager Name

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

[jira] [Updated] (FLINK-30699) Improved getRandomString method code format in the StringUtils class

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

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

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

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

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

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

2023-09-09 Thread via GitHub
pgaref commented on PR #23386: URL: https://github.com/apache/flink/pull/23386#issuecomment-1712609517 @wangzzu @zentol can you please take a look when you have a sec? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[jira] [Updated] (FLINK-33022) Log an error when enrichers defined as part of the configuration can not be found/loaded

2023-09-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33022: --- Labels: pull-request-available (was: ) > Log an error when enrichers defined as part of the

[GitHub] [flink] pgaref opened a new pull request, #23386: [FLINK-33022] Log an error when enrichers defined as part of the configuration can not be found/loaded

2023-09-09 Thread via GitHub
pgaref opened a new pull request, #23386: URL: https://github.com/apache/flink/pull/23386 https://issues.apache.org/jira/browse/FLINK-33022 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather tha

[jira] [Updated] (FLINK-33022) Log an error when enrichers defined as part of the configuration can not be found/loaded

2023-09-09 Thread Panagiotis Garefalakis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Panagiotis Garefalakis updated FLINK-33022: --- Summary: Log an error when enrichers defined as part of the configuration ca

[jira] [Updated] (FLINK-33022) Log when FailureEnricherUtils load FailureEnricherFactory failed should throw exception or add some error logs

2023-09-09 Thread Panagiotis Garefalakis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Panagiotis Garefalakis updated FLINK-33022: --- Summary: Log when FailureEnricherUtils load FailureEnricherFactory failed sh

[jira] [Commented] (FLINK-32818) Support region failover for adaptive scheduler

2023-09-09 Thread Talat Uyarer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763366#comment-17763366 ] Talat Uyarer commented on FLINK-32818: -- Hey [~fanrui] At Palo Alto Networks We also

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

2023-09-09 Thread via GitHub
pgaref commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1320633358 ## 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] pgaref commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-09 Thread via GitHub
pgaref commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1320633268 ## 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-connector-elasticsearch] StefanXiepj commented on pull request #53: [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support

2023-09-09 Thread via GitHub
StefanXiepj commented on PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1712529841 > Thanks @mtfelisb! I have seen many people's urgent need for this, so feel free to ping me for reviewing to accelerate the progress. And I can provide any possible

[GitHub] [flink-connector-elasticsearch] StefanXiepj commented on pull request #74: [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support

2023-09-09 Thread via GitHub
StefanXiepj commented on PR #74: URL: https://github.com/apache/flink-connector-elasticsearch/pull/74#issuecomment-1712529671 @reswqa hi, Weijie, nice meet you here. As you said, I also have many friends who are looking forward to this PR, so I also tried to implement it, can you provide

[GitHub] [flink-connector-elasticsearch] boring-cyborg[bot] commented on pull request #74: Add Elasticsearch 8.0 support

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

[jira] [Commented] (FLINK-33042) Allow trigger flamegraph when task is initializing

2023-09-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763344#comment-17763344 ] Rui Fan commented on FLINK-33042: - Merged via 53702736382b80fa905494e69654061a84741e84

[jira] [Resolved] (FLINK-33042) Allow trigger flamegraph when task is initializing

2023-09-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33042. - Fix Version/s: 1.19.0 Resolution: Fixed > Allow trigger flamegraph when task is initializing > -

[GitHub] [flink] 1996fanrui merged pull request #23372: [FLINK-33042][flamegraph] Allow trigger flamegraph when task is initializing

2023-09-09 Thread via GitHub
1996fanrui merged PR #23372: URL: https://github.com/apache/flink/pull/23372 -- 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.ap

[jira] [Updated] (FLINK-33042) Allow trigger flamegraph when task is initializing

2023-09-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33042: --- Labels: pull-request-available (was: ) > Allow trigger flamegraph when task is initializing

[GitHub] [flink] RocMarshal commented on a diff in pull request #23372: [FLINK-33042][flamegraph] Allow trigger flamegraph when task is initializing

2023-09-09 Thread via GitHub
RocMarshal commented on code in PR #23372: URL: https://github.com/apache/flink/pull/23372#discussion_r1320564934 ## flink-runtime-web/web-dashboard/src/app/pages/job/overview/flamegraph/job-overview-drawer-flamegraph.component.html: ## @@ -16,8 +16,13 @@ ~ limitations under

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

2023-09-09 Thread via GitHub
1996fanrui commented on code in PR #23218: URL: https://github.com/apache/flink/pull/23218#discussion_r1316013616 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/SnapshotDirectoryTest.java: ## @@ -19,180 +19,167 @@ package org.apache.flink.runtime.state; import

[GitHub] [flink] 1996fanrui commented on a diff in pull request #22985: [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler

2023-09-09 Thread via GitHub
1996fanrui commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1319551944 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java: ## @@ -496,6 +556,8 @@ private final class ExecutingStateBuilder {

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

2023-09-09 Thread Aleksandr Pilipenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763326#comment-17763326 ] Aleksandr Pilipenko commented on FLINK-32962: - Fix for 1.18 has been merged,

[jira] [Commented] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

2023-09-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763319#comment-17763319 ] Jark Wu commented on FLINK-33063: - Fixed in - master: 01cb6ef008273100718cd8a8cfd921c02

[jira] [Updated] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

2023-09-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-33063: Fix Version/s: 1.19.0 > udaf with user defined pojo object throw error while generate record equaliser > -

[jira] [Updated] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

2023-09-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33063: --- Labels: pull-request-available (was: ) > udaf with user defined pojo object throw error whi

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

2023-09-09 Thread via GitHub
wuchong commented on PR #23374: URL: https://github.com/apache/flink/pull/23374#issuecomment-1712461880 @swuferhong could you open a cherry-pick pull request for release-1.18 branch? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

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

2023-09-09 Thread via GitHub
wuchong merged PR #23374: URL: https://github.com/apache/flink/pull/23374 -- 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.apach

[jira] [Updated] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-09 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33053: --- Attachment: taskmanager_flink-native-test-117-taskmanager-1-9_thread_dump (1).json > Watcher leak i

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-09 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763315#comment-17763315 ] Yangze Guo commented on FLINK-33053: [~tison] Yes, it seems teh curator framework is

[GitHub] [flink] JunRuiLee closed pull request #23385: Test

2023-09-09 Thread via GitHub
JunRuiLee closed pull request #23385: Test URL: https://github.com/apache/flink/pull/23385 -- 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-unsubs