forked from apache/flink-cdc
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathunexpected.yaml
More file actions
83 lines (82 loc) · 3.08 KB
/
unexpected.yaml
File metadata and controls
83 lines (82 loc) · 3.08 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
# 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.
group: Common
spec: Unexpected Structures
steps:
# Unexpected top-level block
- type: submit
yaml: |
source:
type: values
sink:
type: values
mapping:
- source: userUuid
sink: uuid
- source: userId
sink: user_id
- source: deviceUuid
sink: device_uuid
error: |
Unexpected key `mapping` in YAML top-level block.
Allowed keys in this context are: [source, sink, route, transform, pipeline]
Note: Flink configurations should be defined in "Runtime Configurations" instead of YAML scripts.
# Unexpected transform block keys
- type: submit
yaml: |
source:
type: values
sink:
type: values
transform:
- source-table: foo.bar
mapping:
- source: userUuid
sink: uuid
error: |
Unexpected key `mapping` in YAML transform block.
Allowed keys in this context are: [source-table, projection, filter, primary-keys, partition-keys, table-options, table-options.delimiter, description, converter-after-transform]
Note: option mapping: [{"source":"userUuid","sink":"uuid"}] is unexpected. It was silently ignored in previous versions, and probably should be removed.
# Unexpected route block keys
- type: submit
yaml: |
source:
type: values
sink:
type: values
route:
- source-table: foo.bar
sink-table: fun.baz
regex-style: java
error: |
Unexpected key `regex-style` in YAML route block.
Allowed keys in this context are: [source-table, sink-table, replace-symbol, description]
Note: option regex-style: "java" is unexpected. It was silently ignored in previous versions, and probably should be removed.
# Unexpected UDF block keys
- type: submit
yaml: |
source:
type: values
sink:
type: values
pipeline:
user-defined-function:
- name: addone
classpath: org.apache.flink.cdc.udf.examples.%s.AddOneFunctionClass
language: clojure
error: |
Unexpected key `language` in YAML UDF block.
Allowed keys in this context are: [name, classpath, options]
Note: option language: "clojure" is unexpected. It was silently ignored in previous versions, and probably should be removed.