You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ja...@apache.org on 2014/12/08 18:26:49 UTC
sqoop git commit: SQOOP-1850: Sqoop2: DerbyProvider retry ping
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 <ja...@apache.org>
Authored: Mon Dec 8 09:25:57 2014 -0800
Committer: Jarek Jarcec Cecho <ja...@apache.org>
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;
}
});