Removed null check before setting status page

Author: parveensania

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

@@ -228,7 +228,7 @@ private StreamingDataflowWorker(
     this.workUnitExecutor = workUnitExecutor;
     this.harnessSwitchExecutor =
         Executors.newSingleThreadExecutor(
-            new ThreadFactoryBuilder().setNameFormat("HarnessSwtichExecutor").build());
+            new ThreadFactoryBuilder().setNameFormat("HarnessSwitchExecutor").build());
     this.clock = clock;
     this.memoryMonitor = BackgroundMemoryMonitor.create(memoryMonitor);
     this.numCommitThreads =
@@ -527,26 +527,25 @@ private void switchStreamingWorkerHarness(ConnectivityType connectivityType) {
       streamingWorkerHarness.get().start();
       LOG.debug("Started SingleSourceWorkerHarness");
     }
-    if (newHarnessFactoryOutput != null) {
-      this.statusPages.set(
-          createStatusPageBuilder(
-                  this.options, this.windmillStreamFactory, this.memoryMonitor.memoryMonitor())
-              .setClock(this.clock)
-              .setClientId(this.clientId)
-              .setIsRunning(this.running)
-              .setStateCache(this.stateCache)
-              .setComputationStateCache(this.computationStateCache)
-              .setWorkUnitExecutor(this.workUnitExecutor)
-              .setGlobalConfigHandle(this.configFetcher.getGlobalConfigHandle())
-              .setChannelzServlet(newHarnessFactoryOutput.channelzServlet())
-              .setGetDataStatusProvider(newHarnessFactoryOutput.getDataStatusProvider())
-              .setCurrentActiveCommitBytes(
-                  newHarnessFactoryOutput.currentActiveCommitBytesProvider())
-              .setChannelCache(newHarnessFactoryOutput.channelCache())
-              .build());
-      this.statusPages.get().start(this.options);
-      LOG.info("Started new StreamingWorkerStatusPages instance.");
-    }
+    this.statusPages.set(
+        createStatusPageBuilder(
+                this.options, this.windmillStreamFactory, this.memoryMonitor.memoryMonitor())
+            .setClock(this.clock)
+            .setClientId(this.clientId)
+            .setIsRunning(this.running)
+            .setStateCache(this.stateCache)
+            .setComputationStateCache(this.computationStateCache)
+            .setWorkUnitExecutor(this.workUnitExecutor)
+            .setGlobalConfigHandle(this.configFetcher.getGlobalConfigHandle())
+            .setChannelzServlet(newHarnessFactoryOutput.channelzServlet())
+            .setGetDataStatusProvider(newHarnessFactoryOutput.getDataStatusProvider())
+            .setCurrentActiveCommitBytes(
+                newHarnessFactoryOutput.currentActiveCommitBytesProvider())
+            .setChannelCache(newHarnessFactoryOutput.channelCache())
+            .build());
+    this.statusPages.get().start(this.options);
+    LOG.info("Started new StreamingWorkerStatusPages instance.");
+
   }
 
   private static StreamingWorkerStatusPages.Builder createStatusPageBuilder(

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/StreamingWorkerStatusPages.java

@@ -80,7 +80,7 @@ public final class StreamingWorkerStatusPages {
   private final @Nullable GrpcWindmillStreamFactory windmillStreamFactory;
   private final DebugCapture.@Nullable Manager debugCapture;
   private final @Nullable ChannelzServlet channelzServlet;
-  private @Nullable ChannelCache channelCache;
+  private final @Nullable ChannelCache channelCache;
 
   private final AtomicReference<StreamingGlobalConfig> globalConfig = new AtomicReference<>();