rafaelzimmermann commented on PR #26203:
URL: https://github.com/apache/flink/pull/26203#issuecomment-2795988413
Hey @davidradl, can you have another look at this PR?
--
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-37644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943428#comment-17943428
]
Arvid Heise commented on FLINK-37644:
-
Merged into main as
d44f57458d4198389f804f81
github-actions[bot] commented on PR #25850:
URL: https://github.com/apache/flink/pull/25850#issuecomment-2795950567
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
github-actions[bot] commented on PR #25883:
URL: https://github.com/apache/flink/pull/25883#issuecomment-2795950661
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
github-actions[bot] commented on PR #25823:
URL: https://github.com/apache/flink/pull/25823#issuecomment-2795950513
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
[
https://issues.apache.org/jira/browse/FLINK-37644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-37644:
---
Assignee: Arvid Heise (was: Yanquan Lv)
> flink-sql-connector-kafka leaks Guava dependency
[
https://issues.apache.org/jira/browse/FLINK-37644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-37644:
Summary: flink-sql-connector-kafka leaks Guava dependency (was: Include
guava dependency to packa
beliefer commented on PR #26429:
URL: https://github.com/apache/flink/pull/26429#issuecomment-2795931303
ping @kl0u
--
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
beliefer commented on PR #26428:
URL: https://github.com/apache/flink/pull/26428#issuecomment-2795928329
ping @ferenc-csaky @kl0u @wangyang0918 cc @1996fanrui @davidradl @GOODBOY008
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/FLINK-37644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-37644:
Issue Type: Bug (was: Improvement)
> Include guava dependency to package of Kafka connector relea
AHeise merged PR #170:
URL: https://github.com/apache/flink-connector-kafka/pull/170
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-37627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37627:
---
Labels: pull-request-available (was: )
> Restarting from a checkpoint/savepoint which coinc
boring-cyborg[bot] commented on PR #198:
URL:
https://github.com/apache/flink-connector-aws/pull/198#issuecomment-2795923065
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is a
arunlakshman opened a new pull request, #198:
URL: https://github.com/apache/flink-connector-aws/pull/198
## Purpose of the change
*For example: Implements the Table API for the Kinesis Source.*
## Verifying this change
Please make sure both new and modifi
[
https://issues.apache.org/jira/browse/FLINK-37479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943427#comment-17943427
]
Hongshun Wang commented on FLINK-37479:
---
[~phamvinh1712] As I discussed in
[https
[
https://issues.apache.org/jira/browse/FLINK-37653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yux updated FLINK-37653:
Description:
Currently, HybridSplitAssigners and StreamSplitAssigners in incremental
snapshot framework implicitl
[
https://issues.apache.org/jira/browse/FLINK-37652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943424#comment-17943424
]
Sergey Nuyanzin commented on FLINK-37652:
-
done, thank you for driving this
> [
[
https://issues.apache.org/jira/browse/FLINK-37652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-37652:
---
Assignee: Andriy Redko
> [Connectors/Opensearch] Move to Flink to 2.0.0
> -
hmit commented on PR #103:
URL:
https://github.com/apache/flink-connector-kafka/pull/103#issuecomment-2795888382
@tomncooper thanks for taking the time to look at it and providing feedback!
I've updated the PR description with some details, is it possible to give this
another look?
[
https://issues.apache.org/jira/browse/FLINK-34992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943418#comment-17943418
]
Hao Li commented on FLINK-34992:
Hi [~fsk119] ,
These are good question as I'm startin
[
https://issues.apache.org/jira/browse/FLINK-37653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37653:
--
Assignee: yux
> Incremental snapshot framework supports assigning multiple StreamSplit
>
flinkbot commented on PR #26439:
URL: https://github.com/apache/flink/pull/26439#issuecomment-2795702739
## CI report:
* c01e43d7f1356c0c40af2511cfce58dca12f0afe UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943406#comment-17943406
]
dalongliu commented on FLINK-34992:
---
Hi [~lihaosky], it will be a great work if we can
fredia opened a new pull request, #26439:
URL: https://github.com/apache/flink/pull/26439
Backport https://github.com/apache/flink/pull/26419 to release-2.0
## What is the purpose of the change
This PR adds async state support for `process()` in Datastream API
## Brie
reswqa commented on PR #26437:
URL: https://github.com/apache/flink/pull/26437#issuecomment-2795690581
> I wonder if we should add the test case mentioned in the Jira to the
datagen docs as an example WDYT?
@davidradl The documentation indeed is not very friendly especially when it
d
beliefer commented on PR #26425:
URL: https://github.com/apache/flink/pull/26425#issuecomment-2795689343
ping @guoweiM @1996fanrui cc @davidradl @GOODBOY008
--
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
beliefer commented on PR #26427:
URL: https://github.com/apache/flink/pull/26427#issuecomment-2795687276
ping @tisonkun cc @1996fanrui @davidradl @GOODBOY008
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
[
https://issues.apache.org/jira/browse/FLINK-37623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-37623.
Resolution: Fixed
Merged into master via 98000fbe598ca20eedf6411672509af9624a58ac
> Async state s
fredia merged PR #26419:
URL: https://github.com/apache/flink/pull/26419
--
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
beliefer commented on PR #26429:
URL: https://github.com/apache/flink/pull/26429#issuecomment-2795677694
@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.
JNSimba commented on PR #3767:
URL: https://github.com/apache/flink-cdc/pull/3767#issuecomment-2795676279
> @JNSimba In the backfill task, there may be one problem for projection.
See `RecordUtils.upsertBinlog` in `SnapshotSplitReader#pollSplitRecords`.
>
> For tables with PK, we use
yux created FLINK-37653:
---
Summary: Incremental snapshot framework supports assigning
multiple StreamSplit
Key: FLINK-37653
URL: https://issues.apache.org/jira/browse/FLINK-37653
Project: Flink
Issue T
lvyanquan closed pull request #167: [FLINK-37644] Include guava dependency and
shade it.
URL: https://github.com/apache/flink-connector-kafka/pull/167
--
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
lvyanquan commented on PR #167:
URL:
https://github.com/apache/flink-connector-kafka/pull/167#issuecomment-2795614887
Closed as https://github.com/apache/flink-connector-kafka/pull/170 provided
a more thorough solution
--
This is an automated message from the Apache Git Service.
To respo
[
https://issues.apache.org/jira/browse/FLINK-37652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943402#comment-17943402
]
Andriy Redko commented on FLINK-37652:
--
[~Sergey Nuyanzin] could you please assign
yeoleobun closed pull request #26021: [hotfix][doc] Fix typo in 'Full Window
Partition Processing on DataStream' example code
URL: https://github.com/apache/flink/pull/26021
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-37652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37652:
---
Labels: pull-request-available (was: )
> [Connectors/Opensearch] Move to Flink to 2.0.0
> -
[
https://issues.apache.org/jira/browse/FLINK-37652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andriy Redko updated FLINK-37652:
-
Fix Version/s: (was: 3.0.0)
> [Connectors/Opensearch] Move to Flink to 2.0.0
> -
Andriy Redko created FLINK-37652:
Summary: [Connectors/Opensearch] Move to Flink to 2.0.0
Key: FLINK-37652
URL: https://issues.apache.org/jira/browse/FLINK-37652
Project: Flink
Issue Type: Bu
hql0312 commented on PR #3983:
URL: https://github.com/apache/flink-cdc/pull/3983#issuecomment-2795541630
> > and the change code how to performance the logic ?
>
> Hi, @Mrart , @hql0312 . this pr is mainly focused on most situations. As I
discussed in #2571, In snapshot split phase,
davidradl commented on code in PR #26415:
URL: https://github.com/apache/flink/pull/26415#discussion_r2033079768
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataInputStream.java:
##
@@ -196,72 +213,87 @@ synchronized
[
https://issues.apache.org/jira/browse/FLINK-37642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-37642:
Fix Version/s: 2.1.0
> Use the mailboxExecutor for operator in Async state processing
> --
github-actions[bot] commented on PR #25878:
URL: https://github.com/apache/flink/pull/25878#issuecomment-2788406161
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
[
https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-30371:
--
Fix Version/s: jdbc-4.0.0
(was: jdbc-3.3.0)
> JdbcOutputFormat is at risk of da
github-actions[bot] commented on PR #25471:
URL: https://github.com/apache/flink/pull/25471#issuecomment-2785362107
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
github-actions[bot] commented on PR #25696:
URL: https://github.com/apache/flink/pull/25696#issuecomment-2788405525
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
[
https://issues.apache.org/jira/browse/FLINK-36516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-36516:
Issue Type: Technical Debt (was: Improvement)
> Migrate deprecated SinkV2 API to new API introdu
[
https://issues.apache.org/jira/browse/FLINK-37625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37625:
---
Labels: pull-request-available (was: )
> PyFlink Table API skips validation for Rows create
dawidwys commented on code in PR #26436:
URL: https://github.com/apache/flink/pull/26436#discussion_r2036846898
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/data/DataStructureConvertersTest.java:
##
@@ -355,7 +355,62 @@ static List testData() {
[
https://issues.apache.org/jira/browse/FLINK-37407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-37407.
-
> Add meta information to SQL state connector
> ---
>
>
Zakelly Lan created FLINK-37642:
---
Summary: Use the mailboxExecutor for operator in Async state
processing
Key: FLINK-37642
URL: https://issues.apache.org/jira/browse/FLINK-37642
Project: Flink
lvyanquan commented on code in PR #3904:
URL: https://github.com/apache/flink-cdc/pull/3904#discussion_r2034717354
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergWriter.java:
##
rkhachatryan commented on code in PR #26320:
URL: https://github.com/apache/flink/pull/26320#discussion_r2032884834
##
docs/layouts/shortcodes/generated/rest_v1_dispatcher.html:
##
@@ -509,7 +509,72 @@
"properties" : {
"plan" : {
"type" : "object",
- "id" :
github-actions[bot] commented on PR #25634:
URL: https://github.com/apache/flink/pull/25634#issuecomment-2788405114
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
loserwang1024 commented on code in PR #3980:
URL: https://github.com/apache/flink-cdc/pull/3980#discussion_r2034743082
##
docs/content/docs/connectors/pipeline-connectors/kafka.md:
##
@@ -149,7 +149,7 @@ Pipeline Connector Options
Custom table mappings for each table from
lvyanquan closed pull request #168: [FLINK-37644] Include guava dependency and
shade it.
URL: https://github.com/apache/flink-connector-kafka/pull/168
--
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
davidradl commented on code in PR #26430:
URL: https://github.com/apache/flink/pull/26430#discussion_r2035559270
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/ScanReuserUtils.java:
##
@@ -203,7 +204,13 @@ private static WatermarkPushD
akalash commented on code in PR #26320:
URL: https://github.com/apache/flink/pull/26320#discussion_r2031268020
##
docs/layouts/shortcodes/generated/rest_v1_dispatcher.html:
##
@@ -509,7 +509,72 @@
"properties" : {
"plan" : {
"type" : "object",
- "id" :
"urn:
[
https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35363:
--
Fix Version/s: jdbc-4.0.0
(was: jdbc-3.3.0)
> FLIP-449: Reorganization of flink
FranMorilloAWS commented on code in PR #191:
URL:
https://github.com/apache/flink-connector-aws/pull/191#discussion_r2034866646
##
flink-catalog-aws-glue/src/main/java/com/amazonaws/services/msf/GlueCatalogFactory.java:
##
@@ -0,0 +1,66 @@
+package com.amazonaws.services.msf;
+
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031805203
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -212,4 +336,39 @@ private static void
assertTemporaryCr
[
https://issues.apache.org/jira/browse/FLINK-37476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-37476.
Resolution: Implemented
> Update Kafka connector's ChangelogMode
> ---
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031880386
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/ModelDescriptor.java:
##
@@ -0,0 +1,244 @@
+/*
+ * Licensed to the Apache Software Founda
[
https://issues.apache.org/jira/browse/FLINK-37629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chirag Dewan updated FLINK-37629:
-
Description:
In my use case, I have a 2 cluster Kafka deployment. One is primary and other
one
github-actions[bot] commented on PR #25814:
URL: https://github.com/apache/flink/pull/25814#issuecomment-2788406083
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
rmetzger merged PR #25511:
URL: https://github.com/apache/flink/pull/25511
--
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
dependabot[bot] commented on PR #135:
URL:
https://github.com/apache/flink-connector-kafka/pull/135#issuecomment-2782506506
Sorry, only users with push access can use that command.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031789883
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -158,6 +167,121 @@ void testTableFromDescriptor() {
[
https://issues.apache.org/jira/browse/FLINK-36832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-36832.
-
Resolution: Fixed
> Remove deprecated class in flink-connector-kafka
> -
github-actions[bot] commented on PR #25614:
URL: https://github.com/apache/flink/pull/25614#issuecomment-2788405035
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
beliefer commented on code in PR #26427:
URL: https://github.com/apache/flink/pull/26427#discussion_r2035317560
##
flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java:
##
@@ -440,7 +440,7 @@ private static String getEntryPointClassNameFromJar(URL
ja
mayuehappy commented on code in PR #26416:
URL: https://github.com/apache/flink/pull/26416#discussion_r2034907530
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackend.java:
##
@@ -445,6 +445,22 @@ private
Registered
[
https://issues.apache.org/jira/browse/FLINK-36058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rodrigo Meneses updated FLINK-36058:
Description:
OperatorTestHarness last completed checkpoint for recovery is always reset to
aiwenmo commented on code in PR #3812:
URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2034617315
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/DataSourceFactory.java:
##
@@ -28,4 +28,10 @@ public interface DataSourceFactory extends Facto
github-actions[bot] commented on PR #25442:
URL: https://github.com/apache/flink/pull/25442#issuecomment-2785361816
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
[
https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal closed FLINK-25380.
--
Resolution: Won't Fix
> Introduce DynamicTableSink & DynamicTableSource for RabbitMQ
> ---
davidradl commented on code in PR #161:
URL:
https://github.com/apache/flink-connector-kafka/pull/161#discussion_r2030661476
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterFaultToleranceITCase.java:
##
@@ -40,7 +40,7 @@ public class Kafk
hql0312 commented on PR #3979:
URL: https://github.com/apache/flink-cdc/pull/3979#issuecomment-2785088218
@leonardBang can you review it ?
--
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 spe
[
https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-34554.
-
Release Note: Sinks now support to reuse transactional ids to reduce the
pressure on Kafka broke
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031813534
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -158,6 +167,121 @@ void testTableFromDescriptor() {
[
https://issues.apache.org/jira/browse/FLINK-35811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942094#comment-17942094
]
Ruan Hang commented on FLINK-35811:
---
This issue is not a blocker for jdbc-3.3.0. Move
davidradl commented on code in PR #26430:
URL: https://github.com/apache/flink/pull/26430#discussion_r2035552895
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/ScanReuserUtils.java:
##
@@ -203,7 +204,13 @@ private static WatermarkPushD
yuxiqian opened a new pull request, #3986:
URL: https://github.com/apache/flink-cdc/pull/3986
This closes FLINK-37104.
...by refactoring transform module to improve code readability and
maintainability. No behavior changes are expected for all valid use cases.
Kindly ping @aiwe
dawidwys merged PR #26389:
URL: https://github.com/apache/flink/pull/26389
--
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-35811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35811:
--
Fix Version/s: jdbc-4.0.0
(was: jdbc-3.3.0)
> Add the documentation sections to
flinkbot commented on PR #26425:
URL: https://github.com/apache/flink/pull/26425#issuecomment-2788693483
## CI report:
* de930a07369941248b65473c2abfbdcfa8fd28cc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Weijie Guo created FLINK-37649:
--
Summary: Datagen connector cannot set length for collection type
Key: FLINK-37649
URL: https://issues.apache.org/jira/browse/FLINK-37649
Project: Flink
Issue Typ
beliefer commented on PR #26426:
URL: https://github.com/apache/flink/pull/26426#issuecomment-2789624251
@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.
dawidwys commented on code in PR #26436:
URL: https://github.com/apache/flink/pull/26436#discussion_r2036845844
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/data/DataStructureConvertersTest.java:
##
@@ -355,7 +355,62 @@ static List testData() {
beliefer commented on PR #26426:
URL: https://github.com/apache/flink/pull/26426#issuecomment-2792283654
ping @StephanEwen cc @1996fanrui @davidradl @GOODBOY008
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
aiwenmo commented on code in PR #3812:
URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2034621913
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java:
##
@@ -73,6 +73,12 @@ public SchemaManager() {
be
davidradl commented on code in PR #26419:
URL: https://github.com/apache/flink/pull/26419#discussion_r2032812978
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java:
##
@@ -358,9 +359,10 @@ public SingleOutputStreamOperator process(
@I
MOBIN-F commented on PR #3980:
URL: https://github.com/apache/flink-cdc/pull/3980#issuecomment-2785098828
@leonardBang PTAL
--
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.
davidradl commented on code in PR #957:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/957#discussion_r2037057434
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/FlinkDeploymentStatus.java:
##
@@ -55,4 +60,188 @@ pub
davidradl commented on code in PR #26415:
URL: https://github.com/apache/flink/pull/26415#discussion_r2032837282
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataInputStream.java:
##
@@ -102,62 +102,81 @@ private FSDa
github-actions[bot] commented on PR #25749:
URL: https://github.com/apache/flink/pull/25749#issuecomment-2788405884
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
[
https://issues.apache.org/jira/browse/FLINK-37626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan closed FLINK-37626.
---
Fix Version/s: 2.1.0
Resolution: Resolved
> Flaky test: ForStFlinkFileSystemTest.testSstFileI
Chirag Dewan created FLINK-37629:
Summary: Use Checkpointed Offset while migrating clusters in
DynamicKafkaSource
Key: FLINK-37629
URL: https://issues.apache.org/jira/browse/FLINK-37629
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-36648:
Fix Version/s: (was: kafka-4.0.0)
> Release flink-connector-kafka v4.0.0 for Flink 2.0
> -
snuyanzin commented on code in PR #26407:
URL: https://github.com/apache/flink/pull/26407#discussion_r2032433700
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala:
##
@@ -310,18 +310,26
1 - 100 of 186 matches
Mail list logo
