DataX系列6- MysqlWriter介绍

2021-12-16  本文已影响0人  只是甲

一. 快速介绍

  MysqlWriter 插件实现了写入数据到 Mysql 主库的目的表的功能。在底层实现上, MysqlWriter 通过 JDBC 连接远程 Mysql 数据库,并执行相应的 insert into ... 或者 ( replace into ...) 的 sql 语句将数据写入 Mysql,内部会分批次提交入库,需要数据库本身采用 innodb 引擎。

  MysqlWriter 面向ETL开发工程师,他们使用 MysqlWriter 从数仓导入数据到 Mysql。同时 MysqlWriter 亦可以作为数据迁移工具为DBA等用户提供服务。

二. 实现原理

MysqlWriter 通过 DataX 框架获取 Reader 生成的协议数据,根据你配置的 writeMode 生成

或者

注意:
目的表所在数据库必须是主库才能写入数据;整个任务至少需要具备 insert/replace into...的权限,是否需要其他权限,取决于你任务配置中在 preSql 和 postSql 中指定的语句。

三. 功能说明

3.1 配置样例

{
    "job": {
        "setting": {
            "speed": {
                "channel": 1
            }
        },
        "content": [
            {
                 "reader": {
                    "name": "streamreader",
                    "parameter": {
                        "column" : [
                            {
                                "value": "DataX",
                                "type": "string"
                            },
                            {
                                "value": 19880808,
                                "type": "long"
                            },
                            {
                                "value": "1988-08-08 08:08:08",
                                "type": "date"
                            },
                            {
                                "value": true,
                                "type": "bool"
                            },
                            {
                                "value": "test",
                                "type": "bytes"
                            }
                        ],
                        "sliceRecordCount": 1000
                    }
                },
                "writer": {
                    "name": "mysqlwriter",
                    "parameter": {
                        "writeMode": "insert",
                        "username": "root",
                        "password": "root",
                        "column": [
                            "id",
                            "name"
                        ],
                        "session": [
                            "set session sql_mode='ANSI'"
                        ],
                        "preSql": [
                            "delete from test"
                        ],
                        "connection": [
                            {
                                "jdbcUrl": "jdbc:mysql://127.0.0.1:3306/datax?useUnicode=true&characterEncoding=gbk",
                                "table": [
                                    "test"
                                ]
                            }
                        ]
                    }
                }
            }
        ]
    }
}

3.2 参数说明

3.2.1 jdbcUrl

3.2.2 username

3.2.3 password

3.2.4 table

3.2.5 column

3.2.6 session

3.2.7 preSql

3.2.8 postSql

3.2.9 writeMode

3.2.10 batchSize

3.3 类型转换

  类似 MysqlReader ,目前 MysqlWriter 支持大部分 Mysql 类型,但也存在部分个别类型没有支持的情况,请注意检查你的类型。

下面列出 MysqlWriter 针对 Mysql 类型转换列表:

image.png

四. 测试案例

  现在我们来测试一个从csv读取,然后再写入csv的案例.

4.1 数据准备

MySQL测试数据准备

4.2 json文件准备

{
    "job": {
        "setting": {
            "speed": {
                "channel": 1
            }
        },
        "content": [
            {
                "reader": {
                    "name": "mysqlreader",
                    "parameter": {
                        "username": "root",
                        "password": "abc123",
                        "column": [
                            "id",
                            "sale_date",
                            "prod_name",
                            "sale_nums",
                            "reserverd1"
                        ],
                        "splitPk": "id",
                        "connection": [
                            {
                                "table": [
                                    "fact_sale"
                                ],
                                "jdbcUrl": [
     "jdbc:mysql://10.31.1.122:3306/test"
                                ]
                            }
                        ]
                    }
                },
                "writer": {
                    "name": "mysqlwriter",
                    "parameter": {
                        "writeMode": "insert",
                        "username": "root",
                        "password": "abc123",
                        "column": [
                            "id",
                            "sale_date",
                            "prod_name",
                            "sale_nums",
                            "reserverd1"
                        ],
                        "session": [
                            "set session sql_mode='ANSI'"
                        ],
                        "preSql": [
                            "delete from fact_sale_20211123"
                        ],
                        "connection": [
                            {
                                "jdbcUrl": "jdbc:mysql://10.31.1.122:3306/test?useUnicode=true&characterEncoding=gbk",
                                "table": [
                                    "fact_sale_20211123"
                                ]
                            }
                        ]
                    }
                }
            }
        ]
    }
}

4.3 运行脚本

