[jira] [Assigned] (FLINK-36070) Modifying web UI to adapt to Incremental JobGraph Generation

2024-11-14 Thread Junrui Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-36070: -- Assignee: Yu Chen > Modifying web UI to adapt to Incremental JobGraph Generation > --

Re: [PR] [hotfix] Remove DefaultExecutionGraph's jobType [flink]

2024-11-14 Thread via GitHub
flinkbot commented on PR #25657: URL: https://github.com/apache/flink/pull/25657#issuecomment-2478119348 ## CI report: * 107c9653d5148dc9467e6800c372f507d36aee30 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [hotfix] Remove DefaultExecutionGraph's jobType [flink]

2024-11-14 Thread via GitHub
huyuanfeng2018 opened a new pull request, #25657: URL: https://github.com/apache/flink/pull/25657 ## What is the purpose of the change Remove DefaultExecutionGraph's jobType (added with https://github.com/apache/flink/pull/24718) ## Brief change log Remove D

Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc]

2024-11-14 Thread via GitHub
beryllw commented on PR #3723: URL: https://github.com/apache/flink-cdc/pull/3723#issuecomment-2478113584 If this PR passes, I will rebase after https://github.com/apache/flink-cdc/pull/3728. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch pipeline sink support authentication [flink-cdc]

2024-11-14 Thread via GitHub
beryllw commented on PR #3728: URL: https://github.com/apache/flink-cdc/pull/3728#issuecomment-2478111086 fix NPE bug -- 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 uns

Re: [PR] [FLINK-35966][runtime] Introduce the TASKS for TaskManagerLoadBalanceMode enum [flink]

2024-11-14 Thread via GitHub
RocMarshal commented on PR #25647: URL: https://github.com/apache/flink/pull/25647#issuecomment-2478033320 Thank @zhuzhurk for the reply. > The feature freeze date has been postponed to 2025-01-13[1]. Will it give enough time to complete the FLIP? Currently we only have one cor

Re: [PR] [FLINK-36066][runtime] Introducing the AdaptiveGraphManager component [flink]

2024-11-14 Thread via GitHub
noorall commented on PR #25414: URL: https://github.com/apache/flink/pull/25414#issuecomment-2478011261 > Thank @noorall for the update. Such a complex refactoring is no easy task. I've left some comments, please take a look Thanks for your review. The PR has been updated according to

[jira] [Commented] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP

2024-11-14 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898462#comment-17898462 ] Weijie Guo commented on FLINK-36628: https://dev.azure.com/apache-flink/apache-flink

Re: [PR] [FLINK-36546] Handle batch sources in DataSinkTranslator [flink-cdc]

2024-11-14 Thread via GitHub
morozov commented on PR #3646: URL: https://github.com/apache/flink-cdc/pull/3646#issuecomment-2477835340 @lvyanquan how do we proceed with this change? I propose that you verify the correctness of fix by reverting the fix and running the updated test. Then I drop the commit. Otherwise, can

Re: [PR] [FLINK-35966][runtime] Introduce the TASKS for TaskManagerLoadBalanceMode enum [flink]

2024-11-14 Thread via GitHub
zhuzhurk commented on PR #25647: URL: https://github.com/apache/flink/pull/25647#issuecomment-2477797783 > Thanks @zhuzhurk @1996fanrui for the comments. > > Please let me to synchronize the background information and introduce the reasons for this change. > > The feature freez

[jira] (FLINK-35592) MysqlDebeziumTimeConverter miss timezone convert to timestamp

2024-11-14 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35592 ] Ruan Hang deleted comment on FLINK-35592: --- was (Author: ruanhang1993): release-3.2: 452bceaa2d520b9a2dce841c91527c249a23f153 > MysqlDebeziumTimeConverter miss timezone convert to timestamp > -

Re: [PR] [FLINK-35317][cli] Supports submitting multiple pipeline jobs at once [flink-cdc]

2024-11-14 Thread via GitHub
github-actions[bot] commented on PR #3306: URL: https://github.com/apache/flink-cdc/pull/3306#issuecomment-2477662338 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [FLINK-16155][docs] Translate "Operator/Process Function" into Chinese [flink]

