hailin0 commented on code in PR #7524:
URL: https://github.com/apache/seatunnel/pull/7524#discussion_r1746848876
##########
docs/en/transform-v2/jsonpath.md:
##########
@@ -51,6 +60,14 @@ Support SeatunnelDateType
> Jsonpath
+#### column_error_handle_way [Enum]
Review Comment:
fixed
##########
seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/common/AbstractCatalogSupportTransform.java:
##########
@@ -22,21 +22,47 @@
import org.apache.seatunnel.api.table.catalog.TableSchema;
import org.apache.seatunnel.api.table.type.SeaTunnelRow;
import org.apache.seatunnel.api.transform.SeaTunnelTransform;
+import org.apache.seatunnel.transform.exception.ErrorDataTransformException;
import lombok.NonNull;
+import lombok.extern.slf4j.Slf4j;
+@Slf4j
public abstract class AbstractCatalogSupportTransform implements
SeaTunnelTransform<SeaTunnelRow> {
+ protected final ErrorHandleWay rowErrorHandleWay;
protected CatalogTable inputCatalogTable;
protected volatile CatalogTable outputCatalogTable;
public AbstractCatalogSupportTransform(@NonNull CatalogTable
inputCatalogTable) {
+ this(inputCatalogTable,
CommonOptions.ROW_ERROR_HANDLE_WAY_OPTION.defaultValue());
+ }
+
+ public AbstractCatalogSupportTransform(
+ @NonNull CatalogTable inputCatalogTable, ErrorHandleWay
rowErrorHandleWay) {
this.inputCatalogTable = inputCatalogTable;
+ this.rowErrorHandleWay = rowErrorHandleWay;
}
@Override
public SeaTunnelRow map(SeaTunnelRow row) {
- return transformRow(row);
+ try {
+ return transformRow(row);
+ } catch (ErrorDataTransformException e) {
+ if (e.getErrorHandleWay() != null) {
+ ErrorHandleWay errorHandleWay = e.getErrorHandleWay();
+ if (errorHandleWay.allowSkip() ||
errorHandleWay.allowSkipThisRow()) {
Review Comment:
fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
