Impala Public Jenkins has posted comments on this change. ( 
http://gerrit.cloudera.org:8080/17756 )

Change subject: [WIP]: Initial commit: Add logic to sync to latest event id
......................................................................


Patch Set 8:

(25 comments)

http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/events/MetastoreEventsProcessor.java
File 
fe/src/main/java/org/apache/impala/catalog/events/MetastoreEventsProcessor.java:

http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/events/MetastoreEventsProcessor.java@305
PS8, Line 305:           throws CatalogException, 
MetastoreNotificationException, ImpalaRuntimeException {
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java
File 
fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java:

http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@296
PS8, Line 296:   private final String SYNC_TABLE_LATEST_EVENT_ID_ERR_MSG = 
"Failed to sync table %s to " +
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@602
PS8, Line 602:                                             List<SQLForeignKey> 
sqlForeignKeys, List<SQLUniqueConstraint> sqlUniqueConstraints,
line too long (127 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@603
PS8, Line 603:                                             
List<SQLNotNullConstraint> sqlNotNullConstraints,
line too long (93 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@604
PS8, Line 604:                                             
List<SQLDefaultConstraint> sqlDefaultConstraints,
line too long (93 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@802
PS8, Line 802:     boolean response = super.drop_partition_by_name(dbname, 
tblname, partName, deleteData);
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@857
PS8, Line 857:     if (!catalog_.tryWriteLock(new 
org.apache.impala.catalog.Table[] {srcTbl, destinationTbl})) {
line too long (97 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@926
PS8, Line 926:       super.alter_partitions_with_environment_context(dbName, 
tblName, list, environmentContext);
line too long (97 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@933
PS8, Line 933:     super.alter_partitions_with_environment_context(dbName, 
tblName, list, environmentContext);
line too long (95 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@951
PS8, Line 951:     org.apache.impala.catalog.Table tbl = 
getTableAndAcquireWriteLock(alterPartitionsRequest.getDbName(),
line too long (105 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@1185
PS8, Line 1185:     Preconditions.checkState(syncToLatestEventId_,
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@1267
PS8, Line 1267:       MetastoreEvents.AlterTableEvent alterEvent = 
(MetastoreEvents.AlterTableEvent) event;
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@1272
PS8, Line 1272:       TTableName oldTTable = new 
TTableName(oldMsTable.getDbName(), oldMsTable.getTableName());
line too long (95 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@1273
PS8, Line 1273:       TTableName newTTable = new 
TTableName(newMsTable.getDbName(), newMsTable.getTableName());
line too long (95 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@1279
PS8, Line 1279:         throw new CatalogException("failed to rename table " + 
oldTTable + " to " + newTTable + " " +
line too long (101 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@1285
PS8, Line 1285:               DeleteEventLog.getTblKey(oldTTable.getDb_name(), 
oldTTable.getTable_name()));
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@1321
PS8, Line 1321:         renameTable(currentEventId, newTable.getDbName(), 
newTable.getTableName(), apiName);
line too long (92 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java@1327
PS8, Line 1327:           getTableAndAcquireWriteLock(newTable.getDbName(), 
newTable.getTableName(), apiName);
line too long (94 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java
File 
fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java:

http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java@3140
PS8, Line 3140:           LOG.debug("db {} does not exist in metastore. 
Removing it from catalog if exists ",
line too long (93 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/test/java/org/apache/impala/catalog/events/MetastoreEventsProcessorTest.java
File 
fe/src/test/java/org/apache/impala/catalog/events/MetastoreEventsProcessorTest.java:

http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/test/java/org/apache/impala/catalog/events/MetastoreEventsProcessorTest.java@2510
PS8, Line 2510:       String tblName, Map<String, String> params, boolean 
isPartitioned) throws TException {
line too long (92 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/test/java/org/apache/impala/catalog/events/MetastoreEventsProcessorTest.java@2635
PS8, Line 2635:   public static void createTableFromImpala(CatalogOpExecutor 
catalogOpExecutor, String dbName,
line too long (94 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/test/java/org/apache/impala/catalog/events/MetastoreEventsProcessorTest.java@3202
PS8, Line 3202:   public static void addPartitions(MetaStoreClient msClient, 
String dbName, String tblName,
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/test/java/org/apache/impala/catalog/metastore/CatalogHmsSyncToLatestEventIdTest.java
File 
fe/src/test/java/org/apache/impala/catalog/metastore/CatalogHmsSyncToLatestEventIdTest.java:

http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/test/java/org/apache/impala/catalog/metastore/CatalogHmsSyncToLatestEventIdTest.java@186
PS8, Line 186:             catalogHmsClient_.dropPartition(TEST_DB_NAME, 
tblName, Arrays.asList("3"), true);
line too long (93 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/test/java/org/apache/impala/catalog/metastore/CatalogHmsSyncToLatestEventIdTest.java@187
PS8, Line 187:             assertTrue("Table should have 2 partitions after 
dropping 1 out of 3 partitions",
line too long (93 > 90)


http://gerrit.cloudera.org:8080/#/c/17756/8/fe/src/test/java/org/apache/impala/catalog/metastore/CatalogHmsSyncToLatestEventIdTest.java@296
PS8, Line 296:     private void createDatabaseInHms(String catName, String 
dbName, Map<String, String> params)
line too long (95 > 90)



--
To view, visit http://gerrit.cloudera.org:8080/17756
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings

Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-MessageType: comment
Gerrit-Change-Id: Ia822d15725d0a9a9ad1398e10ed4ae3288d0e9ad
Gerrit-Change-Number: 17756
Gerrit-PatchSet: 8
Gerrit-Owner: Sourabh Goyal <[email protected]>
Gerrit-Reviewer: Impala Public Jenkins <[email protected]>
Gerrit-Comment-Date: Wed, 18 Aug 2021 13:24:47 +0000
Gerrit-HasComments: Yes

Reply via email to