2024-11-14 Thread via GitHub
liboshuai01 commented on PR #25624: URL: https://github.com/apache/flink/pull/25624#issuecomment-2477666527 @PatrickRen Excuse me, do you have time to take a look at this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

Re: [PR] Handle map and array types binary record data [flink-cdc]

2024-11-14 Thread via GitHub
umeshdangat commented on PR #3434: URL: https://github.com/apache/flink-cdc/pull/3434#issuecomment-2477662551 @loserwang1024 @leonardBang can we re-open this? I would still like to get this looked at and merged as I feel it is valuable to handle MapData and ArrayData in BinaryRecordData (as

[jira] [Resolved] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-11-14 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-34466. - Fix Version/s: kafka-3.4.0 Release Note: Kafka connector now provides full OpenLineage metad

Re: [PR] [docs] Add schema evolution type supporting status for pipeline sink connectors [flink-cdc]

2024-11-14 Thread via GitHub
github-actions[bot] commented on PR #3475: URL: https://github.com/apache/flink-cdc/pull/3475#issuecomment-2477662173 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [oracle]Upgrade oracle-chunk to use rowid sharding to determine imbalance [flink-cdc]

2024-11-14 Thread via GitHub
github-actions[bot] closed pull request #3545: [oracle]Upgrade oracle-chunk to use rowid sharding to determine imbalance URL: https://github.com/apache/flink-cdc/pull/3545 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

Re: [PR] [FLINK-35633][cli] Verify YAML pipeline definitions early [flink-cdc]

2024-11-14 Thread via GitHub
github-actions[bot] commented on PR #3429: URL: https://github.com/apache/flink-cdc/pull/3429#issuecomment-2477662278 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [oracle]Upgrade oracle-chunk to use rowid sharding to determine imbalance [flink-cdc]

2024-11-14 Thread via GitHub
github-actions[bot] commented on PR #3545: URL: https://github.com/apache/flink-cdc/pull/3545#issuecomment-2477662127 This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encou

[jira] [Assigned] (FLINK-36729) Add CompiledPlan annotations to BatchExecPythonCorrelate

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36729: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecPythonCorrelate >

[jira] [Assigned] (FLINK-36730) Add CompiledPlan annotations to BatchExecPythonGroupAggregate

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36730: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecPythonGroupAggrega

Re: [PR] [FLINK-29110] Use StatefulSet instead of Deployment to deploy JM and … [flink-kubernetes-operator]

2024-11-14 Thread via GitHub
nviswanath-roblox commented on PR #357: URL: https://github.com/apache/flink-kubernetes-operator/pull/357#issuecomment-2477317283 > @navinvishy , I think this PR / approach does not provide a comprehensive solution as it only works for standalone mode which is strictly inferior to the nati

[jira] [Commented] (FLINK-36552) Fix Table API OVER window support in batch mode

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898409#comment-17898409 ] Jim Hughes commented on FLINK-36552: Does this relate to https://issues.apache.org/j

[jira] [Assigned] (FLINK-36731) Add CompiledPlan annotations to BatchExecPythonGroupWindowAggregate

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36731: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecPythonGroupWindowA

[PR] Upgrade Kafka connector to 3.4.0 [flink-web]

2024-11-14 Thread via GitHub
AHeise opened a new pull request, #763: URL: https://github.com/apache/flink-web/pull/763 (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, e-mai

[jira] [Updated] (FLINK-35797) FLIP-456: CompiledPlan support for Batch Execution Mode

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-35797: --- Description: The CompiledPlan feature, introduced in FLIP-190: Support Version Upgrades for Table A

[jira] [Created] (FLINK-36731) Add CompiledPlan annotations to BatchExecPythonGroupWindowAggregate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36731: -- Summary: Add CompiledPlan annotations to BatchExecPythonGroupWindowAggregate Key: FLINK-36731 URL: https://issues.apache.org/jira/browse/FLINK-36731 Project: Flink

