[
https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522019#comment-17522019
]
ranqiqiang commented on FLINK-17826:
We have also implemented a similar function, remember that the
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17514537#comment-17514537
]
ranqiqiang commented on FLINK-14902:
hello everyone：
I finished this pr for a long time,
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497231#comment-17497231
]
ranqiqiang commented on FLINK-14902:
[~jark] [~ana4] , what can I to do next ? Do you have
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469635#comment-17469635
]
ranqiqiang commented on FLINK-14902:
dear :
[~jark] , can anyone help review ？
>
[
https://issues.apache.org/jira/browse/FLINK-25507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468971#comment-17468971
]
ranqiqiang commented on FLINK-25507:
Thanks, I don't know have some documents ？ It's could be easy
ranqiqiang created FLINK-25507:
--
Summary: ElasticsearchWriterITCase#testWriteOnBulkFlush test
failed
Key: FLINK-25507
URL: https://issues.apache.org/jira/browse/FLINK-25507
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467074#comment-17467074
]
ranqiqiang commented on FLINK-14902:
[~ana4] I don‘t want to modify too much code.I jush create a
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464908#comment-17464908
]
ranqiqiang commented on FLINK-14902:
[~jark] please assign to me, I want to try it.
>
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464387#comment-17464387
]
ranqiqiang commented on FLINK-14902:
[~jark] [~ana4] [~hailong wang]
I don't know, the issue
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456979#comment-17456979
]
ranqiqiang commented on FLINK-14902:
Hello, we are going to use "AsyncJdbcLookupFunction" , but we
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429900#comment-17429900
]
ranqiqiang commented on FLINK-14902:
[~ana4] Do you have the latest version of the code on flink
[
https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420674#comment-17420674
]
ranqiqiang commented on FLINK-16024:
support sql filter by self, hope to use hint /* */ .
[
https://issues.apache.org/jira/browse/FLINK-24378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang updated FLINK-24378:
---
Description:
hello:
If binlog source table-A data is : \{id : 1 , name:'king' }
[
https://issues.apache.org/jira/browse/FLINK-24378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang updated FLINK-24378:
---
Description:
hello:
If binlog source table-A data is : \{id : 1 , name:'king' }
ranqiqiang created FLINK-24378:
--
Summary: Dim table join operator Push down
Key: FLINK-24378
URL: https://issues.apache.org/jira/browse/FLINK-24378
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365267#comment-17365267
]
ranqiqiang commented on FLINK-14902:
[~ana4] I found "hikaricp" is small,and fast than Alibaba
ranqiqiang created FLINK-22538:
--
Summary: How to check sql is right before to execute accross API
Key: FLINK-22538
URL: https://issues.apache.org/jira/browse/FLINK-22538
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-22538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang updated FLINK-22538:
---
Description:
If user writes some flink-sql include (source query sink ) , then
how to
[
https://issues.apache.org/jira/browse/FLINK-22538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang updated FLINK-22538:
---
Summary: How to check sql is right before to execute across API (was:
How to check sql is right
[
https://issues.apache.org/jira/browse/FLINK-22499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335122#comment-17335122
]
ranqiqiang commented on FLINK-22499:
thanks, but the version is "jdbc .. {{1.14-SNAPSHOT}}"
If I
ranqiqiang created FLINK-22499:
--
Summary: JDBC sink table-api support "sink.parallelism" ?
Key: FLINK-22499
URL: https://issues.apache.org/jira/browse/FLINK-22499
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-21476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang closed FLINK-21476.
--
Resolution: Duplicate
> How to appoint jobname
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-21476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289760#comment-17289760
]
ranqiqiang commented on FLINK-21476:
Thanks
> How to appoint jobname
> ---
>
>
ranqiqiang created FLINK-21476:
--
Summary: How to appoint jobname
Key: FLINK-21476
URL: https://issues.apache.org/jira/browse/FLINK-21476
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156638#comment-17156638
]
ranqiqiang commented on FLINK-14902:
1.Caffeine cache performance is better than guava , suggest
[
https://issues.apache.org/jira/browse/FLINK-18584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang updated FLINK-18584:
---
Summary: do you have plan to support AsyncLookupFunction (was:
JDBCLookupFunction not support
[
https://issues.apache.org/jira/browse/FLINK-18584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang updated FLINK-18584:
---
Summary: do you have plan to support JDBCAsyncLookupFunction (was: do you
have plan to support
ranqiqiang created FLINK-18584:
--
Summary: JDBCLookupFunction not support AsyncLookupFunction
Key: FLINK-18584
URL: https://issues.apache.org/jira/browse/FLINK-18584
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang closed FLINK-17459.
--
Release Note:
We suggest to use JDBCUpsertTableSink in Table API & SQL which both support
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100533#comment-17100533
]
ranqiqiang commented on FLINK-17459:
Thanks [~jark]:
I get it . If want to do sink
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100513#comment-17100513
]
ranqiqiang commented on FLINK-17459:
Thanks [~jark] :
I used StreamTableEnvironment,
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100433#comment-17100433
]
ranqiqiang commented on FLINK-17459:
[~jark] can you give an example by JDBCUpsertTableSink to
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096221#comment-17096221
]
ranqiqiang edited comment on FLINK-17459 at 4/30/20, 6:51 AM:
--
Thanks ,
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096221#comment-17096221
]
ranqiqiang commented on FLINK-17459:
Thanks , Maybe I did wrong ! use JDBCUpsertTableSink to append
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096029#comment-17096029
]
ranqiqiang edited comment on FLINK-17459 at 4/30/20, 2:53 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096029#comment-17096029
]
ranqiqiang edited comment on FLINK-17459 at 4/30/20, 2:42 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096029#comment-17096029
]
ranqiqiang commented on FLINK-17459:
1.JDBCAppendTableSink will be abandoned ?
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang updated FLINK-17459:
---
Description:
{{JDBCAppendTableSink just support append by
[
https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang updated FLINK-17459:
---
Description:
{{JDBCAppendTableSink just support append by
ranqiqiang created FLINK-17459:
--
Summary: JDBCAppendTableSink not support flush by
flushIntervalMills
Key: FLINK-17459
URL: https://issues.apache.org/jira/browse/FLINK-17459
Project: Flink
40 matches
Mail list logo
