Non blocking OlapTableSink#3143

Merged

imay merged 23 commits intoapache:masterfrom

vagetablechicken:non-blocking-sink

May 7, 2020

Commits on May 6, 2020

[] non-blocking sink draft
huangwei5
committed
[] DEBUG LOG
huangwei5
committed
delete batches in cancel
huangwei5
committed
[] comments
huangwei5
committed
comments
huangwei5
committed
Revert "[] DEBUG LOG"
huangwei5
committed
fix log level
HuangWei
committed
fix none_of & olaptablesink comments
huangwei5
committed
typo
huangwei5
committed
capture this, error returns, ut fix & comments
huangwei5
committed
fixes, mem limit
huangwei5
committed
capture fix
huangwei5
committed
[] reduce channel status
huangwei5
committed
[] reduce channel status
huangwei5
committed
add row block time, send interval
huangwei5
committed
default send interval 10ms
huangwei5
committed
mInt32

HuangWei
and
imay
committed
std::function copy->ref

HuangWei
and
imay
committed
use sleep in close_wait
huangwei5
committed
fix ac by review
huangwei5
committed
fix close wait time log
huangwei5
committed
revert brocker scan node format
huangwei5
committed
let send_interval_ms modifiable
huangwei5
committed