File tree Expand file tree Collapse file tree 3 files changed +5
-2
lines changed
main/java/com/uber/cadence/internal/compatibility/proto
test/java/com/uber/cadence/internal/compatibility Expand file tree Collapse file tree 3 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -800,7 +800,7 @@ public static UpdateDomainRequest updateDomainRequest(com.uber.cadence.UpdateDom
800
800
fields .add (DomainUpdateVisibilityArchivalURIField );
801
801
}
802
802
}
803
- DomainReplicationConfiguration replicationConfiguration = new DomainReplicationConfiguration ();
803
+ DomainReplicationConfiguration replicationConfiguration = t . getReplicationConfiguration ();
804
804
if (replicationConfiguration != null ) {
805
805
if (replicationConfiguration .getActiveClusterName () != null ) {
806
806
request .setActiveClusterName (replicationConfiguration .getActiveClusterName ());
Original file line number Diff line number Diff line change @@ -1172,6 +1172,8 @@ public final class ProtoObjects {
1172
1172
.setHistoryArchivalUri ("historyArchivalUri" )
1173
1173
.setVisibilityArchivalStatus (ArchivalStatus .ARCHIVAL_STATUS_DISABLED )
1174
1174
.setVisibilityArchivalUri ("visibilityArchivalUri" )
1175
+ .addAllClusters (ImmutableList .of (CLUSTER_REPLICATION_CONFIGURATION ))
1176
+ .setActiveClusterName ("activeCluster" )
1175
1177
.setDeleteBadBinary ("deleteBadBinary" )
1176
1178
.setFailoverTimeout (seconds (1 ))
1177
1179
.setUpdateMask (
@@ -1185,6 +1187,8 @@ public final class ProtoObjects {
1185
1187
.addPaths ("history_archival_uri" )
1186
1188
.addPaths ("visibility_archival_status" )
1187
1189
.addPaths ("visibility_archival_uri" )
1190
+ .addPaths ("active_cluster_name" )
1191
+ .addPaths ("clusters" )
1188
1192
.addPaths ("delete_bad_binary" )
1189
1193
.addPaths ("failover_timeout" )
1190
1194
.build ())
Original file line number Diff line number Diff line change @@ -236,7 +236,6 @@ public static Iterable<Object[]> cases() {
236
236
"emitMetric" ), // Thrift has this field but proto doens't have it
237
237
testCase (
238
238
ThriftObjects .UPDATE_DOMAIN_REQUEST ,
239
- // Data and replicationConfiguration are copied incorrectly due to a bug :(
240
239
ProtoObjects .UPDATE_DOMAIN_REQUEST ,
241
240
RequestMapper ::updateDomainRequest ),
242
241
testCase (
You can’t perform that action at this time.
0 commit comments