diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/SubscopedTokenExternalVolumeManager.java b/src/main/java/net/snowflake/ingest/streaming/internal/SubscopedTokenExternalVolumeManager.java index 8f606b3dd..eb2ee0017 100644 --- a/src/main/java/net/snowflake/ingest/streaming/internal/SubscopedTokenExternalVolumeManager.java +++ b/src/main/java/net/snowflake/ingest/streaming/internal/SubscopedTokenExternalVolumeManager.java @@ -93,12 +93,12 @@ private InternalStage createStageForTable(TableRef tableRef) { this, clientName, getClientPrefix(), tableRef, locationInfo, DEFAULT_MAX_UPLOAD_RETRIES); } catch (SFException ex) { logger.logError( - "ExtVolManager.registerTable for tableRef=% failed with exception=%s", tableRef, ex); + "ExtVolManager.registerTable for tableRef={} failed with exception={}", tableRef, ex); // allow external volume ctor's SFExceptions to bubble up directly throw ex; } catch (Exception err) { logger.logError( - "ExtVolManager.registerTable for tableRef=% failed with exception=%s", tableRef, err); + "ExtVolManager.registerTable for tableRef={} failed with exception={}", tableRef, err); throw new SFException( err, ErrorCode.UNABLE_TO_CONNECT_TO_STAGE, @@ -127,7 +127,7 @@ static BlobPath generateBlobPathFromLocationInfoPath( String[] parts = filePathRelativeToVolume.split("/"); if (parts.length < 5) { logger.logError( - "Invalid file path returned by server. Table=%s FilePathRelativeToVolume=%s", + "Invalid file path returned by server. Table={} FilePathRelativeToVolume={}", fullyQualifiedTableName, filePathRelativeToVolume); throw new SFException(ErrorCode.INTERNAL_ERROR, "File path returned by server is invalid"); } @@ -166,17 +166,17 @@ public FileLocationInfo getRefreshedLocation(TableRef tableRef, Optional RefreshTableInformationResponse response = this.serviceClient.refreshTableInformation( new RefreshTableInformationRequest(tableRef, this.role, true)); - logger.logDebug("Refreshed tokens for table=%s", tableRef); + logger.logDebug("Refreshed tokens for table={}", tableRef); if (response.getIcebergLocationInfo() == null) { logger.logError( "Did not receive location info, this will cause ingestion to grind to a halt." - + " TableRef=%s"); + + " TableRef={}", tableRef); } else { Map creds = response.getIcebergLocationInfo().getCredentials(); if (creds == null || creds.isEmpty()) { logger.logError( "Did not receive creds in location info, this will cause ingestion to grind to a" - + " halt. TableRef=%s"); + + " halt. TableRef={}", tableRef); } }