Re: Job xxx not found exception when starting Flink program in Local

The web ui keeps job ids in web browsers. 徐涛 于2018年11月18日周日 上午8:12写道： > > Hi Chesnay, > Yes, it is. Later I notice before the later started cluster I have use > ./bin/start-cluster.sh to start a local cluster, and after I > ./bin/stop-cluster.sh to stop the cluster, the problem is gone. > But ho

Re: Last batch of stream data could not be sinked when data comes very slow

Hi Gordon, Later I found the implementation of the Elastic Search Sink provided by Flink, and I found it also use the mechanism to flush the data when checkpoints happens. I apply the method, now the problem is solved. It uses exactly the method you have provided. Thanks a lot for your h

Re: Job xxx not found exception when starting Flink program in Local

Hi Chesnay, Yes, it is. Later I notice before the later started cluster I have use ./bin/start-cluster.sh to start a local cluster, and after I ./bin/stop-cluster.sh to stop the cluster, the problem is gone. But how the later started cluster know there is a job in the former star

Flink with Yarn and AbstractDeserializationSchema: ClassCastException

Hi, I'm using the AbstractDeserializationSchema for my RabbitMQ source[1] and try to deserialize the xml message with JAXB. The flink job are running with YARN. After the job was started I get follow exception: javax.xml.bind.JAXBException: ClassCastException: attempting to cast jar:file:/usr/jav