luciano/amazon-kinesis-client-go
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Send nil showdown signal immediately

Browse source
This commit is contained in:
Xavi Ramirez 2017-09-20 04:58:40 +00:00
parent 32d4d33f00
commit 7f2afe9d8f
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
kcl/kcl.go
View file

@ -243,6 +243,12 @@ func (kclp *KCLProcess) handleLine(line string) error {
} }
kclp.ioHandler.writeError("Reporting shutdown done") kclp.ioHandler.writeError("Reporting shutdown done")
err := kclp.sendCheckpoint(nil, nil) // nil sequence num is signal to shutdown
if err != nil {
kclp.ioHandler.writeError(fmt.Sprintf("ERR shutdown ask: %+#v", err))
}
return kclp.reportDone("shutdown") return kclp.reportDone("shutdown")
case ActionInitialize: case ActionInitialize:
err = kclp.recordProcessor.Initialize(action.ShardID, kclp) err = kclp.recordProcessor.Initialize(action.ShardID, kclp)