lvyanquan commented on code in PR #3667:
URL: https://github.com/apache/flink-cdc/pull/3667#discussion_r1914390428
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/WatermarkDispatcher.java:
##
@@ -0,0 +1,35 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-37112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37112:
---
Labels: pull-request-available (was: )
> FLIP-499: Support Event Time by Generalized Waterm
codenohup opened a new pull request, #25978:
URL: https://github.com/apache/flink/pull/25978
## What is the purpose of the change
Support Event Time by Generalized Watermark in DataStream V2
## Brief change log
More information see FLIP-499:
https://cwiki.apache.o
[
https://issues.apache.org/jira/browse/FLINK-37011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912775#comment-17912775
]
ChaomingZhang commented on FLINK-37011:
---
[~Leonard] Please assign to me.
> Improv
xuyangzhong commented on code in PR #25815:
URL: https://github.com/apache/flink/pull/25815#discussion_r1914383645
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/window/utils/WindowJoinHelper.java:
##
@@ -0,0 +1,402 @@
+/*
+ * Lice
lvyanquan commented on PR #3605:
URL: https://github.com/apache/flink-cdc/pull/3605#issuecomment-2589236525
Seems that the CI failures in mongodb and tidb e2e are unrelated to the
change of this pr...
--
This is an automated message from the Apache Git Service.
To respond to the message,
lvyanquan commented on PR #3749:
URL: https://github.com/apache/flink-cdc/pull/3749#issuecomment-2589232551
Hi, @MOBIN-F, rebase to master will help to fix ci failure here.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/FLINK-37042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37042.
Resolution: Resolved
via master: 4dc31d8c61325f8b719aa04d0d60e3d49ccf138b
> Unify option names us
leonardBang merged PR #3852:
URL: https://github.com/apache/flink-cdc/pull/3852
--
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
xuyangzhong commented on code in PR #25815:
URL: https://github.com/apache/flink/pull/25815#discussion_r1914375208
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/AsyncStateTableStreamOperator.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed
leonardBang commented on PR #3852:
URL: https://github.com/apache/flink-cdc/pull/3852#issuecomment-2589224912
> _ No description provided. _
LGTM, but a clear description would be better
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
lincoln-lil commented on code in PR #25815:
URL: https://github.com/apache/flink/pull/25815#discussion_r1914359274
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/AsyncStateTableStreamOperator.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912769#comment-17912769
]
Gabor Somogyi commented on FLINK-37109:
---
[~lamgary] Thanks for investing such amou
leonardBang commented on code in PR #3824:
URL: https://github.com/apache/flink-cdc/pull/3824#discussion_r1914356530
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest
lvyanquan commented on code in PR #3824:
URL: https://github.com/apache/flink-cdc/pull/3824#discussion_r1914351331
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.j
[
https://issues.apache.org/jira/browse/FLINK-37116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-37116:
---
Assignee: xuyang
> Add release notes for all breaking changes in 2.0.0
> --
lincoln lee created FLINK-37116:
---
Summary: Add release notes for all breaking changes in 2.0.0
Key: FLINK-37116
URL: https://issues.apache.org/jira/browse/FLINK-37116
Project: Flink
Issue Type:
AHeise commented on PR #25975:
URL: https://github.com/apache/flink/pull/25975#issuecomment-2589184064
@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.
T
[
https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-20950.
---
Resolution: Cannot Reproduce
> SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed
[
https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912764#comment-17912764
]
Arvid Heise commented on FLINK-20950:
-
Sorry for leaving this ticket open for so lon
xuyangzhong commented on PR #25861:
URL: https://github.com/apache/flink/pull/25861#issuecomment-2589171584
The ci failed by https://issues.apache.org/jira/browse/FLINK-36356.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
AHeise merged PR #25974:
URL: https://github.com/apache/flink/pull/25974
--
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
AHeise merged PR #25973:
URL: https://github.com/apache/flink/pull/25973
--
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
leonardBang commented on code in PR #3824:
URL: https://github.com/apache/flink-cdc/pull/3824#discussion_r1914334892
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest
lvyanquan commented on code in PR #3824:
URL: https://github.com/apache/flink-cdc/pull/3824#discussion_r1914322875
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.j
[
https://issues.apache.org/jira/browse/FLINK-37114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37114:
--
Assignee: hql0312
> Flink CDC Postgres Connector subsribe regular expression will be slow
> -
[
https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912751#comment-17912751
]
Zakelly Lan commented on FLINK-37115:
-
[~Zhanghao Chen] Would you please take a look
[
https://issues.apache.org/jira/browse/FLINK-37114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-37114:
---
Component/s: Flink CDC
> Flink CDC Postgres Connector subsribe regular expression will be slow
> ---
[
https://issues.apache.org/jira/browse/FLINK-37114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-37114:
---
Fix Version/s: cdc-3.3.0
> Flink CDC Postgres Connector subsribe regular expression will be slow
> -
[
https://issues.apache.org/jira/browse/FLINK-37114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-37114:
---
Affects Version/s: cdc-3.2.1
> Flink CDC Postgres Connector subsribe regular expression will be slow
[
https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-37115:
---
Assignee: Zhanghao Chen (was: Zakelly Lan)
> [Benchmark] Compile error related with Serial
[
https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912750#comment-17912750
]
Weijie Guo commented on FLINK-37115:
[~Zhanghao Chen] Could you please take a look?
[
https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-37115:
---
Assignee: Zakelly Lan
> [Benchmark] Compile error related with SerializerConfig
> -
flinkbot commented on PR #25977:
URL: https://github.com/apache/flink/pull/25977#issuecomment-2589137578
## CI report:
* 3dad5b16dbe59b8a79d257c28c9f836cfa086425 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly Lan created FLINK-37115:
---
Summary: [Benchmark] Compile error related with SerializerConfig
Key: FLINK-37115
URL: https://issues.apache.org/jira/browse/FLINK-37115
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-37115:
Description:
{code:java}
12:43:54 [INFO] ---
suez1224 commented on code in PR #25965:
URL: https://github.com/apache/flink/pull/25965#discussion_r1914308321
##
flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java:
##
@@ -681,7 +686,14 @@ public void onCompleted(BeamFnA
ChaomingZhangCN opened a new pull request, #25977:
URL: https://github.com/apache/flink/pull/25977
(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 unsubscri
suez1224 commented on PR #25965:
URL: https://github.com/apache/flink/pull/25965#issuecomment-2589130902
I believe the mainMailboxExecutor is set once for the StreamTask here
https://github.com/apache/flink/blob/60497e7dfddf27b25b80b913ef259010e97569aa/flink-runtime/src/main/java/org/apache/
lvyanquan commented on PR #3667:
URL: https://github.com/apache/flink-cdc/pull/3667#issuecomment-2589125930
Is the failure CI a unstable case?
```
2025-01-14T04:03:55.0826579Z [ERROR] Tests run: 20, Failures: 0, Errors: 1,
Skipped: 0, Time elapsed: 836.065 s <<< FAILURE! - in
org.apac
[
https://issues.apache.org/jira/browse/FLINK-37114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hql0312 updated FLINK-37114:
Description:
PostgresSourceBuilder postgresSourceBuilder =
PostgresSourceBuilder.PostgresIncrementalSourc
hql0312 commented on PR #3854:
URL: https://github.com/apache/flink-cdc/pull/3854#issuecomment-2589115677
> @hql0312 Thanks for your contribution, could you open a Flink jira issue
and link to this PR？
https://issues.apache.org/jira/browse/FLINK-37114
--
This is an automated messag
hql0312 created FLINK-37114:
---
Summary: Flink CDC Postgres Connector subsribe regular expression
will be slow
Key: FLINK-37114
URL: https://issues.apache.org/jira/browse/FLINK-37114
Project: Flink
leonardBang commented on PR #3854:
URL: https://github.com/apache/flink-cdc/pull/3854#issuecomment-2589102357
@hql0312 Thanks for your contribution, could you open a Flink jira issue and
link to this PR？
--
This is an automated message from the Apache Git Service.
To respond to the messag
[
https://issues.apache.org/jira/browse/FLINK-34124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34124:
---
Labels: pull-request-available (was: 2.0-related pull-request-available)
> Disable Kyro by default
[
https://issues.apache.org/jira/browse/FLINK-34124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-34124.
--
Resolution: Won't Do
> Disable Kyro by default
> ---
>
> Key: FLIN
[
https://issues.apache.org/jira/browse/FLINK-34124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34124:
---
Summary: Disable Kyro by default (was: Flink 2.0: Disable Kyro by default)
> Disable Kyro by defaul
[
https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-35068.
Resolution: Resolved
> Introduce built-in serialization support for Set
>
[
https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912744#comment-17912744
]
Weijie Guo commented on FLINK-35068:
master(2.0) via f46bb434
> Introduce built-in
ruanhang1993 commented on code in PR #3463:
URL: https://github.com/apache/flink-cdc/pull/3463#discussion_r1914284429
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java:
##
Weijie Guo created FLINK-37113:
--
Summary: Introduce document for datastream api v2
Key: FLINK-37113
URL: https://issues.apache.org/jira/browse/FLINK-37113
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-36356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912743#comment-17912743
]
xuyang commented on FLINK-36356:
https://dev.azure.com/apache-flink/apache-flink/_build/
xuyangzhong commented on PR #25815:
URL: https://github.com/apache/flink/pull/25815#issuecomment-2589051943
The ci failed by https://issues.apache.org/jira/browse/FLINK-36356.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
lsyldliu commented on code in PR #25566:
URL: https://github.com/apache/flink/pull/25566#discussion_r1914279808
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/dataview/MapView.java:
##
@@ -89,10 +86,12 @@
*
* }
*
+ * {@code MapView(TypeInformati
ruanhang1993 commented on code in PR #3608:
URL: https://github.com/apache/flink-cdc/pull/3608#discussion_r1914211831
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTableP
lsyldliu commented on code in PR #25565:
URL: https://github.com/apache/flink/pull/25565#discussion_r1914278787
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/dataview/ListView.java:
##
@@ -87,9 +84,11 @@
*
* }
*
+ * {@code ListView(TypeInformat
sn-12-3 commented on PR #25528:
URL: https://github.com/apache/flink/pull/25528#issuecomment-2588928936
Hi @xuyangzhong , This PR is ready for review now. I have removed the
`toAppendStream` method from Scala and few tests which had references. Kindly
let me know if any further changes is n
hql0312 opened a new pull request, #3855:
URL: https://github.com/apache/flink-cdc/pull/3855
log output format and text
--
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 u
Zakelly commented on code in PR #25968:
URL: https://github.com/apache/flink/pull/25968#discussion_r1914214191
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -388,14 +403,13 @@ private void seizeCapacity() {
hql0312 closed pull request #3808: [hotfix][postgres] Flink CDC Postgres
Connector subsribe regular expr…
URL: https://github.com/apache/flink-cdc/pull/3808
--
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
hql0312 commented on PR #3808:
URL: https://github.com/apache/flink-cdc/pull/3808#issuecomment-2588899351
add new pr in https://github.com/apache/flink-cdc/pull/3854
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
lsyldliu commented on PR #25585:
URL: https://github.com/apache/flink/pull/25585#issuecomment-2588897923
This is done by pr: https://github.com/apache/flink/pull/25966, close it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
lsyldliu closed pull request #25585: [FLINK-36497][table]Remove all deprecated
methods `CatalogTable`
URL: https://github.com/apache/flink/pull/25585
--
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
[
https://issues.apache.org/jira/browse/FLINK-36497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-36497.
---
Assignee: xuyang
Resolution: Fixed
> Remove all deprecated methods in `CatalogTable`
> ---
[
https://issues.apache.org/jira/browse/FLINK-36497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912738#comment-17912738
]
dalongliu commented on FLINK-36497:
---
Merged in master branch: 60497e7dfddf27b25b80b913
lsyldliu merged PR #25966:
URL: https://github.com/apache/flink/pull/25966
--
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
lsyldliu commented on PR #2:
URL: https://github.com/apache/flink/pull/2#issuecomment-259674
This is done by another PR: https://github.com/apache/flink/pull/25950,
close it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
lsyldliu closed pull request #2: FLINK-36506: Remove all deprecated methods
in `ColumnStats`
URL: https://github.com/apache/flink/pull/2
--
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 s
[
https://issues.apache.org/jira/browse/FLINK-36506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-36506.
---
Assignee: xuyang
Resolution: Fixed
> Remove all deprecated methods in `ColumnStats`
>
[
https://issues.apache.org/jira/browse/FLINK-36985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36985.
Resolution: Implemented
via master: 32934393cefc6227adb172192807a0aa0b3afe19
> remove Catalog.Col
[
https://issues.apache.org/jira/browse/FLINK-36506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912734#comment-17912734
]
dalongliu commented on FLINK-36506:
---
Merged in master branch: 1f6a6af327d6063dda6d29fc
[
https://issues.apache.org/jira/browse/FLINK-36985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36985:
--
Assignee: hiliuxg
> remove Catalog.ColumnAlreadyExistException when apply
> applyAddColumnEv
leonardBang merged PR #3828:
URL: https://github.com/apache/flink-cdc/pull/3828
--
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
lsyldliu merged PR #25950:
URL: https://github.com/apache/flink/pull/25950
--
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
liuxuzxx closed pull request #3835: 修改FlinkDeployment的jarURI地址错误的问题
URL: https://github.com/apache/flink-cdc/pull/3835
--
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 unsubs
Zakelly commented on code in PR #25968:
URL: https://github.com/apache/flink/pull/25968#discussion_r1914196723
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -377,7 +392,7 @@ public void triggerIfNeeded(boolean force)
xuyangzhong commented on code in PR #25723:
URL: https://github.com/apache/flink/pull/25723#discussion_r1914191986
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java:
##
@@ -541,8 +541,10 @@ private void proc
Zakelly commented on code in PR #25968:
URL: https://github.com/apache/flink/pull/25968#discussion_r1914191873
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -388,14 +403,13 @@ private void seizeCapacity() {
[
https://issues.apache.org/jira/browse/FLINK-36936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912729#comment-17912729
]
xuyang commented on FLINK-36936:
Please note that we need to implement an additional map
[
https://issues.apache.org/jira/browse/FLINK-36936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912729#comment-17912729
]
xuyang edited comment on FLINK-36936 at 1/14/25 3:36 AM:
-
Please
zhuanshenbsj1 commented on PR #22:
URL:
https://github.com/apache/flink-connector-hive/pull/22#issuecomment-2588836624
@davidradl @fsk119 cc
--
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
boring-cyborg[bot] commented on PR #22:
URL:
https://github.com/apache/flink-connector-hive/pull/22#issuecomment-2588834971
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is an
xuhuang created FLINK-37112:
---
Summary: FLIP-499: Support Event Time by Generalized Watermark in
DataStream V2
Key: FLINK-37112
URL: https://issues.apache.org/jira/browse/FLINK-37112
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912721#comment-17912721
]
Yanfei Lei commented on FLINK-36899:
Merged into master via c9311756582abff297ed085e
liuxuzxx commented on PR #3835:
URL: https://github.com/apache/flink-cdc/pull/3835#issuecomment-2588822631
https://nightlies.apache.org/flink/flink-cdc-docs-release-3.2/docs/deployment/kubernetes/
看到官方文档说不支持flink operator的形式提交?
Please note that submitting with native application mod
noorall commented on PR #25859:
URL: https://github.com/apache/flink/pull/25859#issuecomment-2588827178
@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.
[
https://issues.apache.org/jira/browse/FLINK-36957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912722#comment-17912722
]
Yanfei Lei commented on FLINK-36957:
Merged into master via 4ae4b871c08900fb31b6bc58
[
https://issues.apache.org/jira/browse/FLINK-36957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-36957.
Resolution: Resolved
> Implement async StreamFlatMap
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-36899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-36899.
Assignee: Yanfei Lei
Resolution: Resolved
> Introduce metrics for cache
> --
fredia merged PR #25884:
URL: https://github.com/apache/flink/pull/25884
--
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
fredia merged PR #25848:
URL: https://github.com/apache/flink/pull/25848
--
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
loserwang1024 commented on PR #3667:
URL: https://github.com/apache/flink-cdc/pull/3667#issuecomment-2588822369
> Hi, @loserwang1024. could you rebase again to include the fix of CI?
done it.
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
fredia commented on PR #25608:
URL: https://github.com/apache/flink/pull/25608#issuecomment-2588802046
@fhueske Sorry, I accidentally deleted your branch
`fhueske-hotfix-add-lead_lag-table-api-agg-functions-to-docs /
fhueske-FLINK-36642-backport /
fhueske-FLINK-36642-Fix_SqlNames_of_builti
lvyanquan commented on PR #3667:
URL: https://github.com/apache/flink-cdc/pull/3667#issuecomment-2588812880
Hi, @loserwang1024. could you rebase again to include the fix of CI?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
ChaomingZhangCN commented on PR #3852:
URL: https://github.com/apache/flink-cdc/pull/3852#issuecomment-2588806163
@dingxin-tech Please take a look~
--
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
yux created FLINK-37111:
---
Summary: Allow setting `sink.version` for StarRocks Pipeline
connector
Key: FLINK-37111
URL: https://issues.apache.org/jira/browse/FLINK-37111
Project: Flink
Issue Type: Im
xuyangzhong commented on code in PR #25723:
URL: https://github.com/apache/flink/pull/25723#discussion_r1914136210
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/AbstractTopNFunction.java:
##
@@ -76,9 +79,15 @@ public abstract clas
xuyangzhong commented on code in PR #25723:
URL: https://github.com/apache/flink/pull/25723#discussion_r1914130378
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/AbstractSyncStateTopNFunction.java:
##
@@ -72,10 +77,10 @@ public voi
Zakelly commented on code in PR #25968:
URL: https://github.com/apache/flink/pull/25968#discussion_r1914125165
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -410,9 +424,11 @@ private void seizeCapacity() {
* (o
[
https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912702#comment-17912702
]
Weijie Guo commented on FLINK-34123:
fixed in FLINK-3 .
> Introduce built-in s
1 - 100 of 285 matches
Mail list logo
