yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-08-15 20:57:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(protobuf) Fix test instability by deterministrically selecting field (#4612)

Browse Source
This commit is contained in:
leifker 2022-04-07 15:35:44 -05:00 committed by GitHub
parent 336a628c5b
commit aa05faad32
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
metadata-integration/java/datahub-protobuf/src/main/java/datahub/protobuf/model/ProtobufField.java
View File

@ -73,6 +73,10 @@ public class ProtobufField implements ProtobufElement {
return nativeType(); return nativeType();
} }
public int getNumber() {
return fieldProto.getNumber();
}
@Override @Override
public String nativeType() { public String nativeType() {
return Optional.ofNullable(nativeType).orElseGet(() -> { return Optional.ofNullable(nativeType).orElseGet(() -> {

2
metadata-integration/java/datahub-protobuf/src/main/java/datahub/protobuf/model/ProtobufGraph.java
View File

@ -306,7 +306,7 @@ public class ProtobufGraph extends DefaultDirectedGraph<ProtobufElement, FieldTy
.collect(Collectors.toSet()); .collect(Collectors.toSet());
removeVertices.addAll(wrappedPrimitiveFields); removeVertices.addAll(wrappedPrimitiveFields);
wrappedPrimitiveFields.forEach(primitiveField -> { wrappedPrimitiveFields.stream().filter(fld -> fld.getNumber() == 1).forEach(primitiveField -> {
// remove incoming old edges to primitive // remove incoming old edges to primitive
removeEdges.addAll(incomingEdgesOf(primitiveField)); removeEdges.addAll(incomingEdgesOf(primitiveField));