Re: Requesting the next InputSplit failed

2016-04-29 Thread Stefano Bortoli
>>>>>> 2016-04-28 9:22 GMT+02:00 Stefano Bortoli : >>>>>>>> >>>>>>>>> I had this type of exception when trying to build and test Flink >>>>>>>>> on a "small machine&

Re: Requesting the next InputSplit failed

2016-04-28 Thread Fabian Hueske
gt;>>>>> I had this type of exception when trying to build and test Flink on >>>>>>>> a "small machine". I worked around the test increasing the timeout for >>>>>>>> Ak

Re: Requesting the next InputSplit failed

2016-04-28 Thread Flavio Pompermaier
>>>>>> https://github.com/stefanobortoli/flink/blob/FLINK-1827/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeAllWindowCheckpointingITCase.java >>>>>>> >>>>>>> it happened only on my machine (a VirtualBox I u

Re: Requesting the next InputSplit failed

2016-04-28 Thread Fabian Hueske
Is it possible that on load situations the >>>>>> JobManager >>>>>> slows down a bit too much? >>>>>> >>>>>> saluti, >>>>>> Stefano >>>>>> >>>>>> 2016-04-27 17:50 GMT+02:00 Flavio Pompermaier :

Re: Requesting the next InputSplit failed

2016-04-28 Thread Flavio Pompermaier
that on load situations the JobManager >>>>> slows down a bit too much? >>>>> >>>>> saluti, >>>>> Stefano >>>>> >>>>> 2016-04-27 17:50 GMT+02:00 Flavio Pompermaier : >>>>> >>>&g

Re: Requesting the next InputSplit failed

2016-04-28 Thread Fabian Hueske
0 GMT+02:00 Flavio Pompermaier : >>>> >>>>> A precursor of the modified connector (since we started a long time >>>>> ago). However the idea is the same, I compute the inputSplits and then I >>>>> get the data split by split (similarly to

Re: Requesting the next InputSplit failed

2016-04-28 Thread Flavio Pompermaier
o what it happens in FLINK-3750 - >>>> https://github.com/apache/flink/pull/1941 ) >>>> >>>> Best, >>>> Flavio >>>> >>>> On Wed, Apr 27, 2016 at 5:38 PM, Chesnay Schepler >>>> wrote: >>>> >&g

Re: Requesting the next InputSplit failed

2016-04-28 Thread Fabian Hueske
esnay Schepler >>> wrote: >>> >>>> Are you using your modified connector or the currently available one? >>>> >>>> >>>> On 27.04.2016 17:35, Flavio Pompermaier wrote: >>>> >>>> Hi to all, >>>> I'

Re: Requesting the next InputSplit failed

2016-04-28 Thread Stefano Bortoli
wrote: >>> >>> Hi to all, >>> I'm running a Flink Job on a JDBC datasource and I obtain the following >>> exception: >>> >>> java.lang.RuntimeException: Requesting the next InputSplit faile

Re: Requesting the next InputSplit failed

2016-04-28 Thread Stefano Bortoli
2016 at 5:38 PM, Chesnay Schepler > wrote: > >> Are you using your modified connector or the currently available one? >> >> >> On 27.04.2016 17:35, Flavio Pompermaier wrote: >> >> Hi to all, >> I'm running a Flink Job on a JDBC datasource and I obta

Re: Requesting the next InputSplit failed

2016-04-27 Thread Flavio Pompermaier
gt; > java.lang.RuntimeException: Requesting the next InputSplit failed. > at > org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91) > at > org.apache.flink.runtime.operators.DataSou

Re: Requesting the next InputSplit failed

2016-04-27 Thread Chesnay Schepler
Are you using your modified connector or the currently available one? On 27.04.2016 17:35, Flavio Pompermaier wrote: Hi to all, I'm running a Flink Job on a JDBC datasource and I obtain the following exception: java.lang.RuntimeException: Requesting the next InputSplit faile

Requesting the next InputSplit failed

2016-04-27 Thread Flavio Pompermaier
Hi to all, I'm running a Flink Job on a JDBC datasource and I obtain the following exception: java.lang.RuntimeException: Requesting the next InputSplit failed. at org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:9