Fix local file sink flush (#1506)

pingcap · Apr 9, 2021 · c438c60 · c438c60
1 parent 6c41167
commit c438c60
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cdc/sink/cdclog/file.go b/cdc/sink/cdclog/file.go
@@ -87,7 +87,7 @@ func (ts *tableStream) isEmpty() bool {
 }
 
 func (ts *tableStream) shouldFlush() bool {
-	return ts.sendSize.Load() > maxPartFlushSize
+	return ts.sendSize.Load() > maxRowFileSize
 }
 
 func (ts *tableStream) flush(ctx context.Context, sink *logSink) error {