Re: Review Request 33280: [SAMZA-561] Basic streaming SQL query planning support

> On May 26, 2015, 7:40 a.m., Yi Pan (Data Infrastructure) wrote: > > samza-sql-core/src/main/java/org/apache/samza/sql/operators/scan/StreamScanSpec.java, > > line 28 > > > > > > Just a question: is this just a dummy

Re: Review Request 33280: [SAMZA-561] Basic streaming SQL query planning support

> On May 26, 2015, 7:40 a.m., Yi Pan (Data Infrastructure) wrote: > > samza-sql-calcite/src/main/java/org/apache/samza/sql/calcite/planner/ExecutionPlanner.java, > > line 189 > > > > > > The more I look at the use cas

Re: Review Request 33280: [SAMZA-561] Basic streaming SQL query planning support

> On May 26, 2015, 7:40 a.m., Yi Pan (Data Infrastructure) wrote: > > samza-sql-calcite/src/main/java/org/apache/samza/sql/calcite/schema/Stream.java, > > line 80 > > > > > > Question: do we have a way to specify the p

Re: Review Request 33280: [SAMZA-561] Basic streaming SQL query planning support

> On May 26, 2015, 7:40 a.m., Yi Pan (Data Infrastructure) wrote: > > build.gradle, line 408 > > > > > > You might need to re-base this change. Hi Yi, Did you mean rebase my local samza-sql branch with master? > On

Samza producer error

Hello, I’m testing my Samza application on a 3 nodes clusters. When the kafka producer thread starts to read incoming messages, it keeps throwing the following message on most of containers: 08:19:06.451 [kafka-producer-network-thread | samza_producer-app-1-1432642687162-2] WARN o.a.kafka.com

Re: Review Request 34626: SAMZA-688 Fix for YarnJobFactory not supporting 'https' filesystem

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34626/#review85155 --- Ship it! LGTM. Thanks! - Yi Pan (Data Infrastructure) On May 23,

Re: Review Request 33280: [SAMZA-561] Basic streaming SQL query planning support

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33280/#review85153 --- Overall looks good to me. Thanks a lot! I just had one comment to us