[
https://issues.apache.org/jira/browse/FLINK-8356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Wu closed FLINK-8356.
--------------------------
Resolution: Not A Bug
Release Note: A person from my workplace found that this can be simply
fixed by appending ";autocommit=true" in the jdbc url.
> JDBCAppendTableSink does not work for Hbase Phoenix Driver
> -----------------------------------------------------------
>
> Key: FLINK-8356
> URL: https://issues.apache.org/jira/browse/FLINK-8356
> Project: Flink
> Issue Type: Bug
> Components: Table API & SQL
> Affects Versions: 1.4.0
> Reporter: Paul Wu
>
> The following code runs without errors, but the data is not inserted into the
> HBase table. However, it does work for MySQL (see the commented out code).
> The Phoenix driver is from
> https://mvnrepository.com/artifact/org.apache.phoenix/phoenix/4.7.0-HBase-1.1
> String query = "select CURRENT_DATE SEGMENTSTARTTIME, CURRENT_DATE
> SEGMENTENDTIME, cast (imsi as varchar) imsi, cast(imei as varchar) imei from
> ts ";
>
> Table table = ste.sqlQuery(query);
> JDBCAppendTableSinkBuilder jdbc = JDBCAppendTableSink.builder();
> jdbc.setDrivername("org.apache.phoenix.jdbc.PhoenixDriver");
> jdbc.setDBUrl("jdbc:phoenix:hosts:2181:/hbase-unsecure");
> jdbc.setQuery("upsert INTO GEO_ANALYTICS_STREAMING_DATA
> (SEGMENTSTARTTIME,SEGMENTENDTIME, imsi, imei) values (?,?,?, ?)");
> // JDBCAppendTableSinkBuilder jdbc = JDBCAppendTableSink.builder();
> // jdbc.setDrivername("com.mysql.jdbc.Driver");
> // jdbc.setDBUrl("jdbc:mysql://localhost/test");
> // jdbc.setUsername("root").setPassword("");
> // jdbc.setQuery("insert INTO GEO_ANALYTICS_STREAMING_DATA
> (SEGMENTSTARTTIME,SEGMENTENDTIME, imsi, imei) values (?,?,?, ?)");
> // jdbc.setBatchSize(1);
> jdbc.setParameterTypes(Types.SQL_DATE, Types.SQL_DATE, Types.STRING,
> Types.STRING);
> JDBCAppendTableSink sink = jdbc.build();
> table.writeToSink(sink);
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
