Current event log mechanism : The events recorded are currently recorded in datatorrent/apps/{appid}/events/ folder in files named part{id}.txt . eg : datatorrent/apps/application_1483801541352_0003/events/part0.txt
We can access these events via REST Api which returns the list of events as List<EventInfo> objects. The below approach can be used for implementing this. Kindly let me know your viewpoints/suggestions on the approach. *Required Changes:* a) Add a enum field like EventLogLevel in StramEvent, assign the log level in constructors of different Stram events like StartOperator, StartContainer, StopOperator, etc. b) Add eventLogLevel in EventInfo class. The events returned via REST api from StramClient is a list of EventInfo objects. c) Changes in EventsAgent - processPartFile() method to parse the eventLogLevel logged into the part{id}.txt file On Thu, Jan 19, 2017 at 10:55 PM, AJAY GUPTA <ajaygit...@gmail.com> wrote: > Hi Apex community, > > > Currently, events logged by stram such as StartContainer, StartOperator, > StopContainer, StopOperator, etc dont have any associated priority level. > > We can provide log levels for such Stram events. Log levels can be INFO, > WARN, ERROR > Eg: > 1. Start Container, Start Operator are INFO level events > 2. OperatorError is ERROR level event > 3. Stop Container, Stop Operator are WARN level events > > Log level for events can help in user experience when showing the event > list in a GUI. eg: In datatorrent gateway UI, we can provide color-coded > log levels so that user can focus more on ERROR and WARN events. > > > > >