Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line numberDiff line numberDiff line change
Expand Up@@ -113,7 +113,8 @@ public ViewConcurrencyAndFailureIT(String transactionProvider,
}

// name is used by failsafe as file name in reports
@Parameters(name="ViewIT_transactionProvider={0}, columnEncoded={1}")
@Parameters(name="ViewConcurrencyAndFailureIT_transactionProvider={0}, "
+ "columnEncoded={1}")
public static synchronized Collection<Object[]> data() {
return TestUtil.filterTxParamData(Arrays.asList(new Object[][] {
{ "TEPHRA", false }, { "TEPHRA", true },
Expand DownExpand Up@@ -629,7 +630,7 @@ public Thread newThread(Runnable r) {
Future<Exception> future = executorService.submit(
new CreateViewRunnable(fullTableName, fullViewName1));
// wait till the thread makes the rpc to add the column
boolean result = latch1.await(20, TimeUnit.MINUTES);
boolean result = latch1.await(2, TimeUnit.MINUTES);
if (!result) {
fail("The create view rpc look too long");
}
Expand DownExpand Up@@ -727,7 +728,7 @@ private void processTable(String tableName)
try {
// wait till the second task is complete before
// completing the first task
boolean result = latch2.await(20, TimeUnit.MINUTES);
boolean result = latch2.await(2, TimeUnit.MINUTES);
if (!result) {
throw new RuntimeException("Second task took too "
+ "long to complete");
Expand Down