[jira] [Reopened] (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 reopened FLINK-1321: - New web interface, contains parts from WebInfoServer and WebClient

[jira] [Resolved] (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 resolved FLINK-2365. - Resolution: Fixed Fixed as part of 1f917e3b40fc74431e06834826cc556e4e78c48b Review of How to

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14700876#comment-14700876 ] Stephan Ewen commented on FLINK-2366: - The leader election service is pluggable in

[jira] [Commented] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

[ https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14701179#comment-14701179 ] Stephan Ewen commented on FLINK-2540: - I put Ufuk as responsible for that (hop that's

[jira] [Updated] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

[ https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2540: Priority: Blocker (was: Major) LocalBufferPool.requestBuffer gets into infinite loop

[jira] [Updated] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

[ https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2540: Assignee: Ufuk Celebi LocalBufferPool.requestBuffer gets into infinite loop

[jira] [Commented] (FLINK-2487) the array has out of bounds

[ https://issues.apache.org/jira/browse/FLINK-2487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14698793#comment-14698793 ] Stephan Ewen commented on FLINK-2487: - Added a fix in

[jira] [Resolved] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

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

[jira] [Closed] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2449. --- DistCache doesn't work with JavaProgram Collection tests

[jira] [Resolved] (FLINK-2458) Distributed Cache doesn't work with iterations.

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

[jira] [Closed] (FLINK-2458) Distributed Cache doesn't work with iterations.

[ https://issues.apache.org/jira/browse/FLINK-2458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2458. --- Distributed Cache doesn't work with iterations. ---

[jira] [Commented] (FLINK-2398) Decouple StreamGraph Building from the API

[ https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699848#comment-14699848 ] Stephan Ewen commented on FLINK-2398: - What does the runtime do in the end, when it

[jira] [Commented] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters

[ https://issues.apache.org/jira/browse/FLINK-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14701802#comment-14701802 ] Stephan Ewen commented on FLINK-2545: - Thanks for reporting this! As a quick fix, you

[jira] [Commented] (FLINK-2528) DriverTestBase tests fail spuriously

[ https://issues.apache.org/jira/browse/FLINK-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703057#comment-14703057 ] Stephan Ewen commented on FLINK-2528: - I have seen before that the canceling tests are

[jira] [Created] (FLINK-2547) Provide Cluster Status Info

Stephan Ewen created FLINK-2547: --- Summary: Provide Cluster Status Info Key: FLINK-2547 URL: https://issues.apache.org/jira/browse/FLINK-2547 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-2548) VertexCentricIteration should avoid doing a coGroup with the edges and the solution set

[ https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703337#comment-14703337 ] Stephan Ewen commented on FLINK-2548: - Actually, the second co-group is not a real

[jira] [Commented] (FLINK-2548) VertexCentricIteration should avoid doing a coGroup with the edges and the solution set

[ https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703401#comment-14703401 ] Stephan Ewen commented on FLINK-2548: - I like the idea of improving this, but it is

[jira] [Resolved] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

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

[jira] [Closed] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

[ https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2540. --- LocalBufferPool.requestBuffer gets into infinite loop

[jira] [Resolved] (FLINK-2306) Add support for named streams in Storm compatibility layer

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

[jira] [Closed] (FLINK-2306) Add support for named streams in Storm compatibility layer

[ https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2306. --- Add support for named streams in Storm compatibility layer

[jira] [Commented] (FLINK-2548) VertexCentricIteration should avoid doing a coGroup with the edges and the solution set

[ https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704489#comment-14704489 ] Stephan Ewen commented on FLINK-2548: - (1) CoGrouping with the solution set is a

[jira] [Commented] (FLINK-2551) Fix Several Bugs in Input/Output Formats

[ https://issues.apache.org/jira/browse/FLINK-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704616#comment-14704616 ] Stephan Ewen commented on FLINK-2551: - Looks like good ideas! There is the

[jira] [Commented] (FLINK-2549) Add topK operator for DataSet

[ https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704498#comment-14704498 ] Stephan Ewen commented on FLINK-2549: - You can implement topK on top if

[jira] [Commented] (FLINK-2541) TypeComparator creation fails for T2T1byte[], byte[]

[ https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704503#comment-14704503 ] Stephan Ewen commented on FLINK-2541: - [~rmetzger] True, the pre-flight checks seem

[jira] [Commented] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest

[ https://issues.apache.org/jira/browse/FLINK-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704744#comment-14704744 ] Stephan Ewen commented on FLINK-2552: - This looks like a corner case akka problem, on

[jira] [Updated] (FLINK-2414) Extend job data in job list

[ https://issues.apache.org/jira/browse/FLINK-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2414: Issue Type: Sub-task (was: Improvement) Parent: FLINK-2357 Extend job data in job list

[jira] [Commented] (FLINK-2550) Rework DataStream API

[ https://issues.apache.org/jira/browse/FLINK-2550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704884#comment-14704884 ] Stephan Ewen commented on FLINK-2550: - How about we make the WindowInfoAvailable in

[jira] [Commented] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20

[ https://issues.apache.org/jira/browse/FLINK-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14701331#comment-14701331 ] Stephan Ewen commented on FLINK-2544: - +1 for documenting this Some test cases using

[jira] [Closed] (FLINK-2529) fix on some unused code for flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-2529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2529. --- fix on some unused code for flink-runtime -

[jira] [Closed] (FLINK-2477) Add test for SocketClientSink

[ https://issues.apache.org/jira/browse/FLINK-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2477. --- Add test for SocketClientSink - Key: FLINK-2477

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1962. --- Add Gelly Scala API --- Key: FLINK-1962 URL:

[jira] [Resolved] (FLINK-2529) fix on some unused code for flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-2529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2529. - Resolution: Fixed Fixed in 8a59f87bd4b3ec15d9bafae8e7de6d8a55e070b1 fix on some unused code for

[jira] [Created] (FLINK-2554) Add exception reporting handler

Stephan Ewen created FLINK-2554: --- Summary: Add exception reporting handler Key: FLINK-2554 URL: https://issues.apache.org/jira/browse/FLINK-2554 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-2282) Deprecate non-grouped stream reduce/fold/aggregations for 0.9.1

[ https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605297#comment-14605297 ] Stephan Ewen commented on FLINK-2282: - Minor versions are bug-fix versions, major

[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=14605298#comment-14605298 ] Stephan Ewen commented on FLINK-2283: - Are these again implemented in java maps, or

[jira] [Commented] (FLINK-2282) Deprecate non-grouped stream reduce/fold/aggregations for 0.9.1

[ https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605330#comment-14605330 ] Stephan Ewen commented on FLINK-2282: - Since the API is labeled beta, it is okay to do

[jira] [Created] (FLINK-2284) Confusing/inconsistent PartitioningStrategy

Stephan Ewen created FLINK-2284: --- Summary: Confusing/inconsistent PartitioningStrategy Key: FLINK-2284 URL: https://issues.apache.org/jira/browse/FLINK-2284 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-2282) Deprecate non-grouped stream reduce/fold/aggregations for 0.9.1

[ https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605297#comment-14605297 ] Stephan Ewen edited comment on FLINK-2282 at 6/29/15 8:48 AM: --

[jira] [Commented] (FLINK-2281) Allow chaining of operators with multiple inputs

[ https://issues.apache.org/jira/browse/FLINK-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605261#comment-14605261 ] Stephan Ewen commented on FLINK-2281: - Nice idea, but probably not very critical. I

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

[ https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608411#comment-14608411 ] Stephan Ewen commented on FLINK-2296: - +1 to do that so the current state is robust

[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=14608412#comment-14608412 ] Stephan Ewen commented on FLINK-2299: - We are getting more reports where this happens.

[jira] [Commented] (FLINK-2293) Division by Zero Exception

[ https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608419#comment-14608419 ] Stephan Ewen commented on FLINK-2293: - [~fhueske] and me have located this and figured

[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=14608810#comment-14608810 ] Stephan Ewen commented on FLINK-2299: - [~andralungu] - from some LOG debugging, it

[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=14608732#comment-14608732 ] Stephan Ewen commented on FLINK-2299: - Aside from the issue that you see, I think you

[jira] [Closed] (FLINK-2407) Add an API switch to select between exactly once and at least once fault tolerance

[ https://issues.apache.org/jira/browse/FLINK-2407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2407. --- Add an API switch to select between exactly once and at least once fault tolerance

[jira] [Resolved] (FLINK-2407) Add an API switch to select between exactly once and at least once fault tolerance

[ https://issues.apache.org/jira/browse/FLINK-2407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2407. - Resolution: Fixed Fixed in b211a62111aa3c558586874d0ec5b168e6bb31f1 Add an API switch to select

[jira] [Commented] (FLINK-2410) PojoTypeInfo is not completely serializable

[ https://issues.apache.org/jira/browse/FLINK-2410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644059#comment-14644059 ] Stephan Ewen commented on FLINK-2410: - [~fhueske] is right. The initial design was

[jira] [Created] (FLINK-2420) OutputFlush thread in stream writers does not propagate exceptions

Stephan Ewen created FLINK-2420: --- Summary: OutputFlush thread in stream writers does not propagate exceptions Key: FLINK-2420 URL: https://issues.apache.org/jira/browse/FLINK-2420 Project: Flink

[jira] [Created] (FLINK-2418) Add an end-to-end streaming fault tolerance test for the Checkpointed interface

Stephan Ewen created FLINK-2418: --- Summary: Add an end-to-end streaming fault tolerance test for the Checkpointed interface Key: FLINK-2418 URL: https://issues.apache.org/jira/browse/FLINK-2418

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14650323#comment-14650323 ] Stephan Ewen commented on FLINK-2449: - We could also add a no op distributed cache for

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14650416#comment-14650416 ] Stephan Ewen commented on FLINK-2449: - Is that a use case for the distributed cache,

[jira] [Commented] (FLINK-2459) Failure on recently added Client side logging test

[ https://issues.apache.org/jira/browse/FLINK-2459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14650427#comment-14650427 ] Stephan Ewen commented on FLINK-2459: - The concern that no log output is in system out

[jira] [Resolved] (FLINK-2438) Improve performance of channel events

[ https://issues.apache.org/jira/browse/FLINK-2438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2438. - Resolution: Fixed Fixed via af88aa09ec94d4d11f38a7134d36793420d7d19d Improve performance of

[jira] [Closed] (FLINK-2438) Improve performance of channel events

[ https://issues.apache.org/jira/browse/FLINK-2438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2438. --- Improve performance of channel events - Key:

[jira] [Closed] (FLINK-2393) Add a stateless at-least-once mode for streaming

[ https://issues.apache.org/jira/browse/FLINK-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2393. --- Add a stateless at-least-once mode for streaming --

[jira] [Resolved] (FLINK-2461) RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest

[ https://issues.apache.org/jira/browse/FLINK-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2461. - Resolution: Fixed Fixed via 645d7cd9e437d3de301ca0ce5c9cdc87bcce494b

[jira] [Closed] (FLINK-2461) RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest

[ https://issues.apache.org/jira/browse/FLINK-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2461. --- RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest

[jira] [Commented] (FLINK-2453) Update POM to use Java7 as the source and target version

[ https://issues.apache.org/jira/browse/FLINK-2453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651042#comment-14651042 ] Stephan Ewen commented on FLINK-2453: - +1 Looking forward to using Java7 features :-)

[jira] [Created] (FLINK-2461) RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest

Stephan Ewen created FLINK-2461: --- Summary: RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest Key: FLINK-2461 URL: https://issues.apache.org/jira/browse/FLINK-2461 Project: Flink

[jira] [Resolved] (FLINK-2427) Allow the BarrierBuffer to maintain multiple queues of blocked inputs

[ https://issues.apache.org/jira/browse/FLINK-2427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2427. - Resolution: Fixed Fixed via 9311b9a9da57796e1eb91aa0ec5fa8948b732a47 Allow the BarrierBuffer to

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651086#comment-14651086 ] Stephan Ewen commented on FLINK-2435: - for (2), is this going to hook into the CSV

[jira] [Commented] (FLINK-2444) Add tests for HadoopInputFormats

[ https://issues.apache.org/jira/browse/FLINK-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651098#comment-14651098 ] Stephan Ewen commented on FLINK-2444: - Yes, big +1 to that Add tests for

[jira] [Closed] (FLINK-2463) Chow execution config in dashboard

[ https://issues.apache.org/jira/browse/FLINK-2463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2463. --- Chow execution config in dashboard -- Key: FLINK-2463

[jira] [Created] (FLINK-2463) Chow execution config in dashboard

Stephan Ewen created FLINK-2463: --- Summary: Chow execution config in dashboard Key: FLINK-2463 URL: https://issues.apache.org/jira/browse/FLINK-2463 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-1665) Add optional annotations for POJOs to specify the order of fields

[ https://issues.apache.org/jira/browse/FLINK-1665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651103#comment-14651103 ] Stephan Ewen commented on FLINK-1665: - Hmm, not sure I am a bit fan of that. We are

[jira] [Commented] (FLINK-2351) Deprecate config builders in InputFormats and Output formats

[ https://issues.apache.org/jira/browse/FLINK-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651088#comment-14651088 ] Stephan Ewen commented on FLINK-2351: - Exactly. The record API classes are deprecated

[jira] [Resolved] (FLINK-2463) Chow execution config in dashboard

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

[jira] [Closed] (FLINK-2434) org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a valid id pattern

[ https://issues.apache.org/jira/browse/FLINK-2434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2434. --- org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a

[jira] [Resolved] (FLINK-2434) org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a valid id pattern

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

[jira] [Commented] (FLINK-2450) IndexOutOfBoundsException in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-2450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651101#comment-14651101 ] Stephan Ewen commented on FLINK-2450: - I this a Kryo issue, or is the byte stream

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

[ https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651040#comment-14651040 ] Stephan Ewen commented on FLINK-2314: - This is a super critical issue. It requires

[jira] [Commented] (FLINK-2464) BufferSpillerTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651206#comment-14651206 ] Stephan Ewen commented on FLINK-2464: - I have seen a similar failure as well. It seems

[jira] [Resolved] (FLINK-2433) Jekyll on windows for building local documentation

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

[jira] [Closed] (FLINK-2433) Jekyll on windows for building local documentation

[ https://issues.apache.org/jira/browse/FLINK-2433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2433. --- Jekyll on windows for building local documentation --

[jira] [Commented] (FLINK-2468) StreamCheckpointingITCase failure

[ https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14653386#comment-14653386 ] Stephan Ewen commented on FLINK-2468: - Interestingly, we are not observing any

[jira] [Commented] (FLINK-2468) StreamCheckpointingITCase failure

[ https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14653417#comment-14653417 ] Stephan Ewen commented on FLINK-2468: - The assumption was that the {{Checkpointed}}

[jira] [Created] (FLINK-2484) BarrierBuffer does not properly clean up temp files

Stephan Ewen created FLINK-2484: --- Summary: BarrierBuffer does not properly clean up temp files Key: FLINK-2484 URL: https://issues.apache.org/jira/browse/FLINK-2484 Project: Flink Issue Type:

[jira] [Closed] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

[ https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2406. --- Abstract BarrierBuffer to an exchangeable BarrierHandler

[jira] [Resolved] (FLINK-2402) Add a non-blocking BarrierTracker

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

[jira] [Closed] (FLINK-2402) Add a non-blocking BarrierTracker

[ https://issues.apache.org/jira/browse/FLINK-2402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2402. --- Add a non-blocking BarrierTracker - Key: FLINK-2402

[jira] [Resolved] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

[ https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2406. - Resolution: Fixed Fixed via 0579f90bab165a7df336163eb9d6337267020029 Abstract BarrierBuffer to

[jira] [Resolved] (FLINK-2418) Add an end-to-end streaming fault tolerance test for the Checkpointed interface

[ https://issues.apache.org/jira/browse/FLINK-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2418. - Resolution: Fixed Fixed via a0556efb233f15c6985d17886372a8b4b00392b2 Add an end-to-end

[jira] [Closed] (FLINK-2418) Add an end-to-end streaming fault tolerance test for the Checkpointed interface

[ https://issues.apache.org/jira/browse/FLINK-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2418. --- Add an end-to-end streaming fault tolerance test for the Checkpointed interface

[jira] [Resolved] (FLINK-2420) OutputFlush thread in stream writers does not propagate exceptions

[ https://issues.apache.org/jira/browse/FLINK-2420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2420. - Resolution: Fixed Fixed via 8ba321332b994579f387add8bd0855bd29cb33ec OutputFlush thread in

[jira] [Resolved] (FLINK-2421) StreamRecordSerializer incorrectly duplicates and misses tests

[ https://issues.apache.org/jira/browse/FLINK-2421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2421. - Resolution: Fixed Fixed via 2d237e18a2f7cf21721340933c505bb518c4fc66 StreamRecordSerializer

[jira] [Closed] (FLINK-2421) StreamRecordSerializer incorrectly duplicates and misses tests

[ https://issues.apache.org/jira/browse/FLINK-2421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2421. --- StreamRecordSerializer incorrectly duplicates and misses tests

[jira] [Closed] (FLINK-2420) OutputFlush thread in stream writers does not propagate exceptions

[ https://issues.apache.org/jira/browse/FLINK-2420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2420. --- OutputFlush thread in stream writers does not propagate exceptions

[jira] [Commented] (FLINK-2424) InstantiationUtil.serializeObject(Object) does not close output stream

[ https://issues.apache.org/jira/browse/FLINK-2424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14645740#comment-14645740 ] Stephan Ewen commented on FLINK-2424: - oha, good one!

[jira] [Created] (FLINK-2421) StreamRecordSerializer incorrectly duplicates and misses tests

Stephan Ewen created FLINK-2421: --- Summary: StreamRecordSerializer incorrectly duplicates and misses tests Key: FLINK-2421 URL: https://issues.apache.org/jira/browse/FLINK-2421 Project: Flink

[jira] [Commented] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets

[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644576#comment-14644576 ] Stephan Ewen commented on FLINK-2361: - A fast way to check this is to run a variant

[jira] [Created] (FLINK-2427) Allow the BarrierBuffer to maintain multiple queues of blocked inputs

Stephan Ewen created FLINK-2427: --- Summary: Allow the BarrierBuffer to maintain multiple queues of blocked inputs Key: FLINK-2427 URL: https://issues.apache.org/jira/browse/FLINK-2427 Project: Flink

[jira] [Created] (FLINK-2428) Clean up unused properties in StreamConfig

Stephan Ewen created FLINK-2428: --- Summary: Clean up unused properties in StreamConfig Key: FLINK-2428 URL: https://issues.apache.org/jira/browse/FLINK-2428 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-2429) Remove the enableCheckpointing() without interval variant

[ https://issues.apache.org/jira/browse/FLINK-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2429: Description: I think it is not very obvious what the default checkpointing interval is. Also, when

[jira] [Updated] (FLINK-2429) Remove the enableCheckpointing() without interval variant

[ https://issues.apache.org/jira/browse/FLINK-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2429: Issue Type: Wish (was: Bug) Remove the enableCheckpointing() without interval variant

[jira] [Updated] (FLINK-2429) Remove the enableCheckpointing() without interval variant

[ https://issues.apache.org/jira/browse/FLINK-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2429: Priority: Minor (was: Major) Remove the enableCheckpointing() without interval variant

[jira] [Updated] (FLINK-2429) Remove the enableCheckpointing() without interval variant

[ https://issues.apache.org/jira/browse/FLINK-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2429: Description: It is not very obvious what the default checkpointing interval. Also, when somebody

[jira] [Assigned] (FLINK-2407) Add an API switch to select between exactly once and at least once fault tolerance

[ https://issues.apache.org/jira/browse/FLINK-2407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-2407: --- Assignee: Stephan Ewen Add an API switch to select between exactly once and at least once

[jira] [Commented] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment

[ https://issues.apache.org/jira/browse/FLINK-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14645997#comment-14645997 ] Stephan Ewen commented on FLINK-2425: - Ah, I think you are in the wrong issue ;-) That

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