Re: FlinkSQL, define parallelism as HINT or CREATE

2024-12-27 Thread Guillermo Ortiz Fernández
And which is the parallelism that flink is going to choose to Kafka topic right now? El vie, 27 dic 2024, 7:47, Xuyang escribió: > Hi, > > Currently, hints can modify the table options in the WITH parameters in a > query. However, unfortunately, the Kafka source does not yet support > related

FlinkSQL, define parallelism as HINT or CREATE

2024-12-26 Thread Guillermo Ortiz Fernández
I'm using Flink SQL and have several Kafka topics with different partition counts, ranging from 4 to 320 partitions. Is it possible to specify the level of parallelism as a HINT in queries or CREATE statements? If I don't define any, it defaults to parallelism.default. However, since the entire pro