[jira] [Commented] (FLINK-33874) Support resource request wait mechanism at DefaultDeclarativeSlotPool side for Default Scheduler

2024-07-25 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868839#comment-17868839 ] Rui Fan commented on FLINK-33874: - Merged to master(2.0.0) via: * b1d78ed749bdd5f2e7325

Re: [PR] [FLINK-35894] Add Elasticsearch Sink Connector for Flink CDC Pipeline [flink-cdc]

2024-07-25 Thread via GitHub
lvyanquan commented on code in PR #3495: URL: https://github.com/apache/flink-cdc/pull/3495#discussion_r1692402071 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/Elastic

[jira] [Updated] (FLINK-35898) When running Flink on Yarn, if the log file path contains a space, the startup will fail.

2024-07-25 Thread yiheng tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yiheng tang updated FLINK-35898: Description: We use Yarn to launch Flink jobs and try to add custom parameters to configure the l

[jira] [Updated] (FLINK-35898) When running Flink on Yarn, if the log file path contains a space, the startup will fail.

2024-07-25 Thread yiheng tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yiheng tang updated FLINK-35898: Description: We use Yarn to launch Flink jobs and try to add custom parameters to configure the l

[jira] [Updated] (FLINK-35898) When running Flink on Yarn, if the log file path contains a space, the startup will fail.

2024-07-25 Thread yiheng tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yiheng tang updated FLINK-35898: Description: We use Yarn to launch Flink jobs and try to add custom parameters to configure the l

[jira] [Updated] (FLINK-35898) When running Flink on Yarn, if the log file path contains a space, the startup will fail.

2024-07-25 Thread yiheng tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yiheng tang updated FLINK-35898: Description: We use Yarn to launch Flink jobs and try to add custom parameters to configure the l

[jira] [Updated] (FLINK-35898) When running Flink on Yarn, if the log file path contains a space, the startup will fail.

2024-07-25 Thread yiheng tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yiheng tang updated FLINK-35898: Description: We use Yarn to launch Flink jobs and try to add custom parameters to configure the l

[jira] [Updated] (FLINK-35898) When running Flink on Yarn, if the log file path contains a space, the startup will fail.

2024-07-25 Thread yiheng tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yiheng tang updated FLINK-35898: Description: We use Yarn to launch Flink jobs and try to add custom parameters to configure the l

[jira] [Updated] (FLINK-35898) When running Flink on Yarn, if the log file path contains a space, the startup will fail.

2024-07-25 Thread yiheng tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yiheng tang updated FLINK-35898: Description: We use Yarn to launch Flink jobs and try to add custom parameters to configure the l

Re: [PR] [FLINK-35894] Add Elasticsearch Sink Connector for Flink CDC Pipeline [flink-cdc]

2024-07-25 Thread via GitHub
lvyanquan commented on code in PR #3495: URL: https://github.com/apache/flink-cdc/pull/3495#discussion_r1692411404 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/Elastic

Re: [PR] [hotfix][tests] Separate Pipeline and Source E2e tests [flink-cdc]

2024-07-25 Thread via GitHub
yuxiqian commented on PR #3427: URL: https://github.com/apache/flink-cdc/pull/3427#issuecomment-2251857806 cc @GOODBOY008 -- 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] [Created] (FLINK-35902) WebUI Metrics RangeError on huge parallelism

2024-07-25 Thread Sergey Paryshev (Jira)
Sergey Paryshev created FLINK-35902: --- Summary: WebUI Metrics RangeError on huge parallelism Key: FLINK-35902 URL: https://issues.apache.org/jira/browse/FLINK-35902 Project: Flink Issue Type

[PR] Fix sqlserver uniqueidentifier column as PK [flink-cdc]

2024-07-25 Thread via GitHub
LiPL2017 opened a new pull request, #3497: URL: https://github.com/apache/flink-cdc/pull/3497 A majority of our Sqlserver databases use uniqueidentifier as primary keys. When we enable 'scan.incremental.snapshot.enabled = true', **flink cdc** will try to split into chunks. The splitTab

[jira] [Assigned] (FLINK-35897) Some checkpoint files and localState files can't be cleanUp when checkpoint is aborted

