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';