wyl/canal
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
1,207 Commits 10 Branches 29 Tags
331dd63c5ff4b711792b0c50a7ec9bd47346f70e
Commit Graph
1207 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
mcy 331dd63c5f Message转Dml对null值的判断 2019-05-14 17:31:51 +08:00
JKTerrific 72c4daba5f 1：添加对于查询结果中，MAX( CASE a.key WHEN 'WORD1' THEN a.value ELSE 0 END ) AS… (#1794) 
* 1：添加对于查询结果中，MAX( CASE a.key WHEN 'WORD1' THEN a.value ELSE 0 END ) AS WORD1 的竖表转横表的支持
2：添加对于查询条件尾部，使用GROUP BY _id 等分组语句时出现的sql解析异常问题

* fix index out of range
 2019-05-11 17:33:59 +08:00
Jet 7427a74612 improve es etl (#1758) 
* fix typo in trace log

* improve es etl

* improve es etl log

* improve es etl by add threadCount

* improve es etl by add threadCount

* improve es etl query

* remove comment
 2019-05-11 17:26:08 +08:00
paascloud 24fae6fa52 变量定义错误 (#1776) 
* 变量定义错误

* 变量定义错误
 2019-05-11 17:21:21 +08:00
Sweet 4c690fb5a3 Null point Exception during loading the checksum (#1788) 
If you connect to the mysql with version 5.1, the result of command 'select @master_binlog_checksum' is an array with only one Null element .
 2019-05-11 17:17:54 +08:00
Jet 8f088cddc0 Fix es bulk (#1743) 
thanks
 2019-04-25 09:36:09 +08:00
Jet e94ee64316 fix typo in trace log (#1738) 2019-04-24 09:57:05 +08:00
dataccs 3165cb9640 支持用户自定义的CanalAlarmHandler (#1736) 
* 支持用户自定义的CanalAlarmHandler

* RowsLogEvent增加对TableMapLogEvent判空检查，防止NPE异常
 2019-04-24 09:56:32 +08:00
rewerma 2b738f4e04 fix bugs (#1712) 
* kafka 模式默认开启事务异步发送

* fix adapter etl rest sql inject bug

* fix #1704
 2019-04-18 20:33:15 +08:00
rewerma 16f335c381 修复rest etl 存在SQL注入风险 (#1685) 
* kafka 模式默认开启事务异步发送

* fix adapter etl rest sql inject bug
 2019-04-15 23:58:12 +08:00
王超 a8bf2b641f String.split(String regex) bug fix (#1696) 2019-04-15 23:55:03 +08:00
chenxyz707 67faf0e03e resovle config/metrics as a destination folder (#1678) 2019-04-09 21:05:42 +08:00
Xin Wang 8cb85753bb open the switch to get codecov test coverage (#1671) 
* add codecov for test coverage
 2019-04-09 19:11:48 +08:00
agapple df86f94409 fixed issue template 2019-04-09 15:12:30 +08:00
agapple 80594444f7 fixed issue template 2019-04-09 15:11:14 +08:00
agapple d8996432b9 add issue template 2019-04-09 15:08:43 +08:00
agapple 69df50fe17 fixed issue #1672 , CanalKafkaProducer send 2019-04-08 19:57:00 +08:00
agapple c5736bd5f3 Merge pull request #1670 from lovepoem/update_compile_jdk 
update jacoco lib
 2019-04-08 12:28:27 +08:00
Xin Wang 55030476ee reverse jdk to 1.8 2019-04-07 19:14:46 +08:00
Xin Wang cd007088db reverse jdk to 1.8 2019-04-07 18:52:35 +08:00
Xin Wang 1fc880f255 reverse jdk to 1.7 2019-04-07 18:45:54 +08:00
Xin Wang 8c68cf833a update jacoco lib 2019-04-07 18:38:50 +08:00
Xin Wang 0de8f4691e update jacoco lib 2019-04-07 18:25:05 +08:00
Xin Wang 5a2efbf9cb update jacoco lib 2019-04-07 18:23:53 +08:00
agapple dfab98fce1 Merge pull request #1669 from lovepoem/add_test_coverage_and_jdk11 
add test coverage and jdk11
 2019-04-06 23:37:40 +08:00
Xin Wang e5c7bbffbf update pom 2019-04-06 18:13:41 +08:00
Xin Wang e139698f6e update pom 2019-04-06 17:50:05 +08:00
Xin Wang 2b8120b6ed update pom 2019-04-06 17:49:03 +08:00
Xin Wang 68ebb3a957 update skipTests=false 2019-04-06 17:35:16 +08:00
Xin Wang 21309cb065 resove Could not resolve dependencies for project com.alibaba.otter:client-adapter.hbase:jar:1.1.4-SNAPSHOT: Could not find artifact jdk.tools:jdk.tools:jar:1.7 at specified path 2019-04-06 17:23:48 +08:00
Xin Wang 386567a633 resove Could not resolve dependencies for project com.alibaba.otter:client-adapter.hbase:jar:1.1.4-SNAPSHOT: Could not find artifact jdk.tools:jdk.tools:jar:1.7 at specified path 2019-04-06 16:56:03 +08:00
Xin Wang 95c69bb854 add test coverage and jdk11 2019-04-06 16:45:04 +08:00
Xin Wang 6febcf1a0f add test coverage and jdk11 2019-04-06 16:42:45 +08:00
agapple fadfe1d6ca [maven-release-plugin] prepare for next development iteration 2019-04-04 10:25:44 +08:00
agapple a7b12c7098 [maven-release-plugin] prepare release canal-1.1.3 canal-1.1.3 2019-04-04 10:25:29 +08:00
agapple 2c320e8618 Merge pull request #1661 from rewerma/master 
flatMessage模式下默认canal.mq.lingerMs=100
 2019-04-04 10:08:34 +08:00
machey d76d25df6c flatMessage模式下默认canal.mq.lingerMs=100 2019-04-04 00:14:27 +08:00
agapple b95c0d03cf fixed issue #1660 ,support mysql8.0 caching_sha2_password auth 2019-04-03 23:42:41 +08:00
agapple 08af40221f Merge pull request #1658 from rewerma/master 
adapter 日志打印修改
 2019-04-03 12:12:56 +08:00
rewerma d13c1eb17c Merge branch 'master' into master 2019-04-03 11:34:10 +08:00
agapple 82ed9db8ae fixed rocketmq partition out of range 2019-04-03 11:26:31 +08:00
agapple d3195ac973 fixed issue #1626 , support alter table id first 2019-04-03 10:58:43 +08:00
agapple 15e29d276a fixed default xml config 2019-03-28 22:05:56 +08:00
agapple d715ff64b4 fixed packet write batch 2019-03-28 21:52:51 +08:00
agapple f63ce4ffe6 fixed mysql auth 2019-03-28 20:45:16 +08:00
agapple a7f9a779ad fixed issue #1640 , support schema partition 2019-03-28 17:01:36 +08:00
agapple 39aeeb8c58 Merge pull request #1641 from wangsaner/master 
修改canal.mq.partitionHash散列规则，使其支持同库下的不同表hash至相同分区
 2019-03-28 16:58:31 +08:00
wangsaner 9826948ebb 修改canal.mq.partitionHash散列规则， 
当指明pk级做分区（schema.table:pk1^pk2）时，由table.hashCode()^column.getValue().hashCode()改为database.hashCode()^column.getValue().hashCode()，从而支持同库下不同表hash至相同分区
 2019-03-28 16:01:02 +08:00
wangsaner d6ef66a281 Merge pull request #1 from alibaba/master 
merge
 2019-03-28 10:37:24 +08:00
agapple 97640b717b fixed compiler 2019-03-28 10:23:33 +08:00