Re: Help with Ignite Zeppelin Demo

2016-03-25 Thread vkulichenko 
Murthy,

SQL query documentation [1] and query example [2] are the best starting
points for using Ignite query API.

To start the console simply set 'IGNITE_H2_DEBUG_CONSOLE' system property
and it will be automatically opened in the browser. E.g., if you start a
standalone node using ignite.sh, execute it like this:

ignite.sh -J-DIGNITE_H2_DEBUG_CONSOLE

-Val

[1] https://apacheignite.readme.io/docs/sql-queries
[2]
https://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Help-with-Ignite-Zeppelin-Demo-tp3681p3689.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Help with Ignite Zeppelin Demo

2016-03-25 Thread Murthy Kakarlamudi 
Hi,
I attended Turbocharge SQL on Ignite webinar earlier in the week and
wanted to get familiar with the examples. I downloaded the code from
https://github.com/vkulichenko/zeppelin-demo and tried to run Query.java
after loading the data. I am getting the below error running Query 2.
Also I did not understand the part where in Load.java why the cache name
was set to null while creating the cache to load Persons.

 try (IgniteDataStreamer personStreamer =
ignite.dataStreamer(null)) { - Line 67 in Load.java

14:51:49] Ignite node started OK (id=f2e7030f)
[14:51:49] Topology snapshot [ver=4, servers=1, clients=1, CPUs=4,
heap=3.5GB]
500
50
Query 1:
Time: 293
Time: 71
Time: 65
Query 2:
[14:51:50] Ignite node stopped OK [uptime=00:00:00:848]
Exception in thread "main" javax.cache.CacheException: class
org.apache.ignite.IgniteException: Failed to bind parameters: [qry=SELECT
o.name as Organization, avg(p.salary) as Salary FROM Person p,
"Organizations".Organization o WHERE p.orgId = o.id AND p.managerId is null
GROUP BY o.name ORDER BY p.salary LIMIT 100, params=[10]]
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.query(IgniteCacheProxy.java:656)
at org.apache.ignite.zeppelin.Query.query(Query.java:58)
at org.apache.ignite.zeppelin.Query.main(Query.java:50)
Caused by: class org.apache.ignite.IgniteException: Failed to bind
parameters: [qry=SELECT o.name as Organization, avg(p.salary) as Salary
FROM Person p, "Organizations".Organization o WHERE p.orgId = o.id AND
p.managerId is null GROUP BY o.name ORDER BY p.salary LIMIT 100,
params=[10]]
at
org.apache.ignite.internal.processors.query.GridQueryProcessor.queryTwoStep(GridQueryProcessor.java:806)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.query(IgniteCacheProxy.java:647)
... 2 more
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to bind
parameters: [qry=SELECT o.name as Organization, avg(p.salary) as Salary
FROM Person p, "Organizations".Organization o WHERE p.orgId = o.id AND
p.managerId is null GROUP BY o.name ORDER BY p.salary LIMIT 100,
params=[10]]
at
org.apache.ignite.internal.processors.query.GridQueryProcessor.executeQuery(GridQueryProcessor.java:1782)
at
org.apache.ignite.internal.processors.query.GridQueryProcessor.queryTwoStep(GridQueryProcessor.java:799)
... 3 more
Caused by: javax.cache.CacheException: Failed to bind parameters:
[qry=SELECT o.name as Organization, avg(p.salary) as Salary FROM Person p,
"Organizations".Organization o WHERE p.orgId = o.id AND p.managerId is null
GROUP BY o.name ORDER BY p.salary LIMIT 100, params=[10]]
at
org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing.queryTwoStep(IgniteH2Indexing.java:1050)
at
org.apache.ignite.internal.processors.query.GridQueryProcessor$4.applyx(GridQueryProcessor.java:801)
at
org.apache.ignite.internal.processors.query.GridQueryProcessor$4.applyx(GridQueryProcessor.java:799)
at
org.apache.ignite.internal.util.lang.IgniteOutClosureX.apply(IgniteOutClosureX.java:36)
at
org.apache.ignite.internal.processors.query.GridQueryProcessor.executeQuery(GridQueryProcessor.java:1764)
... 4 more
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to bind
parameter [idx=1, obj=10, stmt=prep5: SELECT o.name as Organization,
avg(p.salary) as Salary FROM Person p, "Organizations".Organization o WHERE
p.orgId = o.id AND p.managerId is null GROUP BY o.name ORDER BY p.salary
LIMIT 100]
at
org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing.bindObject(IgniteH2Indexing.java:489)
at
org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing.bindParameters(IgniteH2Indexing.java:914)
at
org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing.queryTwoStep(IgniteH2Indexing.java:1047)
... 8 more
Caused by: org.h2.jdbc.JdbcSQLException: Invalid value "1" for parameter
"parameterIndex" [90008-175]
at org.h2.message.DbException.getJdbcSQLException(DbException.java:332)
at org.h2.message.DbException.get(DbException.java:172)
at org.h2.message.DbException.getInvalidValueException(DbException.java:218)
at
org.h2.jdbc.JdbcPreparedStatement.setParameter(JdbcPreparedStatement.java:1338)
at
org.h2.jdbc.JdbcPreparedStatement.setObject(JdbcPreparedStatement.java:451)
at
org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing.bindObject(IgniteH2Indexing.java:486)
... 10 more

