samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Milinda Pathirage" <mili...@apache.org>
Subject Re: Review Request 30667: Samza Calcite Integration Prototype (SAMZA-483)
Date Thu, 12 Feb 2015 03:47:42 GMT

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/30667/
-----------------------------------------------------------

(Updated Feb. 12, 2015, 3:47 a.m.)


Review request for samza, Chris Riccomini, Julian Hyde, and Yi Pan (Data Infrastructure).


Changes
-------

* Calcite based query planner code moved to 'org.apache.samza.sql.planner' package.
* Removed the schema factory prototype. It will be added later with schema-repo based implementaiton.


Repository: samza


Description
-------

# Samza Calcite Integration Prototype

- Supports simple stream query planning based on Calcite's 'chi' branch (https://github.com/julianhyde/incubator-calcite/tree/chi)
with STREAM support. 
- No query planning customizations specific to Samza yet.
- Calcite integration related code can be found under package 'org.apache.samza.sql.compiler'

## Next Steps

- Implement a compiler which converts query plan generated by Calcite to a set of Samza Jobs
- Integrate the Calcite query optimizer


Diffs (updated)
-----

  build.gradle b49c313 
  samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaCalciteConnection.java PRE-CREATION

  samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaQueryPreparingStatement.java PRE-CREATION

  samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java PRE-CREATION

  samza-sql/src/test/java/org/apache/samza/sql/planner/QueryPlannerTest.java PRE-CREATION

  samza-sql/src/test/java/org/apache/samza/sql/planner/SamzaStreamTableFactory.java PRE-CREATION


Diff: https://reviews.apache.org/r/30667/diff/


Testing (updated)
-------

./gradlew build was successful. But following errors were there in the console.


Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-2"

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-7"

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-6"

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-0"

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-9"

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-10"


Thanks,

Milinda Pathirage


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message