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

2015-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14646019#comment-14646019 ] Stephan Ewen commented on FLINK-2425: - The TaskManager configuration object needs only

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

2015-07-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2429: --- Summary: Remove the enableCheckpointing() without interval variant Key: FLINK-2429 URL: https://issues.apache.org/jira/browse/FLINK-2429 Project: Flink Issue

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

2015-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14646029#comment-14646029 ] Stephan Ewen commented on FLINK-2425: - How about opening a pull request for the

[jira] [Commented] (FLINK-2106) Add outer joins to API, Optimizer, and Runtime

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14655236#comment-14655236 ] Stephan Ewen commented on FLINK-2106: - Have a look here as well:

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

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2459. - Resolution: Fixed Fix Version/s: 0.10 Fixed via 81f9b214a37aa81017eface6ba43f24f845a4ec8

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

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2459. --- Failure on recently added Client side logging test --

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

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14658394#comment-14658394 ] Stephan Ewen commented on FLINK-2468: - I think I caught the issue in a pending fix,

[jira] [Commented] (FLINK-2466) Travis build failure

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14658396#comment-14658396 ] Stephan Ewen commented on FLINK-2466: - Found the problem, fix pending tests...

[jira] [Resolved] (FLINK-885) Task cancellation fails in TempBarrier.close()

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-885. Resolution: Cannot Reproduce Fix Version/s: (was: pre-apache) This is related to a much

[jira] [Closed] (FLINK-885) Task cancellation fails in TempBarrier.close()

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-885. -- Task cancellation fails in TempBarrier.close() --

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

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2464. --- BufferSpillerTest sometimes fails - Key: FLINK-2464

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

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2464. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 0.10 Fixed via

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

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2484. --- BarrierBuffer does not properly clean up temp files ---

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

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2484. - Resolution: Fixed Fixed via d738430cb7e26b5e31d953efa5e0036082d8de6e BarrierBuffer does not

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

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2468. - Resolution: Fixed Fix Version/s: 0.10 Fixed via d738430cb7e26b5e31d953efa5e0036082d8de6e

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

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2468. --- StreamCheckpointingITCase failure - Key: FLINK-2468

[jira] [Resolved] (FLINK-2466) Travis build failure

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2466. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 0.10 Fixed via

[jira] [Closed] (FLINK-2466) Travis build failure

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2466. --- Travis build failure Key: FLINK-2466 URL:

[jira] [Resolved] (FLINK-2360) EOFException

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2360. - Resolution: Duplicate Fix Version/s: (was: 0.9.1) (was: 0.10)

[jira] [Created] (FLINK-2489) Improve the streaming window join

2015-08-05 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2489: --- Summary: Improve the streaming window join Key: FLINK-2489 URL: https://issues.apache.org/jira/browse/FLINK-2489 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2489) Improve the streaming window join

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14658779#comment-14658779 ] Stephan Ewen commented on FLINK-2489: - Here is a wiki page stub for further

[jira] [Closed] (FLINK-2361) CompactingHashTable loses entries

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2361. --- CompactingHashTable loses entries - Key: FLINK-2361

[jira] [Resolved] (FLINK-2361) CompactingHashTable loses entries

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2361. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 0.9.1

[jira] [Resolved] (FLINK-1916) EOFException when running delta-iteration job

2015-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1916. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 0.9.1

[jira] [Commented] (FLINK-2466) Travis build failure

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651714#comment-14651714 ] Stephan Ewen commented on FLINK-2466: - Okay, that is a good catch... Travis build

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

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651688#comment-14651688 ] Stephan Ewen commented on FLINK-1665: - You can always specify order the following way:

[jira] [Commented] (FLINK-2466) Travis build failure

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651659#comment-14651659 ] Stephan Ewen commented on FLINK-2466: - Do you know which test cause the kill? A kill

[jira] [Commented] (FLINK-2466) Travis build failure

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651680#comment-14651680 ] Stephan Ewen commented on FLINK-2466: - I don't think it is that test. It just happens

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

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14651546#comment-14651546 ] Stephan Ewen commented on FLINK-2464: - Just ran the {{BufferSpillerTest}} for 10h in a

[jira] [Closed] (FLINK-2473) Add a timeout to ActorSystem shutdown in the Client

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2473. --- Add a timeout to ActorSystem shutdown in the Client ---

