pnowojski commented on code in PR #24895:
URL: https://github.com/apache/flink/pull/24895#discussion_r1634312543
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java:
##
@@ -307,18 +307,37 @@ void onProcessingTime(long time
[
https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-33858.
-
Resolution: Fixed
> CI fails with No space left on device
>
steveGuRen commented on PR #2986:
URL: https://github.com/apache/flink-cdc/pull/2986#issuecomment-2159992536
@joyCurry30 @leonardBang Logically, it is considered a bug when I have to
read all tables in the schema, and the first execution of "alter table sql" is
not triggered. However, sinc
[
https://issues.apache.org/jira/browse/FLINK-28867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853942#comment-17853942
]
Jingsong Lee commented on FLINK-28867:
--
Looks not easy to support... Call for contr
steveGuRen commented on PR #2986:
URL: https://github.com/apache/flink-cdc/pull/2986#issuecomment-216384
In the design of TiDB, I find that they take into account the scenario of
having a large number of tables in a SaaS environment. Therefore, special
attention is given to the performa
gaborgsomogyi commented on code in PR #24914:
URL: https://github.com/apache/flink/pull/24914#discussion_r1634351465
##
flink-connectors/flink-file-sink-common/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/OutputStreamBasedPartFileWriter.java:
##
@@ -50,
leonardBang commented on code in PR #745:
URL: https://github.com/apache/flink-web/pull/745#discussion_r1634358337
##
docs/content/posts/2024-06-14-release-1.19.1.md:
##
@@ -0,0 +1,128 @@
+---
+title: "Apache Flink 1.19.1 Release Announcement"
+date: "2024-06-14T00:00:00.000Z"
中国无锡周良 created FLINK-35564:
--
Summary: The topic cannot be distributed on subtask when
calculatePartitionOwner returns -1
Key: FLINK-35564
URL: https://issues.apache.org/jira/browse/FLINK-35564
Project: Flink
hlteoh37 merged PR #142:
URL: https://github.com/apache/flink-connector-aws/pull/142
--
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...@
reswqa merged PR #24845:
URL: https://github.com/apache/flink/pull/24845
--
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
[
https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-35068.
--
Resolution: Done
master(1.20) via e1b45684394541ee290a3d81cc59a85623396c42
> Introduce built-in seria
[
https://issues.apache.org/jira/browse/FLINK-35458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35458:
---
Summary: Flink 2.0: Add serializer upgrade test for set serializer (was:
Add serializer upgrade tes
[
https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853965#comment-17853965
]
Danny Cranmer commented on FLINK-30400:
---
I agree this is frustrating. It is a simi
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853966#comment-17853966
]
Robert Metzger commented on FLINK-31238:
[~mayuehappy] what's the status of crea
[
https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-35559:
Fix Version/s: aws-connector-3.1.0
> Shading issue cause class conflict
>
[
https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853972#comment-17853972
]
Hong Liang Teoh commented on FLINK-35559:
-
merged commit
[{{20e4ee6}}|https://g
[
https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853971#comment-17853971
]
Hong Liang Teoh commented on FLINK-35559:
-
[~a.pilipenko] can we backport to v3.
[
https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-34123:
--
Release Note: Dedicated serialization support for four common Java
collection types: Map, List
[
https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-35068:
--
Release Note: Dedicated serialization support for four common Java
collection types: Map, List
[
https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853979#comment-17853979
]
Aleksandr Pilipenko commented on FLINK-35559:
-
{quote}can we backport to v3.
[
https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Pilipenko updated FLINK-35559:
Fix Version/s: (was: aws-connector-3.1.0)
> Shading issue cause class conflict
hlteoh37 commented on code in PR #24908:
URL: https://github.com/apache/flink/pull/24908#discussion_r1634474656
##
docs/layouts/shortcodes/generated/python_configuration.html:
##
@@ -24,7 +24,7 @@
python.executable
"python"
String
-
Zakelly closed pull request #24873: [FLINK-32081][checkpoint] Compatibility
between file-merging on and off across job runs
URL: https://github.com/apache/flink/pull/24873
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
[
https://issues.apache.org/jira/browse/FLINK-32081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853989#comment-17853989
]
Zakelly Lan commented on FLINK-32081:
-
master: f33808c0f02c12488d4de2f4d517da8b8b100
[
https://issues.apache.org/jira/browse/FLINK-32081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-32081.
-
Resolution: Fixed
> Compatibility between file-merging on and off across job runs
>
[
https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853990#comment-17853990
]
Ran Tao commented on FLINK-12450:
-
[~kartikeypant] thanks for pushing this issue, feel f
[
https://issues.apache.org/jira/browse/FLINK-32091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-32091:
---
Assignee: Yanfei Lei (was: Hangxiang Yu)
> Add necessary metrics for file-merging
> --
Naci Simsek created FLINK-35565:
---
Summary: Flink KafkaSource Batch Job Gets Into Infinite Loop after
Resetting Offset
Key: FLINK-35565
URL: https://issues.apache.org/jira/browse/FLINK-35565
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-35565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Naci Simsek updated FLINK-35565:
Description:
h2. Summary
Flink batch job gets into an infinite fetch loop and could not gracefull
Martijn Visser created FLINK-35566:
--
Summary: Consider promoting TypeSerializer from PublicEvolving to
Public
Key: FLINK-35566
URL: https://issues.apache.org/jira/browse/FLINK-35566
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35567:
--
Affects Version/s: cdc-3.1.1
(was: cdc-3.2.0)
> CDC BinaryWriter ca
Hongshun Wang created FLINK-35567:
-
Summary: CDC BinaryWriter cast NullableSerializerWrapper error
Key: FLINK-35567
URL: https://issues.apache.org/jira/browse/FLINK-35567
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-35567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35567:
--
Fix Version/s: cdc-3.2.0
(was: cdc-3.1.1)
> CDC BinaryWriter cast Nulla
[
https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-35559.
-
Resolution: Fixed
> Shading issue cause class conflict
> ---
leonardBang merged PR #3396:
URL: https://github.com/apache/flink-cdc/pull/3396
--
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
GOODBOY008 opened a new pull request, #3408:
URL: https://github.com/apache/flink-cdc/pull/3408
(no comment)
--
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,
[
https://issues.apache.org/jira/browse/FLINK-35540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35540:
---
Fix Version/s: cdc-3.2.0
cdc-3.1.1
> flink-cdc-pipeline-connector-mysql lost tabl
[
https://issues.apache.org/jira/browse/FLINK-35540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35540:
--
Assignee: linqigeng
> flink-cdc-pipeline-connector-mysql lost table which database and table
[
https://issues.apache.org/jira/browse/FLINK-35540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854012#comment-17854012
]
Leonard Xu commented on FLINK-35540:
master: c958daf8ab417d16fc7fc0b59f341e8f9cf372e
GOODBOY008 commented on PR #3408:
URL: https://github.com/apache/flink-cdc/pull/3408#issuecomment-2160480202
@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
leonardBang merged PR #3408:
URL: https://github.com/apache/flink-cdc/pull/3408
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink
[
https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853114#comment-17853114
]
Leonard Xu edited comment on FLINK-35545 at 6/11/24 11:22 AM:
leonardBang merged PR #3407:
URL: https://github.com/apache/flink-cdc/pull/3407
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink
[
https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852752#comment-17852752
]
Leonard Xu edited comment on FLINK-34908 at 6/11/24 11:23 AM:
[
https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-34908.
Resolution: Fixed
> [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost precision
morazow commented on PR #24426:
URL: https://github.com/apache/flink/pull/24426#issuecomment-2160556166
Thanks @HuangXingBo for the update!
I have changed the GitHub actions to run the `auditwheel` repair after
installing `patchelf` in Linux. Could you please have another look?
ferenc-csaky commented on code in PR #24914:
URL: https://github.com/apache/flink/pull/24914#discussion_r1634722169
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/operator/CompactService.java:
##
@@ -154,23 +158,27 @@ priva
ferenc-csaky commented on code in PR #24914:
URL: https://github.com/apache/flink/pull/24914#discussion_r1634721788
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/operator/CompactService.java:
##
@@ -154,23 +158,27 @@ priva
ferenc-csaky commented on code in PR #24914:
URL: https://github.com/apache/flink/pull/24914#discussion_r1634721788
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/operator/CompactService.java:
##
@@ -154,23 +158,27 @@ priva
pan3793 commented on PR #24905:
URL: https://github.com/apache/flink/pull/24905#issuecomment-2160590805
ping @JingGe, is there any thing I can do before merging?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
qg-lin opened a new pull request, #3409:
URL: https://github.com/apache/flink-cdc/pull/3409
https://issues.apache.org/jira/browse/FLINK-35540
--
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 s
hlteoh37 commented on code in PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#discussion_r1634758095
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java:
##
@@ -0,0
hlteoh37 commented on code in PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#discussion_r1634758095
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java:
##
@@ -0,0
hlteoh37 commented on code in PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#discussion_r1634758095
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java:
##
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-35541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Pilipenko updated FLINK-35541:
Affects Version/s: aws-connector-4.3.0
> Introduce retry limiting for AWS connecto
gaborgsomogyi commented on code in PR #24919:
URL: https://github.com/apache/flink/pull/24919#discussion_r1634845033
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/CustomSSLEngineProvider.java:
##
@@ -59,13 +71,38 @@ public TrustManager[] trustManag
gaborgsomogyi commented on code in PR #24919:
URL: https://github.com/apache/flink/pull/24919#discussion_r1634861389
##
flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java:
##
@@ -285,7 +291,14 @@ private static KeyManagerFactory getKeyManagerFactory(
[
https://issues.apache.org/jira/browse/FLINK-35378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-35378:
---
Summary: [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate
SinkFunction (was:
[
https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-12450:
---
Assignee: Kartikey Pant (was: Ran Tao)
> [Bitwise Functions] Add BIT_LSHIFT, BIT_RSHIFT fu
[
https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854054#comment-17854054
]
lincoln lee commented on FLINK-12450:
-
Thank you everyone! Assigned to you [~kartike
[
https://issues.apache.org/jira/browse/FLINK-26951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854060#comment-17854060
]
lincoln lee commented on FLINK-26951:
-
Thanks [~kartikeypant] for volunteering this!
LadyForest closed pull request #24889: [Flink-35473][table] Improve Table/SQL
Configuration for Flink 2.0
URL: https://github.com/apache/flink/pull/24889
--
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
[
https://issues.apache.org/jira/browse/FLINK-35263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mate Czagany updated FLINK-35263:
-
Fix Version/s: (was: kubernetes-operator-1.9.0)
> FLIP-446: Kubernetes Operator State Snapsh
[
https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mate Czagany updated FLINK-35265:
-
Fix Version/s: (was: kubernetes-operator-1.9.0)
> Implement FlinkStateSnapshot custom resour
[
https://issues.apache.org/jira/browse/FLINK-35267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mate Czagany updated FLINK-35267:
-
Fix Version/s: (was: kubernetes-operator-1.9.0)
> Create documentation for FlinkStateSnapsho
[
https://issues.apache.org/jira/browse/FLINK-35473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-35473.
---
Resolution: Fixed
Fixed in master 93d49ff6eb9f61cb2450d0b25732f4d8923b840d,
b7b1fc2c29995135b9005f0
[
https://issues.apache.org/jira/browse/FLINK-35266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mate Czagany updated FLINK-35266:
-
Fix Version/s: (was: kubernetes-operator-1.9.0)
> Add e2e tests for FlinkStateSnapshot CRs
>
[
https://issues.apache.org/jira/browse/FLINK-35473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854068#comment-17854068
]
Jane Chan edited comment on FLINK-35473 at 6/11/24 2:10 PM:
[
https://issues.apache.org/jira/browse/FLINK-35473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854068#comment-17854068
]
Jane Chan edited comment on FLINK-35473 at 6/11/24 2:10 PM:
[
https://issues.apache.org/jira/browse/FLINK-35473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-35473.
-
> FLIP-457: Improve Table/SQL Configuration for Flink 2.0
>
[
https://issues.apache.org/jira/browse/FLINK-35116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854084#comment-17854084
]
Mate Czagany commented on FLINK-35116:
--
I think this can be closed as the PR has al
[
https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854141#comment-17854141
]
Pouria Pirzadeh commented on FLINK-20539:
-
[~martijnvisser] Thanks for looking i
[
https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854141#comment-17854141
]
Pouria Pirzadeh edited comment on FLINK-20539 at 6/11/24 6:08 PM:
[
https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854141#comment-17854141
]
Pouria Pirzadeh edited comment on FLINK-20539 at 6/11/24 6:08 PM:
[
https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854141#comment-17854141
]
Pouria Pirzadeh edited comment on FLINK-20539 at 6/11/24 6:09 PM:
[
https://issues.apache.org/jira/browse/FLINK-35116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-35116.
--
Resolution: Fixed
Thanks [~mateczagany] ! Indeed.
> Upgrade JOSDK dependency to 4.8.3
> -
snuyanzin merged PR #741:
URL: https://github.com/apache/flink-web/pull/741
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apa
snuyanzin merged PR #740:
URL: https://github.com/apache/flink-web/pull/740
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apa
snuyanzin merged PR #47:
URL: https://github.com/apache/flink-connector-opensearch/pull/47
--
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-unsubs
[
https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-35140:
Summary: Release flink-connector-opensearch v1.2.0 and v.2.0.0 for Flink
1.19 (was: Relea
snuyanzin opened a new pull request, #24921:
URL: https://github.com/apache/flink/pull/24921
## What is the purpose of the change
Add docs for new Opensearch connector release
In fact docs are same for both v1 and v2, so just referencing to one branch
(also references to multiple b
[
https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35140:
---
Labels: pull-request-available (was: )
> Release flink-connector-opensearch v1.2.0 and v.2.
flinkbot commented on PR #24921:
URL: https://github.com/apache/flink/pull/24921#issuecomment-2161796100
## CI report:
* 84a66fe40a34e3e74b68beee473005b903a69fe3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yux updated FLINK-35242:
Description:
> Update: Changed `fine grained` terminology to avoid confusion between
> fine-grained job resource
1996fanrui commented on PR #24881:
URL: https://github.com/apache/flink/pull/24881#issuecomment-2161888308
> Thanks @GOODBOY008 for the quick update, LGTM now. Hi @1996fanrui, could
you help double check this PR?
Thank @Jiabao-Sun for the ping, I will check it these 2 days.
--
This
leonardBang merged PR #3409:
URL: https://github.com/apache/flink-cdc/pull/3409
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink
[
https://issues.apache.org/jira/browse/FLINK-35540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854012#comment-17854012
]
Leonard Xu edited comment on FLINK-35540 at 6/12/24 1:51 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35540.
Resolution: Fixed
> flink-cdc-pipeline-connector-mysql lost table which database and table with
>
[
https://issues.apache.org/jira/browse/FLINK-35568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gang Huang updated FLINK-35568:
---
Summary: Add the imagePullSecrets property for FlinkDeployment spec (was:
Add imagePullSecrets for
Gang Huang created FLINK-35568:
--
Summary: Add imagePullSecrets for FlinkDeployment spec
Key: FLINK-35568
URL: https://issues.apache.org/jira/browse/FLINK-35568
Project: Flink
Issue Type: Improve
1996fanrui commented on PR #24895:
URL: https://github.com/apache/flink/pull/24895#issuecomment-2161973417
It seems one test related to timer fails, it maybe caused by this PR.
`StreamTaskCancellationTest.testCancelTaskShouldPreventAdditionalEventTimeTimersFromBeingFired:272->testCanc
Jiabao-Sun commented on code in PR #3255:
URL: https://github.com/apache/flink-cdc/pull/3255#discussion_r1635733171
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigurationUtils.java:
##
@@ -130,7 +130,9 @@ static Duration convertToDuration(Objec
yuxiqian commented on PR #3360:
URL: https://github.com/apache/flink-cdc/pull/3360#issuecomment-2161996630
Hi @yuanoOo, thanks for your great contribution! Since @whhe is familiar
with OceanBase, do you have time to take a look?
--
This is an automated message from the Apache Git Service.
Jane Chan created FLINK-35569:
-
Summary:
SnapshotFileMergingCompatibilityITCase#testSwitchFromEnablingToDisablingFileMerging
failed
Key: FLINK-35569
URL: https://issues.apache.org/jira/browse/FLINK-35569
[
https://issues.apache.org/jira/browse/FLINK-35569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-35569:
--
Description:
[https://github.com/apache/flink/actions/runs/9467135511/job/26081097181]
The parameteri
[
https://issues.apache.org/jira/browse/FLINK-35569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854224#comment-17854224
]
Jane Chan commented on FLINK-35569:
---
Hi [~Zakelly], would you mind sparing some time t
[
https://issues.apache.org/jira/browse/FLINK-35569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-35569:
---
Assignee: Zakelly Lan
> SnapshotFileMergingCompatibilityITCase#testSwitchFromEnablingToDisa
[
https://issues.apache.org/jira/browse/FLINK-35569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854225#comment-17854225
]
Zakelly Lan commented on FLINK-35569:
-
Thanks [~qingyue] , I'll take a look.
> Snap
fredia opened a new pull request, #24922:
URL: https://github.com/apache/flink/pull/24922
## What is the purpose of the change
Add file size and file count metrics for file-merging.
## Brief change log
- Add `logicalFileCount`, `logicalFileSize`, `physicalFileCoun
[
https://issues.apache.org/jira/browse/FLINK-32091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32091:
---
Labels: pull-request-available (was: )
> Add necessary metrics for file-merging
> -
1 - 100 of 128 matches
Mail list logo
