Details
-
Sub-task
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
1.19.0
Description
Test suggestion:
- 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
- Add this config to the config.yaml
- taskmanager.system-out.mode : LOG
- Run the job
- 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
Attachments
Issue Links
- is a clone of
-
FLINK-34308 Release Testing Instructions: Verify FLINK-33625 Support System out and err to be redirected to LOG or discarded
- Closed