Member since
05-30-2018
1322
Posts
715
Kudos Received
148
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
3370 | 08-20-2018 08:26 PM | |
1485 | 08-15-2018 01:59 PM | |
1890 | 08-13-2018 02:20 PM | |
3368 | 07-23-2018 04:37 PM | |
4078 | 07-19-2018 12:52 PM |
02-22-2016
09:26 PM
3 Kudos
I am trying to use SQuirrel on phoenix and it does not connect. Command line works ./sqlline.py localhost:/hbase-unsecure I installed the driver in SQuirrel lib directory. I am using driver phoenix-4.4.0.2.3.2.0-2950-client.jar which I pulled from the sandbox /usr/hdp/current/phoenix-client/ I have tried the following url and none work: jdbc:phoenix:localhost:2181:/hbase-unsecurejdbc:phoenix:localhost:/hbase-unsecurejdbc:phoenix:sandbox.hortonworks.com:2181:/hbase-unsecurejdbc:phoenix:sandbox.hortonworks.com:/hbase-unsecure Here is error: java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at net.sourceforge.squirrel_sql.client.mainframe.action.OpenConnectionCommand.awaitConnection(OpenConnectionCommand.java:132)
at net.sourceforge.squirrel_sql.client.mainframe.action.OpenConnectionCommand.access$100(OpenConnectionCommand.java:45)
at net.sourceforge.squirrel_sql.client.mainframe.action.OpenConnectionCommand$2.run(OpenConnectionCommand.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745) Detailed dump: 2016-02-22 16:00:38,691 [pool-11-thread-1] WARN org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper - Possibly transient ZooKeeper, quorum=sandbox.hortoworks.com:2181, exception=org.apache.zookeeper.KeeperException$OperationTimeoutException: KeeperErrorCode = OperationTimeout
2016-02-22 16:00:40,692 [pool-11-thread-1] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=sandbox.hortoworks.com:2181 sessionTimeout=90000 watcher=hconnection-0x7b5238300x0, quorum=sandbox.hortoworks.com:2181, baseZNode=/hbase-unsecure
2016-02-22 16:00:40,692 [pool-11-thread-1] WARN org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper - Unable to create ZooKeeper Connection
java.net.UnknownHostException: sandbox.hortoworks.com
at java.net.InetAddress.getAllByName0(InetAddress.java:1280)
at java.net.InetAddress.getAllByName(InetAddress.java:1192)
at java.net.InetAddress.getAllByName(InetAddress.java:1126)
at org.apache.zookeeper.client.StaticHostProvider.<init>(StaticHostProvider.java:61)
at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:445)
at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:380)
at org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper.checkZk(RecoverableZooKeeper.java:141)
at org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper.exists(RecoverableZooKeeper.java:221)
at org.apache.hadoop.hbase.zookeeper.ZKUtil.checkExists(ZKUtil.java:541)
at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.checkIfBaseNodeAvailable(ConnectionManager.java:895)
at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.access$400(ConnectionManager.java:545)
at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation$StubMaker.makeStubNoRetries(ConnectionManager.java:1483)
at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation$StubMaker.makeStub(ConnectionManager.java:1524)
at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation$MasterServiceStubMaker.makeStub(ConnectionManager.java:1553)
at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.getKeepAliveMasterService(ConnectionManager.java:1704)
at org.apache.hadoop.hbase.client.MasterCallable.prepare(MasterCallable.java:38)
at org.apache.hadoop.hbase.client.RpcRetryingCaller.callWithRetries(RpcRetryingCaller.java:124)
at org.apache.hadoop.hbase.client.HBaseAdmin.executeCallable(HBaseAdmin.java:3917)
at org.apache.hadoop.hbase.client.HBaseAdmin.getTableDescriptor(HBaseAdmin.java:441)
at org.apache.hadoop.hbase.client.HBaseAdmin.getTableDescriptor(HBaseAdmin.java:463)
at org.apache.phoenix.query.ConnectionQueryServicesImpl.ensureTableCreated(ConnectionQueryServicesImpl.java:815)
at org.apache.phoenix.query.ConnectionQueryServicesImpl.createTable(ConnectionQueryServicesImpl.java:1215)
at org.apache.phoenix.query.DelegateConnectionQueryServices.createTable(DelegateConnectionQueryServices.java:112)
at org.apache.phoenix.schema.MetaDataClient.createTableInternal(MetaDataClient.java:1902)
at org.apache.phoenix.schema.MetaDataClient.createTable(MetaDataClient.java:744)
at org.apache.phoenix.compile.CreateTableCompiler$2.execute(CreateTableCompiler.java:186)
at org.apache.phoenix.jdbc.PhoenixStatement$2.call(PhoenixStatement.java:304)
at org.apache.phoenix.jdbc.PhoenixStatement$2.call(PhoenixStatement.java:296)
at org.apache.phoenix.jdbc.PhoenixStatement.executeMutation(PhoenixStatement.java:294)
at org.apache.phoenix.jdbc.PhoenixStatement.executeUpdate(PhoenixStatement.java:1243)
at org.apache.phoenix.query.ConnectionQueryServicesImpl$12.call(ConnectionQueryServicesImpl.java:1893)
at org.apache.phoenix.query.ConnectionQueryServicesImpl$12.call(ConnectionQueryServicesImpl.java:1862)
at org.apache.phoenix.util.PhoenixContextExecutor.call(PhoenixContextExecutor.java:77)
at org.apache.phoenix.query.ConnectionQueryServicesImpl.init(ConnectionQueryServicesImpl.java:1862)
at org.apache.phoenix.jdbc.PhoenixDriver.getConnectionQueryServices(PhoenixDriver.java:180)
at org.apache.phoenix.jdbc.PhoenixEmbeddedDriver.connect(PhoenixEmbeddedDriver.java:132)
at org.apache.phoenix.jdbc.PhoenixDriver.connect(PhoenixDriver.java:151)
at net.sourceforge.squirrel_sql.fw.sql.SQLDriverManager.getConnection(SQLDriverManager.java:133)
at net.sourceforge.squirrel_sql.client.mainframe.action.OpenConnectionCommand.executeConnect(OpenConnectionCommand.java:167)
at net.sourceforge.squirrel_sql.client.mainframe.action.OpenConnectionCommand.access$000(OpenConnectionCommand.java:45)
at net.sourceforge.squirrel_sql.client.mainframe.action.OpenConnectionCommand$1.run(OpenConnectionCommand.java:104)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
... View more
Labels:
- Labels:
-
Apache HBase
-
Apache Phoenix
02-20-2016
04:30 AM
1 Kudo
Thanks @Chris Nauroth the NameNode can tell clients like MapReduce the locations of hosts that contain a replica of the block. MapReduce uses that information in its scheduling decisions, so if there are many MapReduce jobs that all need to read the same block, then having more replicas increases the chances for all of those concurrent tasks to be scheduled to a host containing a replica (and therefore getting a short-circuit read)
... View more
02-18-2016
06:18 PM
1 Kudo
@Benjamin Leonhardi Please excuse my lack of expertise in spark. If only a subset of R functions are available due to the translation into spark functions, what are the alternativeS to run the R functions which do not translate into spark functions?
... View more
02-18-2016
05:55 PM
1 Kudo
I found it the problem, it was the password. I issues the statement you gave and it still failed. Then I went into ambari and changed the password to password and it worked. thank you
... View more
02-18-2016
05:41 PM
1 Kudo
I am testing my ranger db connection on my sandbox it fails. I have not changed any password. using all defaults. Traceback (most recent call last): File "/var/lib/ambari-agent/cache/custom_actions/scripts/check_host.py", line 477, in <module>
CheckHost().execute()
File "/usr/lib/python2.6/site-packages/resource_management/libraries/script/script.py", line 219, in execute
method(env)
File "/var/lib/ambari-agent/cache/custom_actions/scripts/check_host.py", line 212, in actionexecute
raise Fail(error_message)
resource_management.core.exceptions.Fail: Check db_connection_check was unsuccessful. Exit code: 1. Message: ERROR: Unable to connect to the DB. Please check DB connection properties.
java.sql.SQLException: Access denied for user 'root'@'localhost' (using password: YES)
... View more
Labels:
- Labels:
-
Apache Ranger
02-18-2016
05:14 PM
1 Kudo
@Neeraj Sabharwal Transfer data using SFTP to hadoop.
... View more
02-18-2016
04:25 PM
1 Kudo
Thanks @Neeraj Sabharwal. Outside of NiFi, what other options do we have to pull data from SFTP if sqoop does not support it?
... View more
02-18-2016
04:03 PM
1 Kudo
Does phoenix allow role creation? i want to create roles on hbase and would like to avoid doing this on hbase command line. Ranger is not enabled yet so that is not an option. Any help?
... View more
Labels:
- Labels:
-
Apache HBase
-
Apache Phoenix
02-18-2016
04:00 PM
1 Kudo
Does Sqoop support SFTP protocol? Pulling data from mainframe using SFTP. I see FTP is used but not sftp https://sqoop.apache.org/docs/1.4.6/SqoopUserGuide.html
... View more
Labels:
- Labels:
-
Apache Sqoop
02-18-2016
05:23 AM
1 Kudo
@Neeraj Sabharwal Yes I did and it was very helpful. Appreciate you providing the awesome insights.
... View more