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
1996fanrui commented on code in PR #904:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/904#discussion_r1821951582
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ParallelismAdjuster.java:
##
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the Apache Software
Weijie Guo created FLINK-36628:
--
Summary: OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP
Key: FLINK-36628
URL: https://issues.apache.org/jira/browse/FLINK-36628
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-36628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36628:
---
Description:
{code:java}
Oct 30 03:49:31 03:49:31.315 [ERROR]
OpenTelemetryMetricReporterITCase.t
flinkbot commented on PR #25591:
URL: https://github.com/apache/flink/pull/25591#issuecomment-2445776160
## CI report:
* 8ff3516af1880d75c923cb2410fd47366bbe362f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-35268.
Resolution: Resolved
Merged into master via dbfc83d1cfd16bb464fe8d2329b4b13cd440820d
> Support TT
zhuzhurk commented on code in PR #25414:
URL: https://github.com/apache/flink/pull/25414#discussion_r1818916132
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/util/ImmutableStreamGraph.java:
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundat
[
https://issues.apache.org/jira/browse/FLINK-35268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-35268:
--
Assignee: Yanfei Lei
> Support TTL for Async State API
> ---
>
>
github-actions[bot] closed pull request #3501: Refactored Identifiers
URL: https://github.com/apache/flink-cdc/pull/3501
--
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 unsu
fredia merged PR #25515:
URL: https://github.com/apache/flink/pull/25515
--
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 commented on PR #25515:
URL: https://github.com/apache/flink/pull/25515#issuecomment-2445760601
Thanks for the detailed review🚀, merged
--
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
[
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` semantics for cdc formats (was:
Add option to retain `RowKind`
[
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
[
https://issues.apache.org/jira/browse/FLINK-36068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36068:
---
Labels: pull-request-available (was: )
> Support for adaptive job scheduling based on Strea
JunRuiLee opened a new pull request, #25591:
URL: https://github.com/apache/flink/pull/25591
## What is the purpose of the change
[FLINK-36068][runtime] Support for adaptive job scheduling based on
StreamGraph
## Brief change log
Introduce the AdaptiveExecuti
[
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
[
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:
-
Summary: Add option to retain `RowKind` sematics for cdc formats (was: Add
option to retain `RowKind` s
AlexYinHan commented on PR #25587:
URL: https://github.com/apache/flink/pull/25587#issuecomment-2445718309
@Zakelly Thanks for the comments. I've resolved them.
--
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
[
https://issues.apache.org/jira/browse/FLINK-36161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36161:
---
Labels: pull-request-available (was: )
> Integration Test Example uses deprecated SinkFunct
leonardBang commented on code in PR #3619:
URL: https://github.com/apache/flink-cdc/pull/3619#discussion_r1821773381
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/PendingSplitsStateSerializer.java
Zakelly commented on code in PR #25587:
URL: https://github.com/apache/flink/pull/25587#discussion_r1821775190
##
flink-test-utils-parent/flink-test-utils/src/test/java/org/apache/flink/state/benchmark/StateBackendBenchmarkUtils.java:
##
@@ -280,10 +280,15 @@ public static void
flinkbot commented on PR #25590:
URL: https://github.com/apache/flink/pull/25590#issuecomment-2445693542
## CI report:
* fad3e72e06bf99b6564b4fe6b2168e7f2e0533ae UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
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:
-
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
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 `
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
[
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
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
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.
--
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 #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.
--
[
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,
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-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.
[
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:
---
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.
[
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
[
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.
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
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
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-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
[
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
>
[
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-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
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
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
[
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
> -
[
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
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(
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
*
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
[
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
> ---
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 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
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
[
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
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
[
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
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
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`
[
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
> --
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
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
[
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
[
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
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
[
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
[
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
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
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
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
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
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 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:
---
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
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
[
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-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-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
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 @@
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
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
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
1 - 100 of 121 matches
Mail list logo
