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
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
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
[
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
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
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
[
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
[
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
[
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
> ---
[
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
> ---
>
>
[
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
> ---
[
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
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
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
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
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
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
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
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
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
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
[
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
> -
[
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
> ---
[
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
>
[
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
[
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
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
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
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
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
[
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
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.
[
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
[
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
[
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
[
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
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.
[
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
[
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
>
[
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
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
[
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
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
[
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
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
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
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`
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
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
[
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
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
[
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
[
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
[
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
[
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
> -
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
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`
[
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
>
[
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
[
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
[
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:
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
[
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
>
[
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:
--
[
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
> ---
[
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:
--
[
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:
-
[
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-
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.
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.
[
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
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
[
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
[
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.
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
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
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 {
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`
[
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
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
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
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
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
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`
[
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
[
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
> -
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.
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:
[
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
> --
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
[
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
> --
[
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
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.
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.
[
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
> --
[
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
[
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
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
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
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 - 100 of 122 matches
Mail list logo