Zakelly commented on PR #21389:
URL: https://github.com/apache/flink/pull/21389#issuecomment-2443052225
:D Sure, will take a look
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific com
[
https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqigeng updated FLINK-36619:
--
Description:
If some tables are removed from the `tables` parameter and then re-added, the
`CreateTab
Mrart commented on PR #3211:
URL: https://github.com/apache/flink-cdc/pull/3211#issuecomment-2443322635
@whhe RichSourceFunction is Deprecated interface，We can implements use
Source interface？
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-36614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893698#comment-17893698
]
LvYanquan commented on FLINK-36614:
---
looks like this issue is the same with
https://i
[
https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqigeng updated FLINK-36619:
--
Description:
If some tables are removed from the `tables` parameter and then re-added, the
`CreateTab
[
https://issues.apache.org/jira/browse/FLINK-36618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36618:
---
Labels: pull-request-available (was: )
> Improve PostgresDialect.discoverDataCollections to
loserwang1024 commented on PR #3672:
URL: https://github.com/apache/flink-cdc/pull/3672#issuecomment-2443271198
@ruanhang1993 @leonardBang @GOODBOY008 , CC
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above
[
https://issues.apache.org/jira/browse/FLINK-36502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893693#comment-17893693
]
Shengbo commented on FLINK-36502:
-
Hi [~xuyangzhong] , I've fixed the failed test cases.
Zakelly commented on code in PR #25515:
URL: https://github.com/apache/flink/pull/25515#discussion_r1820059326
##
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) un
linqigeng created FLINK-36619:
-
Summary: Downstream lost the CreateTableEvent when tables were
removed and then re-added
Key: FLINK-36619
URL: https://issues.apache.org/jira/browse/FLINK-36619
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqigeng updated FLINK-36619:
--
Description:
If some tables are removed from the `tables` parameter and then re-added, the
`CreateTab
[
https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqigeng updated FLINK-36619:
--
Description:
If some tables are removed from the `tables` parameter and then re-added, the
`CreateTab
[
https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqigeng updated FLINK-36619:
--
Description:
If some tables are removed from the `tables` parameter and then re-added, the
`CreateTab
[
https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqigeng updated FLINK-36619:
--
Attachment: image-2024-10-29-12-04-26-718.png
> Downstream lost the CreateTableEvent when tables were
[
https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqigeng updated FLINK-36619:
--
Description:
If some tables are removed from the `tables` parameter and then re-added, the
`CreateTab
[
https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqigeng updated FLINK-36619:
--
Description:
If some tables are removed from the `tables` parameter and then re-added, the
`CreateTab
flinkbot commented on PR #25584:
URL: https://github.com/apache/flink/pull/25584#issuecomment-2443126627
## CI report:
* 6705cf684ad6a8693d6af4dbab36b39b9a9f5d00 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893687#comment-17893687
]
jarrod commented on FLINK-36497:
I will do it.
> Remove all deprecated methods in `Cata
[
https://issues.apache.org/jira/browse/FLINK-36161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893686#comment-17893686
]
Jinhao Ran commented on FLINK-36161:
Hi, can this issue be assigned to me as my firs
[
https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-32315:
--
Attachment: image-2024-10-29-11-32-25-979.png
> Support local file upload in K8s mode
> --
[
https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893685#comment-17893685
]
melin edited comment on FLINK-32315 at 10/29/24 3:34 AM:
-
Can't
[
https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893685#comment-17893685
]
melin commented on FLINK-32315:
---
./bin/flink run-application \
--target kubernetes-app
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893684#comment-17893684
]
Anil Dasari commented on FLINK-36584:
-
[~loserwang1024] Thank you for your assistanc
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anil Dasari closed FLINK-36584.
---
Resolution: Not A Bug
> PostgresIncrementalSource is not exiting the flink execution when
> Startup
[
https://issues.apache.org/jira/browse/FLINK-36174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-36174.
---
Resolution: Fixed
master(3.3-SNAPSHOT):aa4f15a6364227d39fa2c586b4fdac507f627fc7
> CDC yaml without
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893681#comment-17893681
]
Anil Dasari commented on FLINK-36584:
-
[~loserwang1024] Thank you for the details.
[
https://issues.apache.org/jira/browse/FLINK-36504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36504:
---
Labels: pull-request-available (was: )
> Remove all deprecated methods `ModuleFactory`
> --
Edward-Gavin opened a new pull request, #25584:
URL: https://github.com/apache/flink/pull/25584
## What is the purpose of the change
Remove all deprecated methods `ModuleFactory`
## Brief change log
Remove all deprecated methods `ModuleFactory`
## Verifying
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893683#comment-17893683
]
Hongshun Wang commented on FLINK-36584:
---
[~dasarianil] , Maybe slack of flink cdc
[
https://issues.apache.org/jira/browse/FLINK-36609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893680#comment-17893680
]
Hongshun Wang commented on FLINK-36609:
---
I'd like to do it.
> Protobuf Format not
Hongshun Wang created FLINK-36618:
-
Summary: Improve PostgresDialect.discoverDataCollections to reduce
the start time of Postgres CDC
Key: FLINK-36618
URL: https://issues.apache.org/jira/browse/FLINK-36618
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anil Dasari updated FLINK-36584:
Attachment: image-2024-10-28-20-14-27-255.png
> PostgresIncrementalSource is not exiting the flink
ruanhang1993 merged PR #3588:
URL: https://github.com/apache/flink-cdc/pull/3588
--
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...@flin
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893675#comment-17893675
]
Zakelly Lan commented on FLINK-4602:
Merge 316daca into master
> Move RocksDB backen
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893673#comment-17893673
]
Anil Dasari commented on FLINK-36584:
-
> Yes, when skip backfill, the snapshot spot
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893670#comment-17893670
]
Hongshun Wang commented on FLINK-36584:
---
Yes, when skip backfill, the snapshot spo
lvyanquan commented on code in PR #3648:
URL: https://github.com/apache/flink-cdc/pull/3648#discussion_r1820005853
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriterHelper.java:
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893676#comment-17893676
]
Hongshun Wang commented on FLINK-36584:
---
[~dasarianil] ,
> Is there a reason for
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-36584:
--
Attachment: image-2024-10-29-10-44-23-005.png
> PostgresIncrementalSource is not exiting the f
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-4602.
Resolution: Fixed
> Move RocksDB backend to proper package
> --
Zakelly merged PR #25543:
URL: https://github.com/apache/flink/pull/25543
--
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
tudou-sunge opened a new pull request, #3671:
URL: https://github.com/apache/flink-cdc/pull/3671
we need record the binlog_name first, besease when start with timestamp
option the binlog_name will be '', until the binglog changed
--
This is an automated message from the Apache Git Service
hackergin commented on PR #25579:
URL: https://github.com/apache/flink/pull/25579#issuecomment-2443033568
Test failed because of https://issues.apache.org/jira/browse/FLINK-36613
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
hackergin commented on PR #25579:
URL: https://github.com/apache/flink/pull/25579#issuecomment-2443033303
@xuyangzhong Please help review the pr if you are free.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-36584:
--
Attachment: image-2024-10-29-10-00-44-321.png
> PostgresIncrementalSource is not exiting the f
[
https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893669#comment-17893669
]
Feng Jin commented on FLINK-36613:
--
Another failed tests.
https://dev.azure.com/apache
[
https://issues.apache.org/jira/browse/FLINK-36159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-36159:
---
Assignee: xingbe
> FLIP-470: Support Adaptive Broadcast Join
>
[
https://issues.apache.org/jira/browse/FLINK-36607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-36607:
---
Assignee: xingbe
> Introduce AdaptiveBroadcastJoinProcessor to inject adaptive broadcast join
> ---
[
https://issues.apache.org/jira/browse/FLINK-36608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-36608:
---
Assignee: xingbe
> Support dynamic StreamGraph optimization for AdaptiveBroadcastJoinOperator
> ---
github-actions[bot] commented on PR #3552:
URL: https://github.com/apache/flink-cdc/pull/3552#issuecomment-2442898656
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.
--
mbalassi merged PR #758:
URL: https://github.com/apache/flink-web/pull/758
--
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
stankiewicz commented on PR #33:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/33#issuecomment-2442504832
@vahmed-hamdy done, thanks for the suggestions.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot commented on PR #25583:
URL: https://github.com/apache/flink/pull/25583#issuecomment-2442469719
## CI report:
* dd09f113b30403cb8b1407d716f75cc52feba208 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mxm commented on code in PR #904:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/904#discussion_r1819378159
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ParallelismAdjuster.java:
##
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the Apache Software Founda
[
https://issues.apache.org/jira/browse/FLINK-36617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36617:
---
Labels: pull-request-available (was: )
> Migrate kryo package
>
>
>
r-sidd opened a new pull request, #25583:
URL: https://github.com/apache/flink/pull/25583
## What is the purpose of the change
Migrate kryo package
## Brief change log
Kryo has been moved to the com.esotericsoftware package. Updating to this
version will enhance capabili
Siddharth R created FLINK-36617:
---
Summary: Migrate kryo package
Key: FLINK-36617
URL: https://issues.apache.org/jira/browse/FLINK-36617
Project: Flink
Issue Type: Improvement
Report
AHeise commented on code in PR #25547:
URL: https://github.com/apache/flink/pull/25547#discussion_r1819084931
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/connector/sink2/CommittableSummary.java:
##
@@ -39,11 +39,21 @@ public class CommittableSummary implements
jnh5y commented on code in PR #24699:
URL: https://github.com/apache/flink/pull/24699#discussion_r1819468595
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/MatchRecognizeITCase.java:
##
@@ -567,7 +912,7 @@ void testUserDefinedFu
[
https://issues.apache.org/jira/browse/FLINK-36616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36616:
---
Labels: pull-request-available (was: )
> Null pointer in PubSub's GcpPublisherConfig
> ---
stankiewicz commented on PR #33:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/33#issuecomment-2442159071
@vahmed-hamdy would you be able to take a look at this and merge it?
Also, do you happen to know what is the release cycle for this connector?
--
This is an autom
[
https://issues.apache.org/jira/browse/FLINK-36616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893543#comment-17893543
]
Radosław Stankiewicz commented on FLINK-36616:
--
https://github.com/apache/f
Radosław Stankiewicz created FLINK-36616:
Summary: Null pointer in PubSub's GcpPublisherConfig
Key: FLINK-36616
URL: https://issues.apache.org/jira/browse/FLINK-36616
Project: Flink
boring-cyborg[bot] commented on PR #33:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/33#issuecomment-2442135742
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This
grzegorz8 commented on code in PR #24699:
URL: https://github.com/apache/flink/pull/24699#discussion_r1819361358
##
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
grzegorz8 commented on PR #21841:
URL: https://github.com/apache/flink/pull/21841#issuecomment-2441855866
Hey @chucheng92 ! What is the current status of this FLIP? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
flinkbot commented on PR #25582:
URL: https://github.com/apache/flink/pull/25582#issuecomment-2441838852
## CI report:
* 56b898b6740e62590ca6c69bd9d0877b1422ed4a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dawidwys opened a new pull request, #25582:
URL: https://github.com/apache/flink/pull/25582
## What is the purpose of the change
Support `LEAD/LAG` functions natively in Table API.
## Verifying this change
To be done
## Does this pull request potentially af
[
https://issues.apache.org/jira/browse/FLINK-36615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36615:
---
Labels: pull-request-available (was: )
> Support LEAD/LAG functions in Table API
>
[
https://issues.apache.org/jira/browse/FLINK-33525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-33525:
-
Assignee: Poorvank Bhatia
> Migrate LoadSimulationPipeline in Flink K8S Operato
kimgr commented on PR #25340:
URL: https://github.com/apache/flink/pull/25340#issuecomment-2441682715
Added a multi-threaded testcase. It fails on average 50% of the time before
the bugfix, succeeds consistently after. Runtime on my system is ~5 seconds.
Let me know what you think.
--
Th
Dawid Wysakowicz created FLINK-36615:
Summary: Support LEAD/LAG functions in Table API
Key: FLINK-36615
URL: https://issues.apache.org/jira/browse/FLINK-36615
Project: Flink
Issue Type: I
SML0127 commented on PR #3529:
URL: https://github.com/apache/flink-cdc/pull/3529#issuecomment-2441714262
@ruanhang1993
Could you please take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
[
https://issues.apache.org/jira/browse/FLINK-36611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893468#comment-17893468
]
Andrew Otto commented on FLINK-36611:
-
This will be very useful!
Having Kafka in
hlteoh37 commented on code in PR #25548:
URL: https://github.com/apache/flink/pull/25548#discussion_r1819083958
##
flink-runtime-web/web-dashboard/src/app/components/dagre/components/node/node.component.ts:
##
@@ -82,7 +84,7 @@ export class NodeComponent {
}
isValid = (v
Sud0x67 commented on PR #25559:
URL: https://github.com/apache/flink/pull/25559#issuecomment-2441529771
@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.
flinkbot commented on PR #25581:
URL: https://github.com/apache/flink/pull/25581#issuecomment-2441474387
## CI report:
* 15a2d24c65bb7cd59242cc107a428728ca5aa3d3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
noorall commented on code in PR #25414:
URL: https://github.com/apache/flink/pull/25414#discussion_r1816403718
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/util/StreamEdgeUpdateRequestInfo.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Software F
rkhachatryan commented on code in PR #25280:
URL: https://github.com/apache/flink/pull/25280#discussion_r1818949028
##
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-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893434#comment-17893434
]
Sergey Nuyanzin commented on FLINK-36613:
-
[~roman], [~pnowojski] since you were
[
https://issues.apache.org/jira/browse/FLINK-32483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893435#comment-17893435
]
Sergey Nuyanzin commented on FLINK-32483:
-
[~dmvk] I wonder whether it could be
snuyanzin opened a new pull request, #25581:
URL: https://github.com/apache/flink/pull/25581
## What is the purpose of the change
There is a floating issue while execution of
`RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState`
also could be reproduced loca
[
https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-36613:
Labels: pull-request-available test-stability (was: pull-request-available)
> RescaleChec
rkhachatryan commented on code in PR #25280:
URL: https://github.com/apache/flink/pull/25280#discussion_r1818949028
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/DefaultStateTransitionManager.java:
##
@@ -0,0 +1,434 @@
+/*
+ * Licensed to the Apache
noorall commented on code in PR #25414:
URL: https://github.com/apache/flink/pull/25414#discussion_r1816403718
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/util/StreamEdgeUpdateRequestInfo.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Software F
[
https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36613:
---
Labels: pull-request-available (was: )
> RescaleCheckpointManuallyITCase.testCheckpointResc
[
https://issues.apache.org/jira/browse/FLINK-36612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-36612:
-
Issue Type: New Feature (was: Bug)
> Flink TypeSerializer doesn't recognize valid POJO
Youle created FLINK-36614:
-
Summary: mysql cdc will be stuck when the ChangeEventQueue is full
at snapshot consume phase
Key: FLINK-36614
URL: https://issues.apache.org/jira/browse/FLINK-36614
Project: Flink
rkhachatryan commented on code in PR #25280:
URL: https://github.com/apache/flink/pull/25280#discussion_r1818949028
##
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-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893415#comment-17893415
]
Sergey Nuyanzin edited comment on FLINK-36613 at 10/28/24 12:03 PM:
--
hlteoh37 merged PR #11:
URL: https://github.com/apache/flink-connector-prometheus/pull/11
--
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-unsubsc
[
https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893415#comment-17893415
]
Sergey Nuyanzin commented on FLINK-36613:
-
It is very likely that the reason is
Sergey Nuyanzin created FLINK-36613:
---
Summary:
RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP
Key: FLINK-36613
URL: https://issues.apache.org/jira/browse/FLINK-36613
[
https://issues.apache.org/jira/browse/FLINK-36288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36288:
---
Labels: pull-request-available (was: )
> Set up architectural test
> --
nicusX opened a new pull request, #12:
URL: https://github.com/apache/flink-connector-prometheus/pull/12
## Purpose of the change
* Add archunit tests and initialize archunit-violations
## Verifying this change
This change is a trivial rework / code cleanup without any te
[
https://issues.apache.org/jira/browse/FLINK-36612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-36612:
Description:
When creating a POJO using Lombok, the getters and setters are automatically
[
https://issues.apache.org/jira/browse/FLINK-36612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-36612:
Description:
When creating a POJO using Lombok, the getters and setters are automatically
Hong Liang Teoh created FLINK-36612:
---
Summary: Flink TypeSerializer doesn't recognize valid POJO
getters/setters generated by Lombok
Key: FLINK-36612
URL: https://issues.apache.org/jira/browse/FLINK-36612
snuyanzin commented on PR #21389:
URL: https://github.com/apache/flink/pull/21389#issuecomment-2441365848
@Zakelly sorry for the ping
do you mind if I ask you to have a look here (GitHub says you are the most
matching person)
--
This is an automated message from the Apache Git Service.
pawel-big-lebowski commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1818800029
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetIdentifierProvider.java:
##
@@ -0,0 +1,16 @@
+packag
1 - 100 of 138 matches
Mail list logo
