Yes, it's only the first job preview that has a wrong parallelism. The
optimized plan and the job execution work just fine.
On Mon, Oct 26, 2015 at 3:11 PM, Maximilian Michels wrote:
> That's odd. Does it also execute with parallelism 36 then?
>
> On Mon, Oct 26, 2015 at 3:06 PM, Flavio Pomperma
That's odd. Does it also execute with parallelism 36 then?
On Mon, Oct 26, 2015 at 3:06 PM, Flavio Pompermaier
wrote:
> No, I just use the default parallelism
>
> On Mon, Oct 26, 2015 at 3:05 PM, Maximilian Michels
> wrote:
>
>> Did you set the default parallelism of the cluster to 36? This is
No, I just use the default parallelism
On Mon, Oct 26, 2015 at 3:05 PM, Maximilian Michels wrote:
> Did you set the default parallelism of the cluster to 36? This is because
> the plan gets optimized against the cluster configuration when you try to
> run the uploaded program. Before, it doesn't
Did you set the default parallelism of the cluster to 36? This is because
the plan gets optimized against the cluster configuration when you try to
run the uploaded program. Before, it doesn't do any optimization. This
might not be very intuitive. We should probably change that.
On Mon, Oct 26, 20
Now that I've recompiled flink and restarted the web-client everything
works fine.
However, when I flag the job I want to run I see parallelism 1 in the right
panel, but when I click on "Run Job" button + show optimizer plan flagged I
see parallelism 36. Is that a bug of the first preview?
On Mo
Correct. I'll fix it today.
Cheers,
Max
On Mon, Oct 26, 2015 at 9:08 AM, Flavio Pompermaier
wrote:
> Running from the shell everything works..is it a problem of classloaders
> hierarchy in the webapp?
>
> On Fri, Oct 23, 2015 at 5:53 PM, Maximilian Michels
> wrote:
>
>> ./bin/flink run /path/t
Running from the shell everything works..is it a problem of classloaders
hierarchy in the webapp?
On Fri, Oct 23, 2015 at 5:53 PM, Maximilian Michels wrote:
> ./bin/flink run /path/to/jar arguments
>
> or
>
> ./bin/flink run -c MainClass /path/to/jar arguments
>
> On Fri, Oct 23, 2015 at 5:50 PM
./bin/flink run /path/to/jar arguments
or
./bin/flink run -c MainClass /path/to/jar arguments
On Fri, Oct 23, 2015 at 5:50 PM, Stefano Bortoli
wrote:
> What I normally do is to
>
> java -cp MYUBERJAR.jar my.package.mainclass
>
> does it make sense?
>
> 2015-10-23 17:22 GMT+02:00 Flavio Pomperm
What I normally do is to
java -cp MYUBERJAR.jar my.package.mainclass
does it make sense?
2015-10-23 17:22 GMT+02:00 Flavio Pompermaier :
> could you write ne the command please?I'm not in the office right now..
> On 23 Oct 2015 17:10, "Maximilian Michels" wrote:
>
>> Could you try submitting t
could you write ne the command please?I'm not in the office right now..
On 23 Oct 2015 17:10, "Maximilian Michels" wrote:
> Could you try submitting the job from the command-line and see if it works?
>
> Thanks,
> Max
>
> On Fri, Oct 23, 2015 at 4:42 PM, Flavio Pompermaier
> wrote:
>
>> 0.10-sna
Could you try submitting the job from the command-line and see if it works?
Thanks,
Max
On Fri, Oct 23, 2015 at 4:42 PM, Flavio Pompermaier
wrote:
> 0.10-snapshot
> On 23 Oct 2015 16:09, "Maximilian Michels" wrote:
>
>> Hi Flavio,
>>
>> Which version of Flink are you using?
>>
>> Cheers,
>> Ma
0.10-snapshot
On 23 Oct 2015 16:09, "Maximilian Michels" wrote:
> Hi Flavio,
>
> Which version of Flink are you using?
>
> Cheers,
> Max
>
> On Fri, Oct 23, 2015 at 2:45 PM, Flavio Pompermaier
> wrote:
>
>> Hi to all,
>> I'm trying to run a job from the web interface but I get this error:
>>
>>
Hi Flavio,
Which version of Flink are you using?
Cheers,
Max
On Fri, Oct 23, 2015 at 2:45 PM, Flavio Pompermaier
wrote:
> Hi to all,
> I'm trying to run a job from the web interface but I get this error:
>
> java.lang.RuntimeException: java.io.FileNotFoundException: JAR entry
> core-site.xml
Hi to all,
I'm trying to run a job from the web interface but I get this error:
java.lang.RuntimeException: java.io.FileNotFoundException: JAR entry
core-site.xml not found in /tmp/webclient-jobs/EntitonsJsonizer.jar
at
org.apache.hadoop.conf.Configuration.loadResource(Configuration.java:
14 matches
Mail list logo