[pulsar] branch master updated: Type parameter hides visible type in the current scope (#6609)

[sijie]

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 9d3ab60  Type parameter hides visible type in the current scope (#6609)
9d3ab60 is described below

commit 9d3ab60efddd3f4064789293fd8e9c4d4388b6c7
Author: Yijie Shen <henry.yijies...@gmail.com>
AuthorDate: Thu Mar 26 17:09:43 2020 +0800

    Type parameter hides visible type in the current scope (#6609)
---
 .../src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java      | 2 +-
 .../src/main/java/org/apache/pulsar/zookeeper/ZooKeeperDataCache.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java
 
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java
index 760845c..87e00d2 100644
--- 
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java
+++ 
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java
@@ -83,7 +83,7 @@ public class PulsarSink<T> implements Sink<T> {
             this.schema = schema;
         }
 
-        public <T> Producer<T> createProducer(PulsarClient client, String 
topic, String producerName, Schema<T> schema)
+        public Producer<T> createProducer(PulsarClient client, String topic, 
String producerName, Schema<T> schema)
                 throws PulsarClientException {
             ProducerBuilder<T> builder = client.newProducer(schema)
                     .blockIfQueueFull(true)
diff --git 
a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperDataCache.java
 
b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperDataCache.java
index 8a3a032..8da7e65 100644
--- 
a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperDataCache.java
+++ 
b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperDataCache.java
@@ -164,7 +164,7 @@ public abstract class ZooKeeperDataCache<T> implements 
Deserializer<T>, CacheUpd
         }
     }
 
-    public <T> T getDataIfPresent(String path) {
+    public T getDataIfPresent(String path) {
         return (T) cache.getDataIfPresent(path);
     }