[jira] [Updated] (FLINK-36728) Add CompiledPlan annotations to BatchExecPythonCalc

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-36728: --- Description: (was: In addition to the annotations, implement the BatchRestoreTest for this opera

[jira] [Assigned] (FLINK-36728) Add CompiledPlan annotations to BatchExecPythonCalc

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36728: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecPythonCalc > -

[jira] [Created] (FLINK-36732) Add CompiledPlan annotations to BatchExecPythonOverAggregate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36732: -- Summary: Add CompiledPlan annotations to BatchExecPythonOverAggregate Key: FLINK-36732 URL: https://issues.apache.org/jira/browse/FLINK-36732 Project: Flink Iss

[jira] [Assigned] (FLINK-36732) Add CompiledPlan annotations to BatchExecPythonOverAggregate

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36732: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecPythonOverAggregat

[jira] [Created] (FLINK-36729) Add CompiledPlan annotations to BatchExecPythonCorrelate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36729: -- Summary: Add CompiledPlan annotations to BatchExecPythonCorrelate Key: FLINK-36729 URL: https://issues.apache.org/jira/browse/FLINK-36729 Project: Flink Issue Ty

[jira] [Created] (FLINK-36727) Add a completeness test to cover BatchExecNodes

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36727: -- Summary: Add a completeness test to cover BatchExecNodes Key: FLINK-36727 URL: https://issues.apache.org/jira/browse/FLINK-36727 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-36730) Add CompiledPlan annotations to BatchExecPythonGroupAggregate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36730: -- Summary: Add CompiledPlan annotations to BatchExecPythonGroupAggregate Key: FLINK-36730 URL: https://issues.apache.org/jira/browse/FLINK-36730 Project: Flink Is

[jira] [Created] (FLINK-36728) Add CompiledPlan annotations to BatchExecPythonCalc

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36728: -- Summary: Add CompiledPlan annotations to BatchExecPythonCalc Key: FLINK-36728 URL: https://issues.apache.org/jira/browse/FLINK-36728 Project: Flink Issue Type: S

[jira] [Created] (FLINK-36726) Add CompiledPlan annotations to BatchExecInputAdapter

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36726: -- Summary: Add CompiledPlan annotations to BatchExecInputAdapter Key: FLINK-36726 URL: https://issues.apache.org/jira/browse/FLINK-36726 Project: Flink Issue Type:

[jira] [Created] (FLINK-36724) Add CompiledPlan annotations to BatchExecExecutionOrderEnforcer

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36724: -- Summary: Add CompiledPlan annotations to BatchExecExecutionOrderEnforcer Key: FLINK-36724 URL: https://issues.apache.org/jira/browse/FLINK-36724 Project: Flink

[jira] [Created] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36725: -- Summary: Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes Key: FLINK-36725 URL: https://issues.apache.org/jira/browse/FLINK-36725 Project: Flink

[jira] [Created] (FLINK-36723) Add CompiledPlan annotations to BatchExecDynamicFilteringDataCollector

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36723: -- Summary: Add CompiledPlan annotations to BatchExecDynamicFilteringDataCollector Key: FLINK-36723 URL: https://issues.apache.org/jira/browse/FLINK-36723 Project: Flink

[jira] [Created] (FLINK-36721) Add CompiledPlan annotations to BatchExecHashWindowAggregate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36721: -- Summary: Add CompiledPlan annotations to BatchExecHashWindowAggregate Key: FLINK-36721 URL: https://issues.apache.org/jira/browse/FLINK-36721 Project: Flink Iss

[jira] [Created] (FLINK-36722) Add CompiledPlan annotations to BatchExecSortWindowAggregate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36722: -- Summary: Add CompiledPlan annotations to BatchExecSortWindowAggregate Key: FLINK-36722 URL: https://issues.apache.org/jira/browse/FLINK-36722 Project: Flink Iss

[jira] [Created] (FLINK-36720) Add CompiledPlan annotations to BatchExecWindowTableFunction

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36720: -- Summary: Add CompiledPlan annotations to BatchExecWindowTableFunction Key: FLINK-36720 URL: https://issues.apache.org/jira/browse/FLINK-36720 Project: Flink Iss

[jira] [Created] (FLINK-36718) Add CompiledPlan annotations to BatchExecLookupJoin and BatchExecSortMergeJoin

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36718: -- Summary: Add CompiledPlan annotations to BatchExecLookupJoin and BatchExecSortMergeJoin Key: FLINK-36718 URL: https://issues.apache.org/jira/browse/FLINK-36718 Project: F

[jira] [Created] (FLINK-36719) Add CompiledPlan annotations to BatchExecMultipleInput

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36719: -- Summary: Add CompiledPlan annotations to BatchExecMultipleInput Key: FLINK-36719 URL: https://issues.apache.org/jira/browse/FLINK-36719 Project: Flink Issue Type

Re: [PR] [FLINK-36287] Disallow UC for inner sink channels [1.19] [flink]

2024-11-14 Thread via GitHub
AHeise merged PR #25654: URL: https://github.com/apache/flink/pull/25654 -- 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-36717) Add health check to detect tasks stuck in DEPLOYING state

2024-11-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898324#comment-17898324 ] Maximilian Michels commented on FLINK-36717: CC [~gyfora]  > Add health che

[jira] [Commented] (FLINK-36287) Sink with topologies should not participate in UC

2024-11-14 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898359#comment-17898359 ] Arvid Heise commented on FLINK-36287: - Merged into 1.19 as 3c968e9..de175b4. > Sink

[jira] [Updated] (FLINK-36287) Sink with topologies should not participate in UC

2024-11-14 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-36287: Fix Version/s: 1.19.2 > Sink with topologies should not participate in UC > --

Re: [PR] [FLINK-36709][parquet] fix parquet can not read row with last column is array. [flink]

2024-11-14 Thread via GitHub
xccui merged PR #25651: URL: https://github.com/apache/flink/pull/25651 -- 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] [Resolved] (FLINK-36709) Flink parquet will throw exception when reading nested row data with last column is array.

2024-11-14 Thread Xingcan Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-36709. - Assignee: Wenchao Wu Resolution: Fixed Fixed in master b53875fcfd8c3d721ec44d829ed6707b696

Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]

