Skip to content

Commit

Permalink
log
Browse files Browse the repository at this point in the history
  • Loading branch information
morningman committed Dec 10, 2022
1 parent c134b59 commit f83bed0
Showing 1 changed file with 14 additions and 14 deletions.
28 changes: 14 additions & 14 deletions regression-test/suites/jsonb_p0/test_jsonb_load_and_function.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -52,23 +52,23 @@ suite("test_jsonb_load_and_function", "p0") {
}
log.info("Stream load result: ${result}".toString())
def json = parseJson(result)
assertEquals("fail", json.Status.toLowerCase())
assertEquals("too many filtered rows", json.Message)
assertEquals(25, json.NumberTotalRows)
assertEquals(18, json.NumberLoadedRows)
assertEquals(7, json.NumberFilteredRows)
assertTrue(json.LoadBytes > 0)
log.info("url: " + json.ErrorURL)

StringBuilder sb = new StringBuilder()
sb.append("curl -X GET " + json.ErrorURL)
String command = sb.toString()
// wait for cleaning stale_rowsets
def process = command.execute()
def code = process.waitFor()
def err = IOGroovyMethods.getText(new BufferedReader(new InputStreamReader(process.getErrorStream())))
def out = process.getText()
log.info("error result: " + out)

assertEquals("fail", json.Status.toLowerCase())
assertEquals("too many filtered rows", json.Message)
assertEquals(25, json.NumberTotalRows)
assertEquals(18, json.NumberLoadedRows)
assertEquals(7, json.NumberFilteredRows)
assertTrue(json.LoadBytes > 0)
log.info("url: " + json.ErrorURL)
}
}

Expand All @@ -91,21 +91,21 @@ suite("test_jsonb_load_and_function", "p0") {
}
log.info("Stream load result: ${result}".toString())
def json = parseJson(result)
assertEquals("success", json.Status.toLowerCase())
assertEquals(25, json.NumberTotalRows)
assertEquals(18, json.NumberLoadedRows)
assertEquals(7, json.NumberFilteredRows)
assertTrue(json.LoadBytes > 0)

StringBuilder sb = new StringBuilder()
sb.append("curl -X GET " + json.ErrorURL)
String command = sb.toString()
// wait for cleaning stale_rowsets
def process = command.execute()
def code = process.waitFor()
def err = IOGroovyMethods.getText(new BufferedReader(new InputStreamReader(process.getErrorStream())))
def out = process.getText()
log.info("error result: " + out)

assertEquals("success", json.Status.toLowerCase())
assertEquals(25, json.NumberTotalRows)
assertEquals(18, json.NumberLoadedRows)
assertEquals(7, json.NumberFilteredRows)
assertTrue(json.LoadBytes > 0)
}
}

Expand Down

0 comments on commit f83bed0

Please sign in to comment.