美文网首页
DataX系列6- MysqlWriter介绍

DataX系列6- MysqlWriter介绍

作者: 只是甲 | 来源:发表于2021-12-16 15:59 被阅读0次

    一. 快速介绍

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

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

    二. 实现原理

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

    • insert into...(当主键/唯一性索引冲突时会写不进去冲突的行)
    或者
    • replace into...(没有遇到主键/唯一性索引冲突时,与 insert into 行为一致,冲突时会用新行替换原有行所有字段) 的语句写入数据到 Mysql。出于性能考虑,采用了 PreparedStatement + Batch,并且设置了:rewriteBatchedStatements=true,将数据缓冲到线程上下文 Buffer 中,当 Buffer 累计到预定阈值时,才发起写入请求。

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

    三. 功能说明

    3.1 配置样例

    • 这里使用一份从内存产生到 Mysql 导入的数据。
    {
        "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

    • 描述:目的数据库的 JDBC 连接信息。作业运行时,DataX 会在你提供的 jdbcUrl 后面追加如下属性:yearIsDateType=false&zeroDateTimeBehavior=convertToNull&rewriteBatchedStatements=true
      注意:
      1、在一个数据库上只能配置一个 jdbcUrl 值。这与 MysqlReader 支持多个备库探测不同,因为此处不支持同一个数据库存在多个主库的情况(双主导入数据情况)
      2、jdbcUrl按照Mysql官方规范,并可以填写连接附加控制信息,比如想指定连接编码为 gbk ,则在 jdbcUrl 后面追加属性 useUnicode=true&characterEncoding=gbk。具体请参看 Mysql官方文档或者咨询对应 DBA。

    • 必选:是

    • 默认值:无

    3.2.2 username

    • 描述:目的数据库的用户名

    • 必选:是

    • 默认值:无

    3.2.3 password

    • 描述:目的数据库的密码

    • 必选:是

    • 默认值:无

    3.2.4 table

    • 描述:目的表的表名称。支持写入一个或者多个表。当配置为多张表时,必须确保所有表结构保持一致。

      注意:table 和 jdbcUrl 必须包含在 connection 配置单元中

    • 必选:是

    • 默认值:无

    3.2.5 column

    • 描述:目的表需要写入数据的字段,字段之间用英文逗号分隔。例如: "column": ["id","name","age"]。如果要依次写入全部列,使用*表示, 例如: "column": ["*"]。

      column配置项必须指定,不能留空!

      注意:
      1、我们强烈不推荐你这样配置,因为当你目的表字段个数、类型等有改动时,你的任务可能运行不正确或者失败
      2、 column 不能配置任何常量值

    • 必选:是

    • 默认值:否

    3.2.6 session

    • 描述: DataX在获取Mysql连接时,执行session指定的SQL语句,修改当前connection session属性

    • 必须: 否

    • 默认值: 空

    3.2.7 preSql

    • 描述:写入数据到目的表前,会先执行这里的标准语句。如果 Sql 中有你需要操作到的表名称,请使用 @table 表示,这样在实际执行 Sql 语句时,会对变量按照实际表名称进行替换。比如你的任务是要写入到目的端的100个同构分表(表名称为:datax_00,datax01, ... datax_98,datax_99),并且你希望导入数据前,先对表中数据进行删除操作,那么你可以这样配置:"preSql":["delete from 表名"],效果是:在执行到每个表写入数据前,会先执行对应的 delete from 对应表名称

    • 必选:否

    • 默认值:无

    3.2.8 postSql

    • 描述:写入数据到目的表后,会执行这里的标准语句。(原理同 preSql )

    • 必选:否

    • 默认值:无

    3.2.9 writeMode

    • 描述:控制写入数据到目标表采用 insert into 或者 replace into 或者 ON DUPLICATE KEY UPDATE 语句

    • 必选:是
      所有选项:insert/replace/update

    • 默认值:insert

    3.2.10 batchSize

    • 描述:一次性批量提交的记录数大小,该值可以极大减少DataX与Mysql的网络交互次数,并提升整体吞吐量。但是该值设置过大可能会造成DataX运行进程OOM情况。

    • 必选:否

    • 默认值:1024

    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

    相关文章

      网友评论

          本文标题:DataX系列6- MysqlWriter介绍

          本文链接:https://www.haomeiwen.com/subject/otbbtrtx.html