[
https://issues.apache.org/jira/browse/BEAM-2749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117433#comment-16117433
]
Xu Mingmin commented on BEAM-2749:
----------------------------------
[~takidau] I cannot reproduce the error, can you try below options?
1. run a {{mvn clean install}} in the whole beam project before run this
example with {{exec:java}}; --maybe we're using version '2.2.0-SNAPSHOT' and
mixed with the libraries in master branch;
2. or try the class in my dev branch
https://github.com/XuMingmin/beam/tree/BEAM-2749, run successfully locally,
hope it works in your env.
{code}
mvn -pl sdks/java/extensions/sql compile exec:java
-Dexec.mainClass=org.apache.beam.sdk.extensions.sql.example.BeamSqlExample
-Dexec.args="--runner=DirectRunner" -Pdirect-runner
{code}
Here is the error if it's related with {{-ea|-da}}:
{code}
Exception in thread "main" java.lang.AssertionError
at
org.apache.calcite.plan.volcano.VolcanoPlanner.changeTraits(VolcanoPlanner.java:546)
at
org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:365)
at
org.apache.calcite.prepare.PlannerImpl.transform(PlannerImpl.java:313)
at
org.apache.beam.sdk.extensions.sql.impl.planner.BeamQueryPlanner.convertToBeamRel(BeamQueryPlanner.java:148)
at
org.apache.beam.sdk.extensions.sql.impl.planner.BeamQueryPlanner.validateAndConvert(BeamQueryPlanner.java:139)
at
org.apache.beam.sdk.extensions.sql.impl.planner.BeamQueryPlanner.convertToBeamRel(BeamQueryPlanner.java:127)
at
org.apache.beam.sdk.extensions.sql.BeamSql$QueryTransform.expand(BeamSql.java:152)
at
org.apache.beam.sdk.extensions.sql.BeamSql$QueryTransform.expand(BeamSql.java:1)
at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:514)
at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:454)
at
org.apache.beam.sdk.values.PCollectionTuple.apply(PCollectionTuple.java:159)
at
org.apache.beam.sdk.extensions.sql.BeamSql$SimpleQueryTransform.expand(BeamSql.java:240)
at
org.apache.beam.sdk.extensions.sql.BeamSql$SimpleQueryTransform.expand(BeamSql.java:1)
at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:514)
at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:454)
at org.apache.beam.sdk.values.PCollection.apply(PCollection.java:284)
at
org.apache.beam.sdk.extensions.sql.example.BeamSqlExample.main(BeamSqlExample.java:66)
{code}
> update BeamSqlExample
> ---------------------
>
> Key: BEAM-2749
> URL: https://issues.apache.org/jira/browse/BEAM-2749
> Project: Beam
> Issue Type: Sub-task
> Components: dsl-sql
> Reporter: Xu Mingmin
> Assignee: Xu Mingmin
> Labels: dsl_sql_merge, dsl_sql_review
>
> change usage to reflect the latest status, and add an example with GROUP_BY
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
