[jira] [Updated] (FLINK-20953) canal-json.table.include Supports regular or wildcard characters

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangfei updated FLINK-20953: Description: |h5. canal-json.database.include|optional|(none)|String|Only read changelog rows which

[jira] [Commented] (FLINK-20953) canal-json.table.include Supports regular or wildcard characters

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263963#comment-17263963 ] wangfei commented on FLINK-20953: - @[~jark] @[~nicholasjiang] > canal-json.table.include Supports

[jira] [Created] (FLINK-20953) canal-json.table.include Supports regular or wildcard characters

2021-01-12 Thread wangfei (Jira)
wangfei created FLINK-20953: --- Summary: canal-json.table.include Supports regular or wildcard characters Key: FLINK-20953 URL: https://issues.apache.org/jira/browse/FLINK-20953 Project: Flink

[jira] [Comment Edited] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263923#comment-17263923 ] wangfei edited comment on FLINK-20885 at 1/13/21, 7:03 AM: --- Remove \, the JIRA

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263923#comment-17263923 ] wangfei commented on FLINK-20885: -

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263917#comment-17263917 ] wangfei commented on FLINK-20885: - You can use the JSON above。    and canal-json.database.include and

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263916#comment-17263916 ] wangfei commented on FLINK-20885: -

[jira] [Comment Edited] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263858#comment-17263858 ] wangfei edited comment on FLINK-20885 at 1/13/21, 3:16 AM: --- table

[jira] [Comment Edited] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263858#comment-17263858 ] wangfei edited comment on FLINK-20885 at 1/13/21, 3:14 AM: --- table

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263858#comment-17263858 ] wangfei commented on FLINK-20885: - table test_2.userName (int); table test_1.userName (varchar); You

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263857#comment-17263857 ] wangfei commented on FLINK-20885: - [~nicholasjiang] CREATE TABLE `test_2` ( `id` int(11) NOT NULL,

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17261054#comment-17261054 ] wangfei commented on FLINK-20885: - This is just a temporary solution for my production environment,

[jira] [Updated] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangfei updated FLINK-20885: Attachment: image-2021-01-08-14-53-40-476.png > Exception when use 'canal-json.table.include' to filter

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17261052#comment-17261052 ] wangfei commented on FLINK-20885: - !image-2021-01-08-14-53-40-476.png! > Exception when use

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17261051#comment-17261051 ] wangfei commented on FLINK-20885: - !image-2021-01-08-14-52-53-443.png! > Exception when use

[jira] [Updated] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangfei updated FLINK-20885: Attachment: image-2021-01-08-14-52-53-443.png > Exception when use 'canal-json.table.include' to filter

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17261050#comment-17261050 ] wangfei commented on FLINK-20885: - I have modified the code locally to fix this bug, and if you do, it

[jira] [Issue Comment Deleted] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangfei updated FLINK-20885: Comment: was deleted (was: [~jark] I've modified and tested it, but don't know how to participate in the

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17261031#comment-17261031 ] wangfei commented on FLINK-20885: - [~jark] I've modified and tested it, but don't know how to

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260988#comment-17260988 ] wangfei commented on FLINK-20885: - [~jark] I'm using Flink Master based compilation, probably 1.13. >

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260946#comment-17260946 ] wangfei commented on FLINK-20885: - [~jark] When is this expected to be fixed  > Exception when use

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260402#comment-17260402 ] wangfei commented on FLINK-20385: - [~jark] 3q > Allow to read metadata for Canal-json format >

[jira] [Updated] (FLINK-20385) Allow to read metadata for Canal-json format

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangfei updated FLINK-20385: Attachment: image-2021-01-07-16-57-20-838.png > Allow to read metadata for Canal-json format >

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260328#comment-17260328 ] wangfei commented on FLINK-20385: - 在源码 这步会解析报错   !image-2021-01-07-16-57-20-838.png! > Allow to read

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260326#comment-17260326 ] wangfei commented on FLINK-20385: - !image-2021-01-07-16-56-37-330.png! > Allow to read metadata for

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260324#comment-17260324 ] wangfei commented on FLINK-20385: - 我发现了一个bug 在canal代码，在使用时候 配置’canal-json.table.include’

[jira] [Updated] (FLINK-20385) Allow to read metadata for Canal-json format

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangfei updated FLINK-20385: Attachment: image-2021-01-07-16-56-37-330.png > Allow to read metadata for Canal-json format >

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260323#comment-17260323 ] wangfei commented on FLINK-20385: - I found a bug in the canal code. 'canal-json.table.include' does not

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260322#comment-17260322 ] wangfei commented on FLINK-20385: - i try it > Allow to read metadata for Canal-json format >

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

2020-12-21 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253298#comment-17253298 ] wangfei commented on FLINK-20385: - [~nicholasjiang] [~jark]Thank you. When did this get merged into the

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

2020-12-14 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17249429#comment-17249429 ] wangfei commented on FLINK-20385: - When will this version come online？ > Allow to read metadata for