Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
None
Description
When I read the code, I found that SparkHoodieHBaseIndex#generateStatement uses Hbase's deprecated method(setMaxVersion), I replaced it with new method.
private Get generateStatement(String key) throws IOException { return new Get(Bytes.toBytes(getHBaseKey(key))).setMaxVersions(1).addColumn(SYSTEM_COLUMN_FAMILY, COMMIT_TS_COLUMN) .addColumn(SYSTEM_COLUMN_FAMILY, FILE_NAME_COLUMN).addColumn(SYSTEM_COLUMN_FAMILY, PARTITION_PATH_COLUMN); }
Attachments
Attachments
Issue Links
- links to