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
edges.*
The run method inside the thread class of DataStreamUtils handles this
exception:
@Override
public void run(){
try {
stream.getExecutionEnvironment().execute();
} 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
