Comments (4)
Is this real time only?. Ping me on https://gitter.im/linkedin/pinot when
you get a chance
On Tue, Jul 21, 2015 at 4:34 PM, Joe Betz [email protected] wrote:
Just hit the below NPE, I believe it was triggered by this query:
SELECT COUNT(timestamp) FROM spans WHERE timestamp BETWEEN 1435708800 AND 1437519830 GROUP BY toServiceName
java.lang.NullPointerException
at com.linkedin.pinot.core.operator.MCombineOperator.trimToSize(MCombineOperator.java:257)
at com.linkedin.pinot.core.operator.MCombineOperator.nextBlock(MCombineOperator.java:246)
at com.linkedin.pinot.core.operator.UResultOperator.nextBlock(UResultOperator.java:52)
at com.linkedin.pinot.core.plan.GlobalPlanImplV0.execute(GlobalPlanImplV0.java:58)
at com.linkedin.pinot.core.query.executor.ServerQueryExecutorV1Impl.processQuery(ServerQueryExecutorV1Impl.java:133)
at com.linkedin.pinot.server.request.SimpleRequestHandler.processRequest(SimpleRequestHandler.java:81)
at com.linkedin.pinot.transport.netty.NettyServer$NettyChannelInboundHandler.channelRead(NettyServer.java:218)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
at java.lang.Thread.run(Thread.java:745)—
Reply to this email directly or view it on GitHub
#30.
from pinot.
Yes, real time only.
from pinot.
Thanks Joe. Can you list the contents of index directory on each of the
servers. In one of your earlier messages, you mentioned there were few
crashes. Did you clean up index directory before restarting?
If you haven't specified the data dir during start up, it should be under
/tmp/pinotServerData.
thanks,
Kishore G
On Aug 6, 2015 11:21 AM, "Joe Betz" [email protected] wrote:
Yes, real time only.
—
Reply to this email directly or view it on GitHub
#30 (comment).
from pinot.
closing hopelessly stale issues I've opened
from pinot.
Related Issues (20)
- Not able to set dimension table quota size beyond 200MB HOT 1
- Error in loading `Cluster Manager` page
- Table segment size is not showing up
- non-compliant download page: links should use closer.lua script
- Pinot not loading segments to deep storage, and deletes segments in tmp folders HOT 1
- Request: Flink connector enhancements HOT 2
- String to bytes autocasting HOT 6
- Allow peerDownload config for minion-tasks
- Consumption stops after a specified number of rows HOT 3
- Expose metadata for table freshness through Pinot's query response HOT 1
- Add unit test for segment pre-processor on all data types and index types HOT 2
- Configurable heap size for query and realtime segment persistence. HOT 7
- [Adaptive Server Selector] Extend the HYBRID type to cover query failures HOT 1
- [Adaptive Server Selector] support for strictReplicaGroup routing strategy HOT 3
- Add a config similar to `realtime.segment.flush.threshold.rows` but independent of partitions consumed by server HOT 3
- Consuming segment flush rows significantly reduced after force commit HOT 1
- Auto-tuning Pinot real-time segment size based on actual stream data consumption HOT 3
- Handle OFFLINE -> ONLINE state transition for consuming segment
- Add a test to check whether the HttpClientBuilder instance is updated with all the targeted configs passed to HttpClientConfig while building HttpClient.
- Provide pinot schema when initializing StreamMessageDecoder HOT 3
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from pinot.