commit 48dddc0b74b10a52684adfb1732677351ac08945
author Cheng <yuhcheng@linkedin.com> Tue Nov 17 17:22:21 2020 -0800
committer Cheng <yuhcheng@linkedin.com> Tue Nov 17 17:22:21 2020 -0800
tree d05591464223e01bcc57d1dbe034bbeca6df3d59
parent f20be45b54b74f6ed07f02a84e63f1b37d48c757

clean up code

samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala

diff --git a/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala b/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala
index 949d923..05fd8bc 100644
--- a/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala
+++ b/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala
@@ -244,13 +244,6 @@
     info("CheckpointManager stopped.")
   }
 
-  override def finalize() {
-    super.finalize()
-    systemConsumer.stop()
-    systemAdmin.stop()
-    producerRef.get().stop()
-  }
-
   @VisibleForTesting
   def getSystemProducer(): SystemProducer = {
     systemFactory.getProducer(checkpointSystem, config, metricsRegistry, this.getClass.getSimpleName)