File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -40,10 +40,10 @@ func (s *blockingFlushSink) WriteBlockEvent(commonEvent.BlockEvent) error { retu
4040func (s * blockingFlushSink ) AddCheckpointTs (uint64 ) {}
4141func (s * blockingFlushSink ) SetTableSchemaStore (* commonEvent.TableSchemaStore ) {
4242}
43- func (s * blockingFlushSink ) Close (bool ) {}
43+ func (s * blockingFlushSink ) Close (bool ) {}
4444func (s * blockingFlushSink ) Run (context.Context ) error { return nil }
45- func (s * blockingFlushSink ) BatchCount () int { return 0 }
46- func (s * blockingFlushSink ) BatchBytes () int { return 0 }
45+ func (s * blockingFlushSink ) BatchCount () int { return 0 }
46+ func (s * blockingFlushSink ) BatchBytes () int { return 0 }
4747
4848func (s * blockingFlushSink ) AddDMLEvent (event * commonEvent.DMLEvent ) {
4949 s .added <- event .CommitTs
You can’t perform that action at this time.
0 commit comments