From 9d3ab60efddd3f4064789293fd8e9c4d4388b6c7 Mon Sep 17 00:00:00 2001
From: Yijie Shen <henry.yijieshen@gmail.com>
Date: Thu, 26 Mar 2020 17:09:43 +0800
Subject: [PATCH] Type parameter hides visible type in the current scope
 (#6609)

---
 .../main/java/org/apache/pulsar/functions/sink/PulsarSink.java  | 2 +-
 .../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 760845c05118f..87e00d2c7798a 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 @@ protected PulsarSinkProcessorBase(Schema schema) {
             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 8a3a03276dec0..8da7e65e7902a 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 void process(WatchedEvent event) {
         }
     }
 
-    public <T> T getDataIfPresent(String path) {
+    public T getDataIfPresent(String path) {
         return (T) cache.getDataIfPresent(path);
     }