-
Notifications
You must be signed in to change notification settings - Fork 210
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
添加flink连接同步timeout #298
Labels
enhancement
New feature or request
Milestone
Comments
ChunjunDorisSinkFactory 中添加以下三个参数,用户可以自行定义连接超时异常处理参数 @FormField(ordinal = 13, advance = true, type = FormFieldType.INT_NUMBER, validate = {Validator.require})
public Integer connectTimeout;// = loadConf.getRequestConnectTimeoutMs() == null ? DORIS_REQUEST_CONNECT_TIMEOUT_MS_DEFAULT : loadConf.getRequestConnectTimeoutMs();
@FormField(ordinal = 14, advance = true, type = FormFieldType.INT_NUMBER, validate = {Validator.require})
public Integer socketTimeout;// = loadConf.getRequestReadTimeoutMs() == null ? DORIS_REQUEST_READ_TIMEOUT_MS_DEFAULT : loadConf.getRequestReadTimeoutMs();
@FormField(ordinal = 15, advance = true, type = FormFieldType.INT_NUMBER, validate = {Validator.require})
public Integer retries;// = loadConf.getRequestRetries() == null ? DORIS_REQUEST_RETRIES_DEFAULT : loadConf.getRequestRetries(); |
baisui1981
added a commit
to qlangtech/plugins
that referenced
this issue
Feb 26, 2024
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
mysql -> doris 由于目标端doris在夜晚load 比较高,导致doris connnector 执行streamload 超时导致丢失数据。
期望在doris sink 端配置超时时间,或者,添加执行streamload 失败重试机制
The text was updated successfully, but these errors were encountered: