[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-35217:
---
Fix Version/s: 1.18.2
1.19.1
> Missing fsync in
[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-35217.
--
Resolution: Fixed
Merged to master in
[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-35217:
---
Fix Version/s: 1.20.0
> Missing fsync in FileSystemCheckpointStorage
>
[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-35217:
--
Assignee: Stefan Richter
> Missing fsync in FileSystemCheckpointStorage
>
[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840787#comment-17840787
]
Stefan Richter commented on FLINK-35217:
I think you are right, close will only guarantee a
[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840115#comment-17840115
]
Stefan Richter commented on FLINK-35217:
Hi, the code is calling close on the output stream
[
https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-34693:
---
Attachment: (was: image-2024-03-15-10-30-50-902.png)
> Memory leak in KafkaWriter
>
[
https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-34693:
---
Description:
KafkaWriter is keeping objects in Dequeue of closeables
[
https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-34693:
---
Description:
KafkaWriter is keeping instances of {{TwoPhaseCommitProducer}} in Dequeue of
Stefan Richter created FLINK-34693:
--
Summary: Memory leak in KafkaWriter
Key: FLINK-34693
URL: https://issues.apache.org/jira/browse/FLINK-34693
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-34693:
--
Summary: Memory leak in KafkaWriter
Key: FLINK-34693
URL: https://issues.apache.org/jira/browse/FLINK-34693
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-34579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-34579.
--
Resolution: Won't Do
> Introduce metric for time since last completed checkpoint
>
Stefan Richter created FLINK-34579:
--
Summary: Introduce metric for time since last completed checkpoint
Key: FLINK-34579
URL: https://issues.apache.org/jira/browse/FLINK-34579
Project: Flink
Stefan Richter created FLINK-34579:
--
Summary: Introduce metric for time since last completed checkpoint
Key: FLINK-34579
URL: https://issues.apache.org/jira/browse/FLINK-34579
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-34546.
--
Resolution: Fixed
> Emit span with failure labels on failure
>
Stefan Richter created FLINK-34546:
--
Summary: Emit span with failure labels on failure
Key: FLINK-34546
URL: https://issues.apache.org/jira/browse/FLINK-34546
Project: Flink
Issue Type:
Stefan Richter created FLINK-34546:
--
Summary: Emit span with failure labels on failure
Key: FLINK-34546
URL: https://issues.apache.org/jira/browse/FLINK-34546
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17817916#comment-17817916
]
Stefan Richter commented on FLINK-33555:
[~mapohl] I did some work related to local recovery
[
https://issues.apache.org/jira/browse/FLINK-33962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815274#comment-17815274
]
Stefan Richter commented on FLINK-33962:
Hi [~Zhanghao Chen] ! The proposed change in this Jira
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814312#comment-17814312
]
Stefan Richter edited comment on FLINK-34050 at 2/5/24 10:41 AM:
-
Just
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814312#comment-17814312
]
Stefan Richter commented on FLINK-34050:
Just one idea: since the current proposal is making the
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811194#comment-17811194
]
Stefan Richter commented on FLINK-34200:
[~fanrui] I think you misunderstood my comment. I
[
https://issues.apache.org/jira/browse/FLINK-32410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter resolved FLINK-32410.
Fix Version/s: 1.18.0
(was: 1.19.0)
Resolution: Done
>
[
https://issues.apache.org/jira/browse/FLINK-32410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810420#comment-17810420
]
Stefan Richter commented on FLINK-32410:
Yes, it's already done.
> Allocate hash-based
[
https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter resolved FLINK-33696.
Resolution: Done
merged in 7db2ecad
> FLIP-385: Add OpenTelemetryTraceReporter and
[
https://issues.apache.org/jira/browse/FLINK-34218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810313#comment-17810313
]
Stefan Richter commented on FLINK-34218:
Hi, I also cannot reproduce the problem locally, but
[
https://issues.apache.org/jira/browse/FLINK-34199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-34199:
---
Summary: Add tracing for durations of rescaling/restoring RocksDB
incremental checkpoints
Stefan Richter created FLINK-34199:
--
Summary: Add tracing for durations of rescaling/restoring from
local state
Key: FLINK-34199
URL: https://issues.apache.org/jira/browse/FLINK-34199
Project: Flink
Stefan Richter created FLINK-34199:
--
Summary: Add tracing for durations of rescaling/restoring from
local state
Key: FLINK-34199
URL: https://issues.apache.org/jira/browse/FLINK-34199
Project: Flink
Stefan Richter created FLINK-34134:
--
Summary: Add tracing for restored state size and locations
Key: FLINK-34134
URL: https://issues.apache.org/jira/browse/FLINK-34134
Project: Flink
Issue
Stefan Richter created FLINK-34134:
--
Summary: Add tracing for restored state size and locations
Key: FLINK-34134
URL: https://issues.apache.org/jira/browse/FLINK-34134
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791536#comment-17791536
]
Stefan Richter commented on FLINK-32444:
[~pnowojski] if there really is an issue with heap
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-33341.
--
Resolution: Fixed
merged in a4ad86f
> Use available local keyed state for rescaling
>
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-33341:
---
Summary: Use available local keyed state for rescaling (was: Use available
local state for
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779129#comment-17779129
]
Stefan Richter commented on FLINK-33341:
FYI, here is a link to the development branch:
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779124#comment-17779124
]
Stefan Richter commented on FLINK-33341:
[~Yanfei Lei], yes only the previous local state is
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778677#comment-17778677
]
Stefan Richter commented on FLINK-33341:
Exactly, we support local state for recovery - but not
Stefan Richter created FLINK-33341:
--
Summary: Use available local state for rescaling
Key: FLINK-33341
URL: https://issues.apache.org/jira/browse/FLINK-33341
Project: Flink
Issue Type:
Stefan Richter created FLINK-33341:
--
Summary: Use available local state for rescaling
Key: FLINK-33341
URL: https://issues.apache.org/jira/browse/FLINK-33341
Project: Flink
Issue Type:
Stefan Richter created FLINK-33246:
--
Summary: Add RescalingIT case that uses checkpoints and resource
requests
Key: FLINK-33246
URL: https://issues.apache.org/jira/browse/FLINK-33246
Project: Flink
Stefan Richter created FLINK-33246:
--
Summary: Add RescalingIT case that uses checkpoints and resource
requests
Key: FLINK-33246
URL: https://issues.apache.org/jira/browse/FLINK-33246
Project: Flink
Stefan Richter created FLINK-33077:
--
Summary: Minimize the risk of hard back-pressure with buffer
debloating enabled
Key: FLINK-33077
URL: https://issues.apache.org/jira/browse/FLINK-33077
Project:
Stefan Richter created FLINK-33077:
--
Summary: Minimize the risk of hard back-pressure with buffer
debloating enabled
Key: FLINK-33077
URL: https://issues.apache.org/jira/browse/FLINK-33077
Project:
[
https://issues.apache.org/jira/browse/FLINK-32782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32782:
---
Description:
Covered by nightly tests, for example
- run_test "Resuming Externalized
[
https://issues.apache.org/jira/browse/FLINK-32783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32783:
---
Description:
This feature is automatically used whenever we download state during a restart
[
https://issues.apache.org/jira/browse/FLINK-32783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32783:
---
Description: This feature is automatically used whenever we download state
during a restart
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-32681.
--
Resolution: Fixed
merged into master d11cc32
>
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749599#comment-17749599
]
Stefan Richter commented on FLINK-32681:
[~Feifan Wang]Thanks for the offer but I've already
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749247#comment-17749247
]
Stefan Richter commented on FLINK-32681:
I'm running on Mac, but with a sleep I already managed
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749203#comment-17749203
]
Stefan Richter commented on FLINK-32681:
[~mapohl] I was trying to reproduce this locally
[
https://issues.apache.org/jira/browse/FLINK-32410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32410:
---
Fix Version/s: 1.18.0
(was: 1.19.0)
> Allocate hash-based
[
https://issues.apache.org/jira/browse/FLINK-32345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32345:
---
Fix Version/s: 1.18.0
(was: 1.19.0)
> Improve parallel download of
[
https://issues.apache.org/jira/browse/FLINK-32326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-32326.
--
Resolution: Fixed
> Disable WAL in RocksDBWriteBatchWrapper by default
>
[
https://issues.apache.org/jira/browse/FLINK-32345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-32345.
--
Resolution: Fixed
> Improve parallel download of RocksDB incremental state
>
[
https://issues.apache.org/jira/browse/FLINK-32326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32326:
---
Fix Version/s: 1.18.0
(was: 1.19.0)
> Disable WAL in
[
https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32347:
---
Fix Version/s: 1.18.0
> Exceptions from the CompletedCheckpointStore are not registered by
[
https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-32347.
--
Resolution: Fixed
> Exceptions from the CompletedCheckpointStore are not registered by the
>
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-32441.
--
Resolution: Fixed
> DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore fails
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17737642#comment-17737642
]
Stefan Richter commented on FLINK-32441:
Fixed in master 0c787f5.
>
[ https://issues.apache.org/jira/browse/FLINK-30859 ]
Stefan Richter deleted comment on FLINK-30859:
was (Author: srichter):
[~tzulitai] I think you forgot to remove some code here:
[
https://issues.apache.org/jira/browse/FLINK-30859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17737569#comment-17737569
]
Stefan Richter commented on FLINK-30859:
[~tzulitai] I think you forgot to remove some code
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-32441:
--
Assignee: Stefan Richter
>
[
https://issues.apache.org/jira/browse/FLINK-32437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32437:
---
Fix Version/s: 2.0.0
(was: 1.19.0)
> Determine and set correct
Stefan Richter created FLINK-32437:
--
Summary: Determine and set correct maxParallelism for operator
chains
Key: FLINK-32437
URL: https://issues.apache.org/jira/browse/FLINK-32437
Project: Flink
Stefan Richter created FLINK-32437:
--
Summary: Determine and set correct maxParallelism for operator
chains
Key: FLINK-32437
URL: https://issues.apache.org/jira/browse/FLINK-32437
Project: Flink
Stefan Richter created FLINK-32410:
--
Summary: Allocate hash-based collections with sufficient capacity
for expected size
Key: FLINK-32410
URL: https://issues.apache.org/jira/browse/FLINK-32410
Stefan Richter created FLINK-32410:
--
Summary: Allocate hash-based collections with sufficient capacity
for expected size
Key: FLINK-32410
URL: https://issues.apache.org/jira/browse/FLINK-32410
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17734183#comment-17734183
]
Stefan Richter commented on FLINK-31238:
[~mayuehappy] Thanks for working on this topic! I saw
[
https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733059#comment-17733059
]
Stefan Richter commented on FLINK-32347:
Hey, I've already opened a PR. The issue was still
[
https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-32347:
--
Assignee: Stefan Richter
> Exceptions from the CompletedCheckpointStore are not
Stefan Richter created FLINK-32345:
--
Summary: Improve parallel download of RocksDB incremental state
Key: FLINK-32345
URL: https://issues.apache.org/jira/browse/FLINK-32345
Project: Flink
Stefan Richter created FLINK-32345:
--
Summary: Improve parallel download of RocksDB incremental state
Key: FLINK-32345
URL: https://issues.apache.org/jira/browse/FLINK-32345
Project: Flink
Stefan Richter created FLINK-32326:
--
Summary: Disable WAL in RocksDBWriteBatchWrapper by default
Key: FLINK-32326
URL: https://issues.apache.org/jira/browse/FLINK-32326
Project: Flink
Issue
Stefan Richter created FLINK-32326:
--
Summary: Disable WAL in RocksDBWriteBatchWrapper by default
Key: FLINK-32326
URL: https://issues.apache.org/jira/browse/FLINK-32326
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723051#comment-17723051
]
Stefan Richter commented on FLINK-31963:
Yes, PR is currently in review here:
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722120#comment-17722120
]
Stefan Richter commented on FLINK-31963:
Seems that this is similar to the problem described in
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17721788#comment-17721788
]
Stefan Richter commented on FLINK-31963:
I have a local reproducer as well as a fix, will open a
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17721387#comment-17721387
]
Stefan Richter commented on FLINK-31963:
[~masteryhx] Did your job also make use of
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720596#comment-17720596
]
Stefan Richter commented on FLINK-31963:
Hi, just to clarify: when you say a checkpoint that
Stefan Richter created FLINK-13325:
--
Summary: Add test case for FLINK-13249
Key: FLINK-13325
URL: https://issues.apache.org/jira/browse/FLINK-13325
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-13325:
--
Summary: Add test case for FLINK-13249
Key: FLINK-13325
URL: https://issues.apache.org/jira/browse/FLINK-13325
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-13249.
--
Resolution: Fixed
Merged in:
master: 23bd23b325
release-1.9: 3eff6387b5
> Distributed Jepsen
[
https://issues.apache.org/jira/browse/FLINK-13256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-13256.
--
Resolution: Fixed
Merged in:
master: 1ec34249a0
release-1.9: b7bfafca14
> Periodical
[
https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885981#comment-16885981
]
Stefan Richter commented on FLINK-13249:
My tendency is also more towards having a
[
https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885059#comment-16885059
]
Stefan Richter commented on FLINK-13249:
[~till.rohrmann] alright, I think then we have a
[
https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885002#comment-16885002
]
Stefan Richter commented on FLINK-13249:
[~gaoyunhaii] That is also how I understood your
[
https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884960#comment-16884960
]
Stefan Richter commented on FLINK-13249:
[~gaoyunhaii] thanks for the input, I think what you
[
https://issues.apache.org/jira/browse/FLINK-12958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-12958:
---
Labels: (was: pull-request-available)
> Integrate AsyncWaitOperator with mailbox
>
Stefan Richter created FLINK-13248:
--
Summary: Enhance mailbox executor with yield-to-downstream
functionality
Key: FLINK-13248
URL: https://issues.apache.org/jira/browse/FLINK-13248
Project: Flink
Stefan Richter created FLINK-13248:
--
Summary: Enhance mailbox executor with yield-to-downstream
functionality
Key: FLINK-13248
URL: https://issues.apache.org/jira/browse/FLINK-13248
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-12958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-12958:
--
Assignee: (was: Stefan Richter)
> Integrate AsyncWaitOperator with mailbox
>
[
https://issues.apache.org/jira/browse/FLINK-12804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-12804.
--
Resolution: Implemented
Merged in:
master: 6cf98b671d
> Introduce mailbox-based
[
https://issues.apache.org/jira/browse/FLINK-12804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-12804:
---
Fix Version/s: (was: 1.9.0)
1.10.0
> Introduce mailbox-based
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881825#comment-16881825
]
Stefan Richter commented on FLINK-13072:
I think it is surely not a bad idea to improve or
[
https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-13063.
--
Resolution: Fixed
Release Note: This changes the default chaining behavior of the
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881149#comment-16881149
]
Stefan Richter commented on FLINK-13072:
[~zicat] After reading my previous comment, do you
[
https://issues.apache.org/jira/browse/FLINK-12730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-12730.
--
Resolution: Implemented
Merged in:
master: 14c4b23
> Combine BitSet implementations in
[
https://issues.apache.org/jira/browse/FLINK-12693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-12693.
--
Resolution: Implemented
Merged in:
master: 8f47b38
> Store state per key-group in
[
https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-13063:
--
Assignee: Stefan Richter (was: Piotr Nowojski)
> AsyncWaitOperator shouldn't be
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16879099#comment-16879099
]
Stefan Richter edited comment on FLINK-13072 at 7/5/19 9:21 AM:
[~zicat]
1 - 100 of 1165 matches
Mail list logo