Thanks,
Murthy.

Re: Help with Ignite-Zeppelin

2016-01-17 Thread babu prasad 
I was using Amazon EMR. Looks like there 1.4 jars.
Copied over the 1.5 jars, created a new ignite-jdbc.xml and updated the
jdbc url to use the new jdbc url.
Did the trick!

On Sun, Jan 17, 2016 at 3:50 PM, babu prasad  wrote:

> Hi,
>
> I have been trying to setup Zeppelin to talk to Apache Ignite, but no
> success.
>
> I have my ignite servers running on remote nodes.
> I keep getting this error.
>
> I followed this documentation to set it up -
> http://apacheignite.gridgain.org/v1.1/docs/data-analysis-with-apache-zeppelin
>
>
> ERROR [2016-01-17 23:44:24,598] ({pool-2-thread-2}
> IgniteSqlInterpreter.java[open]:100) - Can't open connection:
> java.sql.SQLException: Failed to establish connection.
> at
> org.apache.ignite.internal.jdbc.JdbcConnection.isValid(JdbcConnection.java:447)
> at
> org.apache.ignite.internal.jdbc.JdbcConnection.(JdbcConnection.java:123)
> at
> org.apache.ignite.IgniteJdbcDriver.connect(IgniteJdbcDriver.java:347)
> at java.sql.DriverManager.getConnection(DriverManager.java:571)
> at java.sql.DriverManager.getConnection(DriverManager.java:233)
> at
> org.apache.zeppelin.ignite.IgniteSqlInterpreter.open(IgniteSqlInterpreter.java:95)
> at
> org.apache.zeppelin.interpreter.ClassloaderInterpreter.open(ClassloaderInterpreter.java:74)
> at
> org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:68)
> at
> org.apache.zeppelin.interpreter.LazyOpenInterpreter.interpret(LazyOpenInterpreter.java:92)
> at
> org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:276)
> at org.apache.zeppelin.scheduler.Job.run(Job.java:170)
> at
> org.apache.zeppelin.scheduler.FIFOScheduler$1.run(FIFOScheduler.java:118)
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask.run(FutureTask.java:262)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: class
> org.apache.ignite.internal.client.GridClientDisconnectedException: Latest
> topology update failed.
> at
> org.apache.ignite.internal.client.impl.connection.GridClientTopology.nodes(GridClientTopology.java:335)
> at
> org.apache.ignite.internal.client.impl.GridClientAbstractProjection.projectionNodes(GridClientAbstractProjection.java:312)
> at
> org.apache.ignite.internal.client.impl.GridClientAbstractProjection.balancedNode(GridClientAbstractProjection.java:352)
> at
> org.apache.ignite.internal.client.impl.GridClientAbstractProjection.withReconnectHandling(GridClientAbstractProjection.java:109)
> at
> org.apache.ignite.internal.client.impl.GridClientComputeImpl.executeAsync(GridClientComputeImpl.java:132)
> at
> org.apache.ignite.internal.jdbc.JdbcConnection.isValid(JdbcConnection.java:444)
> ... 18 more
> Caused by: class
> org.apache.ignite.internal.client.GridServerUnreachableException: Failed to
> connect to any of the servers in list: [/127.0.0.1:40075]
> at
> org.apache.ignite.internal.client.impl.connection.GridClientConnectionManagerAdapter.connect(GridClientConnectionManagerAdapter.java:414)
> at
> org.apache.ignite.internal.client.impl.connection.GridClientConnectionManagerAdapter.init(GridClientConnectionManagerAdapter.java:226)
> at
> org.apache.ignite.internal.client.impl.GridClientImpl.tryInitTopology(GridClientImpl.java:498)
> at
> org.apache.ignite.internal.client.impl.GridClientImpl.(GridClientImpl.java:194)
> at
> org.apache.ignite.internal.client.GridClientFactory.start(GridClientFactory.java:58)
> at
> org.apache.ignite.internal.jdbc.JdbcConnection.(JdbcConnection.java:117)
> ... 17 more
> Caused by: java.net.ConnectException: Connection refused
> at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> at
> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
> at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:117)
> at
> org.apache.ignite.internal.client.impl.connection.GridClientNioTcpConnection.(GridClientNioTcpConnection.java:217)
> at
> org.apache.ignite.internal.client.impl.connection.GridClientConnectionManagerAdapter.connect(GridClientConnectionManagerAdapter.java:463)
> at
> org.apache.ignite.internal.client.impl.connection.GridClientConnectionManagerAdapter.connect(GridClientConnectionManagerAdapter.java:399)
>
>
>