2024-11-14 Thread via GitHub
snuyanzin commented on code in PR #24255: URL: https://github.com/apache/flink/pull/24255#discussion_r1842560994 ## flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj: ## @@ -4935,103 +5031,75 @@ SqlIntervalQualifier IntervalQualifierStart() : } } -/** - *

Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]

2024-11-14 Thread via GitHub
snuyanzin commented on code in PR #24255: URL: https://github.com/apache/flink/pull/24255#discussion_r1842578557 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/JoinDependentConditionDerivationRuleTest.xml: ## @@ -120,7 +12

Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]

2024-11-14 Thread via GitHub
snuyanzin commented on code in PR #24255: URL: https://github.com/apache/flink/pull/24255#discussion_r1842568404 ## flink-table/flink-table-calcite-bridge/pom.xml: ## @@ -45,23 +45,23 @@ under the License. ${calcite.version}

Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]

2024-11-14 Thread via GitHub
snuyanzin commented on code in PR #24255: URL: https://github.com/apache/flink/pull/24255#discussion_r1842560994 ## flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj: ## @@ -4935,103 +5031,75 @@ SqlIntervalQualifier IntervalQualifierStart() : } } -/** - *

Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]

2024-11-14 Thread via GitHub
snuyanzin commented on code in PR #24255: URL: https://github.com/apache/flink/pull/24255#discussion_r1842559184 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/validate/FlinkSqlConformance.java: ## @@ -166,4 +166,14 @@ public boolean allowQualifyingCom

Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]

2024-11-14 Thread via GitHub
snuyanzin commented on code in PR #24255: URL: https://github.com/apache/flink/pull/24255#discussion_r1842558180 ## flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj: ## @@ -6576,11 +6649,127 @@ SqlCall TimestampDiffFunctionCall() : } } +/** + * Parses a

[jira] [Assigned] (FLINK-36717) Add health check to detect tasks stuck in DEPLOYING state

2024-11-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-36717: -- Assignee: Maximilian Michels > Add health check to detect tasks stuck in DEPL

[jira] [Created] (FLINK-36717) Add health check to detect tasks stuck in DEPLOYING state

2024-11-14 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-36717: -- Summary: Add health check to detect tasks stuck in DEPLOYING state Key: FLINK-36717 URL: https://issues.apache.org/jira/browse/FLINK-36717 Project: Flink

[jira] [Commented] (FLINK-36716) Address vulnerabilities in Flink UI

