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

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

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

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:

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:

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

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

[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=17841833#comment-17841833 ] dalongliu commented on FLINK-34379: --- [~jeyhunkarimov]could you please backport it to release-1.19,

[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=17841832#comment-17841832 ] dalongliu commented on FLINK-34379: --- Merged in master: cca14d4210634d481cacb11354e870807d570561 >

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:

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

[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

[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=17841827#comment-17841827 ] Qingsheng Ren commented on FLINK-35255: --- flink-cdc master:

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:

[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

[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

[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=17841825#comment-17841825 ] Qingsheng Ren commented on FLINK-34878: --- flink-cdc master:

[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

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:

[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

[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=17841824#comment-17841824 ] Qingsheng Ren commented on FLINK-35259: --- flink-cdc master:

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=17841823#comment-17841823 ] dongwoo.kim commented on FLINK-34470: - Hi [~m.orazow], I’ve just made a PR and would appreciate

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

[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

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

[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

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.

[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:

[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=17841817#comment-17841817 ] Jing Ge commented on FLINK-32622: - [~jeyhunkarimov] could you please backport it to 1.19? > Do not add

[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

[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=17841816#comment-17841816 ] Jing Ge commented on FLINK-32622: - master: b1544e4e513d2b75b350c20dbb1c17a8232c22fd > Do not add

[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:

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

[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=17841813#comment-17841813 ] Qingsheng Ren commented on FLINK-35258: --- flink-cdc master:

[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

[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

[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=17841551#comment-17841551 ] Qingsheng Ren edited comment on FLINK-35251 at 4/29/24 2:25 AM: fixed in

[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=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=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=17841811#comment-17841811 ] hongxu han commented on FLINK-35260:

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:

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:

[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:

[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=17841799#comment-17841799 ] hongxu han commented on FLINK-35236: hi [~Weijie Guo],can you help me to review it. thanks.  >

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

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

[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

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

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

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

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

[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

[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=17841641#comment-17841641 ] Qingsheng Ren commented on FLINK-35256: --- flink-cdc master:

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:

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:

[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:

[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=17841635#comment-17841635 ] Jane Chan commented on FLINK-34915: --- Fixed in master e412402ca4dfc438e28fb990dc53ea7809430aee >

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:

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

[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,

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

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

Re: [PR] [BP-3.0][FLINK-35258][cdc][doc] Fix broken links to Doris in documentation [flink-cdc]

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

Re: [PR] [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager [flink]

2024-04-28 Thread via GitHub
fredia commented on code in PR #24640: URL: https://github.com/apache/flink/pull/24640#discussion_r1582077221 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java: ## @@ -575,8 +576,51 @@ private void

Re: [PR] [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation [flink-cdc]

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

Re: [PR] [FLINK-35039][rest] Use PUT method supported by YARN web proxy instead of POST [flink]

2024-04-28 Thread via GitHub
yeezychao commented on PR #24689: URL: https://github.com/apache/flink/pull/24689#issuecomment-2081417257 Hi @Myasuka ,I understand what you mean.I tested. If use PUT method, Return 404 error. If use POST method, Return 400 Bad Request.

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

2024-04-28 Thread via GitHub
caicancai commented on code in PR #24734: URL: https://github.com/apache/flink/pull/24734#discussion_r1582070191 ## docs/content/docs/deployment/resource-providers/standalone/kubernetes.md: ## @@ -129,7 +129,7 @@ The *job artifacts* could be provided by these way: After

[PR] [BP-3.0][FLINK-35258][cdc][doc] Fix broken links to Doris in documentation [flink-cdc]

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

[PR] [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation [flink-cdc]

2024-04-28 Thread via GitHub
yuxiqian opened a new pull request, #3274: URL: https://github.com/apache/flink-cdc/pull/3274 This PR backports [FLINK-35258](https://issues.apache.org/jira/browse/FLINK-35258) to release 3.1 branch. -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation [flink-cdc]

2024-04-28 Thread via GitHub
PatrickRen commented on PR #3273: URL: https://github.com/apache/flink-cdc/pull/3273#issuecomment-2081389766 Closed as duplicated to #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

Re: [PR] [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation [flink-cdc]

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

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

2024-04-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35258: --- Labels: pull-request-available (was: ) > Broken links to Doris in Flink CDC Documentation

[PR] [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation [flink-cdc]

2024-04-28 Thread via GitHub
PatrickRen opened a new pull request, #3273: URL: https://github.com/apache/flink-cdc/pull/3273 This pull request fixes broken links to Doris in documentation. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

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

2024-04-28 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-35258: - Summary: Broken links to Doris in Flink CDC Documentation Key: FLINK-35258 URL: https://issues.apache.org/jira/browse/FLINK-35258 Project: Flink Issue

Re: [PR] [FLINK-35196] [Connector / Pulsar] Fix bouncycastle class not found [flink-connector-pulsar]

2024-04-28 Thread via GitHub
syhily commented on PR #91: URL: https://github.com/apache/flink-connector-pulsar/pull/91#issuecomment-2081379636 OK, feel free to reopen this PR if you need. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

  1   2   >