Help with Ignite-Zeppelin

2016-01-17 Thread babu prasad 
Hi,

I have been trying to setup Zeppelin to talk to Apache Ignite, but no
success.

I have my ignite servers running on remote nodes.
I keep getting this error.

I followed this documentation to set it up -
http://apacheignite.gridgain.org/v1.1/docs/data-analysis-with-apache-zeppelin


ERROR [2016-01-17 23:44:24,598] ({pool-2-thread-2}
IgniteSqlInterpreter.java[open]:100) - Can't open connection:
java.sql.SQLException: Failed to establish connection.
at
org.apache.ignite.internal.jdbc.JdbcConnection.isValid(JdbcConnection.java:447)
at
org.apache.ignite.internal.jdbc.JdbcConnection.(JdbcConnection.java:123)
at org.apache.ignite.IgniteJdbcDriver.connect(IgniteJdbcDriver.java:347)
at java.sql.DriverManager.getConnection(DriverManager.java:571)
at java.sql.DriverManager.getConnection(DriverManager.java:233)
at
org.apache.zeppelin.ignite.IgniteSqlInterpreter.open(IgniteSqlInterpreter.java:95)
at
org.apache.zeppelin.interpreter.ClassloaderInterpreter.open(ClassloaderInterpreter.java:74)
at
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:68)
at
org.apache.zeppelin.interpreter.LazyOpenInterpreter.interpret(LazyOpenInterpreter.java:92)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:276)
at org.apache.zeppelin.scheduler.Job.run(Job.java:170)
at
org.apache.zeppelin.scheduler.FIFOScheduler$1.run(FIFOScheduler.java:118)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: class
org.apache.ignite.internal.client.GridClientDisconnectedException: Latest
topology update failed.
at
org.apache.ignite.internal.client.impl.connection.GridClientTopology.nodes(GridClientTopology.java:335)
at
org.apache.ignite.internal.client.impl.GridClientAbstractProjection.projectionNodes(GridClientAbstractProjection.java:312)
at
org.apache.ignite.internal.client.impl.GridClientAbstractProjection.balancedNode(GridClientAbstractProjection.java:352)
at
org.apache.ignite.internal.client.impl.GridClientAbstractProjection.withReconnectHandling(GridClientAbstractProjection.java:109)
at
org.apache.ignite.internal.client.impl.GridClientComputeImpl.executeAsync(GridClientComputeImpl.java:132)
at
org.apache.ignite.internal.jdbc.JdbcConnection.isValid(JdbcConnection.java:444)
... 18 more
Caused by: class
org.apache.ignite.internal.client.GridServerUnreachableException: Failed to
connect to any of the servers in list: [/127.0.0.1:40075]
at
org.apache.ignite.internal.client.impl.connection.GridClientConnectionManagerAdapter.connect(GridClientConnectionManagerAdapter.java:414)
at
org.apache.ignite.internal.client.impl.connection.GridClientConnectionManagerAdapter.init(GridClientConnectionManagerAdapter.java:226)
at
org.apache.ignite.internal.client.impl.GridClientImpl.tryInitTopology(GridClientImpl.java:498)
at
org.apache.ignite.internal.client.impl.GridClientImpl.(GridClientImpl.java:194)
at
org.apache.ignite.internal.client.GridClientFactory.start(GridClientFactory.java:58)
at
org.apache.ignite.internal.jdbc.JdbcConnection.(JdbcConnection.java:117)
... 17 more
Caused by: java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:117)
at
org.apache.ignite.internal.client.impl.connection.GridClientNioTcpConnection.(GridClientNioTcpConnection.java:217)
at
org.apache.ignite.internal.client.impl.connection.GridClientConnectionManagerAdapter.connect(GridClientConnectionManagerAdapter.java:463)
at
org.apache.ignite.internal.client.impl.connection.GridClientConnectionManagerAdapter.connect(GridClientConnectionManagerAdapter.java:399)