mchades commented on code in PR #8922:
URL: https://github.com/apache/gravitino/pull/8922#discussion_r2473963776
##########
core/src/main/java/org/apache/gravitino/storage/relational/utils/POConverters.java:
##########
@@ -440,21 +421,15 @@ public static TablePO initializeTablePOWithVersion(
*
* @param oldTablePO the old TablePO object
* @param newTable the new TableEntity object
- * @param needUpdateVersion whether need to update the version
* @param newSchemaId the new schema id
* @return TablePO object with updated version
*/
public static TablePO updateTablePOWithVersionAndSchemaId(
- TablePO oldTablePO, TableEntity newTable, boolean needUpdateVersion,
Long newSchemaId) {
+ TablePO oldTablePO, TableEntity newTable, Long newSchemaId) {
Long lastVersion;
Long currentVersion;
- if (needUpdateVersion) {
- lastVersion = oldTablePO.getLastVersion() + 1;
- currentVersion = lastVersion;
- } else {
- lastVersion = oldTablePO.getLastVersion();
- currentVersion = oldTablePO.getCurrentVersion();
- }
Review Comment:
`table_version_info` does not include `table_name` field
--
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]
