AlexYinHan opened a new pull request, #98:
URL: https://github.com/apache/flink-benchmarks/pull/98
This resolves the compilation errors introduced by
[FLINK-4602](https://github.com/apache/flink/pull/25543), which moves the
rocksdb classes to o.a.f.state.rocksdb package package.
--
This
[
https://issues.apache.org/jira/browse/FLINK-36271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36271:
---
Labels: pull-request-available (was: )
> Support json and jsonb type in PostgreSQL JDBC Dia
[
https://issues.apache.org/jira/browse/FLINK-36245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893798#comment-17893798
]
LvYanquan commented on FLINK-36245:
---
Hi, Piotr.
Kafka connector has not yet been adapt
Han Yin created FLINK-36622:
---
Summary: Remove the dependency of StateBenchmark on
RocksDBKeyedStateBackend APIs.
Key: FLINK-36622
URL: https://issues.apache.org/jira/browse/FLINK-36622
Project: Flink
Zakelly commented on code in PR #25561:
URL: https://github.com/apache/flink/pull/25561#discussion_r1820533404
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataInputStream.java:
##
@@ -0,0 +1,237 @@
+/*
+ * Licensed t
AHeise commented on PR #25547:
URL: https://github.com/apache/flink/pull/25547#issuecomment-2444290856
Reverted the deprecation of numFailed and added a config option for the
retries. PTAL @fapaul
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
tinaselenge commented on PR #25566:
URL: https://github.com/apache/flink/pull/25566#issuecomment-2443607410
Failing tests don't seem to be related as they pass locally for me.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
dawidwys commented on code in PR #24699:
URL: https://github.com/apache/flink/pull/24699#discussion_r1820328447
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/MatchRecognizeITCase.java:
##
@@ -567,7 +912,7 @@ void testUserDefine
AlexYinHan opened a new pull request, #25586:
URL: https://github.com/apache/flink/pull/25586
## What is the purpose of the change
Add constructors for
o.a.f.contrib.streaming.state.EmbeddedRocksDBStateBackend to maintain interface
compatibility.
## Bri
[
https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36620:
Description:
Currently, most of FlinkCDC's command line arguments are supported in the
format "--$KEY $VA
[
https://issues.apache.org/jira/browse/FLINK-36245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893764#comment-17893764
]
Piotr Nowojski edited comment on FLINK-36245 at 10/29/24 10:39 AM:
---
flinkbot commented on PR #25586:
URL: https://github.com/apache/flink/pull/25586#issuecomment-2443963990
## CI report:
* 8a64c442363ad7af042796ee90a80e82f8fb47f2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
AlexYinHan commented on PR #25586:
URL: https://github.com/apache/flink/pull/25586#issuecomment-2443980646
@Zakelly This resolves the incompatibility of the constructors of
EmbeddedRocksDBStateBackend. Can you take a look?
--
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/FLINK-16851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893806#comment-17893806
]
Poorvank Bhatia commented on FLINK-16851:
-
Hey [~becket_qin] , Is this still bei
[
https://issues.apache.org/jira/browse/FLINK-36621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893812#comment-17893812
]
LvYanquan commented on FLINK-36621:
---
This issue should be related to a bug
https://yo
AlexYinHan opened a new pull request, #25587:
URL: https://github.com/apache/flink/pull/25587
## What is the purpose of the change
Currently, flink-benchmarks relies on non-public APIs in Flink. For example,
in StateBackendBenchmarkUtils.java, the function compactState
snuyanzin commented on code in PR #33:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/33#discussion_r1820768938
##
flink-connector-gcp-pubsub/src/main/java/org/apache/flink/connector/gcp/pubsub/sink/config/GcpPublisherConfig.java:
##
@@ -52,7 +52,11 @@ public Cr
[
https://issues.apache.org/jira/browse/FLINK-36621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36621:
---
Labels: pull-request-available (was: )
> Build failure: StatefulSink not found
> --
Piotr Nowojski created FLINK-36621:
--
Summary: Build failure: StatefulSink not found
Key: FLINK-36621
URL: https://issues.apache.org/jira/browse/FLINK-36621
Project: Flink
Issue Type: Improve
AlexYinHan commented on PR #98:
URL: https://github.com/apache/flink-benchmarks/pull/98#issuecomment-2444005263
@Zakelly This should resolve the compilation errors once [Flink
PR-25586](https://github.com/apache/flink/pull/25586) is merged. PTAL.
--
This is an automated message from the A
flinkbot commented on PR #25588:
URL: https://github.com/apache/flink/pull/25588#issuecomment-2444190248
## CI report:
* de83f7c5c6d6e57252dbf23a0677957e9164d3ac UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25587:
URL: https://github.com/apache/flink/pull/25587#issuecomment-2444189745
## CI report:
* fdcf5f44ec979958a0f65c27b2685f443e70152c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lvyanquan opened a new pull request, #25588:
URL: https://github.com/apache/flink/pull/25588
## What is the purpose of the change
Add comment to help developer avoiding compiling error in flink-examples
module.
## Brief change log
comment
## Verifying this change
[
https://issues.apache.org/jira/browse/FLINK-36622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36622:
---
Labels: pull-request-available (was: )
> Remove the dependency of StateBenchmark on RocksDB
[
https://issues.apache.org/jira/browse/FLINK-32483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-32483.
--
Resolution: Fixed
> RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails
grzegorz8 commented on PR #141:
URL:
https://github.com/apache/flink-connector-jdbc/pull/141#issuecomment-2444020989
> > @grzegorz8 Can You Give me, Some Example to Build This Code and Add Jar
and use in pyflink code for Streaming Data to JSONB in PostgreSQL.
>
> I'm sorry but there
[
https://issues.apache.org/jira/browse/FLINK-21909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893792#comment-17893792
]
Poorvank Bhatia commented on FLINK-21909:
-
Hey [~jark] , If this is still unassi
[
https://issues.apache.org/jira/browse/FLINK-25921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893796#comment-17893796
]
Poorvank Bhatia commented on FLINK-25921:
-
Hey [~fpaul] , If this is still unass
[
https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893856#comment-17893856
]
Piotr Nowojski commented on FLINK-36613:
{quote}
It is very likely that the reas
[
https://issues.apache.org/jira/browse/FLINK-36410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenqiu Huang resolved FLINK-36410.
---
Resolution: Done
> Improve Lineage Info Collection for flink app
> -
[
https://issues.apache.org/jira/browse/FLINK-36410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893955#comment-17893955
]
Zhenqiu Huang commented on FLINK-36410:
---
PR is created and merged https://github.c
Zhenqiu Huang created FLINK-36625:
-
Summary: Add helper classes for Lineage integration in connectors
Key: FLINK-36625
URL: https://issues.apache.org/jira/browse/FLINK-36625
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Summary: Flink SQL temporal JOINs behavior change from Flink 1.15 to Flink
1.18+ (was: Flin
github-actions[bot] commented on PR #3569:
URL: https://github.com/apache/flink-cdc/pull/3569#issuecomment-2445540069
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 #3501:
URL: https://github.com/apache/flink-cdc/pull/3501#issuecomment-2445540164
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 #3433:
URL: https://github.com/apache/flink-cdc/pull/3433#issuecomment-2445540230
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.
--
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
[
https://issues.apache.org/jira/browse/FLINK-36547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-36547:
--
Assignee: Yubin Li
> Add option to retain `RowKind` sematics after serialization/deserializat
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
caicancai commented on code in PR #31:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/31#discussion_r1821701027
##
flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubPublisher.java:
##
@@ -21,11 +21,14 @@
impo
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
rkhachatryan commented on code in PR #25280:
URL: https://github.com/apache/flink/pull/25280#discussion_r1821594247
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/DefaultStateTransitionManager.java:
##
@@ -0,0 +1,434 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
Hector Miuler Malpica Gallegos created FLINK-36627:
--
Summary: Failure to process a CSV file in Flink due to a character
encoding mismatch: the file is in ISO-8859 and the application expects UTF-8.
Key: FLINK-3662
[
https://issues.apache.org/jira/browse/FLINK-36627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hector Miuler Malpica Gallegos updated FLINK-36627:
---
Description:
I have error in read csv with charset ISO-8859,
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Summary: Flink SQL temporal lookup JOINs behavior change from Flink 1.15 to
Flink 1.18+ (wa
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
Eduardo Breijo created FLINK-36626:
--
Summary: Flink SQL JOINs behavior change from Flink 1.15 to Flink
1.18+
Key: FLINK-36626
URL: https://issues.apache.org/jira/browse/FLINK-36626
Project: Flink
RanJinh opened a new pull request, #25590:
URL: https://github.com/apache/flink/pull/25590
## What is the purpose of the change
To update the `Testing Flink Jobs` Docs example from deprecated
`SinkFunction` to `Sink`.
## Brief change log
- Using `Sink` instead of `
Zakelly merged PR #25586:
URL: https://github.com/apache/flink/pull/25586
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893675#comment-17893675
]
Zakelly Lan edited comment on FLINK-4602 at 10/30/24 2:32 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-36621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-36621:
--
Assignee: LvYanquan
> Build failure: StatefulSink not found
> ---
[
https://issues.apache.org/jira/browse/FLINK-36624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-36624:
--
Assignee: Piotr Nowojski
> Log JobID in SourceCoordinator
> -
Piotr Nowojski created FLINK-36624:
--
Summary: Log JobID in SourceCoordinator
Key: FLINK-36624
URL: https://issues.apache.org/jira/browse/FLINK-36624
Project: Flink
Issue Type: Improvement
HuangZhenQiu commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1821361818
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/lineage/LineageUtilTest.java:
##
@@ -0,0 +1,56 @@
+package org.apache.flink.co
vahmed-hamdy commented on PR #30:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/30#issuecomment-2444821498
@snuyanzin thanks for the review, I refactored the factory tests and removed
unnecessary public access modifiers, PTAL
--
This is an automated message from the Apac
[
https://issues.apache.org/jira/browse/FLINK-16851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893911#comment-17893911
]
Jiangjie Qin commented on FLINK-16851:
--
I think most of the metrics have been added
[
https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36620:
Description:
Currently, most of FlinkCDC's command line arguments are supported in the
format `--$KEY $VA
[
https://issues.apache.org/jira/browse/FLINK-27632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-27632:
-
Assignee: Poorvank Bhatia
> Improve connector testing framework to support more cases
>
flinkbot commented on PR #25589:
URL: https://github.com/apache/flink/pull/25589#issuecomment-2444516868
## CI report:
* b3233bfef81e4faf868f0bf92bcf742594e7e5a8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ztison opened a new pull request, #25589:
URL: https://github.com/apache/flink/pull/25589
## What is the purpose of the change
This PR fixes the log-level regression introduced in
https://github.com/apache/flink/pull/25280#discussion_r1818949028
## Brief change log
*
dawidwys commented on code in PR #24699:
URL: https://github.com/apache/flink/pull/24699#discussion_r1820335891
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecMatch.java:
##
@@ -51,7 +71,95 @@ public BatchExecMatch(
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893907#comment-17893907
]
Ahmed Hamdy commented on FLINK-28177:
-
[~martijnvisser] I see the
[PR|https://githu
Roman Khachatryan created FLINK-36623:
-
Summary: Improve logging in DefaultStateTransitionManager
Key: FLINK-36623
URL: https://issues.apache.org/jira/browse/FLINK-36623
Project: Flink
Is
AHeise commented on code in PR #25547:
URL: https://github.com/apache/flink/pull/25547#discussion_r1820836505
##
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/operators/sink/CommitterOperator.java:
##
@@ -164,41 +165,37 @@ public void notifyCheckpointComplete(lo
ztison commented on code in PR #25280:
URL: https://github.com/apache/flink/pull/25280#discussion_r1820968233
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/DefaultStateTransitionManager.java:
##
@@ -0,0 +1,434 @@
+/*
+ * Licensed to the Apache Softwa
snuyanzin commented on code in PR #31:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/31#discussion_r1821436745
##
flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubPublisher.java:
##
@@ -21,11 +21,14 @@
impo
[
https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893734#comment-17893734
]
Ferenc Csaky commented on FLINK-32315:
--
When I developed this, the "s3" related con
[
https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893734#comment-17893734
]
Ferenc Csaky edited comment on FLINK-32315 at 10/29/24 8:31 AM:
--
flinkbot commented on PR #25585:
URL: https://github.com/apache/flink/pull/25585#issuecomment-2443475748
## CI report:
* 33ea97c1bdd9ca2a9e0265600ae2ea36cad24476 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-36547:
-
Description:
As official docs said, `RowKind` sematics have been changed: -U -> -D, +D -> +I
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-36547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-36547:
-
Description:
As official docs said, `RowKind` sematics have been changed: -U -> -D, +D -> +I
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-36547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-36547:
-
Description:
As official docs said, `RowKind` sematics have been changed: -U -> -D, +D -> +I
{code:java}
fredia commented on code in PR #25515:
URL: https://github.com/apache/flink/pull/25515#discussion_r1820233250
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/ttl/TtlListState.java:
##
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
[
https://issues.apache.org/jira/browse/FLINK-36497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36497:
---
Labels: pull-request-available (was: )
> Remove all deprecated methods in `CatalogTable`
>
Edward-Gavin opened a new pull request, #25585:
URL: https://github.com/apache/flink/pull/25585
## What is the purpose of the change
Remove all deprecated methods in `CatalogTable`
## Brief change log
Remove all deprecated methods in `CatalogTable`
## Verif
zjjiang created FLINK-36620:
---
Summary: Add support for the flink-home parameter to be set in
both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats
Key: FLINK-36620
URL: https://issues.apache.org/jira/br
[
https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36620:
Description:
Currently, most of FlinkCDC's command line arguments are supported in the
format "--$KEY $VA
[
https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36620:
Description:
Currently, most of FlinkCDC's command line arguments are supported in the
format "--$KEY $VA
[
https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36620:
Description:
Currently, most of FlinkCDC's command line arguments are supported in the
format "-$KEY $VAL
[
https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36620:
Description:
Currently, most of FlinkCDC's command line arguments are supported in the
format "--$KEY $VA
pawel-big-lebowski commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1820485021
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java:
##
@@ -369,5 +416,43 @@
[
https://issues.apache.org/jira/browse/FLINK-36245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893764#comment-17893764
]
Piotr Nowojski commented on FLINK-36245:
Hi [~kunni], [~renqs] and [~leonard]. I
[
https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36620:
Description:
Currently, most of FlinkCDC's command line arguments are supported in the
format `--$KEY $VA
AHeise commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1820444037
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetIdentifierProvider.java:
##
@@ -0,0 +1,16 @@
+package org.apache
AHeise commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1820446158
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Softwa
AHeise commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1815659513
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java:
##
@@ -369,5 +416,43 @@ public Prod
stankiewicz commented on PR #33:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/33#issuecomment-2443713018
fixed style errors.
--
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
AHeise commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1820453815
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java:
##
@@ -369,5 +416,43 @@ public Prod
[
https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36620:
Description:
Currently, most of FlinkCDC's command line arguments are supported in the
format "--$KEY $VA
[
https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36620:
Description:
Currently, most of FlinkCDC's command line arguments are supported in the
format `\-\-$KEY $
[
https://issues.apache.org/jira/browse/FLINK-36547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-36547:
-
Summary: Add option to retain `RowKind` sematics for cdc formats (was: Add
option to retain `RowKind` s
[
https://issues.apache.org/jira/browse/FLINK-36547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-36547:
-
Description:
As official docs said, `RowKind` sematics have been changed: -U -> -D, +D -> +I
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-36547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-36547:
-
Description:
As official docs said, `RowKind` semantics have been changed: -U -> -D, +D -> +I
{code:java
JunRuiLee commented on code in PR #25578:
URL: https://github.com/apache/flink/pull/25578#discussion_r1820633873
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/JoinUtil.scala:
##
@@ -275,4 +281,32 @@ object JoinUtil {
rowCount
1 - 100 of 121 matches
Mail list logo
