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';*来自志愿者整理的flink邮件归档
Hi!
显示 Unnamed 的 sink 一般是 data stream api 的 sink。这个作业之前的数据是不是从 data stream api 里来的呢?*来自志愿者整理的FLINK邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。