[jira] [Closed] (FLINK-9254) Move NotSoMiniClusterIterations to be an end-to-end test

[ https://issues.apache.org/jira/browse/FLINK-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9254. - Resolution: Fixed Merged in: master: b50cebb656 release-1.5: ed3447e343 > Move NotSoMiniCluster

[jira] [Closed] (FLINK-8978) End-to-end test: Job upgrade

[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8978. - Resolution: Fixed Merged in: master: 5ac4d29609 release-1.5: 54befe5a31 > End-to-end test: Job

[jira] [Reopened] (FLINK-8978) End-to-end test: Job upgrade

[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reopened FLINK-8978: --- Change fix version > End-to-end test: Job upgrade > > >

[jira] [Closed] (FLINK-8978) End-to-end test: Job upgrade

[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8978. - Resolution: Fixed > End-to-end test: Job upgrade > > >

[jira] [Updated] (FLINK-8978) End-to-end test: Job upgrade

[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8978: -- Fix Version/s: (was: 1.5.1) 1.5.0 > End-to-end test: Job upgrade > --

[jira] [Commented] (FLINK-9302) Checkpoints continues to fail when using filesystem state backend with CIRCULAR REFERENCE:java.io.IOException

[ https://issues.apache.org/jira/browse/FLINK-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16465575#comment-16465575 ] Stefan Richter commented on FLINK-9302: --- If you take a look at this stack trace, it

[jira] [Closed] (FLINK-9302) Checkpoints continues to fail when using filesystem state backend with CIRCULAR REFERENCE:java.io.IOException

[ https://issues.apache.org/jira/browse/FLINK-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9302. - Resolution: Not A Problem > Checkpoints continues to fail when using filesystem state backend with

[jira] [Created] (FLINK-9304) Timer service shutdown should not be interrupted

Stefan Richter created FLINK-9304: - Summary: Timer service shutdown should not be interrupted Key: FLINK-9304 URL: https://issues.apache.org/jira/browse/FLINK-9304 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9302) Checkpoints continues to fail when using filesystem state backend with CIRCULAR REFERENCE:java.io.IOException

[ https://issues.apache.org/jira/browse/FLINK-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16467013#comment-16467013 ] Stefan Richter commented on FLINK-9302: --- Thanks for the update, I appreciate it. Thi

[jira] [Created] (FLINK-9355) Simplify configuration of local recovery to a simple on/off

Stefan Richter created FLINK-9355: - Summary: Simplify configuration of local recovery to a simple on/off Key: FLINK-9355 URL: https://issues.apache.org/jira/browse/FLINK-9355 Project: Flink

[jira] [Created] (FLINK-9375) Introduce AbortCheckpoint message from JM to TMs

Stefan Richter created FLINK-9375: - Summary: Introduce AbortCheckpoint message from JM to TMs Key: FLINK-9375 URL: https://issues.apache.org/jira/browse/FLINK-9375 Project: Flink Issue Type:

[jira] [Closed] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8910. - Resolution: Fixed Release Note: We changed the default SLOT_IDLE_TIMEOUT to the HEARTBEAT_TI

[jira] [Reopened] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reopened FLINK-8910: --- Change fix version > Introduce automated end-to-end test for local recovery (including sticky >

[jira] [Updated] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8910: -- Fix Version/s: 1.5.0 > Introduce automated end-to-end test for local recovery (including sticky

[jira] [Closed] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8910. - Resolution: Fixed > Introduce automated end-to-end test for local recovery (including sticky > sc

[jira] [Created] (FLINK-9388) Inconsistency in job shutdown produces confusing log message

Stefan Richter created FLINK-9388: - Summary: Inconsistency in job shutdown produces confusing log message Key: FLINK-9388 URL: https://issues.apache.org/jira/browse/FLINK-9388 Project: Flink

[jira] [Created] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message

Stefan Richter created FLINK-9390: - Summary: Shutdown of KafkaProducer causes confusing log message Key: FLINK-9390 URL: https://issues.apache.org/jira/browse/FLINK-9390 Project: Flink Issue

[jira] [Commented] (FLINK-9373) Fix potential data losing for RocksDBBackend

[ https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478842#comment-16478842 ] Stefan Richter commented on FLINK-9373: --- Maybe we can also take the PR basically "as

[jira] [Commented] (FLINK-9373) Fix potential data losing for RocksDBBackend

[ https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478857#comment-16478857 ] Stefan Richter commented on FLINK-9373: --- Well, but we are also at risk to have only

[jira] [Commented] (FLINK-9373) Fix potential data losing for RocksDBBackend

[ https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478861#comment-16478861 ] Stefan Richter commented on FLINK-9373: --- [~sihuazhou] Will you be able to do this qu

[jira] [Commented] (FLINK-9373) Fix potential data losing for RocksDBBackend

[ https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478866#comment-16478866 ] Stefan Richter commented on FLINK-9373: --- Great, thanks a lot! > Fix potential data

[jira] [Commented] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message

[ https://issues.apache.org/jira/browse/FLINK-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478936#comment-16478936 ] Stefan Richter commented on FLINK-9390: --- [~triones] Unfortunately I don't know a way

[jira] [Commented] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message

[ https://issues.apache.org/jira/browse/FLINK-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478941#comment-16478941 ] Stefan Richter commented on FLINK-9390: --- >From the log, it seems that Kafka09 connec

[jira] [Closed] (FLINK-9373) Fix potential data losing for RocksDBBackend

[ https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9373. - Resolution: Fixed Fix Version/s: 1.6.0 Merged in: master: 105b30686f release-1.5: c75c152

[jira] [Commented] (FLINK-9375) Introduce AbortCheckpoint message from JM to TMs

[ https://issues.apache.org/jira/browse/FLINK-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479298#comment-16479298 ] Stefan Richter commented on FLINK-9375: --- [~yanghua] this task maybe a bit more trick

[jira] [Closed] (FLINK-8845) Use WriteBatch to improve performance for recovery in RocksDB backend

[ https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8845. - Resolution: Fixed Fix Version/s: 1.5.1 Merged in: master: 1c7341ad1a release-1.5: 3f97f33

[jira] [Created] (FLINK-9423) Implement efficient deletes for heap based timer service

Stefan Richter created FLINK-9423: - Summary: Implement efficient deletes for heap based timer service Key: FLINK-9423 URL: https://issues.apache.org/jira/browse/FLINK-9423 Project: Flink Issu

[jira] [Assigned] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-9423: - Assignee: Stefan Richter > Implement efficient deletes for heap based timer service > ---

[jira] [Updated] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-9423: -- Description: The current data structures in the `HeapInternalTimerService` are not able to supp

[jira] [Closed] (FLINK-9064) Add Scaladocs link to documentation

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

[jira] [Closed] (FLINK-9426) Harden RocksDBWriteBatchPerformanceTest.benchMark()

[ https://issues.apache.org/jira/browse/FLINK-9426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9426. - Resolution: Fixed Fix Version/s: 1.5.1 Merged in: master: b485f8cc60 release-1.5: e04f87225

[jira] [Created] (FLINK-9436) Remove generic parameter namespace from InternalTimeServiceManager

Stefan Richter created FLINK-9436: - Summary: Remove generic parameter namespace from InternalTimeServiceManager Key: FLINK-9436 URL: https://issues.apache.org/jira/browse/FLINK-9436 Project: Flink

[jira] [Closed] (FLINK-9355) Simplify configuration of local recovery to a simple on/off

[ https://issues.apache.org/jira/browse/FLINK-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9355. - Resolution: Fixed Fix Version/s: 1.6.0 Merged in: master: 7f42259 release-1.5: b907af2ed6

[jira] [Commented] (FLINK-9440) Allow cancelation and reset of timers

[ https://issues.apache.org/jira/browse/FLINK-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16492547#comment-16492547 ] Stefan Richter commented on FLINK-9440: --- Yes, was just about to answer to this. Once

[jira] [Commented] (FLINK-9450) Job hangs if S3 access it denied during checkpoints

[ https://issues.apache.org/jira/browse/FLINK-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16492587#comment-16492587 ] Stefan Richter commented on FLINK-9450: --- Do you have some logs for this problem, and

[jira] [Comment Edited] (FLINK-9450) Job hangs if S3 access it denied during checkpoints

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

[jira] [Closed] (FLINK-9153) TaskManagerRunner should support rpc port range

[ https://issues.apache.org/jira/browse/FLINK-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9153. - Resolution: Fixed Fix Version/s: 1.6.0 Merged in: master: 7c90447849 release-1.5: b57bf73e5

[jira] [Assigned] (FLINK-9440) Allow cancelation and reset of timers

[ https://issues.apache.org/jira/browse/FLINK-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-9440: - Assignee: Stefan Richter > Allow cancelation and reset of timers > --

[jira] [Commented] (FLINK-9268) RockDB errors from WindowOperator

[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16494851#comment-16494851 ] Stefan Richter commented on FLINK-9268: --- Please notice that this is our attempt to

[jira] [Commented] (FLINK-9480) Let local recovery support rescaling

[ https://issues.apache.org/jira/browse/FLINK-9480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16494892#comment-16494892 ] Stefan Richter commented on FLINK-9480: --- Can you give some more details why you thi

[jira] [Commented] (FLINK-9480) Let local recovery support rescaling

[ https://issues.apache.org/jira/browse/FLINK-9480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16494897#comment-16494897 ] Stefan Richter commented on FLINK-9480: --- Maybe [~StephanEwen] or [~till.rohrmann] c

[jira] [Closed] (FLINK-8360) Implement task-local state recovery

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8360. - Resolution: Fixed > Implement task-local state recovery > --- > >

[jira] [Commented] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380155#comment-16380155 ] Stefan Richter commented on FLINK-8467: --- [~jelmer] any updates on this problem or ca

[jira] [Closed] (FLINK-8777) improve resource release when recovery from failover

[ https://issues.apache.org/jira/browse/FLINK-8777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8777. - Resolution: Fixed Merged in 296f9ff742. > improve resource release when recovery from failover >

[jira] [Commented] (FLINK-7167) Job can't set checkpoint meta directory to cover the system setting state.checkpoints.dir

[ https://issues.apache.org/jira/browse/FLINK-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380246#comment-16380246 ] Stefan Richter commented on FLINK-7167: --- [~StephanEwen]  isn't this already covered

[jira] [Commented] (FLINK-7901) Detecting whether an operator is restored doesn't work with chained state (Flink 1.3)

[ https://issues.apache.org/jira/browse/FLINK-7901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380251#comment-16380251 ] Stefan Richter commented on FLINK-7901: --- [~aljoscha] can we close this issue or will

[jira] [Commented] (FLINK-8413) Snapshot state of aggregated data is not maintained in flink's checkpointing

[ https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380262#comment-16380262 ] Stefan Richter commented on FLINK-8413: --- [~suganyap] and [~aljoscha] are there any u

[jira] [Closed] (FLINK-8515) update RocksDBMapState to replace deprecated remove() with delete()

[ https://issues.apache.org/jira/browse/FLINK-8515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8515. - Resolution: Fixed Already fixed in ff6662c. > update RocksDBMapState to replace deprecated remove

[jira] [Assigned] (FLINK-8557) OperatorSubtaskDescriptionText causes failures on Windows

[ https://issues.apache.org/jira/browse/FLINK-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8557: - Assignee: Stefan Richter > OperatorSubtaskDescriptionText causes failures on Windows > --

[jira] [Closed] (FLINK-8557) OperatorSubtaskDescriptionText causes failures on Windows

[ https://issues.apache.org/jira/browse/FLINK-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8557. - Resolution: Fixed Fixed in af8efe92c3. > OperatorSubtaskDescriptionText causes failures on Window

[jira] [Closed] (FLINK-8751) Canceling a job results in a InterruptedException in the TM

[ https://issues.apache.org/jira/browse/FLINK-8751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8751. - Resolution: Fixed Assignee: Stefan Richter Fix Version/s: 1.5.0 Fixed in f9a583b.

[jira] [Commented] (FLINK-8837) Move DataStreamUtils to package 'experimental'.

[ https://issues.apache.org/jira/browse/FLINK-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383502#comment-16383502 ] Stefan Richter commented on FLINK-8837: --- I think there is one problem with keeping i

[jira] [Comment Edited] (FLINK-8837) Move DataStreamUtils to package 'experimental'.

[ https://issues.apache.org/jira/browse/FLINK-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383502#comment-16383502 ] Stefan Richter edited comment on FLINK-8837 at 3/2/18 11:47 AM:

[jira] [Commented] (FLINK-8837) Move DataStreamUtils to package 'experimental'.

[ https://issues.apache.org/jira/browse/FLINK-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383509#comment-16383509 ] Stefan Richter commented on FLINK-8837: --- The class is annotated as evolving and as y

[jira] [Closed] (FLINK-8859) RocksDB backend should pass WriteOption to Rocks.put() when restoring

[ https://issues.apache.org/jira/browse/FLINK-8859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8859. - Resolution: Fixed Release Note: Merged in 131daa28bf. > RocksDB backend should pass WriteOpt

[jira] [Created] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

Stefan Richter created FLINK-8871: - Summary: Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager Key: FLINK-8871 URL: https://issues.apache.org/jira/browse/FLINK-8871

[jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387786#comment-16387786 ] Stefan Richter commented on FLINK-8871: --- [~sihuazhou] Given the release plan, this w

[jira] [Comment Edited] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387786#comment-16387786 ] Stefan Richter edited comment on FLINK-8871 at 3/6/18 1:40 PM: -

[jira] [Commented] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

[ https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16388012#comment-16388012 ] Stefan Richter commented on FLINK-8867: --- The reported exception is not showing the r

[jira] [Assigned] (FLINK-8882) flink-tests fails with core dump

[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8882: - Assignee: Stefan Richter > flink-tests fails with core dump > ---

[jira] [Commented] (FLINK-8882) flink-tests fails with core dump

[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391300#comment-16391300 ] Stefan Richter commented on FLINK-8882: --- It seems like the problem was introduced by

[jira] [Commented] (FLINK-8882) flink-tests fails with core dump

[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391314#comment-16391314 ] Stefan Richter commented on FLINK-8882: --- Got to double check again, maybe the proble

[jira] [Created] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

Stefan Richter created FLINK-8910: - Summary: Introduce automated end-to-end test for local recovery (including sticky scheduling) Key: FLINK-8910 URL: https://issues.apache.org/jira/browse/FLINK-8910

[jira] [Created] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

Stefan Richter created FLINK-8922: - Summary: Revert FLINK-8859 because it causes segfaults in testing Key: FLINK-8922 URL: https://issues.apache.org/jira/browse/FLINK-8922 Project: Flink Issu

[jira] [Closed] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8922. - Resolution: Fixed Release Note: Merged in a389b43581. > Revert FLINK-8859 because it causes

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395037#comment-16395037 ] Stefan Richter commented on FLINK-8922: --- FYI [~sihuazhou] > Revert FLINK-8859 becau

[jira] [Assigned] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8922: - Assignee: Stefan Richter > Revert FLINK-8859 because it causes segfaults in testing > ---

[jira] [Resolved] (FLINK-8882) flink-tests fails with core dump

[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter resolved FLINK-8882. --- Resolution: Fixed > flink-tests fails with core dump > > >

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395054#comment-16395054 ] Stefan Richter commented on FLINK-8922: --- Ok that sounds good. I also had a look and

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395205#comment-16395205 ] Stefan Richter commented on FLINK-8922: --- Yes, I tried out to create a dedicated \{{W

[jira] [Commented] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart

[ https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395297#comment-16395297 ] Stefan Richter commented on FLINK-8042: --- [~till.rohrmann] and me came to the conclus

[jira] [Closed] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart

[ https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8042. - Resolution: Won't Fix This problem should be solved with FLIP-6 and is hard to support in the lega

[jira] [Commented] (FLINK-8913) RocksDB state backend crashes in alpine image

[ https://issues.apache.org/jira/browse/FLINK-8913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395360#comment-16395360 ] Stefan Richter commented on FLINK-8913: --- This is a known issue, Alpine Linux uses MU

[jira] [Resolved] (FLINK-8913) RocksDB state backend crashes in alpine image

[ https://issues.apache.org/jira/browse/FLINK-8913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter resolved FLINK-8913. --- Resolution: Won't Fix Release Note: RocksDB requires glibc which is not available on ALPI

[jira] [Closed] (FLINK-8927) Eagerly release the checkpoint object created from RocksDB

[ https://issues.apache.org/jira/browse/FLINK-8927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8927. - Resolution: Fixed Merged in 3debf47e5d. > Eagerly release the checkpoint object created from Rock

[jira] [Created] (FLINK-8992) Implement source and operator that validate exactly-once

Stefan Richter created FLINK-8992: - Summary: Implement source and operator that validate exactly-once Key: FLINK-8992 URL: https://issues.apache.org/jira/browse/FLINK-8992 Project: Flink Issu

[jira] [Created] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered)

Stefan Richter created FLINK-8993: - Summary: Add a test operator with keyed state that uses Kryo serializer (registered/unregistered) Key: FLINK-8993 URL: https://issues.apache.org/jira/browse/FLINK-8993

[jira] [Updated] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom)

[ https://issues.apache.org/jira/browse/FLINK-8993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8993: -- Summary: Add a test operator with keyed state that uses Kryo serializer (registered/unregistered

[jira] [Created] (FLINK-8994) Add a test operator with keyed state that uses Avro serializer (from schema/by reflection)

Stefan Richter created FLINK-8994: - Summary: Add a test operator with keyed state that uses Avro serializer (from schema/by reflection) Key: FLINK-8994 URL: https://issues.apache.org/jira/browse/FLINK-8994

[jira] [Updated] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom)

[ https://issues.apache.org/jira/browse/FLINK-8993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8993: -- Description: Add an operator with keyed state that uses Kryo serializer (registered/unregistered

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

Stefan Richter created FLINK-8995: - Summary: Add a test operator with keyed state that uses custom, stateful serializer Key: FLINK-8995 URL: https://issues.apache.org/jira/browse/FLINK-8995 Project: F

[jira] [Created] (FLINK-8996) Include an operator with broadcast and union state

Stefan Richter created FLINK-8996: - Summary: Include an operator with broadcast and union state Key: FLINK-8996 URL: https://issues.apache.org/jira/browse/FLINK-8996 Project: Flink Issue Type

[jira] [Created] (FLINK-8997) Add sliding window aggregation to the job

Stefan Richter created FLINK-8997: - Summary: Add sliding window aggregation to the job Key: FLINK-8997 URL: https://issues.apache.org/jira/browse/FLINK-8997 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-8998) Add user-defined watermark assigner and timestamp extractor to the test job

Stefan Richter created FLINK-8998: - Summary: Add user-defined watermark assigner and timestamp extractor to the test job Key: FLINK-8998 URL: https://issues.apache.org/jira/browse/FLINK-8998 Project:

[jira] [Updated] (FLINK-8998) Add user-defined watermark assigner and timestamp extractor to the test job

[ https://issues.apache.org/jira/browse/FLINK-8998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8998: -- Affects Version/s: 1.5.0 > Add user-defined watermark assigner and timestamp extractor to the te

[jira] [Updated] (FLINK-8998) Add user-defined watermark assigner and timestamp extractor to the test job

[ https://issues.apache.org/jira/browse/FLINK-8998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8998: -- Component/s: Tests > Add user-defined watermark assigner and timestamp extractor to the test job

[jira] [Created] (FLINK-8999) Ensure the job has an operator with operator state.

Stefan Richter created FLINK-8999: - Summary: Ensure the job has an operator with operator state. Key: FLINK-8999 URL: https://issues.apache.org/jira/browse/FLINK-8999 Project: Flink Issue Typ

[jira] [Created] (FLINK-9001) Add operators with input type that goes through Kryo serialization (registered/generic/custom)

Stefan Richter created FLINK-9001: - Summary: Add operators with input type that goes through Kryo serialization (registered/generic/custom) Key: FLINK-9001 URL: https://issues.apache.org/jira/browse/FLINK-9001

[jira] [Created] (FLINK-9002) Add operators with input type that goes through Avro serialization (with schema/generic)

Stefan Richter created FLINK-9002: - Summary: Add operators with input type that goes through Avro serialization (with schema/generic) Key: FLINK-9002 URL: https://issues.apache.org/jira/browse/FLINK-9002

[jira] [Created] (FLINK-9003) Add operators with input type that goes through custom, stateful serialization

Stefan Richter created FLINK-9003: - Summary: Add operators with input type that goes through custom, stateful serialization Key: FLINK-9003 URL: https://issues.apache.org/jira/browse/FLINK-9003 Projec

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401933#comment-16401933 ] Stefan Richter commented on FLINK-8922: --- Hmm, I wonder why that should be a fix? Doe

[jira] [Closed] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8699. - Resolution: Fixed Merged in 21cf59d5ff > Fix concurrency problem in rocksdb full checkpoint > ---

[jira] [Closed] (FLINK-8968) Fix native resource leak caused by ReadOptions

[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8968. - Resolution: Fixed Merged in f5071d7a61 > Fix native resource leak caused by ReadOptions > --

[jira] [Commented] (FLINK-9192) Undo parameterization of StateMachine Example

[ https://issues.apache.org/jira/browse/FLINK-9192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16440934#comment-16440934 ] Stefan Richter commented on FLINK-9192: --- +1, I think that the test could build upon

[jira] [Created] (FLINK-10068) Add documentation for async/RocksDB-based timers

Stefan Richter created FLINK-10068: -- Summary: Add documentation for async/RocksDB-based timers Key: FLINK-10068 URL: https://issues.apache.org/jira/browse/FLINK-10068 Project: Flink Issue Ty

[jira] [Updated] (FLINK-10068) Add documentation for async/RocksDB-based timers

[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10068: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-9485 > Add documentation for

[jira] [Reopened] (FLINK-9504) Change checkpoint duration log level to debug to avoid too much log

[ https://issues.apache.org/jira/browse/FLINK-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reopened FLINK-9504: --- > Change checkpoint duration log level to debug to avoid too much log > -

[jira] [Updated] (FLINK-9504) Change checkpoint duration log level to debug to avoid too much log

[ https://issues.apache.org/jira/browse/FLINK-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-9504: -- Fix Version/s: 1.7.0 > Change checkpoint duration log level to debug to avoid too much log > --

[jira] [Closed] (FLINK-9504) Change checkpoint duration log level to debug to avoid too much log

[ https://issues.apache.org/jira/browse/FLINK-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9504. - Resolution: Implemented Mergend in: master: b2a91310e1 > Change checkpoint duration log level to

[jira] [Closed] (FLINK-9504) Change checkpoint duration log level to debug to avoid too much log

[ https://issues.apache.org/jira/browse/FLINK-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9504. - Resolution: Fixed > Change checkpoint duration log level to debug to avoid too much log > ---

<    2   3   4   5   6   7   8   9   10   >