SaveAsHadoopDataset never closes connection To zookeeper
<p>I am using the below code to write to hbase </p>

<pre><code>    jsonDStream.foreachRDD(new Function&lt;JavaRDD&lt;String&gt;, Void&gt;() {

        @Override
        public Void call(JavaRDD&lt;String&gt; rdd) throws Exception {

            DataFrame jsonFrame = sqlContext.jsonRDD(rdd);
            DataFrame selecteFieldFrame = jsonFrame.select("id_str","created_at","text");

            Configuration config = HBaseConfiguration.create();
            config.set("hbase.zookeeper.quorum", "d-9543");
            config.set("zookeeper.znode.parent","/hbase-unsecure");
            config.set("hbase.zookeeper.property.clientPort", "2181");
            final JobConf jobConfig=new JobConf(config,SveAsHadoopDataSetExample.class);

            jobConfig.setOutputFormat(TableOutputFormat.class);
            jobConfig.set(TableOutputFormat.OUTPUT_TABLE,"tableName");
             selecteFieldFrame.javaRDD().mapToPair(new PairFunction&lt;Row, ImmutableBytesWritable, Put&gt;() {

                @Override
                public Tuple2&lt;ImmutableBytesWritable, Put&gt; call(Row row) throws Exception {
                    // TODO Auto-generated method stub
                    return convertToPut(row);
                }
            }).saveAsHadoopDataset(jobConfig);


            return null;
        }
    });
</code></pre>

<p>But when i see zkDump in zookeeper the connections keeps on increasing </p>

<p>any suggestion/pointers will be of a great help!</p>