Skip to content
This repository was archived by the owner on Mar 23, 2026. It is now read-only.

Commit ed25591

Browse files
lqiu96lqiu96
committed
test: use generated table names to resolve flakiness in ITBigQueryTest
1 parent 31715ff commit ed25591

1 file changed

Lines changed: 22 additions & 18 deletions

File tree

‎google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it/ITBigQueryTest.java‎

Lines changed: 22 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -5988,10 +5988,10 @@ void testCopyJobStatistics() throws InterruptedException, TimeoutException {
59885988

59895989
@Test
59905990
void testSnapshotTableCopyJob() throws InterruptedException {
5991-
String sourceTableName = "test_copy_job_base_table";
5991+
String sourceTableName = generateTableName("test_copy_job_base_table");
59925992
String ddlTableName = TABLE_ID_SIMPLE.getTable();
59935993
// this creates a snapshot table at specified snapshotTime
5994-
String snapshotTableName = "test_snapshot_table";
5994+
String snapshotTableName = generateTableName("test_snapshot_table");
59955995
// Create source table with some data in it
59965996
String ddlQuery =
59975997
String.format(
@@ -6035,7 +6035,7 @@ void testSnapshotTableCopyJob() throws InterruptedException {
60356035
((SnapshotTableDefinition) snapshotTable.getDefinition()).getBaseTableId().getTable());
60366036

60376037
// Restore base table to a new table
6038-
String restoredTableName = "test_restore_table";
6038+
String restoredTableName = generateTableName("test_restore_table");
60396039
TableId restoredTableId = TableId.of(DATASET, restoredTableName);
60406040
CopyJobConfiguration restoreConfiguration =
60416041
CopyJobConfiguration.newBuilder(restoredTableId, snapshotTableId)
@@ -6451,7 +6451,7 @@ void testCancelNonExistingJob() {
64516451

64526452
@Test
64536453
void testInsertFromFile() throws InterruptedException, IOException, TimeoutException {
6454-
String destinationTableName = "test_insert_from_file_table";
6454+
String destinationTableName = generateTableName("test_insert_from_file_table");
64556455
TableId tableId = TableId.of(DATASET, destinationTableName);
64566456
WriteChannelConfiguration configuration =
64576457
WriteChannelConfiguration.newBuilder(tableId)
@@ -6524,7 +6524,7 @@ void testInsertFromFile() throws InterruptedException, IOException, TimeoutExcep
65246524

65256525
@Test
65266526
void testInsertFromFileWithLabels() throws InterruptedException, IOException, TimeoutException {
6527-
String destinationTableName = "test_insert_from_file_table_with_labels";
6527+
String destinationTableName = generateTableName("test_insert_from_file_table_with_labels");
65286528
TableId tableId = TableId.of(DATASET, destinationTableName);
65296529
WriteChannelConfiguration configuration =
65306530
WriteChannelConfiguration.newBuilder(tableId)
@@ -6555,7 +6555,8 @@ void testInsertFromFileWithLabels() throws InterruptedException, IOException, Ti
65556555
@Test
65566556
void testInsertWithDecimalTargetTypes()
65576557
throws InterruptedException, IOException, TimeoutException {
6558-
String destinationTableName = "test_insert_from_file_table_with_decimal_target_type";
6558+
String destinationTableName =
6559+
generateTableName("test_insert_from_file_table_with_decimal_target_type");
65596560
TableId tableId = TableId.of(DATASET, destinationTableName);
65606561
WriteChannelConfiguration configuration =
65616562
WriteChannelConfiguration.newBuilder(tableId)
@@ -6688,7 +6689,8 @@ void testLocation() throws Exception {
66886689
@Test
66896690
void testWriteChannelPreserveAsciiControlCharacters()
66906691
throws InterruptedException, IOException, TimeoutException {
6691-
String destinationTableName = "test_write_channel_preserve_ascii_control_characters";
6692+
String destinationTableName =
6693+
generateTableName("test_write_channel_preserve_ascii_control_characters");
66926694
TableId tableId = TableId.of(DATASET, destinationTableName);
66936695
WriteChannelConfiguration configuration =
66946696
WriteChannelConfiguration.newBuilder(tableId)
@@ -6736,7 +6738,7 @@ void testLoadJobPreserveAsciiControlCharacters() throws InterruptedException {
67366738
@Test
67376739
void testReferenceFileSchemaUriForAvro() {
67386740
try {
6739-
String destinationTableName = "test_reference_file_schema_avro";
6741+
String destinationTableName = generateTableName("test_reference_file_schema_avro");
67406742
TableId tableId = TableId.of(DATASET, destinationTableName);
67416743
Schema expectedSchema =
67426744
Schema.of(
@@ -6795,7 +6797,7 @@ void testReferenceFileSchemaUriForAvro() {
67956797
@Test
67966798
void testReferenceFileSchemaUriForParquet() {
67976799
try {
6798-
String destinationTableName = "test_reference_file_schema_parquet";
6800+
String destinationTableName = generateTableName("test_reference_file_schema_parquet");
67996801
TableId tableId = TableId.of(DATASET, destinationTableName);
68006802
Schema expectedSchema =
68016803
Schema.of(
@@ -6852,7 +6854,8 @@ void testReferenceFileSchemaUriForParquet() {
68526854

68536855
@Test
68546856
void testCreateExternalTableWithReferenceFileSchemaAvro() {
6855-
String destinationTableName = "test_create_external_table_reference_file_schema_avro";
6857+
String destinationTableName =
6858+
generateTableName("test_create_external_table_reference_file_schema_avro");
68566859
TableId tableId = TableId.of(DATASET, destinationTableName);
68576860
Schema expectedSchema =
68586861
Schema.of(
@@ -6891,7 +6894,8 @@ void testCreateExternalTableWithReferenceFileSchemaAvro() {
68916894

68926895
@Test
68936896
void testCreateExternalTableWithReferenceFileSchemaParquet() {
6894-
String destinationTableName = "test_create_external_table_reference_file_schema_parquet";
6897+
String destinationTableName =
6898+
generateTableName("test_create_external_table_reference_file_schema_parquet");
68956899
TableId tableId = TableId.of(DATASET, destinationTableName);
68966900
Schema expectedSchema =
68976901
Schema.of(
@@ -6932,9 +6936,9 @@ void testCreateExternalTableWithReferenceFileSchemaParquet() {
69326936

69336937
@Test
69346938
void testCloneTableCopyJob() throws InterruptedException {
6935-
String sourceTableName = "test_copy_job_base_table";
6939+
String sourceTableName = generateTableName("test_copy_job_base_table");
69366940
String ddlTableName = TABLE_ID_SIMPLE.getTable();
6937-
String cloneTableName = "test_clone_table";
6941+
String cloneTableName = generateTableName("test_clone_table");
69386942
// Create source table with some data in it
69396943
String ddlQuery =
69406944
String.format(
@@ -7510,7 +7514,7 @@ void testUniverseDomainWithMatchingDomain() {
75107514

75117515
@Test
75127516
void testExternalTableMetadataCachingNotEnable() throws InterruptedException {
7513-
String tableName = "test_metadata_cache_not_enable";
7517+
String tableName = generateTableName("test_metadata_cache_not_enable");
75147518
TableId tableId = TableId.of(DATASET, tableName);
75157519
ExternalTableDefinition externalTableDefinition =
75167520
ExternalTableDefinition.of(
@@ -7553,7 +7557,7 @@ void testExternalTableMetadataCachingNotEnable() throws InterruptedException {
75537557
void testExternalMetadataCacheModeFailForNonBiglake() {
75547558
// Validate that MetadataCacheMode is passed to the backend.
75557559
// TODO: Enhance this test after BigLake testing infrastructure is inplace.
7556-
String tableName = "test_metadata_cache_mode_fail_for_non_biglake";
7560+
String tableName = generateTableName("test_metadata_cache_mode_fail_for_non_biglake");
75577561
TableId tableId = TableId.of(DATASET, tableName);
75587562
ExternalTableDefinition externalTableDefinition =
75597563
ExternalTableDefinition.newBuilder(
@@ -7578,7 +7582,7 @@ void testExternalMetadataCacheModeFailForNonBiglake() {
75787582

75797583
@Test
75807584
void testObjectTable() throws InterruptedException {
7581-
String tableName = "test_object_table";
7585+
String tableName = generateTableName("test_object_table");
75827586
TableId tableId = TableId.of(DATASET, tableName);
75837587

75847588
String sourceUri = "gs://" + BUCKET + "/" + JSON_LOAD_FILE;
@@ -7649,7 +7653,7 @@ void testLoadConfigurationFlexibleColumnName() throws InterruptedException {
76497653
// mapping.
76507654

76517655
// Test v1 mapping.
7652-
String v1TableName = "flexible_column_name_data_testing_table_v1";
7656+
String v1TableName = generateTableName("flexible_column_name_data_testing_table_v1");
76537657
TableId v1TableId = TableId.of(DATASET, v1TableName);
76547658
try {
76557659
LoadJobConfiguration loadJobConfigurationV1 =
@@ -7674,7 +7678,7 @@ void testLoadConfigurationFlexibleColumnName() throws InterruptedException {
76747678
}
76757679

76767680
// Test v2 mapping.
7677-
String v2TableName = "flexible_column_name_data_testing_table_v2";
7681+
String v2TableName = generateTableName("flexible_column_name_data_testing_table_v2");
76787682
TableId v2TableId = TableId.of(DATASET, v2TableName);
76797683
try {
76807684
LoadJobConfiguration loadJobConfigurationV2 =

0 commit comments

Comments
 (0)