I have put the task manager of the data sink log to
https://gist.github.com/yinhua2018/7de42ff9c1738d5fdf9d99030db903e2
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi Qi,
I checked the JVM heap of the sink TM is low.
I tried to read flink source code to identify where is exact the error
happen.
I think the exception happened inside DataSinkTask.invoke()
// work!
while (!this.taskCanceled && ((
Hi Yinhua,
This looks like the TM executing the sink is down, maybe due to OOM or some
other error. You can check the JVM heap and GC log to see if there’re any clues.
Regards,
Qi
> On Mar 28, 2019, at 7:23 PM, yinhua.dai wrote:
>
> Hi,
>
> I write a single flink job with flink SQL with vers
Hi,
I write a single flink job with flink SQL with version 1.6.1
I have one table source which read data from a database, and one table sink
to output as avro format file.
The table source has parallelism of 19, and table sink only has parallelism
of 1.
But there is always RemoteTransportExceptio