2024-11-14 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898315#comment-17898315 ] Ferenc Csaky commented on FLINK-36716: -- Assigned to you [~mehdidb1993], thanks for

[jira] [Assigned] (FLINK-36716) Address vulnerabilities in Flink UI

2024-11-14 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky reassigned FLINK-36716: Assignee: Mehdi > Address vulnerabilities in Flink UI > -

Re: [PR] [FLINK-36646][helm] Add required Java Opts to allow Java 17 based job images [flink-kubernetes-operator]

2024-11-14 Thread via GitHub
tomncooper commented on code in PR #915: URL: https://github.com/apache/flink-kubernetes-operator/pull/915#discussion_r1842286805 ## helm/flink-kubernetes-operator/conf/flink-conf.yaml: ## @@ -21,9 +21,11 @@ taskmanager.numberOfTaskSlots: 1 parallelism.default: 1 # These pa

Re: [PR] [FLINK-36646][helm] Add required Java Opts to allow Java 17 based job images [flink-kubernetes-operator]

2024-11-14 Thread via GitHub
tomncooper commented on code in PR #915: URL: https://github.com/apache/flink-kubernetes-operator/pull/915#discussion_r1842285729 ## helm/flink-kubernetes-operator/conf/flink-conf.yaml: ## @@ -21,9 +21,11 @@ taskmanager.numberOfTaskSlots: 1 parallelism.default: 1 # These pa

[jira] [Commented] (FLINK-36716) Address vulnerabilities in Flink UI

2024-11-14 Thread Mehdi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898292#comment-17898292 ] Mehdi commented on FLINK-36716: --- I currently started working on this issue to remove first

[jira] [Updated] (FLINK-36716) Address vulnerabilities in Flink UI

2024-11-14 Thread Mehdi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mehdi updated FLINK-36716: -- Priority: Major (was: Minor) > Address vulnerabilities in Flink UI > --- > >

Re: [PR] [FLINK-36047] Add CompiledPlan annotations to BatchExecOverAggregate [flink]

2024-11-14 Thread via GitHub
jnh5y commented on code in PR #25635: URL: https://github.com/apache/flink/pull/25635#discussion_r1842242439 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/OverAggregateTestPrograms.java: ## @@ -0,0 +1,433 @@ +/* + * Licens

[jira] [Created] (FLINK-36716) Address vulnerabilities in Flink UI

2024-11-14 Thread Mehdi (Jira)
Mehdi created FLINK-36716: - Summary: Address vulnerabilities in Flink UI Key: FLINK-36716 URL: https://issues.apache.org/jira/browse/FLINK-36716 Project: Flink Issue Type: Improvement Compo

Re: [PR] [FLINK-36146][connector] Fix SingleThreadFetcherManager race condition [flink]

2024-11-14 Thread via GitHub
kimgr commented on PR #25340: URL: https://github.com/apache/flink/pull/25340#issuecomment-2476392521 @becketqin Ping -- 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 uns

[jira] [Created] (FLINK-36715) Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite upgrade to 1.33

2024-11-14 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-36715: --- Summary: Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite upgrade to 1.33 Key: FLINK-36715 URL: https://issues.apache.org/jira/browse/FLINK-3671

Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]

2024-11-14 Thread via GitHub
snuyanzin commented on code in PR #24255: URL: https://github.com/apache/flink/pull/24255#discussion_r1842186049 ## flink-table/flink-table-planner/src/main/java/org/apache/calcite/rex/RexUtil.java: ## @@ -0,0 +1,3176 @@ +/* + * Licensed to the Apache Software Foundation (ASF) u

Re: [PR] [FLINK-36710] Log job ID in RecreateOnResetOperatorCoordinator [flink]

2024-11-14 Thread via GitHub
pnowojski commented on code in PR #25652: URL: https://github.com/apache/flink/pull/25652#discussion_r1842181428 ## flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java: ## @@ -149,9 +149,7 @@ void testJobIDLogging(@InjectClusterClient ClusterClient clus

Re: [PR] [FLINK-29110] Use StatefulSet instead of Deployment to deploy JM and … [flink-kubernetes-operator]

