Skip to content

Conversation

@loserwang1024
Copy link
Contributor

Purpose

Linked issue: close #2140

Brief change log

Tests

API and Format

Documentation

@loserwang1024
Copy link
Contributor Author

@swuferhong @wuchong , CC

Copy link
Member

@wuchong wuchong left a comment

Choose a reason for hiding this comment

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

Could you add a IT case to verify this exception will truly been thrown to user?

I think we can add this logic at the end of org.apache.fluss.flink.source.FlinkTableSourceFailOverITCase#testRestore that re-creates test_partitioned table and restart the insert into result_table select * from test_partitioned query again.

}
checkArgument(
tableId.equals(sourceSplitBase.getTableBucket().getTableId()),
"table id not equal across splits {}",
Copy link
Member

Choose a reason for hiding this comment

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

Make the exception message more clear to users, what table path, what is the different table ids, why this error happens, how to resolve this error.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Flink Source need to check tableId on recovery in case that table is removed and created.

2 participants