[jira] [Commented] (PHOENIX-2334) CSV Bulk load fails on local indexes

["Rajeshbabu Chintaguntla (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/PHOENIX-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14963590#comment-14963590 ] 

Rajeshbabu Chintaguntla commented on PHOENIX-2334:
--------------------------------------------------

When we run the job for index we are running upsert query on index table. The key values preparation is same as data table that's why the region start key is not getting added properly. 

> 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
>
> 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)