[jira] [Resolved] (FLINK-2473) Add a timeout to ActorSystem shutdown in the Client

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2473. - Resolution: Fixed Trivial fix via 2cff89ed93bbacf8d054399514c1ca4fb8b24730 Add a timeout to

[jira] [Closed] (FLINK-2426) Create a read-only variant of the Configuration

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2426. --- Create a read-only variant of the Configuration ---

[jira] [Created] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase

2015-08-03 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2474: --- Summary: Occasional failures in PartitionedStateCheckpointingITCase Key: FLINK-2474 URL: https://issues.apache.org/jira/browse/FLINK-2474 Project: Flink Issue

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

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2425. - Resolution: Fixed Fixed via 8eb9cbf88111b0375860a3965e093a736455db79 and

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

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2425. --- Give access to TaskManager config and hostname in the Runtime Environment

[jira] [Closed] (FLINK-2465) SocketClientSink closeConnection function has memory leak

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2465. --- SocketClientSink closeConnection function has memory leak

[jira] [Resolved] (FLINK-2465) SocketClientSink closeConnection function has memory leak

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2465. - Resolution: Fixed Fix Version/s: 0.10 Fixed via b08e30ad9a39ed9885f4daa05a08d13eb22ebb8c

[jira] [Resolved] (FLINK-2322) Unclosed stream may leak resource

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2322. - Resolution: Fixed Fix Version/s: 0.10 Fixed in 0693c92bdda655e1fbce232038909a7c2a385a22

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

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14652119#comment-14652119 ] Stephan Ewen commented on FLINK-2464: - Can you paste the build on which that happened?

[jira] [Created] (FLINK-2473) Add a timeout to ActorSystem shutdown in the Client

2015-08-03 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2473: --- Summary: Add a timeout to ActorSystem shutdown in the Client Key: FLINK-2473 URL: https://issues.apache.org/jira/browse/FLINK-2473 Project: Flink Issue Type:

[jira] [Closed] (FLINK-2456) The flink-hbase module dependencies hadoop-2 specifies a repository ID

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2456. --- The flink-hbase module dependencies hadoop-2 specifies a repository ID

[jira] [Resolved] (FLINK-2456) The flink-hbase module dependencies hadoop-2 specifies a repository ID

2015-08-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2456. - Resolution: Fixed Merged in 949ff8dae6deb58229367bdcf199336c92399c27 The flink-hbase module

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

2015-07-30 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2438: --- Summary: Improve performance of channel events Key: FLINK-2438 URL: https://issues.apache.org/jira/browse/FLINK-2438 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2391. --- Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

[jira] [Resolved] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2391. - Resolution: Fixed Fixed in ada9037bef760d46a4c3be2177e04bd72e620dad Thank you for the patch!

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

2015-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14645984#comment-14645984 ] Stephan Ewen commented on FLINK-2425: - Could you describe in a few lines how you mean

[jira] [Closed] (FLINK-2502) FiniteStormSpout documenation does not render correclty

2015-08-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2502. --- FiniteStormSpout documenation does not render correclty

[jira] [Resolved] (FLINK-2502) FiniteStormSpout documenation does not render correclty

2015-08-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2502. - Resolution: Fixed Fix Version/s: 0.10 Fixed via 5bb855bac7441701495ce47db7ba03ab0e0c6963

[jira] [Created] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment

2015-08-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2508: --- Summary: Confusing sharing of StreamExecutionEnvironment Key: FLINK-2508 URL: https://issues.apache.org/jira/browse/FLINK-2508 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-2500) Some reviews to improve code quality

2015-08-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2500. --- Some reviews to improve code quality Key:

[jira] [Resolved] (FLINK-2500) Some reviews to improve code quality

2015-08-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2500. - Resolution: Fixed Fixed via b42fbf7a81c5b57dcf9760825edb175ffd944fb2 Thank you for the

[jira] [Resolved] (FLINK-2277) In Scala API delta Iterations can not be set to unmanaged

2015-08-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2277. - Resolution: Fixed Fix Version/s: 0.10 Fixed via f50ae26a2fb4a0c7f5b390e2f0f5528be9f61730

