Skip to content

Conversation

Raffaellorr
Copy link

It would insert an empty statement, which covered the before statement. Now I insert a before statement first and then insert an after statement.

It would insert an empty statement, which covered the `before` statement. Now I insert a `before` statement first and then insert an `after` statement.
@aadant aadant requested a review from subkanthi September 11, 2022 18:24
} else if(CdcRecordState.CDC_RECORD_STATE_BOTH == getCdcSectionBasedOnOperation(record.getCdcOperation())) {
if(this.engine != null && this.engine.getEngine().equalsIgnoreCase(DBMetadata.TABLE_ENGINE.COLLAPSING_MERGE_TREE.getEngine())) {
insertPreparedStatement(entry.getKey().right, ps, record.getBeforeModifiedFields(), record, record.getBeforeStruct(), true);
if (!beforeInseted) {
Copy link
Collaborator

@subkanthi subkanthi Sep 11, 2022

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

typo, This should be beforeInserted

Copy link
Author

@Raffaellorr Raffaellorr Sep 12, 2022

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Sorry, my bad. I'll fix it.

@Raffaellorr
Copy link
Author

Hi, @subkanthi . I've fixed it.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants