Hi there,
is there a canonical / suggested way to customize the classpath of the
Flink JM and TM processes?
At the moment I hardcoded my way around this by manually changing the
following lines like that:
# in taskmanager.sh
$JAVA_RUN [...] -classpath "/tmp/classes:$FLINK_TM_CLASSPATH"
# in job
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
