Hi
I am a CS PhD student at UMN Twin Cities. I am trying to use Flink for
implementing some very specific use-cases: (They may not seem relevant but I
need to implement them or I at least need to know if it is possible to
implement them in Flink)
Assumptions:
1. Data stream is of the form (key
Stephan,
That would be helpful. On job manager side, entry class provides such an
entry point hook. The problem is on the task manager side, where we don't
have such an initialization/entry point.
I have brought up the same question 3 months ago in this list with subject
"entrypoint for executing
