virajjasani commented on code in PR #2033:
URL: https://github.com/apache/phoenix/pull/2033#discussion_r1877074035
##########
phoenix-core-client/src/main/java/org/apache/phoenix/query/QueryConstants.java:
##########
@@ -655,11 +655,11 @@ enum JoinType {INNER, LEFT_OUTER}
SYSTEM_CDC_STREAM_STATUS_TABLE + "\"(\n" +
// PK columns
TABLE_NAME + " VARCHAR NOT NULL," +
- STREAM_STATUS + " VARCHAR NOT NULL," +
+ STREAM_NAME + " VARCHAR NOT NULL," +
// Non-PK columns
- STREAM_NAME + " VARCHAR,\n" +
+ STREAM_STATUS + " VARCHAR,\n" +
Review Comment:
@palashc btw the query pattern is going to be:
```
Step 1: Get the active table stream from the metadata.
SELECT STREAM_NAME FROM SYSTEM.CDC_STREAM_STATUS WHERE TABLE_NAME =
<table-name> AND STREAM_STATUS = 'ACTIVE'
```
How would keeping STREAM_NAME help here? I missed this earlier.
--
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]
