Ben Sidhom created BEAM-4285:
--------------------------------
Summary: Flink batch state request handler
Key: BEAM-4285
URL: https://issues.apache.org/jira/browse/BEAM-4285
Project: Beam
Issue Type: Bug
Components: runner-flink
Reporter: Ben Sidhom
In order to support side inputs Flink needs a state service request handler. As
in the non-portable we can start by handling batch side inputs by Flink
broadcast variables.
[https://github.com/bsidhom/beam/blob/41de3bce60f1ebc9211f299612a20d8e561f9b6f/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkBatchStateRequestHandler.java]
or
[https://github.com/bsidhom/beam/blob/41de3bce60f1ebc9211f299612a20d8e561f9b6f/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkBatchStateRequestHandler.java]
can be used as a starting point.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
