Re: Network PartitionNotFoundException when run on multi nodes

ed > from JobManager, or some operations in upstream task initialization > unexpectly cost more time before registering result partition. > > Best, > Zhijiang > ------ > 发件人：Steffen Wohlers > 发送时间：2018年7月22日(星期日)

Network PartitionNotFoundException when run on multi nodes

Hi all, I have some problems when running my application on more than one Task Manager. setup: node1: Job Manager, Task Manager node2: Task Manager I can run my program successfully on each node alone when I stop the other Task Manager. But when I start both and set parallelism = 2, every time

Re: data enrichment via endpoint, serializable issue

ts in its > `open()` method. > > [1] > https://ci.apache.org/projects/flink/flink-docs-master/dev/api_concepts.html#rich-functions > > <https://ci.apache.org/projects/flink/flink-docs-master/dev/api_concepts.html#rich-functions> > > Best, > Xingcan

data enrichment via endpoint, serializable issue

Hi all, I’m new to Apache Flink and I have the following issue: I would like to enrich data via map function. For that I call a method which calls an endpoint but I get following error message „The implementation of the MapFunction is not serializable. The object probably contains or referenc