You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@phoenix.apache.org by "Suhas Nalapure (JIRA)" <ji...@apache.org> on 2017/01/25 06:49:26 UTC

[jira] [Created] (PHOENIX-3636) CurrentSCN doesn't work with phoenix-spark plugin

Suhas Nalapure created PHOENIX-3636:
---------------------------------------

             Summary: CurrentSCN doesn't work with phoenix-spark plugin
                 Key: PHOENIX-3636
                 URL: https://issues.apache.org/jira/browse/PHOENIX-3636
             Project: Phoenix
          Issue Type: Bug
    Affects Versions: 4.6.0
            Reporter: Suhas Nalapure


Specifying CurrentSCN property while creating a Spark DataFrame as shown below doesn't give the expected results.

E.g. below code doesn't return those records from Hbase that have row timestamp > current system timestamp  

Map<String, String> params = new HashMap<String, String>();
params.put("table", tableName);
params.put("zkUrl", zkUrl);
Calendar cal = Calendar.getInstance();
cal.set(2017, 3, 15);
params.put("CurrentSCN", Long.toString(cal.getTime().getTime()));
			df = sqlContext.read().format(hbaseFormat).options(params).load();
df.show()



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)