2024-07-25 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-35897: --- Assignee: Jinzhong Li > Some checkpoint files and localState files can't be cleanUp when ch

[PR] [FLINK-26939][Table SQL / Planner] Add TRANSLATE supported in SQL & Table API [flink]

2024-07-25 Thread via GitHub
dylanhz opened a new pull request, #25121: URL: https://github.com/apache/flink/pull/25121 ## What is the purpose of the change Add TRANSLATE function. Examples: ```SQL > SELECT TRANSLATE('AaBbCc', 'abc', '123'); A1B2C3 ``` ## Brief change log [FLINK-26939

Re: [PR] [FLINK-26939][Table SQL / Planner] Add TRANSLATE supported in SQL & Table API [flink]

2024-07-25 Thread via GitHub
flinkbot commented on PR #25121: URL: https://github.com/apache/flink/pull/25121#issuecomment-2251997931 ## CI report: * 96f7bcea0a05455e6134cef3063f83859030dab5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-26939][Table SQL / Planner] Add TRANSLATE supported in SQL & Table API [flink]

2024-07-25 Thread via GitHub
dylanhz closed pull request #25121: [FLINK-26939][Table SQL / Planner] Add TRANSLATE supported in SQL & Table API URL: https://github.com/apache/flink/pull/25121 -- 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

[PR] [FLINK-26939][Table SQL / Planner] Add TRANSLATE supported in SQL & Table API [flink]

2024-07-25 Thread via GitHub
dylanhz opened a new pull request, #25122: URL: https://github.com/apache/flink/pull/25122 ## What is the purpose of the change Add TRANSLATE function. Examples: ```SQL > SELECT TRANSLATE('AaBbCc', 'abc', '123'); A1B2C3 ``` ## Brief change log [FLINK-26939

Re: [PR] [FLINK-26939][Table SQL / Planner] Add TRANSLATE supported in SQL & Table API [flink]

2024-07-25 Thread via GitHub
flinkbot commented on PR #25122: URL: https://github.com/apache/flink/pull/25122#issuecomment-2252014468 ## CI report: * 57b86cb10cd2b97b1329f0e08a752c76b30fa068 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-35902][ui] WebUI Metrics RangeError on huge parallelism [flink]

2024-07-25 Thread via GitHub
ParyshevSergey opened a new pull request, #25123: URL: https://github.com/apache/flink/pull/25123 ## What is the purpose of the change Suggestion of a solution to the bug on WebUI related to non-displaying of metrics at large amount of operator parallelism. ## Brief change

[jira] [Updated] (FLINK-35902) WebUI Metrics RangeError on huge parallelism

2024-07-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35902: --- Labels: pull-request-available (was: ) > WebUI Metrics RangeError on huge parallelism > ---

Re: [PR] [FLINK-35902][ui] WebUI Metrics RangeError on huge parallelism [flink]

2024-07-25 Thread via GitHub
flinkbot commented on PR #25123: URL: https://github.com/apache/flink/pull/25123#issuecomment-2252045636 ## CI report: * 7809aeb8dcb4a42c89bb6a38bede0136fc6631d0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-35016] catalog changes for model resource [flink]

2024-07-25 Thread via GitHub
lihaosky commented on code in PR #25036: URL: https://github.com/apache/flink/pull/25036#discussion_r1692573488 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Catalog.java: ## @@ -790,4 +792,126 @@ void alterPartitionColumnStatistics(

[jira] [Updated] (FLINK-35901) Setting web.submit.enable to false prevents FlinkSessionJobs from working

2024-07-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35901: -- Component/s: Kubernetes Operator > Setting web.submit.enable to false prevents FlinkSessionJob

[jira] [Commented] (FLINK-35899) Accumulated TumblingProcessingTimeWindows in the state for a few days

2024-07-25 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868862#comment-17868862 ] Zakelly Lan commented on FLINK-35899: - [~pnowojski] Does FLINK-20217 or FLIP-443 hel

[jira] [Updated] (FLINK-35902) WebUI Metrics RangeError on huge parallelism

2024-07-25 Thread Sergey Paryshev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Paryshev updated FLINK-35902: Description: Displaying metrics with high parallelism causes a RangeError (looks like stac

<    1   2