2024-11-14 Thread via GitHub
gyfora commented on PR #357: URL: https://github.com/apache/flink-kubernetes-operator/pull/357#issuecomment-2476238416 @navinvishy , I think this PR / approach does not provide a comprehensive solution as it only works for standalone mode which is strictly inferior to the native integratio

Re: [PR] [FLINK-36646][helm] Add required Java Opts to allow Java 17 based job images [flink-kubernetes-operator]

2024-11-14 Thread via GitHub
gyfora commented on code in PR #915: URL: https://github.com/apache/flink-kubernetes-operator/pull/915#discussion_r1842137751 ## helm/flink-kubernetes-operator/conf/flink-conf.yaml: ## @@ -21,9 +21,11 @@ taskmanager.numberOfTaskSlots: 1 parallelism.default: 1 # These parame

Re: [PR] [FLINK-36047] Add CompiledPlan annotations to BatchExecOverAggregate [flink]

2024-11-14 Thread via GitHub
twalthr commented on code in PR #25635: URL: https://github.com/apache/flink/pull/25635#discussion_r1842136272 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/OverAggregateTestPrograms.java: ## @@ -0,0 +1,433 @@ +/* + * Lice

Re: [PR] [FLINK-28897] [TABLE-SQL] Fail to use udf in added jar when enabling checkpoint [flink]

2024-11-14 Thread via GitHub
flinkbot commented on PR #25656: URL: https://github.com/apache/flink/pull/25656#issuecomment-2476046578 ## CI report: * eafd41fefd49f8e006c13525634c3228dbc0e65f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-28897] [TABLE-SQL] Fail to use udf in added jar when enabling checkpoint [flink]

2024-11-14 Thread via GitHub
ammu20-dev opened a new pull request, #25656: URL: https://github.com/apache/flink/pull/25656 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

Re: [PR] [FLINK-36714][state] Ignore interrupted in sstmerge.CompactionScheduler#stop [flink]

2024-11-14 Thread via GitHub
flinkbot commented on PR #25655: URL: https://github.com/apache/flink/pull/25655#issuecomment-2476000924 ## CI report: * e9707f21fd43ad565fa4d31644c276c4fad220bb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-36714) sstmerge/CompactionScheduler termination can be interrupted

2024-11-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36714: --- Labels: pull-request-available (was: ) > sstmerge/CompactionScheduler termination can be in

[PR] [FLINK-36714][state] Ignore interrupted in sstmerge.CompactionScheduler#stop [flink]

2024-11-14 Thread via GitHub
rkhachatryan opened a new pull request, #25655: URL: https://github.com/apache/flink/pull/25655 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring th

[jira] [Created] (FLINK-36714) sstmerge/CompactionScheduler termination can be interrupted

2024-11-14 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-36714: - Summary: sstmerge/CompactionScheduler termination can be interrupted Key: FLINK-36714 URL: https://issues.apache.org/jira/browse/FLINK-36714 Project: Flink

Re: [PR] [FLINK-36287] Disallow UC for inner sink channels [1.19] [flink]

2024-11-14 Thread via GitHub
flinkbot commented on PR #25654: URL: https://github.com/apache/flink/pull/25654#issuecomment-2475935904 ## CI report: * 824fe92bc1731a2f56e9ec512f0e32d01303b124 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-36287] Disallow UC for inner sink channels [1.19] [flink]

2024-11-14 Thread via GitHub
AHeise opened a new pull request, #25654: URL: https://github.com/apache/flink/pull/25654 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-11-14 Thread via GitHub
pawel-big-lebowski commented on PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#issuecomment-2475858452 Awesome. @AHeise Thank you for your feedback and cooperation on that. -- This is an automated message from the Apache Git Service. To respond to the message, ple

Re: [PR] [FLINK-36285][doris] Fix unable to alter column type without default value specified [flink-cdc]

2024-11-14 Thread via GitHub
yuxiqian commented on PR #3725: URL: https://github.com/apache/flink-cdc/pull/3725#issuecomment-2475868296 Upgrading dependency version might break compatibility. Just exclude this from 3.2.1. -- This is an automated message from the Apache Git Service. To respond to the message, please l

Re: [PR] [FLINK-36285][doris] Fix unable to alter column type without default value specified [flink-cdc]

