[Blink]Cep SQL code generator bug

Hi 当CEP SQL Pattern中出现aggregate 操作 并且SQL code generator 没有split 情况下 code generator 会出现问题 TableConfigOptions.SQL_CODEGEN_LENGTH_MAX 设置为默认 即48 * 1024 SQL Example SELECT * FROM source MATCH_RECOGNIZE ( PARTITION BY userId ORDER BY proctime MEASURES ...

Re: [Blink]sql client kafka sink 失败

t;> Kurt >> >> >> On Mon, Feb 25, 2019 at 9:56 AM 张洪涛 wrote: >> >> > >> > >> > sql-client.sh 的启动参数首先在classpath里面会包含kafka相关的jar 另外会有--jar >> > 包含所有connector的jar >> > >> > >> > 这些jars在sql-client提交job时候会上传到clu

Re:Re: Re: [Blink]sql client kafka sink 失败

-sql-client-1.5.1.jar 在 2019-02-22 19:32:18，"Becket Qin" 写道： >能不能看一下运行sql-client.sh的运行参数。具体做法是: > >运行sql-client.sh >ps | grep sql-client > >查看一下其中是不是有这个 flink-connector-kafka-0.11 的 jar. > >Jiangjie (Becket) Qin > >On Fri, Feb 22, 2019 at 6:54 PM 张洪涛 wr

Re:Re: [Blink]sql client kafka sink 失败

在 2019-02-22 18:03:18，"Zhenghua Gao" 写道： >能否看一下对应的包里是否有这个类， 方法如下(假设你的blink安装包在 /tmp/blink): > >cd /tmp/blink/opt/connectors/kafka011 >jar -tf flink-connector-kafka-0.11_2.11-*.jar | grep Crc32C > >On Fri, Feb 22, 2019 at 2:56 PM 张洪涛 wrote: > >> >

[Blink]sql client kafka sink 失败

大家好！ 我正在测试Blink sql client kafka sink connector ，但是发现写入失败，以下是我的步骤 环境配置 blink standalone 模式 1. 配置environment 启动sql client 2. 创建kafka sink table CREATETABLEkafka_sink( messageKeyVARBINARY, messageValueVARBINARY, PRIMARYKEY(messageKey)) with( type='KAFKA011',