Changes in BatchTSetIWorker

[Pulasthi Supun Wickramasinghe]

Hi Ahmet.

With the changes from 0.6.0 to 0.7.0 the class BatchTSetIWorker has been removed and replaced with Twister2Worker, The latter was used with the Beam integration, In BatchTSetIWorker there is a code segment [1] that sent job status to driver, Is there an equivalent code segment in the new Twister2Worker that performs this operation?  

[1] https://github.com/DSC-SPIDAL/twister2/blob/28cd6858e03893ff98d54ed849bf1580fcb964f9/twister2/tset/src/java/edu/iu/dsc/tws/tset/worker/BatchTSetIWorker.java#L43

Best Regards

Pulasthi

--

Pulasthi S. Wickramasinghe

PhD Candidate  | Research Assistant

School of Informatics and Computing | Digital Science Center

Indiana University, Bloomington

cell: 224-386-9035

[Ahmet Uyar]

Hi Pulasthi,

Yes we have that code in Twister2WorkerStarter.java

But, I think we should remove this code segment. Because, each worker already sends a COMPLETED message to JobMaster when they are done. So, the Driver can get this message. Though, We need to implement a proper event propagator.

Ahmet