[
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
[
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-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
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
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
[
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
[
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=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=17722120#comment-17722120
]
Stefan Richter commented on FLINK-31963:
Seems that this is similar to the probl
[
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-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-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
[
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-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-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-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-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-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-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-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=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-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-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
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 updated FLINK-12958:
---
Labels: (was: pull-request-available)
> Integrate AsyncWaitOperator with mailbox
> ---
[
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-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=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=16885981#comment-16885981
]
Stefan Richter commented on FLINK-13249:
My tendency is also more towards having
[
https://issues.apache.org/jira/browse/FLINK-11417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11417.
--
Resolution: Implemented
Fix Version/s: 1.8.0
Merged in:
master: 85bae44
> Make access
[
https://issues.apache.org/jira/browse/FLINK-11311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11311.
--
Resolution: Fixed
Merged in:
master: e354d0bf70
> StreamSource implements StreamOperator inte
[
https://issues.apache.org/jira/browse/FLINK-11314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11314.
--
Resolution: Fixed
Fix Version/s: 1.8.0
Merged in:
master: 1b71e447e0
> Reuse RocksDBWr
[
https://issues.apache.org/jira/browse/FLINK-11315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11315.
--
Resolution: Fixed
Fix Version/s: 1.8.0
Merged in:
master: e6a318c420
> Make magic numb
[
https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10431.
--
Resolution: Implemented
Merged in:
master: c60995d60a
> Extract scheduling-related code from
[
https://issues.apache.org/jira/browse/FLINK-11121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11121.
--
Resolution: Fixed
Assignee: Stefan Richter
Merged in:
master: 05a1dd2
> Check and updat
[
https://issues.apache.org/jira/browse/FLINK-11541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16771769#comment-16771769
]
Stefan Richter commented on FLINK-11541:
I would assume it is a test instability
[
https://issues.apache.org/jira/browse/FLINK-10471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10471.
--
Resolution: Implemented
Merged in:
master: 735b514
> State TTL cleanup using RocksDb compacti
[
https://issues.apache.org/jira/browse/FLINK-11691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773123#comment-16773123
]
Stefan Richter commented on FLINK-11691:
I think this is a useful change for wha
[
https://issues.apache.org/jira/browse/FLINK-11691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11691.
--
Resolution: Implemented
Merged in:
master: c763c35
> Introduce ClassLoader in the methods of
[
https://issues.apache.org/jira/browse/FLINK-11375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter resolved FLINK-11375.
Resolution: Fixed
This issue is already fixed as a byproduct of the changes in FLINK-10431
[
https://issues.apache.org/jira/browse/FLINK-10775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773853#comment-16773853
]
Stefan Richter commented on FLINK-10775:
[~till.rohrmann] can this issue be clos
[
https://issues.apache.org/jira/browse/FLINK-10944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773885#comment-16773885
]
Stefan Richter commented on FLINK-10944:
[~aljoscha] what was the result from th
[
https://issues.apache.org/jira/browse/FLINK-11552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773900#comment-16773900
]
Stefan Richter commented on FLINK-11552:
[~wcummings] Do you think we can close
[
https://issues.apache.org/jira/browse/FLINK-11041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11041.
--
Resolution: Fixed
Merged in:
master: 178fe6b678
release-1.7: b9f78bbe68
> ReinterpretDataStre
[
https://issues.apache.org/jira/browse/FLINK-11541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16774149#comment-16774149
]
Stefan Richter commented on FLINK-11541:
I analyzed it a bit more and it seems t
[
https://issues.apache.org/jira/browse/FLINK-11524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reopened FLINK-11524:
It seems like this test is not fully fixed. I still observe failing instances,
e.g. :
https:/
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16774231#comment-16774231
]
Stefan Richter commented on FLINK-9900:
---
Saw another instance here: https://api.tra
[
https://issues.apache.org/jira/browse/FLINK-11704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11704.
--
Resolution: Implemented
Merged in:
master: 5db40c3
> Improve AbstractCheckpointStateOutputStr
[
https://issues.apache.org/jira/browse/FLINK-11541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11541.
--
Resolution: Fixed
Merged in:
master: 42d9df8fa2
> Heavy deployment E2E test failed on Travis
[
https://issues.apache.org/jira/browse/FLINK-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10043.
--
Resolution: Implemented
Merged in:
master: 3bf06b9
> Refactor object construction/inititlizat
[
https://issues.apache.org/jira/browse/FLINK-11618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11618.
--
Resolution: Fixed
Merged in:
master: bdb7760
> [state] Refactor operator state repartition me
[
https://issues.apache.org/jira/browse/FLINK-10044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10044.
--
Resolution: Fixed
Assignee: (was: Stefan Richter)
> Check proper RIA style and intro
[
https://issues.apache.org/jira/browse/FLINK-11743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-11743:
--
Assignee: Stefan Richter
> Sticky E2E tests failed on travis
> --
Stefan Richter created FLINK-11744:
--
Summary: Provide stable/final toHexString for AbstractID
Key: FLINK-11744
URL: https://issues.apache.org/jira/browse/FLINK-11744
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-11743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-11743:
---
Priority: Blocker (was: Critical)
> Sticky E2E tests failed on travis
> ---
[
https://issues.apache.org/jira/browse/FLINK-11744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11744.
--
Resolution: Fixed
Merged in:
master: 435807e51c
release-1.8: aa55d58734
> Provide stable/fina
[
https://issues.apache.org/jira/browse/FLINK-11007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-11007:
--
Assignee: Stefan Richter
> Update documentation to describe new checkpoint metadata f
[
https://issues.apache.org/jira/browse/FLINK-11743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11743.
--
Resolution: Fixed
Merged in:
master: 7a078a632c
release-1.8: 060d0e6837
> Sticky E2E tests fa
[
https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10912.
--
Resolution: Implemented
Fix Version/s: 1.8.0
Merged in:
master: a8580ca08d
release-1.8:
[
https://issues.apache.org/jira/browse/FLINK-11804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter resolved FLINK-11804.
Resolution: Fixed
Fix Version/s: 1.8.0
Merged in:
master: eada52be
release-1.8: e17
[
https://issues.apache.org/jira/browse/FLINK-11730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter resolved FLINK-11730.
Resolution: Implemented
Fix Version/s: 1.8.0
Merged in:
master: 237d07c7
release-1.
Stefan Richter created FLINK-11141:
--
Summary: Key generation for RocksDBMapState can theoretically be
ambiguous
Key: FLINK-11141
URL: https://issues.apache.org/jira/browse/FLINK-11141
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-9702.
-
Resolution: Fixed
Merged in:
master: 54ef382439
> Improvement in (de)serialization of keys and v
[
https://issues.apache.org/jira/browse/FLINK-11273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-11273:
--
Assignee: Stefan Richter
> Queryable state (rocksdb) end-to-end test fails
>
[
https://issues.apache.org/jira/browse/FLINK-11273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11273.
--
Resolution: Fixed
Merged in:
master: 0b28bfd0d9
> Queryable state (rocksdb) end-to-end test f
[
https://issues.apache.org/jira/browse/FLINK-11012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11012.
--
Resolution: Implemented
Merged in:
master: c08db3fda3
> Introduce abstract superclass for fil
Stefan Richter created FLINK-11417:
--
Summary: Make access to ExecutionGraph single threaded from
JobMaster main thread
Key: FLINK-11417
URL: https://issues.apache.org/jira/browse/FLINK-11417
Project:
[
https://issues.apache.org/jira/browse/FLINK-11008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11008.
--
Resolution: Implemented
Merged in:
master: 4c4ce451fc
> Speed up upload checkpoint files usin
[
https://issues.apache.org/jira/browse/FLINK-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-10043:
---
Description:
Currently, the constructor of {{RocksDBKeyedStateBackend}} has the following
s
[
https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10473.
--
Resolution: Fixed
Merged in:
master: 592f3a9
> State TTL incremental cleanup using Heap backe
[
https://issues.apache.org/jira/browse/FLINK-11469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11469.
--
Resolution: Fixed
Fix Version/s: 1.8.0
1.7.2
1.6.4
[
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-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-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-37365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-37365:
--
Assignee: Mika Naylor
> Add API stability annotations (@Experimental, @PublicEvolving
901 - 977 of 977 matches
Mail list logo
