From 7f2afe9d8f651470dd57eff177fe0968e494a231 Mon Sep 17 00:00:00 2001 From: Xavi Ramirez Date: Wed, 20 Sep 2017 04:58:40 +0000 Subject: [PATCH] Send nil showdown signal immediately --- kcl/kcl.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/kcl/kcl.go b/kcl/kcl.go index b1d2d2e..b26098c 100644 --- a/kcl/kcl.go +++ b/kcl/kcl.go @@ -243,6 +243,12 @@ func (kclp *KCLProcess) handleLine(line string) error { } 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") case ActionInitialize: err = kclp.recordProcessor.Initialize(action.ShardID, kclp)