[pulsar] branch master updated: Remove redundant SuppressWarnings (#4371)

[si...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new f9ab535  Remove redundant SuppressWarnings (#4371)
f9ab535 is described below

commit f9ab535b0c3da37f3918aad7f565cac2353ce852
Author: Like <ke...@outlook.com>
AuthorDate: Sun May 26 18:10:19 2019 +0800

    Remove redundant SuppressWarnings (#4371)
---
 .../main/java/org/apache/pulsar/functions/instance/ContextImpl.java    | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
index 5bf8c59..6145271 100644
--- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
+++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
@@ -320,7 +320,6 @@ class ContextImpl implements Context, SinkContext, SourceContext {
         }
     }
 
-    @SuppressWarnings("unchecked")
     @Override
     public <O> CompletableFuture<Void> publish(String topicName, O object) {
         return publish(topicName, object, "");
@@ -332,7 +331,6 @@ class ContextImpl implements Context, SinkContext, SourceContext {
         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 @@ class ContextImpl implements Context, SinkContext, SourceContext {
         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);