(beam) branch master updated: Remove unnecessary checkNotNull (#34664)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new b2db7a41bd4 Remove unnecessary checkNotNull (#34664)
b2db7a41bd4 is described below

commit b2db7a41bd405735ec89122bfe89acb4111f050a
Author: akashorabek <70029317+akashora...@users.noreply.github.com>
AuthorDate: Fri Apr 18 19:05:08 2025 +0500

    Remove unnecessary checkNotNull (#34664)
---
 .../streaming/harness/FanOutStreamingEngineWorkerHarnessTest.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/streaming/harness/FanOutStreamingEngineWorkerHarnessTest.java
 
b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/streaming/harness/FanOutStreamingEngineWorkerHarnessTest.java
index c25abb9bc5e..66f962ae772 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/streaming/harness/FanOutStreamingEngineWorkerHarnessTest.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/streaming/harness/FanOutStreamingEngineWorkerHarnessTest.java
@@ -173,9 +173,8 @@ public class FanOutStreamingEngineWorkerHarnessTest {
     Preconditions.checkNotNull(fanOutStreamingEngineWorkProvider).shutdown();
     stubFactory.shutdown();
     fakeStreamingEngineServer.shutdown();
-    if (!Preconditions.checkNotNull(
-        fakeStreamingEngineServer.awaitTermination(
-            SERVER_SHUTDOWN_TIMEOUT_SECONDS, TimeUnit.SECONDS))) {
+    if (!fakeStreamingEngineServer.awaitTermination(
+        SERVER_SHUTDOWN_TIMEOUT_SECONDS, TimeUnit.SECONDS)) {
       fakeStreamingEngineServer.shutdownNow();
     }
   }