You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by sl...@apache.org on 2011/12/06 17:30:53 UTC
svn commit: r1211000 -
/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/tools/BulkLoader.java
Author: slebresne
Date: Tue Dec 6 16:30:53 2011
New Revision: 1211000
URL: http://svn.apache.org/viewvc?rev=1211000&view=rev
Log:
fix loader progress bar display when the transfer was lightning fast
Modified:
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/tools/BulkLoader.java
Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/tools/BulkLoader.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/tools/BulkLoader.java?rev=1211000&r1=1210999&r2=1211000&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/tools/BulkLoader.java (original)
+++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/tools/BulkLoader.java Tue Dec 6 16:30:53 2011
@@ -69,12 +69,14 @@ public class BulkLoader
ProgressIndicator indicator = new ProgressIndicator(future.getPendingFiles());
indicator.start();
System.out.println("");
+ boolean printEnd = false;
while (!future.isDone())
{
if (indicator.printProgress())
{
// We're done with streaming
System.out.println("\nWaiting for targets to rebuild indexes ...");
+ printEnd = true;
future.get();
assert future.isDone();
}
@@ -83,6 +85,8 @@ public class BulkLoader
try { Thread.sleep(1000L); } catch (Exception e) {}
}
}
+ if (!printEnd)
+ indicator.printProgress();
}
System.exit(0); // We need that to stop non daemonized threads