virajjasani opened a new pull request, #2186:
URL: https://github.com/apache/phoenix/pull/2186
Jira: PHOENIX-7636
While creating CDC object on table with case-sensitive pk columns, the CDC
PTable definition does not include case-sensitive pk columns of the data table.
Therefore, reading of the CDC records fails as the query optimizer cannot
select any plan.
e.g.
SQL statements:
```
CREATE TABLE XYZ."test.table" ("key1" VARCHAR NOT NULL, COL BSON CONSTRAINT
pk PRIMARY KEY ("key1"));
CREATE CDC "CDC_test.table" on XYZ."test.table";
UPSERT INTO XYZ."test.table" VALUES (?,?);
SELECT /*+ CDC_INCLUDE(PRE, POST) */ * FROM XYZ."CDC_test.table" WHERE
PARTITION_ID() = ? AND PHOENIX_ROW_TIMESTAMP() >= CAST(CAST(? AS BIGINT) AS
TIMESTAMP) LIMIT ?;
```
causes
```
Caused by:
org.apache.phoenix.schema.RowValueConstructorOffsetNotCoercibleException: ERROR
2014 (INT16): Row Value Constructor Offset Not Coercible to a Primary or
Indexed RowKey. No table or index could be coerced to the PK as the offset. Or
an uncovered index was attempted
at
org.apache.phoenix.optimize.QueryOptimizer.getApplicablePlansForSingleFlatQuery(QueryOptimizer.java:331)
~[phoenix-core-client-5.3.0-sfdc-13.0.24.jar:5.3.0-sfdc-13.0.24]
at
org.apache.phoenix.optimize.QueryOptimizer.getApplicablePlans(QueryOptimizer.java:142)
~[phoenix-core-client-5.3.0-sfdc-13.0.24.jar:5.3.0-sfdc-13.0.24]
at
org.apache.phoenix.optimize.QueryOptimizer.optimize(QueryOptimizer.java:120)
~[phoenix-core-client-5.3.0-sfdc-13.0.24.jar:5.3.0-sfdc-13.0.24]
at
org.apache.phoenix.optimize.QueryOptimizer.optimize(QueryOptimizer.java:106)
~[phoenix-core-client-5.3.0-sfdc-13.0.24.jar:5.3.0-sfdc-13.0.24]
at
org.apache.phoenix.jdbc.PhoenixStatement$1.call(PhoenixStatement.java:392)
~[phoenix-core-client-5.3.0-sfdc-13.0.24.jar:5.3.0-sfdc-13.0.24]
at
org.apache.phoenix.jdbc.PhoenixStatement$1.call(PhoenixStatement.java:360)
~[phoenix-core-client-5.3.0-sfdc-13.0.24.jar:5.3.0-sfdc-13.0.24]
at org.apache.phoenix.call.CallRunner.run(CallRunner.java:53)
~[phoenix-core-client-5.3.0-sfdc-13.0.24.jar:5.3.0-sfdc-13.0.24]
at
org.apache.phoenix.jdbc.PhoenixStatement.executeQuery(PhoenixStatement.java:360)
~[phoenix-core-client-5.3.0-sfdc-13.0.24.jar:5.3.0-sfdc-13.0.24]
at
org.apache.phoenix.jdbc.PhoenixStatement.executeQuery(PhoenixStatement.java:342)
~[phoenix-core-client-5.3.0-sfdc-13.0.24.jar:5.3.0-sfdc-13.0.24]
at
org.apache.phoenix.jdbc.PhoenixPreparedStatement.executeQuery(PhoenixPreparedStatement.java:197)
~[phoenix-core-client-5.3.0-sfdc-13.0.24.jar:5.3.0-sfdc-13.0.24]
at
org.apache.phoenix.ddb.service.GetRecordsService.getRecords(GetRecordsService.java:71)
~[classes/:?]
at org.apache.phoenix.ddb.rest.RootResource.get(RootResource.java:196)
~[classes/:?]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_362]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_362]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_362]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_362]
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
