Skip to content

Commit 6fbcbb9

Browse files
hailin0hailin0
committed
[Improve][Config] Support ignore plugin_input/plugin_output of simple job config
1 parent d58fce1 commit 6fbcbb9

File tree

591 files changed

+163
-1308
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

591 files changed

+163
-1308
lines changed

‎docs/en/concept/schema-evolution.md

-4
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,6 @@ env {
8585
source {
8686
# This is a example source plugin **only for test and demonstrate the feature source plugin**
8787
Oracle-CDC {
88-
plugin_output = "customers"
8988
username = "dbzuser"
9089
password = "dbz"
9190
database-names = ["ORCLCDB"]
@@ -101,7 +100,6 @@ source {
101100
102101
sink {
103102
Jdbc {
104-
plugin_input = "customers"
105103
driver = "oracle.jdbc.driver.OracleDriver"
106104
url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
107105
user = "dbzuser"
@@ -128,7 +126,6 @@ env {
128126
source {
129127
# This is a example source plugin **only for test and demonstrate the feature source plugin**
130128
Oracle-CDC {
131-
plugin_output = "customers"
132129
username = "dbzuser"
133130
password = "dbz"
134131
database-names = ["ORCLCDB"]
@@ -144,7 +141,6 @@ source {
144141
145142
sink {
146143
jdbc {
147-
plugin_input = "customers"
148144
url = "jdbc:mysql://oracle-host:3306/oracle_sink"
149145
driver = "com.mysql.cj.jdbc.Driver"
150146
user = "st_user_sink"

‎docs/en/concept/schema-feature.md

-2
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,6 @@ tables_configs = [
220220
source {
221221
FakeSource {
222222
parallelism = 2
223-
plugin_output = "fake"
224223
row.num = 16
225224
schema {
226225
table = "FakeDatabase.FakeTable"
@@ -274,7 +273,6 @@ If you only need to define the column, you can use fields to define the column,
274273
source {
275274
FakeSource {
276275
parallelism = 2
277-
plugin_output = "fake"
278276
row.num = 16
279277
schema = {
280278
fields {

‎docs/en/connector-v2/Config-Encryption-Decryption.md

-2
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@ Next, I'll show how to quickly use SeaTunnel's own `base64` encryption:
4242
4343
source {
4444
MySQL-CDC {
45-
plugin_output = "fake"
4645
parallelism = 1
4746
server-id = 5656
4847
port = 56725
@@ -96,7 +95,6 @@ Next, I'll show how to quickly use SeaTunnel's own `base64` encryption:
9695
"port" : 56725,
9796
"database-name" : "inventory_vwyw0n",
9897
"parallelism" : 1,
99-
"plugin_output" : "fake",
10098
"table-name" : "products",
10199
"plugin_name" : "MySQL-CDC",
102100
"server-id" : 5656,

‎docs/en/connector-v2/formats/avro.md

-3
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,6 @@ source {
5151
}
5252
}
5353
}
54-
plugin_output = "fake"
5554
}
5655
}
5756

@@ -76,7 +75,6 @@ source {
7675
Kafka {
7776
bootstrap.servers = "kafkaCluster:9092"
7877
topic = "test_avro_topic"
79-
plugin_output = "kafka_table"
8078
start_mode = "earliest"
8179
format = avro
8280
format_error_handle_way = skip
@@ -104,7 +102,6 @@ source {
104102

105103
sink {
106104
Console {
107-
plugin_input = "kafka_table"
108105
}
109106
}
110107
```

‎docs/en/connector-v2/formats/canal-json.md

-1
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,6 @@ source {
8585
Kafka {
8686
bootstrap.servers = "kafkaCluster:9092"
8787
topic = "products_binlog"
88-
plugin_output = "kafka_name"
8988
start_mode = earliest
9089
schema = {
9190
fields {

‎docs/en/connector-v2/formats/cdc-compatible-debezium-json.md

-4
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,6 @@ env {
1717

1818
source {
1919
MySQL-CDC {
20-
plugin_output = "table1"
21-
2220
base-url="jdbc:mysql://localhost:3306/test"
2321
"startup.mode"=INITIAL
2422
table-names=[
@@ -41,8 +39,6 @@ source {
4139

4240
sink {
4341
Kafka {
44-
plugin_input = "table1"
45-
4642
bootstrap.servers = "localhost:9092"
4743
topic = "${topic}"
4844

‎docs/en/connector-v2/formats/debezium-json.md

-1
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,6 @@ source {
8484
Kafka {
8585
bootstrap.servers = "kafkaCluster:9092"
8686
topic = "products_binlog"
87-
plugin_output = "kafka_name"
8887
start_mode = earliest
8988
schema = {
9089
fields {

‎docs/en/connector-v2/formats/kafka-compatible-kafkaconnect-json.md

-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ source {
1616
Kafka {
1717
bootstrap.servers = "localhost:9092"
1818
topic = "jdbc_source_record"
19-
plugin_output = "kafka_table"
2019
start_mode = earliest
2120
schema = {
2221
fields {

‎docs/en/connector-v2/formats/maxwell-json.md

-1
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,6 @@ source {
6262
Kafka {
6363
bootstrap.servers = "kafkaCluster:9092"
6464
topic = "products_binlog"
65-
plugin_output = "kafka_name"
6665
start_mode = earliest
6766
schema = {
6867
fields {

‎docs/en/connector-v2/formats/ogg-json.md

-1
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,6 @@ source {
6666
Kafka {
6767
bootstrap.servers = "127.0.0.1:9092"
6868
topic = "ogg"
69-
plugin_output = "kafka_name"
7069
start_mode = earliest
7170
schema = {
7271
fields {

‎docs/en/connector-v2/formats/protobuf.md

-3
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ env {
1717
source {
1818
FakeSource {
1919
parallelism = 1
20-
plugin_output = "fake"
2120
row.num = 16
2221
schema = {
2322
fields {
@@ -151,13 +150,11 @@ source {
151150
}
152151
bootstrap.servers = "kafkaCluster:9092"
153152
start_mode = "earliest"
154-
plugin_output = "kafka_table"
155153
}
156154
}
157155
158156
sink {
159157
Console {
160-
plugin_input = "kafka_table"
161158
}
162159
}
163160
```

‎docs/en/connector-v2/sink/AmazonSqs.md

-1
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,6 @@ source {
7070
}
7171
}
7272
}
73-
plugin_output = "fake"
7473
}
7574
}
7675

‎docs/en/connector-v2/sink/Assert.md

-2
Original file line numberDiff line numberDiff line change
@@ -267,13 +267,11 @@ source {
267267
]
268268
}
269269
]
270-
plugin_output = "fake"
271270
}
272271
}
273272
274273
sink{
275274
Assert {
276-
plugin_input = "fake"
277275
rules =
278276
{
279277
row_rules = [

‎docs/en/connector-v2/sink/Console.md

-2
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,6 @@ env {
4444
4545
source {
4646
FakeSource {
47-
plugin_output = "fake"
4847
schema = {
4948
fields {
5049
name = "string"
@@ -56,7 +55,6 @@ source {
5655
5756
sink {
5857
Console {
59-
plugin_input = "fake"
6058
}
6159
}
6260
```

‎docs/en/connector-v2/sink/DB2.md

-1
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,6 @@ source {
101101
# This is a example source plugin **only for test and demonstrate the feature source plugin**
102102
FakeSource {
103103
parallelism = 1
104-
plugin_output = "fake"
105104
row.num = 16
106105
schema = {
107106
fields {

‎docs/en/connector-v2/sink/HdfsFile.md

-1
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,6 @@ source {
9393
# This is a example source plugin **only for test and demonstrate the feature source plugin**
9494
FakeSource {
9595
parallelism = 1
96-
plugin_output = "fake"
9796
row.num = 16
9897
schema = {
9998
fields {

‎docs/en/connector-v2/sink/Iceberg.md

-1
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,6 @@ env {
9292
9393
source {
9494
MySQL-CDC {
95-
plugin_output = "customers_mysql_cdc_iceberg"
9695
server-id = 5652
9796
username = "st_user"
9897
password = "seatunnel"

‎docs/en/connector-v2/sink/Kafka.md

-1
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,6 @@ env {
111111
source {
112112
FakeSource {
113113
parallelism = 1
114-
plugin_output = "fake"
115114
row.num = 16
116115
schema = {
117116
fields {

‎docs/en/connector-v2/sink/Kingbase.md

-1
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,6 @@ source {
105105
# This is a example source plugin **only for test and demonstrate the feature source plugin**
106106
FakeSource {
107107
parallelism = 1
108-
plugin_output = "fake"
109108
row.num = 16
110109
schema = {
111110
fields {

‎docs/en/connector-v2/sink/Kudu.md

-2
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,6 @@ env {
6767
}
6868
source {
6969
FakeSource {
70-
plugin_output = "kudu"
7170
schema = {
7271
fields {
7372
id = int
@@ -114,7 +113,6 @@ env {
114113
115114
sink {
116115
kudu{
117-
plugin_input = "kudu"
118116
kudu_masters = "kudu-master-cdc:7051"
119117
table_name = "kudu_sink_table"
120118
enable_kerberos = true

‎docs/en/connector-v2/sink/Mysql.md

-1
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,6 @@ source {
112112
# This is a example source plugin **only for test and demonstrate the feature source plugin**
113113
FakeSource {
114114
parallelism = 1
115-
plugin_output = "fake"
116115
row.num = 16
117116
schema = {
118117
fields {

‎docs/en/connector-v2/sink/OceanBase.md

-1
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,6 @@ source {
111111
# This is a example source plugin **only for test and demonstrate the feature source plugin**
112112
FakeSource {
113113
parallelism = 1
114-
plugin_output = "fake"
115114
row.num = 16
116115
schema = {
117116
fields {

‎docs/en/connector-v2/sink/Oracle.md

-1
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,6 @@ env {
110110
source {
111111
FakeSource {
112112
parallelism = 1
113-
plugin_output = "fake"
114113
row.num = 16
115114
schema = {
116115
fields {

‎docs/en/connector-v2/sink/PostgreSql.md

-1
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,6 @@ env {
154154
source {
155155
FakeSource {
156156
parallelism = 1
157-
plugin_output = "fake"
158157
row.num = 16
159158
schema = {
160159
fields {

‎docs/en/connector-v2/sink/Prometheus.md

-1
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,6 @@ source {
6868
c_timestamp = timestamp
6969
}
7070
}
71-
plugin_output = "fake"
7271
rows = [
7372
{
7473
kind = INSERT

‎docs/en/connector-v2/sink/Pulsar.md

-2
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,6 @@ env {
145145
source {
146146
FakeSource {
147147
parallelism = 1
148-
plugin_output = "fake"
149148
row.num = 16
150149
schema = {
151150
fields {
@@ -161,7 +160,6 @@ sink {
161160
topic = "example"
162161
client.service-url = "localhost:pulsar://localhost:6650"
163162
admin.service-url = "http://my-broker.example.com:8080"
164-
plugin_output = "test"
165163
pulsar.config = {
166164
sendTimeoutMs = 30000
167165
}

‎docs/en/connector-v2/sink/RocketMQ.md

-2
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,6 @@ source {
115115
Rocketmq {
116116
name.srv.addr = "localhost:9876"
117117
topics = "test_topic"
118-
plugin_output = "rocketmq_table"
119118
schema = {
120119
fields {
121120
c_map = "map<string, string>"
@@ -161,7 +160,6 @@ source {
161160
Rocketmq {
162161
name.srv.addr = "localhost:9876"
163162
topics = "test_topic"
164-
plugin_output = "rocketmq_table"
165163
start.mode = "CONSUME_FROM_FIRST_OFFSET"
166164
batch.size = "400"
167165
consumer.group = "test_topic_group"

‎docs/en/connector-v2/sink/S3File.md

-1
Original file line numberDiff line numberDiff line change
@@ -315,7 +315,6 @@ source {
315315
# This is a example source plugin **only for test and demonstrate the feature source plugin**
316316
FakeSource {
317317
parallelism = 1
318-
plugin_output = "fake"
319318
row.num = 16
320319
schema = {
321320
fields {

‎docs/en/connector-v2/sink/Snowflake.md

-1
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,6 @@ source {
8989
# This is a example source plugin **only for test and demonstrate the feature source plugin**
9090
FakeSource {
9191
parallelism = 1
92-
plugin_output = "fake"
9392
row.num = 16
9493
schema = {
9594
fields {

‎docs/en/connector-v2/sink/Socket.md

-1
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@ env {
3939
4040
source {
4141
FakeSource {
42-
plugin_output = "fake"
4342
schema = {
4443
fields {
4544
name = "string"

‎docs/en/connector-v2/sink/SqlServer.md

-1
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,6 @@ sink {
147147
148148
```
149149
Jdbc {
150-
plugin_input = "customers"
151150
driver = com.microsoft.sqlserver.jdbc.SQLServerDriver
152151
url = "jdbc:sqlserver://localhost:1433;databaseName=column_type_test"
153152
user = SA

‎docs/en/connector-v2/sink/Typesense.md

-1
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,6 @@ Simple example:
7777
```bash
7878
sink {
7979
Typesense {
80-
plugin_input = "typesense_test_table"
8180
hosts = ["localhost:8108"]
8281
collection = "typesense_to_typesense_sink_with_query"
8382
max_retry_count = 3

‎docs/en/connector-v2/sink/Vertica.md

-1
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,6 @@ source {
109109
# This is a example source plugin **only for test and demonstrate the feature source plugin**
110110
FakeSource {
111111
parallelism = 1
112-
plugin_output = "fake"
113112
row.num = 16
114113
schema = {
115114
fields {

‎docs/en/connector-v2/source/Cassandra.md

-1
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,6 @@ source {
6767
datacenter = "datacenter1"
6868
keyspace = "test"
6969
cql = "select * from source_table"
70-
plugin_output = "source_table"
7170
}
7271
}
7372
```

‎docs/en/connector-v2/source/Clickhouse.md

-1
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,6 @@ source {
8080
username = "xxxxx"
8181
password = "xxxxx"
8282
server_time_zone = "UTC"
83-
plugin_output = "test"
8483
clickhouse.config = {
8584
"socket_timeout": "300000"
8685
}

0 commit comments

Comments
 (0)