[Calcite] Volcano planner fails to optimize

2016-06-21 Thread Zhangrucong
Hi everyone, I want to test calcite optimization of volcano planner with null cost factory. To avoid implementing some RelNodes and ConvertRules, I use BindableConvention trait set to transform converted RelNode. The QueryPlanner references to the implementation of SamzaSQL: https://github.com

How to make the window() of different partitions to start at different time?

2016-06-21 Thread Jack Huang
Hi all, I have a window() that performs external IO to a database (Aerospike). It seems that window() gets called at pretty much the same time for every partition. I want to make all containers to execute window() at different time so they distribute the IO load evenly across time. Is it possible?

Re: Location of the RocksDB Key-Value store

2016-06-21 Thread Jack Huang
Finally found it. Since I am using YARN, it is located under path specified by *yarn.nodemanager.local-dirs * On Sat, Jun 11, 2016 at 11:40 PM, David Yu wrote: > Not sure if it is configurable. But you should be able to find an entry in > your samza log like this: > > > /data/b/yarn/nm/usercache