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

2024-04-28 Thread via GitHub
JustinLeesin commented on PR #24397: URL: https://github.com/apache/flink/pull/24397#issuecomment-2082006498 > @JustinLeesin Could you please cherry pick it to release-1.19 branch? And if ci passed, please let me know Hi, it's done on release-1.19 branch , please help to review if con

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

2024-04-28 Thread via GitHub
JustinLeesin commented on PR #24397: URL: https://github.com/apache/flink/pull/24397#issuecomment-2082005693 > > @JustinLeesin Could you please cherry pick it to release-1.19 branch? And if ci passed, please let me know > > Sorry to reply so late, I will work on it recently. Hi

Re: [PR] [FLINK-32852][JUnit5 Migration] Migrate the scheduler package of flink-runtime module to JUnit5 [flink]

2024-04-28 Thread via GitHub
1996fanrui commented on code in PR #24732: URL: https://github.com/apache/flink/pull/24732#discussion_r1582594242 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/BackgroundTaskTest.java: ## @@ -18,55 +18,52 @@ package org.apache.flink.runtime.schedu

[jira] [Commented] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing

2024-04-28 Thread hongxu han (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841860#comment-17841860 ] hongxu han commented on FLINK-35236:  [GitHub Pull Request #24726|https://github.com

Re: [PR] [FLINK-35194][table] Support describe job with job id [flink]

2024-04-28 Thread via GitHub
lsyldliu commented on code in PR #24728: URL: https://github.com/apache/flink/pull/24728#discussion_r1582558688 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java: ## @@ -774,6 +777,53 @@ public ResultFetcher ca

Re: [PR] [FLINK-34916][table] Support `ALTER CATALOG SET` syntax [flink]

2024-04-28 Thread via GitHub
liyubin117 commented on PR #24735: URL: https://github.com/apache/flink/pull/24735#issuecomment-2081957087 @LadyForest Hi, CI passed, looking forward your review, thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-35222) Adding getJobType for AccessExecutionGraph

2024-04-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841854#comment-17841854 ] Rui Fan commented on FLINK-35222: - Merged to master(1.20.0) via: 5263f9cbf20536e9a81a004

[jira] [Commented] (FLINK-35224) Show the JobType on Flink WebUI

2024-04-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841856#comment-17841856 ] Rui Fan commented on FLINK-35224: - Merged to master(1.20.0) via: 86de622c807413f2a7a1664

[jira] [Resolved] (FLINK-35223) Add jobType in JobDetailsInfo related rest api

2024-04-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35223. - Resolution: Fixed > Add jobType in JobDetailsInfo related rest api > ---

[jira] [Resolved] (FLINK-35224) Show the JobType on Flink WebUI

2024-04-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35224. - Resolution: Fixed > Show the JobType on Flink WebUI > --- > >

[jira] [Resolved] (FLINK-35222) Adding getJobType for AccessExecutionGraph

2024-04-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35222. - Resolution: Fixed > Adding getJobType for AccessExecutionGraph > ---

[jira] [Commented] (FLINK-35223) Add jobType in JobDetailsInfo related rest api

2024-04-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841855#comment-17841855 ] Rui Fan commented on FLINK-35223: - Merged to master(1.20.0) via: 917352ed35eff562a032a6e

Re: [PR] [FLINK-35223][rest] Add jobType in JobDetailsInfo related rest api [flink]

2024-04-28 Thread via GitHub
1996fanrui commented on PR #24718: URL: https://github.com/apache/flink/pull/24718#issuecomment-2081946736 Thanks @RocMarshal for the review! > Would we keep the same style typing in the commits message ? Updated, and the CI is green for now. Merging~ -- This is an automated

Re: [PR] [FLINK-35223][rest] Add jobType in JobDetailsInfo related rest api [flink]

2024-04-28 Thread via GitHub
1996fanrui merged PR #24718: URL: https://github.com/apache/flink/pull/24718 -- 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

Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink]

2024-04-28 Thread via GitHub
WencongLiu closed pull request #24710: [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser URL: https://github.com/apache/flink/pull/24710 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

