Hi??
??????????sql??????????????????????????????????????????????????????????Unnamed??????????????bug??
??????????????
node103.taskmanager.container_1627469681067_0030_01_000002.e621b91ec4a34ababeb6b0e2c4d6f22b.Source:
HiveSource-qc_test_t_student_score -> Calc(select=[id,
CAST(_UTF-16LE'Bob':VARCHAR(2147483647) CHARACTER SET "UTF-16LE") AS name,
class_id, class_name, score,
_UTF-16LE'9bdb0e98cc5b4800ae3b56575c442225':VARCHAR(2147483647) CHARACTER SET
"UTF-16LE" AS rule_id, _UTF-16LE'????33333':VARCHAR(2147483647) CHARACTER SET
"UTF-16LE" AS task_batch_id], where=[(name = _UTF-16LE'Bob':VARCHAR(2147483647)
CHARACTER SET "UTF-16LE")]) -> Map -> Sink:
Unnamed.0.Shuffle.Netty.Input.Buffers.inputFloatingBuffersUsage
node103.taskmanager.container_1627469681067_0030_01_000002.e621b91ec4a34ababeb6b0e2c4d6f22b.Source:
HiveSource-qc_test_t_student_score -> Calc(select=[id,
CAST(_UTF-16LE'Bob':VARCHAR(2147483647) CHARACTER SET "UTF-16LE") AS name,
class_id, class_name, score,
_UTF-16LE'9bdb0e98cc5b4800ae3b56575c442225':VARCHAR(2147483647) CHARACTER SET
"UTF-16LE" AS rule_id, _UTF-16LE'????33333':VARCHAR(2147483647) CHARACTER SET
"UTF-16LE" AS task_batch_id], where=[(name = _UTF-16LE'Bob':VARCHAR(2147483647)
CHARACTER SET "UTF-16LE")]) -> Map -> Sink:
Unnamed.0.Shuffle.Netty.Input.Buffers.inPoolUsage
node103.taskmanager.container_1627469681067_0030_01_000002.e621b91ec4a34ababeb6b0e2c4d6f22b.Sink:
Unnamed.0.numRecordsIn
????sql??????
CREATE CATALOG `qc_hive_catalog` WITH ( 'type' = 'hive', 'default-database' =
'qc_test' );
USE CATALOG `qc_hive_catalog`;
CREATE TABLE
IF
NOT EXISTS QC_RESULT_T_STUDENT_SCORE ( id STRING, NAME STRING, class_id
STRING, class_name STRING, score INTEGER, rule_id STRING, task_batch_id STRING
) WITH ( 'is_generic' = 'false', 'connector' = 'hive' );
INSERT INTO QC_RESULT_T_STUDENT_SCORE SELECT
id,
NAME,
class_id,
class_name,
score,
cast( '9bdb0e98cc5b4800ae3b56575c442225' AS STRING ) AS rule_id,
cast( '????33333' AS STRING ) AS task_batch_id
FROM
t_student_score
WHERE
t_student_score.NAME = 'Bob';
