Skip to content

Commit e323f86

Browse files
committed
chore(example): 添加重试sleep时间
1 parent 3cd5b9e commit e323f86

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

odps-examples/tunnel-examples/src/main/java/SchemaEvolution/StreamUploadIfSchemaEvolutionExpectedSample.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,7 @@ private static TableTunnel.StreamUploadSession rebuildSessionUtilSchemaEvolution
152152
.build();
153153
System.out.println("Session Schema: " + debugString(session.getSchema()));
154154
System.out.println("Table Schema: " + debugString(odps.tables().get(project, table).getSchema()));
155-
155+
TimeUnit.SECONDS.sleep(5);
156156
} while (!basicallyEquals(odps.tables().get(project, table).getSchema()
157157
, session.getSchema()));
158158
return session;

odps-examples/tunnel-examples/src/main/java/SchemaEvolution/StreamUploadIfSchemaEvolutionUnexpectedSample.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ private static TableTunnel.StreamUploadSession rebuildSessionUtilSchemaEvolution
163163
.build();
164164
System.out.println("Session Schema: " + debugString(session.getSchema()));
165165
System.out.println("Table Schema: " + debugString(odps.tables().get(project, table).getSchema()));
166-
166+
TimeUnit.SECONDS.sleep(5);
167167
} while (!basicallyEquals(odps.tables().get(project, table).getSchema()
168168
, session.getSchema()));
169169
return session;

0 commit comments

Comments
 (0)