This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 19c0d13 Fixes class logger variable name, keep the same with other
class file. (#915)
19c0d13 is described below
commit 19c0d134579367de2d955ca4a2fd1f53e37da9a8
Author: Zonglei Dong <[email protected]>
AuthorDate: Sat Jan 1 19:57:07 2022 +0800
Fixes class logger variable name, keep the same with other class file.
(#915)
---
.../src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java | 6 +++---
.../main/java/org/apache/seatunnel/flink/util/EnvironmentUtil.java | 4 ++--
.../java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java | 6 +++---
.../main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java | 6 +++---
.../src/main/java/org/apache/seatunnel/flink/sink/FileSink.java | 4 ++--
5 files changed, 13 insertions(+), 13 deletions(-)
diff --git
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java
index 53a4103..22dec68 100644
---
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java
+++
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java
@@ -41,7 +41,7 @@ import org.slf4j.LoggerFactory;
public class FlinkEnvironment implements RuntimeEnv {
- private static final Logger LOG =
LoggerFactory.getLogger(FlinkEnvironment.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(FlinkEnvironment.class);
private Config config;
@@ -172,7 +172,7 @@ public class FlinkEnvironment implements RuntimeEnv {
environment.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);
break;
default:
- LOG.warn("set time-characteristic failed, unknown
time-characteristic [{}],only support
event-time,ingestion-time,processing-time", timeType);
+ LOGGER.warn("set time-characteristic failed, unknown
time-characteristic [{}],only support
event-time,ingestion-time,processing-time", timeType);
break;
}
}
@@ -194,7 +194,7 @@ public class FlinkEnvironment implements RuntimeEnv {
checkpointConfig.setCheckpointingMode(CheckpointingMode.AT_LEAST_ONCE);
break;
default:
- LOG.warn("set checkpoint.mode failed, unknown
checkpoint.mode [{}],only support exactly-once,at-least-once", mode);
+ LOGGER.warn("set checkpoint.mode failed, unknown
checkpoint.mode [{}],only support exactly-once,at-least-once", mode);
break;
}
}
diff --git
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/EnvironmentUtil.java
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/EnvironmentUtil.java
index 174d6b4..6e515ed 100644
---
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/EnvironmentUtil.java
+++
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/EnvironmentUtil.java
@@ -29,7 +29,7 @@ import java.util.concurrent.TimeUnit;
public class EnvironmentUtil {
- private static final Logger LOG =
LoggerFactory.getLogger(EnvironmentUtil.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(EnvironmentUtil.class);
public static void setRestartStrategy(Config config, ExecutionConfig
executionConfig) {
try {
@@ -53,7 +53,7 @@ public class EnvironmentUtil {
Time.of(delayInterval,
TimeUnit.MILLISECONDS)));
break;
default:
- LOG.warn("set restart.strategy failed, unknown
restart.strategy [{}],only support no,fixed-delay,failure-rate",
restartStrategy);
+ LOGGER.warn("set restart.strategy failed, unknown
restart.strategy [{}],only support no,fixed-delay,failure-rate",
restartStrategy);
}
}
} catch (Exception e) {
diff --git
a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java
b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java
index 2c21ca1..4c7a952 100644
---
a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java
+++
b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java
@@ -43,7 +43,7 @@ import java.util.regex.Pattern;
* DorisDynamicOutputFormat
**/
public class DorisOutputFormat<T> extends RichOutputFormat<T> {
- private static final Logger LOG =
LoggerFactory.getLogger(DorisSinkFunction.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(DorisSinkFunction.class);
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
private static final String FIELD_DELIMITER_KEY = "column_separator";
private static final String FIELD_DELIMITER_DEFAULT = "\t";
@@ -186,7 +186,7 @@ public class DorisOutputFormat<T> extends
RichOutputFormat<T> {
try {
flush();
} catch (Exception e) {
- LOG.warn("Writing records to doris failed.", e);
+ LOGGER.warn("Writing records to doris failed.", e);
throw new RuntimeException("Writing records to doris failed.",
e);
}
}
@@ -214,7 +214,7 @@ public class DorisOutputFormat<T> extends
RichOutputFormat<T> {
batch.clear();
break;
} catch (Exception e) {
- LOG.error("doris sink error, retry times = {}", i, e);
+ LOGGER.error("doris sink error, retry times = {}", i, e);
if (i >= maxRetries) {
throw new IOException(e);
}
diff --git
a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java
b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java
index 68fea38..91928f6 100644
---
a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java
+++
b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java
@@ -44,7 +44,7 @@ import java.util.UUID;
*/
public class DorisStreamLoad implements Serializable {
- private static final Logger LOG =
LoggerFactory.getLogger(DorisStreamLoad.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(DorisStreamLoad.class);
private static final List<String> DORIS_SUCCESS_STATUS =
Arrays.asList("Success", "Publish Timeout");
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
private static final String LOAD_URL_PATTERN =
"http://%s/api/%s/%s/_stream_load?";;
@@ -82,7 +82,7 @@ public class DorisStreamLoad implements Serializable {
public void load(String value) {
LoadResponse loadResponse = loadBatch(value);
- LOG.info("Streamload Response:{}", loadResponse);
+ LOGGER.info("Streamload Response:{}", loadResponse);
if (loadResponse.status != 200) {
throw new RuntimeException("stream load error: " +
loadResponse.respContent);
} else {
@@ -138,7 +138,7 @@ public class DorisStreamLoad implements Serializable {
return new LoadResponse(status, respMsg, response.toString());
} catch (Exception e) {
String err = "failed to stream load data with label:" + label;
- LOG.warn(err, e);
+ LOGGER.warn(err, e);
throw new RuntimeException("stream load error: " + err);
} finally {
if (feConn != null) {
diff --git
a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
index 5d5d849..8777243 100644
---
a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
+++
b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
@@ -43,7 +43,7 @@ import java.io.PrintStream;
public class FileSink implements FlinkStreamSink<Row, Row>,
FlinkBatchSink<Row, Row> {
- private static final Logger LOG = LoggerFactory.getLogger(FileSink.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(FileSink.class);
private static final String PATH = "path";
private static final String FORMAT = "format";
@@ -83,7 +83,7 @@ public class FileSink implements FlinkStreamSink<Row, Row>,
FlinkBatchSink<Row,
outputFormat = new TextOutputFormat(filePath);
break;
default:
- LOG.warn(" unknown file_format [{}],only support
json,csv,text", format);
+ LOGGER.warn(" unknown file_format [{}],only support
json,csv,text", format);
break;
}
