zavakid
6989eb3d2b
+ fix logging call placeholders number
2020-09-17 23:26:02 +08:00
zavakid
df24596092
= code cleanup
...
- for loop replaceable with enhanced 'for' loop
- using diamond in generic type
- collapse try catch exception
- using try-with-resource
- using List#sort instead of Collections#sort
- replaced lambda with method reference
- using native compare method to compare numbers
- using switch instead of if for in ESSyncUtil
2020-09-17 23:22:25 +08:00
zavakid
43c23ffb97
= remove unused improt
2020-09-17 22:40:06 +08:00
zavakid
e7658879bc
= cold cleanup
...
* using lambda if possible (we are already building in Java8)
* using diamond when new generic instance
* remove used improt
2020-09-17 17:46:20 +08:00
zavakid
df60eda679
= code cleanup
2020-09-16 14:18:05 +08:00
liguangyao
b81e9dfeb8
支持不同topic指定专属partitionNum ( #2479 )
2020-08-22 13:11:53 +08:00
agapple
b79af46054
merge code and fixed issue #2755 #2756 #2735 #2714 #2711 #2710 #2616 #2602 #2585 #2565 #2935 #2434 #2623 #2418 #2387
2020-08-22 13:07:24 +08:00
calvinhkf
90bf9e6de5
align h2 version to 1.4.196 ( #2663 )
2020-08-20 21:19:22 +08:00
zhaohua
182163c3bd
MemoryTableMeta ddl 处理注释2 ( #2694 )
...
* MemoryTableMeta ddl 处理注释
* MemoryTableMeta ddl 处理注释2
2020-08-20 21:19:08 +08:00
dengliming
e4726972de
refactor: delete duplicate code ( #2748 )
2020-08-20 21:18:51 +08:00
dengliming
985892cf7e
Remove deprecated sudo setting. ( #2749 )
2020-08-20 21:18:37 +08:00
chank
746d51e621
Change maven repository to HTTPS ( #2763 )
...
* change maven repository to https
* change maven repository to https
2020-08-20 21:18:25 +08:00
caoyixiong
cdd077b758
FIX NPE When ddl event ( #2801 )
2020-08-20 21:18:12 +08:00
DinoZhang
72ae7ba8d7
meta admin ( #2836 )
2020-08-20 21:18:00 +08:00
Tocker
b82c8bca83
Fix:Alibaba Coding Guidelines-Object的equals方法容易抛空指针异常，应使用常量或确定有值的对象来调用equals。 ( #2919 )
2020-08-20 21:17:44 +08:00
Tocker
576406a4ce
Fix:Alibaba Coding Guidelines-所有的包装类对象之间值的比较，全部使用equals方法比较 ( #2918 )
2020-08-20 21:17:32 +08:00
Ymangz
b5b08e92e3
Unbuntu 20.0 默认sh为dash执行时会报语法异常 ( #2939 )
2020-08-20 21:17:11 +08:00
wanshao
9f6021cf36
fix(dml): revert wrong fix
2020-03-13 17:41:53 +08:00
bucketli
0e3d719a39
refact(canal):duplicate dependence
2020-03-09 14:15:40 +08:00
agapple
afbf125231
fixed format
2020-03-05 15:26:59 +08:00
agapple
b2b2a82554
client-adapter 写入kudu ( #2396 )
...
* client-adapter 提交写入kudu适配器
* kudu etl 处理数据缓存提交问题
* Update KuduTemplate.java
* 1.写入kudu前获取元数据方式更改
2.解决etl批量导入kudu数据少量丢失问题
* 1.修改文件头注释
2.调整kudu更新事件update为upsert
2020-03-05 15:22:01 +08:00
wanshao
30a1b067a8
fix(project): no need to process tinyint(1) specially #631
2020-02-28 14:34:30 +08:00
wanshao
beaca165d0
Merge branch 'master' of github.com:alibaba/canal
2020-02-28 14:24:33 +08:00
wanshao
c21c18458b
fix(project): fix isDdl judge #2599
2020-02-28 14:21:12 +08:00
agapple
5e761e14fa
format
2020-02-28 13:15:27 +08:00
agapple
18418ebd98
merge pull/2120
2020-02-28 12:29:41 +08:00
844392610
92f04f86cb
添加目标表不区分大小写的支持，并可开关（默认为区分大小写） ( #2329 )
...
* 添加目标表不区分大小写的支持，并可开关（默认为区分大小写）
* 添加目标表不区分大小写的支持，并可开关（默认为区分大小写）-format
2020-02-28 12:22:17 +08:00
littleneko
0d5505aa2c
fix_json_type_opaque_parse_err ( #2318 )
...
对于`JSONB_TYPE_OPAQUE`类型的解析计算`q_max_bytes`时，多算了`1`字节
2020-02-28 12:15:09 +08:00
zhshy11
bd56438eca
sql语句增加引号，兼容mysql关键字 ( #2358 )
2020-02-28 11:47:38 +08:00
agapple
b9a157657f
merge /pull/2373
2020-02-28 11:46:28 +08:00
agapple
523e8b85e6
format
2020-02-28 11:40:14 +08:00
agapple
ab74b2c82c
fixed mq spi package
2020-02-28 11:32:30 +08:00
rewerma
265a8e8594
模块化mq connector ( #2562 )
...
* add connector module, add kafka producer connector module for server
* add rocketMQ producer connector module for server
* add rabbitMQ producer connector module for server
* optimize code, add annotation
* add canal message consumer connector for canal-adapter module
2020-02-28 11:00:08 +08:00
jianqingdu
4fc7e5f7d9
fix bug: wrong quit command implementation ( #2554 )
2020-02-28 10:52:35 +08:00
Li Qiang
9cc8caa834
feature(canal):support start with timestamp position(empty journal_file,set position=0),#2594 ( #2595 )
2020-02-28 10:50:38 +08:00
Li Qiang
a71375dad5
fix(canal):fix endless local binlog mode with exception. ( #2597 )
2020-02-28 10:48:54 +08:00
Rg
70d8a379f2
add Rust canal client support ( #2518 )
2020-01-15 20:12:28 +08:00
rewerma
b6333f018f
Revert "修复kafka消费回滚的bug ( #2521 )" ( #2526 )
...
This reverts commit 31acfc0101
2020-01-02 17:04:57 +08:00
rewerma
31acfc0101
修复kafka消费回滚的bug ( #2521 )
2020-01-02 16:15:47 +08:00
rewerma
6d9ea57186
修复子线程阻塞造成不能中止的问题 ( #2508 )
2019-12-26 19:29:48 +08:00
Li Qiang
c4c0255073
Update README.md
2019-11-04 10:20:00 +08:00
agapple
1fa9020599
format
2019-10-15 21:38:48 +08:00
agapple
dd7554374f
format
2019-10-15 21:35:57 +08:00
shicongyang
65b5325ca6
建议增加一个属性，针对根据某一字段hash时，hash算法可以不根据database算出 #2248 ( #2294 )
2019-10-15 21:32:42 +08:00
agapple
b64a3e301a
fixed issue #2286 , ArithmeticException zero
2019-10-10 15:37:17 +08:00
agapple
31562919bb
rename canal-admin project to admin
2019-10-09 14:50:08 +08:00
agapple
9c75e25da7
optimizer pom dependency
2019-10-09 14:18:37 +08:00
agapple
7d91850be6
fixed issue #2257 , time 100 parse bugfix
2019-10-09 13:39:22 +08:00
agapple
4af3b24b69
fixed issue #2281 , null reject
2019-10-08 18:50:37 +08:00
craigwu9
e4e66b143c
make canal.admin.port canal.admin.user canal.admin.passwd can be override by system env properties ( #2274 )
...
* Update SimpleAdminConnectors.java
add more information about which server execute failed
* Update CanalStarter.java
make canal.admin.port canal.admin.user canal.admin.passwd can be override by system env
2019-09-30 20:45:00 +08:00
