Details
-
New Feature
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
None
-
None
-
None
Description
In Bolt.execute(Tuple input) the given input tuple contains meta information about its origin (like source component name, stream id, source task ID).
This meta information in currently not provided by Flink and the corresponding methods throw an UnsupportedOperationException.