Re: [PR] [FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format [flink]

2024-04-28 Thread via GitHub
GOODBOY008 commented on PR #24730: URL: https://github.com/apache/flink/pull/24730#issuecomment-2081927244 @robobario Thanks for your kind suggestions. PR is updated, PTAL~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

Re: [PR] [BP-3.1][minor][docs] Fix route definition example in core concept docs [flink-cdc]

2024-04-28 Thread via GitHub
yuxiqian commented on PR #3270: URL: https://github.com/apache/flink-cdc/pull/3270#issuecomment-2081901235 Rebased, cc @PatrickRen -- 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 com

Re: [PR] [hotfix][docs] Fix file reference [flink]

2024-04-28 Thread via GitHub
1996fanrui merged PR #24734: URL: https://github.com/apache/flink/pull/24734 -- 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

Re: [PR] [hotfix][docs] Fix typo in checkpoints documentation [flink]

2024-04-28 Thread via GitHub
1996fanrui merged PR #24738: URL: https://github.com/apache/flink/pull/24738 -- 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

Re: [PR] [FLINK-33211][table] support flink table lineage [flink]

2024-04-28 Thread via GitHub
HuangZhenQiu commented on PR #24618: URL: https://github.com/apache/flink/pull/24618#issuecomment-2081875974 @PatrickRen Thanks for reviewing the RP. For the testing purpose, I only added lineage provider implementation for values related source functions and input format. I will add li

Re: [PR] [FLINK-33211][table] support flink table lineage [flink]

2024-04-28 Thread via GitHub
HuangZhenQiu commented on code in PR #24618: URL: https://github.com/apache/flink/pull/24618#discussion_r1582530548 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/lineage/TableDataSetSchemaFacet.java: ## @@ -0,0 +1,47 @@ +/* + * Licensed to the A

[jira] [Updated] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError

2024-04-28 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-34379: -- Fix Version/s: 1.20.0 > table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError > -

[jira] [Resolved] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError

2024-04-28 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-34379. --- Resolution: Fixed > table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError > ---

[jira] [Assigned] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError

2024-04-28 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-34379: - Assignee: Jeyhun Karimov > table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError >

[jira] [Commented] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError

2024-04-28 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841833#comment-17841833 ] dalongliu commented on FLINK-34379: --- [~jeyhunkarimov]could you please backport it to r

[jira] [Commented] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError

2024-04-28 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841832#comment-17841832 ] dalongliu commented on FLINK-34379: --- Merged in master: cca14d4210634d481cacb11354e8708

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-04-28 Thread via GitHub
lsyldliu merged PR #24600: URL: https://github.com/apache/flink/pull/24600 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

Re: [PR] [FLINK-35255]DataSinkWriterOperator should override snapshotState and processWatermark method [flink-cdc]

2024-04-28 Thread via GitHub
yanghuaiGit commented on PR #3279: URL: https://github.com/apache/flink-cdc/pull/3279#issuecomment-2081852389 @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

[PR] [FLINK-35255]DataSinkWriterOperator should override snapshotState and processWatermark method [flink-cdc]

2024-04-28 Thread via GitHub
yanghuaiGit opened a new pull request, #3279: URL: https://github.com/apache/flink-cdc/pull/3279 … for the snapshotState and processWatermark methods -- 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

Re: [PR] [FLINK-35255]DataSinkWriterOperator should override snapshotState and processWatermark method [flink-cdc]

2024-04-28 Thread via GitHub
PatrickRen commented on PR #3271: URL: https://github.com/apache/flink-cdc/pull/3271#issuecomment-2081847614 @yanghuaiGit Could you also back port this commit to release-3.1? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[jira] [Commented] (FLINK-35255) DataSinkWriterOperator should override snapshotState and processWatermark method

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841827#comment-17841827 ] Qingsheng Ren commented on FLINK-35255: --- flink-cdc master: 23a67dcdb985f135e984e8e

Re: [PR] [FLINK-35255]DataSinkWriterOperator should override snapshotState and processWatermark method [flink-cdc]

2024-04-28 Thread via GitHub
PatrickRen merged PR #3271: URL: https://github.com/apache/flink-cdc/pull/3271 -- 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.

[jira] [Assigned] (FLINK-35255) DataSinkWriterOperator should override snapshotState and processWatermark method

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35255: - Assignee: yanghuai > DataSinkWriterOperator should override snapshotState and processWa

[jira] [Updated] (FLINK-35255) DataSinkWriterOperator should override snapshotState and processWatermark method

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35255: -- Fix Version/s: cdc-3.1.0 > DataSinkWriterOperator should override snapshotState and processWat

[jira] [Commented] (FLINK-34878) [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841825#comment-17841825 ] Qingsheng Ren commented on FLINK-34878: --- flink-cdc master: 75a553eb924a9108f57ce6c

[jira] [Assigned] (FLINK-34878) [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34878: - Assignee: Wenkai Qi > [Feature][Pipeline] Flink CDC pipeline transform supports CASE WH

Re: [PR] [FLINK-34878][cdc] Flink CDC pipeline transform supports CASE WHEN [flink-cdc]

2024-04-28 Thread via GitHub
PatrickRen merged PR #3228: URL: https://github.com/apache/flink-cdc/pull/3228 -- 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.

[jira] [Updated] (FLINK-34878) [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34878: -- Fix Version/s: cdc-3.1.0 > [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN

[jira] [Assigned] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35259: - Assignee: Wenkai Qi > FlinkCDC Pipeline transform can't deal timestamp field >

[jira] [Commented] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841824#comment-17841824 ] Qingsheng Ren commented on FLINK-35259: --- flink-cdc master: 0108d0e5d18c55873c3d67e

Re: [PR] [hotfix][docs] Fix typo in checkpoints documentation [flink]

2024-04-28 Thread via GitHub
caicancai commented on PR #24738: URL: https://github.com/apache/flink/pull/24738#issuecomment-2081833742 > Hi, @caicancai Thanks for the catching ! Would mind helping have a check on the whole doc scope for the case ? It would be appreciated! Thanks for the reminder, I have searched

[jira] [Commented] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging

2024-04-28 Thread dongwoo.kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841823#comment-17841823 ] dongwoo.kim commented on FLINK-34470: - Hi [~m.orazow], I’ve just made a PR and woul

Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]

2024-04-28 Thread via GitHub
fredia commented on code in PR #24698: URL: https://github.com/apache/flink/pull/24698#discussion_r1582504623 ## flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/StateFuture.java: ## @@ -49,7 +49,7 @@ public interface StateFuture { * @param action the acti

[jira] [Updated] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging

2024-04-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34470: --- Labels: pull-request-available (was: ) > Transactional message + Table api kafka source wit

Re: [PR] [FLINK-34470][Connectors/Kafka] Fix indefinite blocking by adjusting stopping condition in split reader [flink-connector-kafka]

2024-04-28 Thread via GitHub
boring-cyborg[bot] commented on PR #100: URL: https://github.com/apache/flink-connector-kafka/pull/100#issuecomment-2081822026 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[PR] [FLINK-34470][Connectors/Kafka] Fix indefinite blocking by adjusting stopping condition in split reader [flink-connector-kafka]

2024-04-28 Thread via GitHub
dongwoo6kim opened a new pull request, #100: URL: https://github.com/apache/flink-connector-kafka/pull/100 ## Problem When using the flink kafka connector in batch scenarios, consuming transactional messages can cause indefinite hanging. This issue can be easily reproduced with follow

Re: [PR] [hotfix][docs] Fix typo in checkpoints documentation [flink]

2024-04-28 Thread via GitHub
flinkbot commented on PR #24738: URL: https://github.com/apache/flink/pull/24738#issuecomment-2081819806 ## CI report: * 2c141212fb8f6eadbbbdc3cf84710cfec18f0302 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [hotfix][docs] Fix typo in checkpoints documentation [flink]

2024-04-28 Thread via GitHub
caicancai commented on PR #24738: URL: https://github.com/apache/flink/pull/24738#issuecomment-2081815309 cc @1996fanrui -- 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

[PR] [hotfix][docs] Fix typo in checkpoints documentation [flink]

2024-04-28 Thread via GitHub
caicancai opened a new pull request, #24738: URL: https://github.com/apache/flink/pull/24738 ## 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

[jira] [Updated] (FLINK-35261) Flink CDC pipeline transform doesn't support decimal-type comparison

2024-04-28 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35261: Summary: Flink CDC pipeline transform doesn't support decimal-type comparison (was: Flink CDC pipeline transform

[jira] [Created] (FLINK-35261) Flink CDC pipeline transform doesn't support decimal comparison

2024-04-28 Thread yux (Jira)
yux created FLINK-35261: --- Summary: Flink CDC pipeline transform doesn't support decimal comparison Key: FLINK-35261 URL: https://issues.apache.org/jira/browse/FLINK-35261 Project: Flink Issue Type: Im

[jira] [Commented] (FLINK-32622) Do not add mini-batch assigner operator if it is useless

2024-04-28 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841817#comment-17841817 ] Jing Ge commented on FLINK-32622: - [~jeyhunkarimov] could you please backport it to 1.19

[jira] [Resolved] (FLINK-32622) Do not add mini-batch assigner operator if it is useless

2024-04-28 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-32622. - Fix Version/s: 1.20.0 Resolution: Fixed > Do not add mini-batch assigner operator if it is useles

[jira] [Commented] (FLINK-32622) Do not add mini-batch assigner operator if it is useless

2024-04-28 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841816#comment-17841816 ] Jing Ge commented on FLINK-32622: - master: b1544e4e513d2b75b350c20dbb1c17a8232c22fd > D

[jira] [Assigned] (FLINK-32622) Do not add mini-batch assigner operator if it is useless

2024-04-28 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-32622: --- Assignee: Jeyhun Karimov > Do not add mini-batch assigner operator if it is useless > -

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-04-28 Thread via GitHub
JingGe merged PR #23470: URL: https://github.com/apache/flink/pull/23470 -- 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

Re: [PR] [FLINK-35191][table] Support alter materialized table related syntaxes: suspend, resume, refresh, set and reset [flink]

2024-04-28 Thread via GitHub
flinkbot commented on PR #24737: URL: https://github.com/apache/flink/pull/24737#issuecomment-2081799039 ## CI report: * bd8de05cf3e81e54afd57e25f0ed7cf985925604 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Resolved] (FLINK-35258) Broken links to Doris in Flink CDC Documentation

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35258. --- Resolution: Fixed > Broken links to Doris in Flink CDC Documentation >

[jira] [Assigned] (FLINK-35258) Broken links to Doris in Flink CDC Documentation

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35258: - Assignee: yux (was: Qingsheng Ren) > Broken links to Doris in Flink CDC Documentation

[jira] [Commented] (FLINK-35258) Broken links to Doris in Flink CDC Documentation

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841813#comment-17841813 ] Qingsheng Ren commented on FLINK-35258: --- flink-cdc master: a513e9f82e815409a8c91bd

[jira] [Updated] (FLINK-35191) Support alter materialized table related syntaxes: suspend, resume, refresh, set and reset

2024-04-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35191: --- Labels: pull-request-available (was: ) > Support alter materialized table related syntaxes:

[PR] [FLINK-35191][table] Support alter materialized table related syntaxes: suspend, resume, refresh, set and reset [flink]

2024-04-28 Thread via GitHub
hackergin opened a new pull request, #24737: URL: https://github.com/apache/flink/pull/24737 ## What is the purpose of the change *Support alter materialized table related syntaxes: suspend, resume, refresh, set and reset* Note: For the sake of current implementation conven

[jira] [Resolved] (FLINK-35251) SchemaDerivation serializes mapping incorrectly on checkpoint

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35251. --- Resolution: Fixed > SchemaDerivation serializes mapping incorrectly on checkpoint >

[jira] [Comment Edited] (FLINK-35251) SchemaDerivation serializes mapping incorrectly on checkpoint

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841551#comment-17841551 ] Qingsheng Ren edited comment on FLINK-35251 at 4/29/24 2:25 AM: --

[jira] [Resolved] (FLINK-35256) Pipeline transform ignores column type nullability

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35256. --- Resolution: Fixed > Pipeline transform ignores column type nullability > ---

[jira] [Comment Edited] (FLINK-35256) Pipeline transform ignores column type nullability

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841641#comment-17841641 ] Qingsheng Ren edited comment on FLINK-35256 at 4/29/24 2:23 AM: --

[jira] [Comment Edited] (FLINK-35260) Translate "Watermark alignment "page into Chinese

2024-04-28 Thread hongxu han (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841811#comment-17841811 ] hongxu han edited comment on FLINK-35260 at 4/29/24 2:23 AM: -

[jira] [Commented] (FLINK-35260) Translate "Watermark alignment "page into Chinese

2024-04-28 Thread hongxu han (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841811#comment-17841811 ] hongxu han commented on FLINK-35260: [https://nightlies.apache.org/flink/flink-docs-

Re: [PR] [BP-3.1][FLINK-35256][runtime] Fix transform node does not respect type nullability [flink-cdc]

2024-04-28 Thread via GitHub
PatrickRen merged PR #3277: URL: https://github.com/apache/flink-cdc/pull/3277 -- 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] [minor][docs] Fix route definition example in core concept docs [flink-cdc]

2024-04-28 Thread via GitHub
PatrickRen merged PR #3269: URL: https://github.com/apache/flink-cdc/pull/3269 -- 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.

[jira] [Updated] (FLINK-35260) Translate "Watermark alignment "page into Chinese

2024-04-28 Thread hongxu han (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hongxu han updated FLINK-35260: --- Attachment: image-2024-04-29-10-21-00-565.png Description: Watermark alignment lack of chinese

[jira] [Created] (FLINK-35260) Translate "Watermark alignment "page into Chinese

2024-04-28 Thread hongxu han (Jira)
hongxu han created FLINK-35260: -- Summary: Translate "Watermark alignment "page into Chinese Key: FLINK-35260 URL: https://issues.apache.org/jira/browse/FLINK-35260 Project: Flink Issue Type: Imp

[jira] [Updated] (FLINK-35252) Update the operators marked as deprecated in the instance program on the official website

2024-04-28 Thread hongxu han (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hongxu han updated FLINK-35252: --- Component/s: Examples (was: Documentation / Training / Exercises) > Update the

[jira] [Commented] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing

2024-04-28 Thread hongxu han (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841799#comment-17841799 ] hongxu han commented on FLINK-35236: hi [~Weijie Guo],can you help me to review it.

Re: [PR] [FLINK-34916][table] Support `ALTER CATALOG SET` syntax [flink]

2024-04-28 Thread via GitHub
liyubin117 commented on PR #24735: URL: https://github.com/apache/flink/pull/24735#issuecomment-2081711322 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

Re: [PR] [hotfix] Ensure that all yaml has a unified format [flink-kubernetes-operator]

2024-04-28 Thread via GitHub
caicancai closed pull request #820: [hotfix] Ensure that all yaml has a unified format URL: https://github.com/apache/flink-kubernetes-operator/pull/820 -- 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

Re: [PR] [FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format [flink]

2024-04-28 Thread via GitHub
robobario commented on code in PR #24730: URL: https://github.com/apache/flink/pull/24730#discussion_r1582425139 ## flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvBulkWriter.java: ## @@ -51,13 +54,19 @@ class CsvBulkWriter implements BulkWriter {

Re: [PR] [FLINK-35165] AdaptiveBatch Scheduler should not restrict the default source parall… [flink]

2024-04-28 Thread via GitHub
flinkbot commented on PR #24736: URL: https://github.com/apache/flink/pull/24736#issuecomment-2081579518 ## CI report: * 7a3264c0dcc8b19c4b7eb70a73d430d1ad2e76f6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35165) AdaptiveBatch Scheduler should not restrict the default source parallelism to the max parallelism set

2024-04-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35165: --- Labels: pull-request-available (was: ) > AdaptiveBatch Scheduler should not restrict the de

[PR] [FLINK-35165] AdaptiveBatch Scheduler should not restrict the default source parall… [flink]

2024-04-28 Thread via GitHub
venkata91 opened a new pull request, #24736: URL: https://github.com/apache/flink/pull/24736 …elism to the max parallelism set ## What is the purpose of the change With AdaptiveBatchScheduler, the current behavior is if both `execution.batch.adaptive.auto-parallelism.defaul

Re: [PR] [hotfix] Ensure that all yaml has a unified format [flink-kubernetes-operator]

2024-04-28 Thread via GitHub
gyfora commented on PR #820: URL: https://github.com/apache/flink-kubernetes-operator/pull/820#issuecomment-2081571402 @caicancai I think these changes are a bit random and do not make too much sense. Can you include it together with some other fix instead? -- This is an automated messag

Re: [PR] [FLINK-34916][table] Support `ALTER CATALOG SET` syntax [flink]

2024-04-28 Thread via GitHub
liyubin117 commented on PR #24735: URL: https://github.com/apache/flink/pull/24735#issuecomment-2081561616 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

Re: [PR] [FLINK-34916][table] Support `ALTER CATALOG SET` syntax [flink]

2024-04-28 Thread via GitHub
liyubin117 commented on PR #24735: URL: https://github.com/apache/flink/pull/24735#issuecomment-2081561574 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

Re: [PR] [FLINK-34916][table] Support `ALTER CATALOG SET` syntax [flink]

2024-04-28 Thread via GitHub
flinkbot commented on PR #24735: URL: https://github.com/apache/flink/pull/24735#issuecomment-2081503746 ## CI report: * 247f5afe51f1a1c13fdeefec61f303ac1d98f9f8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

2024-04-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35259: --- Labels: pull-request-available (was: ) > FlinkCDC Pipeline transform can't deal timestamp f

[jira] [Updated] (FLINK-34916) Support `ALTER CATALOG SET` syntax

2024-04-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34916: --- Labels: pull-request-available (was: ) > Support `ALTER CATALOG SET` syntax > -

[PR] [FLINK-34916][table] Support `ALTER CATALOG SET` syntax [flink]

2024-04-28 Thread via GitHub
liyubin117 opened a new pull request, #24735: URL: https://github.com/apache/flink/pull/24735 ## What is the purpose of the change Set one or more properties in the specified catalog. If a particular property is already set in the catalog, override the old value with the new one.

[jira] [Created] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

2024-04-28 Thread Wenkai Qi (Jira)
Wenkai Qi created FLINK-35259: - Summary: FlinkCDC Pipeline transform can't deal timestamp field Key: FLINK-35259 URL: https://issues.apache.org/jira/browse/FLINK-35259 Project: Flink Issue Type:

[jira] [Updated] (FLINK-35256) Pipeline transform ignores column type nullability

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35256: -- Fix Version/s: cdc-3.1.0 > Pipeline transform ignores column type nullability > --

Re: [PR] [FLINK-35256][runtime] Fix transform node does not respect type nullability [flink-cdc]

2024-04-28 Thread via GitHub
PatrickRen commented on PR #3272: URL: https://github.com/apache/flink-cdc/pull/3272#issuecomment-2081482756 @yuxiqian Could you also back port the patch onto `release-3.1`? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[jira] [Assigned] (FLINK-35256) Pipeline transform ignores column type nullability

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35256: - Assignee: yux > Pipeline transform ignores column type nullability > --

[jira] [Commented] (FLINK-35256) Pipeline transform ignores column type nullability

2024-04-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841641#comment-17841641 ] Qingsheng Ren commented on FLINK-35256: --- flink-cdc master: 6258bec5bb31533c501bedf

Re: [PR] [FLINK-35256][runtime] Fix transform node does not respect type nullability [flink-cdc]

2024-04-28 Thread via GitHub
PatrickRen merged PR #3272: URL: https://github.com/apache/flink-cdc/pull/3272 -- 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] [BP-3.1][FLINK-35258][cdc][doc] Fix broken links to Doris in documentation [flink-cdc]

2024-04-28 Thread via GitHub
PatrickRen merged PR #3274: URL: https://github.com/apache/flink-cdc/pull/3274 -- 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.

[jira] [Resolved] (FLINK-34915) Complete `DESCRIBE CATALOG` syntax

2024-04-28 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan resolved FLINK-34915. --- Fix Version/s: 1.20.0 Resolution: Fixed > Complete `DESCRIBE CATALOG` syntax > --

[jira] [Closed] (FLINK-34915) Complete `DESCRIBE CATALOG` syntax

2024-04-28 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan closed FLINK-34915. - > Complete `DESCRIBE CATALOG` syntax > -- > > Key: FLINK-349

[jira] [Commented] (FLINK-34915) Complete `DESCRIBE CATALOG` syntax

2024-04-28 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841635#comment-17841635 ] Jane Chan commented on FLINK-34915: --- Fixed in master e412402ca4dfc438e28fb990dc53ea780

Re: [PR] [FLINK-34915][table] Complete `DESCRIBE CATALOG` syntax [flink]

2024-04-28 Thread via GitHub
LadyForest merged PR #24630: URL: https://github.com/apache/flink/pull/24630 -- 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

Re: [PR] [FLINK-35256][runtime] Fix transform node does not respect type nullability [flink-cdc]

2024-04-28 Thread via GitHub
lvyanquan commented on PR #3272: URL: https://github.com/apache/flink-cdc/pull/3272#issuecomment-2081442070 I've tested that if namespace of TableId is not set and `__namespace_name__` column will be `null` string, so it won't cause error if MetadataColumns are not null. -- This is a

[PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink-connector-hive]

2024-04-28 Thread via GitHub
WencongLiu opened a new pull request, #18: URL: https://github.com/apache/flink-connector-hive/pull/18 ## What is the purpose of the change According to Hive user documentation[1], starting from version 0.13.0, Hive prohibits the use of reserved keywords as identifiers. Moreover, vers

  1   2   >