Re: Nested Iterations supported in Flink?

2015-04-14 Thread Benoît Hanotte
ted iterations. Can you write your program as one iterations (the inner) and start the program multiple times to simulate the nesting? Greetings, Stephan On Tue, Apr 14, 2015 at 8:11 AM, Benoît Hanotte wrote: Hello, I'm implementing an algorithm which requires nested iterations, and,

Nested Iterations supported in Flink?

2015-04-13 Thread Benoît Hanotte
Hello, I'm implementing an algorithm which requires nested iterations, and, from what I understood, this feature was not yet available in Flink [1], and my experiments with 2 nested bulk iterations seem to confirm that. However I came across a Flink unit test [2] using nested iterations, so

PotsgreSQL JDBC Sink, "writeRecord() failed" and "Batch element cancelled" on upsert

2015-01-14 Thread Benoît Hanotte
Hi, I'm trying to use a spatial PostgreSQL with PostGIS database as a Sink for my data. It works perfectly when performing an INSERT with my data, but when trying to perform an UPSERT it fails with the following errors: 15/01/14 12:52:08 ERROR operators.DataSinkTask: Error in user code: w