一. 快速介绍
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 类型转换列表:
四. 测试案例
现在我们来测试一个从csv读取,然后再写入csv的案例.
4.1 数据准备
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]#
网友评论