Thomas Groh created BEAM-723:
--------------------------------
Summary: Provide a runner-internal ExecutorService for maintenance
tasks
Key: BEAM-723
URL: https://issues.apache.org/jira/browse/BEAM-723
Project: Beam
Issue Type: Improvement
Components: runner-direct
Reporter: Thomas Groh
Assignee: Davor Bonaci
Priority: Minor
There are multiple locations throughout the DirectRunner that require some work
to be done at some later point (e.g. DirectMetrics.COUNTER_COMMITTER,
EvaluationContext.watermarkCallbackExecutor). These should use a common
ExecutorService to ensure that if necessary we can manage the shared JVM
resources properly.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)