Skip to content

Commit 9c68038

Browse files
committed
Ran spotlessApply
1 parent e1cd3dc commit 9c68038

1 file changed

Lines changed: 1 addition & 3 deletions

File tree

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -539,13 +539,11 @@ private void switchStreamingWorkerHarness(ConnectivityType connectivityType) {
539539
.setGlobalConfigHandle(this.configFetcher.getGlobalConfigHandle())
540540
.setChannelzServlet(newHarnessFactoryOutput.channelzServlet())
541541
.setGetDataStatusProvider(newHarnessFactoryOutput.getDataStatusProvider())
542-
.setCurrentActiveCommitBytes(
543-
newHarnessFactoryOutput.currentActiveCommitBytesProvider())
542+
.setCurrentActiveCommitBytes(newHarnessFactoryOutput.currentActiveCommitBytesProvider())
544543
.setChannelCache(newHarnessFactoryOutput.channelCache())
545544
.build());
546545
this.statusPages.get().start(this.options);
547546
LOG.info("Started new StreamingWorkerStatusPages instance.");
548-
549547
}
550548

551549
private static StreamingWorkerStatusPages.Builder createStatusPageBuilder(

0 commit comments

Comments
 (0)