jyothsnakonisa commented on code in PR #213:
URL: https://github.com/apache/cassandra-sidecar/pull/213#discussion_r2035941112
##########
server/src/main/java/org/apache/cassandra/sidecar/cdc/CdcConfigImpl.java:
##########
@@ -179,7 +179,7 @@ public MinuteBoundConfiguration watermarkWindow()
{
// this prop sets the maximum duration age accepted by CDC, any
mutations with write timestamps older than
// the watermark window will be dropped with log message "Exclude the
update due to out of the allowed time window."
- return new
MinuteBoundConfiguration(getInt(ConfigKeys.WATERMARK_SECONDS.lowcaseName,
DEFAULT_WATERMARK_WINDOW), TimeUnit.SECONDS);
+ return new
MinuteBoundConfiguration(getInt(ConfigKeys.WATERMARK_SECONDS.lowcaseName,
DEFAULT_WATERMARK_WINDOW) / 60, TimeUnit.MINUTES);
Review Comment:
I think changing the MinuteBound to SecondBound is better compared to
changing configkey as it will break at compile time.
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
