Type parameter hides visible type in the current scope (apache#6609)

hcxiong · Mar 26, 2020 · 9d3ab60 · 9d3ab60
1 parent 7de44a9
commit 9d3ab60
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -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
@@ -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);
     }
-Original file line number
+Diff line change
@@ Expand Up / @@ -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);
         }
@@ Expand Down @@