diff options
author | Peter Wu <peter@lekensteyn.nl> | 2014-05-03 17:54:16 +0200 |
---|---|---|
committer | Peter Wu <peter@lekensteyn.nl> | 2014-05-03 17:54:16 +0200 |
commit | 6e2caf0d9ffd11b5cd425d7af153b653da95ab8d (patch) | |
tree | a4dd5222440ad8f8740e87a9fed40a4324f25d96 /src | |
parent | 7e1307259ef932fe8d8e4309ec288d3558fce79c (diff) | |
download | TwitterDataAnalytics-6e2caf0d9ffd11b5cd425d7af153b653da95ab8d.tar.gz |
DataWriter: first read, then open for writing
Prevents occasional "Unexpected end of ZLIB input stream" errors.
Diffstat (limited to 'src')
-rw-r--r-- | src/io/DataWriter.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/io/DataWriter.java b/src/io/DataWriter.java index b4cf4d5..578c3a7 100644 --- a/src/io/DataWriter.java +++ b/src/io/DataWriter.java @@ -70,10 +70,11 @@ public class DataWriter implements ResultListener, Closeable { */ public void open() throws IOException { try { - m_profile.open(); - m_tweet.open(); readIds(m_profileIdSet, m_profile); readIds(m_tweetIdSet, m_tweet); + // open after reading input to prevent simultaneous r/w access + m_profile.open(); + m_tweet.open(); } catch (IOException ex) { m_profile.close(); m_tweet.close(); |