[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14592256#comment-14592256 ] Stephan Ewen commented on FLINK-2237: - All of that being said, be aware of what you

[jira] [Commented] (FLINK-2204) Tez ConnectedComponentsStepITCase fails spuriously on Travis

[ https://issues.apache.org/jira/browse/FLINK-2204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14595910#comment-14595910 ] Stephan Ewen commented on FLINK-2204: - Hmm, looks again like a Tez issue. No Flink

[jira] [Commented] (FLINK-2228) Web frontend uses two different timezones when reporting the time for job

[ https://issues.apache.org/jira/browse/FLINK-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14587312#comment-14587312 ] Stephan Ewen commented on FLINK-2228: - I think that is subject to the Google JS

[jira] [Commented] (FLINK-2229) Data sets involving non-primitive arrays cannot be unioned

[ https://issues.apache.org/jira/browse/FLINK-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14587309#comment-14587309 ] Stephan Ewen commented on FLINK-2229: - Good catch, thanks! Do you want to prepare a

[jira] [Commented] (FLINK-2213) Configure number of vcores

[ https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14587321#comment-14587321 ] Stephan Ewen commented on FLINK-2213: - Does this number influence the number of

[jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails

[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14587315#comment-14587315 ] Stephan Ewen commented on FLINK-2220: - It should be possible to put in a check that

[jira] [Created] (FLINK-2231) Create a Serializer for Scala Enumerations

Stephan Ewen created FLINK-2231: --- Summary: Create a Serializer for Scala Enumerations Key: FLINK-2231 URL: https://issues.apache.org/jira/browse/FLINK-2231 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-2159) SimpleRecoveryITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2159. - Resolution: Cannot Reproduce The cause for the failed test case is that one TaskManager

[jira] [Created] (FLINK-2097) Add support for JobSessions

Stephan Ewen created FLINK-2097: --- Summary: Add support for JobSessions Key: FLINK-2097 URL: https://issues.apache.org/jira/browse/FLINK-2097 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-2101) Scheme Inference doesn't work for Tuple5

[ https://issues.apache.org/jira/browse/FLINK-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567489#comment-14567489 ] Stephan Ewen commented on FLINK-2101: - So, is there any problem remaining, or can this

[jira] [Closed] (FLINK-2121) FileInputFormat.addFilesInDir miscalculates total size

[ https://issues.apache.org/jira/browse/FLINK-2121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2121. --- FileInputFormat.addFilesInDir miscalculates total size

[jira] [Resolved] (FLINK-2121) FileInputFormat.addFilesInDir miscalculates total size

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

[jira] [Closed] (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 closed FLINK-2004. --- Memory leak in presence of failed checkpoints in KafkaSource

[jira] [Commented] (FLINK-2120) Rename AbstractJobVertex to JobVertex

[ https://issues.apache.org/jira/browse/FLINK-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567329#comment-14567329 ] Stephan Ewen commented on FLINK-2120: - +1 Rename AbstractJobVertex to JobVertex

[jira] [Closed] (FLINK-1747) Remove deadlock detection and pipeline breaker placement in optimizer

[ https://issues.apache.org/jira/browse/FLINK-1747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1747. --- Remove deadlock detection and pipeline breaker placement in optimizer

[jira] [Resolved] (FLINK-1747) Remove deadlock detection and pipeline breaker placement in optimizer

[ https://issues.apache.org/jira/browse/FLINK-1747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1747. - Resolution: Duplicate Duplicate of FLINK-2041 Remove deadlock detection and pipeline breaker

[jira] [Created] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

Stephan Ewen created FLINK-2098: --- Summary: Checkpoint barrier initiation at source is not aligned with snapshotting Key: FLINK-2098 URL: https://issues.apache.org/jira/browse/FLINK-2098 Project: Flink

[jira] [Commented] (FLINK-2101) Scheme Inference doesn't work for Tuple5

[ https://issues.apache.org/jira/browse/FLINK-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561068#comment-14561068 ] Stephan Ewen commented on FLINK-2101: - Type inference cannot work on generic,

[jira] [Closed] (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:all-tabpanel ] Stephan Ewen closed FLINK-1952. --- Cannot run ConnectedComponents example: Could not allocate a slot on instance

[jira] [Commented] (FLINK-2081) Change order of restore state and open for Streaming Operators

[ https://issues.apache.org/jira/browse/FLINK-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561102#comment-14561102 ] Stephan Ewen commented on FLINK-2081: - How about guarding this assumption with a test

[jira] [Created] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements

Stephan Ewen created FLINK-2130: --- Summary: RabbitMQ source does not fail when failing to retrieve elements Key: FLINK-2130 URL: https://issues.apache.org/jira/browse/FLINK-2130 Project: Flink

[jira] [Commented] (FLINK-2301) In BarrierBuffer newer Barriers trigger old Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-2301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14609727#comment-14609727 ] Stephan Ewen commented on FLINK-2301: - I agree that we should change that behavior.

[jira] [Commented] (FLINK-2302) Allow multiple instances to run on single host

[ https://issues.apache.org/jira/browse/FLINK-2302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14609725#comment-14609725 ] Stephan Ewen commented on FLINK-2302: - TaskManagers have no pre-configured port. I

[jira] [Created] (FLINK-2308) Improve error messages on broken user-defined serialization

Stephan Ewen created FLINK-2308: --- Summary: Improve error messages on broken user-defined serialization Key: FLINK-2308 URL: https://issues.apache.org/jira/browse/FLINK-2308 Project: Flink

[jira] [Resolved] (FLINK-2158) NullPointerException in DateSerializer.

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

[jira] [Closed] (FLINK-2158) NullPointerException in DateSerializer.

[ https://issues.apache.org/jira/browse/FLINK-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2158. --- NullPointerException in DateSerializer. --- Key:

[jira] [Commented] (FLINK-2308) Improve error messages on broken user-defined serialization

[ https://issues.apache.org/jira/browse/FLINK-2308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14610440#comment-14610440 ] Stephan Ewen commented on FLINK-2308: - Have a very simple patch coming up that only

[jira] [Closed] (FLINK-2308) Improve error messages on broken user-defined serialization

[ https://issues.apache.org/jira/browse/FLINK-2308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2308. --- Improve error messages on broken user-defined serialization

[jira] [Resolved] (FLINK-2308) Improve error messages on broken user-defined serialization

[ https://issues.apache.org/jira/browse/FLINK-2308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2308. - Resolution: Fixed Fixed in f5c1768aa730fb6be74c0ebf480675acb1488d4f Improve error messages on

[jira] [Closed] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators'

[ https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2275. --- Migrate test from package 'org.apache.flink.test.javaApiOperators'

[jira] [Created] (FLINK-2309) Use static code analysis to replace selector functions with field accesses.

Stephan Ewen created FLINK-2309: --- Summary: Use static code analysis to replace selector functions with field accesses. Key: FLINK-2309 URL: https://issues.apache.org/jira/browse/FLINK-2309 Project:

[jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed

[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14609708#comment-14609708 ] Stephan Ewen commented on FLINK-2299: - Okay, judging from the timestamps, it looks

[jira] [Comment Edited] (FLINK-2299) The slot on which the task maanger was scheduled was killed

[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14609708#comment-14609708 ] Stephan Ewen edited comment on FLINK-2299 at 7/1/15 8:07 AM: -

[jira] [Created] (FLINK-2313) Change Streaming Driver Execution Model

Stephan Ewen created FLINK-2313: --- Summary: Change Streaming Driver Execution Model Key: FLINK-2313 URL: https://issues.apache.org/jira/browse/FLINK-2313 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed

[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14611700#comment-14611700 ] Stephan Ewen commented on FLINK-2299: - Could you try and see when the JobManager and

[jira] [Commented] (FLINK-2296) Checkpoint committing broken

[ https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14611714#comment-14611714 ] Stephan Ewen commented on FLINK-2296: - Can you share the a minimal case that

[jira] [Commented] (FLINK-2313) Change Streaming Driver Execution Model

[ https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14611753#comment-14611753 ] Stephan Ewen commented on FLINK-2313: - Since this is API breaking, let's get at least

[jira] [Updated] (FLINK-2314) Make Streaming File Sources Persistent

[ https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2314: Labels: easyfix starter (was: ) Make Streaming File Sources Persistent

[jira] [Created] (FLINK-2314) Make Streaming File Sources Persistent

Stephan Ewen created FLINK-2314: --- Summary: Make Streaming File Sources Persistent Key: FLINK-2314 URL: https://issues.apache.org/jira/browse/FLINK-2314 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed

[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14611946#comment-14611946 ] Stephan Ewen commented on FLINK-2299: - The JobManager is not dying. It temporarily

[jira] [Commented] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state

[ https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605416#comment-14605416 ] Stephan Ewen commented on FLINK-2283: - This would be a temporary solution that will

[jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed

[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14614730#comment-14614730 ] Stephan Ewen commented on FLINK-2299: - [~andralungu] Th number you want to increase is

[jira] [Created] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey

Stephan Ewen created FLINK-2315: --- Summary: Hadoop Writables cannot exploit implementing NormalizableKey Key: FLINK-2315 URL: https://issues.apache.org/jira/browse/FLINK-2315 Project: Flink

[jira] [Commented] (FLINK-2296) Checkpoint committing broken

[ https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608264#comment-14608264 ] Stephan Ewen commented on FLINK-2296: - I think there is a misunderstanding on what the

[jira] [Commented] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559077#comment-14559077 ] Stephan Ewen commented on FLINK-2088: - Agree, it should be at least that. In the

[jira] [Commented] (FLINK-2080) Execute Flink with sbt

[ https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559082#comment-14559082 ] Stephan Ewen commented on FLINK-2080: - How to contribute documentation:

[jira] [Commented] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge

[ https://issues.apache.org/jira/browse/FLINK-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559083#comment-14559083 ] Stephan Ewen commented on FLINK-2090: - How about we print at most N (= 3 or 10)

[jira] [Closed] (FLINK-1828) Impossible to output data to an HBase table

[ https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1828. --- Impossible to output data to an HBase table ---

[jira] [Created] (FLINK-2070) Confusing methods print() that print on client vs on TaskManager

Stephan Ewen created FLINK-2070: --- Summary: Confusing methods print() that print on client vs on TaskManager Key: FLINK-2070 URL: https://issues.apache.org/jira/browse/FLINK-2070 Project: Flink

[jira] [Closed] (FLINK-2063) Streaming checkpoints consider only input and output vertices

[ https://issues.apache.org/jira/browse/FLINK-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2063. --- Streaming checkpoints consider only input and output vertices

[jira] [Resolved] (FLINK-2062) Fix names of memory segment config parameter

[ https://issues.apache.org/jira/browse/FLINK-2062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2062. - Resolution: Fixed Fixed via 939e3fc40fbdb05f2a564c241eb2c791e869f2d3 Fix names of memory

[jira] [Closed] (FLINK-2062) Fix names of memory segment config parameter

[ https://issues.apache.org/jira/browse/FLINK-2062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2062. --- Fix names of memory segment config parameter

[jira] [Resolved] (FLINK-2063) Streaming checkpoints consider only input and output vertices

[ https://issues.apache.org/jira/browse/FLINK-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2063. - Resolution: Fixed Fixed via 7bd7b056a2947440ad5acab6dbd45915c356f145 Streaming checkpoints

[jira] [Created] (FLINK-2071) Projection function can fail non serializable

Stephan Ewen created FLINK-2071: --- Summary: Projection function can fail non serializable Key: FLINK-2071 URL: https://issues.apache.org/jira/browse/FLINK-2071 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-2071) Projection function can fail non serializable

[ https://issues.apache.org/jira/browse/FLINK-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2071. --- Projection function can fail non serializable -

[jira] [Resolved] (FLINK-2071) Projection function can fail non serializable

[ https://issues.apache.org/jira/browse/FLINK-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2071. - Resolution: Fixed Fixed in ad1d9362c88343972b19fdcce0b041d8380805a9 Projection function can

[jira] [Closed] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1418. --- Make 'print()' output on the client command line, rather than on the task manager sysout

[jira] [Resolved] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

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

[jira] [Closed] (FLINK-2052) Clear up Serializable warnings in streaming operators

[ https://issues.apache.org/jira/browse/FLINK-2052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2052. --- Clear up Serializable warnings in streaming operators

[jira] [Resolved] (FLINK-2052) Clear up Serializable warnings in streaming operators

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

[jira] [Updated] (FLINK-2043) Change the KMeansDataGenerator to allow passing a custom path

[ https://issues.apache.org/jira/browse/FLINK-2043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2043: Assignee: pietro pinoli Change the KMeansDataGenerator to allow passing a custom path

[jira] [Resolved] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

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

[jira] [Closed] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1985. --- Streaming does not correctly forward ExecutionConfig to runtime

[jira] [Commented] (FLINK-2043) Change the KMeansDataGenerator to allow passing a custom path

[ https://issues.apache.org/jira/browse/FLINK-2043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14554916#comment-14554916 ] Stephan Ewen commented on FLINK-2043: - Sounds good, welcome to Flink! I added you to

[jira] [Created] (FLINK-2076) Bug in re-openable hash join

Stephan Ewen created FLINK-2076: --- Summary: Bug in re-openable hash join Key: FLINK-2076 URL: https://issues.apache.org/jira/browse/FLINK-2076 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2084) Create a dedicated streaming mode

Stephan Ewen created FLINK-2084: --- Summary: Create a dedicated streaming mode Key: FLINK-2084 URL: https://issues.apache.org/jira/browse/FLINK-2084 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-1323) Implement memory management profiles

[ https://issues.apache.org/jira/browse/FLINK-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1323. --- Implement memory management profiles Key:

[jira] [Created] (FLINK-2085) Add an option to the MemoryManager to allocate memory as needed, rather than preallocating it

Stephan Ewen created FLINK-2085: --- Summary: Add an option to the MemoryManager to allocate memory as needed, rather than preallocating it Key: FLINK-2085 URL: https://issues.apache.org/jira/browse/FLINK-2085

[jira] [Resolved] (FLINK-1323) Implement memory management profiles

[ https://issues.apache.org/jira/browse/FLINK-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1323. - Resolution: Won't Fix Subsumed by FLINK-2085 Implement memory management profiles

[jira] [Resolved] (FLINK-1476) Flink VS Spark on loop test

[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1476. - Resolution: Invalid This is a discussion that should happen on the mailing list Flink VS Spark

[jira] [Updated] (FLINK-2085) Add an option to the MemoryManager to allocate memory as needed, rather than preallocating it

[ https://issues.apache.org/jira/browse/FLINK-2085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2085: Issue Type: Sub-task (was: New Feature) Parent: FLINK-2084 Add an option to the

[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=14550892#comment-14550892 ] Stephan Ewen commented on FLINK-1952: - Next step in the diagnosis: There is apparently

[jira] [Resolved] (FLINK-1980) Allowing users to decorate input streams

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

[jira] [Closed] (FLINK-2059) Rename modules flink-compiler to flink-optimizer in pom.xml

[ https://issues.apache.org/jira/browse/FLINK-2059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2059. --- Rename modules flink-compiler to flink-optimizer in pom.xml

[jira] [Created] (FLINK-2063) Streaming checkpoints consider only input and output vertices

Stephan Ewen created FLINK-2063: --- Summary: Streaming checkpoints consider only input and output vertices Key: FLINK-2063 URL: https://issues.apache.org/jira/browse/FLINK-2063 Project: Flink

[jira] [Closed] (FLINK-1980) Allowing users to decorate input streams

[ https://issues.apache.org/jira/browse/FLINK-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1980. --- Allowing users to decorate input streams

[jira] [Resolved] (FLINK-2059) Rename modules flink-compiler to flink-optimizer in pom.xml

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

[jira] [Closed] (FLINK-2084) Create a dedicated streaming mode

[ https://issues.apache.org/jira/browse/FLINK-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2084. --- Create a dedicated streaming mode - Key: FLINK-2084

[jira] [Resolved] (FLINK-2084) Create a dedicated streaming mode

[ https://issues.apache.org/jira/browse/FLINK-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2084. - Resolution: Implemented Implemented in efec2297b46b83e0dc6111a91a3f80f9d5375e0d Create a

[jira] [Resolved] (FLINK-2085) Add an option to the MemoryManager to allocate memory as needed, rather than preallocating it

[ https://issues.apache.org/jira/browse/FLINK-2085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2085. - Resolution: Implemented Implemented in ea60678e9ecdcf954cddf0ce6d0e0b6da01b4cbc Add an option

[jira] [Closed] (FLINK-2085) Add an option to the MemoryManager to allocate memory as needed, rather than preallocating it

[ https://issues.apache.org/jira/browse/FLINK-2085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2085. --- Add an option to the MemoryManager to allocate memory as needed, rather than preallocating it

[jira] [Commented] (FLINK-2493) Simplify names of example program JARs

[ https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694854#comment-14694854 ] Stephan Ewen commented on FLINK-2493: - Still, seeking consensus on the dev list is a

[jira] [Commented] (FLINK-2493) Simplify names of example program JARs

[ https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694851#comment-14694851 ] Stephan Ewen commented on FLINK-2493: - I think there was a discussion about combining

[jira] [Created] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution.

Stephan Ewen created FLINK-2514: --- Summary: Local and Remote environment behave differently when re-triggering execution. Key: FLINK-2514 URL: https://issues.apache.org/jira/browse/FLINK-2514 Project:

[jira] [Updated] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution.

[ https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2514: Priority: Critical (was: Major) Local and Remote environment behave differently when

[jira] [Created] (FLINK-2515) CheckpointCoordinator triggers checkpoints even if not all sources are running any more

Stephan Ewen created FLINK-2515: --- Summary: CheckpointCoordinator triggers checkpoints even if not all sources are running any more Key: FLINK-2515 URL: https://issues.apache.org/jira/browse/FLINK-2515

[jira] [Closed] (FLINK-2534) Improve execution code in CompactingHashTable.java

[ https://issues.apache.org/jira/browse/FLINK-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2534. --- Improve execution code in CompactingHashTable.java --

[jira] [Closed] (FLINK-2462) Wrong exception reporting in streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2462. --- Wrong exception reporting in streaming jobs ---

[jira] [Assigned] (FLINK-2415) Link nodes in plan to vertices

[ https://issues.apache.org/jira/browse/FLINK-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-2415: --- Assignee: Stephan Ewen Link nodes in plan to vertices --

[jira] [Commented] (FLINK-2415) Link nodes in plan to vertices

[ https://issues.apache.org/jira/browse/FLINK-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699374#comment-14699374 ] Stephan Ewen commented on FLINK-2415: - The plan is currently created from the

[jira] [Closed] (FLINK-855) Web interface: flow vs stack layout

[ https://issues.apache.org/jira/browse/FLINK-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-855. -- Web interface: flow vs stack layout --- Key: FLINK-855

[jira] [Resolved] (FLINK-855) Web interface: flow vs stack layout

[ https://issues.apache.org/jira/browse/FLINK-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-855. Resolution: Won't Fix Will be subsumed by the new web dashboard Web interface: flow vs stack

[jira] [Resolved] (FLINK-2534) Improve execution code in CompactingHashTable.java

[ https://issues.apache.org/jira/browse/FLINK-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2534. - Resolution: Fixed Fixed via 63ee34c5b894e2795e74a3c2aa3d5dc9ac2d5b88 Thank you for the

[jira] [Resolved] (FLINK-2462) Wrong exception reporting in streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2462. - Resolution: Fixed Fixed via 92b1e471d4762545637817c74f9396765984b39a Wrong exception reporting

[jira] [Updated] (FLINK-2415) Link nodes in plan to vertices

[ https://issues.apache.org/jira/browse/FLINK-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2415: Issue Type: Sub-task (was: Improvement) Parent: FLINK-2357 Link nodes in plan to vertices

[jira] [Resolved] (FLINK-2527) If a VertexUpdateFunction calls setNewVertexValue more than once, the MessagingFunction will only see the first value set

[ https://issues.apache.org/jira/browse/FLINK-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2527. - Resolution: Fixed Fixed - 0.10 in 0ea0bc12b3f8a8a82b6fca563340af547c0a02ab - 0.9.1 in

[jira] [Closed] (FLINK-2527) If a VertexUpdateFunction calls setNewVertexValue more than once, the MessagingFunction will only see the first value set

[ https://issues.apache.org/jira/browse/FLINK-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2527. --- If a VertexUpdateFunction calls setNewVertexValue more than once, the MessagingFunction will only see

[jira] [Closed] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient

[ https://issues.apache.org/jira/browse/FLINK-1321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1321. --- Resolution: Fixed New web interface, contains parts from WebInfoServer and WebClient

[jira] [Resolved] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient

[ https://issues.apache.org/jira/browse/FLINK-1321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1321. - Resolution: Incomplete Fix Version/s: (was: 0.7.0-incubating) No progress on that

[jira] [Closed] (FLINK-2365) Review of How to contribute page

[ https://issues.apache.org/jira/browse/FLINK-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2365. --- Review of How to contribute page Key: FLINK-2365

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