Closed
Description
Steps to reproduce the behavior (Required)
-- DROP TABLE row_error_test;
CREATE TABLE IF NOT EXISTS row_error_test (
row_field ROW<
f_sequence INT,
f_random INT,
f_random_str STRING,
f_random_boolean BOOLEAN
>
);
-- DROP TEMPORARY TABLE datagen_source;
CREATE TEMPORARY TABLE datagen_source (
row_field ROW<
f_sequence INT,
f_random INT,
f_random_str STRING,
f_random_boolean BOOLEAN
>
) WITH (
'connector' = 'datagen',
'number-of-rows' = '10',
'fields.row_field.f_sequence.min'='1',
'fields.row_field.f_sequence.max'='1000',
'fields.row_field.f_random.min'='1',
'fields.row_field.f_random.max'='1000',
'fields.row_field.f_random_str.length'='100'
);
INSERT INTO row_error_test select * from datagen_source;
select * from row_error_test;
Expected behavior (Required)
Flink SQL return resut below
Flink SQL> select * from row_error_test limit 1;
2023-09-08 21:10:37,642 INFO org.apache.hadoop.fs.s3a.S3AInputStream [] - Switching to Random IO seek policy
2023-09-08 21:10:37,677 INFO org.apache.hadoop.fs.s3a.S3AInputStream [] - Switching to Random IO seek policy
2023-09-08 21:10:37,735 INFO org.apache.hadoop.fs.s3a.S3AInputStream [] - Switching to Random IO seek policy
+--------------------------------+
| row_field |
+--------------------------------+
| (612, 86, bf91e50e0e3fb82d4... |
+--------------------------------+
1 row in set
Real behavior (Required)
Sql-client return an error below
StarRocks > select * from row_error_test limit 1;
+--------------------------------------------------+
| row_field |
+--------------------------------------------------+
| {"f_sequence":0,"f_random":0,"f_random_str":"0"} |
+--------------------------------------------------+
1 row in set (3.14 sec)
StarRocks version (Required)
- You can get the StarRocks version by executing SQL
select current_version()
in branch main and the latest commit is da50131