Memory management in Flink

2015-03-13 Thread Emmanuel
Hello, In Storm, when running a new topology, a new JVM is started and this takes some memory. In my use case, I may need to run many different topologies. How does it work in Flink? Is the Flink run command spinning a new JVM each time?If I run multiple topologies it seems like the additional pr

Re: IDE indicates the data type error of my Filter operator in Scala

2015-03-13 Thread HungChang
Thank you. Your explanation helps me to understand more. -- View this message in context: http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/IDE-indicates-the-data-type-error-of-my-Filter-operator-in-Scala-tp820p838.html Sent from the Apache Flink (Incubator) User Mai