Skip to content

Commit c59ec4c

Browse files
committed
[feat-35406][http] close http connection after send data
1 parent c822d05 commit c59ec4c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

http/http-sink/src/main/java/com/dtstack/flink/sql/sink/http/HttpOutputFormat.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ public void writeRecord(Tuple2 record) {
118118
outDirtyRecords.inc();
119119
} finally {
120120
sendMessage.clear();
121-
if (client == null) {
121+
if (client != null) {
122122
try {
123123
client.close();
124124
} catch (IOException e) {

0 commit comments

Comments
 (0)