File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -871,10 +871,9 @@ private static String castObjectIntoString(Object object) {
871871 private static int universalCompares (Object lhs , Object rhs ) {
872872 Class <?> leftClass = lhs .getClass ();
873873 Class <?> rightClass = rhs .getClass ();
874- if (leftClass .equals (rightClass ) && Comparable . class . isAssignableFrom ( leftClass ) ) {
874+ if (leftClass .equals (rightClass ) && lhs instanceof Comparable ) {
875875 return ((Comparable ) lhs ).compareTo (rhs );
876- } else if (Number .class .isAssignableFrom (leftClass )
877- && Number .class .isAssignableFrom (rightClass )) {
876+ } else if (lhs instanceof Number && rhs instanceof Number ) {
878877 return Double .compare (((Number ) lhs ).doubleValue (), ((Number ) rhs ).doubleValue ());
879878 } else {
880879 throw new RuntimeException (
You can’t perform that action at this time.
0 commit comments