Skip to content

Commit 8fa7926

Browse files
committed
addressed multithreading issues
1 parent d3e3b72 commit 8fa7926

File tree

4 files changed

+7
-10
lines changed

4 files changed

+7
-10
lines changed

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/DefaultArguments.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
import com.google.common.base.Joiner;
2020
import com.google.common.base.MoreObjects;
2121
import com.google.common.base.Throwables;
22-
import com.google.edwmigration.dumper.application.dumper.metrics.DumperMetadata;
22+
import com.google.edwmigration.dumper.application.dumper.metrics.DumperInitialization;
2323
import java.io.IOException;
2424
import java.io.PrintStream;
2525
import java.util.*;
@@ -134,8 +134,9 @@ protected OptionSet parseOptions() throws Exception {
134134
System.exit(1);
135135
}
136136
if (o.has(versionOption)) {
137-
DumperMetadata dumperMetadata = StartUpMetaInfoProcessor.getDumperMetadata();
138-
String versionString = dumperMetadata.getVersion() + " : " + dumperMetadata.getGitCommit();
137+
DumperInitialization dumperInitialization = StartUpMetaInfoProcessor.getDumperMetadata();
138+
String versionString =
139+
dumperInitialization.getVersion() + " : " + dumperInitialization.getGitCommit();
139140
System.err.println(versionString);
140141
System.exit(1);
141142
}

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/TasksRunner.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -46,9 +46,7 @@
4646
import org.slf4j.Logger;
4747
import org.slf4j.LoggerFactory;
4848

49-
/**
50-
* @author ishmum
51-
*/
49+
/** @author ishmum */
5250
public class TasksRunner implements TaskRunContextOps {
5351

5452
private static final Logger logger = LoggerFactory.getLogger(TasksRunner.class);

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakeLogsConnector.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -428,8 +428,7 @@ enum TimeSeriesView {
428428
QueryAttributionHistoryFormat.Header.class,
429429
QueryAttributionHistoryFormat.ZIP_ENTRY_PREFIX,
430430
TimeSeriesColumn.END_TIME,
431-
SnowflakeLogsConnectorProperty.QUERY_ATTRIBUTION_HISTORY_OVERRIDE_QUERY
432-
),
431+
SnowflakeLogsConnectorProperty.QUERY_ATTRIBUTION_HISTORY_OVERRIDE_QUERY),
433432
REPLICATION_GROUP_USAGE_HISTORY(
434433
ReplicationGroupUsageHistoryFormat.Header.class,
435434
ReplicationGroupUsageHistoryFormat.ZIP_ENTRY_PREFIX,

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakeLogsConnectorProperty.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,8 +49,7 @@ enum SnowflakeLogsConnectorProperty implements ConnectorProperty {
4949
"Custom query for query acceleration history dump"),
5050
QUERY_ATTRIBUTION_HISTORY_OVERRIDE_QUERY(
5151
"snowflake.query_attribution_history.query",
52-
"Custom query for query attribution history dump"
53-
),
52+
"Custom query for query attribution history dump"),
5453
REPLICATION_GROUP_USAGE_HISTORY_OVERRIDE_QUERY(
5554
"snowflake.replication_group_usage_history.query",
5655
"Custom query for replication group usage history dump"),

0 commit comments

Comments
 (0)