RocMarshal opened a new pull request, #872:
URL: https://github.com/apache/flink-kubernetes-operator/pull/872
## What is the purpose of the change
Fix that the 'deletedTotalCount' is not updated when cleaning historical
event handler records in JDBC event handler
yuxiqian opened a new pull request, #3577:
URL: https://github.com/apache/flink-cdc/pull/3577
This tweaks `SchemaRegistry` coordinator to let it handle requests / trigger
checkpoints in background threads to avoid blocking the main thread.
This also adds E2e test case running on vario
morozov commented on code in PR #24692:
URL: https://github.com/apache/flink/pull/24692#discussion_r1732153194
##
docs/content.zh/docs/connectors/datastream/datagen.md:
##
@@ -65,14 +65,13 @@ Rate Limiting
`Long` values at the overall source rate (across all source subtasks) no
morozov commented on code in PR #24692:
URL: https://github.com/apache/flink/pull/24692#discussion_r1732153194
##
docs/content.zh/docs/connectors/datastream/datagen.md:
##
@@ -65,14 +65,13 @@ Rate Limiting
`Long` values at the overall source rate (across all source subtasks) no
GOODBOY008 commented on code in PR #24692:
URL: https://github.com/apache/flink/pull/24692#discussion_r1732070723
##
docs/content.zh/docs/connectors/datastream/datagen.md:
##
@@ -65,14 +65,13 @@ Rate Limiting
`Long` values at the overall source rate (across all source subtasks)
GOODBOY008 commented on code in PR #24692:
URL: https://github.com/apache/flink/pull/24692#discussion_r1732070723
##
docs/content.zh/docs/connectors/datastream/datagen.md:
##
@@ -65,14 +65,13 @@ Rate Limiting
`Long` values at the overall source rate (across all source subtasks)
GOODBOY008 commented on code in PR #24692:
URL: https://github.com/apache/flink/pull/24692#discussion_r1732070723
##
docs/content.zh/docs/connectors/datastream/datagen.md:
##
@@ -65,14 +65,13 @@ Rate Limiting
`Long` values at the overall source rate (across all source subtasks)
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876896#comment-17876896
]
melin commented on FLINK-34257:
---
Thank you! The input format problem has been solved, it i
Junrui Li created FLINK-36158:
-
Summary: Support for StreamGraph store
Key: FLINK-36158
URL: https://issues.apache.org/jira/browse/FLINK-36158
Project: Flink
Issue Type: Sub-task
Compon
[
https://issues.apache.org/jira/browse/FLINK-36065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Li updated FLINK-36065:
--
Description:
This ticket will encompass the following tasks:
# Make StreamGraph serializable
# Suppo
[
https://issues.apache.org/jira/browse/FLINK-36065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-36065:
---
Assignee: Junrui Li
> Support for submitting StreamGraph
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-36063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-36063:
---
Assignee: Junrui Li
> Migrate StreamGraph and its related classes to flink-runtime
> --
[
https://issues.apache.org/jira/browse/FLINK-36064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-36064:
---
Assignee: Junrui Li
> Refactor CollectResultIterator to eliminate dependency on OperatorID
> --
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876888#comment-17876888
]
Junrui Li commented on FLINK-34257:
---
[~melin]
I don’t see any clear connections betw
[
https://issues.apache.org/jira/browse/FLINK-36157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-36157:
---
Assignee: xuyang
> FLIP-473 Introduce New SQL Operators Based on Asynchronous State APIs
>
xuyang created FLINK-36157:
--
Summary: FLIP-473 Introduce New SQL Operators Based on
Asynchronous State APIs
Key: FLINK-36157
URL: https://issues.apache.org/jira/browse/FLINK-36157
Project: Flink
Is
spoon-lz commented on code in PR #25192:
URL: https://github.com/apache/flink/pull/25192#discussion_r1732036346
##
docs/layouts/shortcodes/generated/rest_v1_dispatcher.html:
##
@@ -571,7 +571,7 @@
"allowNonRestoredState" : {
"type" : "boolean"
},
-"claimMode
[
https://issues.apache.org/jira/browse/FLINK-36130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876872#comment-17876872
]
zzm commented on FLINK-36130:
-
[~leonard] HI
> flink cdc submit yaml task
> --
[
https://issues.apache.org/jira/browse/FLINK-35964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-35964.
---
Fix Version/s: 2.0.0
Resolution: Fixed
Fixed in master: 4c14c763ca0f9c71d642953228b364dce3eb3
[
https://issues.apache.org/jira/browse/FLINK-35965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-35965.
---
Fix Version/s: 2.0.0
Resolution: Fixed
Fixed in master: 5bbdbb2889268e879b6aa06d2cdab02fd6154
[
https://issues.apache.org/jira/browse/FLINK-35965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-35965:
---
Assignee: Dylan He
> Add ENDSWITH function
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-35964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-35964:
---
Assignee: Dylan He
> Add STARTSWITH function
> ---
>
>
lincoln-lil merged PR #25156:
URL: https://github.com/apache/flink/pull/25156
--
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.a
github-actions[bot] commented on PR #3398:
URL: https://github.com/apache/flink-cdc/pull/3398#issuecomment-2311317235
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.
--
brada commented on PR #156:
URL:
https://github.com/apache/flink-connector-aws/pull/156#issuecomment-2311252620
It look like this PR might not be necessary if
[https://github.com/apache/flink-connector-aws/pull/150](https://github.com/apache/flink-connector-aws/pull/150)
gets merged.
Th
Rodrigo Meneses created FLINK-36156:
---
Summary: SinkV2: Provide the ability to set Committer Operator
parallelism
Key: FLINK-36156
URL: https://issues.apache.org/jira/browse/FLINK-36156
Project: Flin
morozov commented on PR #24692:
URL: https://github.com/apache/flink/pull/24692#issuecomment-2310680036
I copied the rate limiting example from `DataGenerator.java` to everywhere
into the documentation. I also updated `DataGenerator.java` and renamed
`generatorSource` to `source` for consis
leonardBang merged PR #3576:
URL: https://github.com/apache/flink-cdc/pull/3576
--
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
lincoln-lil commented on PR #25156:
URL: https://github.com/apache/flink/pull/25156#issuecomment-2310439648
The failed case
`LeftOuterJoinTaskTest#testCancelLeftOuterJoinTaskWhileBuilding` in core moulde
looks weird...
--
This is an automated message from the Apache Git Service.
To respo
lincoln-lil commented on PR #25156:
URL: https://github.com/apache/flink/pull/25156#issuecomment-2310438124
@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 commen
[
https://issues.apache.org/jira/browse/FLINK-36100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-36100.
---
Fix Version/s: 2.0.0
Resolution: Fixed
Fixed in master: ae4eb7dc3ae399659e52da39f7ac74242aaca
[
https://issues.apache.org/jira/browse/FLINK-36100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-36100:
Affects Version/s: 1.19.1
1.20.0
> Support ESCAPE in built-in function LIKE
nicknezis commented on PR #22660:
URL: https://github.com/apache/flink/pull/22660#issuecomment-2310424567
I added my comment on the [Jira
ticket](https://issues.apache.org/jira/browse/FLINK-3154), but also posting it
here for better visibility.
I wanted to revisit the status of this
lincoln-lil merged PR #25225:
URL: https://github.com/apache/flink/pull/25225
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876748#comment-17876748
]
Nick Nezis commented on FLINK-3154:
---
I wanted to revisit the status of this ticket. The
[
https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876747#comment-17876747
]
luolei commented on FLINK-36149:
Thank you for your suggestion. Yes, it is more reasonab
HuangZhenQiu commented on PR #111:
URL:
https://github.com/apache/flink-connector-kafka/pull/111#issuecomment-2310366594
@AHeise
Thanks. It is a very reasonable plan! Let me know anything I can help before
merging PR also.
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-36090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maxim Vershinin updated FLINK-36090:
Description:
*Summary:* Incorrect handling of priority queue states in IngestDB during
re
[
https://issues.apache.org/jira/browse/FLINK-36155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-36155:
--
Description:
The following warning logs are seen from kinesis connector indicating
```
LEAK: ByteBuf
[
https://issues.apache.org/jira/browse/FLINK-36155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-36155:
--
Description:
The following warning logs are seen from kinesis connector indicating memory
leak.
```
[
https://issues.apache.org/jira/browse/FLINK-36155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-36155:
--
Summary: ByteBuf.release() was not called before it's garbage-collected in
Kinesis Connector (was: By
Keith Lee created FLINK-36155:
-
Summary: ByteBuf.release() was not called before it's
garbage-collected
Key: FLINK-36155
URL: https://issues.apache.org/jira/browse/FLINK-36155
Project: Flink
Iss
mayuehappy commented on PR #25253:
URL: https://github.com/apache/flink/pull/25253#issuecomment-2310121356
`RocksDBResourceContainerTest.testGetColumnFamilyOptionsWithPartitionedIndex`
failed because RocksDB-V8.10.0 Overrided the `equals()` of
`org.rocksdb.BloomFilter` .In RocksDBResourceC
rkhachatryan commented on code in PR #25235:
URL: https://github.com/apache/flink/pull/25235#discussion_r1731164817
##
docs/content/docs/deployment/filesystems/s3.md:
##
@@ -164,4 +164,38 @@ The `s3.entropy.key` defines the string in paths that is
replaced by the random
If a f
mayuehappy commented on PR #25253:
URL: https://github.com/apache/flink/pull/25253#issuecomment-2310071852
> Is the CI failure related with compilation or release of the frocksdb?
@Zakelly The compilation looks fine
There are two main reasons why CI has failed
The error message f
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876695#comment-17876695
]
melin commented on FLINK-34257:
---
添加 -Dkubernetes.container.image.pull-secrets=docker-reg-
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-34257:
--
Attachment: image-2024-08-26-19-55-06-927.png
> Update Flink YAML Parser to Support YAML 1.2 Specification
>
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-34257:
--
Attachment: image-2024-08-26-19-53-40-349.png
> Update Flink YAML Parser to Support YAML 1.2 Specification
>
[
https://issues.apache.org/jira/browse/FLINK-36140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-36140.
-
> Log a warning when pods are terminated by kubernetes
> ---
[
https://issues.apache.org/jira/browse/FLINK-36140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-36140.
---
Fix Version/s: 2.0.0
Resolution: Fixed
9bcd8f4 on master
> Log a warning when pods a
gaborgsomogyi merged PR #25242:
URL: https://github.com/apache/flink/pull/25242
--
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
wqshr12345 commented on code in PR #25233:
URL: https://github.com/apache/flink/pull/25233#discussion_r1731118174
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java:
##
@@ -475,6 +482,32 @@ public LocalRecoveryConfig getLocalRecoveryCon
wqshr12345 commented on code in PR #25233:
URL: https://github.com/apache/flink/pull/25233#discussion_r1731117894
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/ValueStateWrapper.java:
##
@@ -0,0 +1,87 @@
+//
+// Source code recreated from a .class file by Inte
dylanhz commented on PR #25156:
URL: https://github.com/apache/flink/pull/25156#issuecomment-2309963258
@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.
Zakelly commented on code in PR #25192:
URL: https://github.com/apache/flink/pull/25192#discussion_r1731064677
##
docs/layouts/shortcodes/generated/rest_v1_dispatcher.html:
##
@@ -571,7 +571,7 @@
"allowNonRestoredState" : {
"type" : "boolean"
},
-"claimMode"
lexluo09 commented on PR #25257:
URL: https://github.com/apache/flink/pull/25257#issuecomment-2309895864
@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 specif
[
https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876663#comment-17876663
]
lincoln lee commented on FLINK-36149:
-
[~lexluo09] Thanks for reporting this! It see
liangyu-1 commented on PR #25226:
URL: https://github.com/apache/flink/pull/25226#issuecomment-2309843416
@xintongsong
Hi, would you please help me check this issue?
Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
wqshr12345 commented on code in PR #25233:
URL: https://github.com/apache/flink/pull/25233#discussion_r1731019339
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/ValueStateWrapper.java:
##
@@ -0,0 +1,87 @@
+//
+// Source code recreated from a .class file by Inte
wqshr12345 commented on code in PR #25233:
URL: https://github.com/apache/flink/pull/25233#discussion_r1731017991
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptorTransformer.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundat
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876650#comment-17876650
]
Leonard Xu commented on FLINK-36128:
Thanks [~xiqian_yu] for the reporting, I adjust
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36128:
---
Summary: The in-flight data will meet unrecoverable issue when restore from
checkpoint once old sche
Zakelly commented on PR #25253:
URL: https://github.com/apache/flink/pull/25253#issuecomment-2309808133
Is the CI failure related with compilation or release of the frocksdb?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36128:
---
Summary: The in-flight data will meet uncoverable issue when restore from
checkpoint once old schema
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36128:
---
Summary: The in-flight data will meet uncoverable issue once old schema
flushed to downstream system
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36128:
---
Affects Version/s: cdc-3.1.1
> Promote LENIENT mode as the default schema evolution behavior
> -
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36128:
---
Fix Version/s: cdc-3.2.0
> Promote LENIENT mode as the default schema evolution behavior
> -
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36128:
--
Assignee: yux
> Promote LENIENT mode as the default schema evolution behavior
> -
[
https://issues.apache.org/jira/browse/FLINK-36154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
KevinyhZou updated FLINK-36154:
---
Affects Version/s: 1.20.0
> Support deserialize json ignore field key case
> ---
leonardBang merged PR #3574:
URL: https://github.com/apache/flink-cdc/pull/3574
--
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
lexluo09 commented on PR #25257:
URL: https://github.com/apache/flink/pull/25257#issuecomment-2309709712
@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.
gyfora opened a new pull request, #871:
URL: https://github.com/apache/flink-kubernetes-operator/pull/871
## What is the purpose of the change
Rework the last-state upgrade mode to not be solely reliant on HA metadata
but to be flexible and use the job cancel mechanism in other cases.
[
https://issues.apache.org/jira/browse/FLINK-35414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35414:
---
Labels: pull-request-available (was: )
> Cancel jobs through rest api for last-state upgrad
dylanhz commented on PR #25225:
URL: https://github.com/apache/flink/pull/25225#issuecomment-2309692044
> Also verified the result with escaping characters, all results with
supported patterns are consistent with mysql:
> Support cleaning up expired states to prevent the
lexluo09 opened a new pull request, #25257:
URL: https://github.com/apache/flink/pull/25257
## What is the purpose of the change
*In Rank operators, add the
cleanupInRocksdbCompactFilter(queryTimeAfterNumEntries) parameter setting,
allowing adjustment based on the size of use
flinkbot commented on PR #25255:
URL: https://github.com/apache/flink/pull/25255#issuecomment-2309660974
## CI report:
* cda95febf414e947f12df59608f0cedbe065c21e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33678:
---
Labels: 2.0-related pull-request-available (was: 2.0-related)
> Remove configuration getter
loserwang1024 commented on PR #3573:
URL: https://github.com/apache/flink-cdc/pull/3573#issuecomment-2309661159
> Could you please add some IT tests for this in the mysql source cdc
connector?
I have done it in
org.apache.flink.cdc.connectors.mysql.source.MysqlPipelineNewlyAddedTable
JunRuiLee opened a new pull request, #25256:
URL: https://github.com/apache/flink/pull/25256
## What is the purpose of the change
[FLINK-33581](https://issues.apache.org/jira/browse/FLINK-33581)/FLIP-381
Deprecate configuration getters/setters that return/set complex J
KevinyhZou opened a new pull request, #25255:
URL: https://github.com/apache/flink/pull/25255
## What is the purpose of the change
Support parse json string ignore the field key case.
## Brief change log
Introduce a config `json.ignore-key-case` to ignore the key case
[
https://issues.apache.org/jira/browse/FLINK-36154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36154:
---
Labels: pull-request-available (was: )
> Support parse json ignore field key case
> ---
KevinyhZou created FLINK-36154:
--
Summary: Support parse json ignore field key case
Key: FLINK-36154
URL: https://issues.apache.org/jira/browse/FLINK-36154
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-35772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-35772.
--
Fix Version/s: 2.0.0
Resolution: Fixed
merged commit 56c8199 into apache:master
> Depr
[
https://issues.apache.org/jira/browse/FLINK-36108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-36108.
--
Fix Version/s: 2.0.0
Resolution: Fixed
Merged as 576b30820ff to master
> Wait for stat
[
https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876624#comment-17876624
]
Gyula Fora commented on FLINK-36145:
I also like initialStateReference more, we coul
[
https://issues.apache.org/jira/browse/FLINK-35771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-35771.
--
Fix Version/s: 2.0.0
Resolution: Fixed
merged as 0daca7b6db8 to master
> Limit s5cmd r
[
https://issues.apache.org/jira/browse/FLINK-35770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876622#comment-17876622
]
Piotr Nowojski edited comment on FLINK-35770 at 8/26/24 8:16 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-35770.
--
Fix Version/s: 2.0.0
Resolution: Fixed
merged as 0daca7b6db8 to master
> Interrupt s5c
pnowojski merged PR #25228:
URL: https://github.com/apache/flink/pull/25228
--
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
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30629:
---
Affects Version/s: 1.19.1
> ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable
>
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876620#comment-17876620
]
Weijie Guo commented on FLINK-30629:
1.19:
https://dev.azure.com/apache-flink/apach
[
https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luolei updated FLINK-36149:
---
Description:
1、Problem description：
{code:java}
select *
from
(
SELECT *, ROW_NUMBER() OVER (PARTITION
[
https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luolei updated FLINK-36149:
---
Summary: Support cleaning up expired states to prevent the continuous
increase of states and add RocksDB sta
AHeise commented on PR #111:
URL:
https://github.com/apache/flink-connector-kafka/pull/111#issuecomment-2309529736
> Thanks for the reply. I totally understand the pain points of maintain
multiple flink version compatibility for a connector. In each Flink release,
there are always some new
98 matches
Mail list logo
