serialize REEF exceptions and rethrow

uwescience · Jun 9, 2017 · 761d849 · 761d849
1 parent 07ceb18
commit 761d849
Show file tree

Hide file tree

Showing 15 changed files with 1,447 additions and 642 deletions.
diff --git a/protobuf/control.proto b/protobuf/control.proto
@@ -17,6 +17,12 @@ message ControlMessage {
   optional SocketInfo remote_address = 3;
   repeated ResourceStats resource_stats = 4;
   repeated int32 acked_worker_ids = 5;
+  optional Exception worker_exception = 6;	// REMOVE_WORKER
+}
+
+message Exception {
+ // for now, the exception is a simple java serialized object.
+ required bytes exception = 1;
 }
 
 message SocketInfo {