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

[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=16478941#comment-16478941 ] Stefan Richter commented on FLINK-9390: --- >From the log, it seems that Kafka09 connectors are used.

[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=16478936#comment-16478936 ] Stefan Richter commented on FLINK-9390: --- [~triones] Unfortunately I don't know a way to reproduce

[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=16478866#comment-16478866 ] Stefan Richter commented on FLINK-9373: --- Great, thanks a lot! > Fix potential data losing for

[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=16478861#comment-16478861 ] Stefan Richter commented on FLINK-9373: --- [~sihuazhou] Will you be able to do this quickly or can I

[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=16478857#comment-16478857 ] Stefan Richter commented on FLINK-9373: --- Well, but we are also at risk to have only a partial fix.

[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=16478842#comment-16478842 ] Stefan Richter commented on FLINK-9373: --- Maybe we can also take the PR basically "as is" for now so

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

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

[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] [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] [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-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] [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=16467013#comment-16467013 ] Stefan Richter commented on FLINK-9302: --- Thanks for the update, I appreciate it. This information

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

[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=16465575#comment-16465575 ] Stefan Richter commented on FLINK-9302: --- If you take a look at this stack trace, it tells you that

[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] [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] [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 Merged in: master: 5ac4d29609 release-1.5: 54befe5a31 > End-to-end test: Job

[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

[jira] [Closed] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

[ https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9269. - Resolution: Fixed Merged in: master: 14e7d35f26 release-1.5: 3ba21adc0e > Concurrency problem

[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=16462164#comment-16462164 ] Stefan Richter commented on FLINK-9268: --- It is hard to make any assumptions about your job without

[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=16462086#comment-16462086 ] Stefan Richter commented on FLINK-9268: --- Yes, you could have duplicates in AT_LEAST_ONCE. But if

[jira] [Issue Comment Deleted] (FLINK-9268) RockDB errors from WindowOperator

[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-9268: -- Comment: was deleted (was: Maybe what your are looking for is using a window with aggregate

[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=16462072#comment-16462072 ] Stefan Richter commented on FLINK-9268: --- Maybe what your are looking for is using a window with

[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=16462068#comment-16462068 ] Stefan Richter commented on FLINK-9268: --- The 2GB limit actually applies on a per-key-per-window

[jira] [Commented] (FLINK-9291) Checkpoint failure (CIRCULAR REFERENCE:java.lang.NegativeArraySizeException)

[ https://issues.apache.org/jira/browse/FLINK-9291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462025#comment-16462025 ] Stefan Richter commented on FLINK-9291: --- Yes, this is basically a duplicate, just the access to the

[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=16461231#comment-16461231 ] Stefan Richter commented on FLINK-9268: --- I don't think that is the cause. The exception comes right

[jira] [Commented] (FLINK-9290) The job is unable to recover from a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461167#comment-16461167 ] Stefan Richter commented on FLINK-9290: --- [~sihuazhou] yes, looks like it. > The job is unable to

[jira] [Commented] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460907#comment-16460907 ] Stefan Richter commented on FLINK-7484: --- [~joshlemer] this looks like a different problem to me,

[jira] [Closed] (FLINK-9263) Kafka010ITCase failed on travis because of the concurrency problem in DefaultOperateStateBackend

[ https://issues.apache.org/jira/browse/FLINK-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9263. - Resolution: Fixed Merged in: master: c11f11359b release 1.5: de4f283087 > Kafka010ITCase

[jira] [Closed] (FLINK-9270) Upgrade RocksDB to 5.11.3, and resolve concurrent test invocation problem of @RetryOnFailure

[ https://issues.apache.org/jira/browse/FLINK-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9270. - Resolution: Won't Fix Won't fix until we figure out a way around the performance regression of

[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=16457505#comment-16457505 ] Stefan Richter commented on FLINK-9268: --- This is a known issue with RocksDB, see

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

[ https://issues.apache.org/jira/browse/FLINK-8992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8992. - Resolution: Fixed Merged in: master: 31c717697a52af2c64439aaaba2f6a1f97a22159 release 1.5: 

[jira] [Closed] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5372. - Resolution: Fixed Fix Version/s: (was: 1.4.3) 1.6.0 Fixed in:

[jira] [Closed] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

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

[jira] [Commented] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak

[ https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16448183#comment-16448183 ] Stefan Richter commented on FLINK-9080: --- [~rohsing] could you somehow provide your heap dump to me

[jira] [Assigned] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8836: - Assignee: Stefan Richter > Duplicating a KryoSerializer does not duplicate registered

[jira] [Commented] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443973#comment-16443973 ] Stefan Richter commented on FLINK-8836: --- Serialization will probably work in most cases, but still

[jira] [Closed] (FLINK-9022) fix resource close in `StreamTaskStateInitializerImpl.streamOperatorStateContext()`

[ https://issues.apache.org/jira/browse/FLINK-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9022. - Resolution: Fixed Fixed in master: 777cc1ab53 release-1.5: 01f701ab72 > fix resource close in

[jira] [Closed] (FLINK-9144) Spilling batch job hangs

[ https://issues.apache.org/jira/browse/FLINK-9144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9144. - Resolution: Fixed Fixed in: master: 388a083c90 release-1.5: f7e621d322 > Spilling batch job

[jira] [Reopened] (FLINK-9022) fix resource close in `StreamTaskStateInitializerImpl.streamOperatorStateContext()`

[ https://issues.apache.org/jira/browse/FLINK-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reopened FLINK-9022: --- Assignee: Stefan Richter (was: Sihua Zhou) Reopened because the dispose of backends should

[jira] [Commented] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442673#comment-16442673 ] Stefan Richter commented on FLINK-8836: --- That is a very good question, potentially not at all

[jira] [Updated] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8836: -- Priority: Critical (was: Major) > Duplicating a KryoSerializer does not duplicate registered

[jira] [Commented] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442589#comment-16442589 ] Stefan Richter commented on FLINK-8836: --- Hi, I have seen a report on the mailing list that could

[jira] [Comment Edited] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442589#comment-16442589 ] Stefan Richter edited comment on FLINK-8836 at 4/18/18 2:29 PM: Hi, I have

[jira] [Closed] (FLINK-9011) YarnResourceManager spamming log file at INFO level

[ https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9011. - Resolution: Fixed Merge in d5ec911f55. > YarnResourceManager spamming log file at INFO level >

[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=16440934#comment-16440934 ] Stefan Richter commented on FLINK-9192: --- +1, I think that the test could build upon the universal

[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] [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] [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=16401933#comment-16401933 ] Stefan Richter commented on FLINK-8922: --- Hmm, I wonder why that should be a fix? Does that mean that

[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

[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

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

[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

[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

[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

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

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

[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

[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

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

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

[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

[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: -- Summary: Add a test operator with keyed state that uses Kryo serializer

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

[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

[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

[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

[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=16395360#comment-16395360 ] Stefan Richter commented on FLINK-8913: --- This is a known issue, Alpine Linux uses MUSL instead of

[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

[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=16395297#comment-16395297 ] Stefan Richter commented on FLINK-8042: --- [~till.rohrmann] and me came to the conclusion that this

[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=16395205#comment-16395205 ] Stefan Richter commented on FLINK-8922: --- Yes, I tried out to create a dedicated \{{WriteOptions}}

[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=16395054#comment-16395054 ] Stefan Richter commented on FLINK-8922: --- Ok that sounds good. I also had a look and it looks strange

[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] [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] [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=16395037#comment-16395037 ] Stefan Richter commented on FLINK-8922: --- FYI [~sihuazhou] > Revert FLINK-8859 because it causes

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

[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

[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

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