Hello everybody
I am truing to build a very simple streaming application with the nightly build
of flink 0.10, my code runs fine in eclipse.
But when I build and deploy the jar locally I always get
java.lang.ClassNotFoundException: com.otter.ist.flink.DaoJoin$1
There is also no plan visible in
r classes are in the jar file?
On Thu, Aug 6, 2015 at 11:08 AM, Michael Huelfenhaus
mailto:m.huelfenh...@davengo.com>> wrote:
Hello everybody
I am truing to build a very simple streaming application with the nightly build
of flink 0.10, my code runs fine in eclipse.
But when I build and
I am back at work next Tuesday, any further ideas would be great until then,
for now I am continuing inside ecplise.
Am 06.08.2015 um 11:27 schrieb Michael Huelfenhaus
mailto:m.huelfenh...@davengo.com>>:
hi,
how did you build the jar file?
mvn clean install -Pbuild-jar
Have you c
> But your error message says
>>
>>> ClassNotFoundException: com.otter.ist.flink.DaoJoin$1
>>
>> Both are different packages. Your jar seems not be correctly packaged.
>>
>>
>> -Matthias
>>
>> On 08/06/2015 12:46 PM, Michael Huelfenhaus wrote:
>>> I a
check in the TaskManager log whether you see an entry that it
downloads or pulls the BLOB (here the jar file) from the JobManager?
Thanks,
Stephan
On Tue, Aug 11, 2015 at 1:04 PM, Michael Huelfenhaus
mailto:m.huelfenh...@davengo.com>> wrote:
I tried this before without success.
Same e
11.08.2015 um 15:29 schrieb Michael Huelfenhaus
mailto:m.huelfenh...@davengo.com>>:
Hey Stephan
the error disappeared after restarting the computer.
now I got another one but this is also strange because the program ran once
successful and is now failing again without me knowingly ch
m to a part where the plan is created (for
visualization), but the program is not executed.
Apparently this logic is a bit broken in the latest version, or you are
catching and re-throwing the exception.
On Tue, Aug 11, 2015 at 3:44 PM, Michael Huelfenhaus
mailto:m.huelfenh...@davengo.com>&
Hello
I have a question about the programming of user defined functions, is it still
like in old Stratosphere times the case that object creation should be avoided
al all cost? Because in some of the examples there are now Tuples and other
objects created before returning them.
I gonna have an
t;p.f = s;
> }
> }
>
> do:
>
> class Mapper implements MapFunction {
> private Pojo p = new Pojo();
> public Pojo map(String s) {
>p.f = s;
> }
> }
>
> Then an object is only created once per Mapper and not per record.
>
> Hope this helps.
>
