com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770857837076, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "status" : "STARTED", "activeActiveReplicationEnabled" : false, "pushType" : "BATCH", "versionSwapDeferred" : false, "minActiveReplicas" : 2, "useVersionLevelIncrementalPushEna"[truncated 1356 bytes]; line: 42, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770857822380, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "activeActiveReplicationEnabled" : false, "blobTransferEnabled" : false, "blobTransferInServerEnabled" : "NOT_SPECIFIED", "targetSwapRegion" : "", "targetSwapRegionWaitTime" : 60"[truncated 1356 bytes]; line: 42, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770857810233, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "status" : "STARTED", "repushSourceVersion" : -1, "separateRealTimeTopicEnabled" : false, "pushType" : "BATCH", "hybridStoreConfig" : { "rewindTimeInSeconds" : 100, "offs"[truncated 1356 bytes]; line: 23, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770857604446, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "status" : "STARTED", "repushSourceVersion" : -1, "separateRealTimeTopicEnabled" : false, "pushType" : "BATCH", "hybridStoreConfig" : { "rewindTimeInSeconds" : 100, "offs"[truncated 1356 bytes]; line: 23, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

java.lang.AssertionError: expected [1] but found [0]

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4308 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4308 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4308 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4308 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4308 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

Process completed with exit code 1.

java.lang.NullPointerException: Cannot invoke "java.lang.CharSequence.toString()" because "charSequence" is null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: Cannot invoke "java.lang.CharSequence.toString()" because "charSequence" is null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: Cannot invoke "java.lang.CharSequence.toString()" because "charSequence" is null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: Cannot invoke "java.lang.CharSequence.toString()" because "charSequence" is null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: Cannot invoke "java.lang.CharSequence.toString()" because "charSequence" is null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: Cannot invoke "java.lang.CharSequence.toString()" because "charSequence" is null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: Cannot invoke "java.lang.CharSequence.toString()" because "charSequence" is null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: Cannot invoke "java.lang.CharSequence.toString()" because "charSequence" is null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: Cannot invoke "java.lang.CharSequence.toString()" because "charSequence" is null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: Cannot invoke "java.lang.CharSequence.toString()" because "charSequence" is null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

Process completed with exit code 1.

java.lang.AssertionError: expected [true] but found [false]

java.lang.AssertionError: expected [true] but found [false]

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770858521601, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9660 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770858508963, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9660 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770858496109, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9660 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770858482402, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9660 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770858448746, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9660 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770858521601, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9660 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770858508963, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9660 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770858496109, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9660 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770858482402, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9660 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770858448746, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9660 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

