?????? flink 1.13.1, metrics?????????????? Unnamed

Thu, 29 Jul 2021 23:44:29 -0700 

????????????sql??sql????????????




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2021??7??30??(??????) ????10:54
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: flink 1.13.1, metrics?????????????? Unnamed



Hi??

???? Unnamed ?? sink ?????? data stream api ?? sink???????????????????????????? 
data stream api
??????????

Asahi Lee <[email protected]&gt; ??2021??7??29?????? ????9:25??????

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

回复