Repository: sqoop Updated Branches: refs/heads/sqoop2 162615742 -> 5f58a1d46
SQOOP-1850: Sqoop2: DerbyProvider retry ping (Abraham Elmahrek via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/5f58a1d4 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/5f58a1d4 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/5f58a1d4 Branch: refs/heads/sqoop2 Commit: 5f58a1d462caeeb5fd53449682115aacb1b063ff Parents: 1626157 Author: Jarek Jarcec Cecho <[email protected]> Authored: Mon Dec 8 09:25:57 2014 -0800 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Mon Dec 8 09:25:57 2014 -0800 ---------------------------------------------------------------------- .../org/apache/sqoop/common/test/db/DerbyProvider.java | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/5f58a1d4/common-test/src/main/java/org/apache/sqoop/common/test/db/DerbyProvider.java ---------------------------------------------------------------------- diff --git a/common-test/src/main/java/org/apache/sqoop/common/test/db/DerbyProvider.java b/common-test/src/main/java/org/apache/sqoop/common/test/db/DerbyProvider.java index 1546b97..a25a300 100644 --- a/common-test/src/main/java/org/apache/sqoop/common/test/db/DerbyProvider.java +++ b/common-test/src/main/java/org/apache/sqoop/common/test/db/DerbyProvider.java @@ -74,7 +74,17 @@ public class DerbyProvider extends DatabaseProvider { Future future = executorService.submit(new Callable<Object>() { @Override public Object call() throws Exception { - server.ping(); + while (true) { + try { + server.ping(); + break; + } catch (Exception e) { + LOG.warn("Could not ping derby server on port " + port, e); + } + + Thread.sleep(1000); + } + return null; } });