2024-11-14 Thread via GitHub
yuxiqian closed pull request #3725: [FLINK-36285][doris] Fix unable to alter column type without default value specified URL: https://github.com/apache/flink-cdc/pull/3725 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[jira] [Closed] (FLINK-32496) Sources with idleness and alignment always wait for alignment when part of multiple sources is idle

2024-11-14 Thread haishui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] haishui closed FLINK-32496. --- > Sources with idleness and alignment always wait for alignment when part of > multiple sources is idle > -

[jira] [Closed] (FLINK-35497) The wrong enum value was used to get month in timestampDiff

2024-11-14 Thread haishui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] haishui closed FLINK-35497. --- Resolution: Won't Do > The wrong enum value was used to get month in timestampDiff > ---

Re: [PR] [FLINK-36285][doris] Fix unable to alter column type without default value specified [flink-cdc]

2024-11-14 Thread via GitHub
leonardBang merged PR #3691: URL: https://github.com/apache/flink-cdc/pull/3691 -- 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

Re: [PR] [FLINK-36565] Route module allows merging Decimals with various precisions [flink-cdc]

2024-11-14 Thread via GitHub
leonardBang merged PR #3651: URL: https://github.com/apache/flink-cdc/pull/3651 -- 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

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-11-14 Thread via GitHub
boring-cyborg[bot] commented on PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#issuecomment-2475731290 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[jira] [Updated] (FLINK-36285) Modify column type failed when downstream's column with defalut value

2024-11-14 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36285: --- Fix Version/s: cdc-3.3.0 cdc-3.2.1 > Modify column type failed when downstream's

[jira] [Commented] (FLINK-36285) Modify column type failed when downstream's column with defalut value

2024-11-14 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898189#comment-17898189 ] Leonard Xu commented on FLINK-36285: master: 8e6c361f961966c25c9c34ffecdfc87cf2b599a

[jira] [Assigned] (FLINK-36285) Modify column type failed when downstream's column with defalut value

2024-11-14 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36285: -- Assignee: yux > Modify column type failed when downstream's column with defalut value > -

[jira] [Commented] (FLINK-36565) Pipeline YAML should allow merging decimal with different precisions

2024-11-14 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898188#comment-17898188 ] Leonard Xu commented on FLINK-36565: master: 4bd3a2347bf4a8235a0cc4cd3c3b74447c969e3

Re: [PR] [FLINK-36285][doris] Fix unable to alter column type without default value specified [flink-cdc]

2024-11-14 Thread via GitHub
leonardBang commented on PR #3691: URL: https://github.com/apache/flink-cdc/pull/3691#issuecomment-2475735672 CI passed, merging... -- 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 co

[jira] [Updated] (FLINK-36565) Pipeline YAML should allow merging decimal with different precisions

2024-11-14 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36565: --- Affects Version/s: cdc-3.1.1 > Pipeline YAML should allow merging decimal with different precisions

[jira] [Updated] (FLINK-36565) Pipeline YAML should allow merging decimal with different precisions

2024-11-14 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36565: --- Fix Version/s: cdc-3.3.0 cdc-3.2.1 > Pipeline YAML should allow merging decimal w

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-11-14 Thread via GitHub
AHeise commented on PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#issuecomment-2475731822 Thank you very much for your contribution (and patience). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-11-14 Thread via GitHub
AHeise merged PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130 -- 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...@

Re: [PR] [FLINK-25920] Ignore duplicate EOI in SinkWriter [1.19] [flink]

2024-11-14 Thread via GitHub
AHeise merged PR #25627: URL: https://github.com/apache/flink/pull/25627 -- 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

[PR] use lazy initialization to resolve circular dependency between the `DataFieldSerializer`, `DataTypeSerializer`, and `RowTypeSerializer` classes that causes NPE for certain RowTypes like nested ro

2024-11-14 Thread via GitHub
umeshdangat opened a new pull request, #3400: URL: https://github.com/apache/flink-cdc/pull/3400 There is a circular dependency between the `DataFieldSerializer`, `DataTypeSerializer`, and `RowTypeSerializer` classes. This circular dependency can lead to incomplete initialization of the ser

  1   2   >