Hi Vladimir,
As I see, your SQL query is reading data from the Kafka topic and pulls all
data to the client side. The "*.collect" method is quite network/memory
intensive. You probably do want that.
If you want to debug/print the ingested data via SQL, I would recommend the
"print" connector.
htt
Фролов
Cc: user@flink.apache.org
Subject: Re: Issue with Flink Job when Reading Data from Kafka and Executing
SQL Query (q77 TPC-DS)
⚠EXTERNAL MESSAGE – CAUTION: Think Before You Click ⚠
Hi Vladimir,
As I see, your SQL query is reading data from the Kafka topic and pulls all
data to the client
