Re: Re：Flink SQL format问题

[Jark Wu <im...@gmail.com>]

只支持单字符。 支持不可见字符。

On Wed, 16 Sep 2020 at 15:24, guaishushu1103@163.com <gu...@163.com>
wrote:

> 好的 谢谢啦，csv.field-delimiter 字段分隔目前是只支持 ,和; 这种简单字符吗
>
> ------------------------------
> guaishushu1103@163.com
>
>
> *发件人：* Jark Wu <im...@gmail.com>
> *发送时间：* 2020-09-16 15:21
> *收件人：* user-zh <us...@flink.apache.org>; Shuai Xia
> <jk...@dingtalk.com>
> *抄送：* guaishushu1103@163.com
> *主题：* Re: 回复：Flink SQL format问题
> 文档 [1] 中写的有问题，应该是 U&'\000A'   只有一个反斜线。
>
> Best,
> Jark
>
> [1]:
> https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/formats/csv.html#csv-line-delimiter
>
> On Wed, 16 Sep 2020 at 12:53, Shuai Xia <jk...@dingtalk.com.invalid>
> wrote:
>
>> U&'\\000A'，代码也用了U&？
>>
>>
>> ------------------------------------------------------------------
>> 发件人：guaishushu1103@163.com <gu...@163.com>
>> 发送时间：2020年9月16日(星期三) 10:50
>> 收件人：Shuai Xia <jk...@dingtalk.com>
>> 主 题：Re: 回复：Flink SQL format问题
>>
>>
>>
>> 表定义：
>> 'connector.type' = 'kafka',
>> 'connector.version' = 'universal',
>> 'connector.topic' = 'xxxx',
>> 'connector.properties.bootstrap.servers' = 'xxxx',
>> 'connector.properties.zookeeper.connect' = 'xxxx',
>> 'connector.properties.group.id' = 'xxxx',
>> 'connector.properties.client.id' = 'xxxx',
>> 'connector.startup-mode' = 'latest-offset',
>> 'format.type' = 'csv',
>> 'csv.field-delimiter' = '\001',
>> 'csv.line-delimiter' = U&'\\000A'
>> 错误：
>> aused by: org.apache.flink.table.api.NoMatchingTableFactoryException:
>> Could not find a suitable table factory for
>> 'org.apache.flink.table.factories.TableSinkFactory' in
>> (com.dataplatform.flink.util.FlinkDebugThread)
>> [2020-09-16 10:46:52,533] INFO ---the classpath.
>> (com.dataplatform.flink.util.FlinkDebugThread)
>> bugThread)
>> [2020-09-16 10:46:52,533] INFO ---      at
>> org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$1.apply(PlannerBase.scala:163)
>> (com.dataplatform.flink.util.Flink
>> DebugThread)
>> [2020-09-16 10:46:52,533] INFO ---      at
>> org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$1.apply(PlannerBase.scala:163)
>> (com.dataplatform.flink.util.Flink
>> DebugThread)
>> [2020-09-16 10:46:52,533] INFO ---      at
>> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
>> (com.dataplatform.flink.util.FlinkDebugThread)
>> [2020-09-16 10:46:52,533] INFO ---      at
>> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
>> (com.dataplatform.flink.util.FlinkDebugThread)
>> [2020-09-16 10:46:52,533] INFO ---      at
>> scala.collection.Iterator$class.foreach(Iterator.scala:891)
>> (com.dataplatform.flink.util.FlinkDebugThread)
>> [2020-09-16 10:46:52,533] INFO ---      at
>> scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
>> (com.dataplatform.flink.util.FlinkDebugThread)
>> [2020-09-16 10:46:52,533] INFO ---      at
>> scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
>> (com.dataplatform.flink.util.FlinkDebugThread)
>> [2020-09-16 10:46:52,533] INFO ---      at
>> scala.collection.AbstractIterable.foreach(Iterable.scala:54)
>> (com.dataplatform.flink.util.FlinkDebugThread)
>>
>>
>>
>>
>> guaishushu1103@163.com
>> 发件人： Shuai Xia
>> 发送时间： 2020-09-16 10:33
>> 收件人： user-zh; guaishushu1103
>> 主题： 回复：Flink SQL format问题
>> Hi，麻烦代码以及报错贴一下
>>
>> ------------------------------------------------------------------
>> 发件人：guaishushu1103@163.com <gu...@163.com>
>> 发送时间：2020年9月16日(星期三) 10:29
>> 收件人：user-zh <us...@flink.apache.org>
>> 主 题：Flink SQL format问题
>>
>> csv.field-delimiter
>> csv.line-delimiter
>> 想问下大佬们 官方文档说是可以设置这两个值，指定行分隔和字段分隔，但是在设置kafka sinkTable的时候会出现语法错误？？？很奇怪
>>
>>
>>
>> guaishushu1103@163.com
>>
>