[
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
[
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
[
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
[
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
[
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
[
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
[
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
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
[
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 ?
>
[
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
[
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
>
[
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
[
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
[
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
[
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
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
[
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
[
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
>
[
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
[
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
[
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:
---
[
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
[
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
>
[
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
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
[
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
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
[
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
28 matches
Mail list logo