[jira] [Closed] (FLINK-34564) Unstable test case TableSourceITCase#testTableHintWithLogicalTableScanReuse

2024-03-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-34564. - Resolution: Duplicate Thanks for reporting this, [~RocMarshal]. This test is especially flaky

[jira] [Commented] (FLINK-34429) Adding K8S Annotations to Internal Service

2024-03-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823893#comment-17823893 ] Danny Cranmer commented on FLINK-34429: --- Merged commit

[jira] [Resolved] (FLINK-34429) Adding K8S Annotations to Internal Service

2024-03-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-34429. --- Resolution: Done > Adding K8S Annotations to Internal Service >

Re: [PR] [FLINK-34429] [flink-kubernetes] Adding K8S Annotations to Internal Service [flink]

2024-03-05 Thread via GitHub
dannycranmer merged PR #24348: URL: https://github.com/apache/flink/pull/24348 -- 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:

[jira] [Commented] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-03-05 Thread Sebastien Pereira (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823892#comment-17823892 ] Sebastien Pereira commented on FLINK-34016: --- Hi [~xuyangzhong] any change for the fix to land

[jira] [Comment Edited] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-03-05 Thread Sebastien Pereira (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823892#comment-17823892 ] Sebastien Pereira edited comment on FLINK-34016 at 3/6/24 7:47 AM: --- Hi

[jira] [Created] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC

2024-03-05 Thread Hang Ruan (Jira)
Hang Ruan created FLINK-34585: - Summary: [JUnit5 Migration] Module: Flink CDC Key: FLINK-34585 URL: https://issues.apache.org/jira/browse/FLINK-34585 Project: Flink Issue Type: Sub-task

Re: [PR] [FLINK-34413] Remove HBase 1.x connector files and deps [flink-connector-hbase]

2024-03-05 Thread via GitHub
Tan-JiaLiang commented on code in PR #42: URL: https://github.com/apache/flink-connector-hbase/pull/42#discussion_r1513905416 ## docs/content.zh/docs/connectors/table/hbase.md: ## Review Comment: @ferenc-csaky I think just remove lines 21-22 instead of the whole file,

[jira] [Updated] (FLINK-34584) Change package name to org.apache.flink.cdc

2024-03-05 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34584: --- Fix Version/s: cdc-3.1.0 > Change package name to org.apache.flink.cdc >

[jira] [Assigned] (FLINK-34584) Change package name to org.apache.flink.cdc

2024-03-05 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-34584: -- Assignee: Hang Ruan > Change package name to org.apache.flink.cdc >

[jira] [Created] (FLINK-34584) Change package name to org.apache.flink.cdc

2024-03-05 Thread Hang Ruan (Jira)
Hang Ruan created FLINK-34584: - Summary: Change package name to org.apache.flink.cdc Key: FLINK-34584 URL: https://issues.apache.org/jira/browse/FLINK-34584 Project: Flink Issue Type: Sub-task

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-03-05 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1980164212 @JingGe sure,could you help me do the "Squash and merge" action? thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] Revert "[FLINK-33532][network] Move the serialization of ShuffleDescr… [flink]

2024-03-05 Thread via GitHub
KarmaGYZ commented on PR #24441: URL: https://github.com/apache/flink/pull/24441#issuecomment-1980162303 cc @zhuzhurk -- 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

Re: [PR] Revert "[FLINK-33532][network] Move the serialization of ShuffleDescr… [flink]

2024-03-05 Thread via GitHub
flinkbot commented on PR #24441: URL: https://github.com/apache/flink/pull/24441#issuecomment-1980160690 ## CI report: * c1974425fb043c911042633fd255098988c09e0e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34268] Add a test to verify if restore test exists for ExecNode [flink]

2024-03-05 Thread via GitHub
bvarghese1 commented on code in PR #24219: URL: https://github.com/apache/flink/pull/24219#discussion_r1513875190 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java: ## @@ -0,0 +1,129 @@ +/* + *

Re: [PR] [FLINK-34268] Add a test to verify if restore test exists for ExecNode [flink]

2024-03-05 Thread via GitHub
bvarghese1 commented on code in PR #24219: URL: https://github.com/apache/flink/pull/24219#discussion_r1513874825 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java: ## @@ -0,0 +1,129 @@ +/* + *

[PR] Revert "[FLINK-33532][network] Move the serialization of ShuffleDescr… [flink]

2024-03-05 Thread via GitHub
caodizhou opened a new pull request, #24441: URL: https://github.com/apache/flink/pull/24441 …iptorGroup out of the RPC main thread]" This reverts commit d18a4bfe596fc580f8280750fa3bfa22007671d9. ## What is the purpose of the change *(For example: This pull

[jira] [Commented] (FLINK-34576) Flink deployment keep staying at RECONCILING/STABLE status

2024-03-05 Thread chenyuzhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823864#comment-17823864 ] chenyuzhi commented on FLINK-34576: --- I have check our operaotr's log, got some error log: {code:java}

[jira] [Updated] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

2024-03-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34582: Priority: Blocker (was: Critical) > release build tools lost the newly added py3.11 packages for

[jira] [Closed] (FLINK-20399) Migrate test_sql_client.sh

2024-03-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20399. --- Assignee: (was: Lorenzo Affetti) Resolution: Fixed > Migrate test_sql_client.sh >

[jira] [Commented] (FLINK-20399) Migrate test_sql_client.sh

2024-03-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823859#comment-17823859 ] Jark Wu commented on FLINK-20399: - [~lorenzo.affetti] Yes, I think so. Thank you for the reminder. >

Re: [PR] [FLINK-34516] Move CheckpointingMode to flink-core [flink]

2024-03-05 Thread via GitHub
Zakelly commented on code in PR #24381: URL: https://github.com/apache/flink/pull/24381#discussion_r1513823880 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java: ## @@ -178,7 +178,9 @@ public boolean isCheckpointingEnabled()

[jira] [Created] (FLINK-34583) Bug for dynamic table option hints with multiple CTEs

2024-03-05 Thread Xingcan Cui (Jira)
Xingcan Cui created FLINK-34583: --- Summary: Bug for dynamic table option hints with multiple CTEs Key: FLINK-34583 URL: https://issues.apache.org/jira/browse/FLINK-34583 Project: Flink Issue

[jira] [Updated] (FLINK-34583) Bug for dynamic table option hints with multiple CTEs

2024-03-05 Thread Xingcan Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-34583: Description: The table options hints don't work well with multiple WITH clauses referring to the

Re: [PR] [FLINK-34566] Pass a FixedThreadPool to set reconciliation parallelism correctly [flink-kubernetes-operator]

2024-03-05 Thread via GitHub
ysymi commented on code in PR #790: URL: https://github.com/apache/flink-kubernetes-operator/pull/790#discussion_r1513802450 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/FlinkOperatorTest.java: ## @@ -70,10 +70,21 @@ public void

Re: [PR] [FLINK-34516] Move CheckpointingMode to flink-core [flink]

2024-03-05 Thread via GitHub
masteryhx commented on code in PR #24381: URL: https://github.com/apache/flink/pull/24381#discussion_r1513788931 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java: ## @@ -178,7 +178,9 @@ public boolean

Re: [PR] [FLINK-34413] Remove HBase 1.x connector files and deps [flink-connector-hbase]

2024-03-05 Thread via GitHub
Tan-JiaLiang commented on code in PR #42: URL: https://github.com/apache/flink-connector-hbase/pull/42#discussion_r1513778129 ## docs/content.zh/docs/connectors/table/hbase.md: ## Review Comment: `docs/data/hbase.yml` we still have an inclusion of hbase-1.4 on 21-22, See

Re: [PR] [FLINK-34456][configuration]Move all checkpoint-related options into CheckpointingOptions [flink]

2024-03-05 Thread via GitHub
spoon-lz commented on PR #24374: URL: https://github.com/apache/flink/pull/24374#issuecomment-1980033057 @Zakelly A separate PR seems more reasonable, I will submit a separate PR to split `ExternalizedCheckpointCleanup` -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

2024-03-05 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-34582: - Fix Version/s: 1.19.0 > release build tools lost the newly added py3.11 packages for mac >

[jira] [Closed] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

2024-03-05 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-34582. Resolution: Fixed Merged into master via a9d9bab47a6b2a9520f7d2b6f3791690df50e214 Merged into

[jira] [Commented] (FLINK-34566) Flink Kubernetes Operator reconciliation parallelism setting not work

2024-03-05 Thread Fei Feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823848#comment-17823848 ] Fei Feng commented on FLINK-34566: -- OK, I have reviewed their changes.   > Flink Kubernetes Operator

[jira] [Commented] (FLINK-16627) Support only generate non-null values when serializing into JSON

2024-03-05 Thread yisha zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823845#comment-17823845 ] yisha zhou commented on FLINK-16627: [~libenchao]  Thanks a lot for your help! > Support only

Re: [PR] [FLINK-34582][realse][python] Updates cibuildwheel to support cpython 3.11 wheel package [flink]

2024-03-05 Thread via GitHub
HuangXingBo closed pull request #24439: [FLINK-34582][realse][python] Updates cibuildwheel to support cpython 3.11 wheel package URL: https://github.com/apache/flink/pull/24439 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [hotfix] [docs] Flink comment typo in pyflink datastream [flink]

2024-03-05 Thread via GitHub
flinkbot commented on PR #24440: URL: https://github.com/apache/flink/pull/24440#issuecomment-1980006049 ## CI report: * 6167e861d0f03efc743588946e39274abe48dab9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34582][realse][python] Updates cibuildwheel to support cpython 3.11 wheel package [flink]

2024-03-05 Thread via GitHub
HuangXingBo commented on PR #24439: URL: https://github.com/apache/flink/pull/24439#issuecomment-1980003795 https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=2229=artifacts=false=publishedArtifacts build in my azure pipeline -- This is an automated message from the

[PR] [hotfix] [docs] Flink comment typo in pyflink datastream [flink]

2024-03-05 Thread via GitHub
mynkyu opened a new pull request, #24440: URL: https://github.com/apache/flink/pull/24440 ## What is the purpose of the change - Comment typo fix PR ## Brief change log ASIS: `THe parallelism for this operator.` TOBE: `The parallelism for this operator.` ##

[jira] [Resolved] (FLINK-34184) Update copyright and license file

2024-03-05 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-34184. Resolution: Fixed Fixed in flink-cdc(master) via: a6c1b06e11004918cb6e5714ade3699e052e1aad >

[jira] [Updated] (FLINK-34184) Update copyright and license file

2024-03-05 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34184: --- Fix Version/s: cdc-3.1.0 > Update copyright and license file > - >

Re: [PR] [hotfix] [docs] Flink comment typo in pyflink datastream [flink]

2024-03-05 Thread via GitHub
mynkyu closed pull request #24434: [hotfix] [docs] Flink comment typo in pyflink datastream URL: https://github.com/apache/flink/pull/24434 -- 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

Re: [PR] [FLINK-34582][realse][python] Updates cibuildwheel to support cpython 3.11 wheel package [flink]

2024-03-05 Thread via GitHub
flinkbot commented on PR #24439: URL: https://github.com/apache/flink/pull/24439#issuecomment-1979991024 ## CI report: * 7b165aad01493ad32124c9e5b807c0f75a64aead UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32081) Compatibility between file-merging on and off across job runs

2024-03-05 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-32081: Fix Version/s: 1.20.0 (was: 1.19.0) > Compatibility between file-merging

[jira] [Updated] (FLINK-32083) Chinese translation of documentation of checkpoint file-merging

2024-03-05 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-32083: Fix Version/s: 1.20.0 (was: 1.19.0) > Chinese translation of documentation

[jira] [Updated] (FLINK-32082) Documentation of checkpoint file-merging

2024-03-05 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-32082: Fix Version/s: 1.20.0 (was: 1.19.0) > Documentation of checkpoint

[jira] [Updated] (FLINK-32080) Restoration of FileMergingSnapshotManager

2024-03-05 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-32080: Fix Version/s: 1.20.0 (was: 1.19.0) > Restoration of

[jira] [Updated] (FLINK-32079) Read/write checkpoint metadata of merged files

2024-03-05 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-32079: Fix Version/s: 1.20.0 (was: 1.19.0) > Read/write checkpoint metadata of

[jira] [Updated] (FLINK-32074) Support file merging across checkpoints

2024-03-05 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-32074: Fix Version/s: 1.20.0 (was: 1.19.0) > Support file merging across

[jira] [Updated] (FLINK-32076) Add file pool for concurrent file reusing

2024-03-05 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-32076: Fix Version/s: 1.20.0 (was: 1.19.0) > Add file pool for concurrent file

[jira] [Updated] (FLINK-32078) Implement private state file merging

2024-03-05 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-32078: Fix Version/s: 1.20.0 (was: 1.19.0) > Implement private state file merging

[jira] [Updated] (FLINK-32077) Implement shared state file merging

2024-03-05 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-32077: Fix Version/s: 1.20.0 (was: 1.19.0) > Implement shared state file merging

[jira] [Updated] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

2024-03-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34582: --- Labels: pull-request-available (was: ) > release build tools lost the newly added py3.11

[PR] [FLINK-34582][realse][python] Updates cibuildwheel to support cpython 3.11 wheel package [flink]

2024-03-05 Thread via GitHub
HuangXingBo opened a new pull request, #24439: URL: https://github.com/apache/flink/pull/24439 ## What is the purpose of the change *This pull request will update cibuildwheel to support cpython 3.11 wheel package* ## Brief change log - *Updates cibuildwheel to

[jira] [Created] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

2024-03-05 Thread lincoln lee (Jira)
lincoln lee created FLINK-34582: --- Summary: release build tools lost the newly added py3.11 packages for mac Key: FLINK-34582 URL: https://issues.apache.org/jira/browse/FLINK-34582 Project: Flink

Re: [PR] [FLINK-34456][configuration]Move all checkpoint-related options into CheckpointingOptions [flink]

2024-03-05 Thread via GitHub
Zakelly commented on PR #24374: URL: https://github.com/apache/flink/pull/24374#issuecomment-1979977569 > @Zakelly I also saw the conclusion of the discussion in the email. I will re-edit this PR after #24381 is merged. Another question is, "Split ExternalizedCheckpointCleanup out of

Re: [PR] [FLINK-34456][configuration]Move all checkpoint-related options into CheckpointingOptions [flink]

2024-03-05 Thread via GitHub
spoon-lz commented on PR #24374: URL: https://github.com/apache/flink/pull/24374#issuecomment-1979967662 @Zakelly I also saw the conclusion of the discussion in the email. I will re-edit this PR after #24381 is merged. Another question is, "Split ExternalizedCheckpointCleanup out of

[jira] [Closed] (FLINK-33210) Introduce lineage graph relevant interfaces

2024-03-05 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-33210. - Fix Version/s: 1.20.0 Resolution: Resolved Closed by 6b9c282b5090720a02b941586cb7f5389691dba9 >

Re: [PR] [hotfix][docs] Modify obvious errors in the doc. [flink]

2024-03-05 Thread via GitHub
flinkbot commented on PR #24438: URL: https://github.com/apache/flink/pull/24438#issuecomment-1979939628 ## CI report: * 4269bebf26d5b1fd9699183a4caef207e4071806 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-33210] Introduce lineage graph relevant interfaces [flink]

2024-03-05 Thread via GitHub
FangYongs merged PR #23626: URL: https://github.com/apache/flink/pull/23626 -- 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:

[PR] [hotfix][docs] Modify obvious errors in the doc. [flink]

2024-03-05 Thread via GitHub
damonxue opened a new pull request, #24438: URL: https://github.com/apache/flink/pull/24438 ## What is the purpose of the change Modify obvious errors in the doc. ## Brief change log *(for example:)* - *Apahe => Apache* ## Documentation - Does

[jira] [Created] (FLINK-34581) streaming code throws java.lang.reflect.InaccessibleObjectException

2024-03-05 Thread Henning Schmiedehausen (Jira)
Henning Schmiedehausen created FLINK-34581: -- Summary: streaming code throws java.lang.reflect.InaccessibleObjectException Key: FLINK-34581 URL: https://issues.apache.org/jira/browse/FLINK-34581

Re: [PR] [hotfix][docs] Modify obvious errors in the doc. [flink]

2024-03-05 Thread via GitHub
damonxue closed pull request #24425: [hotfix][docs] Modify obvious errors in the doc. URL: https://github.com/apache/flink/pull/24425 -- 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

[jira] [Commented] (FLINK-34530) Build Release Candidate: 1.19.0-rc1

2024-03-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823828#comment-17823828 ] lincoln lee commented on FLINK-34530: - Rechecked the python wheel packages  

Re: [PR] [hotfix][docs] Modify obvious errors in the doc. [flink]

2024-03-05 Thread via GitHub
damonxue closed pull request #24425: [hotfix][docs] Modify obvious errors in the doc. URL: https://github.com/apache/flink/pull/24425 -- 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

[jira] [Comment Edited] (FLINK-34517) environment configs ignored when calling procedure operation

2024-03-05 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823069#comment-17823069 ] luoyuxia edited comment on FLINK-34517 at 3/6/24 1:45 AM: -- 1.18:

Re: [PR] [FLINK-34517][table]fix environment configs ignored when calling procedure operation [flink]

2024-03-05 Thread via GitHub
luoyuxia merged PR #24397: URL: https://github.com/apache/flink/pull/24397 -- 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:

[jira] [Commented] (FLINK-34534) Vote on the release candidate

2024-03-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823822#comment-17823822 ] lincoln lee commented on FLINK-34534: -

[jira] [Assigned] (FLINK-34534) Vote on the release candidate

2024-03-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34534: --- Assignee: lincoln lee > Vote on the release candidate > - > >

[jira] [Closed] (FLINK-34531) Build and stage Java and Python artifacts

2024-03-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34531. --- Resolution: Fixed > Build and stage Java and Python artifacts >

[jira] [Closed] (FLINK-34532) Stage source and binary releases on dist.apache.org

2024-03-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34532. --- Resolution: Fixed [https://dist.apache.org/repos/dist/dev/flink/flink-1.19.0-rc1/]

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-03-05 Thread via GitHub
rkhachatryan commented on PR #24292: URL: https://github.com/apache/flink/pull/24292#issuecomment-1979884146 @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

Re: [PR] [FLINK-34566] Pass a FixedThreadPool to set reconciliation parallelism correctly [flink-kubernetes-operator]

2024-03-05 Thread via GitHub
ysymi commented on code in PR #790: URL: https://github.com/apache/flink-kubernetes-operator/pull/790#discussion_r1513647273 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/FlinkOperatorTest.java: ## @@ -70,10 +70,21 @@ public void

[jira] [Updated] (FLINK-34469) Implement TableDistribution toString

2024-03-05 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-34469: Affects Version/s: 1.20.0 > Implement TableDistribution toString > >

[jira] [Updated] (FLINK-34509) Docs: Fix Debezium JSON/AVRO opts in examples

2024-03-05 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-34509: Fix Version/s: 1.20.0 > Docs: Fix Debezium JSON/AVRO opts in examples >

[jira] [Updated] (FLINK-34509) Docs: Fix Debezium JSON/AVRO opts in examples

2024-03-05 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-34509: Affects Version/s: 1.19.0 1.20.0 > Docs: Fix Debezium JSON/AVRO opts in examples

[jira] [Closed] (FLINK-34509) Docs: Fix Debezium JSON/AVRO opts in examples

2024-03-05 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge closed FLINK-34509. --- Resolution: Fixed > Docs: Fix Debezium JSON/AVRO opts in examples >

[jira] [Commented] (FLINK-34509) Docs: Fix Debezium JSON/AVRO opts in examples

2024-03-05 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823793#comment-17823793 ] Jing Ge commented on FLINK-34509: - master: 641f4f4d0d0156b84bdb9ba528b1dd96f7ae9d9c > Docs: Fix

Re: [PR] [WIP][FLINK-34442][table] Support optimizations for pre-partitioned data sources [flink]

2024-03-05 Thread via GitHub
jeyhunkarimov commented on PR #24437: URL: https://github.com/apache/flink/pull/24437#issuecomment-1979739792 @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

Re: [PR] [FLINK-32263]-table-Add-ELT-function [flink]

2024-03-05 Thread via GitHub
hanyuzheng7 commented on PR #22853: URL: https://github.com/apache/flink/pull/22853#issuecomment-1979728745 @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

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-03-05 Thread via GitHub
zentol commented on code in PR #24292: URL: https://github.com/apache/flink/pull/24292#discussion_r1513528600 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java: ## @@ -903,22 +907,28 @@ private Stream filterPartitionsRequiringRel

Re: [PR] [WIP][FLINK-34442][table] Support optimizations for pre-partitioned data sources [flink]

2024-03-05 Thread via GitHub
jeyhunkarimov commented on PR #24437: URL: https://github.com/apache/flink/pull/24437#issuecomment-1979689365 @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

[jira] [Commented] (FLINK-34575) Vulnerabilities in commons-compress 1.24.0; upgrade to 1.26.0 needed.

2024-03-05 Thread Adrian Vasiliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823762#comment-17823762 ] Adrian Vasiliu commented on FLINK-34575: Thanks Martijn. I couldn't find an estimated date for

[jira] [Comment Edited] (FLINK-34575) Vulnerabilities in commons-compress 1.24.0; upgrade to 1.26.0 needed.

2024-03-05 Thread Adrian Vasiliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823762#comment-17823762 ] Adrian Vasiliu edited comment on FLINK-34575 at 3/5/24 8:18 PM: Thanks

[jira] [Commented] (FLINK-34152) Tune TaskManager memory

2024-03-05 Thread Yang LI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823720#comment-17823720 ] Yang LI commented on FLINK-34152: - Hello [~mxm] ,  About the integration of Flink autoscaling with

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-03-05 Thread via GitHub
rkhachatryan commented on code in PR #24292: URL: https://github.com/apache/flink/pull/24292#discussion_r1513218720 ## flink-tests/src/test/resources/log4j2-test.properties: ## @@ -28,7 +28,7 @@ appender.testlogger.name = TestLogger appender.testlogger.type = CONSOLE

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-03-05 Thread via GitHub
rkhachatryan commented on code in PR #24292: URL: https://github.com/apache/flink/pull/24292#discussion_r1513218720 ## flink-tests/src/test/resources/log4j2-test.properties: ## @@ -28,7 +28,7 @@ appender.testlogger.name = TestLogger appender.testlogger.type = CONSOLE

Re: [PR] [WIP][FLINK-34442][table] Support optimizations for pre-partitioned data sources [flink]

2024-03-05 Thread via GitHub
jeyhunkarimov commented on PR #24437: URL: https://github.com/apache/flink/pull/24437#issuecomment-1979268800 @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

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-03-05 Thread via GitHub
zentol commented on code in PR #24292: URL: https://github.com/apache/flink/pull/24292#discussion_r1513207066 ## flink-tests/src/test/resources/log4j2-test.properties: ## @@ -28,7 +28,7 @@ appender.testlogger.name = TestLogger appender.testlogger.type = CONSOLE

Re: [PR] [WIP][FLINK-34442][table] Support optimizations for pre-partitioned data sources [flink]

2024-03-05 Thread via GitHub
jeyhunkarimov commented on PR #24437: URL: https://github.com/apache/flink/pull/24437#issuecomment-1979247860 @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

[jira] [Closed] (FLINK-34579) Introduce metric for time since last completed checkpoint

2024-03-05 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-34579. -- Resolution: Won't Do > Introduce metric for time since last completed checkpoint >

Re: [PR] [FLINK-34579][metrics] Introduce metric for time since last competed checkpoint [flink]

2024-03-05 Thread via GitHub
StefanRRichter closed pull request #24435: [FLINK-34579][metrics] Introduce metric for time since last competed checkpoint URL: https://github.com/apache/flink/pull/24435 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] (FLINK-34532) Stage source and binary releases on dist.apache.org

2024-03-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34532 ] lincoln lee deleted comment on FLINK-34532: - was (Author: lincoln.86xy): An error occurred when build from the source package:

[jira] [Commented] (FLINK-34566) Flink Kubernetes Operator reconciliation parallelism setting not work

2024-03-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823682#comment-17823682 ] Gyula Fora commented on FLINK-34566: [~Fei Feng] here is the JOSDK side fix, can you please help

[jira] [Commented] (FLINK-34532) Stage source and binary releases on dist.apache.org

2024-03-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823680#comment-17823680 ] lincoln lee commented on FLINK-34532: - An error occurred when build from the source package:

[jira] [Resolved] (FLINK-16627) Support only generate non-null values when serializing into JSON

2024-03-05 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li resolved FLINK-16627. Fix Version/s: 1.20.0 Resolution: Fixed Fixed via 93555a7d55dc27571122cccb7c4d8af2c5db54cb

Re: [PR] [FLINK-16627][json]Support ignore null fields when serializing into JSON [flink]

2024-03-05 Thread via GitHub
libenchao closed pull request #24430: [FLINK-16627][json]Support ignore null fields when serializing into JSON URL: https://github.com/apache/flink/pull/24430 -- 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

[jira] [Commented] (FLINK-34576) Flink deployment keep staying at RECONCILING/STABLE status

2024-03-05 Thread chenyuzhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823663#comment-17823663 ] chenyuzhi commented on FLINK-34576: --- Thanks for the reply. 1.  Is there a way to somehow repro this

Re: [PR] [WIP][FLINK-34442][table] Support optimizations for pre-partitioned data sources [flink]

2024-03-05 Thread via GitHub
flinkbot commented on PR #24437: URL: https://github.com/apache/flink/pull/24437#issuecomment-1978955923 ## CI report: * b714f6b03da97df2284d82941a3014dc6a3530ad UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34442) Support optimizations for pre-partitioned [external] data sources

2024-03-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34442: --- Labels: pull-request-available (was: ) > Support optimizations for pre-partitioned

[PR] [WIP][FLINK-34442][table] Support optimizations for pre-partitioned data sources [flink]

2024-03-05 Thread via GitHub
jeyhunkarimov opened a new pull request, #24437: URL: https://github.com/apache/flink/pull/24437 ## 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] feat: autoscaling decision parallelism improvement [FLINK-34563] [flink-kubernetes-operator]

2024-03-05 Thread via GitHub
mxm commented on PR #787: URL: https://github.com/apache/flink-kubernetes-operator/pull/787#issuecomment-1978939188 >In my use case, the job graph comprises only 6 operators and allocates 6 task slots per task manager. Prior to implementing this improvement, setting the maximum

Re: [PR] [FLINK-34566] Pass a FixedThreadPool to set reconciliation parallelism correctly [flink-kubernetes-operator]

2024-03-05 Thread via GitHub
gyfora commented on code in PR #790: URL: https://github.com/apache/flink-kubernetes-operator/pull/790#discussion_r1512945769 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/FlinkOperatorTest.java: ## @@ -70,10 +70,21 @@ public void

  1   2   >