[
https://issues.apache.org/jira/browse/FLINK-34382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34382:
--------------------------------
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
> Release Testing: Verify FLINK-33625 Support System out and err to be
> redirected to LOG or discarded
> ---------------------------------------------------------------------------------------------------
>
> Key: FLINK-34382
> URL: https://issues.apache.org/jira/browse/FLINK-34382
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Configuration
> Affects Versions: 1.19.0
> Reporter: lincoln lee
> Priority: Blocker
> Labels: release-testing
> Fix For: 1.19.0
>
>
> 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
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
