You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@phoenix.apache.org by "James Taylor (JIRA)" <ji...@apache.org> on 2016/01/22 22:08:39 UTC
[jira] [Updated] (PHOENIX-2334) CSV Bulk load fails on local
indexes
[ https://issues.apache.org/jira/browse/PHOENIX-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
James Taylor updated PHOENIX-2334:
----------------------------------
Fix Version/s: (was: 4.7.0)
4.8.0
> CSV Bulk load fails on local indexes
> ------------------------------------
>
> Key: PHOENIX-2334
> URL: https://issues.apache.org/jira/browse/PHOENIX-2334
> Project: Phoenix
> Issue Type: Bug
> Reporter: maghamravikiran
> Assignee: Rajeshbabu Chintaguntla
> Fix For: 4.8.0
>
> Attachments: PHOENIX-2334.patch, PHOENIX-2334_v2.patch
>
>
> CSV Bulk load fails on local indexes. A quick test for this is
> {code}
> @Test
> public void testImportWithLocalIndex() throws Exception {
> Statement stmt = conn.createStatement();
> stmt.execute("CREATE TABLE TABLE6 (ID INTEGER NOT NULL PRIMARY KEY, " +
> "FIRST_NAME VARCHAR, LAST_NAME VARCHAR) SPLIt ON (1,2)");
> String ddl = "CREATE LOCAL INDEX TABLE6_IDX ON TABLE6 "
> + " (FIRST_NAME ASC)";
> stmt.execute(ddl);
> FileSystem fs = FileSystem.get(hbaseTestUtil.getConfiguration());
> FSDataOutputStream outputStream = fs.create(new Path("/tmp/input3.csv"));
> PrintWriter printWriter = new PrintWriter(outputStream);
> printWriter.println("1,FirstName 1,LastName 1");
> printWriter.println("2,FirstName 2,LastName 2");
> printWriter.close();
> CsvBulkLoadTool csvBulkLoadTool = new CsvBulkLoadTool();
> csvBulkLoadTool.setConf(hbaseTestUtil.getConfiguration());
> int exitCode = csvBulkLoadTool.run(new String[] {
> "--input", "/tmp/input3.csv",
> "--table", "table6",
> "--zookeeper", zkQuorum});
> assertEquals(0, exitCode);
> ResultSet rs = stmt.executeQuery("SELECT id, FIRST_NAME FROM TABLE6 where first_name='FirstName 2'");
> assertTrue(rs.next());
> assertEquals(2, rs.getInt(1));
> assertEquals("FirstName 2", rs.getString(2));
> rs.close();
> stmt.close();
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)