virajjasani commented on code in PR #2230:
URL: https://github.com/apache/phoenix/pull/2230#discussion_r2213934229
##########
phoenix-core/src/it/java/org/apache/phoenix/end2end/CDCStreamIT.java:
##########
@@ -95,6 +99,146 @@ public static synchronized void doSetup() throws Exception {
.findCoprocessorEnvironment(TaskRegionObserver.class.getName());
}
+ /**
+ * Test to verify CDC events with index/table level maxLookback and TTL.
+ */
+ @Test
+ public void testCdcWithMaxLookbackAndCompaction() throws Exception {
+ Connection conn = newConnection();
+ String tableName = generateUniqueName();
+ String cdcName = generateUniqueName();
+ String cdcDdl = "CREATE CDC " + cdcName + " ON " + tableName;
+ // maxLookback 27 hr
+ conn.createStatement().execute(
Review Comment:
Do we update `KEEP_DELETED_CELLS` and `REPLICATION_SCOPE` of index table if
one updates data table using ALTER TABLE? I saw UpgradeUtil has some utility to
keep them in sync but that utility is only in use for version less than 4.15
(PHOENIX-3955).
--
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]
