[jira] [Created] (FLINK-17185) blink执行计划，自定义函数解析 array，参数为空元素

["zck (Jira)" <ji...@apache.org>]

zck created FLINK-17185:
---------------------------

             Summary: 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


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)