[
https://issues.apache.org/jira/browse/FLINK-36090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter resolved FLINK-36090.
Assignee: (was: Maxim Vershinin)
Resolution: Duplicate
Already fixed in FLINK-35
[
https://issues.apache.org/jira/browse/FLINK-36090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-36090:
--
Assignee: Maxim Vershinin
> Bug with IngestDB restore operation for priority queue st
[
https://issues.apache.org/jira/browse/FLINK-37365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-37365:
--
Assignee: Mika Naylor
> Add API stability annotations (@Experimental, @PublicEvolving
[
https://issues.apache.org/jira/browse/FLINK-35580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-35580.
--
Resolution: Fixed
> Improvements and fix ingestDB recovery mode related bugs
> ---
[
https://issues.apache.org/jira/browse/FLINK-35580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-35580:
---
Summary: Improvements and fix ingestDB recovery mode related bugs (was:
Fix ingestDB recove
[
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 FileSystemCheckpointStora
[
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
[{{80af4d5}}|https://github.com/apache/flink/commit/80a
[
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&focusedCommentId=17840787#comment-17840787
]
Stefan Richter commented on FLINK-35217:
I think you are right, close will only
[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840115#comment-17840115
]
Stefan Richter commented on FLINK-35217:
Hi, the code is calling close on the ou
[
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
({{{}producerCloseable
[
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
c
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
Comp
[
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
[
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: Impr
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817916#comment-17817916
]
Stefan Richter commented on FLINK-33555:
[~mapohl] I did some work related to lo
[
https://issues.apache.org/jira/browse/FLINK-33962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815274#comment-17815274
]
Stefan Richter commented on FLINK-33962:
Hi [~Zhanghao Chen] ! The proposed chan
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814312#comment-17814312
]
Stefan Richter edited comment on FLINK-34050 at 2/5/24 10:41 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814312#comment-17814312
]
Stefan Richter commented on FLINK-34050:
Just one idea: since the current propos
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811194#comment-17811194
]
Stefan Richter commented on FLINK-34200:
[~fanrui] I think you misunderstood my
[
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
> Alloc
[
https://issues.apache.org/jira/browse/FLINK-32410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810420#comment-17810420
]
Stefan Richter commented on FLINK-32410:
Yes, it's already done.
> Allocate has
[
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 OpenTe
[
https://issues.apache.org/jira/browse/FLINK-34218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810313#comment-17810313
]
Stefan Richter commented on FLINK-34218:
Hi, I also cannot reproduce the problem
[
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 fr
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 T
[
https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791536#comment-17791536
]
Stefan Richter commented on FLINK-32444:
[~pnowojski] if there really is an issu
[
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&focusedCommentId=17779129#comment-17779129
]
Stefan Richter commented on FLINK-33341:
FYI, here is a link to the development
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779124#comment-17779124
]
Stefan Richter commented on FLINK-33341:
[~Yanfei Lei], yes only the previous lo
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17778677#comment-17778677
]
Stefan Richter commented on FLINK-33341:
Exactly, we support local state for rec
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: Impro
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: F
[
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 Check
[
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
> RocksDBStateDownloaderTest.testMultiThreadClea
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749599#comment-17749599
]
Stefan Richter commented on FLINK-32681:
[~Feifan Wang]Thanks for the offer but
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749247#comment-17749247
]
Stefan Richter commented on FLINK-32681:
I'm running on Mac, but with a sleep I
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749203#comment-17749203
]
Stefan Richter commented on FLINK-32681:
[~mapohl] I was trying to reproduce thi
[
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 collections
[
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 Ro
[
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 RocksDBWriteBatc
[
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 t
[
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 wit
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737642#comment-17737642
]
Stefan Richter commented on FLINK-32441:
Fixed in master 0c787f5.
> DefaultSche
[ 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://github.com/apache/flink/blob/149a5e34c1ed8d8943c90
[
https://issues.apache.org/jira/browse/FLINK-30859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737569#comment-17737569
]
Stefan Richter commented on FLINK-30859:
[~tzulitai] I think you forgot to remov
[
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
> DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfte
[
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 maxPar
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
Projec
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734183#comment-17734183
]
Stefan Richter commented on FLINK-31238:
[~mayuehappy] Thanks for working on thi
[
https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733059#comment-17733059
]
Stefan Richter commented on FLINK-32347:
Hey, I've already opened a PR. The issu
[
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 regis
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
Is
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&focusedCommentId=17723051#comment-17723051
]
Stefan Richter commented on FLINK-31963:
Yes, PR is currently in review here: ht
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722120#comment-17722120
]
Stefan Richter commented on FLINK-31963:
Seems that this is similar to the probl
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17721788#comment-17721788
]
Stefan Richter commented on FLINK-31963:
I have a local reproducer as well as a
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17721387#comment-17721387
]
Stefan Richter commented on FLINK-31963:
[~masteryhx] Did your job also make use
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720596#comment-17720596
]
Stefan Richter commented on FLINK-31963:
Hi, just to clarify: when you say a che
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 checkpoi
[
https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885981#comment-16885981
]
Stefan Richter commented on FLINK-13249:
My tendency is also more towards having
[
https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885059#comment-16885059
]
Stefan Richter commented on FLINK-13249:
[~till.rohrmann] alright, I think then
[
https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885002#comment-16885002
]
Stefan Richter commented on FLINK-13249:
[~gaoyunhaii] That is also how I unders
[
https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16884960#comment-16884960
]
Stefan Richter commented on FLINK-13249:
[~gaoyunhaii] thanks for the input, I t
[
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
[
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 ExecutorServi
[
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 Executor
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881825#comment-16881825
]
Stefan Richter commented on FLINK-13072:
I think it is surely not a bad idea to
[
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
AsyncW
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881149#comment-16881149
]
Stefan Richter commented on FLINK-13072:
[~zicat] After reading my previous comm
[
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 flink
[
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 CopyOnWrite
[
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 rele
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879099#comment-16879099
]
Stefan Richter edited comment on FLINK-13072 at 7/5/19 9:21 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879099#comment-16879099
]
Stefan Richter commented on FLINK-13072:
[~zicat] All operators in Flink are ass
[
https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16874318#comment-16874318
]
Stefan Richter commented on FLINK-7289:
---
[~mikekap] I think that is a very good sug
[
https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11662.
--
Resolution: Fixed
Fix Version/s: 1.9.0
Merged in:
master: b760d55
> Discarded checkpoi
Stefan Richter created FLINK-12958:
--
Summary: Integrate AsyncWaitOperator with mailbox
Key: FLINK-12958
URL: https://issues.apache.org/jira/browse/FLINK-12958
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-12364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-12364.
--
Resolution: Implemented
Merged in:
master: 8c57e5ae
> Introduce a CheckpointFailureManager to
Stefan Richter created FLINK-12804:
--
Summary: Introduce mailbox-based ExecutorService
Key: FLINK-12804
URL: https://issues.apache.org/jira/browse/FLINK-12804
Project: Flink
Issue Type: Sub-t
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16855013#comment-16855013
]
Stefan Richter commented on FLINK-12070:
I have one more additional question: ca
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848118#comment-16848118
]
Stefan Richter edited comment on FLINK-8871 at 5/25/19 9:58 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848118#comment-16848118
]
Stefan Richter commented on FLINK-8871:
---
After this quiet intense exchange, I was t
1 - 100 of 977 matches
Mail list logo
