[jira] [Commented] (FLINK-19423) Primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException

2020-10-12 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212785#comment-17212785 ] limbo commented on FLINK-19423: --- Good job, Thanks to pull request > Primary key position cause JDBC SQL

[jira] [Commented] (FLINK-18383) Translate "JDBC SQL Connector" page into Chinese

2020-10-11 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211867#comment-17211867 ] limbo commented on FLINK-18383: --- [~zhoupeijie] still working on it? > Translate "JDBC SQL Connector" page

[jira] [Commented] (FLINK-19423) Primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException

2020-10-11 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211841#comment-17211841 ] limbo commented on FLINK-19423: --- I'm trying to fix the code, and do some test, but find that the table API

[jira] [Commented] (FLINK-19423) Primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException

2020-09-26 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202570#comment-17202570 ] limbo commented on FLINK-19423: --- KeyedBatchStatementExecutor.java {code:java} @Override public void

[jira] [Updated] (FLINK-19423) Primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException

2020-09-26 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] limbo updated FLINK-19423: -- Description: We found  that the primary key position can cause  ArrayIndexOutOfBoundsException the sink

[jira] [Updated] (FLINK-19423) Primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException

2020-09-26 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] limbo updated FLINK-19423: -- Description: We found  that the primary key position can cause  ArrayIndexOutOfBoundsException the sink

[jira] [Updated] (FLINK-19423) Primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException

2020-09-26 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] limbo updated FLINK-19423: -- Summary: Primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException (was: primary key

[jira] [Created] (FLINK-19423) primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException

2020-09-26 Thread limbo (Jira)
limbo created FLINK-19423: - Summary: primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException Key: FLINK-19423 URL: https://issues.apache.org/jira/browse/FLINK-19423 Project: Flink

[jira] [Commented] (FLINK-19200) UNIX_TIMESTAMP function support return in millisecond

2020-09-24 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201366#comment-17201366 ] limbo commented on FLINK-19200: --- How about add UNIX_TIMESTAMP_MILLIS to return millisecond ? >

[jira] [Commented] (FLINK-19200) UNIX_TIMESTAMP function support return in millisecond

2020-09-23 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201240#comment-17201240 ] limbo commented on FLINK-19200: --- way(2) +1,  we just meet the same question hi, [~jark], can you assignee

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

2020-09-18 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17198160#comment-17198160 ] limbo commented on FLINK-19285: --- [~dwysakowicz] Oh, yes, I find my version is 1.11.0, thanks very much >

[jira] [Updated] (FLINK-19285) Kafka sql connector fixed partitioner not work

2020-09-18 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] limbo updated FLINK-19285: -- Affects Version/s: (was: 1.11.1) 1.11.0 > Kafka sql connector fixed partitioner

[jira] [Updated] (FLINK-19285) Kafka sql connector fixed partitioner not work

2020-09-18 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] limbo updated FLINK-19285: -- Affects Version/s: (was: 1.11.2) 1.11.1 > Kafka sql connector fixed partitioner

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

2020-09-18 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17198154#comment-17198154 ] limbo commented on FLINK-19285: --- Hi [~jark], thanks very much I set parallelism is 2, and I logged in

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

2020-09-17 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17198121#comment-17198121 ] limbo commented on FLINK-19285: --- I tracked the code and find that

[jira] [Created] (FLINK-19285) Kafka sql connector fixed partitioner not work

2020-09-17 Thread limbo (Jira)
limbo created FLINK-19285: - Summary: Kafka sql connector fixed partitioner not work Key: FLINK-19285 URL: https://issues.apache.org/jira/browse/FLINK-19285 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-11747) Elasticsearch 6 connector - Expose RestHighLevelClient to allow for custom sniffing

2020-01-14 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015627#comment-17015627 ] limbo commented on FLINK-11747: --- yes, if we need sniffer function  we would like do a lot of work , so 

[jira] [Commented] (FLINK-10538) standalone-job.sh causes Classpath issues

2019-11-25 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982216#comment-16982216 ] limbo commented on FLINK-10538: --- I think the dependencies have been shaded, issue could be closed >

[jira] [Commented] (FLINK-13899) Add SQL DDL for Elasticsearch 5.X version

2019-11-25 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981413#comment-16981413 ] limbo commented on FLINK-13899: --- I'm not ture anybody else need this feature and if the community  have

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

2019-09-03 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921894#comment-16921894 ] limbo commented on FLINK-13025: --- [~yanghua] as Leonid llyevsky mentioned, I just test the elasticsearch6

[jira] [Commented] (FLINK-10173) Elasticsearch 6 connector does not package Elasticsearch

2019-09-03 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921230#comment-16921230 ] limbo commented on FLINK-10173: ---

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

2019-09-02 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921121#comment-16921121 ] limbo commented on FLINK-13025: --- I think  a universal connector can be very nice, and I just test es6

[jira] [Updated] (FLINK-13899) Add SQL DDL for Elasticsearch 5.X version

2019-08-29 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] limbo updated FLINK-13899: -- Fix Version/s: (was: 1.9.1) > Add SQL DDL for Elasticsearch 5.X version >

[jira] [Updated] (FLINK-13899) Add SQL DDL for Elasticsearch 5.X version

2019-08-29 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] limbo updated FLINK-13899: -- Description: Hi, I need Elasticsearch 5.X verison  DDL to connect our old version Elasticsearch, can I

[jira] [Created] (FLINK-13899) Add SQL DDL for Elasticsearch 5.X version

2019-08-29 Thread limbo (Jira)
limbo created FLINK-13899: - Summary: Add SQL DDL for Elasticsearch 5.X version Key: FLINK-13899 URL: https://issues.apache.org/jira/browse/FLINK-13899 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-13859) JSONDeserializationSchema spell error

2019-08-26 Thread limbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] limbo updated FLINK-13859: -- Description: In kafka page the JsonDeserializationSchema would be JSONDeserializationSchema

[jira] [Created] (FLINK-13859) JSONDeserializationSchema spell error

2019-08-26 Thread limbo (Jira)
limbo created FLINK-13859: - Summary: JSONDeserializationSchema spell error Key: FLINK-13859 URL: https://issues.apache.org/jira/browse/FLINK-13859 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-12770) Make number of bulk concurrentRequests configurable

2019-06-27 Thread limbo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873856#comment-16873856 ] limbo commented on FLINK-12770: --- +1 really useful config > Make number of bulk concurrentRequests