Process completed with exit code 1.

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770860070943, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "status" : "STARTED", "pushType" : "BATCH", "repushSourceVersion" : -1, "separateRealTimeTopicEnabled" : false, "hybridStoreConfig" : { "rewindTimeInSeconds" : 100, "offs"[truncated 1334 bytes]; line: 23, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770860057001, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "blobTransferEnabled" : false, "blobTransferInServerEnabled" : "NOT_SPECIFIED", "targetSwapRegion" : "", "targetSwapRegionWaitTime" : 60, "isDavinciHeartbeatReported" : false, "[truncated 1334 bytes]; line: 42, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770860027936, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "status" : "STARTED", "pushType" : "BATCH", "versionSwapDeferred" : false, "minActiveReplicas" : 2, "useVersionLevelIncrementalPushEnabled" : true, "useVersionLevelHybridConfig"[truncated 1334 bytes]; line: 42, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770859824740, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "activeActiveReplicationEnabled" : false, "globalRtDivEnabled" : false, "keyUrnCompressionEnabled" : false, "keyUrnFields" : [ ], "pushType" : "BATCH", "versionSwapDeferred" : "[truncated 1334 bytes]; line: 42, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (74.07872) which is too far from the predictedUsage (40); delta: 0.852; maxAllowedDelta: 0.013. No more attempts left.

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4286 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4286 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4286 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4286 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4286 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

Process completed with exit code 1.

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860033413, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860018303, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860004163, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770859990224, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770859956140, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860033413, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860018303, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860004163, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770859990224, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770859956140, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

Process completed with exit code 1.

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770860131383, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "status" : "STARTED", "pushType" : "BATCH", "repushSourceVersion" : -1, "separateRealTimeTopicEnabled" : false, "hybridStoreConfig" : { "rewindTimeInSeconds" : 100, "offs"[truncated 1356 bytes]; line: 23, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770860116176, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "status" : "STARTED", "pushType" : "BATCH", "repushSourceVersion" : -1, "separateRealTimeTopicEnabled" : false, "hybridStoreConfig" : { "rewindTimeInSeconds" : 100, "offs"[truncated 1356 bytes]; line: 23, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770860100318, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "status" : "STARTED", "hybridStoreConfig" : { "rewindTimeInSeconds" : 100, "offsetLagThresholdToGoOnline" : 1, "producerTimestampLagThresholdToGoOnlineInSeconds" : 10, "[truncated 1356 bytes]; line: 20, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770860084859, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "status" : "STARTED", "pushType" : "BATCH", "repushSourceVersion" : -1, "separateRealTimeTopicEnabled" : false, "hybridStoreConfig" : { "rewindTimeInSeconds" : 100, "offs"[truncated 1356 bytes]; line: 23, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "storeName" : "test", "number" : 1, "createdTime" : 1770859882489, "pushJobId" : "test-push-job-id", "partitionCount" : 1, "partitionerConfig" : { "partitionerClass" : "com.linkedin.venice.partitioner.DefaultVenicePartitioner", "partitionerParams" : { }, "amplificationFactor" : 1 }, "status" : "STARTED", "pushType" : "BATCH", "repushSourceVersion" : -1, "separateRealTimeTopicEnabled" : false, "hybridStoreConfig" : { "rewindTimeInSeconds" : 100, "offs"[truncated 1356 bytes]; line: 23, column: 37] (through reference chain: com.linkedin.venice.meta.VersionImpl["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4308 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4308 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4308 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4308 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "name" : "s1", "owner" : "owner", "createdTime" : 1, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 100, "hybridStoreConfig" : { "rewindTimeInSeconds" : 1000, "offsetLagThresholdToGoOnline" : 1000, "producerTimestampLagThresholdToGoOnlineInSeconds" : -1, "dataReplicationPolicy" :"[truncated 4308 bytes]; line: 19, column: 37] (through reference chain: com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

Process completed with exit code 1.

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

Process completed with exit code 1.

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860426407, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860410939, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860396601, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860382156, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860347510, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860426407, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860410939, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860396601, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860382156, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `int` from Object value (token `JsonToken.START_OBJECT`) at [Source: (byte[])"{ "zkSharedStore" : { "name" : "venice_system_store_METADATA_SYSTEM_SCHEMA_STORE", "owner" : "test", "createdTime" : 1770860347510, "persistenceType" : "IN_MEMORY", "routingStrategy" : "CONSISTENT_HASH", "readStrategy" : "ANY_OF_ONLINE", "offLinePushStrategy" : "WAIT_ALL_REPLICAS", "currentVersion" : 0, "storageQuotaInByte" : 21474836480, "readQuotaInCU" : 1800, "hybridStoreConfig" : { "rewindTimeInSeconds" : 86400, "offsetLagThresholdToG"[truncated 9684 bytes]; line: 20, column: 39] (through reference chain: com.linkedin.venice.meta.SerializableSystemStore["zkSharedStore"]->com.linkedin.venice.meta.ZKStore["hybridStoreConfig"]->com.linkedin.venice.meta.HybridStoreConfigImpl["uncleanLeaderElectionEnable"])

Process completed with exit code 1.

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

java.lang.NullPointerException: null of string in field blobDbEnabled of com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore of union in field payloadUnion of com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation

Process completed with exit code 1.

Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 256 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4ea5b6b451_9d63d47a_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4ea5b6b451_9d63d47a_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1889568128 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1889568128 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4ea5b6b451_9d63d47a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860556628}, Mock for Store, hashCode: 1889568128 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4ea5b6b451_9d63d47a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860556628} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_4ea5b6b451_9d63d47a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

org.mockito.exceptions.verification.TooFewActualInvocations: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); Wanted 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) But was 0 times.

Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 236 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_438332ed93_c716b5b2_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_438332ed93_c716b5b2_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1053591692 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1053591692 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_438332ed93_c716b5b2_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860508819}, Mock for Store, hashCode: 1053591692 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_438332ed93_c716b5b2_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860508819} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_438332ed93_c716b5b2_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

