Xuannan Su created FLINK-36811:
--
Summary: MySQL CDC
Key: FLINK-36811
URL: https://issues.apache.org/jira/browse/FLINK-36811
Project: Flink
Issue Type: Improvement
Components: Flink CDC
[
https://issues.apache.org/jira/browse/FLINK-36811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-36811:
--
Assignee: Ruan Hang
Summary: MySQL CDC source set is processing backlog during snapshot p
ouyangwulin created FLINK-36812:
---
Summary: The flink jdbc connector's 'scan.partition.column'
supports the varchar field type.
Key: FLINK-36812
URL: https://issues.apache.org/jira/browse/FLINK-36812
Pro
[
https://issues.apache.org/jira/browse/FLINK-35670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901604#comment-17901604
]
ouyangwulin commented on FLINK-35670:
-
I investigated the implementation, it is real
[
https://issues.apache.org/jira/browse/FLINK-36813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-36813:
--
Description:
*Background*
In some scenarios, MySQL synchronization only expects to synchronize specified
fiel
[
https://issues.apache.org/jira/browse/FLINK-36751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-36751:
-
Assignee: haishui
> PausableRelativeClock does not pause when the source only h
[
https://issues.apache.org/jira/browse/FLINK-36751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901589#comment-17901589
]
Roman Khachatryan commented on FLINK-36751:
---
Merged into master as 0c338ae6d21
[
https://issues.apache.org/jira/browse/FLINK-36751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan closed FLINK-36751.
-
Resolution: Fixed
Thanks for the contribution [~haishui] !
> PausableRelativeClock does
rkhachatryan merged PR #25695:
URL: https://github.com/apache/flink/pull/25695
--
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.
umeshdangat commented on code in PR #3434:
URL: https://github.com/apache/flink-cdc/pull/3434#discussion_r1861307255
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/DataFieldSerializer.java:
##
@@ -39,7 +39,14 @@ public class DataFieldSerializer
snuyanzin commented on PR #24829:
URL: https://github.com/apache/flink/pull/24829#issuecomment-2504944809
@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-36756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-36756:
-
Assignee: Shengkai Fang
> Bump up the sql-gateway rest api version
> --
fsk119 opened a new pull request, #25705:
URL: https://github.com/apache/flink/pull/25705
## What is the purpose of the change
*Bump up the SQL Gateway REST API verison.*
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
[
https://issues.apache.org/jira/browse/FLINK-36756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36756:
---
Labels: pull-request-available (was: )
> Bump up the sql-gateway rest api version
> ---
yuxiqian commented on code in PR #3763:
URL: https://github.com/apache/flink-cdc/pull/3763#discussion_r1861478089
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/source/assigner/state/PendingSplitsStateSerializerTest.jav
flinkbot commented on PR #25705:
URL: https://github.com/apache/flink/pull/25705#issuecomment-2505221909
## CI report:
* 1e83f1bda02cb512b4b1acb6f5c5758f2bc37e6d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Di Wu created FLINK-36813:
-
Summary: MySQLCDC supports synchronization of specified fields
Key: FLINK-36813
URL: https://issues.apache.org/jira/browse/FLINK-36813
Project: Flink
Issue Type: Improveme
JNSimba opened a new pull request, #3767:
URL: https://github.com/apache/flink-cdc/pull/3767
**Background**
In some scenarios, MySQL synchronization only expects to synchronize
specified fields instead of all fields in the table.
1. The user only has the permission for some fields in M
[
https://issues.apache.org/jira/browse/FLINK-36813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36813:
---
Labels: CDC pull-request-available (was: CDC)
> MySQLCDC supports synchronization of specif
snuyanzin commented on PR #24829:
URL: https://github.com/apache/flink/pull/24829#issuecomment-2505382087
@naferx can you rebase the PR
I tend to think that the reason of the current failure has already been
fixed in master
--
This is an automated message from the Apache Git Service.
T
snuyanzin commented on code in PR #24858:
URL: https://github.com/apache/flink/pull/24858#discussion_r1861608059
##
docs/content/docs/dev/table/hive-compatibility/hive-dialect/alter.md:
##
@@ -40,7 +40,7 @@ With Hive dialect, the following ALTER statements are
supported for now
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860867485
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
mehdid93 commented on PR #25670:
URL: https://github.com/apache/flink/pull/25670#issuecomment-2504432014
@zentol Thank you! I have pushed a commit to use the new Image in order to
test the changes
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860846971
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
flinkbot commented on PR #25703:
URL: https://github.com/apache/flink/pull/25703#issuecomment-2504141228
## CI report:
* b366d760dc117aa17cc528e2be5070b2f9036f4a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860854487
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860851806
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860853048
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
gustavodemorais closed pull request #25703: [FLINK-36809][table] Support
ignoreIfExists param for createTable
URL: https://github.com/apache/flink/pull/25703
--
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 t
zentol commented on PR #25670:
URL: https://github.com/apache/flink/pull/25670#issuecomment-2504396199
@mehdid93 You can try your changes with
[chesnay/flink-ci:java_8_11_17_21_maven_386_jammy](https://hub.docker.com/layers/chesnay/flink-ci/java_8_11_17_21_maven_386_jammy/images/sha256-85838
hlteoh37 merged PR #767:
URL: https://github.com/apache/flink-web/pull/767
--
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
[
https://issues.apache.org/jira/browse/FLINK-33566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-33566:
-
Fix Version/s: hbase-4.1.0
(was: hbase-3.0.0)
> HBase sql-connector needs
ferenc-csaky opened a new pull request, #25702:
URL: https://github.com/apache/flink/pull/25702
Simple release chore.
--
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 uns
flinkbot commented on PR #25704:
URL: https://github.com/apache/flink/pull/25704#issuecomment-2504208974
## CI report:
* d2bcde1986b8a02f114f9ff5556aae73919dcf7d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860897153
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
ferenc-csaky commented on PR #25697:
URL: https://github.com/apache/flink/pull/25697#issuecomment-2504020451
@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 comm
[
https://issues.apache.org/jira/browse/FLINK-36808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-36808:
--
Description:
Here is the SQL to reproduce the issue:
{code:java}
-- Data of table `stream`:
--
gustavodemorais commented on PR #25703:
URL: https://github.com/apache/flink/pull/25703#issuecomment-2504152111
Forgot one detail, let me open that again
--
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
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860859551
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860866006
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
ferenc-csaky merged PR #53:
URL: https://github.com/apache/flink-connector-hbase/pull/53
--
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
ferenc-csaky commented on PR #52:
URL:
https://github.com/apache/flink-connector-hbase/pull/52#issuecomment-2504645328
Closed, as it is obsolete now.
--
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
boring-cyborg[bot] commented on PR #53:
URL:
https://github.com/apache/flink-connector-hbase/pull/53#issuecomment-2504644678
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
ferenc-csaky closed pull request #52: [FLINK-36595][docs] Explicitly set
connector compatibility as string …
URL: https://github.com/apache/flink-connector-hbase/pull/52
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-35315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-35315:
--
Priority: Critical (was: Major)
> MemoryManagerConcurrentModReleaseTest executes more than 15
flinkbot commented on PR #25702:
URL: https://github.com/apache/flink/pull/25702#issuecomment-2504107185
## CI report:
* 41b6582f692f590ce71d2721306a8c06d3be97ee UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901531#comment-17901531
]
Yusu Gao commented on FLINK-36810:
--
[~tomncooper]
Thank you for pointing out that one
gustavodemorais opened a new pull request, #25703:
URL: https://github.com/apache/flink/pull/25703
## What is the purpose of the change
Support ignoreIfExists for createTable. Works exactly the same way for other
resources, like createFunction. Similar to SQL's `IF NOT EXISTS`
[
https://issues.apache.org/jira/browse/FLINK-36809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36809:
---
Labels: pull-request-available (was: )
> Add ifNotExists param to createTable
> ---
Yusu Gao created FLINK-36810:
Summary: Reflective access warning not addressed causing Flink
failing to process job creation
Key: FLINK-36810
URL: https://issues.apache.org/jira/browse/FLINK-36810
Project
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860845426
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
ferenc-csaky merged PR #762:
URL: https://github.com/apache/flink-web/pull/762
--
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.
ferenc-csaky merged PR #25697:
URL: https://github.com/apache/flink/pull/25697
--
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-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895936#comment-17895936
]
Matthias Pohl edited comment on FLINK-36451 at 11/27/24 2:33 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895936#comment-17895936
]
Matthias Pohl edited comment on FLINK-36451 at 11/27/24 2:34 PM:
-
Gustavo de Morais created FLINK-36809:
-
Summary: Add ifNotExists param to createTable
Key: FLINK-36809
URL: https://issues.apache.org/jira/browse/FLINK-36809
Project: Flink
Issue Type: Im
Qingsheng Ren created FLINK-36808:
-
Summary: UNION ALL after lookup join produces unexpected results
Key: FLINK-36808
URL: https://issues.apache.org/jira/browse/FLINK-36808
Project: Flink
Iss
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860883342
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
nicusX commented on code in PR #766:
URL: https://github.com/apache/flink-web/pull/766#discussion_r1860886508
##
docs/content/posts/2024-11-26-introducing-new-prometheus-connector.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Introducing the new Prometheus connector"
+date: "2024-11-2
[
https://issues.apache.org/jira/browse/FLINK-36810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901522#comment-17901522
]
Thomas Cooper commented on FLINK-36810:
---
Are you setting the Java options needed f
gustavodemorais opened a new pull request, #25704:
URL: https://github.com/apache/flink/pull/25704
## What is the purpose of the change
Support ignoreIfExists for createTable. Works exactly the same way for other
resources, like createFunction. Similar to SQL's `IF NOT EXISTS`
nicusX commented on PR #766:
URL: https://github.com/apache/flink-web/pull/766#issuecomment-2504225605
@hlteoh37 @dannycranmer I addressed all your comments
--
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
XComp commented on code in PR #25679:
URL: https://github.com/apache/flink/pull/25679#discussion_r1860904735
##
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionServiceTest.java:
##
@@ -311,8 +312,11 @@ void testMultipleDriverCreations() t
nicusX commented on PR #766:
URL: https://github.com/apache/flink-web/pull/766#issuecomment-2504229269
@hlteoh37 @dannycranmer I addressed all your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
twalthr commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1860917076
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -745,6 +745,35 @@ void createTemporarySystemFunction(
*/
github-actions[bot] commented on PR #3440:
URL: https://github.com/apache/flink-cdc/pull/3440#issuecomment-2505023790
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] closed pull request #3286:
[FLINK-35277][cdc-connector][db2] Fix the error in the `asncdcaddremove.sql`
script for the DB2 test container.
URL: https://github.com/apache/flink-cdc/pull/3286
--
This is an automated message from the Apache Git Service.
To respond to the mes
github-actions[bot] commented on PR #3616:
URL: https://github.com/apache/flink-cdc/pull/3616#issuecomment-2505023628
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
github-actions[bot] commented on PR #3286:
URL: https://github.com/apache/flink-cdc/pull/3286#issuecomment-2505023836
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] commented on PR #3507:
URL: https://github.com/apache/flink-cdc/pull/3507#issuecomment-2505023722
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] closed pull request #3440: [FLINK-35718][mysql] cherry pick
DBZ-5333 from debezium MySqlErrorHandler and add logs.
URL: https://github.com/apache/flink-cdc/pull/3440
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
github-actions[bot] closed pull request #3507: SQL Server CDC support - fixing
the issues in the outstanding pull request by another author
URL: https://github.com/apache/flink-cdc/pull/3507
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
melin created FLINK-36814:
-
Summary: Flink CDC Support Mutil Datasource
Key: FLINK-36814
URL: https://issues.apache.org/jira/browse/FLINK-36814
Project: Flink
Issue Type: New Feature
Compon
[
https://issues.apache.org/jira/browse/FLINK-36815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-36815:
--
Assignee: xuhuang
> series bugs of DSv2
> ---
>
> Key: FLINK-
xuhuang created FLINK-36815:
---
Summary: series bugs of DSv2
Key: FLINK-36815
URL: https://issues.apache.org/jira/browse/FLINK-36815
Project: Flink
Issue Type: Bug
Components: API / DataStr
codenohup opened a new pull request, #25706:
URL: https://github.com/apache/flink/pull/25706
## What is the purpose of the change
Fix fix series bugs of DSv2.
1. The DSv2 org.apache.flink.datastream.api.ExecutionEnvironment#fromSource
method return a
NonKeyedPartitionStream
[
https://issues.apache.org/jira/browse/FLINK-36815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36815:
---
Labels: pull-request-available (was: )
> series bugs of DSv2
> ---
>
>
flinkbot commented on PR #25706:
URL: https://github.com/apache/flink/pull/25706#issuecomment-2505464742
## CI report:
* f24821faddf52ab597bb635334aee0e252fbba65 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
AHeise commented on code in PR #25685:
URL: https://github.com/apache/flink/pull/25685#discussion_r1860247749
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/connector/sink2/StandardSinkTopologies.java:
##
@@ -39,12 +41,29 @@ private StandardSinkTopologies() {}
yuxiqian commented on code in PR #3658:
URL: https://github.com/apache/flink-cdc/pull/3658#discussion_r1860226446
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/resources/ddl/column_type_test_mysql8.sql:
##
Review Comment:
Accidental cha
AHeise commented on code in PR #25685:
URL: https://github.com/apache/flink/pull/25685#discussion_r1860251139
##
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/translators/GlobalCommitterTransformationTranslator.java:
##
@@ -90,7 +92,18 @@ private Collection tran
AHeise commented on code in PR #25685:
URL: https://github.com/apache/flink/pull/25685#discussion_r1860253151
##
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java:
##
@@ -188,6 +196,14 @@ private void expand() {
zentol commented on PR #25670:
URL: https://github.com/apache/flink/pull/25670#issuecomment-2503299977
> why are the CI tests failing?
Because the image was modified incorrectly.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
Guttz closed pull request #25701: DRAFT [FLINK-][flink-table] Support
create table ignoreIfExists for table-api
URL: https://github.com/apache/flink/pull/25701
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
tomncooper commented on PR #25602:
URL: https://github.com/apache/flink/pull/25602#issuecomment-2503426742
@snuyanzin Good point, I ammended the title and commit message to point at
[FLINK-33571](https://issues.apache.org/jira/browse/FLINK-33571).
--
This is an automated message from the
pnowojski merged PR #25671:
URL: https://github.com/apache/flink/pull/25671
--
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.apa
pnowojski merged PR #25693:
URL: https://github.com/apache/flink/pull/25693
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-36764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-36764.
--
Resolution: Fixed
merged commit 09ad451 into apache:master
> Add checkpoint type to checkpoin
lvyanquan commented on PR #3434:
URL: https://github.com/apache/flink-cdc/pull/3434#issuecomment-2503216515
Hi, @umeshdangat gentle ping.
I think that this pr is an important base for many other following features,
and we can try to merge it as soon as possible.
--
This is an automated
foxus opened a new pull request, #767:
URL: https://github.com/apache/flink-web/pull/767
I've addressed some minor grammar nits in the KinesisStreamsSource and
DynamoDbStreamsSource blog.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
rkhachatryan commented on PR #25695:
URL: https://github.com/apache/flink/pull/25695#issuecomment-2503274062
@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 comme
fapaul commented on code in PR #25685:
URL: https://github.com/apache/flink/pull/25685#discussion_r1860223898
##
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/translators/GlobalCommitterTransformationTranslator.java:
##
@@ -90,7 +92,18 @@ private Collection tran
[
https://issues.apache.org/jira/browse/FLINK-36780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901414#comment-17901414
]
Hongshun Wang commented on FLINK-36780:
---
[~liuml07] , I agree with you. This modif
lvyanquan opened a new pull request, #3764:
URL: https://github.com/apache/flink-cdc/pull/3764
Sorry for this mistake.
--
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 un
yuxiqian opened a new pull request, #3765:
URL: https://github.com/apache/flink-cdc/pull/3765
Use parameterized version string instead of write hard-encoded links.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
yuxiqian opened a new pull request, #3766:
URL: https://github.com/apache/flink-cdc/pull/3766
Use parameterized version string instead of write hard-encoded links.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
yuxiqian closed pull request #3765: [BP-3.2][docs] Update download links to
up-to-date cdc version
URL: https://github.com/apache/flink-cdc/pull/3765
--
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
zjjiang created FLINK-36806:
---
Summary: Support for synchronization between timestamp fields with
and without time zones to avoid time offsets
Key: FLINK-36806
URL: https://issues.apache.org/jira/browse/FLINK-36806
[
https://issues.apache.org/jira/browse/FLINK-36806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36806:
Description:
Currently, FlinkCDC can correctly synchronize the same time type (where the
type indicates w
AHeise commented on code in PR #25685:
URL: https://github.com/apache/flink/pull/25685#discussion_r1860258571
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/TestSinkV2.java:
##
@@ -241,7 +242,8 @@ public TestSinkV2WithPostCommitTopology(
1 - 100 of 121 matches
Mail list logo
