diff --git a/inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/arithmetic/TestRandIntegerFunction.java b/inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/arithmetic/TestRandIntegerFunction.java index 6e6a87743cb..f388e962d3a 100644 --- a/inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/arithmetic/TestRandIntegerFunction.java +++ b/inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/arithmetic/TestRandIntegerFunction.java @@ -53,9 +53,9 @@ public void testRandIntegerFunction() throws Exception { TransformProcessor processor2 = TransformProcessor .create(config2, SourceDecoderFactory.createCsvDecoder(csvSource), SinkEncoderFactory.createKvEncoder(kvSink)); - // case: rand_integer(2, 89) - List output3 = processor2.transform("2|89||", new HashMap<>()); + // case: rand_integer(88, 89) + List output3 = processor2.transform("88|89||", new HashMap<>()); Assert.assertEquals(1, output3.size()); - Assert.assertEquals(output3.get(0), "result=" + new Random(2).nextInt(89)); + Assert.assertEquals(output3.get(0), "result=" + new Random(89).nextInt(88)); } }