[jira] [Closed] (FLINK-6009) Deprecate DataSetUtils#checksumHashCode

[ https://issues.apache.org/jira/browse/FLINK-6009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6009. --- > Deprecate DataSetUtils#checksumHashCode > --- > > Ke

[jira] [Resolved] (FLINK-5134) Aggregate ResourceSpec for chained operators when generating job graph

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

[jira] [Closed] (FLINK-5134) Aggregate ResourceSpec for chained operators when generating job graph

[ https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5134. --- > Aggregate ResourceSpec for chained operators when generating job graph > ---

[jira] [Closed] (FLINK-5981) SSL version and ciper suites cannot be constrained as configured

[ https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5981. --- > SSL version and ciper suites cannot be constrained as configured > -

[jira] [Resolved] (FLINK-5981) SSL version and ciper suites cannot be constrained as configured

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

[jira] [Commented] (FLINK-5668) passing taskmanager configuration through taskManagerEnv instead of file

[ https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929916#comment-15929916 ] Stephan Ewen commented on FLINK-5668: - There are other config files and config objects

[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=15930088#comment-15930088 ] Stephan Ewen commented on FLINK-4545: - There are a few reasons why I think the GlobalB

[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=15932481#comment-15932481 ] Stephan Ewen commented on FLINK-4545: - [~zjwang] The logic outlined above is tailored

[jira] [Commented] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934866#comment-15934866 ] Stephan Ewen commented on FLINK-6103: - +1 to go with {{Files.move(source, target, REPL

[jira] [Closed] (FLINK-6000) Can not start HA cluster with start-cluster.sh

[ https://issues.apache.org/jira/browse/FLINK-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6000. --- > Can not start HA cluster with start-cluster.sh > -- > >

[jira] [Resolved] (FLINK-6000) Can not start HA cluster with start-cluster.sh

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

[jira] [Closed] (FLINK-6056) apache-rat exclude flink directory in tools

[ https://issues.apache.org/jira/browse/FLINK-6056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6056. --- > apache-rat exclude flink directory in tools > --- > >

[jira] [Resolved] (FLINK-6056) apache-rat exclude flink directory in tools

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

[jira] [Resolved] (FLINK-6144) Port job manager related configuration options to ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6144. - Resolution: Fixed Fixed in 1.3.0 via e2ca12957435e9ac3d811ebec611c4465525dea9 > Port job manager

[jira] [Closed] (FLINK-6144) Port job manager related configuration options to ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6144. --- > Port job manager related configuration options to ConfigOption > ---

[jira] [Commented] (FLINK-6168) Make flink-core independent of Avro

[ https://issues.apache.org/jira/browse/FLINK-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936638#comment-15936638 ] Stephan Ewen commented on FLINK-6168: - +1 We can actually do that even before Flink 2

[jira] [Commented] (FLINK-6159) Add Java/Scala FlinkLauncher

[ https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936644#comment-15936644 ] Stephan Ewen commented on FLINK-6159: - As Robert mentioned, the original plan was to h

[jira] [Commented] (FLINK-6151) The zookeeper occur a warning when one node of zookeeper server is down

[ https://issues.apache.org/jira/browse/FLINK-6151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936682#comment-15936682 ] Stephan Ewen commented on FLINK-6151: - Isn't that ZooKeeper's default behavior? What

[jira] [Commented] (FLINK-6167) Consider removing ArchivedExecutionGraph classes

[ https://issues.apache.org/jira/browse/FLINK-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936800#comment-15936800 ] Stephan Ewen commented on FLINK-6167: - If the classes are not used any more I would sa

[jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940044#comment-15940044 ] Stephan Ewen commented on FLINK-3947: - The use case was effectively {{MapState}}, so I

[jira] [Commented] (FLINK-6159) Add Java/Scala FlinkLauncher

[ https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940068#comment-15940068 ] Stephan Ewen commented on FLINK-6159: - The Yarn Environment, Mesos Envitonment do not

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

[ https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15943028#comment-15943028 ] Stephan Ewen commented on FLINK-5982: - [~till.rohrmann] Why not throw an illegal state

[jira] [Commented] (FLINK-6141) Add buffering service for stream operators

[ https://issues.apache.org/jira/browse/FLINK-6141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15943182#comment-15943182 ] Stephan Ewen commented on FLINK-6141: - I don't think I have capacity to help out here

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15943212#comment-15943212 ] Stephan Ewen commented on FLINK-4319: - Flink on Kubernetes works today already. We nee

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

[ https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15943286#comment-15943286 ] Stephan Ewen commented on FLINK-5982: - I think that is actually simpler to shoot yours

[jira] [Commented] (FLINK-6203) DataSet Transformations

[ https://issues.apache.org/jira/browse/FLINK-6203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947750#comment-15947750 ] Stephan Ewen commented on FLINK-6203: - I think there is simply one line missing in the

[jira] [Commented] (FLINK-6199) Single outstanding Async I/O operation per key

[ https://issues.apache.org/jira/browse/FLINK-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947753#comment-15947753 ] Stephan Ewen commented on FLINK-6199: - Sounds like a useful extension. > Single outst

[jira] [Commented] (FLINK-4831) Implement a log4j metric reporter

[ https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947756#comment-15947756 ] Stephan Ewen commented on FLINK-4831: - This makes for a good starter issue - adjusted

[jira] [Updated] (FLINK-4831) Implement a log4j metric reporter

[ https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4831: Labels: easyfix starter (was: ) > Implement a log4j metric reporter > -

[jira] [Updated] (FLINK-6013) Add Datadog HTTP metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-6013: Fix Version/s: 1.3.0 > Add Datadog HTTP metrics reporter > - > >

[jira] [Resolved] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2730. - Resolution: Fixed Fix Version/s: 1.2.0 Has been fixed via a different issue in the meantime

[jira] [Commented] (FLINK-4532) Allow independent metrics reporter for tasks

[ https://issues.apache.org/jira/browse/FLINK-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947767#comment-15947767 ] Stephan Ewen commented on FLINK-4532: - Sorry for the late reply. (2) is implemented f

[jira] [Resolved] (FLINK-5340) Add a metric exposing jobs uptimes

[ https://issues.apache.org/jira/browse/FLINK-5340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5340. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 1.3.0 Added new metrics "u

[jira] [Reopened] (FLINK-5340) Add a metric exposing jobs uptimes

[ https://issues.apache.org/jira/browse/FLINK-5340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-5340: - Apologies, docs need to be added still... > Add a metric exposing jobs uptimes >

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5038. --- > Errors in the "cancelTask" method prevent closeables from being closed early > -

[jira] [Created] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

Stephan Ewen created FLINK-5048: --- Summary: Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior Key: FLINK-5048 URL: https://issues.apache.org/jira/browse/FLINK-5048 Project

[jira] [Commented] (FLINK-5050) JSON.org license is CatX

[ https://issues.apache.org/jira/browse/FLINK-5050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15656895#comment-15656895 ] Stephan Ewen commented on FLINK-5050: - Do we need the {{hive-exec}} dependency, or can

[jira] [Commented] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure

[ https://issues.apache.org/jira/browse/FLINK-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15656919#comment-15656919 ] Stephan Ewen commented on FLINK-5049: - Does the test have any specific guard against t

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

[ https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5002: Labels: easyfix starter (was: ) > Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15670219#comment-15670219 ] Stephan Ewen commented on FLINK-2646: - One thing we can do is mirror the way it is don

[jira] [Comment Edited] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15670219#comment-15670219 ] Stephan Ewen edited comment on FLINK-2646 at 11/16/16 11:34 AM:

[jira] [Updated] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5048: Priority: Blocker (was: Major) > Kafka Consumer (0.9/0.10) threading model leads problematic cancel

[jira] [Updated] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5048: Fix Version/s: 1.1.4 > Kafka Consumer (0.9/0.10) threading model leads problematic cancellation > b

[jira] [Commented] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15671432#comment-15671432 ] Stephan Ewen commented on FLINK-5048: - Fixed in 1.2.0 via a66e7ad14e41fa07737f447d6892

[jira] [Closed] (FLINK-5057) Cancellation timeouts are picked from wrong config

[ https://issues.apache.org/jira/browse/FLINK-5057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5057. --- > Cancellation timeouts are picked from wrong config > --

[jira] [Resolved] (FLINK-5057) Cancellation timeouts are picked from wrong config

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

[jira] [Resolved] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints

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

[jira] [Closed] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints

[ https://issues.apache.org/jira/browse/FLINK-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5063. --- > State handles are not properly cleaned up for declined or expired checkpoints >

[jira] [Commented] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE

[ https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674111#comment-15674111 ] Stephan Ewen commented on FLINK-4587: - [~RenkaiGe] Is this issue still valid, or has i

[jira] [Created] (FLINK-5090) Expose optionally detailed metrics about network queue lengths

Stephan Ewen created FLINK-5090: --- Summary: Expose optionally detailed metrics about network queue lengths Key: FLINK-5090 URL: https://issues.apache.org/jira/browse/FLINK-5090 Project: Flink I

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676678#comment-15676678 ] Stephan Ewen commented on FLINK-2821: - +1 for getting rid of {{jobmanager.rpc.bind-add

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676689#comment-15676689 ] Stephan Ewen commented on FLINK-2821: - Concerning HA setups: Publishing the JobManager

[jira] [Commented] (FLINK-5090) Expose optionally detailed metrics about network queue lengths

[ https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676692#comment-15676692 ] Stephan Ewen commented on FLINK-5090: - I have added min/max/avg across the channels fo

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676696#comment-15676696 ] Stephan Ewen commented on FLINK-3617: - How pressing is that? Is it a serious problem 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=15677332#comment-15677332 ] Stephan Ewen commented on FLINK-5002: - The link is referring to opening a pull request

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683181#comment-15683181 ] Stephan Ewen commented on FLINK-2646: - Strictly speaking, this is API breaking, becaus

[jira] [Commented] (FLINK-5108) Remove ClientShutdownHook during job execution

[ https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683763#comment-15683763 ] Stephan Ewen commented on FLINK-5108: - +1 > Remove ClientShutdownHook during job exec

[jira] [Updated] (FLINK-5108) Remove ClientShutdownHook during job execution

[ https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5108: Priority: Blocker (was: Major) > Remove ClientShutdownHook during job execution > -

[jira] [Updated] (FLINK-5108) Remove ClientShutdownHook during job execution

[ https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5108: Fix Version/s: 1.2.0 > Remove ClientShutdownHook during job execution >

[jira] [Created] (FLINK-5123) Add description how to do proper shading to Flink docs.

Stephan Ewen created FLINK-5123: --- Summary: Add description how to do proper shading to Flink docs. Key: FLINK-5123 URL: https://issues.apache.org/jira/browse/FLINK-5123 Project: Flink Issue Typ

[jira] [Closed] (FLINK-5123) Add description how to do proper shading to Flink docs.

[ https://issues.apache.org/jira/browse/FLINK-5123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5123. --- > Add description how to do proper shading to Flink docs. > --

[jira] [Resolved] (FLINK-5123) Add description how to do proper shading to Flink docs.

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

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689779#comment-15689779 ] Stephan Ewen commented on FLINK-2646: - [~kkl0u] Please go ahead! > Rich functions sho

[jira] [Assigned] (FLINK-5142) Resource leak in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-5142: --- Assignee: Stephan Ewen > Resource leak in CheckpointCoordinator > ---

[jira] [Commented] (FLINK-5142) Resource leak in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689792#comment-15689792 ] Stephan Ewen commented on FLINK-5142: - Thanks for reporting and diagnosing that. I'll

[jira] [Commented] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set

[ https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689796#comment-15689796 ] Stephan Ewen commented on FLINK-5128: - Sounds like a good idea, +1 > Get Kafka partit

[jira] [Commented] (FLINK-5126) Remove Checked Exceptions from State Interfaces

[ https://issues.apache.org/jira/browse/FLINK-5126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689800#comment-15689800 ] Stephan Ewen commented on FLINK-5126: - Not sure about that. They were added there for

[jira] [Assigned] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels.

[ https://issues.apache.org/jira/browse/FLINK-4820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-4820: --- Assignee: Stephan Ewen > Slf4j / log4j version upgrade to support dynamic change of log level

[jira] [Commented] (FLINK-4100) RocksDBStateBackend#close() can throw NPE

[ https://issues.apache.org/jira/browse/FLINK-4100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15701525#comment-15701525 ] Stephan Ewen commented on FLINK-4100: - [~Zentol] [~srichter] Is this issue obsolete by

[jira] [Created] (FLINK-5172) In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided"

Stephan Ewen created FLINK-5172: --- Summary: In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided" Key: FLINK-5172 URL: https://issues.apache.org/jira/browse/FLINK-5172 Project: Fl

[jira] [Created] (FLINK-5173) Upgrade RocksDB dependency

Stephan Ewen created FLINK-5173: --- Summary: Upgrade RocksDB dependency Key: FLINK-5173 URL: https://issues.apache.org/jira/browse/FLINK-5173 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-5142) Resource leak in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5142: Fix Version/s: (was: 1.2.0) 1.1.4 > Resource leak in CheckpointCoordinator >

[jira] [Closed] (FLINK-5050) JSON.org license is CatX

[ https://issues.apache.org/jira/browse/FLINK-5050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5050. --- Thank you for the contribution! > JSON.org license is CatX > > >

[jira] [Resolved] (FLINK-5050) JSON.org license is CatX

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

[jira] [Resolved] (FLINK-5168) Scaladoc annotation link use [[]] instead of {@link}

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

[jira] [Closed] (FLINK-5168) Scaladoc annotation link use [[]] instead of {@link}

[ https://issues.apache.org/jira/browse/FLINK-5168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5168. --- > Scaladoc annotation link use [[]] instead of {@link} > -

[jira] [Resolved] (FLINK-5142) Resource leak in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5142. - Resolution: Fixed Fixed via e2c53cf85c1af73c040d96dbd24b9e2cf3e8cdf6 > Resource leak in Checkpoin

[jira] [Closed] (FLINK-5142) Resource leak in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5142. --- > Resource leak in CheckpointCoordinator > -- > > Key:

[jira] [Commented] (FLINK-4855) Add partitionedKeyBy to DataStream

[ https://issues.apache.org/jira/browse/FLINK-4855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15709090#comment-15709090 ] Stephan Ewen commented on FLINK-4855: - I think this is a good idea, I have heard this

[jira] [Resolved] (FLINK-2999) Support connected keyed streams

[ https://issues.apache.org/jira/browse/FLINK-2999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2999. - Resolution: Fixed Fix Version/s: 1.0.1 This has been implemented a while back already. > S

[jira] [Closed] (FLINK-2644) State partitioning does not respect the different partitioning of multiple inputs

[ https://issues.apache.org/jira/browse/FLINK-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2644. --- > State partitioning does not respect the different partitioning of multiple > inputs > -

[jira] [Resolved] (FLINK-2644) State partitioning does not respect the different partitioning of multiple inputs

[ https://issues.apache.org/jira/browse/FLINK-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2644. - Resolution: Fixed Fix Version/s: 1.0.1 Fixed a few versions back... > State partitioning d

[jira] [Comment Edited] (FLINK-5188) Redirect dependencies

[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15709313#comment-15709313 ] Stephan Ewen edited comment on FLINK-5188 at 11/30/16 6:14 PM: -

[jira] [Commented] (FLINK-5188) Redirect dependencies

[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15709313#comment-15709313 ] Stephan Ewen commented on FLINK-5188: - What does "redirect dependencies" mean? > Redi

[jira] [Created] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion

Stephan Ewen created FLINK-5216: --- Summary: CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion Key: FLINK-5216 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-5218) Eagerly close checkpoint streams on cancellation

Stephan Ewen created FLINK-5218: --- Summary: Eagerly close checkpoint streams on cancellation Key: FLINK-5218 URL: https://issues.apache.org/jira/browse/FLINK-5218 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5218) Eagerly close checkpoint streams on cancellation

[ https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711988#comment-15711988 ] Stephan Ewen commented on FLINK-5218: - True, will close one of the issues. > Eagerly

[jira] [Closed] (FLINK-5215) Close checkpoint streams upon cancellation

[ https://issues.apache.org/jira/browse/FLINK-5215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5215. --- Resolution: Duplicate Duplicated by FLINK-5218 Closed in favor of the newer issue (which is already r

[jira] [Commented] (FLINK-5217) Deprecated interface Checkpointed make clear suggestion

[ https://issues.apache.org/jira/browse/FLINK-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711997#comment-15711997 ] Stephan Ewen commented on FLINK-5217: - Agreed, this should add a comment to refer to t

[jira] [Resolved] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion

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

[jira] [Closed] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion

[ https://issues.apache.org/jira/browse/FLINK-5216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5216. --- > CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint > start rather then checkpoin

[jira] [Commented] (FLINK-5218) Eagerly close checkpoint streams on cancellation

[ https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712693#comment-15712693 ] Stephan Ewen commented on FLINK-5218: - Fixed in 1.1.4 via 59f61bf6cb8351cec9369e2de39c

[jira] [Resolved] (FLINK-5218) Eagerly close checkpoint streams on cancellation

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

[jira] [Closed] (FLINK-5218) Eagerly close checkpoint streams on cancellation

[ https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5218. --- > Eagerly close checkpoint streams on cancellation > > >

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715186#comment-15715186 ] Stephan Ewen commented on FLINK-4632: - Is this something that needs re-tries to enhanc

[jira] [Commented] (FLINK-5227) Add warning to include flink-table in job fat jars

[ https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715196#comment-15715196 ] Stephan Ewen commented on FLINK-5227: - When adding/shading Calcite, is it possible to

[jira] [Created] (FLINK-5230) Safety nets against leaving dysfunctional JobManagers

Stephan Ewen created FLINK-5230: --- Summary: Safety nets against leaving dysfunctional JobManagers Key: FLINK-5230 URL: https://issues.apache.org/jira/browse/FLINK-5230 Project: Flink Issue Type:

[jira] [Created] (FLINK-5231) JobManager should exit on "OutOfMemoryError"

Stephan Ewen created FLINK-5231: --- Summary: JobManager should exit on "OutOfMemoryError" Key: FLINK-5231 URL: https://issues.apache.org/jira/browse/FLINK-5231 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager

Stephan Ewen created FLINK-5232: --- Summary: Add a Thread default uncaught exception handler on the JobManager Key: FLINK-5232 URL: https://issues.apache.org/jira/browse/FLINK-5232 Project: Flink

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