flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From subash basnet <yasub...@gmail.com>
Subject Unable to understand datastream error message
Date Sat, 07 May 2016 17:16:20 GMT
Hello all,

I am getting the below error on execute of StreamExecutionEnvironment.

*Caused by: java.lang.IllegalStateException: Iteration
FeedbackTransformation{id=15, name='Feedback',
outputType=PojoType<wikiedits.StockAnalysis$Centroid, fields = [id: String,
pt: BasicArrayTypeInfo<Double>]>, parallelism=4} does not have any feedback
The run method inside the thread class of DataStreamUtils handles this
public void run(){
try {
} catch (Exception e) {
throw new RuntimeException("Exception in execute()", e);

I am not able to understand what to infer from this error message so that I
could solve it.

Best Regards,
Subash Basnet

View raw message