[
https://issues.apache.org/jira/browse/FLINK-17185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084778#comment-17084778
]
Benchao Li commented on FLINK-17185:
------------------------------------
[~kcz] If you are asking questions, please post to
[user|mailto:user/[email protected]]
[@flink.apache.org|mailto:user/[email protected]] [ /
[email protected]|mailto:user/[email protected]]
> blink执行计划，自定义函数解析 array<row>，参数为空元素
> -----------------------------------
>
> Key: FLINK-17185
> URL: https://issues.apache.org/jira/browse/FLINK-17185
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.10.0
> Reporter: zck
> Priority: Major
>
> source_ddl:
> CREATE TABLE sourceTable (
> event_time_line array<ROW (
> `rule_name` VARCHAR,
> `count` VARCHAR
> )>
> ) WITH (
> 'connector.type' = 'kafka',
> 'connector.version' = 'universal',
> 'connector.startup-mode' = 'earliest-offset',
> 'connector.topic' = 'topic_test_1',
> 'connector.properties.zookeeper.connect' = 'localhost:2181',
> 'connector.properties.bootstrap.servers' = 'localhost:9092',
> 'update-mode' = 'append',
> 'format.type' = 'json',
> 'format.derive-schema' = 'true'
> );
>
>
> public class MyUDTF extends TableFunction<Row> {
> /**
> *
> * *@param rows blink执行计划 为null，但是数组有长度 。默认执行计划有值*
> */
> public void eval(Row [] rows) {
> collector.collect(Row.of(1, 1));
> }
> }
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