[jira] [Closed] (FLINK-2277) In Scala API delta Iterations can not be set to unmanaged

2015-08-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2277. --- In Scala API delta Iterations can not be set to unmanaged

[jira] [Created] (FLINK-2509) Improve error messages when user code classes are not found

2015-08-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2509: --- Summary: Improve error messages when user code classes are not found Key: FLINK-2509 URL: https://issues.apache.org/jira/browse/FLINK-2509 Project: Flink

[jira] [Commented] (FLINK-2501) [py] Remove the need to specify types for transformations

2015-08-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14681906#comment-14681906 ] Stephan Ewen commented on FLINK-2501: - Can the Java API always think as Tuple2

[jira] [Commented] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster

2015-08-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14681994#comment-14681994 ] Stephan Ewen commented on FLINK-2510: - Currently blocked by [FLINK-2386]

[jira] [Created] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster

2015-08-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2510: --- Summary: KafkaConnector should access partition metadata from master/cluster Key: FLINK-2510 URL: https://issues.apache.org/jira/browse/FLINK-2510 Project: Flink

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

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2464. - Resolution: Duplicate Problem is tracked in [FLINK-2466] BufferSpillerTest sometimes fails

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

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2464. --- BufferSpillerTest sometimes fails - Key: FLINK-2464

[jira] [Commented] (FLINK-2466) Travis build failure

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659928#comment-14659928 ] Stephan Ewen commented on FLINK-2466: - If someone could double check whether they see

[jira] [Comment Edited] (FLINK-2466) Travis build failure

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659928#comment-14659928 ] Stephan Ewen edited comment on FLINK-2466 at 8/6/15 12:29 PM: --

[jira] [Commented] (FLINK-2466) Travis build failure

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659904#comment-14659904 ] Stephan Ewen commented on FLINK-2466: - It is the BarrierBufferMassiveRandomTest again.

[jira] [Created] (FLINK-2492) Rename remaining runtime classes from match to join

2015-08-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2492: --- Summary: Rename remaining runtime classes from match to join Key: FLINK-2492 URL: https://issues.apache.org/jira/browse/FLINK-2492 Project: Flink Issue Type:

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

2015-08-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2493: --- Summary: Simplify names of example program JARs Key: FLINK-2493 URL: https://issues.apache.org/jira/browse/FLINK-2493 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-100) Pact API Proposal: Add keyless CoGroup (send all to a single group)

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-100. -- Pact API Proposal: Add keyless CoGroup (send all to a single group)

[jira] [Resolved] (FLINK-202) Workset Iterations: No Match Found Behaviour of Solution Set Join

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-202. Resolution: Fixed Fix Version/s: (was: pre-apache) 0.8.0 Solution set

[jira] [Commented] (FLINK-655) Add support for both single and set of broadcast values

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660395#comment-14660395 ] Stephan Ewen commented on FLINK-655: Will this still be done, or should we close it as

[jira] [Resolved] (FLINK-915) Introduce two in one progress bars

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-915. Resolution: Invalid Fix Version/s: (was: pre-apache) Outdated and subsumed by new Task

[jira] [Closed] (FLINK-915) Introduce two in one progress bars

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-915. -- Introduce two in one progress bars -- Key: FLINK-915

[jira] [Resolved] (FLINK-1082) WebClient improvements

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1082. - Resolution: Done Remaining issues will not be fixed. Remainder is subsumed by new web frontend

[jira] [Resolved] (FLINK-1083) WebInterface improvements

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1083. - Resolution: Done Remainder is subsumed by new web frontend [FLINK-2357] WebInterface

[jira] [Closed] (FLINK-1082) WebClient improvements

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1082. --- WebClient improvements -- Key: FLINK-1082 URL:

[jira] [Updated] (FLINK-7) [GitHub] Enable Range Partitioner

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7: - Issue Type: Sub-task (was: New Feature) Parent: FLINK-598 [GitHub] Enable Range Partitioner

[jira] [Closed] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-938. -- Change start-cluster.sh script so that users don't have to configure the JobManager address

[jira] [Resolved] (FLINK-266) Warn user if cluster did not come up as expected

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-266. Resolution: Won't Fix Fix Version/s: (was: pre-apache) The deployment model is different

