[incubator-pulsar] branch branch-2.1 updated: Remove snapshot-topic ref (#2355)

[sijie]

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

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


The following commit(s) were added to refs/heads/branch-2.1 by this push:
     new f2e6ea7  Remove snapshot-topic ref (#2355)
f2e6ea7 is described below

commit f2e6ea73aab47a5c977d44c9deb3f99a07e53a94
Author: Rajan Dhabalia <rdhaba...@apache.org>
AuthorDate: Thu Aug 9 23:43:02 2018 -0700

    Remove snapshot-topic ref (#2355)
    
    ### Motivation
    
    remove unused config `functionMetadataSnapshotsTopicPath`
---
 conf/functions_worker.yml                                                | 1 -
 .../src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java   | 1 -
 2 files changed, 2 deletions(-)

diff --git a/conf/functions_worker.yml b/conf/functions_worker.yml
index 4194337..8c0d903 100644
--- a/conf/functions_worker.yml
+++ b/conf/functions_worker.yml
@@ -24,7 +24,6 @@ workerPort: 6750
 connectorsDirectory: ./connectors
 
 functionMetadataTopicName: metadata
-functionMetadataSnapshotsTopicPath: snapshots
 clusterCoordinationTopicName: coordinate
 pulsarFunctionsNamespace: public/functions
 pulsarFunctionsCluster: standalone
diff --git 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java
 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java
index eda9b15..348d245 100644
--- 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java
+++ 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java
@@ -58,7 +58,6 @@ public class WorkerConfig implements Serializable, 
PulsarConfiguration {
     private String pulsarServiceUrl;
     private String pulsarWebServiceUrl;
     private String clusterCoordinationTopicName;
-    private String functionMetadataSnapshotsTopicPath;
     private String pulsarFunctionsNamespace;
     private String pulsarFunctionsCluster;
     private int numFunctionPackageReplicas;