timeplus-io / proton

A streaming SQL engine, a fast and lightweight alternative to ksqlDB and Apache Flink, 🚀 powered by ClickHouse.
https://timeplus.com
Apache License 2.0
1.55k stars 68 forks source link

Write data to Kafka external stream facing Fatal error occurred, shall tear down the whole program. (DWAL_FATAL_ERROR) #791

Open mateng0915 opened 4 months ago

mateng0915 commented 4 months ago

I insert data into my internal stream image

Then insert into my external kafka stream

image

image

facing the DB::Exception: Fatal error occurred, shall tear down the whole program. (DWAL_FATAL_ERROR)

Proton Version

1.5.11 image

jovezhong commented 4 months ago

Thanks for reporting this. Assigned the ticket to @zliang-min

zliang-min commented 3 months ago

Hi @mateng0915 , I created the stream and external stream as you described in the ticket, and everything works just fine for me.

image

When did that error show up? Was it immediately after you execute the insert into external_kafka_time_producer SQL? Or when you inserted data into the self_stream.local_stream stream? And, did you run the proton binary on your machine, or did you use docker?

Also, could you please try if this SQL works for you?

insert into external_kafka_time_producer (id, product, price) values (1, 'keep-insert001', 1.11);
mateng0915 commented 3 months ago

Hi @mateng0915 , I created the stream and external stream as you described in the ticket, and everything works just fine for me. image

When did that error show up? Was it immediately after you execute the insert into external_kafka_time_producer SQL? Or when you inserted data into the self_stream.local_stream stream? And, did you run the proton binary on your machine, or did you use docker?

Also, could you please try if this SQL works for you?

insert into external_kafka_time_producer (id, product, price) values (1, 'keep-insert001', 1.11);

Hi @zliang-min , thx for reply For Env: I running the proton instance in the docker

The error is occoured when I insert data into elf_stream.local_stream stream

I running the sql insert into external_kafka_time_producer (id, product, price) values (1, 'keep-insert001', 1.11); it throw the same error

image