Skip to content

Commit cb984a2

Browse files
fixed socket
1 parent f314e30 commit cb984a2

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

src/main/java/com/datastax/cdm/CassandraDatasetManager.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -265,10 +265,6 @@ void install(String name) throws IOException, InterruptedException, GitAPIExcept
265265

266266
System.out.println("Loading data");
267267

268-
Cluster cluster2 = Cluster.builder()
269-
.addContactPoint(address)
270-
.build();
271-
272268

273269
this.session = session;
274270

@@ -277,7 +273,7 @@ void install(String name) throws IOException, InterruptedException, GitAPIExcept
277273
Iterable<CSVRecord> records = openCSV(dataFile);
278274

279275
System.out.println("Importing " + table);
280-
KeyspaceMetadata keyspaceMetadata = cluster2.getMetadata()
276+
KeyspaceMetadata keyspaceMetadata = cluster.getMetadata()
281277
.getKeyspace(config.keyspace);
282278
TableMetadata tableMetadata = keyspaceMetadata.getTable(table);
283279

@@ -325,7 +321,7 @@ void install(String name) throws IOException, InterruptedException, GitAPIExcept
325321
System.out.println("Done importing " + table);
326322
}
327323

328-
cluster2.close();
324+
cluster.close();
329325
System.out.println("Loading data");
330326
}
331327

0 commit comments

Comments
 (0)