From d7f53601db32a5ee0bb310bf49fbc36843fb24e4 Mon Sep 17 00:00:00 2001 From: quinto Date: Thu, 24 Sep 2020 07:07:54 +0800 Subject: [PATCH] When Flink uses udf functions,udf functions field mapping split bug --- .../edp/wormhole/flinkx/util/FlinkSchemaUtils.scala | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/flinkx/src/main/scala/edp/wormhole/flinkx/util/FlinkSchemaUtils.scala b/flinkx/src/main/scala/edp/wormhole/flinkx/util/FlinkSchemaUtils.scala index c833738a2..4de0ebf4d 100644 --- a/flinkx/src/main/scala/edp/wormhole/flinkx/util/FlinkSchemaUtils.scala +++ b/flinkx/src/main/scala/edp/wormhole/flinkx/util/FlinkSchemaUtils.scala @@ -103,8 +103,10 @@ object FlinkSchemaUtils extends java.io.Serializable { for (sIndex <- 0 until fieldString.length) { if (fieldString(sIndex) == ',' && num == 0) { if (s.contains('(') && s.contains("as")) { - val udfName = s.trim.substring(0, s.trim.indexOf('(')) - val newName = s.trim.substring(s.indexOf("as") + 2).trim + //val udfName = s.trim.substring(0, s.trim.indexOf('(')) + //val newName = s.trim.substring(s.indexOf("as") + 2).trim + val udfName = s.substring(0, s.indexOf('(')).trim + val newName = s.substring(s.indexOf("as") + 2).trim nameMap += newName -> udfName } s = "" @@ -115,8 +117,10 @@ object FlinkSchemaUtils extends java.io.Serializable { } } if (s.contains('(') && s.contains("as")) { - val udfName = s.trim.substring(0, s.trim.indexOf('(')) - val newName = s.trim.substring(s.indexOf("as") + 2).trim + //val udfName = s.trim.substring(0, s.trim.indexOf('(')) + //val newName = s.trim.substring(s.indexOf("as") + 2).trim + val udfName = s.substring(0, s.indexOf('(')).trim + val newName = s.substring(s.indexOf("as") + 2).trim nameMap += newName -> udfName } logger.debug("nameMap:" + nameMap.toString())