Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-34285 [Umbrella] Test Flink Release 1.19
  3. FLINK-34382

Release Testing: Verify FLINK-33625 Support System out and err to be redirected to LOG or discarded

    XMLWordPrintableJSON

Details

    Description

      Test suggestion:

      1. Prepare a Flink SQL job and a flink datastream job
        • they can use the print sink or call System.out.println inside of the UDF
      2. Add this config to the config.yaml
        • taskmanager.system-out.mode : LOG
      3. Run the job
      4. Check whether the print log is redirected to log file

      SQL demo:

      ./bin/sql-client.sh
      
      CREATE TABLE orders (
        id           INT,
        app          INT,
        channel      INT,
        user_id      STRING,
        ts           TIMESTAMP(3),
        WATERMARK FOR ts AS ts
      ) WITH (
         'connector' = 'datagen',
         'rows-per-second'='20',
         'fields.app.min'='1',
         'fields.app.max'='10',
         'fields.channel.min'='21',
         'fields.channel.max'='30',
         'fields.user_id.length'='10'
      );
      
      create table print_sink ( 
        id           INT,
        app          INT,
        channel      INT,
        user_id      STRING,
        ts           TIMESTAMP(3)
      ) with ('connector' = 'print' );
      
      insert into print_sink
      select id       ,app       ,channel       ,user_id       ,ts   from orders 
      

      Attachments

        1. test2.png
          104 kB
          Caican Cai
        2. test1.png
          17 kB
          Caican Cai

        Issue Links

          Activity

            People

              caicancai Caican Cai
              lincoln.86xy lincoln lee
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: