Remove numerical offset usage #9201
Annotations
11 errors
|
Publish Test Report:
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L1018
java.lang.AssertionError: Non-deterministic condition not met. expected [true] but found [false]
|
|
Publish Test Report:
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224
java.lang.AssertionError: expected [true] but found [false]
|
|
Publish Test Report:
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L1018
java.lang.AssertionError: Non-deterministic condition not met. expected [true] but found [false]
|
|
Publish Test Report:
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224
java.lang.AssertionError: expected [true] but found [false]
|
|
Publish Test Report:
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L1018
java.lang.AssertionError: Non-deterministic condition not met. expected [true] but found [false]
|
|
Publish Test Report:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestZkAdminTopicMetadataAccessor.java#L128
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadata",
{"executionId" = 1L, "offset" = 100L, "adminOperationProtocolVersion" = 18L, "upstreamOffset" = 12345L},
0
);
-> at org.apache.helix.zookeeper.zkclient.ZkClient.writeDataGetStat(ZkClient.java:2353)
Actual invocations have different arguments:
zkClient.setZkSerializer(
Mock for HelixAdapterSerializer, hashCode: 1437243359
);
-> at com.linkedin.venice.controller.ZkAdminTopicMetadataAccessor.<init>(ZkAdminTopicMetadataAccessor.java:72)
zkClient.readData(
"/test-cluster/adminTopicMetadata",
0,0,0,0,0,0,0,0,0,0,0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:440)
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadata",
{"executionId" = 1L, "offset" = 100L, "adminOperationProtocolVersion" = 18L},
0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:443)
zkClient.readData(
"/test-cluster/adminTopicMetadataV2",
0,0,0,0,0,0,0,0,0,0,0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:440)
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadataV2",
AdminMetadata{executionId=1, offset=100, upstreamOffset=null, adminOperationProtocolVersion=18, position=ApacheKafkaOffsetPosition{100}, upstreamPosition=ApacheKafkaOffsetPosition{12345}},
0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:443)
|
|
Publish Test Report:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestZkAdminTopicMetadataAccessor.java#L128
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadata",
{"executionId" = 1L, "offset" = 100L, "adminOperationProtocolVersion" = 18L, "upstreamOffset" = 12345L},
0
);
-> at org.apache.helix.zookeeper.zkclient.ZkClient.writeDataGetStat(ZkClient.java:2353)
Actual invocations have different arguments:
zkClient.setZkSerializer(
Mock for HelixAdapterSerializer, hashCode: 1959940703
);
-> at com.linkedin.venice.controller.ZkAdminTopicMetadataAccessor.<init>(ZkAdminTopicMetadataAccessor.java:72)
zkClient.readData(
"/test-cluster/adminTopicMetadata",
0,0,0,0,0,0,0,0,0,0,0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:440)
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadata",
{"executionId" = 1L, "offset" = 100L, "adminOperationProtocolVersion" = 18L},
0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:443)
zkClient.readData(
"/test-cluster/adminTopicMetadataV2",
0,0,0,0,0,0,0,0,0,0,0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:440)
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadataV2",
AdminMetadata{executionId=1, offset=100, upstreamOffset=null, adminOperationProtocolVersion=18, position=ApacheKafkaOffsetPosition{100}, upstreamPosition=ApacheKafkaOffsetPosition{12345}},
0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:443)
|
|
Publish Test Report:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestZkAdminTopicMetadataAccessor.java#L128
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadata",
{"executionId" = 1L, "offset" = 100L, "adminOperationProtocolVersion" = 18L, "upstreamOffset" = 12345L},
0
);
-> at org.apache.helix.zookeeper.zkclient.ZkClient.writeDataGetStat(ZkClient.java:2353)
Actual invocations have different arguments:
zkClient.setZkSerializer(
Mock for HelixAdapterSerializer, hashCode: 1959940703
);
-> at com.linkedin.venice.controller.ZkAdminTopicMetadataAccessor.<init>(ZkAdminTopicMetadataAccessor.java:72)
zkClient.readData(
"/test-cluster/adminTopicMetadata",
0,0,0,0,0,0,0,0,0,0,0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:440)
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadata",
{"executionId" = 1L, "offset" = 100L, "adminOperationProtocolVersion" = 18L},
0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:443)
zkClient.readData(
"/test-cluster/adminTopicMetadataV2",
0,0,0,0,0,0,0,0,0,0,0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:440)
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadataV2",
AdminMetadata{executionId=1, offset=100, upstreamOffset=null, adminOperationProtocolVersion=18, position=ApacheKafkaOffsetPosition{100}, upstreamPosition=ApacheKafkaOffsetPosition{12345}},
0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:443)
|
|
Publish Test Report:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestZkAdminTopicMetadataAccessor.java#L128
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadata",
{"executionId" = 1L, "offset" = 100L, "adminOperationProtocolVersion" = 18L, "upstreamOffset" = 12345L},
0
);
-> at org.apache.helix.zookeeper.zkclient.ZkClient.writeDataGetStat(ZkClient.java:2353)
Actual invocations have different arguments:
zkClient.setZkSerializer(
Mock for HelixAdapterSerializer, hashCode: 1437243359
);
-> at com.linkedin.venice.controller.ZkAdminTopicMetadataAccessor.<init>(ZkAdminTopicMetadataAccessor.java:72)
zkClient.readData(
"/test-cluster/adminTopicMetadata",
0,0,0,0,0,0,0,0,0,0,0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:440)
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadata",
{"executionId" = 1L, "offset" = 100L, "adminOperationProtocolVersion" = 18L},
0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:443)
zkClient.readData(
"/test-cluster/adminTopicMetadataV2",
0,0,0,0,0,0,0,0,0,0,0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:440)
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadataV2",
AdminMetadata{executionId=1, offset=100, upstreamOffset=null, adminOperationProtocolVersion=18, position=ApacheKafkaOffsetPosition{100}, upstreamPosition=ApacheKafkaOffsetPosition{12345}},
0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:443)
|
|
Publish Test Report:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestZkAdminTopicMetadataAccessor.java#L128
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadata",
{"executionId" = 1L, "offset" = 100L, "adminOperationProtocolVersion" = 18L, "upstreamOffset" = 12345L},
0
);
-> at org.apache.helix.zookeeper.zkclient.ZkClient.writeDataGetStat(ZkClient.java:2353)
Actual invocations have different arguments:
zkClient.setZkSerializer(
Mock for HelixAdapterSerializer, hashCode: 881784000
);
-> at com.linkedin.venice.controller.ZkAdminTopicMetadataAccessor.<init>(ZkAdminTopicMetadataAccessor.java:72)
zkClient.readData(
"/test-cluster/adminTopicMetadata",
0,0,0,0,0,0,0,0,0,0,0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:440)
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadata",
{"executionId" = 1L, "offset" = 100L, "adminOperationProtocolVersion" = 18L},
0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:443)
zkClient.readData(
"/test-cluster/adminTopicMetadataV2",
0,0,0,0,0,0,0,0,0,0,0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:440)
zkClient.writeDataGetStat(
"/test-cluster/adminTopicMetadataV2",
AdminMetadata{executionId=1, offset=100, upstreamOffset=null, adminOperationProtocolVersion=18, position=ApacheKafkaOffsetPosition{100}, upstreamPosition=ApacheKafkaOffsetPosition{12345}},
0
);
-> at org.apache.helix.manager.zk.ZkBaseDataAccessor.doUpdate(ZkBaseDataAccessor.java:443)
|
|
Run Unit Tests with Code Coverage
Process completed with exit code 1.
|
Loading