[jira] [Commented] (FLINK-1918) NullPointerException at org.apache.flink.client.program.Client's constructor while using ExecutionEnvironment.createRemoteEnvironment

[ https://issues.apache.org/jira/browse/FLINK-1918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14505348#comment-14505348 ] Stephan Ewen commented on FLINK-1918: - Thank you for reporting this. From what I can

[jira] [Commented] (FLINK-1930) NullPointerException in vertex-centric iteration

[ https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14509097#comment-14509097 ] Stephan Ewen commented on FLINK-1930: - Should give better error messages now. Please

[jira] [Commented] (FLINK-1930) NullPointerException in vertex-centric iteration

[ https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14510649#comment-14510649 ] Stephan Ewen commented on FLINK-1930: - And this is the only exception that you see, it

[jira] [Commented] (FLINK-1930) NullPointerException in vertex-centric iteration

[ https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14510650#comment-14510650 ] Stephan Ewen commented on FLINK-1930: - Seems like a bug that the pools get released to

[jira] [Commented] (FLINK-1804) flink-quickstart-scala tests fail on scala-2.11 build profile on travis

[ https://issues.apache.org/jira/browse/FLINK-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14505645#comment-14505645 ] Stephan Ewen commented on FLINK-1804: - Do these consistently fail, or was that one

[jira] [Commented] (FLINK-1930) NullPointerException in vertex-centric iteration

[ https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507290#comment-14507290 ] Stephan Ewen commented on FLINK-1930: - I have a bit of code pending that may help to

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14505618#comment-14505618 ] Stephan Ewen commented on FLINK-1907: - Yes, the shell needs to start a mini cluster

[jira] [Commented] (FLINK-1878) Add mode to Environments to deactivate sysout printing

[ https://issues.apache.org/jira/browse/FLINK-1878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506978#comment-14506978 ] Stephan Ewen commented on FLINK-1878: - Complemented in

[jira] [Resolved] (FLINK-1918) NullPointerException at org.apache.flink.client.program.Client's constructor while using ExecutionEnvironment.createRemoteEnvironment

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

[jira] [Closed] (FLINK-1918) NullPointerException at org.apache.flink.client.program.Client's constructor while using ExecutionEnvironment.createRemoteEnvironment

[ https://issues.apache.org/jira/browse/FLINK-1918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1918. --- NullPointerException at org.apache.flink.client.program.Client's constructor while using

[jira] [Commented] (FLINK-1918) NullPointerException at org.apache.flink.client.program.Client's constructor while using ExecutionEnvironment.createRemoteEnvironment

[ https://issues.apache.org/jira/browse/FLINK-1918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506983#comment-14506983 ] Stephan Ewen commented on FLINK-1918: - [~Ehnalis] It should be fixed in the the latest

[jira] [Closed] (FLINK-1923) Replace asynchronous logging in JobManager with regular slf4j logging

[ https://issues.apache.org/jira/browse/FLINK-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1923. --- Replace asynchronous logging in JobManager with regular slf4j logging

[jira] [Resolved] (FLINK-1923) Replace asynchronous logging in JobManager with regular slf4j logging

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

[jira] [Closed] (FLINK-1922) Failed task deployment causes NPE on input split assignment

[ https://issues.apache.org/jira/browse/FLINK-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1922. --- Failed task deployment causes NPE on input split assignment

[jira] [Created] (FLINK-1953) Rework Checkpoint Coordinator

Stephan Ewen created FLINK-1953: --- Summary: Rework Checkpoint Coordinator Key: FLINK-1953 URL: https://issues.apache.org/jira/browse/FLINK-1953 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance

[ https://issues.apache.org/jira/browse/FLINK-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14516845#comment-14516845 ] Stephan Ewen commented on FLINK-1952: - That is helpful, thanks! Cannot run

[jira] [Commented] (FLINK-1953) Rework Checkpoint Coordinator

[ https://issues.apache.org/jira/browse/FLINK-1953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519058#comment-14519058 ] Stephan Ewen commented on FLINK-1953: - First part implemented in

[jira] [Closed] (FLINK-1925) Split SubmitTask method up into two phases: Receive TDD and instantiation of TDD

[ https://issues.apache.org/jira/browse/FLINK-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1925. --- Split SubmitTask method up into two phases: Receive TDD and instantiation of TDD

[jira] [Commented] (FLINK-1947) Make Avro and Tachyon test logging less verbose

[ https://issues.apache.org/jira/browse/FLINK-1947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513768#comment-14513768 ] Stephan Ewen commented on FLINK-1947: - You can avoid the sysout logging by using

[jira] [Commented] (FLINK-1950) Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants

[ https://issues.apache.org/jira/browse/FLINK-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514215#comment-14514215 ] Stephan Ewen commented on FLINK-1950: - 20% and 30% are both rather random magic

[jira] [Commented] (FLINK-1950) Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants

[ https://issues.apache.org/jira/browse/FLINK-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14516694#comment-14516694 ] Stephan Ewen commented on FLINK-1950: - Given that our non-heap overhead has a minimal

[jira] [Assigned] (FLINK-1968) Make Distributed Cache more robust

[ https://issues.apache.org/jira/browse/FLINK-1968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-1968: --- Assignee: Stephan Ewen Make Distributed Cache more robust

[jira] [Created] (FLINK-1972) Remove instanceID in streaming tasks

Stephan Ewen created FLINK-1972: --- Summary: Remove instanceID in streaming tasks Key: FLINK-1972 URL: https://issues.apache.org/jira/browse/FLINK-1972 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519542#comment-14519542 ] Stephan Ewen commented on FLINK-1959: - Can you try if this only happens with a

[jira] [Commented] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521736#comment-14521736 ] Stephan Ewen commented on FLINK-1690: - This one is interesting, it is not Test

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530313#comment-14530313 ] Stephan Ewen commented on FLINK-1962: - How about remove the generic type constraints

[jira] [Created] (FLINK-1973) JobManager log does not contain state change messages on INFO level

Stephan Ewen created FLINK-1973: --- Summary: JobManager log does not contain state change messages on INFO level Key: FLINK-1973 URL: https://issues.apache.org/jira/browse/FLINK-1973 Project: Flink

[jira] [Commented] (FLINK-1996) Add output methods to Table API

[ https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538457#comment-14538457 ] Stephan Ewen commented on FLINK-1996: - Does this make a good starter issue? Add

[jira] [Commented] (FLINK-1996) Add output methods to Table API

[ https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538456#comment-14538456 ] Stephan Ewen commented on FLINK-1996: - I think it may actually be worth adding those

[jira] [Resolved] (FLINK-1968) Make Distributed Cache more robust

[ https://issues.apache.org/jira/browse/FLINK-1968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1968. - Resolution: Fixed Fixed via 1c8d866a83065e3d1bc9707dab81117f24c9f678 Make Distributed Cache

[jira] [Closed] (FLINK-1968) Make Distributed Cache more robust

[ https://issues.apache.org/jira/browse/FLINK-1968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1968. --- Make Distributed Cache more robust -- Key: FLINK-1968

[jira] [Commented] (FLINK-1874) Break up streaming connectors into submodules

[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538556#comment-14538556 ] Stephan Ewen commented on FLINK-1874: - I think we are about to merge the biggest

[jira] [Resolved] (FLINK-1672) Refactor task registration/unregistration

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

[jira] [Resolved] (FLINK-1969) Remove old profile code

[ https://issues.apache.org/jira/browse/FLINK-1969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1969. - Resolution: Done Done in fbea2da26d01c470687a5ad217a5fd6ad1de89e4 Remove old profile code

[jira] [Commented] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538540#comment-14538540 ] Stephan Ewen commented on FLINK-1959: - I will try and look into this very soon...

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538571#comment-14538571 ] Stephan Ewen commented on FLINK-1962: - This seems like a flaw in the Scala Type

[jira] [Closed] (FLINK-1969) Remove old profile code

[ https://issues.apache.org/jira/browse/FLINK-1969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1969. --- Remove old profile code --- Key: FLINK-1969 URL:

[jira] [Closed] (FLINK-1672) Refactor task registration/unregistration

[ https://issues.apache.org/jira/browse/FLINK-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1672. --- Refactor task registration/unregistration -

[jira] [Commented] (FLINK-1986) Group by fails on iterative data streams

[ https://issues.apache.org/jira/browse/FLINK-1986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538328#comment-14538328 ] Stephan Ewen commented on FLINK-1986: - [~gyfora] and [~senorcarbone] Are you using

[jira] [Commented] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException

[ https://issues.apache.org/jira/browse/FLINK-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538348#comment-14538348 ] Stephan Ewen commented on FLINK-1989: - Storing the type information breaks with the

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14539532#comment-14539532 ] Stephan Ewen commented on FLINK-1962: - In Scala, you usually use the Scala tuples.

[jira] [Closed] (FLINK-1857) Flakey SimpleRecoveryITCase#testRestartMultipleTimes test

[ https://issues.apache.org/jira/browse/FLINK-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1857. --- Flakey SimpleRecoveryITCase#testRestartMultipleTimes test

[jira] [Resolved] (FLINK-1857) Flakey SimpleRecoveryITCase#testRestartMultipleTimes test

[ https://issues.apache.org/jira/browse/FLINK-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1857. - Resolution: Done Fix Version/s: 0.9 Flakey SimpleRecoveryITCase#testRestartMultipleTimes

[jira] [Commented] (FLINK-1857) Flakey SimpleRecoveryITCase#testRestartMultipleTimes test

[ https://issues.apache.org/jira/browse/FLINK-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541682#comment-14541682 ] Stephan Ewen commented on FLINK-1857: - I think this has been fixed by the combination

[jira] [Resolved] (FLINK-1784) KafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1784. - Resolution: Not A Problem KafkaITCase --- Key: FLINK-1784

[jira] [Commented] (FLINK-1784) KafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541689#comment-14541689 ] Stephan Ewen commented on FLINK-1784: - Subsumed by FLINK-2008 KafkaITCase

[jira] [Commented] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541692#comment-14541692 ] Stephan Ewen commented on FLINK-1690: - I think this one is stable by now...

[jira] [Commented] (FLINK-1865) Unstable test KafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541684#comment-14541684 ] Stephan Ewen commented on FLINK-1865: - With the rewrite of the PersistentKafkaSource,

[jira] [Closed] (FLINK-1865) Unstable test KafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1865. --- Resolution: Not A Problem Unstable test KafkaITCase -

[jira] [Commented] (FLINK-1983) Remove dependencies on Record APIs for Spargel

[ https://issues.apache.org/jira/browse/FLINK-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538180#comment-14538180 ] Stephan Ewen commented on FLINK-1983: - This seems doable without implications.

[jira] [Commented] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

[ https://issues.apache.org/jira/browse/FLINK-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538156#comment-14538156 ] Stephan Ewen commented on FLINK-1982: - I think the runtime and optimizer

[jira] [Created] (FLINK-2011) Improve error message when user-defined serialization logic is wrong

Stephan Ewen created FLINK-2011: --- Summary: Improve error message when user-defined serialization logic is wrong Key: FLINK-2011 URL: https://issues.apache.org/jira/browse/FLINK-2011 Project: Flink

[jira] [Created] (FLINK-2010) Add test that verifies that chained tasks are properly checkpointed

Stephan Ewen created FLINK-2010: --- Summary: Add test that verifies that chained tasks are properly checkpointed Key: FLINK-2010 URL: https://issues.apache.org/jira/browse/FLINK-2010 Project: Flink

[jira] [Created] (FLINK-2004) Memory leack in presence of failed checkpoints in KafkaSource

Stephan Ewen created FLINK-2004: --- Summary: Memory leack in presence of failed checkpoints in KafkaSource Key: FLINK-2004 URL: https://issues.apache.org/jira/browse/FLINK-2004 Project: Flink

[jira] [Updated] (FLINK-2004) Memory leak in presence of failed checkpoints in KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2004: Summary: Memory leak in presence of failed checkpoints in KafkaSource (was: Memory leack in

[jira] [Commented] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14540610#comment-14540610 ] Stephan Ewen commented on FLINK-1959: - Great debugging, this is perfect! I will

[jira] [Closed] (FLINK-1953) Rework Checkpoint Coordinator

[ https://issues.apache.org/jira/browse/FLINK-1953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1953. --- Rework Checkpoint Coordinator - Key: FLINK-1953

[jira] [Resolved] (FLINK-1953) Rework Checkpoint Coordinator

[ https://issues.apache.org/jira/browse/FLINK-1953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1953. - Resolution: Implemented Implemented in 9b7f8aa121e4a231632296d0809029aca9ebde6a Rework

[jira] [Resolved] (FLINK-1973) JobManager log does not contain state change messages on INFO level

[ https://issues.apache.org/jira/browse/FLINK-1973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1973. - Resolution: Fixed Fixed in ededb6b74a2d388ff1c54ddf0f2733c65675c9a0 JobManager log does not

[jira] [Closed] (FLINK-1973) JobManager log does not contain state change messages on INFO level

[ https://issues.apache.org/jira/browse/FLINK-1973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1973. --- JobManager log does not contain state change messages on INFO level

[jira] [Resolved] (FLINK-1935) Reimplement PersistentKafkaSource using high level Kafka API

[ https://issues.apache.org/jira/browse/FLINK-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1935. - Resolution: Implemented Implemented and merged in 54e957614c38fed69baf726fc86059e9b11384cb

[jira] [Closed] (FLINK-1935) Reimplement PersistentKafkaSource using high level Kafka API

[ https://issues.apache.org/jira/browse/FLINK-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1935. --- Reimplement PersistentKafkaSource using high level Kafka API

[jira] [Resolved] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1959. - Resolution: Pending Closed Fix Version/s: (was: master) 0.9

[jira] [Closed] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1959. --- Accumulators BROKEN after Partitioning -- Key:

[jira] [Commented] (FLINK-2005) Remove dependencies on Record APIs for flink-jdbc module

[ https://issues.apache.org/jira/browse/FLINK-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14540955#comment-14540955 ] Stephan Ewen commented on FLINK-2005: - I think those can be simply removed. The

[jira] [Created] (FLINK-2041) Optimizer plans with memory for pipeline breakers, even though they are not used any more

Stephan Ewen created FLINK-2041: --- Summary: Optimizer plans with memory for pipeline breakers, even though they are not used any more Key: FLINK-2041 URL: https://issues.apache.org/jira/browse/FLINK-2041

[jira] [Closed] (FLINK-1659) Rename classes and packages that contains Pact

[ https://issues.apache.org/jira/browse/FLINK-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1659. --- Rename classes and packages that contains Pact --

[jira] [Resolved] (FLINK-1659) Rename classes and packages that contains Pact

[ https://issues.apache.org/jira/browse/FLINK-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1659. - Resolution: Fixed Fix Version/s: 0.9 Solved and subsumed by FLINK-1611 Rename classes

[jira] [Commented] (FLINK-2006) TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but was:FAILED

[ https://issues.apache.org/jira/browse/FLINK-2006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547967#comment-14547967 ] Stephan Ewen commented on FLINK-2006: - You are right the test setup was not respecting

[jira] [Closed] (FLINK-2006) TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but was:FAILED

[ https://issues.apache.org/jira/browse/FLINK-2006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2006. --- TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but was:FAILED

[jira] [Resolved] (FLINK-2006) TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but was:FAILED

[ https://issues.apache.org/jira/browse/FLINK-2006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2006. - Resolution: Fixed Fixed (again, hopefully correctly this time) in

[jira] [Commented] (FLINK-2027) Flink website does not provide link to source repo

[ https://issues.apache.org/jira/browse/FLINK-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14548005#comment-14548005 ] Stephan Ewen commented on FLINK-2027: - Agreed, the canonical source repo should

[jira] [Commented] (FLINK-2035) Update 0.9 roadmap with ML issues

[ https://issues.apache.org/jira/browse/FLINK-2035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547971#comment-14547971 ] Stephan Ewen commented on FLINK-2035: - Can you also put the issue into this doc, for

[jira] [Commented] (FLINK-2029) DOAP has disappeared

[ https://issues.apache.org/jira/browse/FLINK-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547953#comment-14547953 ] Stephan Ewen commented on FLINK-2029: - I updates the entry in

[jira] [Commented] (FLINK-2027) Flink website does not provide link to source repo

[ https://issues.apache.org/jira/browse/FLINK-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547721#comment-14547721 ] Stephan Ewen commented on FLINK-2027: - I liked it that the link was fairly prominent

[jira] [Commented] (FLINK-2020) Table API JoinITCase fails non-deterministically

[ https://issues.apache.org/jira/browse/FLINK-2020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547726#comment-14547726 ] Stephan Ewen commented on FLINK-2020: - I think we can lazily migrate the tests. I did

[jira] [Commented] (FLINK-2020) Table API JoinITCase fails non-deterministically

[ https://issues.apache.org/jira/browse/FLINK-2020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547670#comment-14547670 ] Stephan Ewen commented on FLINK-2020: - This may be a sporadic temp fie failure. I have

[jira] [Commented] (FLINK-2025) Support booleans in CSV reader

[ https://issues.apache.org/jira/browse/FLINK-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547674#comment-14547674 ] Stephan Ewen commented on FLINK-2025: - Oh, I was always under the impression that it

[jira] [Commented] (FLINK-2025) Support booleans in CSV reader

[ https://issues.apache.org/jira/browse/FLINK-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547675#comment-14547675 ] Stephan Ewen commented on FLINK-2025: - I think it parses similar to

[jira] [Commented] (FLINK-2025) Support booleans in CSV reader

[ https://issues.apache.org/jira/browse/FLINK-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547715#comment-14547715 ] Stephan Ewen commented on FLINK-2025: - Just checked, you are right. Do you want to

[jira] [Closed] (FLINK-2001) DistanceMetric cannot be serialized

[ https://issues.apache.org/jira/browse/FLINK-2001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2001. --- DistanceMetric cannot be serialized --- Key:

[jira] [Closed] (FLINK-785) Add Chained operators for AllReduce and AllGroupReduce

[ https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-785. -- Add Chained operators for AllReduce and AllGroupReduce

[jira] [Resolved] (FLINK-1987) Broken links in the add_operator section of the documentation

[ https://issues.apache.org/jira/browse/FLINK-1987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1987. - Resolution: Pending Closed Fix Version/s: 0.9 Fixed and merged in

[jira] [Closed] (FLINK-2006) TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but was:FAILED

[ https://issues.apache.org/jira/browse/FLINK-2006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2006. --- TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but was:FAILED

[jira] [Closed] (FLINK-2011) Improve error message when user-defined serialization logic is wrong

[ https://issues.apache.org/jira/browse/FLINK-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2011. --- Improve error message when user-defined serialization logic is wrong

[jira] [Resolved] (FLINK-2011) Improve error message when user-defined serialization logic is wrong

[ https://issues.apache.org/jira/browse/FLINK-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2011. - Resolution: Pending Closed Fixed in 113b20b7f8717b12c5f0dfa691da582d426fbae0 Improve error

[jira] [Resolved] (FLINK-2006) TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but was:FAILED

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

[jira] [Closed] (FLINK-2041) Optimizer plans with memory for pipeline breakers, even though they are not used any more

[ https://issues.apache.org/jira/browse/FLINK-2041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2041. --- Optimizer plans with memory for pipeline breakers, even though they are not used any more

[jira] [Resolved] (FLINK-2041) Optimizer plans with memory for pipeline breakers, even though they are not used any more

[ https://issues.apache.org/jira/browse/FLINK-2041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2041. - Resolution: Fixed Fixed in c12403e20547bcdc2104781e0c160525a48783c8 Optimizer plans with memory

[jira] [Commented] (FLINK-2040) TaskTest.testCancelDuringInvoke:434-validateListenerMessage:712 expected:CANCELING but was:CANCELED

[ https://issues.apache.org/jira/browse/FLINK-2040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550035#comment-14550035 ] Stephan Ewen commented on FLINK-2040: - Funny, I just saw the same thing...

[jira] [Commented] (FLINK-2040) TaskTest.testCancelDuringInvoke:434-validateListenerMessage:712 expected:CANCELING but was:CANCELED

[ https://issues.apache.org/jira/browse/FLINK-2040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550038#comment-14550038 ] Stephan Ewen commented on FLINK-2040: - The cause is the following: It may be (very

[jira] [Commented] (FLINK-2042) Increase font size for stack figure on website home

[ https://issues.apache.org/jira/browse/FLINK-2042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550058#comment-14550058 ] Stephan Ewen commented on FLINK-2042: - I would like to increase the entire figure,

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550056#comment-14550056 ] Stephan Ewen commented on FLINK-2026: - +1 for a good error message. I agree with

[jira] [Commented] (FLINK-2038) Extend headline of website

[ https://issues.apache.org/jira/browse/FLINK-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550066#comment-14550066 ] Stephan Ewen commented on FLINK-2038: - How about making the scalable part of the

[jira] [Closed] (FLINK-2040) TaskTest.testCancelDuringInvoke:434-validateListenerMessage:712 expected:CANCELING but was:CANCELED

[ https://issues.apache.org/jira/browse/FLINK-2040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2040. --- TaskTest.testCancelDuringInvoke:434-validateListenerMessage:712 expected:CANCELING but was:CANCELED

[jira] [Commented] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance

[ https://issues.apache.org/jira/browse/FLINK-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550201#comment-14550201 ] Stephan Ewen commented on FLINK-1952: - I cannot reproduce this error any more with

[jira] [Created] (FLINK-2046) Quickstarts are missing on the new Website

Stephan Ewen created FLINK-2046: --- Summary: Quickstarts are missing on the new Website Key: FLINK-2046 URL: https://issues.apache.org/jira/browse/FLINK-2046 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1890) Add withReadFields or sth. similar to Scala API

[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14499758#comment-14499758 ] Stephan Ewen commented on FLINK-1890: - I think the {{readFields}} are not evaluated by

[jira] [Commented] (FLINK-1906) Add tip to work around plain Tuple return type of project operator

[ https://issues.apache.org/jira/browse/FLINK-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14499655#comment-14499655 ] Stephan Ewen commented on FLINK-1906: - Makes sense. Add tip to work around plain

[jira] [Commented] (FLINK-1868) EnvironmentInformationTest.testJavaMemory fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-1868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492076#comment-14492076 ] Stephan Ewen commented on FLINK-1868: - This may happen if, in the cource of a GC

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