[15:15:08] [root@10-31-1-119 bin]# python datax.py mysqlreader.json 
[15:15:08] 
[15:15:08] DataX (DATAX-OPENSOURCE-3.0), From Alibaba !
[15:15:08] Copyright (C) 2010-2017, Alibaba Group. All Rights Reserved.
[15:15:08] 
[15:15:08] 
[15:15:09] 2021-11-23 15:15:15.227 [main] INFO  VMInfo - VMInfo# operatingSystem class => sun.management.OperatingSystemImpl
[15:15:09] 2021-11-23 15:15:15.233 [main] INFO  Engine - the machine info  => 
[15:15:09] 
[15:15:09]         osInfo: Oracle Corporation 1.8 25.242-b08
[15:15:09]         jvmInfo:        Linux amd64 3.10.0-1127.el7.x86_64
[15:15:09]         cpu num:        8
[15:15:09] 
[15:15:09]         totalPhysicalMemory:    -0.00G
[15:15:09]         freePhysicalMemory:     -0.00G
[15:15:09]         maxFileDescriptorCount: -1
[15:15:09]         currentOpenFileDescriptorCount: -1
[15:15:09] 
[15:15:09]         GC Names        [PS MarkSweep, PS Scavenge]
[15:15:09] 
[15:15:09]         MEMORY_NAME                    | allocation_size                | init_size                      
[15:15:09]         PS Eden Space                  | 256.00MB                       | 256.00MB                       
[15:15:09]         Code Cache                     | 240.00MB                       | 2.44MB                         
[15:15:09]         Compressed Class Space         | 1,024.00MB                     | 0.00MB                         
[15:15:09]         PS Survivor Space              | 42.50MB                        | 42.50MB                        
[15:15:09]         PS Old Gen                     | 683.00MB                       | 683.00MB                       
[15:15:09]         Metaspace                      | -0.00MB                        | 0.00MB                         
[15:15:09] 
[15:15:09] 
[15:15:09] 2021-11-23 15:15:15.249 [main] INFO  Engine - 
[15:15:09] {
[15:15:09]         "content":[
[15:15:09]                 {
[15:15:09]                         "reader":{
[15:15:09]                                 "name":"mysqlreader",
[15:15:09]                                 "parameter":{
[15:15:09]                                         "column":[
[15:15:09]                                                 "id",
[15:15:09]                                                 "sale_date",
[15:15:09]                                                 "prod_name",
[15:15:09]                                                 "sale_nums",
[15:15:09]                                                 "reserverd1"
[15:15:09]                                         ],
[15:15:09]                                         "connection":[
[15:15:09]                                                 {
[15:15:09]                                                         "jdbcUrl":[
[15:15:09]                                                                 "jdbc:mysql://10.31.1.122:3306/test"
[15:15:09]                                                         ],
[15:15:09]                                                         "table":[
[15:15:09]                                                                 "fact_sale"
[15:15:09]                                                         ]
[15:15:09]                                                 }
[15:15:09]                                         ],
[15:15:09]                                         "password":"******",
[15:15:09]                                         "splitPk":"id",
[15:15:09]                                         "username":"root"
[15:15:09]                                 }
[15:15:09]                         },
[15:15:09]                         "writer":{
[15:15:09]                                 "name":"mysqlwriter",
[15:15:09]                                 "parameter":{
[15:15:09]                                         "column":[
[15:15:09]                                                 "id",
[15:15:09]                                                 "sale_date",
[15:15:09]                                                 "prod_name",
[15:15:09]                                                 "sale_nums",
[15:15:09]                                                 "reserverd1"
[15:15:09]                                         ],
[15:15:09]                                         "connection":[
[15:15:09]                                                 {
[15:15:09]                                                         "jdbcUrl":"jdbc:mysql://10.31.1.122:3306/test?useUnicode=true&characterEncoding=gbk",
[15:15:09]                                                         "table":[
[15:15:09]                                                                 "fact_sale_20211123"
[15:15:09]                                                         ]
[15:15:09]                                                 }
[15:15:09]                                         ],
[15:15:09]                                         "password":"******",
[15:15:09]                                         "preSql":[
[15:15:09]                                                 "delete from fact_sale_20211123"
[15:15:09]                                         ],
[15:15:09]                                         "session":[
[15:15:09]                                                 "set session sql_mode='ANSI'"
[15:15:09]                                         ],
[15:15:09]                                         "username":"root",
[15:15:09]                                         "writeMode":"insert"
[15:15:09]                                 }
[15:15:09]                         }
[15:15:09]                 }
[15:15:09]         ],
[15:15:09]         "setting":{
[15:15:09]                 "speed":{
[15:15:09]                         "channel":1
[15:15:09]                 }
[15:15:09]         }
[15:15:09] }
[15:15:09] 
[15:15:09] 2021-11-23 15:15:15.262 [main] WARN  Engine - prioriy set to 0, because NumberFormatException, the value is: null
[15:15:09] 2021-11-23 15:15:15.264 [main] INFO  PerfTrace - PerfTrace traceId=job_-1, isEnable=false, priority=0
[15:15:09] 2021-11-23 15:15:15.264 [main] INFO  JobContainer - DataX jobContainer starts job.
[15:15:09] 2021-11-23 15:15:15.266 [main] INFO  JobContainer - Set jobId = 0
[15:15:09] 2021-11-23 15:15:15.548 [job-0] INFO  OriginalConfPretreatmentUtil - Available jdbcUrl:jdbc:mysql://10.31.1.122:3306/test?yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true.
[15:15:09] 2021-11-23 15:15:15.571 [job-0] INFO  OriginalConfPretreatmentUtil - table:[fact_sale] has columns:[id,sale_date,prod_name,sale_nums,reserverd1].
[15:15:09] 2021-11-23 15:15:15.765 [job-0] INFO  OriginalConfPretreatmentUtil - table:[fact_sale_20211123] all columns:[
[15:15:09] id,sale_date,prod_name,sale_nums,reserverd1
[15:15:09] ].
[15:15:09] 2021-11-23 15:15:15.780 [job-0] INFO  OriginalConfPretreatmentUtil - Write data [
[15:15:09] insert INTO %s (id,sale_date,prod_name,sale_nums,reserverd1) VALUES(?,?,?,?,?)
[15:15:09] ], which jdbcUrl like:[jdbc:mysql://10.31.1.122:3306/test?useUnicode=true&characterEncoding=gbk&yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true]
[15:15:09] 2021-11-23 15:15:15.781 [job-0] INFO  JobContainer - jobContainer starts to do prepare ...
[15:15:09] 2021-11-23 15:15:15.782 [job-0] INFO  JobContainer - DataX Reader.Job [mysqlreader] do prepare work .
[15:15:09] 2021-11-23 15:15:15.783 [job-0] INFO  JobContainer - DataX Writer.Job [mysqlwriter] do prepare work .
[15:15:09] 2021-11-23 15:15:15.796 [job-0] INFO  CommonRdbmsWriter$Job - Begin to execute preSqls:[delete from fact_sale_20211123]. context info:jdbc:mysql://10.31.1.122:3306/test?useUnicode=true&characterEncoding=gbk&yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true.
[15:15:09] 2021-11-23 15:15:15.798 [job-0] INFO  JobContainer - jobContainer starts to do split ...
[15:15:09] 2021-11-23 15:15:15.799 [job-0] INFO  JobContainer - Job set Channel-Number to 1 channels.
[15:15:09] 2021-11-23 15:15:15.807 [job-0] INFO  JobContainer - DataX Reader.Job [mysqlreader] splits to [1] tasks.
[15:15:09] 2021-11-23 15:15:15.808 [job-0] INFO  JobContainer - DataX Writer.Job [mysqlwriter] splits to [1] tasks.
[15:15:09] 2021-11-23 15:15:15.829 [job-0] INFO  JobContainer - jobContainer starts to do schedule ...
[15:15:09] 2021-11-23 15:15:15.834 [job-0] INFO  JobContainer - Scheduler starts [1] taskGroups.
[15:15:09] 2021-11-23 15:15:15.838 [job-0] INFO  JobContainer - Running by standalone Mode.
[15:15:09] 2021-11-23 15:15:15.848 [taskGroup-0] INFO  TaskGroupContainer - taskGroupId=[0] start [1] channels for [1] tasks.
[15:15:09] 2021-11-23 15:15:15.853 [taskGroup-0] INFO  Channel - Channel set byte_speed_limit to -1, No bps activated.
[15:15:09] 2021-11-23 15:15:15.853 [taskGroup-0] INFO  Channel - Channel set record_speed_limit to -1, No tps activated.
[15:15:09] 2021-11-23 15:15:15.862 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] taskId[0] attemptCount[1] is started
[15:15:09] 2021-11-23 15:15:15.864 [0-0-0-reader] INFO  CommonRdbmsReader$Task - Begin to read record by Sql: [select id,sale_date,prod_name,sale_nums,reserverd1 from fact_sale 
[15:15:09] ] jdbcUrl:[jdbc:mysql://10.31.1.122:3306/test?yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true].
[15:15:09] 2021-11-23 15:15:15.877 [0-0-0-writer] INFO  DBUtil - execute sql:[set session sql_mode='ANSI']
[15:15:09] 2021-11-23 15:15:15.886 [0-0-0-writer] INFO  DBUtil - execute sql:[set session sql_mode='ANSI']
[15:15:19] 2021-11-23 15:15:25.858 [job-0] INFO  StandAloneJobContainerCommunicator - Total 0 records, 0 bytes | Speed 0B/s, 0 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 0.000s |  All Task WaitReaderTime 0.000s | Percentage 0.00%
[15:15:29] 2021-11-23 15:15:35.860 [job-0] INFO  StandAloneJobContainerCommunicator - Total 457216 records, 9520846 bytes | Speed 929.77KB/s, 45721 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 8.239s |  All Task WaitReaderTime 1.307s | Percentage 0.00%
[15:15:39] 2021-11-23 15:15:45.862 [job-0] INFO  StandAloneJobContainerCommunicator - Total 965120 records, 20220951 bytes | Speed 1.02MB/s, 50790 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 16.529s |  All Task WaitReaderTime 2.663s | Percentage 0.00%
[15:15:49] 2021-11-23 15:15:55.865 [job-0] INFO  StandAloneJobContainerCommunicator - Total 1509888 records, 32207555 bytes | Speed 1.14MB/s, 54476 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 24.654s |  All Task WaitReaderTime 4.114s | Percentage 0.00%
[15:15:59] 2021-11-23 15:16:05.868 [job-0] INFO  StandAloneJobContainerCommunicator - Total 2040320 records, 43912382 bytes | Speed 1.12MB/s, 53043 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 32.874s |  All Task WaitReaderTime 5.492s | Percentage 0.00%
[15:16:09] 2021-11-23 15:16:15.870 [job-0] INFO  StandAloneJobContainerCommunicator - Total 2571680 records, 55638136 bytes | Speed 1.12MB/s, 53136 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 41.109s |  All Task WaitReaderTime 6.882s | Percentage 0.00%
[15:16:19] 2021-11-23 15:16:25.872 [job-0] INFO  StandAloneJobContainerCommunicator - Total 3101376 records, 67327123 bytes | Speed 1.11MB/s, 52969 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 49.291s |  All Task WaitReaderTime 8.293s | Percentage 0.00%
[15:16:29] 2021-11-23 15:16:35.874 [job-0] INFO  StandAloneJobContainerCommunicator - Total 3680768 records, 80112189 bytes | Speed 1.22MB/s, 57939 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 57.509s |  All Task WaitReaderTime 9.677s | Percentage 0.00%
[15:16:39] 2021-11-23 15:16:45.876 [job-0] INFO  StandAloneJobContainerCommunicator - Total 4221440 records, 92042930 bytes | Speed 1.14MB/s, 54067 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 65.598s |  All Task WaitReaderTime 11.132s | Percentage 0.00%
[15:16:49] 2021-11-23 15:16:55.879 [job-0] INFO  StandAloneJobContainerCommunicator - Total 4759424 records, 103914506 bytes | Speed 1.13MB/s, 53798 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 73.766s |  All Task WaitReaderTime 12.573s | Percentage 0.00%
[15:16:59] 2021-11-23 15:17:05.881 [job-0] INFO  StandAloneJobContainerCommunicator - Total 5292544 records, 115678554 bytes | Speed 1.12MB/s, 53312 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 81.863s |  All Task WaitReaderTime 14.051s | Percentage 0.00%
[15:17:09] 2021-11-23 15:17:15.883 [job-0] INFO  StandAloneJobContainerCommunicator - Total 5843456 records, 127835825 bytes | Speed 1.16MB/s, 55091 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 90.052s |  All Task WaitReaderTime 15.449s | Percentage 0.00%
[15:17:19] 2021-11-23 15:17:25.885 [job-0] INFO  StandAloneJobContainerCommunicator - Total 6388224 records, 139857335 bytes | Speed 1.15MB/s, 54476 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 98.266s |  All Task WaitReaderTime 16.825s | Percentage 0.00%
[15:17:29] 2021-11-23 15:17:35.887 [job-0] INFO  StandAloneJobContainerCommunicator - Total 6914560 records, 151471729 bytes | Speed 1.11MB/s, 52633 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 106.439s |  All Task WaitReaderTime 18.248s | Percentage 0.00%
[15:17:39] 2021-11-23 15:17:45.890 [job-0] INFO  StandAloneJobContainerCommunicator - Total 7445152 records, 163180191 bytes | Speed 1.12MB/s, 53059 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 114.561s |  All Task WaitReaderTime 19.705s | Percentage 0.00%
[15:17:49] 2021-11-23 15:17:55.892 [job-0] INFO  StandAloneJobContainerCommunicator - Total 8008192 records, 175604687 bytes | Speed 1.18MB/s, 56304 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 122.665s |  All Task WaitReaderTime 21.153s | Percentage 0.00%
[15:17:59] 2021-11-23 15:18:05.895 [job-0] INFO  StandAloneJobContainerCommunicator - Total 8546816 records, 187489992 bytes | Speed 1.13MB/s, 53862 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 130.803s |  All Task WaitReaderTime 22.582s | Percentage 0.00%
[15:18:09] 2021-11-23 15:18:15.897 [job-0] INFO  StandAloneJobContainerCommunicator - Total 9085440 records, 199375730 bytes | Speed 1.13MB/s, 53862 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 139.033s |  All Task WaitReaderTime 23.985s | Percentage 0.00%
[15:18:19] 2021-11-23 15:18:25.899 [job-0] INFO  StandAloneJobContainerCommunicator - Total 9607680 records, 210900025 bytes | Speed 1.10MB/s, 52224 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 147.244s |  All Task WaitReaderTime 25.354s | Percentage 0.00%
[15:18:29] 2021-11-23 15:18:35.902 [job-0] INFO  StandAloneJobContainerCommunicator - Total 10162688 records, 223309813 bytes | Speed 1.18MB/s, 55500 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 155.491s |  All Task WaitReaderTime 26.681s | Percentage 0.00%
[15:18:39] 2021-11-23 15:18:45.904 [job-0] INFO  StandAloneJobContainerCommunicator - Total 10703360 records, 235781136 bytes | Speed 1.19MB/s, 54067 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 163.649s |  All Task WaitReaderTime 28.114s | Percentage 0.00%
[15:18:49] 2021-11-23 15:18:55.906 [job-0] INFO  StandAloneJobContainerCommunicator - Total 11252224 records, 248441430 bytes | Speed 1.21MB/s, 54886 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 171.776s |  All Task WaitReaderTime 29.578s | Percentage 0.00%
[15:18:59] 2021-11-23 15:19:05.908 [job-0] INFO  StandAloneJobContainerCommunicator - Total 11809280 records, 261291375 bytes | Speed 1.23MB/s, 55705 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 179.943s |  All Task WaitReaderTime 30.977s | Percentage 0.00%
[15:19:09] 2021-11-23 15:19:15.910 [job-0] INFO  StandAloneJobContainerCommunicator - Total 12362240 records, 274045964 bytes | Speed 1.22MB/s, 55296 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 188.055s |  All Task WaitReaderTime 32.432s | Percentage 0.00%
[15:19:19] 2021-11-23 15:19:25.912 [job-0] INFO  StandAloneJobContainerCommunicator - Total 12907008 records, 286612190 bytes | Speed 1.20MB/s, 54476 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 196.322s |  All Task WaitReaderTime 33.756s | Percentage 0.00%
[15:19:29] 2021-11-23 15:19:35.914 [job-0] INFO  StandAloneJobContainerCommunicator - Total 13455872 records, 299272627 bytes | Speed 1.21MB/s, 54886 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 204.395s |  All Task WaitReaderTime 35.212s | Percentage 0.00%
[15:19:39] 2021-11-23 15:19:45.916 [job-0] INFO  StandAloneJobContainerCommunicator - Total 14006784 records, 311980588 bytes | Speed 1.21MB/s, 55091 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 212.706s |  All Task WaitReaderTime 36.526s | Percentage 0.00%
[15:19:49] 2021-11-23 15:19:55.917 [job-0] INFO  StandAloneJobContainerCommunicator - Total 14565888 records, 324876983 bytes | Speed 1.23MB/s, 55910 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 220.906s |  All Task WaitReaderTime 37.896s | Percentage 0.00%
[15:19:59] 2021-11-23 15:20:05.926 [job-0] INFO  StandAloneJobContainerCommunicator - Total 15127040 records, 337821227 bytes | Speed 1.23MB/s, 56115 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 229.167s |  All Task WaitReaderTime 39.226s | Percentage 0.00%
[15:20:09] 2021-11-23 15:20:15.928 [job-0] INFO  StandAloneJobContainerCommunicator - Total 15659520 records, 350103073 bytes | Speed 1.17MB/s, 53248 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 237.358s |  All Task WaitReaderTime 40.614s | Percentage 0.00%
[15:20:09] 2021-11-23 15:20:15.933 [job-0] INFO  VMInfo - 
[15:20:09]          [delta cpu info] => 
[15:20:09]                 curDeltaCpu                    | averageCpu                     | maxDeltaCpu                    | minDeltaCpu                    
[15:20:09]                 -1.00%                         | -1.00%                         | -1.00%                         | -1.00%
[15:20:09]                         
[15:20:09] 
[15:20:09]          [delta memory info] => 
[15:20:09]                  NAME                           | used_size                      | used_percent                   | max_used_size                  | max_percent                    
[15:20:09]                  PS Eden Space                  | 165.53MB                       | 49.27%                         | 165.53MB                       | 49.27%                         
[15:20:09]                  Code Cache                     | 7.11MB                         | 73.83%                         | 7.11MB                         | 73.83%                         
[15:20:09]                  Compressed Class Space         | 1.82MB                         | 90.86%                         | 1.82MB                         | 90.86%                         
[15:20:09]                  PS Survivor Space              | 1.13MB                         | 45.00%                         | 1.13MB                         | 45.00%                         
[15:20:09]                  PS Old Gen                     | 6.31MB                         | 0.92%                          | 6.31MB                         | 0.92%                          
[15:20:09]                  Metaspace                      | 18.87MB                        | 96.77%                         | 18.87MB                        | 96.77%                         
[15:20:09] 
[15:20:09]          [delta gc info] => 
[15:20:09]                  NAME                 | curDeltaGCCount    | totalGCCount       | maxDeltaGCCount    | minDeltaGCCount    | curDeltaGCTime     | totalGCTime        | maxDeltaGCTime     | minDeltaGCTime     
[15:20:09]                  PS MarkSweep         | 0                  | 0                  | 0                  | 0                  | 0.000s             | 0.000s             | 0.000s             | 0.000s             
[15:20:09]                  PS Scavenge          | 207                | 207                | 207                | 207                | 0.861s             | 0.861s             | 0.861s             | 0.861s             
[15:20:10] 
[15:20:19] 2021-11-23 15:20:25.935 [job-0] INFO  StandAloneJobContainerCommunicator - Total 16198144 records, 362527406 bytes | Speed 1.18MB/s, 53862 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 245.531s |  All Task WaitReaderTime 42.024s | Percentage 0.00%
[15:20:29] 2021-11-23 15:20:35.937 [job-0] INFO  StandAloneJobContainerCommunicator - Total 16773632 records, 375802114 bytes | Speed 1.27MB/s, 57548 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 253.588s |  All Task WaitReaderTime 43.529s | Percentage 0.00%
[15:20:39] 2021-11-23 15:20:45.939 [job-0] INFO  StandAloneJobContainerCommunicator - Total 17312800 records, 388239224 bytes | Speed 1.19MB/s, 53916 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 261.724s |  All Task WaitReaderTime 44.941s | Percentage 0.00%
[15:20:49] 2021-11-23 15:20:55.940 [job-0] INFO  StandAloneJobContainerCommunicator - Total 17852928 records, 400698476 bytes | Speed 1.19MB/s, 54012 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 269.856s |  All Task WaitReaderTime 46.361s | Percentage 0.00%
[15:20:59] 2021-11-23 15:21:05.942 [job-0] INFO  StandAloneJobContainerCommunicator - Total 18393600 records, 413169855 bytes | Speed 1.19MB/s, 54067 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 278.005s |  All Task WaitReaderTime 47.770s | Percentage 0.00%
[15:21:09] 2021-11-23 15:21:15.944 [job-0] INFO  StandAloneJobContainerCommunicator - Total 18952704 records, 426066634 bytes | Speed 1.23MB/s, 55910 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 286.098s |  All Task WaitReaderTime 49.241s | Percentage 0.00%
[15:21:19] 2021-11-23 15:21:25.945 [job-0] INFO  StandAloneJobContainerCommunicator - Total 19508576 records, 438889072 bytes | Speed 1.22MB/s, 55587 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 294.250s |  All Task WaitReaderTime 50.699s | Percentage 0.00%
[15:21:29] 2021-11-23 15:21:35.946 [job-0] INFO  StandAloneJobContainerCommunicator - Total 20050432 records, 451387881 bytes | Speed 1.19MB/s, 54185 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 302.391s |  All Task WaitReaderTime 52.109s | Percentage 0.00%
[15:21:39] 2021-11-23 15:21:45.948 [job-0] INFO  StandAloneJobContainerCommunicator - Total 20587008 records, 463765031 bytes | Speed 1.18MB/s, 53657 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 310.540s |  All Task WaitReaderTime 53.520s | Percentage 0.00%
[15:21:49] 2021-11-23 15:21:55.949 [job-0] INFO  StandAloneJobContainerCommunicator - Total 21133824 records, 476378164 bytes | Speed 1.20MB/s, 54681 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 318.690s |  All Task WaitReaderTime 54.971s | Percentage 0.00%
[15:21:59] 2021-11-23 15:22:05.951 [job-0] INFO  StandAloneJobContainerCommunicator - Total 21684736 records, 489086159 bytes | Speed 1.21MB/s, 55091 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 326.753s |  All Task WaitReaderTime 56.399s | Percentage 0.00%
[15:22:09] 2021-11-23 15:22:15.953 [job-0] INFO  StandAloneJobContainerCommunicator - Total 22252032 records, 502172058 bytes | Speed 1.25MB/s, 56729 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 334.940s |  All Task WaitReaderTime 57.847s | Percentage 0.00%
[15:22:19] 2021-11-23 15:22:25.954 [job-0] INFO  StandAloneJobContainerCommunicator - Total 22804992 records, 514926854 bytes | Speed 1.22MB/s, 55296 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 343.095s |  All Task WaitReaderTime 59.283s | Percentage 0.00%
[15:22:29] 2021-11-23 15:22:35.956 [job-0] INFO  StandAloneJobContainerCommunicator - Total 23353856 records, 527587763 bytes | Speed 1.21MB/s, 54886 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 351.214s |  All Task WaitReaderTime 60.717s | Percentage 0.00%
[15:22:39] 2021-11-23 15:22:45.958 [job-0] INFO  StandAloneJobContainerCommunicator - Total 23900672 records, 540201405 bytes | Speed 1.20MB/s, 54681 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 359.361s |  All Task WaitReaderTime 62.144s | Percentage 0.00%
[15:22:49] 2021-11-23 15:22:55.959 [job-0] INFO  StandAloneJobContainerCommunicator - Total 24451584 records, 552908981 bytes | Speed 1.21MB/s, 55091 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 367.532s |  All Task WaitReaderTime 63.545s | Percentage 0.00%
[15:22:59] 2021-11-23 15:23:05.961 [job-0] INFO  StandAloneJobContainerCommunicator - Total 24996544 records, 565479153 bytes | Speed 1.20MB/s, 54496 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 375.710s |  All Task WaitReaderTime 64.946s | Percentage 0.00%
[15:23:09] 2021-11-23 15:23:15.962 [job-0] INFO  StandAloneJobContainerCommunicator - Total 25549312 records, 578229777 bytes | Speed 1.22MB/s, 55276 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 383.887s |  All Task WaitReaderTime 66.332s | Percentage 0.00%
[15:23:19] 2021-11-23 15:23:25.963 [job-0] INFO  StandAloneJobContainerCommunicator - Total 26083840 records, 590559507 bytes | Speed 1.18MB/s, 53452 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 392.063s |  All Task WaitReaderTime 67.735s | Percentage 0.00%
[15:23:29] 2021-11-23 15:23:35.965 [job-0] INFO  StandAloneJobContainerCommunicator - Total 26632704 records, 603220300 bytes | Speed 1.21MB/s, 54886 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 400.178s |  All Task WaitReaderTime 69.174s | Percentage 0.00%
[15:23:40] 2021-11-23 15:23:45.970 [job-0] INFO  StandAloneJobContainerCommunicator - Total 27171328 records, 615644848 bytes | Speed 1.18MB/s, 53862 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 408.379s |  All Task WaitReaderTime 70.568s | Percentage 0.00%
[15:23:50] 2021-11-23 15:23:55.972 [job-0] INFO  StandAloneJobContainerCommunicator - Total 27704224 records, 627937753 bytes | Speed 1.17MB/s, 53289 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 416.588s |  All Task WaitReaderTime 71.970s | Percentage 0.00%
[15:24:00] 2021-11-23 15:24:05.973 [job-0] INFO  StandAloneJobContainerCommunicator - Total 28278016 records, 641172527 bytes | Speed 1.26MB/s, 57379 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 424.621s |  All Task WaitReaderTime 73.477s | Percentage 0.00%
[15:24:10] 2021-11-23 15:24:15.974 [job-0] INFO  StandAloneJobContainerCommunicator - Total 28826112 records, 653815341 bytes | Speed 1.21MB/s, 54809 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 432.785s |  All Task WaitReaderTime 74.877s | Percentage 0.00%
[15:24:20] 2021-11-23 15:24:25.976 [job-0] INFO  StandAloneJobContainerCommunicator - Total 29405696 records, 667184043 bytes | Speed 1.27MB/s, 57958 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 441.118s |  All Task WaitReaderTime 76.141s | Percentage 0.00%
[15:24:30] 2021-11-23 15:24:35.977 [job-0] INFO  StandAloneJobContainerCommunicator - Total 29985280 records, 680554076 bytes | Speed 1.28MB/s, 57958 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 449.547s |  All Task WaitReaderTime 77.345s | Percentage 0.00%
[15:24:40] 2021-11-23 15:24:45.978 [job-0] INFO  StandAloneJobContainerCommunicator - Total 30532096 records, 693166761 bytes | Speed 1.20MB/s, 54681 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 457.637s |  All Task WaitReaderTime 78.797s | Percentage 0.00%
[15:24:50] 2021-11-23 15:24:55.979 [job-0] INFO  StandAloneJobContainerCommunicator - Total 31089152 records, 706015855 bytes | Speed 1.23MB/s, 55705 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 465.732s |  All Task WaitReaderTime 80.273s | Percentage 0.00%
[15:25:00] 2021-11-23 15:25:05.981 [job-0] INFO  StandAloneJobContainerCommunicator - Total 31642112 records, 718770839 bytes | Speed 1.22MB/s, 55296 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 473.948s |  All Task WaitReaderTime 81.645s | Percentage 0.00%
[15:25:10] 2021-11-23 15:25:15.982 [job-0] INFO  StandAloneJobContainerCommunicator - Total 32184832 records, 731289672 bytes | Speed 1.19MB/s, 54272 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 482.139s |  All Task WaitReaderTime 83.031s | Percentage 0.00%
[15:25:10] 2021-11-23 15:25:15.985 [job-0] INFO  VMInfo - 
[15:25:10]          [delta cpu info] => 
[15:25:10]                 curDeltaCpu                    | averageCpu                     | maxDeltaCpu                    | minDeltaCpu                    
[15:25:10]                 -1.00%                         | -1.00%                         | -1.00%                         | -1.00%
[15:25:10]                         
[15:25:10] 
[15:25:10]          [delta memory info] => 
[15:25:10]                  NAME                           | used_size                      | used_percent                   | max_used_size                  | max_percent                    
[15:25:10]                  PS Eden Space                  | 255.42MB                       | 76.25%                         | 255.42MB                       | 76.25%                         
[15:25:10]                  Code Cache                     | 6.90MB                         | 71.73%                         | 7.11MB                         | 73.83%                         
[15:25:10]                  Compressed Class Space         | 1.82MB                         | 90.86%                         | 1.82MB                         | 90.86%                         
[15:25:10]                  PS Survivor Space              | 1.84MB                         | 73.75%                         | 1.84MB                         | 73.75%                         
[15:25:10]                  PS Old Gen                     | 7.09MB                         | 1.04%                          | 7.09MB                         | 1.04%                          
[15:25:10]                  Metaspace                      | 18.93MB                        | 97.09%                         | 18.93MB                        | 97.09%                         
[15:25:10] 
[15:25:10]          [delta gc info] => 
[15:25:10]                  NAME                 | curDeltaGCCount    | totalGCCount       | maxDeltaGCCount    | minDeltaGCCount    | curDeltaGCTime     | totalGCTime        | maxDeltaGCTime     | minDeltaGCTime     
[15:25:10]                  PS MarkSweep         | 0                  | 0                  | 0                  | 0                  | 0.000s             | 0.000s             | 0.000s             | 0.000s             
[15:25:10]                  PS Scavenge          | 209                | 416                | 209                | 207                | 0.766s             | 1.627s             | 0.861s             | 0.766s             
[15:25:10] 
.....................................................
.....................................................
.....................................................
.....................................................
.....................................................
.....................................................
[20:58:00] 
[20:58:10] 2021-11-23 20:58:17.205 [job-0] INFO  StandAloneJobContainerCommunicator - Total 755894784 records, 18080744351 bytes | Speed 563.15KB/s, 23961 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,040.412s |  All Task WaitReaderTime 1,948.532s | Percentage 0.00%
[20:58:30] 2021-11-23 20:58:37.206 [job-0] INFO  StandAloneJobContainerCommunicator - Total 756361728 records, 18091981815 bytes | Speed 548.70KB/s, 23347 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,058.898s |  All Task WaitReaderTime 1,949.762s | Percentage 0.00%
[20:58:50] 2021-11-23 20:58:57.206 [job-0] INFO  StandAloneJobContainerCommunicator - Total 756828672 records, 18103219295 bytes | Speed 548.71KB/s, 23347 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,077.316s |  All Task WaitReaderTime 1,950.989s | Percentage 0.00%
[20:59:00] 2021-11-23 20:59:07.207 [job-0] INFO  StandAloneJobContainerCommunicator - Total 757066240 records, 18108936608 bytes | Speed 558.33KB/s, 23756 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,086.449s |  All Task WaitReaderTime 1,951.626s | Percentage 0.00%
[20:59:20] 2021-11-23 20:59:27.208 [job-0] INFO  StandAloneJobContainerCommunicator - Total 757522944 records, 18119927896 bytes | Speed 536.68KB/s, 22835 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,105.027s |  All Task WaitReaderTime 1,952.794s | Percentage 0.00%
[20:59:40] 2021-11-23 20:59:47.209 [job-0] INFO  StandAloneJobContainerCommunicator - Total 757987840 records, 18131116582 bytes | Speed 546.32KB/s, 23244 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,123.482s |  All Task WaitReaderTime 1,953.999s | Percentage 0.00%
[21:00:00] 2021-11-23 21:00:07.209 [job-0] INFO  StandAloneJobContainerCommunicator - Total 758450688 records, 18142255902 bytes | Speed 543.91KB/s, 23142 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,142.016s |  All Task WaitReaderTime 1,955.109s | Percentage 0.00%
[21:00:10] 2021-11-23 21:00:17.210 [job-0] INFO  StandAloneJobContainerCommunicator - Total 758682112 records, 18147825345 bytes | Speed 543.89KB/s, 23142 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,151.313s |  All Task WaitReaderTime 1,955.656s | Percentage 0.00%
[21:00:30] 2021-11-23 21:00:37.210 [job-0] INFO  StandAloneJobContainerCommunicator - Total 759138816 records, 18158816743 bytes | Speed 536.69KB/s, 22835 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,169.842s |  All Task WaitReaderTime 1,956.786s | Percentage 0.00%
[21:00:40] 2021-11-23 21:00:47.211 [job-0] INFO  StandAloneJobContainerCommunicator - Total 759365312 records, 18164267169 bytes | Speed 532.27KB/s, 22649 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,179.135s |  All Task WaitReaderTime 1,957.387s | Percentage 0.00%
[21:01:00] 2021-11-23 21:01:07.212 [job-0] INFO  StandAloneJobContainerCommunicator - Total 759822848 records, 18175278416 bytes | Speed 537.66KB/s, 22876 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,197.670s |  All Task WaitReaderTime 1,958.516s | Percentage 0.00%
[21:01:20] 2021-11-23 21:01:27.212 [job-0] INFO  StandAloneJobContainerCommunicator - Total 760283648 records, 18186368428 bytes | Speed 541.50KB/s, 23040 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,216.049s |  All Task WaitReaderTime 1,959.759s | Percentage 0.00%
[21:01:30] 2021-11-23 21:01:37.213 [job-0] INFO  StandAloneJobContainerCommunicator - Total 760508928 records, 18191789890 bytes | Speed 529.44KB/s, 22528 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,225.354s |  All Task WaitReaderTime 1,960.331s | Percentage 0.00%
[21:01:50] 2021-11-23 21:01:57.213 [job-0] INFO  StandAloneJobContainerCommunicator - Total 760969728 records, 18202879729 bytes | Speed 541.50KB/s, 23040 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,243.754s |  All Task WaitReaderTime 1,961.525s | Percentage 0.00%
[21:02:00] 2021-11-23 21:02:07.214 [job-0] INFO  StandAloneJobContainerCommunicator - Total 761203488 records, 18208505204 bytes | Speed 549.36KB/s, 23376 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,253.023s |  All Task WaitReaderTime 1,962.159s | Percentage 0.00%
[21:02:20] 2021-11-23 21:02:27.215 [job-0] INFO  StandAloneJobContainerCommunicator - Total 761666048 records, 18219637650 bytes | Speed 543.58KB/s, 23128 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,271.445s |  All Task WaitReaderTime 1,963.390s | Percentage 0.00%
[21:02:40] 2021-11-23 21:02:47.216 [job-0] INFO  StandAloneJobContainerCommunicator - Total 762126848 records, 18230727736 bytes | Speed 541.51KB/s, 23040 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,289.904s |  All Task WaitReaderTime 1,964.554s | Percentage 0.00%
[21:03:00] 2021-11-23 21:03:07.216 [job-0] INFO  StandAloneJobContainerCommunicator - Total 762591744 records, 18241916140 bytes | Speed 546.31KB/s, 23244 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,308.391s |  All Task WaitReaderTime 1,965.748s | Percentage 0.00%
[21:03:00] 2021-11-23 21:03:07.217 [job-0] INFO  VMInfo - 
[21:03:00]          [delta cpu info] => 
[21:03:00]                 curDeltaCpu                    | averageCpu                     | maxDeltaCpu                    | minDeltaCpu                    
[21:03:00]                 -1.00%                         | -1.00%                         | -1.00%                         | -1.00%
[21:03:00]                         
[21:03:00] 
[21:03:00]          [delta memory info] => 
[21:03:00]                  NAME                           | used_size                      | used_percent                   | max_used_size                  | max_percent                    
[21:03:00]                  PS Eden Space                  | 5.29MB                         | 1.58%                          | 334.44MB                       | 99.83%                         
[21:03:00]                  Code Cache                     | 8.75MB                         | 88.59%                         | 8.75MB                         | 88.59%                         
[21:03:00]                  Compressed Class Space         | 1.82MB                         | 90.86%                         | 1.82MB                         | 90.86%                         
[21:03:00]                  PS Survivor Space              | 2.12MB                         | 84.69%                         | 2.27MB                         | 90.63%                         
[21:03:00]                  PS Old Gen                     | 62.84MB                        | 9.20%                          | 62.84MB                        | 9.20%                          
[21:03:00]                  Metaspace                      | 19.14MB                        | 96.93%                         | 19.14MB                        | 97.51%                         
[21:03:00] 
[21:03:00]          [delta gc info] => 
[21:03:00]                  NAME                 | curDeltaGCCount    | totalGCCount       | maxDeltaGCCount    | minDeltaGCCount    | curDeltaGCTime     | totalGCTime        | maxDeltaGCTime     | minDeltaGCTime     
[21:03:00]                  PS MarkSweep         | 0                  | 0                  | 0                  | 0                  | 0.000s             | 0.000s             | 0.000s             | 0.000s             
[21:03:00]                  PS Scavenge          | 89                 | 9728               | 220                | 87                 | 0.294s             | 33.253s            | 1.097s             | 0.253s             
[21:03:00] 
[21:03:10] 2021-11-23 21:03:17.218 [job-0] INFO  StandAloneJobContainerCommunicator - Total 762823168 records, 18247485885 bytes | Speed 543.92KB/s, 23142 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,317.656s |  All Task WaitReaderTime 1,966.344s | Percentage 0.00%
[21:03:30] 2021-11-23 21:03:37.219 [job-0] INFO  StandAloneJobContainerCommunicator - Total 763275776 records, 18258378926 bytes | Speed 531.89KB/s, 22630 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,336.061s |  All Task WaitReaderTime 1,967.562s | Percentage 0.00%
[21:03:50] 2021-11-23 21:03:57.219 [job-0] INFO  StandAloneJobContainerCommunicator - Total 763722240 records, 18269123270 bytes | Speed 524.63KB/s, 22323 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,354.619s |  All Task WaitReaderTime 1,968.737s | Percentage 0.00%
[21:04:00] 2021-11-23 21:04:07.220 [job-0] INFO  StandAloneJobContainerCommunicator - Total 763953664 records, 18274692677 bytes | Speed 543.89KB/s, 23142 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,363.797s |  All Task WaitReaderTime 1,969.368s | Percentage 0.00%
[21:04:20] 2021-11-23 21:04:27.220 [job-0] INFO  StandAloneJobContainerCommunicator - Total 764414464 records, 18285782030 bytes | Speed 541.47KB/s, 23040 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,382.330s |  All Task WaitReaderTime 1,970.509s | Percentage 0.00%
[21:04:30] 2021-11-23 21:04:37.221 [job-0] INFO  StandAloneJobContainerCommunicator - Total 764647936 records, 18291401210 bytes | Speed 548.75KB/s, 23347 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,391.488s |  All Task WaitReaderTime 1,971.144s | Percentage 0.00%
[21:04:50] 2021-11-23 21:04:57.222 [job-0] INFO  StandAloneJobContainerCommunicator - Total 765110784 records, 18302540521 bytes | Speed 543.91KB/s, 23142 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,409.973s |  All Task WaitReaderTime 1,972.357s | Percentage 0.00%
[21:05:00] 2021-11-23 21:05:07.222 [job-0] INFO  StandAloneJobContainerCommunicator - Total 765342208 records, 18308110668 bytes | Speed 543.96KB/s, 23142 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,419.242s |  All Task WaitReaderTime 1,972.907s | Percentage 0.00%
[21:05:20] 2021-11-23 21:05:27.223 [job-0] INFO  StandAloneJobContainerCommunicator - Total 765815296 records, 18319496498 bytes | Speed 555.95KB/s, 23654 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,437.746s |  All Task WaitReaderTime 1,974.072s | Percentage 0.00%
[21:05:40] 2021-11-23 21:05:47.224 [job-0] INFO  StandAloneJobContainerCommunicator - Total 766274048 records, 18330537207 bytes | Speed 539.10KB/s, 22937 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,456.283s |  All Task WaitReaderTime 1,975.217s | Percentage 0.00%
[21:05:50] 2021-11-23 21:05:57.224 [job-0] INFO  StandAloneJobContainerCommunicator - Total 766508800 records, 18336187030 bytes | Speed 551.74KB/s, 23475 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,465.588s |  All Task WaitReaderTime 1,975.812s | Percentage 0.00%
[21:06:10] 2021-11-23 21:06:17.225 [job-0] INFO  StandAloneJobContainerCommunicator - Total 766974464 records, 18347393894 bytes | Speed 547.21KB/s, 23283 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,484.096s |  All Task WaitReaderTime 1,976.971s | Percentage 0.00%
[21:06:30] 2021-11-23 21:06:37.225 [job-0] INFO  StandAloneJobContainerCommunicator - Total 767433472 records, 18358440103 bytes | Speed 539.37KB/s, 22950 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,502.627s |  All Task WaitReaderTime 1,978.130s | Percentage 0.00%
[21:06:40] 2021-11-23 21:06:47.226 [job-0] INFO  StandAloneJobContainerCommunicator - Total 767674880 records, 18364250175 bytes | Speed 567.39KB/s, 24140 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,511.877s |  All Task WaitReaderTime 1,978.706s | Percentage 0.00%
[21:06:46] 2021-11-23 21:06:52.825 [0-0-0-reader] INFO  CommonRdbmsReader$Task - Finished read record by Sql: [select id,sale_date,prod_name,sale_nums,reserverd1 from fact_sale 
[21:06:46] ] jdbcUrl:[jdbc:mysql://10.31.1.122:3306/test?yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true].
[21:06:46] 2021-11-23 21:06:53.151 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] taskId[0] is successed, used[21097290]ms
[21:06:46] 2021-11-23 21:06:53.152 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] completed it's tasks.
[21:06:50] 2021-11-23 21:06:57.226 [job-0] INFO  AbstractScheduler - Scheduler accomplished all tasks.
[21:06:50] 2021-11-23 21:06:57.228 [job-0] INFO  JobContainer - DataX Writer.Job [mysqlwriter] do post work.
[21:06:50] 2021-11-23 21:06:57.228 [job-0] INFO  JobContainer - DataX Reader.Job [mysqlreader] do post work.
[21:06:50] 2021-11-23 21:06:57.229 [job-0] INFO  JobContainer - DataX jobId [0] completed successfully.
[21:06:50] 2021-11-23 21:06:57.232 [job-0] INFO  HookInvoker - No hook invoked, because base dir not exists or is a file: /home/software/datax/hook
[21:06:50] 2021-11-23 21:06:57.232 [job-0] INFO  JobContainer - 
[21:06:50]          [total cpu info] => 
[21:06:50]                 averageCpu                     | maxDeltaCpu                    | minDeltaCpu                    
[21:06:50]                 -1.00%                         | -1.00%                         | -1.00%
[21:06:50]                         
[21:06:50] 
[21:06:50]          [total gc info] => 
[21:06:50]                  NAME                 | totalGCCount       | maxDeltaGCCount    | minDeltaGCCount    | totalGCTime        | maxDeltaGCTime     | minDeltaGCTime     
[21:06:50]                  PS MarkSweep         | 0                  | 0                  | 0                  | 0.000s             | 0.000s             | 0.000s             
[21:06:50]                  PS Scavenge          | 9794               | 220                | 66                 | 33.446s            | 1.097s             | 0.193s             
[21:06:50] 
[21:06:50] 2021-11-23 21:06:57.232 [job-0] INFO  JobContainer - PerfTrace not enable!
[21:06:50] 2021-11-23 21:06:57.233 [job-0] INFO  StandAloneJobContainerCommunicator - Total 767830000 records, 18367983662 bytes | Speed 850.08KB/s, 36388 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 18,518.020s |  All Task WaitReaderTime 1,979.127s | Percentage 100.00%
[21:06:50] 2021-11-23 21:06:57.234 [job-0] INFO  JobContainer - 
[21:06:50] 任务启动时刻                    : 2021-11-23 15:15:15
[21:06:50] 任务结束时刻                    : 2021-11-23 21:06:57
[21:06:50] 任务总计耗时                    :              21101s
[21:06:50] 任务平均流量                    :          850.08KB/s
[21:06:50] 记录写入速度                    :          36388rec/s
[21:06:50] 读出记录总数                    :           767830000
[21:06:50] 读写失败总数                    :                   0
[21:06:50] 
[21:06:50] [root@10-31-1-119 bin]# 

参考:

  1. https://github.com/alibaba/DataX/blob/master/mysqlwriter/doc/mysqlwriter.md
上一篇下一篇

猜你喜欢

热点阅读