fredia commented on code in PR #24924:
URL: https://github.com/apache/flink/pull/24924#discussion_r1635853720
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/SnapshotFileMergingCompatibilityITCase.java:
##
@@ -167,22 +166,25 @@ private void
ammar-master commented on PR #24919:
URL: https://github.com/apache/flink/pull/24919#issuecomment-2162158973
@gaborgsomogyi I have addressed the comment, 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
ammar-master commented on PR #24919:
URL: https://github.com/apache/flink/pull/24919#issuecomment-2162158609
@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
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854253#comment-17854253
]
Hongshun Wang commented on FLINK-35121:
---
[~kwafor] , Sorry, I have done it
> CDC pipeline
flinkbot commented on PR #24925:
URL: https://github.com/apache/flink/pull/24925#issuecomment-2162103966
## CI report:
* e5d84501e6a2781205494bf429c29e1afe0d4031 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24924:
URL: https://github.com/apache/flink/pull/24924#issuecomment-2162103785
## CI report:
* 9ce0a6f2bb299224ed170ce0944de94703253b81 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24923:
URL: https://github.com/apache/flink/pull/24923#issuecomment-2162103603
## CI report:
* 88f9a4cf7a8e79d861755262f84f91a4b1b0d026 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854247#comment-17854247
]
Zhanghao Chen commented on FLINK-35068:
---
Will revert it as it breaks state-compatibility. If a
X-czh opened a new pull request, #24925:
URL: https://github.com/apache/flink/pull/24925
## What is the purpose of the change
Reverting previous changes that break state compatibility.
[FLINK-34123](https://issues.apache.org/jira/browse/FLINK-34123) &
[
https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854242#comment-17854242
]
Zhanghao Chen commented on FLINK-34123:
---
Will revert it as it breaks state-compatibility. If a
[
https://issues.apache.org/jira/browse/FLINK-35570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35570:
---
Labels: pull-request-available (was: )
> Consider PlaceholderStreamStateHandle in
Zakelly opened a new pull request, #24924:
URL: https://github.com/apache/flink/pull/24924
## What is the purpose of the change
In checkpoint file merging, we should take `PlaceholderStreamStateHandle`
into account during lifecycle, since it can be a file merged one.
## Brief
Zakelly Lan created FLINK-35570:
---
Summary: Consider PlaceholderStreamStateHandle in checkpoint file
merging
Key: FLINK-35570
URL: https://issues.apache.org/jira/browse/FLINK-35570
Project: Flink
schlosna opened a new pull request, #24923:
URL: https://github.com/apache/flink/pull/24923
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
flinkbot commented on PR #24922:
URL: https://github.com/apache/flink/pull/24922#issuecomment-2162053937
## CI report:
* 3405d0cc2c400c9c2d3a596b600b2ebda07af2f9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly merged PR #90:
URL: https://github.com/apache/flink-benchmarks/pull/90
--
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:
[
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
>
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`,
[
https://issues.apache.org/jira/browse/FLINK-35569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854225#comment-17854225
]
Zakelly Lan commented on FLINK-35569:
-
Thanks [~qingyue] , I'll take a look.
>
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-35569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854224#comment-17854224
]
Jane Chan commented on FLINK-35569:
---
Hi [~Zakelly], would you mind sparing some time to take a look?
[
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
Jane Chan created FLINK-35569:
-
Summary:
SnapshotFileMergingCompatibilityITCase#testSwitchFromEnablingToDisablingFileMerging
failed
Key: FLINK-35569
URL: https://issues.apache.org/jira/browse/FLINK-35569
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
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
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.
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:
[
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
[
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-35540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854012#comment-17854012
]
Leonard Xu edited comment on FLINK-35540 at 6/12/24 1:51 AM:
-
master:
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:
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.
--
[
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
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-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
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
[
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:
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:
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:
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:
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854141#comment-17854141
]
Pouria Pirzadeh edited comment on FLINK-20539 at 6/11/24 6:09 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=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=17854141#comment-17854141
]
Pouria Pirzadeh commented on FLINK-20539:
-
[~martijnvisser] Thanks for looking into the issue
[
https://issues.apache.org/jira/browse/FLINK-35116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854084#comment-17854084
]
Mate Czagany commented on FLINK-35116:
--
I think this can be closed as the PR has already been
[
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-35473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854068#comment-17854068
]
Jane Chan edited comment on FLINK-35473 at 6/11/24 2:10 PM:
Fixed in master
[
https://issues.apache.org/jira/browse/FLINK-35473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854068#comment-17854068
]
Jane Chan edited comment on FLINK-35473 at 6/11/24 2:10 PM:
Fixed in master
[
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:all-tabpanel
]
Jane Chan resolved FLINK-35473.
---
Resolution: Fixed
Fixed in master 93d49ff6eb9f61cb2450d0b25732f4d8923b840d,
[
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
[
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
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-26951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854060#comment-17854060
]
lincoln lee commented on FLINK-26951:
-
Thanks [~kartikeypant] for volunteering this!
Before
[
https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854054#comment-17854054
]
lincoln lee commented on FLINK-12450:
-
Thank you everyone! Assigned to you [~kartikeypant].
>
[
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
[
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:
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(
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[]
[
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
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:
##
@@
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:
##
@@
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:
##
@@
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
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
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 @@
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 @@
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 @@
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?
[
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
[
https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852752#comment-17852752
]
Leonard Xu edited comment on FLINK-34908 at 6/11/24 11:23 AM:
--
master:
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:
[
https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853114#comment-17853114
]
Leonard Xu edited comment on FLINK-35545 at 6/11/24 11:22 AM:
--
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:
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
[
https://issues.apache.org/jira/browse/FLINK-35540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854012#comment-17854012
]
Leonard Xu commented on FLINK-35540:
master: c958daf8ab417d16fc7fc0b59f341e8f9cf372e7
release-3.1:
[
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:all-tabpanel
]
Leonard Xu updated FLINK-35540:
---
Fix Version/s: cdc-3.2.0
cdc-3.1.1
> flink-cdc-pipeline-connector-mysql lost
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
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:
[
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
>
[
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
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
[
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
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-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
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:
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853990#comment-17853990
]
Ran Tao commented on FLINK-12450:
-
[~kartikeypant] thanks for pushing this issue, feel free to assign it
[
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-32081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853989#comment-17853989
]
Zakelly Lan commented on FLINK-32081:
-
master: f33808c0f02c12488d4de2f4d517da8b8b100224
>
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
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
-
[
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
[
https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853979#comment-17853979
]
Aleksandr Pilipenko commented on FLINK-35559:
-
{quote}can we backport to v3.1 branch?
[
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,
[
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,
[
https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853971#comment-17853971
]
Hong Liang Teoh commented on FLINK-35559:
-
[~a.pilipenko] can we backport to v3.1 branch?
>
1 - 100 of 132 matches
Mail list logo
