-
Notifications
You must be signed in to change notification settings - Fork 1.8k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[Improve][Transform] Support errorHandleWay on jsonpath transform #7524
Conversation
good idea |
13682b1
to
fabd8c1
Compare
fabd8c1
to
2d9131e
Compare
...-v2/src/main/java/org/apache/seatunnel/transform/common/AbstractCatalogSupportTransform.java
Outdated
Show resolved
Hide resolved
...transforms-v2/src/test/java/org/apache/seatunnel/transform/JsonPathTransformFactoryTest.java
Outdated
Show resolved
Hide resolved
2d9131e
to
d3af0c7
Compare
@@ -102,11 +104,23 @@ public List<DatasetTableInfo> execute(List<DatasetTableInfo> upstreamDataStreams | |||
} | |||
ClassLoader classLoader = Thread.currentThread().getContextClassLoader(); | |||
DatasetTableInfo input = upstreamDataStreams.get(0); | |||
|
|||
Map<String, DatasetTableInfo> outputTables = | |||
upstreamDataStreams.stream() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fix spark bugs when jsonpath e2e
@@ -85,12 +88,22 @@ public List<DataStreamTableInfo> execute(List<DataStreamTableInfo> upstreamDataS | |||
return upstreamDataStreams; | |||
} | |||
DataStreamTableInfo input = upstreamDataStreams.get(0); | |||
Map<String, DataStreamTableInfo> outputTables = |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fix spark bugs when jsonpath e2e
d3af0c7
to
62631e6
Compare
...transforms-v2/src/test/java/org/apache/seatunnel/transform/JsonPathTransformFactoryTest.java
Outdated
Show resolved
Hide resolved
62631e6
to
37c1816
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1
Purpose of this pull request
[Improve][Transform] Ignore error with jsonpath transform
Does this PR introduce any user-facing change?
Add new config item
How was this patch tested?
Added
Check list
New License Guide
release-note
.