Remove redundant SuppressWarnings (apache#4371)

nicky1 · May 26, 2019 · f9ab535 · f9ab535
1 parent 7924846
commit f9ab535
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/...ar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java b/...ar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
@@ -320,7 +320,6 @@ public ByteBuffer getState(String key) {
         }
     }
 
-    @SuppressWarnings("unchecked")
     @Override
     public <O> CompletableFuture<Void> publish(String topicName, O object) {
         return publish(topicName, object, "");
@@ -332,7 +331,6 @@ public <O> CompletableFuture<Void> publish(String topicName, O object, String sc
         return publish(topicName, object, (Schema<O>) topicSchema.getSchema(topicName, object, schemaOrSerdeClassName, false));
     }
 
-    @SuppressWarnings("unchecked")
     @Override
     public <O> TypedMessageBuilder<O> newOutputMessage(String topicName, Schema<O> schema) throws PulsarClientException {
         MessageBuilderImpl<O> messageBuilder = new MessageBuilderImpl<>();
@@ -341,7 +339,6 @@ public <O> TypedMessageBuilder<O> newOutputMessage(String topicName, Schema<O> s
         return messageBuilder;
     }
 
-    @SuppressWarnings("unchecked")
     public <O> CompletableFuture<Void> publish(String topicName, O object, Schema<O> schema) {
         try {
             return newOutputMessage(topicName, schema).value(object).sendAsync().thenApply(msgId -> null);