This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 2b711af [docs] update readme.md flink version (#62)
2b711af is described below
commit 2b711af1656237187f63952a3f731bae627c8789
Author: zhou zhuohan <[email protected]>
AuthorDate: Wed Sep 14 09:37:17 2022 +0800
[docs] update readme.md flink version (#62)
Co-authored-by: ninjazhou <[email protected]>
---
README.md | 4 ++--
flink-doris-connector/build.sh | 2 +-
.../src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java | 3 ---
.../java/org/apache/doris/flink/datastream/DorisSourceFunction.java | 2 +-
.../src/main/java/org/apache/doris/flink/rest/RestService.java | 2 +-
5 files changed, 5 insertions(+), 8 deletions(-)
diff --git a/README.md b/README.md
index dd69234..86b5c1b 100644
--- a/README.md
+++ b/README.md
@@ -24,7 +24,7 @@ under the License.
## Flink Doris Connector
-Flink Doris Connector now support flink version from 1.11 to 1.14.
+Flink Doris Connector now support flink version from 1.11 to 1.15.
If you wish to contribute or use a connector from flink 1.13 (and earlier),
please use the
[branch-for-flink-before-1.13](https://github.com/apache/doris-flink-connector/tree/branch-for-flink-before-1.13)
@@ -37,7 +37,7 @@ More information about compilation and usage, please visit
[Flink Doris Connecto
## Building
You need to copy customer_env.sh.tpl to customer_env.sh before build and you
need to configure it before build.
```shell
-sh build.sh --flink 1.14.3 --scala 2.12
+sh build.sh --flink 1.15.2 --scala 2.12
```
If you are using mac, you must install gnu-getopt before executing the
build.sh.
diff --git a/flink-doris-connector/build.sh b/flink-doris-connector/build.sh
index d0ca34d..203e57e 100755
--- a/flink-doris-connector/build.sh
+++ b/flink-doris-connector/build.sh
@@ -36,7 +36,7 @@ usage() {
$0 --flink version --scala version # specify flink and scala version
$0 --tag # this is a build from tag
e.g.:
- $0 --flink 1.14.3 --scala 2.12
+ $0 --flink 1.15.2 --scala 2.12
$0 --tag
"
exit 1
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java
index 00f7fb3..3b5834f 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java
@@ -81,9 +81,6 @@ import static
org.apache.doris.flink.table.DorisConfigOptions.USERNAME;
import static org.apache.flink.table.factories.FactoryUtil.CONNECTOR;
import static org.apache.flink.util.Preconditions.checkArgument;
-/**
- * ClickHouse catalog.
- */
public class DorisCatalog extends AbstractCatalog {
private static final Logger LOG =
LoggerFactory.getLogger(DorisCatalog.class);
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
index fc5fd14..3199eed 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
@@ -70,7 +70,7 @@ public class DorisSourceFunction extends
RichParallelSourceFunction<List<?>> imp
}
/**
- * Assign patitions to each task.
+ * Assign partitions to each task.
*/
private void assignTaskPartitions() {
int taskIndex = getRuntimeContext().getIndexOfThisSubtask();
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
index ff03e01..2f93f95 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
@@ -493,7 +493,7 @@ public class RestService implements Serializable {
*
* @param options configuration of request
* @param logger {@link Logger}
- * @return an list of Doris partitions
+ * @return a list of Doris partitions
* @throws DorisException throw when find partition failed
*/
public static List<PartitionDefinition> findPartitions(DorisOptions
options, DorisReadOptions readOptions, Logger logger) throws DorisException {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
