Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4544#discussion_r140717599 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkTypeFactory.scala --- @@ -269,6 +272,10 @@ class FlinkTypeFactory(typeSystem: RelDataTypeSystem) extends JavaTypeFactoryImp canonize(newType) } + + override def getDefaultCharset: Charset = { + Charset.forName(ConversionUtil.NATIVE_UTF16_CHARSET_NAME) --- End diff -- +1 doesn't having UTF-8 everywhere solve all problems?
---