Re: Failing Test

2015-07-16 Thread Matthias J. Sax
Hi, the test still fails. This time in both runs (Flink Travis and my own Travis) -- only for Java 8 again: https://travis-ci.org/apache/flink/jobs/71314132 https://travis-ci.org/mjsax/flink/jobs/71179608 -Matthias On 07/16/2015 02:28 PM, Matthias J. Sax wrote: > Great! I will. As 4 of 5 runs

[jira] [Created] (FLINK-2370) Unify Client Code

2015-07-16 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2370: -- Summary: Unify Client Code Key: FLINK-2370 URL: https://issues.apache.org/jira/browse/FLINK-2370 Project: Flink Issue Type: Improvement Repor

Exception during job submission in RemoteEnvironment

2015-07-16 Thread Andreas Kunft
Hello, I want to execute a Job from Java on an already running instance of Flink. I connect via the RemoteEnvironment. Everything goes fine, but then I get an exception from akka telling me the payload size is exceeded: 15-07-16 17:47:27 [ERROR] Transient association error (association remai

Re: [DISCUSS] Unifying client code

2015-07-16 Thread Fabian Hueske
Yes definitely. The client and submission code is spread out over multiple classes and different clients follow different paths. This is a bit messy right now, IMO. A big +1 to unify and restructure the client. 2015-07-16 17:52 GMT+02:00 Till Rohrmann : > I like the idea to have a single point of

Re: [DISCUSS] Unifying client code

2015-07-16 Thread Till Rohrmann
I like the idea to have a single point of access. That would improve maintainability and makes the code easier to understand. Thus +1. On Thu, Jul 16, 2015 at 4:45 PM, Matthias J. Sax < mj...@informatik.hu-berlin.de> wrote: > Hi, > > I just had a look into CliFrontend and Client and it seems to m

[jira] [Created] (FLINK-2369) On Windows, in testFailingSortingDataSinkTask the temp file is not removed

2015-07-16 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-2369: -- Summary: On Windows, in testFailingSortingDataSinkTask the temp file is not removed Key: FLINK-2369 URL: https://issues.apache.org/jira/browse/FLINK-2369 Project: Flink

[DISCUSS] Unifying client code

2015-07-16 Thread Matthias J. Sax
Hi, I just had a look into CliFrontend and Client and it seems to me, that there is no uniform design. For example, CliFrontend uses Client to execute "run" and "info" command. However, for "cancel" and "list" it does not (because org.apache.flink.client.program.Client) lacks those methods. I wo

[jira] [Created] (FLINK-2368) Add a convergence criteria

2015-07-16 Thread Sachin Goel (JIRA)
Sachin Goel created FLINK-2368: -- Summary: Add a convergence criteria Key: FLINK-2368 URL: https://issues.apache.org/jira/browse/FLINK-2368 Project: Flink Issue Type: Bug Components: Ma

Extending StreamExecutionEnvironment

2015-07-16 Thread Matthias J. Sax
Hi, currently, StreamExecutionEnvironment runs programs in a blocking fashion, ie, it expects a job to finish by itself. However, streaming jobs might run infinitely. With the upcoming STOP signal, I would recommend to extend StreamExecutionEnvironment such that a job can be executed in a detache

Re: Failing Test

2015-07-16 Thread Matthias J. Sax
Great! I will. As 4 of 5 runs succeeded I cannot test explicitly. Will have an eye on it in future runs. -Matthias On 07/16/2015 02:24 PM, Maximilian Michels wrote: > Hi Matthias, > > I've pushed a fix to the master. The problem should be solved. Please tell > me if your Travis reports an error

Re: Failing Test

2015-07-16 Thread Maximilian Michels
Hi Matthias, I've pushed a fix to the master. The problem should be solved. Please tell me if your Travis reports an error again. My Travis never complained :) Cheers, Max On Thu, Jul 16, 2015 at 12:00 PM, Maximilian Michels wrote: > Hi Matthias, > > This is indeed a timing issue when checking

[jira] [Created] (FLINK-2367) “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected after mistaking delete

2015-07-16 Thread chenliang (JIRA)
chenliang created FLINK-2367: Summary: “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected after mistaking delete Key: FLINK-2367 URL: https://issues.apache.org/jira/browse/FLINK-2367

Re: Failing Test

2015-07-16 Thread Maximilian Michels
Hi Matthias, This is indeed a timing issue when checking for the results in this test. The new accumulator implementation now continuously reports from the running tasks to the job manager. This was merged yesterday. The assertion that fails there is a bit strict. Actually, I've already integrate

Re: Failing Test

2015-07-16 Thread Ufuk Celebi
Hey, this has been merged yesterday. I guess it's a timing issue when verifying the results. Can you file an issue for this? – Ufuk On 16 Jul 2015, at 11:30, Matthias J. Sax wrote: > Hi, > > I hit another failing test (that is new to me): > >> Results : >> Failed tests: >> AccumulatorLiveIT

Failing Test

2015-07-16 Thread Matthias J. Sax
Hi, I hit another failing test (that is new to me): > Results : > Failed tests: > AccumulatorLiveITCase.testProgram:106->access$1100:68->checkFlinkAccumulators:189 > null > Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 8.694 sec <<< > FAILURE! - in org.apache.flink.test.accu

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

2015-07-16 Thread Suminda Dharmasena (JIRA)
Suminda Dharmasena created FLINK-2366: - Summary: HA Without ZooKeeper Key: FLINK-2366 URL: https://issues.apache.org/jira/browse/FLINK-2366 Project: Flink Issue Type: Bug Repo