supress warnings in tests

Author: stankiewicz

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

@@ -166,6 +166,8 @@ public final class StreamingDataflowWorker {
   private static final String CHANNELZ_PATH = "/channelz";
   private static final String BEAM_FN_API_EXPERIMENT = "beam_fn_api";
   private static final String ELEMENT_METADATA_SUPPORTED_EXPERIMENT = "element_metadata_supported";
+
+  @SuppressWarnings("unused")
   private static final String STREAMING_ENGINE_USE_JOB_SETTINGS_FOR_HEARTBEAT_POOL_EXPERIMENT =
       "streaming_engine_use_job_settings_for_heartbeat_pool";
   // Experiment make the monitor within BoundedQueueExecutor fair

runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorkerTest.java

@@ -224,7 +224,7 @@
 
 /** Unit tests for {@link StreamingDataflowWorker}. */
 @RunWith(Parameterized.class)
-@SuppressWarnings("deprecation")
+@SuppressWarnings({"deprecation", "unused"})
 public class StreamingDataflowWorkerTest {
 
   private static final Logger LOG = LoggerFactory.getLogger(StreamingDataflowWorkerTest.class);

runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/logging/DataflowWorkerLoggingHandlerTest.java

@@ -679,6 +679,7 @@ public void testDirectLoggingWithoutExceptionOrMessage() throws IOException {
   }
 
   @Test
+  @SuppressWarnings("unused")
   public void isConfiguredDirectLog() throws IOException {
     ByteArrayOutputStream fileOutput = new ByteArrayOutputStream();
     FixedOutputStreamFactory factory = new FixedOutputStreamFactory(fileOutput);

sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReaderIdlePartitionTest.java

@@ -173,7 +173,7 @@ private MockConsumer<byte[], byte[]> createMockConsumer(
         List<String> topics,
         int partitionsPerTopic,
         int numElements,
-        Map<String, Object> config,
+        @SuppressWarnings("unused") Map<String, Object> config,
         SerializableFunction<Integer, byte[]> keyFunction,
         SerializableFunction<Integer, byte[]> valueFunction) {