Open luyee opened 7 years ago
时间类型取值咋回取到是0值?
数据库啥原始记录?
看起来少了一列,revoke_date字段的值是loan_period字段的12
EventColumn[index=27,columnType=12,columnName=revoke_remark,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=28,columnType=4,columnName=revoke_way,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=29,columnType=12,columnName=operator,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=30,columnType=93,columnName=revoke_date,columnValue=12,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=31,columnType=4,columnName=loan_period,columnValue=03,isNull=false,isKey=false,isUpdate=true]
表结构
MySQL [agreement]> desc agreement;
+------------------------+---------------------+------+-----+-------------------+-----------------------------+
| Field | Type | Null | Key | Default | Extra |
+------------------------+---------------------+------+-----+-------------------+-----------------------------+
| id | bigint(20) unsigned | NO | PRI | NULL | auto_increment |
| agreement_no | varchar(45) | NO | UNI | NULL | |
| system_source_id | int(11) | YES | | NULL | |
| agreement_type | int(11) | YES | | 0 | |
| apply_serial_no | varchar(45) | NO | UNI | NULL | |
| product_spu_id | varchar(45) | YES | | NULL | |
| product_spu_name | varchar(45) | YES | | NULL | |
| product_sku_id | varchar(45) | YES | | NULL | |
| product_sku_name | varchar(45) | YES | | NULL | |
| debtor_user_id | bigint(20) | YES | MUL | NULL | |
| natural_person_id | bigint(20) | YES | MUL | NULL | |
| channel | int(11) | YES | | NULL | |
| debtor_realname | varchar(45) | YES | | NULL | |
| debtor_credential_type | varchar(45) | YES | | NULL | |
| debtor_credential_no | varchar(45) | YES | MUL | NULL | |
| debtor_mobile | varchar(20) | YES | | NULL | |
| apply_amount | decimal(16,2) | YES | | NULL | |
| loan_amount | decimal(16,2) | YES | | NULL | |
| wholesale_amount | decimal(16,2) | YES | | NULL | |
| lending_amount | decimal(16,2) | YES | | NULL | |
| handling_fee | decimal(16,2) | YES | | NULL | |
| apply_date | timestamp | YES | | NULL | |
| loan_date | timestamp | YES | | NULL | |
| effective_date | timestamp | YES | | NULL | |
| agreement_status | int(11) | YES | | NULL | |
| loan_status | int(11) | YES | | NULL | |
| lending_status | int(11) | YES | | NULL | |
| revoke_remark | varchar(500) | YES | | NULL | |
| revoke_way | int(11) | YES | | NULL | |
| operator | varchar(20) | YES | | | |
| revoke_date | timestamp | YES | | NULL | |
| loan_period | int(11) | YES | | NULL | |
| loan_period_unit | varchar(255) | YES | | NULL | |
| repay_way | int(11) | YES | | NULL | |
| bid_error | varchar(512) | YES | | NULL | |
| settle_error | varchar(512) | YES | | NULL | |
| version | int(11) | YES | | NULL | |
| refreshed | int(11) | YES | | 0 | |
| created_time | timestamp | NO | | CURRENT_TIMESTAMP | |
| modified_time | timestamp | NO | | CURRENT_TIMESTAMP | on update CURRENT_TIMESTAMP |
| market_coupons | varchar(256) | YES | | NULL | |
| market_coupons_res | varchar(256) | YES | | NULL | |
| org_loan_amount | decimal(16,2) | YES | | NULL | |
| org_wholesale_amount | decimal(16,2) | YES | | NULL | |
| org_lending_amount | decimal(16,2) | YES | | NULL | |
| org_handling_fee | decimal(16,2) | YES | | NULL | |
| withhold_permition | int(2) | NO | | 0 | |
| vip_service_exp | int(2) | YES | | 0 | |
| insur_exp | int(2) | YES | | 0 | |
| brk_insur_exp | int(2) | YES | | 0 | |
+------------------------+---------------------+------+-----+-------------------+-----------------------------+
50 rows in set (0.00 sec)
源表数据
MySQL [agreement]> select * from agreement where id=708726\G;
*************************** 1. row ***************************
id: 708726
agreement_no: 17102716405338585639
system_source_id: NULL
agreement_type: 0
apply_serial_no: E6D9401FACB1A3E0
product_spu_id: CCL2017040004
product_spu_name: 交叉现金贷
product_sku_id: CCL2017040004-019
product_sku_name: 交叉现金贷12期
debtor_user_id: 1473413141060
natural_person_id: 3859361140056391680
channel: 301
debtor_realname: 高XX
debtor_credential_type: 0
debtor_credential_no: 41xxxxxxxxxxxxxx18
debtor_mobile: 180xxxx9661
apply_amount: 3000.00
loan_amount: 3787.00
wholesale_amount: 787.00
lending_amount: 3000.00
handling_fee: 0.00
apply_date: 2017-10-27 16:40:53
loan_date: NULL
effective_date: NULL
agreement_status: 1
loan_status: 2
lending_status: 1
revoke_remark: NULL
revoke_way: NULL
operator:
revoke_date: NULL
loan_period: 12
loan_period_unit: 03
repay_way: 0
bid_error: NULL
settle_error: NULL
version: 1
refreshed: NULL
created_time: 2017-10-27 16:40:53
modified_time: 2017-10-27 18:44:41
market_coupons: NULL
market_coupons_res: NULL
org_loan_amount: 3787.00
org_wholesale_amount: 787.00
org_lending_amount: 3000.00
org_handling_fee: 0.00
withhold_permition: 0
vip_service_exp: 0
insur_exp: 0
brk_insur_exp: 0
1 row in set (0.00 sec)
ERROR: No query specified
dump message
---Pks
EventColumn[index=0,columnType=3,columnName=id,columnValue=708726,isNull=false,isKey=true,isUpdate=true]
---oldPks
---Columns
EventColumn[index=1,columnType=12,columnName=agreement_no,columnValue=17102716405338585639,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=2,columnType=4,columnName=system_source_id,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=3,columnType=4,columnName=agreement_type,columnValue=0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=4,columnType=12,columnName=apply_serial_no,columnValue=E6D9401FACB1A3E0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=5,columnType=12,columnName=product_spu_id,columnValue=CCL2017040004,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=6,columnType=12,columnName=product_spu_name,columnValue=交叉现金贷,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=7,columnType=12,columnName=product_sku_id,columnValue=CCL2017040004-019,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=8,columnType=12,columnName=product_sku_name,columnValue=交叉现金贷12期,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=9,columnType=-5,columnName=debtor_user_id,columnValue=1473413141060,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=10,columnType=-5,columnName=natural_person_id,columnValue=3859361140056391680,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=11,columnType=4,columnName=channel,columnValue=301,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=12,columnType=12,columnName=debtor_realname,columnValue=高XX,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=13,columnType=12,columnName=debtor_credential_type,columnValue=0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=14,columnType=12,columnName=debtor_credential_no,columnValue=41xxxxxxxxxxxxxx18,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=15,columnType=12,columnName=debtor_mobile,columnValue=180xxxx9661,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=16,columnType=3,columnName=apply_amount,columnValue=3000.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=17,columnType=3,columnName=loan_amount,columnValue=3787.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=18,columnType=3,columnName=wholesale_amount,columnValue=787.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=19,columnType=3,columnName=lending_amount,columnValue=3000.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=20,columnType=3,columnName=handling_fee,columnValue=0.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=21,columnType=93,columnName=apply_date,columnValue=2017-10-27 16:40:53,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=22,columnType=93,columnName=loan_date,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=23,columnType=93,columnName=effective_date,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=24,columnType=4,columnName=agreement_status,columnValue=1,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=25,columnType=4,columnName=loan_status,columnValue=2,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=26,columnType=4,columnName=lending_status,columnValue=1,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=27,columnType=12,columnName=revoke_remark,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=28,columnType=4,columnName=revoke_way,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=29,columnType=12,columnName=operator,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=30,columnType=93,columnName=revoke_date,columnValue=12,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=31,columnType=4,columnName=loan_period,columnValue=03,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=32,columnType=12,columnName=loan_period_unit,columnValue=0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=33,columnType=4,columnName=repay_way,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=34,columnType=12,columnName=bid_error,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=35,columnType=12,columnName=settle_error,columnValue=1,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=36,columnType=4,columnName=version,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=37,columnType=4,columnName=refreshed,columnValue=2017-10-27 16:40:53,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=38,columnType=93,columnName=created_time,columnValue=2017-10-27 16:42:50,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=39,columnType=93,columnName=modified_time,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=40,columnType=12,columnName=market_coupons,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=41,columnType=12,columnName=market_coupons_res,columnValue=3787.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=42,columnType=3,columnName=org_loan_amount,columnValue=787.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=43,columnType=3,columnName=org_wholesale_amount,columnValue=3000.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=44,columnType=3,columnName=org_lending_amount,columnValue=0.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=45,columnType=3,columnName=org_handling_fee,columnValue=0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=46,columnType=4,columnName=withhold_permition,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=47,columnType=4,columnName=vip_service_exp,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=48,columnType=4,columnName=insur_exp,columnValue=<null>,isNull=true,isKey=false,isUpdate=true]
---Sql
insert into datawall.agreement(`agreement_no` , `system_source_id` , `agreement_type` , `apply_serial_no` , `product_spu_id` , `product_spu_name` , `product_sku_id` , `product_sku_name` , `debtor_user_id` , `natural_person_id` , `channel` , `debtor_realname` , `debtor_credential_type` , `debtor_credential_no` , `debtor_mobile` , `apply_amount` , `loan_amount` , `wholesale_amount` , `lending_amount` , `handling_fee` , `apply_date` , `loan_date` , `effective_date` , `agreement_status` , `loan_status` , `lending_status` , `revoke_remark` , `revoke_way` , `operator` , `revoke_date` , `loan_period` , `loan_period_unit` , `repay_way` , `bid_error` , `settle_error` , `version` , `refreshed` , `created_time` , `modified_time` , `market_coupons` , `market_coupons_res` , `org_loan_amount` , `org_wholesale_amount` , `org_lending_amount` , `org_handling_fee` , `withhold_permition` , `vip_service_exp` , `insur_exp` , `id`) values (? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ?) on duplicate key update `agreement_no`=values(`agreement_no`) , `system_source_id`=values(`system_source_id`) , `agreement_type`=values(`agreement_type`) , `apply_serial_no`=values(`apply_serial_no`) , `product_spu_id`=values(`product_spu_id`) , `product_spu_name`=values(`product_spu_name`) , `product_sku_id`=values(`product_sku_id`) , `product_sku_name`=values(`product_sku_name`) , `debtor_user_id`=values(`debtor_user_id`) , `natural_person_id`=values(`natural_person_id`) , `channel`=values(`channel`) , `debtor_realname`=values(`debtor_realname`) , `debtor_credential_type`=values(`debtor_credential_type`) , `debtor_credential_no`=values(`debtor_credential_no`) , `debtor_mobile`=values(`debtor_mobile`) , `apply_amount`=values(`apply_amount`) , `loan_amount`=values(`loan_amount`) , `wholesale_amount`=values(`wholesale_amount`) , `lending_amount`=values(`lending_amount`) , `handling_fee`=values(`handling_fee`) , `apply_date`=values(`apply_date`) , `loan_date`=values(`loan_date`) , `effective_date`=values(`effective_date`) , `agreement_status`=values(`agreement_status`) , `loan_status`=values(`loan_status`) , `lending_status`=values(`lending_status`) , `revoke_remark`=values(`revoke_remark`) , `revoke_way`=values(`revoke_way`) , `operator`=values(`operator`) , `revoke_date`=values(`revoke_date`) , `loan_period`=values(`loan_period`) , `loan_period_unit`=values(`loan_period_unit`) , `repay_way`=values(`repay_way`) , `bid_error`=values(`bid_error`) , `settle_error`=values(`settle_error`) , `version`=values(`version`) , `refreshed`=values(`refreshed`) , `created_time`=values(`created_time`) , `modified_time`=values(`modified_time`) , `market_coupons`=values(`market_coupons`) , `market_coupons_res`=values(`market_coupons_res`) , `org_loan_amount`=values(`org_loan_amount`) , `org_wholesale_amount`=values(`org_wholesale_amount`) , `org_lending_amount`=values(`org_lending_amount`) , `org_handling_fee`=values(`org_handling_fee`) , `withhold_permition`=values(`withhold_permition`) , `vip_service_exp`=values(`vip_service_exp`) , `insur_exp`=values(`insur_exp`) , `id`=values(`id`)
你给的数据和notice_date列没关系啊
同类问题吧, 目标库手动新增字段。settlement_bill_type与withhold_type这两个字段拿到的值往后移了两个字段,也就是settlement_bill_type拿的是asset_product的字段304,withhold_type拿的是asset字段的值201
select * from settlement_bill where id=149647\G;
*************************** 1. row ***************************
id: 149647
bill_no: 18010416063068028152
agreement_no: 18010416045863970663
settlement_bill_type: 0
withhold_type: 0
asset_product: 304
asset: 201
lending_amount: 1568.00
payee_bank_card_no: 102
payee_bank_card_name: 中国工商银行
settlement_bill_status: 1
created_time: 2018-01-04 16:06:30
modified_time: 2018-01-04 16:06:39
finish_time: 2018-01-04 16:06:39
remark:
1 row in set (0.00 sec)
pid:32 nid:1 exception:setl:com.alibaba.otter.node.etl.load.exception.LoadException: java.util.concurrent.ExecutionException: com.alibaba.otter.node.etl.load.exception.LoadException: com.alibaba.otter.node.etl.load.exception.LoadException: com.alibaba.otter.node.etl.load.exception.LoadException: org.apache.commons.beanutils.ConversionException: Error converting from 'String' to 'BigDecimal' null
at org.apache.commons.beanutils.converters.AbstractConverter.handleError(AbstractConverter.java:267)
at org.apache.commons.beanutils.converters.AbstractConverter.convert(AbstractConverter.java:164)
at org.apache.commons.beanutils.converters.ConverterFacade.convert(ConverterFacade.java:60)
at org.apache.commons.beanutils.ConvertUtilsBean.convert(ConvertUtilsBean.java:470)
at com.alibaba.otter.node.etl.common.db.utils.SqlUtils.stringToSqlValue(SqlUtils.java:149)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.doPreparedStatement(DbLoadAction.java:754)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.access$800(DbLoadAction.java:513)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker$2$1.setValues(DbLoadAction.java:624)
at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:816)
at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:1)
at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:587)
at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:812)
at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:868)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker$2.doInTransaction(DbLoadAction.java:621)
at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:130)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.doCall(DbLoadAction.java:613)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.call(DbLoadAction.java:541)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.doTwoPhase(DbLoadAction.java:458)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.doLoad(DbLoadAction.java:275)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.load(DbLoadAction.java:161)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$$FastClassByCGLIB$$d932a4cb.invoke()
at net.sf.cglib.proxy.MethodProxy.invoke(MethodProxy.java:191)
at org.springframework.aop.framework.Cglib2AopProxy$DynamicAdvisedInterceptor.intercept(Cglib2AopProxy.java:618)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$$EnhancerByCGLIB$$80fd23c2.load()
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader$2.call(DataBatchLoader.java:198)
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader$2.call(DataBatchLoader.java:189)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.NumberFormatException
at java.math.BigDecimal.(BigDecimal.java:494)
at java.math.BigDecimal.(BigDecimal.java:383)
at java.math.BigDecimal.(BigDecimal.java:806)
at org.apache.commons.beanutils.converters.NumberConverter.toNumber(NumberConverter.java:448)
at org.apache.commons.beanutils.converters.NumberConverter.convertToType(NumberConverter.java:268)
at org.apache.commons.beanutils.converters.AbstractConverter.convert(AbstractConverter.java:156)
... 30 more
:-----------------
- PairId: 33 , TableId: 62 , EventType : I , Time : 1515053190000
- Consistency : , Mode :
-----------------
---Pks
EventColumn[index=0,columnType=3,columnName=id,columnValue=149647,isNull=false,isKey=true,isUpdate=true]
---oldPks
---Columns
EventColumn[index=1,columnType=12,columnName=bill_no,columnValue=18010416063068028152,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=2,columnType=12,columnName=agreement_no,columnValue=18010416045863970663,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=3,columnType=4,columnName=settlement_bill_type,columnValue=304,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=4,columnType=4,columnName=withhold_type,columnValue=201,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=5,columnType=12,columnName=asset_product,columnValue=1568.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=6,columnType=12,columnName=asset,columnValue=102,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=7,columnType=3,columnName=lending_amount,columnValue=中国工商银行,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=8,columnType=12,columnName=payee_bank_card_no,columnValue=0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=9,columnType=12,columnName=payee_bank_card_name,columnValue=2018-01-04 16:06:30,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=10,columnType=4,columnName=settlement_bill_status,columnValue=2018-01-04 16:06:30,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=11,columnType=93,columnName=created_time,columnValue=,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=12,columnType=93,columnName=modified_time,columnValue=,isNull=false,isKey=false,isUpdate=true]
---Sql
insert into agreement.settlement_bill(`bill_no` , `agreement_no` , `settlement_bill_type` , `withhold_type` , `asset_product` , `asset` , `lending_amount` , `payee_bank_card_no` , `payee_bank_card_name` , `settlement_bill_status` , `created_time` , `modified_time` , `id`) values (? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ?) on duplicate key update `bill_no`=values(`bill_no`) , `agreement_no`=values(`agreement_no`) , `settlement_bill_type`=values(`settlement_bill_type`) , `withhold_type`=values(`withhold_type`) , `asset_product`=values(`asset_product`) , `asset`=values(`asset`) , `lending_amount`=values(`lending_amount`) , `payee_bank_card_no`=values(`payee_bank_card_no`) , `payee_bank_card_name`=values(`payee_bank_card_name`) , `settlement_bill_status`=values(`settlement_bill_status`) , `created_time`=values(`created_time`) , `modified_time`=values(`modified_time`) , `id`=values(`id`)
Caused by: java.util.concurrent.ExecutionException: com.alibaba.otter.node.etl.load.exception.LoadException: com.alibaba.otter.node.etl.load.exception.LoadException: com.alibaba.otter.node.etl.load.exception.LoadException: org.apache.commons.beanutils.ConversionException: Error converting from 'String' to 'BigDecimal' null
at org.apache.commons.beanutils.converters.AbstractConverter.handleError(AbstractConverter.java:267)
at org.apache.commons.beanutils.converters.AbstractConverter.convert(AbstractConverter.java:164)
at org.apache.commons.beanutils.converters.ConverterFacade.convert(ConverterFacade.java:60)
at org.apache.commons.beanutils.ConvertUtilsBean.convert(ConvertUtilsBean.java:470)
at com.alibaba.otter.node.etl.common.db.utils.SqlUtils.stringToSqlValue(SqlUtils.java:149)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.doPreparedStatement(DbLoadAction.java:754)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.access$800(DbLoadAction.java:513)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker$2$1.setValues(DbLoadAction.java:624)
at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:816)
at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:1)
at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:587)
at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:812)
at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:868)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker$2.doInTransaction(DbLoadAction.java:621)
at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:130)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.doCall(DbLoadAction.java:613)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.call(DbLoadAction.java:541)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.doTwoPhase(DbLoadAction.java:458)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.doLoad(DbLoadAction.java:275)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.load(DbLoadAction.java:161)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$$FastClassByCGLIB$$d932a4cb.invoke()
at net.sf.cglib.proxy.MethodProxy.invoke(MethodProxy.java:191)
at org.springframework.aop.framework.Cglib2AopProxy$DynamicAdvisedInterceptor.intercept(Cglib2AopProxy.java:618)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$$EnhancerByCGLIB$$80fd23c2.load()
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader$2.call(DataBatchLoader.java:198)
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader$2.call(DataBatchLoader.java:189)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.NumberFormatException
at java.math.BigDecimal.(BigDecimal.java:494)
at java.math.BigDecimal.(BigDecimal.java:383)
at java.math.BigDecimal.(BigDecimal.java:806)
at org.apache.commons.beanutils.converters.NumberConverter.toNumber(NumberConverter.java:448)
at org.apache.commons.beanutils.converters.NumberConverter.convertToType(NumberConverter.java:268)
at org.apache.commons.beanutils.converters.AbstractConverter.convert(AbstractConverter.java:156)
... 30 more
:-----------------
- PairId: 33 , TableId: 62 , EventType : I , Time : 1515053190000
- Consistency : , Mode :
-----------------
---Pks
EventColumn[index=0,columnType=3,columnName=id,columnValue=149647,isNull=false,isKey=true,isUpdate=true]
---oldPks
---Columns
EventColumn[index=1,columnType=12,columnName=bill_no,columnValue=18010416063068028152,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=2,columnType=12,columnName=agreement_no,columnValue=18010416045863970663,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=3,columnType=4,columnName=settlement_bill_type,columnValue=304,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=4,columnType=4,columnName=withhold_type,columnValue=201,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=5,columnType=12,columnName=asset_product,columnValue=1568.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=6,columnType=12,columnName=asset,columnValue=102,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=7,columnType=3,columnName=lending_amount,columnValue=中国工商银行,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=8,columnType=12,columnName=payee_bank_card_no,columnValue=0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=9,columnType=12,columnName=payee_bank_card_name,columnValue=2018-01-04 16:06:30,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=10,columnType=4,columnName=settlement_bill_status,columnValue=2018-01-04 16:06:30,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=11,columnType=93,columnName=created_time,columnValue=,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=12,columnType=93,columnName=modified_time,columnValue=,isNull=false,isKey=false,isUpdate=true]
---Sql
insert into agreement.settlement_bill(`bill_no` , `agreement_no` , `settlement_bill_type` , `withhold_type` , `asset_product` , `asset` , `lending_amount` , `payee_bank_card_no` , `payee_bank_card_name` , `settlement_bill_status` , `created_time` , `modified_time` , `id`) values (? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ?) on duplicate key update `bill_no`=values(`bill_no`) , `agreement_no`=values(`agreement_no`) , `settlement_bill_type`=values(`settlement_bill_type`) , `withhold_type`=values(`withhold_type`) , `asset_product`=values(`asset_product`) , `asset`=values(`asset`) , `lending_amount`=values(`lending_amount`) , `payee_bank_card_no`=values(`payee_bank_card_no`) , `payee_bank_card_name`=values(`payee_bank_card_name`) , `settlement_bill_status`=values(`settlement_bill_status`) , `created_time`=values(`created_time`) , `modified_time`=values(`modified_time`) , `id`=values(`id`)
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader.load(DataBatchLoader.java:107)
at com.alibaba.otter.node.etl.load.loader.OtterLoaderFactory.load(OtterLoaderFactory.java:50)
at com.alibaba.otter.node.etl.load.LoadTask$1.run(LoadTask.java:85)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: com.alibaba.otter.node.etl.load.exception.LoadException: com.alibaba.otter.node.etl.load.exception.LoadException: com.alibaba.otter.node.etl.load.exception.LoadException: org.apache.commons.beanutils.ConversionException: Error converting from 'String' to 'BigDecimal' null
at org.apache.commons.beanutils.converters.AbstractConverter.handleError(AbstractConverter.java:267)
at org.apache.commons.beanutils.converters.AbstractConverter.convert(AbstractConverter.java:164)
at org.apache.commons.beanutils.converters.ConverterFacade.convert(ConverterFacade.java:60)
at org.apache.commons.beanutils.ConvertUtilsBean.convert(ConvertUtilsBean.java:470)
at com.alibaba.otter.node.etl.common.db.utils.SqlUtils.stringToSqlValue(SqlUtils.java:149)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.doPreparedStatement(DbLoadAction.java:754)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.access$800(DbLoadAction.java:513)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker$2$1.setValues(DbLoadAction.java:624)
at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:816)
at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:1)
at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:587)
at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:812)
at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:868)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker$2.doInTransaction(DbLoadAction.java:621)
at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:130)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.doCall(DbLoadAction.java:613)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.call(DbLoadAction.java:541)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.doTwoPhase(DbLoadAction.java:458)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.doLoad(DbLoadAction.java:275)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.load(DbLoadAction.java:161)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$$FastClassByCGLIB$$d932a4cb.invoke()
at net.sf.cglib.proxy.MethodProxy.invoke(MethodProxy.java:191)
at org.springframework.aop.framework.Cglib2AopProxy$DynamicAdvisedInterceptor.intercept(Cglib2AopProxy.java:618)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$$EnhancerByCGLIB$$80fd23c2.load()
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader$2.call(DataBatchLoader.java:198)
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader$2.call(DataBatchLoader.java:189)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.NumberFormatException
at java.math.BigDecimal.(BigDecimal.java:494)
at java.math.BigDecimal.(BigDecimal.java:383)
at java.math.BigDecimal.(BigDecimal.java:806)
at org.apache.commons.beanutils.converters.NumberConverter.toNumber(NumberConverter.java:448)
at org.apache.commons.beanutils.converters.NumberConverter.convertToType(NumberConverter.java:268)
at org.apache.commons.beanutils.converters.AbstractConverter.convert(AbstractConverter.java:156)
... 30 more
:-----------------
- PairId: 33 , TableId: 62 , EventType : I , Time : 1515053190000
- Consistency : , Mode :
-----------------
---Pks
EventColumn[index=0,columnType=3,columnName=id,columnValue=149647,isNull=false,isKey=true,isUpdate=true]
---oldPks
---Columns
EventColumn[index=1,columnType=12,columnName=bill_no,columnValue=18010416063068028152,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=2,columnType=12,columnName=agreement_no,columnValue=18010416045863970663,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=3,columnType=4,columnName=settlement_bill_type,columnValue=304,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=4,columnType=4,columnName=withhold_type,columnValue=201,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=5,columnType=12,columnName=asset_product,columnValue=1568.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=6,columnType=12,columnName=asset,columnValue=102,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=7,columnType=3,columnName=lending_amount,columnValue=中国工商银行,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=8,columnType=12,columnName=payee_bank_card_no,columnValue=0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=9,columnType=12,columnName=payee_bank_card_name,columnValue=2018-01-04 16:06:30,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=10,columnType=4,columnName=settlement_bill_status,columnValue=2018-01-04 16:06:30,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=11,columnType=93,columnName=created_time,columnValue=,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=12,columnType=93,columnName=modified_time,columnValue=,isNull=false,isKey=false,isUpdate=true]
---Sql
insert into agreement.settlement_bill(`bill_no` , `agreement_no` , `settlement_bill_type` , `withhold_type` , `asset_product` , `asset` , `lending_amount` , `payee_bank_card_no` , `payee_bank_card_name` , `settlement_bill_status` , `created_time` , `modified_time` , `id`) values (? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ?) on duplicate key update `bill_no`=values(`bill_no`) , `agreement_no`=values(`agreement_no`) , `settlement_bill_type`=values(`settlement_bill_type`) , `withhold_type`=values(`withhold_type`) , `asset_product`=values(`asset_product`) , `asset`=values(`asset`) , `lending_amount`=values(`lending_amount`) , `payee_bank_card_no`=values(`payee_bank_card_no`) , `payee_bank_card_name`=values(`payee_bank_card_name`) , `settlement_bill_status`=values(`settlement_bill_status`) , `created_time`=values(`created_time`) , `modified_time`=values(`modified_time`) , `id`=values(`id`)
Caused by: com.alibaba.otter.node.etl.load.exception.LoadException: com.alibaba.otter.node.etl.load.exception.LoadException: org.apache.commons.beanutils.ConversionException: Error converting from 'String' to 'BigDecimal' null
at org.apache.commons.beanutils.converters.AbstractConverter.handleError(AbstractConverter.java:267)
at org.apache.commons.beanutils.converters.AbstractConverter.convert(AbstractConverter.java:164)
at org.apache.commons.beanutils.converters.ConverterFacade.convert(ConverterFacade.java:60)
at org.apache.commons.beanutils.ConvertUtilsBean.convert(ConvertUtilsBean.java:470)
at com.alibaba.otter.node.etl.common.db.utils.SqlUtils.stringToSqlValue(SqlUtils.java:149)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.doPreparedStatement(DbLoadAction.java:754)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.access$800(DbLoadAction.java:513)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker$2$1.setValues(DbLoadAction.java:624)
at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:816)
at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:1)
at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:587)
at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:812)
at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:868)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker$2.doInTransaction(DbLoadAction.java:621)
at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:130)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.doCall(DbLoadAction.java:613)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.call(DbLoadAction.java:541)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.doTwoPhase(DbLoadAction.java:458)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.doLoad(DbLoadAction.java:275)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.load(DbLoadAction.java:161)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$$FastClassByCGLIB$$d932a4cb.invoke()
at net.sf.cglib.proxy.MethodProxy.invoke(MethodProxy.java:191)
at org.springframework.aop.framework.Cglib2AopProxy$DynamicAdvisedInterceptor.intercept(Cglib2AopProxy.java:618)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$$EnhancerByCGLIB$$80fd23c2.load()
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader$2.call(DataBatchLoader.java:198)
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader$2.call(DataBatchLoader.java:189)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.NumberFormatException
at java.math.BigDecimal.(BigDecimal.java:494)
at java.math.BigDecimal.(BigDecimal.java:383)
at java.math.BigDecimal.(BigDecimal.java:806)
at org.apache.commons.beanutils.converters.NumberConverter.toNumber(NumberConverter.java:448)
at org.apache.commons.beanutils.converters.NumberConverter.convertToType(NumberConverter.java:268)
at org.apache.commons.beanutils.converters.AbstractConverter.convert(AbstractConverter.java:156)
... 30 more
:-----------------
- PairId: 33 , TableId: 62 , EventType : I , Time : 1515053190000
- Consistency : , Mode :
-----------------
---Pks
EventColumn[index=0,columnType=3,columnName=id,columnValue=149647,isNull=false,isKey=true,isUpdate=true]
---oldPks
---Columns
EventColumn[index=1,columnType=12,columnName=bill_no,columnValue=18010416063068028152,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=2,columnType=12,columnName=agreement_no,columnValue=18010416045863970663,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=3,columnType=4,columnName=settlement_bill_type,columnValue=304,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=4,columnType=4,columnName=withhold_type,columnValue=201,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=5,columnType=12,columnName=asset_product,columnValue=1568.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=6,columnType=12,columnName=asset,columnValue=102,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=7,columnType=3,columnName=lending_amount,columnValue=中国工商银行,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=8,columnType=12,columnName=payee_bank_card_no,columnValue=0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=9,columnType=12,columnName=payee_bank_card_name,columnValue=2018-01-04 16:06:30,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=10,columnType=4,columnName=settlement_bill_status,columnValue=2018-01-04 16:06:30,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=11,columnType=93,columnName=created_time,columnValue=,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=12,columnType=93,columnName=modified_time,columnValue=,isNull=false,isKey=false,isUpdate=true]
---Sql
insert into agreement.settlement_bill(`bill_no` , `agreement_no` , `settlement_bill_type` , `withhold_type` , `asset_product` , `asset` , `lending_amount` , `payee_bank_card_no` , `payee_bank_card_name` , `settlement_bill_status` , `created_time` , `modified_time` , `id`) values (? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ?) on duplicate key update `bill_no`=values(`bill_no`) , `agreement_no`=values(`agreement_no`) , `settlement_bill_type`=values(`settlement_bill_type`) , `withhold_type`=values(`withhold_type`) , `asset_product`=values(`asset_product`) , `asset`=values(`asset`) , `lending_amount`=values(`lending_amount`) , `payee_bank_card_no`=values(`payee_bank_card_no`) , `payee_bank_card_name`=values(`payee_bank_card_name`) , `settlement_bill_status`=values(`settlement_bill_status`) , `created_time`=values(`created_time`) , `modified_time`=values(`modified_time`) , `id`=values(`id`)
Caused by: com.alibaba.otter.node.etl.load.exception.LoadException: org.apache.commons.beanutils.ConversionException: Error converting from 'String' to 'BigDecimal' null
at org.apache.commons.beanutils.converters.AbstractConverter.handleError(AbstractConverter.java:267)
at org.apache.commons.beanutils.converters.AbstractConverter.convert(AbstractConverter.java:164)
at org.apache.commons.beanutils.converters.ConverterFacade.convert(ConverterFacade.java:60)
at org.apache.commons.beanutils.ConvertUtilsBean.convert(ConvertUtilsBean.java:470)
at com.alibaba.otter.node.etl.common.db.utils.SqlUtils.stringToSqlValue(SqlUtils.java:149)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.doPreparedStatement(DbLoadAction.java:754)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.access$800(DbLoadAction.java:513)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker$2$1.setValues(DbLoadAction.java:624)
at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:816)
at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:1)
at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:587)
at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:812)
at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:868)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker$2.doInTransaction(DbLoadAction.java:621)
at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:130)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.doCall(DbLoadAction.java:613)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$DbLoadWorker.call(DbLoadAction.java:541)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.doTwoPhase(DbLoadAction.java:458)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.doLoad(DbLoadAction.java:275)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction.load(DbLoadAction.java:161)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$$FastClassByCGLIB$$d932a4cb.invoke()
at net.sf.cglib.proxy.MethodProxy.invoke(MethodProxy.java:191)
at org.springframework.aop.framework.Cglib2AopProxy$DynamicAdvisedInterceptor.intercept(Cglib2AopProxy.java:618)
at com.alibaba.otter.node.etl.load.loader.db.DbLoadAction$$EnhancerByCGLIB$$80fd23c2.load()
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader$2.call(DataBatchLoader.java:198)
at com.alibaba.otter.node.etl.load.loader.db.DataBatchLoader$2.call(DataBatchLoader.java:189)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.NumberFormatException
at java.math.BigDecimal.(BigDecimal.java:494)
at java.math.BigDecimal.(BigDecimal.java:383)
at java.math.BigDecimal.(BigDecimal.java:806)
at org.apache.commons.beanutils.converters.NumberConverter.toNumber(NumberConverter.java:448)
at org.apache.commons.beanutils.converters.NumberConverter.convertToType(NumberConverter.java:268)
at org.apache.commons.beanutils.converters.AbstractConverter.convert(AbstractConverter.java:156)
... 30 more
:-----------------
- PairId: 33 , TableId: 62 , EventType : I , Time : 1515053190000
- Consistency : , Mode :
-----------------
---Pks
EventColumn[index=0,columnType=3,columnName=id,columnValue=149647,isNull=false,isKey=true,isUpdate=true]
---oldPks
---Columns
EventColumn[index=1,columnType=12,columnName=bill_no,columnValue=18010416063068028152,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=2,columnType=12,columnName=agreement_no,columnValue=18010416045863970663,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=3,columnType=4,columnName=settlement_bill_type,columnValue=304,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=4,columnType=4,columnName=withhold_type,columnValue=201,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=5,columnType=12,columnName=asset_product,columnValue=1568.0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=6,columnType=12,columnName=asset,columnValue=102,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=7,columnType=3,columnName=lending_amount,columnValue=中国工商银行,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=8,columnType=12,columnName=payee_bank_card_no,columnValue=0,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=9,columnType=12,columnName=payee_bank_card_name,columnValue=2018-01-04 16:06:30,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=10,columnType=4,columnName=settlement_bill_status,columnValue=2018-01-04 16:06:30,isNull=false,isKey=false,isUpdate=true]
EventColumn[index=11,columnType=93,columnName=created_time,columnValue=,isNull=true,isKey=false,isUpdate=true]
EventColumn[index=12,columnType=93,columnName=modified_time,columnValue=,isNull=false,isKey=false,isUpdate=true]
---Sql
insert into agreement.settlement_bill(`bill_no` , `agreement_no` , `settlement_bill_type` , `withhold_type` , `asset_product` , `asset` , `lending_amount` , `payee_bank_card_no` , `payee_bank_card_name` , `settlement_bill_status` , `created_time` , `modified_time` , `id`) values (? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ?) on duplicate key update `bill_no`=values(`bill_no`) , `agreement_no`=values(`agreement_no`) , `settlement_bill_type`=values(`settlement_bill_type`) , `withhold_type`=values(`withhold_type`) , `asset_product`=values(`asset_product`) , `asset`=values(`asset`) , `lending_amount`=values(`lending_amount`) , `payee_bank_card_no`=values(`payee_bank_card_no`) , `payee_bank_card_name`=values(`payee_bank_card_name`) , `settlement_bill_status`=values(`settlement_bill_status`) , `created_time`=values(`created_time`) , `modified_time`=values(`modified_time`) , `id`=values(`id`)
临时方案: 通过EventProcessor过滤这几个有问题的表不同步。过一段时间之后重做这几个有问题的表就好了 ~
insert 语句挂起 otter 4.2.13 源 mysql5.7 目标 mysql5.6 Data truncation: Incorrect datetime value: '0' for column 'notice_date' at row 1; nested exception is com.mysql.jdbc.MysqlDataTruncation: Data truncation: Incorrect datetime value: '0' for column 'notice_date' at row 1
源表+目标表,都是timestamp desc
| notice_date | timestamp | YES | | NULL | |
EventColumn[index=23,columnType=93,columnName=notice_date,columnValue=0,isNull=false,isKey=false,isUpdate=true]