Prasanna,
You might want to check the kafka broker configs where
'auto.create.topics.enable' helps with creating a new topic whenever a new
message with non existent topic is published.
https://kafka.apache.org/documentation/#brokerconfigs
I am not too sure about pitfalls if any.
On Mon, Jun 1, 2
to Dispatcher successfully and the
> internal submitting job takes
> too long time(more than 10s). So it failed with timeout. Could you please
> set the `web.timeout: 3`
> and run again?
>
>
>
> Best,
> Yang
>
> satya brat 于2020年1月20日周一 下午4:34写道：
>
>> I am u
I am using standalone cluster of Flink with 1 jobManager and n
taskManagers. When I try to submit a job via command line, the job
submission fails with error message as
org.apache.flink.client.program.ProgramInvocationException: Could not
submit job (JobID: f839aefee74aa4483ce8f8fd2e49b69e).
On jo