org.mockito.exceptions.verification.TooFewActualInvocations: abstractStorageEngine.put( 1, [(byte) 0x01, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x31, (byte) 0x5F, (byte) 0x31, (byte) 0x35, (byte) 0x62, (byte) 0x65, (byte) 0x39, (byte) 0x37, (byte) 0x66, (byte) 0x30, (byte) 0x33, (byte) 0x33, (byte) 0x5F, (byte) 0x33, (byte) 0x66, (byte) 0x66, (byte) 0x63, (byte) 0x32, (byte) 0x37, (byte) 0x37, (byte) 0x62], java.nio.HeapByteBuffer[pos=0 lim=17 cap=17] ); Wanted 2 times: -> at com.linkedin.davinci.store.AbstractStorageEngine.put(AbstractStorageEngine.java:478) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:39)

Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 256 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4ea5b6b451_9d63d47a_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4ea5b6b451_9d63d47a_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1889568128 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1889568128 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4ea5b6b451_9d63d47a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860556628}, Mock for Store, hashCode: 1889568128 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4ea5b6b451_9d63d47a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860556628} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_4ea5b6b451_9d63d47a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

Process completed with exit code 1.

Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 256 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4b95b90e23_92ed1e79_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4b95b90e23_92ed1e79_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1607407365 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1607407365 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b95b90e23_92ed1e79_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860857481}, Mock for Store, hashCode: 1607407365 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b95b90e23_92ed1e79_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860857481} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_4b95b90e23_92ed1e79_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

org.mockito.exceptions.verification.TooFewActualInvocations: hostLevelIngestionStats.recordTotalBytesConsumed( <any long> ); Wanted 2 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

org.mockito.exceptions.verification.TooFewActualInvocations: hostLevelIngestionStats.recordTotalBytesConsumed( <any long> ); Wanted 3 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523) But was 2 times: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)

Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 256 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4b95b90e23_92ed1e79_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4b95b90e23_92ed1e79_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1607407365 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1607407365 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b95b90e23_92ed1e79_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860857481}, Mock for Store, hashCode: 1607407365 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b95b90e23_92ed1e79_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860857481} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_4b95b90e23_92ed1e79_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

org.mockito.exceptions.verification.TooFewActualInvocations: hostLevelIngestionStats.recordTotalBytesConsumed( <any long> ); Wanted 2 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)

Process completed with exit code 1.

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

com.linkedin.venice.serializer.VeniceSerializationException: Unable to serialize object

java.lang.AssertionError: expected [2000.0] but found [1000.0]

Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 256 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_44cf1115f6_9b9edab5_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_44cf1115f6_9b9edab5_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1520121740 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1520121740 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_44cf1115f6_9b9edab5_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860911338}, Mock for Store, hashCode: 1520121740 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_44cf1115f6_9b9edab5_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860911338} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_44cf1115f6_9b9edab5_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr

Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 276 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_3b075138f9_269278a0_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_3b075138f9_269278a0_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 297784269 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 297784269 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_3b075138f9_269278a0_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860869334}, Mock for Store, hashCode: 297784269 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_3b075138f9_269278a0_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860869334} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_3b075138f9_269278a0_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce

java.lang.NullPointerException

Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 276 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_47ad8f67ee_b5a74a89_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_47ad8f67ee_b5a74a89_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1838526865 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1838526865 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_47ad8f67ee_b5a74a89_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860923635}, Mock for Store, hashCode: 1838526865 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_47ad8f67ee_b5a74a89_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770860923635} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_47ad8f67ee_b5a74a89_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr

Process completed with exit code 1.