[jira] [Commented] (FLINK-4977) Enum serialization does not work in all cases

[ https://issues.apache.org/jira/browse/FLINK-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15626443#comment-15626443 ] Stephan Ewen commented on FLINK-4977: - Nice, thanks for diagnosing this. Would be gre

[jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15629341#comment-15629341 ] Stephan Ewen commented on FLINK-4022: - Thinking about this, I am actually not sure tha

[jira] [Updated] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh

[ https://issues.apache.org/jira/browse/FLINK-5001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5001: Priority: Blocker (was: Critical) > Ensure that the Kafka 0.9+ connector is compatible with > kafk

[jira] [Commented] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers

[ https://issues.apache.org/jira/browse/FLINK-4999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15630624#comment-15630624 ] Stephan Ewen commented on FLINK-4999: - I am skeptical about locks acquired by metrics

[jira] [Commented] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService

[ https://issues.apache.org/jira/browse/FLINK-4992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15630631#comment-15630631 ] Stephan Ewen commented on FLINK-4992: - Would having different timer services solve thi

[jira] [Commented] (FLINK-4990) Remove JAR option from savepoint disposal

[ https://issues.apache.org/jira/browse/FLINK-4990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15630637#comment-15630637 ] Stephan Ewen commented on FLINK-4990: - +1 > Remove JAR option from savepoint disposal

[jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15630704#comment-15630704 ] Stephan Ewen commented on FLINK-4022: - Ah, okay, this is relevant when there are initi

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15632615#comment-15632615 ] Stephan Ewen commented on FLINK-4576: - +1 for the "watermark idle" messages approach.

[jira] [Commented] (FLINK-4545) Flink automatically manages TM network buffer

[ https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15632652#comment-15632652 ] Stephan Ewen commented on FLINK-4545: - For a YARN-job-at-a-time setup, one could pre-c

[jira] [Resolved] (FLINK-4977) Enum serialization does not work in all cases

[ https://issues.apache.org/jira/browse/FLINK-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4977. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 1.1.4 1.

[jira] [Closed] (FLINK-4977) Enum serialization does not work in all cases

[ https://issues.apache.org/jira/browse/FLINK-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4977. --- > Enum serialization does not work in all cases > - > >

[jira] [Commented] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction

[ https://issues.apache.org/jira/browse/FLINK-5012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15637246#comment-15637246 ] Stephan Ewen commented on FLINK-5012: - I just wanted the simple way of outputting an e

[jira] [Commented] (FLINK-5023) Add get() method in State interface

[ https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644451#comment-15644451 ] Stephan Ewen commented on FLINK-5023: - I agree with [~xiaogang.shi] - do we really nee

[jira] [Updated] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing

[ https://issues.apache.org/jira/browse/FLINK-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5011: Priority: Blocker (was: Major) > TraversableSerializer does not perform a deep copy of the elements

[jira] [Commented] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions

[ https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644503#comment-15644503 ] Stephan Ewen commented on FLINK-5013: - +1 > Flink Kinesis connector doesn't work on o

[jira] [Updated] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions

[ https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5013: Priority: Critical (was: Major) > Flink Kinesis connector doesn't work on old EMR versions > --

[jira] [Updated] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing

[ https://issues.apache.org/jira/browse/FLINK-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5011: Fix Version/s: 1.2.0 > TraversableSerializer does not perform a deep copy of the elements it is > t

[jira] [Commented] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

[ https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644500#comment-15644500 ] Stephan Ewen commented on FLINK-5002: - I am skeptical about that - these methods are u

[jira] [Created] (FLINK-5028) Stream Tasks must not go through clean shutdown logic on cancellation

Stephan Ewen created FLINK-5028: --- Summary: Stream Tasks must not go through clean shutdown logic on cancellation Key: FLINK-5028 URL: https://issues.apache.org/jira/browse/FLINK-5028 Project: Flink

[jira] [Commented] (FLINK-5016) EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs

[ https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15645088#comment-15645088 ] Stephan Ewen commented on FLINK-5016: - The issue reported here has most likely a diffe

[jira] [Closed] (FLINK-5028) Stream Tasks must not go through clean shutdown logic on cancellation

[ https://issues.apache.org/jira/browse/FLINK-5028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5028. --- > Stream Tasks must not go through clean shutdown logic on cancellation >

[jira] [Resolved] (FLINK-5028) Stream Tasks must not go through clean shutdown logic on cancellation

[ https://issues.apache.org/jira/browse/FLINK-5028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5028. - Resolution: Fixed Fixed in - 1.2.0 via 1a578657d078dfb2d26a6f6e60876271d6f4c2ff - 1.1.4 via 4d

[jira] [Commented] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts

[ https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15647558#comment-15647558 ] Stephan Ewen commented on FLINK-5024: - Can we call it differently than {{SimpleStateDe

[jira] [Resolved] (FLINK-5014) RocksDBStateBackend misses good toString

[ https://issues.apache.org/jira/browse/FLINK-5014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5014. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via d450beece2f5f76d7f519101316f850e6fa4924a

[jira] [Closed] (FLINK-5014) RocksDBStateBackend misses good toString

[ https://issues.apache.org/jira/browse/FLINK-5014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5014. --- > RocksDBStateBackend misses good toString > > >

[jira] [Resolved] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down

[ https://issues.apache.org/jira/browse/FLINK-5022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5022. - Resolution: Fixed Fixed via d3908241323f5de3d454c7daf560faed49b3c779 > Suppress RejectedExecution

[jira] [Closed] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down

[ https://issues.apache.org/jira/browse/FLINK-5022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5022. --- > Suppress RejectedExecutionException when the Executor is shut down > ---

[jira] [Commented] (FLINK-3389) Add Pre-defined Options settings for RocksDB State backend

[ https://issues.apache.org/jira/browse/FLINK-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15648038#comment-15648038 ] Stephan Ewen commented on FLINK-3389: - It is implemented. Is it documented? > Add Pre

[jira] [Commented] (FLINK-3389) Add Pre-defined Options settings for RocksDB State backend

[ https://issues.apache.org/jira/browse/FLINK-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15648195#comment-15648195 ] Stephan Ewen commented on FLINK-3389: - I think it is very important to point out in th

[jira] [Resolved] (FLINK-4984) Add Cancellation Barriers to BarrierTracker and BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-4984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4984. - Resolution: Fixed Fixed in - 1.2.0 via 0a79dd5fb165c714bdac8de770b45d9406177401 - 1.1.4 via a1

[jira] [Closed] (FLINK-4984) Add Cancellation Barriers to BarrierTracker and BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-4984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4984. --- > Add Cancellation Barriers to BarrierTracker and BarrierBuffer >

[jira] [Resolved] (FLINK-4976) Add a way to abort in flight checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4976. - Resolution: Implemented Done via resolution of the subtasks > Add a way to abort in flight checkp

[jira] [Closed] (FLINK-4976) Add a way to abort in flight checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4976. --- > Add a way to abort in flight checkpoints > > >

[jira] [Resolved] (FLINK-4985) Report Declined/Canceled Checkpoints to Checkpoint Coordinator

[ https://issues.apache.org/jira/browse/FLINK-4985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4985. - Resolution: Fixed Fixed in - 1.2.0 via 48a48139172e86f548f3b2f1564bdc948c3fe76a - 1.1.4 via 1a

[jira] [Closed] (FLINK-4985) Report Declined/Canceled Checkpoints to Checkpoint Coordinator

[ https://issues.apache.org/jira/browse/FLINK-4985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4985. --- > Report Declined/Canceled Checkpoints to Checkpoint Coordinator > ---

[jira] [Resolved] (FLINK-4975) Add a limit for how much data may be buffered during checkpoint alignment

[ https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4975. - Resolution: Fixed Implemented in - 1.2.0 via 07ab9f45341f8c49354d9357d9459ee2199b4e1d - 1.1.4

[jira] [Closed] (FLINK-4975) Add a limit for how much data may be buffered during checkpoint alignment

[ https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4975. --- > Add a limit for how much data may be buffered during checkpoint alignment >

[jira] [Commented] (FLINK-5036) Perform the grouping of keys in restoring instead of checkpointing

[ https://issues.apache.org/jira/browse/FLINK-5036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15650354#comment-15650354 ] Stephan Ewen commented on FLINK-5036: - Actually, the checkpointing operation is very c

[jira] [Created] (FLINK-5038) Errors in the "cancelTask" method prevent closeables from being closed early

Stephan Ewen created FLINK-5038: --- Summary: Errors in the "cancelTask" method prevent closeables from being closed early Key: FLINK-5038 URL: https://issues.apache.org/jira/browse/FLINK-5038 Project: Fli

[jira] [Closed] (FLINK-5748) Make the ExecutionGraph's FutureExecutor a ScheduledExecutionService

[ https://issues.apache.org/jira/browse/FLINK-5748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5748. --- > Make the ExecutionGraph's FutureExecutor a ScheduledExecutionService > -

[jira] [Resolved] (FLINK-5748) Make the ExecutionGraph's FutureExecutor a ScheduledExecutionService

[ https://issues.apache.org/jira/browse/FLINK-5748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5748. - Resolution: Fixed Fixed via 665c7e399928188b22a7963cc05654589d47941c > Make the ExecutionGraph's

[jira] [Resolved] (FLINK-4912) Introduce RECONCILING state in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4912. - Resolution: Implemented Fix Version/s: 1.3.0 Implemented in cc27f0803f4ed1d9799594c75ac00d0

[jira] [Closed] (FLINK-4912) Introduce RECONCILING state in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4912. --- > Introduce RECONCILING state in ExecutionGraph > - > >

[jira] [Resolved] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API

[ https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5132. - Resolution: Implemented Fix Version/s: 1.3.0 Implemented in fd872a14974cad14c63478e44edb4e5

[jira] [Closed] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API

[ https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5132. --- > Introduce the ResourceSpec for grouping different resource factors in API >

[jira] [Created] (FLINK-5766) Unify NoAvailableResourceException handling on ExecutionGraph

Stephan Ewen created FLINK-5766: --- Summary: Unify NoAvailableResourceException handling on ExecutionGraph Key: FLINK-5766 URL: https://issues.apache.org/jira/browse/FLINK-5766 Project: Flink Is

[jira] [Closed] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

[ https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5759. --- > Set an UncaughtExceptionHandler for all Thread Pools in JobManager > ---

[jira] [Resolved] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5718. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed via dfc6fba5b9830e6a7804a6a0c9f69b36bf772730

[jira] [Resolved] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

[ https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5759. - Resolution: Fixed Fixed in ef77c254dadbe4c04810681fe765f5ec7d2a7400 > Set an UncaughtExceptionHan

[jira] [Closed] (FLINK-5766) Unify NoAvailableResourceException handling on ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5766. --- > Unify NoAvailableResourceException handling on ExecutionGraph >

[jira] [Closed] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5718. --- > Handle JVM Fatal Exceptions in Tasks > > > Key: FLI

[jira] [Resolved] (FLINK-5766) Unify NoAvailableResourceException handling on ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5766. - Resolution: Fixed Fixed in 3bde6ffb6f55ec7ff807633ab1e79d9238e5a942 > Unify NoAvailableResourceEx

[jira] [Assigned] (FLINK-5758) Port-range for the web interface via YARN

[ https://issues.apache.org/jira/browse/FLINK-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-5758: --- Assignee: Yelei Feng > Port-range for the web interface via YARN > --

[jira] [Commented] (FLINK-5758) Port-range for the web interface via YARN

[ https://issues.apache.org/jira/browse/FLINK-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863652#comment-15863652 ] Stephan Ewen commented on FLINK-5758: - It would be nice to not introduce another param

[jira] [Resolved] (FLINK-5729) add hostname option in SocketWindowWordCount example to be more convenient

[ https://issues.apache.org/jira/browse/FLINK-5729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5729. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed via 30c5b771a7943e981dd5f67131c932fdb204fbc2

[jira] [Resolved] (FLINK-5631) [yarn] Support downloading additional jars from non-HDFS paths

[ https://issues.apache.org/jira/browse/FLINK-5631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5631. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 186b12309b540f82a055be28f3f005dce4b8cf46 T

[jira] [Closed] (FLINK-5729) add hostname option in SocketWindowWordCount example to be more convenient

[ https://issues.apache.org/jira/browse/FLINK-5729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5729. --- > add hostname option in SocketWindowWordCount example to be more convenient > ---

[jira] [Closed] (FLINK-5631) [yarn] Support downloading additional jars from non-HDFS paths

[ https://issues.apache.org/jira/browse/FLINK-5631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5631. --- > [yarn] Support downloading additional jars from non-HDFS paths > ---

[jira] [Created] (FLINK-5788) Document assumptions about File Systems and persistence

Stephan Ewen created FLINK-5788: --- Summary: Document assumptions about File Systems and persistence Key: FLINK-5788 URL: https://issues.apache.org/jira/browse/FLINK-5788 Project: Flink Issue Typ

[jira] [Created] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSysten

Stephan Ewen created FLINK-5789: --- Summary: Make Bucketing Sink independent of Hadoop's FileSysten Key: FLINK-5789 URL: https://issues.apache.org/jira/browse/FLINK-5789 Project: Flink Issue Type

[jira] [Resolved] (FLINK-5788) Document assumptions about File Systems and persistence

[ https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5788. - Resolution: Fixed Fixed via f7af3b01681592787db16a555b55d6b11d35f869 > Document assumptions about

[jira] [Closed] (FLINK-5788) Document assumptions about File Systems and persistence

[ https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5788. --- > Document assumptions about File Systems and persistence > --

[jira] [Resolved] (FLINK-5553) Job fails during deployment with IllegalStateException from subpartition request

[ https://issues.apache.org/jira/browse/FLINK-5553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5553. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed via af81bebd0fabc6390930689df131e72edab6995b

[jira] [Closed] (FLINK-5553) Job fails during deployment with IllegalStateException from subpartition request

[ https://issues.apache.org/jira/browse/FLINK-5553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5553. --- > Job fails during deployment with IllegalStateException from subpartition > request > --

[jira] [Resolved] (FLINK-5762) Protect initializeState() and open() by the same lock.

[ https://issues.apache.org/jira/browse/FLINK-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5762. - Resolution: Fixed Fixed via a91b6ff05d8af870ad076f9bf0fc17886787bc46 > Protect initializeState()

[jira] [Closed] (FLINK-5762) Protect initializeState() and open() by the same lock.

[ https://issues.apache.org/jira/browse/FLINK-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5762. --- > Protect initializeState() and open() by the same lock. > ---

[jira] [Commented] (FLINK-5778) Split FileStateHandle into fileName and basePath

[ https://issues.apache.org/jira/browse/FLINK-5778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866466#comment-15866466 ] Stephan Ewen commented on FLINK-5778: - I am not sure about this design. State handle i

[jira] [Closed] (FLINK-5239) Properly unpack thrown exceptions in RPC methods

[ https://issues.apache.org/jira/browse/FLINK-5239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5239. --- Resolution: Fixed Fix Version/s: 1.3.0 Old issue, fixed a while back already. > Properly unpac

[jira] [Commented] (FLINK-5253) Remove special treatment of "dynamic properties"

[ https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866672#comment-15866672 ] Stephan Ewen commented on FLINK-5253: - When the {{flink-conf.yaml}} is anyways generat

[jira] [Commented] (FLINK-5253) Remove special treatment of "dynamic properties"

[ https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866673#comment-15866673 ] Stephan Ewen commented on FLINK-5253: - That means we can drop it for all modes that do

[jira] [Commented] (FLINK-4813) Having flink-test-utils as a dependency outside Flink fails the build

[ https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866678#comment-15866678 ] Stephan Ewen commented on FLINK-4813: - [~NicoK] Do you want to go ahead and patch this

[jira] [Created] (FLINK-5800) Make sure that the CheckpointStreamFactory is instantiated once per operator only

Stephan Ewen created FLINK-5800: --- Summary: Make sure that the CheckpointStreamFactory is instantiated once per operator only Key: FLINK-5800 URL: https://issues.apache.org/jira/browse/FLINK-5800 Project

[jira] [Created] (FLINK-5812) Clean up FileSystem

Stephan Ewen created FLINK-5812: --- Summary: Clean up FileSystem Key: FLINK-5812 URL: https://issues.apache.org/jira/browse/FLINK-5812 Project: Flink Issue Type: Improvement Components:

[jira] [Resolved] (FLINK-5793) Running slot may not be add to AllocatedMap in SlotPool

[ https://issues.apache.org/jira/browse/FLINK-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5793. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 33ea78ea37fab819a329b09aa213e61c16252067 T

[jira] [Closed] (FLINK-5805) improve docs for ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-5805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5805. --- > improve docs for ProcessFunction > > > Key: FLINK-5805

[jira] [Resolved] (FLINK-5805) improve docs for ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-5805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5805. - Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in - 1.2.1 via 2e4a

[jira] [Resolved] (FLINK-5800) Make sure that the CheckpointStreamFactory is instantiated once per operator only

[ https://issues.apache.org/jira/browse/FLINK-5800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5800. - Resolution: Fixed Fixed in - 1.2.1 via d3435b05f9ca94b4b9bd32df22b49f3829287075 - 1.3.0 via 04

[jira] [Closed] (FLINK-5800) Make sure that the CheckpointStreamFactory is instantiated once per operator only

[ https://issues.apache.org/jira/browse/FLINK-5800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5800. --- > Make sure that the CheckpointStreamFactory is instantiated once per operator > only > -

[jira] [Commented] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts.

[ https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869687#comment-15869687 ] Stephan Ewen commented on FLINK-5817: - I would encourage you to use the JUnit tool to

[jira] [Created] (FLINK-5820) Extend State Backend Abstraction to support Global Cleanup Hooks

Stephan Ewen created FLINK-5820: --- Summary: Extend State Backend Abstraction to support Global Cleanup Hooks Key: FLINK-5820 URL: https://issues.apache.org/jira/browse/FLINK-5820 Project: Flink

[jira] [Created] (FLINK-5821) Create StateBackend root interface

Stephan Ewen created FLINK-5821: --- Summary: Create StateBackend root interface Key: FLINK-5821 URL: https://issues.apache.org/jira/browse/FLINK-5821 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5822) Make Checkpoint Coordinator aware of State Backend

Stephan Ewen created FLINK-5822: --- Summary: Make Checkpoint Coordinator aware of State Backend Key: FLINK-5822 URL: https://issues.apache.org/jira/browse/FLINK-5822 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

Stephan Ewen created FLINK-5823: --- Summary: Store Checkpoint Root Metadata in StateBackend (not in HA custom store) Key: FLINK-5823 URL: https://issues.apache.org/jira/browse/FLINK-5823 Project: Flink

[jira] [Updated] (FLINK-5824) Fix String/byte conversions without explicit encoding

[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5824: Priority: Blocker (was: Major) > Fix String/byte conversions without explicit encoding > --

[jira] [Commented] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts.

[ https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869939#comment-15869939 ] Stephan Ewen commented on FLINK-5817: - There is also a pull request that tries to chan

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869989#comment-15869989 ] Stephan Ewen commented on FLINK-5824: - We should add a checkstyle rule that forbids {{

[jira] [Resolved] (FLINK-5705) webmonitor's request/response use UTF-8 explicitly

[ https://issues.apache.org/jira/browse/FLINK-5705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5705. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in - 1.2.1 via d3f2fe2625171f89404e1b90fa8c9

[jira] [Closed] (FLINK-5705) webmonitor's request/response use UTF-8 explicitly

[ https://issues.apache.org/jira/browse/FLINK-5705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5705. --- > webmonitor's request/response use UTF-8 explicitly > --

[jira] [Closed] (FLINK-5814) flink-dist creates wrong symlink when not used with cleaned before

[ https://issues.apache.org/jira/browse/FLINK-5814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5814. --- > flink-dist creates wrong symlink when not used with cleaned before > ---

[jira] [Resolved] (FLINK-5814) flink-dist creates wrong symlink when not used with cleaned before

[ https://issues.apache.org/jira/browse/FLINK-5814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5814. - Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in - 1.2.1 via 6114

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15870236#comment-15870236 ] Stephan Ewen commented on FLINK-1725: - I would like to make this user-driven. While it

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871722#comment-15871722 ] Stephan Ewen commented on FLINK-5824: - I think some names in checkpoints are serialize

[jira] [Resolved] (FLINK-5747) Eager Scheduling should deploy all Tasks together

[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5747. - Resolution: Fixed Fixed via f113d79451ba88c487358861cc3e20aac3d19257 > Eager Scheduling should de

[jira] [Closed] (FLINK-5812) Clean up FileSystem

[ https://issues.apache.org/jira/browse/FLINK-5812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5812. --- > Clean up FileSystem > --- > > Key: FLINK-5812 > URL: htt

[jira] [Resolved] (FLINK-5812) Clean up FileSystem

[ https://issues.apache.org/jira/browse/FLINK-5812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5812. - Resolution: Fixed Fixed via 5902ea0e88c70f330c23b9ace94033ae34c84445 > Clean up FileSystem >

[jira] [Resolved] (FLINK-5497) remove duplicated tests

[ https://issues.apache.org/jira/browse/FLINK-5497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5497. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed via 53134594644407d0a3cd691b0e93ae09ff6c8102

[jira] [Resolved] (FLINK-5522) Storm LocalCluster can't run with powermock

[ https://issues.apache.org/jira/browse/FLINK-5522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5522. - Resolution: Fixed Fixed via d05fc377ee688b231fb1b0daeb8a34fd054f3ca1 > Storm LocalCluster can't r

[jira] [Closed] (FLINK-5522) Storm LocalCluster can't run with powermock

[ https://issues.apache.org/jira/browse/FLINK-5522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5522. --- > Storm LocalCluster can't run with powermock > --- > >

[jira] [Closed] (FLINK-5497) remove duplicated tests

[ https://issues.apache.org/jira/browse/FLINK-5497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5497. --- > remove duplicated tests > --- > > Key: FLINK-5497 >

[jira] [Closed] (FLINK-5129) make the BlobServer use a distributed file system

[ https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5129. --- > make the BlobServer use a distributed file system > - >

<    6   7   8   9   10   11   12   13   14   15   >