JdbcTypeConverter { public static int getIntegerSqlType(TypeInformation<?> type) { if (MAP_FLINK_TYPE_TO_INDEX.containsKey(type)) { return MAP_FLINK_TYPE_TO_INDEX.get(type); } else if (type instanceof ObjectArrayTypeInfo || type instanceof PrimitiveArrayTypeInfo) { return Types.ARRAY; } else { throw new IllegalArgumentException("Unsupported type: " + type); } }  static int getIntegerSqlType(TypeInformation<?> type); static TypeInformation<?> getFlinkType(int typeIndex);  }
@Test(expected = IllegalArgumentException.class) public void testUnsupportedFlinkType() { JdbcTypeConverter.getIntegerSqlType(TypeInformation.of(JdbcTypeConverter.class)); }