From b231e2ca5ee7eec3c2169a1a2a657a7fd5543929 Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Wed, 20 Sep 2023 19:31:37 +0530 Subject: [PATCH] removes conversions --- flow/connectors/utils/partition/partition.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flow/connectors/utils/partition/partition.go b/flow/connectors/utils/partition/partition.go index 092b4a9cb3..b25c39f6b1 100644 --- a/flow/connectors/utils/partition/partition.go +++ b/flow/connectors/utils/partition/partition.go @@ -54,9 +54,9 @@ func compareValues(prevEnd interface{}, start interface{}) int { } } case uint32: //xmin - if prevEnd.(uint32) < uint32(v) { + if prevEnd.(uint32) < v { return -1 - } else if prevEnd.(uint32) > uint32(v) { + } else if prevEnd.(uint32) > v { return 1 } else { return 0