Flink savepoints - Confused

2017-07-21 Thread chouicha
All: Based on flink 1.2 doc, savepoints are generated manually when running "flink savepoint jobId". But in my cluster I see 1000s of files in the form of e.g "savepoint-777cce9b". Who is creating these savepoints? -- View this message in context: http://apache-flink-mailing-list-archive.10

Re: 4 DataStream using RichCoFlatMapFunction

2017-06-26 Thread chouicha
All: If I want to connect to 4 streams using RichCoFlatMapFunction. How I can do this. RichCoFlatMapFunction only support connecting 2 datastream. Thanks. -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/4-DataStream-using-RichCoFlatMapFunction-tp1