[jira] [Closed] (FLINK-12478) Decompose monolithic run-loops in StreamTask implementations into step-wise calls

[ https://issues.apache.org/jira/browse/FLINK-12478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-12478. -- Resolution: Implemented Merged in: master 022f6cce > Decompose monolithic run-loops in Stream

[jira] [Closed] (FLINK-12480) Introduce mailbox to StreamTask main-loop

[ https://issues.apache.org/jira/browse/FLINK-12480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-12480. -- Resolution: Implemented Merged in: master 022f6cce > Introduce mailbox to StreamTask main-loo

[jira] [Assigned] (FLINK-12482) Make checkpoint trigger/notifyComplete run via the mailbox queue

[ https://issues.apache.org/jira/browse/FLINK-12482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-12482: -- Assignee: Stefan Richter (was: vinoyang) > Make checkpoint trigger/notifyComplete ru

[jira] [Closed] (FLINK-12483) Support (legacy) SourceFunctions with mailbox

[ https://issues.apache.org/jira/browse/FLINK-12483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-12483. -- Resolution: Implemented Fix Version/s: 1.9.0 Merged in: master ead91396 > Support (leg

[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=16848118#comment-16848118 ] Stefan Richter commented on FLINK-8871: --- After this quiet intense exchange, I was t

[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=16848118#comment-16848118 ] Stefan Richter edited comment on FLINK-8871 at 5/25/19 9:58 AM: ---

[jira] [Commented] (FLINK-12070) Make blocking result partitions consumable multiple times

[ 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

[jira] [Created] (FLINK-12804) Introduce mailbox-based ExecutorService

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

[jira] [Closed] (FLINK-12364) Introduce a CheckpointFailureManager to centralized manage checkpoint failure

[ 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

[jira] [Created] (FLINK-12958) Integrate AsyncWaitOperator with mailbox

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-

[jira] [Commented] (FLINK-33555) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory:

[ 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

[jira] [Created] (FLINK-34546) 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

[jira] [Closed] (FLINK-34546) Emit span with failure labels on failure

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

[jira] [Created] (FLINK-34579) 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

[jira] [Closed] (FLINK-34579) Introduce metric for time since last completed checkpoint

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

[jira] [Created] (FLINK-34693) Memory leak in KafkaWriter

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

[jira] [Updated] (FLINK-34693) 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 instances of {{TwoPhaseCommitProducer}} in Dequeue of c

[jira] [Updated] (FLINK-34693) 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

[jira] [Updated] (FLINK-34693) 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: --- Attachment: (was: image-2024-03-15-10-30-50-902.png) > Memory leak in KafkaWriter >

[jira] [Created] (FLINK-33341) Use available local state for rescaling

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

[jira] [Commented] (FLINK-33341) Use available local state for rescaling

[ 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

[jira] [Commented] (FLINK-33341) Use available local state for rescaling

[ 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

[jira] [Commented] (FLINK-33341) Use available local state for rescaling

[ 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

[jira] [Updated] (FLINK-33341) 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

[jira] [Closed] (FLINK-33341) 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 closed FLINK-33341. -- Resolution: Fixed merged in a4ad86f  > Use available local keyed state for rescaling > --

[jira] [Created] (FLINK-34134) Add tracing for restored state size and locations

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

[jira] [Created] (FLINK-34199) Add tracing for durations of rescaling/restoring from local state

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

[jira] [Updated] (FLINK-34199) Add tracing for durations of rescaling/restoring RocksDB incremental checkpoints from downloaded and local state

[ 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

[jira] [Commented] (FLINK-34218) AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

[ 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

[jira] [Resolved] (FLINK-33696) FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter

[ 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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17810420#comment-17810420 ] Stefan Richter commented on FLINK-32410: Yes, it's already done. > Allocate has

[jira] [Resolved] (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 resolved FLINK-32410. Fix Version/s: 1.18.0 (was: 1.19.0) Resolution: Done > Alloc

[jira] [Commented] (FLINK-34200) AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

[ 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

[jira] [Commented] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

[ 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

[jira] [Comment Edited] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

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

[jira] [Commented] (FLINK-33962) Chaining-agnostic OperatorID generation for improved state compatibility on parallelism change

[ 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

[jira] [Commented] (FLINK-32444) Enable object reuse for Flink SQL jobs by default

[ 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

[jira] [Commented] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage

[ 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

[jira] [Commented] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331982#comment-15331982 ] Stefan Richter commented on FLINK-4037: --- I think introducing an {{ArchivedExecutionG

[jira] [Comment Edited] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331982#comment-15331982 ] Stefan Richter edited comment on FLINK-4037 at 6/15/16 4:11 PM:

[jira] [Comment Edited] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331982#comment-15331982 ] Stefan Richter edited comment on FLINK-4037 at 6/15/16 4:12 PM:

[jira] [Comment Edited] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331982#comment-15331982 ] Stefan Richter edited comment on FLINK-4037 at 6/15/16 4:13 PM:

[jira] [Comment Edited] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331982#comment-15331982 ] Stefan Richter edited comment on FLINK-4037 at 6/15/16 4:14 PM:

[jira] [Updated] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4037: -- Assignee: (was: Stefan Richter) > Introduce ArchivedExecutionGraph without any user classes

[jira] [Created] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

Stefan Richter created FLINK-4083: - Summary: Use ClosureCleaner for Join where and equalTo Key: FLINK-4083 URL: https://issues.apache.org/jira/browse/FLINK-4083 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

[ https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333747#comment-15333747 ] Stefan Richter commented on FLINK-4083: --- Same problem. > Use ClosureCleaner for Joi

[jira] [Issue Comment Deleted] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

[ https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4083: -- Comment: was deleted (was: Same problem.) > Use ClosureCleaner for Join where and equalTo > ---

[jira] [Updated] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

[ https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4083: -- Description: When specifying a key selector in the where or equalTo clause of a Join, the closu

[jira] [Updated] (FLINK-35580) 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

[jira] [Commented] (FLINK-35217) 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

[jira] [Assigned] (FLINK-35217) 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 > ---

[jira] [Updated] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage

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

[jira] [Closed] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage

[ 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

[jira] [Updated] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage

[ 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

[jira] [Created] (FLINK-33077) Minimize the risk of hard back-pressure with buffer debloating enabled

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

[jira] [Created] (FLINK-33246) Add RescalingIT case that uses checkpoints and resource requests

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

[jira] [Commented] (FLINK-7873) Introduce CheckpointCacheManager for reading checkpoint data locally when performing failover

[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16233608#comment-16233608 ] Stefan Richter commented on FLINK-7873: --- The first proposal of this JIRA had some is

[jira] [Comment Edited] (FLINK-7873) Introduce CheckpointCacheManager for reading checkpoint data locally when performing failover

[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16233608#comment-16233608 ] Stefan Richter edited comment on FLINK-7873 at 11/1/17 3:36 AM:

[jira] [Commented] (FLINK-7880) flink-queryable-state-java fails with core-dump

[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16239068#comment-16239068 ] Stefan Richter commented on FLINK-7880: --- My theory is that the `dispose()` is not pr

[jira] [Commented] (FLINK-7880) flink-queryable-state-java fails with core-dump

[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240153#comment-16240153 ] Stefan Richter commented on FLINK-7880: --- Yes, but the test seems to expect that wait

[jira] [Comment Edited] (FLINK-7880) flink-queryable-state-java fails with core-dump

[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240153#comment-16240153 ] Stefan Richter edited comment on FLINK-7880 at 11/6/17 11:20 AM: ---

[jira] [Assigned] (FLINK-8053) Default to asynchronous snapshots for FsStateBackend

[ https://issues.apache.org/jira/browse/FLINK-8053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8053: - Assignee: Stefan Richter (was: Aljoscha Krettek) > Default to asynchronous snapshots for

[jira] [Closed] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8040. - Resolution: Fixed Merged in ad8ef6d01b. > Test instability ResourceGuard#testCloseBlockIfAcquired

[jira] [Commented] (FLINK-7873) Introduce CheckpointCacheManager for reading checkpoint data locally when performing failover

[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16249823#comment-16249823 ] Stefan Richter commented on FLINK-7873: --- [~sihuazhou] We are already planning to int

[jira] [Closed] (FLINK-8053) Default to asynchronous snapshots for FsStateBackend

[ https://issues.apache.org/jira/browse/FLINK-8053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8053. - Resolution: Fixed Merged in 2906698b4a. > Default to asynchronous snapshots for FsStateBackend >

[jira] [Created] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery

Stefan Richter created FLINK-8086: - Summary: FlinkKafkaProducer011 can permanently fail in recovery Key: FLINK-8086 URL: https://issues.apache.org/jira/browse/FLINK-8086 Project: Flink Issue

[jira] [Updated] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

[ https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8086: -- Summary: FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

[jira] [Updated] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

[ https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8086: -- Description: Chaos monkey test in a cluster environment can permanently bring down our FlinkKaf

[jira] [Commented] (FLINK-7873) Introduce CheckpointCacheManager for reading checkpoint data locally when performing failover

[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16255069#comment-16255069 ] Stefan Richter commented on FLINK-7873: --- [~sihuazhou] If you want, you can also open

[jira] [Commented] (FLINK-7873) Introduce CheckpointCacheManager for reading checkpoint data locally when performing failover

[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16255087#comment-16255087 ] Stefan Richter commented on FLINK-7873: --- Very good, that fits well because we are st

[jira] [Commented] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16259045#comment-16259045 ] Stefan Richter commented on FLINK-8098: --- >From a first glance, this does not look li

[jira] [Comment Edited] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16259045#comment-16259045 ] Stefan Richter edited comment on FLINK-8098 at 11/20/17 10:05 AM: --

[jira] [Commented] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262324#comment-16262324 ] Stefan Richter commented on FLINK-8098: --- What do you mean by "parallelism of checkpo

[jira] [Commented] (FLINK-8125) Support limiting the number of open FileSystem connections

[ https://issues.apache.org/jira/browse/FLINK-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262343#comment-16262343 ] Stefan Richter commented on FLINK-8125: --- Maybe we can add this monitoring to the alr

[jira] [Comment Edited] (FLINK-8125) Support limiting the number of open FileSystem connections

[ https://issues.apache.org/jira/browse/FLINK-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262343#comment-16262343 ] Stefan Richter edited comment on FLINK-8125 at 11/22/17 11:27 AM: --

[jira] [Commented] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

[ https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16264061#comment-16264061 ] Stefan Richter commented on FLINK-5465: --- Hi [~dernasherbrezon], it is true that this

[jira] [Commented] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16264175#comment-16264175 ] Stefan Richter commented on FLINK-8098: --- Parallel scripts was just another option th

[jira] [Closed] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-6505. - Resolution: Fixed Fix Version/s: 1.5.0 1.4.0 merged in ccf917de23. > Pr

[jira] [Reopened] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

[ https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reopened FLINK-5465: --- Assignee: Stefan Richter Reconsidered for a better solution because JVM crashed can also hea

[jira] [Closed] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

[ https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5465. - Resolution: Fixed Fix Version/s: 1.5.0 1.4.0 merged in d86c6b6bb3. > Ro

[jira] [Closed] (FLINK-7316) always use off-heap network buffers

[ https://issues.apache.org/jira/browse/FLINK-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-7316. - Resolution: Fixed Fix Version/s: 1.5.0 Merged in 1854a3de19. > always use off-heap network

[jira] [Created] (FLINK-9799) Generalize/unify state meta info

Stefan Richter created FLINK-9799: - Summary: Generalize/unify state meta info Key: FLINK-9799 URL: https://issues.apache.org/jira/browse/FLINK-9799 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-9511) Implement TTL config

[ https://issues.apache.org/jira/browse/FLINK-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9511. - Resolution: Implemented Merged in: master: dc7d81c9c0 > Implement TTL config > -

[jira] [Commented] (FLINK-9831) Too many open files for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541415#comment-16541415 ] Stefan Richter commented on FLINK-9831: --- In your list of open files, I can only see

[jira] [Commented] (FLINK-9831) Too many open files for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541621#comment-16541621 ] Stefan Richter commented on FLINK-9831: --- Defaults are in {{org.apache.flink.contrib

[jira] [Comment Edited] (FLINK-9831) Too many open files for RocksDB

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

[jira] [Closed] (FLINK-9799) Generalize/unify state meta info

[ https://issues.apache.org/jira/browse/FLINK-9799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9799. - Resolution: Implemented Fix Version/s: 1.6.0 Merged in: master: f1ac0f2797 > Generalize/u

[jira] [Closed] (FLINK-9701) Activate TTL in state descriptors

[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9701. - Resolution: Implemented Merged in: master: f45b7f7ff2 > Activate TTL in state descriptors >

[jira] [Created] (FLINK-9887) Ensure serializer upgrades work with timer service remake

Stefan Richter created FLINK-9887: - Summary: Ensure serializer upgrades work with timer service remake Key: FLINK-9887 URL: https://issues.apache.org/jira/browse/FLINK-9887 Project: Flink Iss

[jira] [Created] (FLINK-9902) Improve and refactor window checkpointing IT cases

Stefan Richter created FLINK-9902: - Summary: Improve and refactor window checkpointing IT cases Key: FLINK-9902 URL: https://issues.apache.org/jira/browse/FLINK-9902 Project: Flink Issue Type

[jira] [Closed] (FLINK-9858) State TTL End-to-End Test

[ https://issues.apache.org/jira/browse/FLINK-9858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9858. - Resolution: Implemented Merged in: master: 01cf808ee8 release-1.6: 6a36afd > State TTL End-to-En

[jira] [Closed] (FLINK-9902) Improve and refactor window checkpointing IT cases

[ https://issues.apache.org/jira/browse/FLINK-9902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9902. - Resolution: Implemented Merged in: master: d309e61 release-1.6: f19337a > Improve and refactor w

[jira] [Created] (FLINK-9918) Outsource fastutil dependency to flink-shading.

Stefan Richter created FLINK-9918: - Summary: Outsource fastutil dependency to flink-shading. Key: FLINK-9918 URL: https://issues.apache.org/jira/browse/FLINK-9918 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-9918) Outsource fastutil dependency to flink-shading.

[ https://issues.apache.org/jira/browse/FLINK-9918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16552776#comment-16552776 ] Stefan Richter commented on FLINK-9918: --- What would it help to guard against clashe

[jira] [Commented] (FLINK-9918) Outsource fastutil dependency to flink-shading.

[ https://issues.apache.org/jira/browse/FLINK-9918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16552777#comment-16552777 ] Stefan Richter commented on FLINK-9918: --- I am currently checking if I can replace m

[jira] [Commented] (FLINK-9945) RocksDB state backend Checkpointing Failed

[ https://issues.apache.org/jira/browse/FLINK-9945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16557994#comment-16557994 ] Stefan Richter commented on FLINK-9945: --- The exception does not show the root cause

[jira] [Commented] (FLINK-9945) RocksDB state backend Checkpointing Failed

[ https://issues.apache.org/jira/browse/FLINK-9945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16558160#comment-16558160 ] Stefan Richter commented on FLINK-9945: --- Ok, there is no exception but it clearly s

[jira] [Comment Edited] (FLINK-9945) RocksDB state backend Checkpointing Failed

[ https://issues.apache.org/jira/browse/FLINK-9945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16558160#comment-16558160 ] Stefan Richter edited comment on FLINK-9945 at 7/26/18 10:47 AM: --

[jira] [Created] (FLINK-9981) Tune performance of RocksDB implementation

Stefan Richter created FLINK-9981: - Summary: Tune performance of RocksDB implementation Key: FLINK-9981 URL: https://issues.apache.org/jira/browse/FLINK-9981 Project: Flink Issue Type: Sub-ta

[jira] [Closed] (FLINK-9918) Outsource fastutil dependency to flink-shading.

[ https://issues.apache.org/jira/browse/FLINK-9918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9918. - Resolution: Workaround Fix Version/s: 1.6.0 We currently no longer need the dependency aft

<    1   2   3   4   5   6   7   8   9   10   >