This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository
https://gitbox.apache.org/repos/asf/incubator-doris-flink-connector.git
commit 87ccd3e10914b13bd6abf56c28bbeb7dcbc19bab
Author: Mingyu Chen <morningman....@gmail.com>
AuthorDate: Tue Nov 16 18:37:54 2021 +0800
[License] Add License header for missing files (#7130)
1. Add License header for missing files
2. Modify the spark pom.xml to correct the location of `thrift`
---
pom.xml | 20 ++++++++++++++++++++
.../java/org/apache/doris/flink/cfg/DorisSink.java | 17 +++++++++++++++++
.../doris/flink/cfg/GenericDorisSinkFunction.java | 19 ++++++++++++++++++-
.../apache/doris/flink/DorisStreamSinkExample.java | 19 ++++++++++++++++++-
4 files changed, 73 insertions(+), 2 deletions(-)
diff --git a/pom.xml b/pom.xml
index c5c3905..3cdd0db 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1,4 +1,24 @@
<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements. See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership. The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied. See the License for the
+specific language governing permissions and limitations
+under the License.
+-->
+
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
diff --git a/src/main/java/org/apache/doris/flink/cfg/DorisSink.java
b/src/main/java/org/apache/doris/flink/cfg/DorisSink.java
index f11c587..2c3db4c 100644
--- a/src/main/java/org/apache/doris/flink/cfg/DorisSink.java
+++ b/src/main/java/org/apache/doris/flink/cfg/DorisSink.java
@@ -1,3 +1,20 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
package org.apache.doris.flink.cfg;
import org.apache.doris.flink.table.DorisDynamicOutputFormat;
diff --git
a/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
b/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
index 92dd300..6be6aa4 100644
--- a/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
+++ b/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
@@ -1,3 +1,20 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
package org.apache.doris.flink.cfg;
import org.apache.doris.flink.table.DorisDynamicOutputFormat;
@@ -50,4 +67,4 @@ public class GenericDorisSinkFunction<T> extends
RichSinkFunction<T>
super.close();
}
-}
\ No newline at end of file
+}
diff --git a/src/test/java/org/apache/doris/flink/DorisStreamSinkExample.java
b/src/test/java/org/apache/doris/flink/DorisStreamSinkExample.java
index d37fd0d..cf35db6 100644
--- a/src/test/java/org/apache/doris/flink/DorisStreamSinkExample.java
+++ b/src/test/java/org/apache/doris/flink/DorisStreamSinkExample.java
@@ -1,3 +1,20 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
package org.apache.doris.flink;
import org.apache.doris.flink.cfg.DorisExecutionOptions;
@@ -216,4 +233,4 @@ public class DorisStreamSinkExample {
));
env.execute("doris stream sink example");
}
-}
\ No newline at end of file
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
