Re: Dynamic source and sink.

hzyuemeng1

elasticsearch sink can't connect to elastic cluster with BasicAuth

ction,num"), new RetryRejectedExecutionFailureHandler())).name("elasticsearch_4068").setParallelism(2);Any help will be greatly appreciated

can we recover job use latest checkpointed state instead of savepoint, and how?

i found that use savepoint to recover job sometimes failed, can we use  latest checkpointed to recover failed jobhow?thank you. 发自网易邮箱大师