Skip to content

Commit

Permalink
improve
Browse files Browse the repository at this point in the history
  • Loading branch information
JNSimba committed Dec 26, 2024
1 parent b7b5802 commit 7344549
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 3 deletions.
2 changes: 1 addition & 1 deletion flink-doris-connector/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ under the License.
</mailingLists>

<properties>
<revision>24.0.0-SNAPSHOT</revision>
<revision>24.1.0-SNAPSHOT</revision>
<flink.version>1.18.0</flink.version>
<flink.major.version>1.18</flink.major.version>
<flink.sql.cdc.version>3.2.1</flink.sql.cdc.version>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -169,7 +169,8 @@ public static List<Get> deduplicateRecords(List<Get> recordList) {

private void appendSelect(StringBuilder sb, LookupSchema schema) {
String[] selectFields = schema.getSelectFields();
sb.append("select ");
sb.append("/* ApplicationName=Flink Lookup Query */ ");
sb.append(" select ");
for (int i = 0; i < selectFields.length; i++) {
if (i > 0) {
sb.append(",");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -209,9 +209,9 @@ private static String getConnectionGet(
HttpURLConnection connection = (HttpURLConnection) realUrl.openConnection();
connection.setRequestProperty("Authorization", authHeader(dorisOptions));

connection.connect();
connection.setConnectTimeout(request.getConfig().getConnectTimeout());
connection.setReadTimeout(request.getConfig().getSocketTimeout());
connection.connect();
return parseResponse(connection, logger);
}

Expand Down

0 comments on commit 7344549

Please sign in to comment.