lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Tweak change log more as FULL for flink streaming source (#3466)

Browse Source
This commit is contained in:
Danny Chan
2021-08-13 16:31:16 +08:00
committed by GitHub
parent 6602e55cd2
commit 6a4100bb91
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java
View File

@@ -198,7 +198,6 @@ public class HoodieTableSource implements
@Override @Override
public ChangelogMode getChangelogMode() { public ChangelogMode getChangelogMode() {
return conf.getBoolean(FlinkOptions.READ_AS_STREAMING) return conf.getBoolean(FlinkOptions.READ_AS_STREAMING)
&& !conf.getBoolean(FlinkOptions.CHANGELOG_ENABLED)
? ChangelogModes.FULL ? ChangelogModes.FULL
// when all the changes are persisted or read as batch, // when all the changes are persisted or read as batch,
// use INSERT mode. // use INSERT mode.

6
hudi-flink/src/main/java/org/apache/hudi/util/RowDataProjection.java
View File

@@ -25,10 +25,14 @@ import org.apache.flink.table.data.RowData;
import org.apache.flink.table.types.logical.LogicalType; import org.apache.flink.table.types.logical.LogicalType;
import org.apache.flink.table.types.logical.RowType; import org.apache.flink.table.types.logical.RowType;
import java.io.Serializable;
/** /**
* Utilities to project the row data with given positions. * Utilities to project the row data with given positions.
*/ */
public class RowDataProjection { public class RowDataProjection implements Serializable {
private static final long serialVersionUID = 1L;
private final RowData.FieldGetter[] fieldGetters; private final RowData.FieldGetter[] fieldGetters;
private RowDataProjection(LogicalType[] types, int[] positions) { private RowDataProjection(LogicalType[] types, int[] positions) {