Fehlermeldung Unklar, google hilft auch nicht weiter

[ayoooo]

Hallo Freunde der Code läuft, das Programm läuft doch nach dem 1667 eintrag meckert er rum und zwar wirft er diese Fehlermeldung aus.

java.lang.IllegalStateException: Content has been consumed
at org.apache.http.entity.BasicHttpEntity.getContent(BasicHttpEntity.java:84)
at org.apache.http.conn.BasicManagedEntity.getContent(BasicManagedEntity.java:89)
at org.ektorp.http.StdHttpResponse.releaseConnection(StdHttpResponse.java:93)
at org.ektorp.http.StdHttpResponse$ConnectionReleasingInputStream.close(StdHttpResponse.java:118)
at sun.nio.cs.StreamDecoder.implClose(Unknown Source)
at sun.nio.cs.StreamDecoder.close(Unknown Source)
at java.io.InputStreamReader.close(Unknown Source)
at java.io.BufferedReader.close(Unknown Source)
at org.ektorp.StreamingViewResult$StreamingViewResultIterator.hasNext(StreamingViewResult.java:100)
at Twitterdb.fink.App.main(App.java:44)


Der Code ist der gleiche hier

package Twitterdb.fink;

import java.net.MalformedURLException;
import java.io.FileWriter;

import org.ektorp.CouchDbConnector;
import org.ektorp.CouchDbInstance;
import org.ektorp.StreamingViewResult;
import org.ektorp.ViewQuery;
import org.ektorp.ViewResult.Row;
import org.ektorp.http.HttpClient;
import org.ektorp.http.StdHttpClient;
import org.ektorp.impl.StdCouchDbConnector;
import org.ektorp.impl.StdCouchDbInstance;

import com.opencsv.CSVWriter;

public class App 
{
    public static void main( String[] args ) throws MalformedURLException 
    {
       HttpClient httpclient = new org.ektorp.http.StdHttpClient.Builder().url("http://localhost:5984").build();
       
       CouchDbInstance dbInstance = new StdCouchDbInstance(httpclient);
       
       CouchDbConnector db = new StdCouchDbConnector("twitterdb",dbInstance);
  
       ViewQuery query = new ViewQuery().designDocId("_design/tweetzahl").viewName("tweetzahl").group(true);
       
       StreamingViewResult data = db.queryForStreamingView(query);
       
    
    
    
   {
        try{
        	
          CSVWriter writer = new CSVWriter(new FileWriter("C:\\Users\\Sei_Erfolgreich\\Desktop\\Test.csv"));
          long counter = 1; 
          String [] read = new String [] {"UserID","tweetzahl"};
          writer.writeNext(read);  
          //close the writer
          writer.flush();
          for (Row row : data) {
        	  read = new String[] {row.getKey(),row.getValue()};
        	  writer.writeNext(read);
        	  writer.flush();
        	  System.out.println(counter);
        	  counter++;
          }
          System.out.println("tamam ya");
          data.close();
          writer.close();
       }catch (Exception e){
    	   e.printStackTrace();
       }
    }
}


}

Hat jemand wieder vielleicht ein tip???

 

[dzim]

Sieht so aus, als wäre dein data-Object von aussen gelehrt worden. Da ich haber - wie schon in deinem anderen Post bemerkt - CouchDB nicht weiter kenne, ist das reines Mutmassen...

 

[ayoooo]

Aber es läuft bis knapp zum ende, danach kommt die fehlermeldung ? also die Einträge sind auch korrekt