Ling Jin

icon location Chengdu icon location Keep silent

Results 317 comments of Ling Jin

Question: what would happen if produce a mount of messages by an async Writer to a Kafka cluster without response？

For the current implementation，is there any way to prevent close blocked a long time？

[DNM] changefeed(ticdc): refactor new changefeed method attach the reactor directly

/run-all-tests

[DNM] changefeed(ticdc): refactor new changefeed method attach the reactor directly

/run-all-tests

[DNM] changefeed(ticdc): refactor new changefeed method attach the reactor directly

/merge

[DNM] changefeed(ticdc): refactor new changefeed method attach the reactor directly

/run-verify-ci

[DNM] changefeed(ticdc): refactor new changefeed method attach the reactor directly

/run-leak-test /run-integration-test

[DNM] changefeed(ticdc): refactor new changefeed method attach the reactor directly

/run-dm-compatibility-test

Tracking issue for reducing high latency

`tiup cluster stop test-cluster` cost a long time, looks triggered `graceful shutdown`, Is this expected? the command above is to hard stop the whole cluster, I don't think it should...

processor(ticdc): refactor create processor method

/run-all-tests

processor(ticdc): refactor create processor method

/run-all-tests