[jira] [Closed] (FLINK-202) Workset Iterations: No Match Found Behaviour of Solution Set Join

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-202. -- Workset Iterations: No Match Found Behaviour of Solution Set Join

[jira] [Closed] (FLINK-266) Warn user if cluster did not come up as expected

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-266. -- Warn user if cluster did not come up as expected

[jira] [Resolved] (FLINK-2492) Rename remaining runtime classes from match to join

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2492. - Resolution: Fixed Fixed via 685086a3dd9afcec2eec76485298bc7b3f031a3c Rename remaining runtime

[jira] [Closed] (FLINK-2492) Rename remaining runtime classes from match to join

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2492. --- Rename remaining runtime classes from match to join

[jira] [Resolved] (FLINK-854) Web interface: show runtime of subtasks

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-854. Resolution: Won't Fix Fix Version/s: (was: pre-apache) Subsumed by effort for the new web

[jira] [Closed] (FLINK-854) Web interface: show runtime of subtasks

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-854. -- Web interface: show runtime of subtasks --- Key:

[jira] [Resolved] (FLINK-871) Create a documentation distribution together with other release artifacts

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-871. Resolution: Fixed Fix Version/s: (was: pre-apache) Documentation is part of the source

[jira] [Resolved] (FLINK-1013) ArithmeticException: / by zero in MutableHashTable

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1013. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 0.9 Fixed already a while

[jira] [Closed] (FLINK-1013) ArithmeticException: / by zero in MutableHashTable

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1013. --- ArithmeticException: / by zero in MutableHashTable --

[jira] [Resolved] (FLINK-509) Move virtual machines building process / hosting to Amazon S3 / EC2

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-509. Resolution: Invalid Fix Version/s: (was: pre-apache) No virtual machine images are built

[jira] [Closed] (FLINK-509) Move virtual machines building process / hosting to Amazon S3 / EC2

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-509. -- Move virtual machines building process / hosting to Amazon S3 / EC2

[jira] [Closed] (FLINK-848) Move combine() from GroupReduceFunction to Interface

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-848. -- Move combine() from GroupReduceFunction to Interface

[jira] [Resolved] (FLINK-848) Move combine() from GroupReduceFunction to Interface

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-848. Resolution: Fixed Fix Version/s: (was: pre-apache) 0.7.1-incubating

[jira] [Closed] (FLINK-701) Change new Java API functions to SAMs

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-701. -- Change new Java API functions to SAMs - Key:

[jira] [Closed] (FLINK-967) Make intermediate results a first-class citizen in the JobGraph

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-967. -- Make intermediate results a first-class citizen in the JobGraph

[jira] [Commented] (FLINK-981) Support for generated Cloudera Hadoop configuration

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660484#comment-14660484 ] Stephan Ewen commented on FLINK-981: Is this still valid, or is this fixed already by

[jira] [Resolved] (FLINK-1116) Packaged Scala Examples do not work due to missing test data

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1116. - Resolution: Invalid Scala examples are not packaged any more (redundancy with java examples)

[jira] [Closed] (FLINK-1116) Packaged Scala Examples do not work due to missing test data

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1116. --- Packaged Scala Examples do not work due to missing test data

[jira] [Closed] (FLINK-1083) WebInterface improvements

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1083. --- WebInterface improvements - Key: FLINK-1083

[jira] [Commented] (FLINK-1135) Blog post with topic Accessing Data Stored in Hive with Flink

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660516#comment-14660516 ] Stephan Ewen commented on FLINK-1135: - I this still going to happen? Blog post with

[jira] [Resolved] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2240. - Resolution: Implemented Fix Version/s: 0.10 Implemented in

[jira] [Closed] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2240. --- Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

[jira] [Updated] (FLINK-553) Add getGroupKey() method to group-at-time operators

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-553: --- Assignee: Fabian Hueske Add getGroupKey() method to group-at-time operators

[jira] [Commented] (FLINK-553) Add getGroupKey() method to group-at-time operators

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660388#comment-14660388 ] Stephan Ewen commented on FLINK-553: There is an almost ready solution by [~fhueske]

[jira] [Updated] (FLINK-553) Add getGroupKey() method to group-at-time operators

2015-08-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-553: --- Fix Version/s: (was: pre-apache) Add getGroupKey() method to group-at-time operators

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