You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 陈卓宇 <25...@qq.com.INVALID> on 2022/06/08 08:49:20 UTC

flink webui stdout疑惑

您好：
向flink集群提交的sql：
CREATE TABLE datagen (
    f_sequence INT,
    f_random INT,
    f_random_str STRING,
    ts AS localtimestamp,
    WATERMARK FOR ts AS ts
  ) WITH (
    'connector' = 'datagen',
    -- optional options --
    'rows-per-second'='5',
    'fields.f_sequence.kind'='sequence',
    'fields.f_sequence.start'='1',
    'fields.f_sequence.end'='500',
    'fields.f_random.min'='1',
    'fields.f_random.max'='500',
    'fields.f_random_str.length'='10'
  );

  CREATE TABLE print_table (
    f_sequence INT,
    f_random INT,
    f_random_str STRING
    ) WITH (
    'connector' = 'print'
  );

  INSERT INTO print_table select f_sequence,f_random,f_random_str from datagen;


想请问一下在flink web ui的stdout上发现没有打印一片空白，进入日志是有打印的，这是什么原因导致的？ 我如何解决，让ui的stdout能把内容打印出来

Re:flink webui stdout疑惑

Posted by Xuyang <xy...@163.com>.

Hi, 
    请问下你找的.out文件是tm的还是jm的？tm的out文件应该是有内容的才对。




--

    Best！
    Xuyang





在 2022-06-08 16:49:20，"陈卓宇" <25...@qq.com.INVALID> 写道：
>您好：
>向flink集群提交的sql：
>CREATE TABLE datagen (
>    f_sequence INT,
>    f_random INT,
>    f_random_str STRING,
>    ts AS localtimestamp,
>    WATERMARK FOR ts AS ts
>  ) WITH (
>    'connector' = 'datagen',
>    -- optional options --
>    'rows-per-second'='5',
>    'fields.f_sequence.kind'='sequence',
>    'fields.f_sequence.start'='1',
>    'fields.f_sequence.end'='500',
>    'fields.f_random.min'='1',
>    'fields.f_random.max'='500',
>    'fields.f_random_str.length'='10'
>  );
>
>  CREATE TABLE print_table (
>    f_sequence INT,
>    f_random INT,
>    f_random_str STRING
>    ) WITH (
>    'connector' = 'print'
>  );
>
>  INSERT INTO print_table select f_sequence,f_random,f_random_str from datagen;
>
>
>想请问一下在flink web ui的stdout上发现没有打印一片空白，进入日志是有打印的，这是什么原因导致的？ 我如何解决，让ui的stdout能把内容打印出来