[jira] [Created] (FLINK-13325) Add test case for FLINK-13249

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

[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration (State TTL)

[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341298#comment-16341298 ] Stefan Richter commented on FLINK-3089: --- [~phoenixjiangnan] I agree that we could st

[jira] [Comment Edited] (FLINK-3089) State API Should Support Data Expiration (State TTL)

[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341298#comment-16341298 ] Stefan Richter edited comment on FLINK-3089 at 1/26/18 5:12 PM:

[jira] [Comment Edited] (FLINK-3089) State API Should Support Data Expiration (State TTL)

[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341298#comment-16341298 ] Stefan Richter edited comment on FLINK-3089 at 1/26/18 5:13 PM:

[jira] [Commented] (FLINK-8522) DefaultOperatorStateBackend writes data in checkpoint that is never read.

[ https://issues.apache.org/jira/browse/FLINK-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16343580#comment-16343580 ] Stefan Richter commented on FLINK-8522: --- Option 1 looks good for me. > DefaultOpera

[jira] [Commented] (FLINK-8522) DefaultOperatorStateBackend writes data in checkpoint that is never read.

[ https://issues.apache.org/jira/browse/FLINK-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16343622#comment-16343622 ] Stefan Richter commented on FLINK-8522: --- I don't think that we ever need to read the

[jira] [Commented] (FLINK-8411) HeapListState#add(null) will wipe out entire list state

[ https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16344793#comment-16344793 ] Stefan Richter commented on FLINK-8411: --- That is a tough one. I feel like the previo

[jira] [Commented] (FLINK-8411) HeapListState#add(null) will wipe out entire list state

[ https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16344870#comment-16344870 ] Stefan Richter commented on FLINK-8411: --- Ola, I always assumed that to be a copy-pas

[jira] [Commented] (FLINK-8411) HeapListState#add(null) will wipe out entire list state

[ https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16344895#comment-16344895 ] Stefan Richter commented on FLINK-8411: --- Fine with me, we can revert the commit on t

[jira] [Closed] (FLINK-4809) Operators should tolerate checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-4809. - Resolution: Fixed Fix Version/s: 1.4.0 Merged in  {{[7c63526|https://github.com/apache/flin

[jira] [Reopened] (FLINK-4809) Operators should tolerate checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reopened FLINK-4809: --- > Operators should tolerate checkpoint failures > - >

[jira] [Closed] (FLINK-4809) Operators should tolerate checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-4809. - Resolution: Fixed Fix Version/s: (was: 1.4.0) 1.5.0 Merged in  {{[7c

[jira] [Assigned] (FLINK-8569) Provide a hook to override the default KeyGroupRangeAssignment

[ https://issues.apache.org/jira/browse/FLINK-8569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8569: - Assignee: Stefan Richter > Provide a hook to override the default KeyGroupRangeAssignment

[jira] [Assigned] (FLINK-8569) Provide a hook to override the default KeyGroupRangeAssignment

[ https://issues.apache.org/jira/browse/FLINK-8569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8569: - Assignee: (was: Stefan Richter) > Provide a hook to override the default KeyGroupRang

[jira] [Assigned] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8571: - Assignee: Stefan Richter > Provide an enhanced KeyedStream implementation to use ForwardP

[jira] [Closed] (FLINK-8385) Fix exceptions in AbstractEventTimeWindowCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-8385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8385. - Resolution: Fixed Merged in  b32b835. > Fix exceptions in AbstractEventTimeWindowCheckpointingITC

[jira] [Closed] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8571. - Resolution: Fixed Fix Version/s: 1.4.1 1.5.0 Merged in 91eea376ee. Merg

[jira] [Closed] (FLINK-8657) Fix incorrect description for external checkpoint vs savepoint

[ https://issues.apache.org/jira/browse/FLINK-8657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8657. - Resolution: Fixed Merged in 5909b5bb7f. > Fix incorrect description for external checkpoint vs sa

[jira] [Commented] (FLINK-8709) Flaky test: SlotPoolRpcTest.testCancelSlotAllocationWithoutResourceManager

[ https://issues.apache.org/jira/browse/FLINK-8709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371146#comment-16371146 ] Stefan Richter commented on FLINK-8709: --- Also still seeing this. https://api.travis

[jira] [Closed] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8547. - Resolution: Fixed Fix Version/s: 1.5.0 Merged in 3126bf5229. > Implement CheckpointBarrier

[jira] [Closed] (FLINK-8674) Efficiently handle alwaysFlush case (0ms flushTimeout)

[ https://issues.apache.org/jira/browse/FLINK-8674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8674. - Resolution: Fixed Fix Version/s: 1.5.0 Merged in a144d0f77f. > Efficiently handle alwaysFl

[jira] [Closed] (FLINK-8639) Fix always need to seek multiple times when iterator RocksDBMapState

[ https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8639. - Resolution: Fixed Merged in 1e315f0. > Fix always need to seek multiple times when iterator Rocks

[jira] [Closed] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8679. - Resolution: Fixed Merged in eeac022f05. > RocksDBKeyedBackend.getKeys(stateName, namespace) doesn

[jira] [Created] (FLINK-8781) Try to reschedule failed tasks to previous allocation

Stefan Richter created FLINK-8781: - Summary: Try to reschedule failed tasks to previous allocation Key: FLINK-8781 URL: https://issues.apache.org/jira/browse/FLINK-8781 Project: Flink Issue T

[jira] [Closed] (FLINK-8781) Try to reschedule failed tasks to previous allocation

[ https://issues.apache.org/jira/browse/FLINK-8781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8781. - Resolution: Fixed Merged in d63bc75ffa. > Try to reschedule failed tasks to previous allocation >

[jira] [Created] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state

Stefan Richter created FLINK-10712: -- Summary: RestartPipelinedRegionStrategy does not restore state Key: FLINK-10712 URL: https://issues.apache.org/jira/browse/FLINK-10712 Project: Flink Iss

[jira] [Created] (FLINK-10713) RestartIndividualStrategy does not restore state

Stefan Richter created FLINK-10713: -- Summary: RestartIndividualStrategy does not restore state Key: FLINK-10713 URL: https://issues.apache.org/jira/browse/FLINK-10713 Project: Flink Issue Ty

[jira] [Updated] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10712: --- Description: RestartPipelinedRegionStrategy does not perform any state restore. This is big

[jira] [Updated] (FLINK-10714) java.lang.IndexOutOfBoundsException when creating a heap backend snapshot

[ https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10714: --- Priority: Blocker (was: Major) > java.lang.IndexOutOfBoundsException when creating a heap b

[jira] [Updated] (FLINK-10714) java.lang.IndexOutOfBoundsException when creating a heap backend snapshot

[ https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10714: --- Fix Version/s: 1.7.0 > java.lang.IndexOutOfBoundsException when creating a heap backend snap

[jira] [Commented] (FLINK-10714) java.lang.IndexOutOfBoundsException when creating a heap backend snapshot

[ https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668486#comment-16668486 ] Stefan Richter commented on FLINK-10714: [~cmick] Can you share the part of your

[jira] [Closed] (FLINK-8995) Add a test operator with keyed state that uses custom, stateful serializer

[ https://issues.apache.org/jira/browse/FLINK-8995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8995. - Resolution: Implemented Merged in: master: 0e9a249fb8 > Add a test operator with keyed state tha

[jira] [Commented] (FLINK-10714) java.lang.IndexOutOfBoundsException when creating a heap backend snapshot

[ https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668776#comment-16668776 ] Stefan Richter commented on FLINK-10714: [~cmick] I had a look at your code and

[jira] [Closed] (FLINK-10714) java.lang.IndexOutOfBoundsException when creating a heap backend snapshot

[ https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10714. -- Resolution: Not A Problem User code was not holding the checkpointing lock in the source. > j

[jira] [Closed] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9635. - Resolution: Fixed Merged in: master: c8a6471a58 > Local recovery scheduling can cause spread out

[jira] [Assigned] (FLINK-10364) Test instability in NonHAQueryableStateFsBackendITCase#testMapState

[ https://issues.apache.org/jira/browse/FLINK-10364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-10364: -- Assignee: Stefan Richter > Test instability in NonHAQueryableStateFsBackendITCase#tes

[jira] [Assigned] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-10353: -- Assignee: Stefan Richter > Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from

[jira] [Updated] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer

[ https://issues.apache.org/jira/browse/FLINK-10490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10490: --- Fix Version/s: 1.8.0 1.7.0 > OperatorSnapshotUtil should probably use Sav

[jira] [Closed] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer

[ https://issues.apache.org/jira/browse/FLINK-10490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10490. -- Resolution: Fixed Release Note: Snapshots created with OperatorSnapshotUtil before this

[jira] [Created] (FLINK-10793) Change visibility of TtlValue and TtlSerializer to public for external tools

Stefan Richter created FLINK-10793: -- Summary: Change visibility of TtlValue and TtlSerializer to public for external tools Key: FLINK-10793 URL: https://issues.apache.org/jira/browse/FLINK-10793 Proj

[jira] [Assigned] (FLINK-10793) Change visibility of TtlValue and TtlSerializer to public for external tools

[ https://issues.apache.org/jira/browse/FLINK-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-10793: -- Assignee: Stefan Richter > Change visibility of TtlValue and TtlSerializer to public

[jira] [Closed] (FLINK-10364) Test instability in NonHAQueryableStateFsBackendITCase#testMapState

[ https://issues.apache.org/jira/browse/FLINK-10364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10364. -- Resolution: Fixed Fix Version/s: (was: 1.5.6) Merged in: master: b9351fcf6d release

[jira] [Closed] (FLINK-10793) Change visibility of TtlValue and TtlSerializer to public for external tools

[ https://issues.apache.org/jira/browse/FLINK-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10793. -- Resolution: Fixed Fix Version/s: 1.7.0 1.6.3 Merged in: master: e1d9

[jira] [Closed] (FLINK-10720) Add stress deployment end-to-end test

[ https://issues.apache.org/jira/browse/FLINK-10720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10720. -- Resolution: Implemented Merged in: master: 660bb687c1 release-1.7: 380df0559b > Add stress de

[jira] [Closed] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10353. -- Resolution: Fixed Merged in: master: 85f895b083 release-1.7: 090119ac96 > Restoring a KafkaPr

[jira] [Reopened] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reopened FLINK-10353: > Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written > with Semant

[jira] [Issue Comment Deleted] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10353: --- Comment: was deleted (was: Merged in: master: 85f895b083 release-1.7: 090119ac96) > Restori

[jira] [Updated] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10353: --- Fix Version/s: 1.7.0 1.6.3 > Restoring a KafkaProducer with Semantic.EXAC

[jira] [Closed] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10353. -- Resolution: Fixed Merged in: master: 85f895b083 release-1.7: 090119ac96 release-1.6: b609ede4b

[jira] [Assigned] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-10809: -- Assignee: Stefan Richter > Using DataStreamUtils.reinterpretAsKeyedStream produces co

[jira] [Created] (FLINK-10816) Fix LockableTypeSerializer.duplicate()

Stefan Richter created FLINK-10816: -- Summary: Fix LockableTypeSerializer.duplicate() Key: FLINK-10816 URL: https://issues.apache.org/jira/browse/FLINK-10816 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis

[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-10826: -- Assignee: Stefan Richter (was: Hequn Cheng) > Heavy deployment end-to-end test produ

[jira] [Commented] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis

[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16680061#comment-16680061 ] Stefan Richter commented on FLINK-10826: I think we just need to tune this test

[jira] [Closed] (FLINK-10816) Fix LockableTypeSerializer.duplicate()

[ https://issues.apache.org/jira/browse/FLINK-10816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10816. -- Resolution: Fixed Fix Version/s: 1.7.0 1.6.3 Merged in: master: 997f

[jira] [Created] (FLINK-10828) Enforce that all TypeSerializers are tested through SerializerTestBase

Stefan Richter created FLINK-10828: -- Summary: Enforce that all TypeSerializers are tested through SerializerTestBase Key: FLINK-10828 URL: https://issues.apache.org/jira/browse/FLINK-10828 Project: F

[jira] [Created] (FLINK-10827) Add test for duplicate() to SerializerTestBase

Stefan Richter created FLINK-10827: -- Summary: Add test for duplicate() to SerializerTestBase Key: FLINK-10827 URL: https://issues.apache.org/jira/browse/FLINK-10827 Project: Flink Issue Type

[jira] [Closed] (FLINK-10765) Modify one of the s3 tests to use the Presto S3 s3p schema

[ https://issues.apache.org/jira/browse/FLINK-10765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10765. -- Resolution: Fixed Merged in: master: c5e227baca release-1.7: ca66bed090 > Modify one of the s

[jira] [Assigned] (FLINK-10753) Propagate and log snapshotting exceptions

[ https://issues.apache.org/jira/browse/FLINK-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-10753: -- Assignee: Stefan Richter > Propagate and log snapshotting exceptions > --

[jira] [Updated] (FLINK-10828) Enforce that all TypeSerializers are tested through SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10828: --- Description: As pointed out in FLINK-10827, type serializers are a common source of bugs and

[jira] [Commented] (FLINK-10828) Enforce that all TypeSerializers are tested through SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681072#comment-16681072 ] Stefan Richter commented on FLINK-10828: When I was talking to [~trohrm...@apach

[jira] [Commented] (FLINK-10630) Update migration tests for Flink 1.7

[ https://issues.apache.org/jira/browse/FLINK-10630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681074#comment-16681074 ] Stefan Richter commented on FLINK-10630: There is no work for 1.8 from my side,

[jira] [Commented] (FLINK-9702) Improvement in (de)serialization of keys and values for RocksDB state

[ https://issues.apache.org/jira/browse/FLINK-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681078#comment-16681078 ] Stefan Richter commented on FLINK-9702: --- I think it still makes sense, please consi

[jira] [Created] (FLINK-10839) Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer

Stefan Richter created FLINK-10839: -- Summary: Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer Key: FLINK-10839 URL: https://issues.apache.org/jira/browse/FLINK-10839 Proje

[jira] [Commented] (FLINK-10839) Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer

[ https://issues.apache.org/jira/browse/FLINK-10839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681347#comment-16681347 ] Stefan Richter commented on FLINK-10839: https://github.com/apache/flink/pull/70

[jira] [Updated] (FLINK-10839) Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer

[ https://issues.apache.org/jira/browse/FLINK-10839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10839: --- Description: The implementation of {{PojoSerializer.duplicate()}} currently ignores that {{s

[jira] [Updated] (FLINK-10839) Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer

[ https://issues.apache.org/jira/browse/FLINK-10839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10839: --- Labels: pull-request-available (was: ) > Fix implementation of PojoSerializer.duplicate() w

[jira] [Commented] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2)

[ https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681734#comment-16681734 ] Stefan Richter commented on FLINK-10844: I don't think that it is an issue with

[jira] [Comment Edited] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2)

[ https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681734#comment-16681734 ] Stefan Richter edited comment on FLINK-10844 at 11/9/18 5:28 PM: -

[jira] [Closed] (FLINK-10839) Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer

[ https://issues.apache.org/jira/browse/FLINK-10839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10839. -- Resolution: Fixed Fix Version/s: 1.5.6 Merged in: master: c4d366c9ab release-1.7: 19c34

[jira] [Closed] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10827. -- Resolution: Fixed Fix Version/s: 1.6.3 1.5.6 Merged in: master: 2db5

[jira] [Closed] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10809. -- Resolution: Fixed Fix Version/s: 1.7.0 1.6.3 Merged in: master: bf76

[jira] [Closed] (FLINK-10753) Propagate and log snapshotting exceptions

[ https://issues.apache.org/jira/browse/FLINK-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10753. -- Resolution: Fixed Fix Version/s: 1.6.3 1.5.6 Merged in: master: dc8e

[jira] [Created] (FLINK-10863) Assign uids to all operators

Stefan Richter created FLINK-10863: -- Summary: Assign uids to all operators Key: FLINK-10863 URL: https://issues.apache.org/jira/browse/FLINK-10863 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-10859) Queryable state (rocksdb) end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-10859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685061#comment-16685061 ] Stefan Richter commented on FLINK-10859: I think all problems of this sort are r

[jira] [Closed] (FLINK-10863) Assign uids to all operators

[ https://issues.apache.org/jira/browse/FLINK-10863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10863. -- Resolution: Fixed Merged in: master: 31176d5 release-1.7: 44777b6 release-1.6: 76d7fb1 release

[jira] [Commented] (FLINK-10860) java.lang.ArrayIndexOutOfBoundsException Error reading state

[ https://issues.apache.org/jira/browse/FLINK-10860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685493#comment-16685493 ] Stefan Richter commented on FLINK-10860: This could be the result of a serialize

[jira] [Commented] (FLINK-10860) java.lang.ArrayIndexOutOfBoundsException Error reading state

[ https://issues.apache.org/jira/browse/FLINK-10860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685497#comment-16685497 ] Stefan Richter commented on FLINK-10860: I opened https://issues.apache.org/jira

[jira] [Resolved] (FLINK-10860) java.lang.ArrayIndexOutOfBoundsException Error reading state

[ https://issues.apache.org/jira/browse/FLINK-10860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter resolved FLINK-10860. Resolution: Not A Problem Problem is most likely in the Beam code, where serializers are d

[jira] [Commented] (FLINK-10828) Enforce that all TypeSerializers are tested through SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686302#comment-16686302 ] Stefan Richter commented on FLINK-10828: Interesting sidenode, it seems like the

[jira] [Commented] (FLINK-10909) Possible RocksDBStateBackend performance regression with rocksdbjni-5.7.5

[ https://issues.apache.org/jira/browse/FLINK-10909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16689332#comment-16689332 ] Stefan Richter commented on FLINK-10909: The test you mentioned is part of the f

[jira] [Updated] (FLINK-32437) Determine and set correct maxParallelism for operator chains

[ 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

[jira] [Assigned] (FLINK-32441) DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore fails with timeout on AZP

[ 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

[jira] [Commented] (FLINK-30859) Remove flink-connector-kafka from master branch

[ 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

[jira] (FLINK-30859) Remove flink-connector-kafka from master branch

[ 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

[jira] [Commented] (FLINK-32441) DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore fails with timeout on AZP

[ 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

[jira] [Closed] (FLINK-32441) DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore fails with timeout on AZP

[ 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

[jira] [Closed] (FLINK-32347) Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager

[ 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 >

[jira] [Updated] (FLINK-32347) Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager

[ 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

[jira] [Updated] (FLINK-32326) Disable WAL in RocksDBWriteBatchWrapper by default

[ 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

[jira] [Closed] (FLINK-32345) Improve parallel download of RocksDB incremental state

[ 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 > -

[jira] [Closed] (FLINK-32326) Disable WAL in RocksDBWriteBatchWrapper by default

[ 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 > -

[jira] [Updated] (FLINK-32345) Improve parallel download of RocksDB incremental state

[ 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

[jira] [Updated] (FLINK-32410) Allocate hash-based collections with sufficient capacity for expected size

[ 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

[jira] [Commented] (FLINK-32681) RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure unstablie

[ 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

[jira] [Commented] (FLINK-32681) RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure unstablie

[ 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

[jira] [Commented] (FLINK-32681) RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure unstablie

[ 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

[jira] [Closed] (FLINK-32681) RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure unstablie

[ 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

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scaling down with unaligned checkpoints

[ 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

[jira] [Created] (FLINK-32326) Disable WAL in RocksDBWriteBatchWrapper by default

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

[jira] [Created] (FLINK-32345) Improve parallel download of RocksDB incremental state

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

<    4   5   6   7   8   9   10   >