We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9bad81b commit aaa59c1Copy full SHA for aaa59c1
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java
@@ -276,8 +276,7 @@ public static void main(
276
277
IdGenerator idGenerator = IdGenerators.decrementingLongs();
278
ShortIdMap metricsShortIds = new ShortIdMap();
279
- UnboundedScheduledExecutorService executorService =
280
- new UnboundedScheduledExecutorService();
+ UnboundedScheduledExecutorService executorService = new UnboundedScheduledExecutorService();
281
options.as(ExecutorOptions.class).setScheduledExecutorService(executorService);
282
ExecutionStateSampler executionStateSampler =
283
new ExecutionStateSampler(options, System::currentTimeMillis);
0 commit comments