|
y(ExceptionsAndFinalizers.scala:46) // ... // at java.lang.Thread.run(Thread.java:745) // ***Finally*** the end of streamState!!! */
/* val v = viewState.appendTask(errorRow).appendTask(trackRows) val v1 = v.onError {case e: Exception => println(s"Caught Error in viewState!!![${e.getMessage}]"); fda_appendRow(FDANullRow)} v1.startRun val s = streamState.appendTask(errorRow).appendTask(trackRows) val s1 = s.onError {case e: Exception => println(s"Caught Error in streamState!!![${e.getMessage}]"); fda_appendRow(FDANullRow)} s1.startRun */ val s = streamState.take(5).appendTask(catchError).appendTask(trackRows) val s1 = s.onError {case e: Exception => println(s"Caught Error in streamState!!![${e.getMessage}]"); fda_appendRow(FDANullRow)} s1.startRun }
|