Как установить kafka CommitOffset в Flink?

Question

Используйте localhost вместо вашего IP-адреса.

, например,

$myServer = "localhost";

И также дважды проверьте свое имя пользователя и пароль mysql.

0

задан 孙兴斌 6 March 2019 в 06:25

1 ответ

Другие вопросы по тегам:

score 0 · Answer 1

После включения проверки наведения теперь работает:

StreamExecutionEnvironment environment =
            StreamExecutionEnvironment.getExecutionEnvironment();

environment.enableCheckpointing(5000);