Hi, I am new to Apache Flink and I really like the look of the API. I have been working with Storm for the past year and have questions about the DataStream API among others.
1. What are the interactions of the actor system in the flink ecosystem? Where can I find more information? 2. Is there a Flink web UI in embedded mode? ( Not on cluster ) 3. Why is there a poll time min of 50ms for the Datastream API? 4. Is it possible to log each datastream to a separate file?( i.e. not all in the same task manager log ). 5. I checked out the master from git, but I am unable to build the project in Intellij, due to compilation errors in flink-staging. The root cause is lack of "generated" files of avro such as import org.apache.flink.api.io.avro.generated.Address; import org.apache.flink.api.io.avro.generated.Colors; import org.apache.flink.api.io.avro.generated.Fixed16; import org.apache.flink.api.io.avro.generated.User; These files are not being found. I have the avro plugin installed for Intellij. What else do I need to do to make the project build/compile? Appreciate the help! Best, Arjun
