Skip to content

Commit dcfc0af

Browse files
kalencayawangqi
kalencaya
and
wangqi
authored
[Feature][scaleph-plugin-seatunnel-connectors] upgrade seatunnel connectors to 2.3.8 (flowerfine#754)
* feature: update prometheus operator 部署 * feature: upgrade seatunnel to 2.3.6 * feature: upgrade seatunnel cassandra connector to 2.3.7 * feature: upgrade seatunnel oracle-cdc connector to 2.3.7 * feature: update minio bucket policy * feature: upgrade seatunnel to 2.3.8 * feature: upgrade seatunnel clickhouse to 2.3.8 * feature: upgrade seatunnel doris to 2.3.8 * feature: upgrade seatunnel elasticsearch to 2.3.8 * feature: upgrade seatunnel email to 2.3.8 --------- Co-authored-by: wangqi <wangqi@xinxuan.net>
1 parent ad7f1ae commit dcfc0af

File tree

25 files changed

+105
-35
lines changed

25 files changed

+105
-35
lines changed

‎.github/workflows/release-manual-docker-seatunnel.yml

+2-2
Original file line numberDiff line numberDiff line change
@@ -22,11 +22,11 @@ on:
2222
seatunnelVersion:
2323
description: 'seatunnel version'
2424
required: true
25-
default: '2.3.7'
25+
default: '2.3.8'
2626
type: choice
2727
options:
28+
- 2.3.8
2829
- 2.3.7
29-
- 2.3.6
3030
flinkVersion:
3131
description: 'flink version'
3232
required: true

‎README.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ Scaleph is driven by personal interest and evolves actively through faithful dev
1313
* Data Integration
1414
* Web-ui click-and-drag data integration ways backended by [Apache SeaTunnel](https://seatunnel.apache.org/) on Flink engine.
1515

16-
* Support the latest 2.3.7 V2 out-of-the-box connectors and transforms.
16+
* Support the latest 2.3.8 V2 out-of-the-box connectors and transforms.
1717

1818
* DataSource management.
1919

‎scaleph-application/scaleph-application-flink/src/main/java/cn/sliew/scaleph/application/flink/resource/handler/FlinkImageMapping.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public enum FlinkImageMapping {
3838
SQL_1_17(FlinkJobType.SQL, OperatorFlinkVersion.v1_17, FlinkVersionMapping.V_1_17, "ghcr.io/flowerfine/scaleph-sql-template:1.17"),
3939
SQL_1_18(FlinkJobType.SQL, OperatorFlinkVersion.v1_18, FlinkVersionMapping.V_1_18, "ghcr.io/flowerfine/scaleph-sql-template:1.18"),
4040

41-
SEATUNNEL_1_16(FlinkJobType.SEATUNNEL, OperatorFlinkVersion.v1_16, FlinkVersionMapping.V_1_16, "ghcr.io/flowerfine/scaleph-seatunnel:2.3.7-flink-1.16"),
41+
SEATUNNEL_1_16(FlinkJobType.SEATUNNEL, OperatorFlinkVersion.v1_16, FlinkVersionMapping.V_1_16, "ghcr.io/flowerfine/scaleph-seatunnel:2.3.8-flink-1.16"),
4242
FLINK_CDC_1_18(FlinkJobType.FLINK_CDC, OperatorFlinkVersion.v1_18, FlinkVersionMapping.V_1_18, "ghcr.io/flowerfine/scaleph-flink-cdc:3.0.0-flink-1.18"),
4343
;
4444

‎scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelVersion.java

+1
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ public enum SeaTunnelVersion implements DictInstance {
3333
V_2_3_5("2.3.5", "2.3.5"),
3434
V_2_3_6("2.3.6", "2.3.6"),
3535
V_2_3_7("2.3.7", "2.3.7"),
36+
V_2_3_8("2.3.8", "2.3.8"),
3637
;
3738

3839
@JsonCreator

‎scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/clickhosue/ClickHouseProperties.java

+10
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
package cn.sliew.scaleph.plugin.seatunnel.flink.connectors.clickhosue;
2020

2121
import cn.sliew.scaleph.plugin.framework.property.*;
22+
import org.codehaus.jackson.JsonNode;
2223

2324
public enum ClickHouseProperties {
2425
;
@@ -60,4 +61,13 @@ public enum ClickHouseProperties {
6061
.addValidator(Validators.NON_BLANK_VALIDATOR)
6162
.validateAndBuild();
6263

64+
public static final PropertyDescriptor<JsonNode> CLICKHOUSE_CONFIG = new PropertyDescriptor.Builder()
65+
.name("clickhouse.config")
66+
.description(
67+
"clickhouse.* The way to specify the parameter is to add the prefix clickhouse. to the original parameter name. For example, the way to specify socket_timeout is: clickhouse.socket_timeout = 50000 . "
68+
+ "If these non-essential parameters are not specified, they will use the default values given by clickhouse-jdbc.\n")
69+
.type(PropertyType.OBJECT)
70+
.parser(Parsers.JSON_PARSER)
71+
.validateAndBuild();
72+
6373
}

‎scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/clickhosue/sink/ClickHouseSinkProperties.java

-9
Original file line numberDiff line numberDiff line change
@@ -33,15 +33,6 @@ public enum ClickHouseSinkProperties {
3333
.addValidator(Validators.NON_BLANK_VALIDATOR)
3434
.validateAndBuild();
3535

36-
public static final PropertyDescriptor<JsonNode> CLICKHOUSE_CONFIG = new PropertyDescriptor.Builder()
37-
.name("clickhouse.config")
38-
.description(
39-
"clickhouse.* The way to specify the parameter is to add the prefix clickhouse. to the original parameter name. For example, the way to specify socket_timeout is: clickhouse.socket_timeout = 50000 . "
40-
+ "If these non-essential parameters are not specified, they will use the default values given by clickhouse-jdbc.\n")
41-
.type(PropertyType.OBJECT)
42-
.parser(Parsers.JSON_PARSER)
43-
.validateAndBuild();
44-
4536
public static final PropertyDescriptor<Integer> BULK_SIZE = new PropertyDescriptor.Builder()
4637
.name("bulk_size")
4738
.description(

‎scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/clickhosue/source/ClickHouseSourcePlugin.java

+1
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ public ClickHouseSourcePlugin() {
5050
final List<PropertyDescriptor> props = new ArrayList<>();
5151
props.add(SQL);
5252
props.add(SERVER_TIME_ZONE);
53+
props.add(CLICKHOUSE_CONFIG);
5354
props.add(CommonProperties.PARALLELISM);
5455
props.add(CommonProperties.RESULT_TABLE_NAME);
5556
supportedProperties = Collections.unmodifiableList(props);

‎scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/doris/source/DorisSourcePlugin.java

+2
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737
import java.util.List;
3838

3939
import static cn.sliew.scaleph.plugin.seatunnel.flink.connectors.doris.DorisProperties.*;
40+
import static cn.sliew.scaleph.plugin.seatunnel.flink.connectors.doris.DorisProperties.DORIS_BATCH_SIZE;
4041
import static cn.sliew.scaleph.plugin.seatunnel.flink.connectors.doris.source.DorisSourceProperties.*;
4142

4243
@AutoService(SeaTunnelConnectorPlugin.class)
@@ -51,6 +52,7 @@ public DorisSourcePlugin() {
5152
props.add(TABLE);
5253
props.add(DORIS_READ_FIELD);
5354
props.add(DORIS_FILTER_QUERY);
55+
props.add(DORIS_BATCH_SIZE);
5456
props.add(DORIS_REQUEST_CONNECT_TIMEOUT_MS);
5557
props.add(DORIS_REQUEST_QUERY_TIMEOUT_S);
5658
props.add(DORIS_REQUEST_READ_TIMEOUT_MS);

‎scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/elasticsearch/source/ElasticsearchSourcePlugin.java

+2
Original file line numberDiff line numberDiff line change
@@ -47,8 +47,10 @@ public ElasticsearchSourcePlugin() {
4747
"Used to read data from Elasticsearch. support version >= 2.x and < 8.x.",
4848
ElasticsearchSourcePlugin.class.getName());
4949
final List<PropertyDescriptor> props = new ArrayList<>();
50+
props.add(INDEX_LIST);
5051
props.add(INDEX);
5152
props.add(SOURCE);
53+
props.add(ARRAY_COLUMN);
5254
props.add(QUERY);
5355
props.add(SCROLL_TIME);
5456
props.add(SCROLL_SIZE);

‎scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/elasticsearch/source/ElasticsearchSourceProperties.java

+16
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,14 @@
2727
public enum ElasticsearchSourceProperties {
2828
;
2929

30+
public static final PropertyDescriptor<JsonNode> INDEX_LIST = new PropertyDescriptor.Builder()
31+
.name("index_list")
32+
.description("The index_list is used to define multi-index synchronization tasks")
33+
.type(PropertyType.OBJECT)
34+
.parser(Parsers.JSON_PARSER)
35+
.addValidator(Validators.NON_BLANK_VALIDATOR)
36+
.validateAndBuild();
37+
3038
public static final PropertyDescriptor<JsonNode> SOURCE = new PropertyDescriptor.Builder()
3139
.name("source")
3240
.description("The fields of index.")
@@ -35,6 +43,14 @@ public enum ElasticsearchSourceProperties {
3543
.addValidator(Validators.NON_BLANK_VALIDATOR)
3644
.validateAndBuild();
3745

46+
public static final PropertyDescriptor<String> ARRAY_COLUMN = new PropertyDescriptor.Builder()
47+
.name("array_column")
48+
.description("The fields of array type")
49+
.type(PropertyType.STRING)
50+
.parser(Parsers.STRING_PARSER)
51+
.addValidator(Validators.NON_BLANK_VALIDATOR)
52+
.validateAndBuild();
53+
3854
public static final PropertyDescriptor<JsonNode> QUERY = new PropertyDescriptor.Builder()
3955
.name("query")
4056
.description("Elasticsearch DSL. You can control the range of data read.")

‎scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/email/sink/EmailSinkPlugin.java

+1
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@ public EmailSinkPlugin() {
4343
props.add(EMAIL_TRANSPORT_PROTOCOL);
4444
props.add(EMAIL_FROM_ADDRESS);
4545
props.add(EMAIL_SMTP_AUTH);
46+
props.add(EMAIL_SMTP_PORT);
4647
props.add(EMAIL_AUTHORIZATION_CODE);
4748
props.add(EMAIL_TO_ADDRESS);
4849
props.add(EMAIL_MESSAGE_HEADLINE);

‎scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/email/sink/EmailSinkProperties.java

+13-5
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
package cn.sliew.scaleph.plugin.seatunnel.flink.connectors.email.sink;
2020

2121
import cn.sliew.scaleph.plugin.framework.property.*;
22+
import com.amazonaws.services.dynamodbv2.xspec.BOOL;
2223

2324
public enum EmailSinkProperties {
2425
;
@@ -50,13 +51,20 @@ public enum EmailSinkProperties {
5051
.addValidator(Validators.NON_BLANK_VALIDATOR)
5152
.validateAndBuild();
5253

53-
public static final PropertyDescriptor<String> EMAIL_SMTP_AUTH = new PropertyDescriptor.Builder()
54+
public static final PropertyDescriptor<BOOL> EMAIL_SMTP_AUTH = new PropertyDescriptor.Builder()
5455
.name("email_smtp_auth")
5556
.description("Whether to authenticate the customer")
56-
.type(PropertyType.STRING)
57-
.parser(Parsers.STRING_PARSER)
58-
.properties(Property.Required)
59-
.addValidator(Validators.NON_BLANK_VALIDATOR)
57+
.type(PropertyType.BOOLEAN)
58+
.parser(Parsers.BOOLEAN_PARSER)
59+
.addValidator(Validators.BOOLEAN_VALIDATOR)
60+
.validateAndBuild();
61+
62+
public static final PropertyDescriptor<Integer> EMAIL_SMTP_PORT = new PropertyDescriptor.Builder()
63+
.name("email_smtp_port")
64+
.description("Select port for authentication.")
65+
.type(PropertyType.INT)
66+
.parser(Parsers.INTEGER_PARSER)
67+
.addValidator(Validators.INTEGER_VALIDATOR)
6068
.validateAndBuild();
6169

6270
public static final PropertyDescriptor<String> EMAIL_AUTHORIZATION_CODE = new PropertyDescriptor.Builder()

‎scaleph-ui-react/src/locales/zh-CN/pages/project.ts

+4-1
Original file line numberDiff line numberDiff line change
@@ -334,6 +334,7 @@ export default {
334334
'pages.project.di.step.email.emailTransportProtocol': '邮件传输协议',
335335
'pages.project.di.step.email.emailFromAddress': '邮件发送者地址',
336336
'pages.project.di.step.email.emailSmtpAuth': '启用SMTP认证',
337+
'pages.project.di.step.email.emailSmtpPort': 'SMTP端口号',
337338
'pages.project.di.step.email.emailAuthorizationCode': 'SMTP认证代码',
338339
'pages.project.di.step.email.emailToAddress': '邮件接收者地址',
339340
'pages.project.di.step.email.emailMessageHeadline': '邮件标题',
@@ -611,6 +612,8 @@ export default {
611612
'pages.project.di.step.elasticsearch.scrollSize': '滚动大小',
612613
'pages.project.di.step.elasticsearch.source': '字段列表',
613614
'pages.project.di.step.elasticsearch.source.tooltip': '字段列表',
615+
'pages.project.di.step.elasticsearch.arrayColumn': '数组字段',
616+
'pages.project.di.step.elasticsearch.arrayColumn.placeholder': '{tags = "array<string>",phones = "array<string>"}',
614617

615618
// neo4j
616619
'pages.project.di.step.neo4j.uri': 'URI',
@@ -679,7 +682,7 @@ export default {
679682
'pages.project.di.step.doris.sinkMaxRetries': '重试次数',
680683
'pages.project.di.step.doris.sinkBufferSize': 'Buffer 大小',
681684
'pages.project.di.step.doris.sinkBufferCount': 'Buffer 数量',
682-
'pages.project.di.step.doris.dorisBatchSize': '批量写入数量',
685+
'pages.project.di.step.doris.dorisBatchSize': '批量读取或写入数量',
683686
'pages.project.di.step.doris.needsUnsupportedTypeCasting': '启用类型转换',
684687
'pages.project.di.step.doris.needsUnsupportedTypeCasting.tooltip': '上游数据类型和 Doris 数据类型不匹配时，将上游数据转换成 Doris 支持的数据类型。如 Decimal64 转换成 Double',
685688
'pages.project.di.step.doris.saveModeCreateTemplate': 'Schema 创建模板',

‎scaleph-ui-react/src/pages/Project/Workspace/DataIntegration/SeaTunnel/Dag/components/node/canvas-node.tsx

+1-1
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ const SeaTunnelConnectorDagNode = ({node}: { node: Node }) => {
6464
>
6565
<Popover title={<div>
6666
<Typography.Text>{node.data.label}</Typography.Text>
67-
<a href="https://seatunnel.apache.org/docs/2.3.7/about/" target="_blank">
67+
<a href="https://seatunnel.apache.org/docs/2.3.8/about/" target="_blank">
6868
<Button shape="default" type="link" icon={<InfoCircleOutlined/>}/>
6969
</a>
7070
</div>}

‎scaleph-ui-react/src/pages/Project/Workspace/DataIntegration/SeaTunnel/Dag/components/node/steps/constant.tsx

+2
Original file line numberDiff line numberDiff line change
@@ -246,6 +246,7 @@ export const EmailParams = {
246246
emailTransportProtocol: 'email_transport_protocol',
247247
emailFromAddress: 'email_from_address',
248248
emailSmtpAuth: 'email_smtp_auth',
249+
emailSmtpPort: 'email_smtp_port',
249250
emailAuthorizationCode: 'email_authorization_code',
250251
emailToAddress: 'email_to_address',
251252
emailMessageHeadline: 'email_message_headline',
@@ -500,6 +501,7 @@ export const ElasticsearchParams = {
500501
scrollTime: "scroll_time",
501502
scrollSize: "scroll_size",
502503
source: "source",
504+
arrayColumn: "array_column",
503505
schema: "schema"
504506
};
505507

‎scaleph-ui-react/src/pages/Project/Workspace/DataIntegration/SeaTunnel/Dag/components/node/steps/sink/sink-email-step.tsx

+7-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ import React, {useEffect} from 'react';
22
import {Form} from 'antd';
33
import {
44
DrawerForm,
5-
ProFormDependency,
5+
ProFormDependency, ProFormDigit,
66
ProFormGroup,
77
ProFormSelect,
88
ProFormSwitch,
@@ -81,6 +81,12 @@ const SinkEmailStepForm: React.FC<ModalFormProps<Node>> = ({data, visible, onVis
8181
if (email_smtp_auth) {
8282
return (
8383
<ProFormGroup>
84+
<ProFormDigit
85+
name={EmailParams.emailSmtpPort}
86+
label={intl.formatMessage({id: 'pages.project.di.step.email.emailSmtpPort'})}
87+
min={0}
88+
initialValue={465}
89+
/>
8490
<ProFormTextArea
8591
name={EmailParams.emailAuthorizationCode}
8692
label={intl.formatMessage({id: 'pages.project.di.step.email.emailAuthorizationCode'})}

‎scaleph-ui-react/src/pages/Project/Workspace/DataIntegration/SeaTunnel/Dag/components/node/steps/source/source-clickhouse-step.tsx

+14-1
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,14 @@
11
import React, {useEffect} from 'react';
22
import {Form} from 'antd';
33
import {InfoCircleOutlined} from "@ant-design/icons";
4-
import {DrawerForm, ProFormText, ProFormTextArea,} from '@ant-design/pro-components';
4+
import {DrawerForm, ProFormGroup, ProFormText, ProFormTextArea,} from '@ant-design/pro-components';
55
import {getIntl, getLocale} from "@umijs/max";
66
import {Node, XFlow} from '@antv/xflow';
77
import {ModalFormProps} from '@/typings';
88
import {ClickHouseParams, STEP_ATTR_TYPE} from '../constant';
99
import DataSourceItem from "../dataSource";
10+
import CommonConfigItem
11+
from "@/pages/Project/Workspace/DataIntegration/SeaTunnel/Dag/components/node/steps/common/config/commonConfig";
1012

1113
const SourceClickHouseStepForm: React.FC<ModalFormProps<Node>> = ({data, visible, onVisibleChange, onOK}) => {
1214
const intl = getIntl(getLocale());
@@ -58,6 +60,17 @@ const SourceClickHouseStepForm: React.FC<ModalFormProps<Node>> = ({data, visible
5860
icon: <InfoCircleOutlined/>,
5961
}}
6062
/>
63+
<ProFormGroup
64+
title={intl.formatMessage({id: 'pages.project.di.step.clickhosue.clickhouseConf'})}
65+
tooltip={{
66+
title: intl.formatMessage({id: 'pages.project.di.step.clickhosue.clickhouseConf.tooltip'}),
67+
icon: <InfoCircleOutlined/>,
68+
}}
69+
collapsible={true}
70+
defaultCollapsed={true}
71+
>
72+
<CommonConfigItem data={ClickHouseParams.clickhouseConf}/>
73+
</ProFormGroup>
6174
</DrawerForm>
6275
</XFlow>
6376
);

‎scaleph-ui-react/src/pages/Project/Workspace/DataIntegration/SeaTunnel/Dag/components/node/steps/source/source-doris-step.tsx

+9
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,15 @@ const SourceDorisStepForm: React.FC<ModalFormProps<Node>> = ({data, visible, onV
6969
placeholder={intl.formatMessage({id: 'pages.project.di.step.doris.dorisFiterQuery.placeholder'})}
7070
colProps={{span: 12}}
7171
/>
72+
<ProFormDigit
73+
name={DorisParams.dorisBatchSize}
74+
label={intl.formatMessage({id: 'pages.project.di.step.doris.dorisBatchSize'})}
75+
initialValue={1024}
76+
fieldProps={{
77+
step: 1024,
78+
min: 1
79+
}}
80+
/>
7281
<ProFormDigit
7382
name={DorisParams.dorisRequestConnectTimeoutMs}
7483
label={intl.formatMessage({id: 'pages.project.di.step.doris.dorisRequestConnectTimeoutMs'})}

‎scaleph-ui-react/src/pages/Project/Workspace/DataIntegration/SeaTunnel/Dag/components/node/steps/source/source-elasticsearch-step.tsx

+6-1
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,12 @@ const SourceElasticsearchStepForm: React.FC<ModalFormProps<Node>> = ({data, visi
8888
>
8989
<CommonListItem data={ElasticsearchParams.source}/>
9090
</ProFormGroup>
91-
<FieldItem/>
91+
<ProFormText
92+
name={ElasticsearchParams.arrayColumn}
93+
label={intl.formatMessage({id: 'pages.project.di.step.elasticsearch.arrayColumn'})}
94+
placeholder={intl.formatMessage({id: 'pages.project.di.step.elasticsearch.arrayColumn.placeholder'})}
95+
/>
96+
{/*<FieldItem/>*/}
9297
</DrawerForm>
9398
</XFlow>
9499
);

‎tools/docker/build/scaleph-seatunnel/Dockerfile

+1-1
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ ARG FLINK_VERSION=1.16
1818
ARG BASE_RELEASE_IMAGE=flink:${FLINK_VERSION}
1919
FROM $BASE_RELEASE_IMAGE as release
2020

21-
ARG SEATUNNEL_VERSION=2.3.7
21+
ARG SEATUNNEL_VERSION=2.3.8
2222
ARG TAR_FILE=apache-seatunnel-${SEATUNNEL_VERSION}-bin.tar.gz
2323

2424
ENV SEATUNNEL_HOME=/opt/seatunnel

‎tools/docker/build/scaleph-seatunnel/Dockerfile_backup

+1-1
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ ARG FLINK_VERSION=1.15
1818
ARG BASE_RELEASE_IMAGE=flink:${FLINK_VERSION}
1919
FROM maven:3.8-eclipse-temurin-11 as build
2020

21-
ARG SEATUNNEL_VERSION=2.3.7
21+
ARG SEATUNNEL_VERSION=2.3.8
2222

2323
ENV SEATUNNEL_HOME=/opt/seatunnel
2424

‎tools/docker/build/scaleph-seatunnel/Dockerfile_single

+1-1
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ ARG FLINK_VERSION=1.15
1818
ARG BASE_RELEASE_IMAGE=flink:${FLINK_VERSION}
1919
FROM $BASE_RELEASE_IMAGE as release
2020

21-
ARG SEATUNNEL_VERSION=2.3.7
21+
ARG SEATUNNEL_VERSION=2.3.8
2222

2323
ENV SEATUNNEL_HOME=/opt/seatunnel
2424

‎tools/docker/build/scaleph-seatunnel/install-plugin.sh

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
SEATUNNEL_HOME=$(cd $(dirname $0);cd ../;pwd)
2525

2626
# connector default version is 2.3.4, you can also choose a custom version. eg: 2.1.2: sh install-plugin.sh 2.1.2
27-
version=2.3.7
27+
version=2.3.8
2828

2929
if [ -n "$1" ]; then
3030
version="$1"

‎tools/docker/local/docker-compose.yml

+1-1
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ services:
5858
environment:
5959
- MINIO_ROOT_USER=admin
6060
- MINIO_ROOT_PASSWORD=password
61-
- MINIO_DEFAULT_BUCKETS=scaleph
61+
- MINIO_DEFAULT_BUCKETS=scaleph,scaleph-public:public
6262
ports:
6363
- 9000:9000
6464
- 9001:9001

‎tools/docker/mysql/init.d/scaleph-ws-mysql.sql

+7-7
Original file line numberDiff line numberDiff line change
@@ -176,25 +176,25 @@ create table ws_artifact_seatunnel
176176
) engine = innodb comment 'artifact seatunnel';
177177
INSERT INTO ws_artifact_seatunnel(id, artifact_id, seatunnel_engine, flink_version, seatunnel_version, dag_id, current,
178178
creator, editor)
179-
VALUES (1, 4, 'seatunnel', '1.16.3', '2.3.7', 1, 1, 'sys', 'sys');
179+
VALUES (1, 4, 'seatunnel', '1.16.3', '2.3.8', 1, 1, 'sys', 'sys');
180180
INSERT INTO ws_artifact_seatunnel(id, artifact_id, seatunnel_engine, flink_version, seatunnel_version, dag_id, current,
181181
creator, editor)
182-
VALUES (2, 5, 'seatunnel', '1.16.3', '2.3.7', 2, 1, 'sys', 'sys');
182+
VALUES (2, 5, 'seatunnel', '1.16.3', '2.3.8', 2, 1, 'sys', 'sys');
183183
INSERT INTO ws_artifact_seatunnel(id, artifact_id, seatunnel_engine, flink_version, seatunnel_version, dag_id, current,
184184
creator, editor)
185-
VALUES (3, 11, 'seatunnel', '1.16.3', '2.3.7', 8, 1, 'sys', 'sys');
185+
VALUES (3, 11, 'seatunnel', '1.16.3', '2.3.8', 8, 1, 'sys', 'sys');
186186
INSERT INTO ws_artifact_seatunnel(id, artifact_id, seatunnel_engine, flink_version, seatunnel_version, dag_id, current,
187187
creator, editor)
188-
VALUES (4, 12, 'seatunnel', '1.16.3', '2.3.7', 9, '1', 'sys', 'sys');
188+
VALUES (4, 12, 'seatunnel', '1.16.3', '2.3.8', 9, '1', 'sys', 'sys');
189189
INSERT INTO `ws_artifact_seatunnel`(`id`, `artifact_id`, `seatunnel_engine`, `flink_version`, `seatunnel_version`,
190190
`dag_id`, `current`, `creator`, `editor`)
191-
VALUES (5, 13, 'seatunnel', '1.16.3', '2.3.7', 10, '1', 'sys', 'sys');
191+
VALUES (5, 13, 'seatunnel', '1.16.3', '2.3.8', 10, '1', 'sys', 'sys');
192192
INSERT INTO `ws_artifact_seatunnel`(`id`, `artifact_id`, `seatunnel_engine`, `flink_version`, `seatunnel_version`,
193193
`dag_id`, `current`, `creator`, `editor`)
194-
VALUES (6, 14, 'seatunnel', '1.16.3', '2.3.7', 11, '1', 'sys', 'sys');
194+
VALUES (6, 14, 'seatunnel', '1.16.3', '2.3.8', 11, '1', 'sys', 'sys');
195195
INSERT INTO `ws_artifact_seatunnel`(`id`, `artifact_id`, `seatunnel_engine`, `flink_version`, `seatunnel_version`,
196196
`dag_id`, `current`, `creator`, `editor`)
197-
VALUES (7, 15, 'seatunnel', '1.16.3', '2.3.7', 12, '1', 'sys', 'sys');
197+
VALUES (7, 15, 'seatunnel', '1.16.3', '2.3.8', 12, '1', 'sys', 'sys');
198198

199199
DROP TABLE IF EXISTS ws_flink_kubernetes_template;
200200
CREATE TABLE ws_flink_kubernetes_template

0 commit comments

Comments
 (0)