[2018-06-04 21:06:31,064] [DEBUG] |Returning KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'} to spout for retrying.|
[2018-06-04 21:06:31,065] [WARN] |failedPerShard does not contain KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'}. This should never happen.|
[2018-06-04 21:06:31,065] [DEBUG] |No failed record to emit for now. Hence will try to emit new records|
[2018-06-04 21:06:31,065] [DEBUG] |Returning uncommittedRecordsCount as 10000|
[2018-06-04 21:06:31,065] [WARN] |maximum uncommitted records count has reached. so not emitting any new records and returning|
[2018-06-04 21:06:31,066] [DEBUG] |Returning KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'} to spout for retrying.|
[2018-06-04 21:06:31,066] [WARN] |failedPerShard does not contain KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'}. This should never happen.|
[2018-06-04 21:06:31,067] [DEBUG] |No failed record to emit for now. Hence will try to emit new records|
[2018-06-04 21:06:31,067] [DEBUG] |Returning uncommittedRecordsCount as 10000|
[2018-06-04 21:06:31,067] [WARN] |maximum uncommitted records count has reached. so not emitting any new records and returning|
[2018-06-04 21:06:31,068] [DEBUG] |Returning KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'} to spout for retrying.|
[2018-06-04 21:06:31,068] [WARN] |failedPerShard does not contain KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'}. This should never happen.|
[2018-06-04 21:06:31,068] [DEBUG] |No failed record to emit for now. Hence will try to emit new records|
[2018-06-04 21:06:31,068] [DEBUG] |Returning uncommittedRecordsCount as 10000|
[2018-06-04 21:06:31,069] [WARN] |maximum uncommitted records count has reached. so not emitting any new records and returning|
[2018-06-04 21:06:31,069] [DEBUG] |New merged log config is {"" {:action #object[org.apache.storm.generated.LogLevelAction 0x72683382 "UPDATE"], :target-log-level #object[org.apache.logging.log4j.Level 0x516e1456 "DEBUG"], :reset-log-level #object[org.apache.logging.log4j.Level 0x6bb41190 "ERROR"], :timeout 1528146421046}}|
[2018-06-04 21:06:31,070] [DEBUG] |Returning KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'} to spout for retrying.|
[2018-06-04 21:06:31,070] [WARN] |failedPerShard does not contain KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'}. This should never happen.|
[2018-06-04 21:06:31,070] [DEBUG] |No failed record to emit for now. Hence will try to emit new records|
[2018-06-04 21:06:31,070] [DEBUG] |Returning uncommittedRecordsCount as 10000|
[2018-06-04 21:06:31,070] [WARN] |maximum uncommitted records count has reached. so not emitting any new records and returning|
[2018-06-04 21:06:31,071] [DEBUG] |Returning KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'} to spout for retrying.|
[2018-06-04 21:06:31,072] [WARN] |failedPerShard does not contain KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'}. This should never happen.|
[2018-06-04 21:06:31,072] [DEBUG] |No failed record to emit for now. Hence will try to emit new records|
[2018-06-04 21:06:31,072] [DEBUG] |Returning uncommittedRecordsCount as 10000|
[2018-06-04 21:06:31,072] [WARN] |maximum uncommitted records count has reached. so not emitting any new records and returning|
[2018-06-04 21:06:31,073] [DEBUG] |Returning KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'} to spout for retrying.|
[2018-06-04 21:06:31,074] [WARN] |failedPerShard does not contain KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'}. This should never happen.|
[2018-06-04 21:06:31,074] [DEBUG] |No failed record to emit for now. Hence will try to emit new records|
[2018-06-04 21:06:31,075] [DEBUG] |Returning uncommittedRecordsCount as 10000|
[2018-06-04 21:06:31,075] [WARN] |maximum uncommitted records count has reached. so not emitting any new records and returning|
[2018-06-04 21:06:31,076] [DEBUG] |Reading reply sessionid:0x362e3f251980043, packet:: clientPath:null serverPath:null finished:false header:: 4027358,3  replyHeader:: 4027358,12943262498,0  request:: '/storm/logconfigs/CMDTopology-prod-4-1516412799,T  response:: s{12943262497,12943262497,1528146391051,1528146391051,0,0,0,0,68,0,12943262497} |
[2018-06-04 21:06:31,076] [DEBUG] |Returning KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'} to spout for retrying.|
[2018-06-04 21:06:31,076] [WARN] |failedPerShard does not contain KinesisMessageId{streamName='K12RS_Production_MB_Source_Data', shardId='shardId-000000000002', sequenceNumber='49578091088922145332870462286162197312330826492151857186'}. This should never happen.|
[2018-06-04 21:06:31,076] [DEBUG] |No failed record to emit for now. Hence will try to emit new records|