No value present when joining two tables

[alexhafner]

Given two tables

CREATE TABLE pageviews_avg_1b \
    AS SELECT \
        userid, \
      SUM(viewtime) AS sum_viewtime, \
      MIN(viewtime) AS min_viewtime, \
      MAX(viewtime) AS max_viewtime, \
      COUNT(*) AS view_count \
    FROM pageviews \
    WINDOW SESSION (60 SECONDS) GROUP BY userid;
    
    CREATE TABLE pageviews_avg_5b \
    AS SELECT \
        userid, \
      SUM(viewtime) AS sum_viewtime, \
      MIN(viewtime) AS min_viewtime, \
      MAX(viewtime) AS max_viewtime, \
      COUNT(*) AS view_count \
    FROM pageviews \
    WINDOW SESSION (300 SECONDS) GROUP BY userid;

which individually return results

We want to compare them with a query

SELECT \
    p1.view_count AS view_count_p1, \
    p5.view_count AS view_count_p5 \
FROM \
    pageviews_avg_1b p1 \
    LEFT JOIN pageviews_avg_5b p5 \
    ON p1.user_id   = p5.user_id;

The query returns immediately and the user interface returns "No value present".

Is this not supported?

[2017-09-22 15:27:02,565] ERROR No value present
java.util.Optional.get(Optional.java:135)
io.confluent.ksql.physical.PhysicalPlanBuilder.buildJoin(PhysicalPlanBuilder.java:506)
io.confluent.ksql.physical.PhysicalPlanBuilder.kafkaStreamsDsl(PhysicalPlanBuilder.java:112)
io.confluent.ksql.physical.PhysicalPlanBuilder.kafkaStreamsDsl(PhysicalPlanBuilder.java:104)
io.confluent.ksql.physical.PhysicalPlanBuilder.buildProject(PhysicalPlanBuilder.java:363)
io.confluent.ksql.physical.PhysicalPlanBuilder.kafkaStreamsDsl(PhysicalPlanBuilder.java:119)
io.confluent.ksql.physical.PhysicalPlanBuilder.kafkaStreamsDsl(PhysicalPlanBuilder.java:104)
io.confluent.ksql.physical.PhysicalPlanBuilder.buildOutput(PhysicalPlanBuilder.java:137)
io.confluent.ksql.physical.PhysicalPlanBuilder.kafkaStreamsDsl(PhysicalPlanBuilder.java:127)
io.confluent.ksql.physical.PhysicalPlanBuilder.kafkaStreamsDsl(PhysicalPlanBuilder.java:104)
io.confluent.ksql.physical.PhysicalPlanBuilder.buildPhysicalPlan(PhysicalPlanBuilder.java:100)
io.confluent.ksql.QueryEngine.buildQueryPhysicalPlan(QueryEngine.java:221)
io.confluent.ksql.QueryEngine.buildPhysicalPlans(QueryEngine.java:199)
io.confluent.ksql.KsqlEngine.planQueries(KsqlEngine.java:139)
io.confluent.ksql.KsqlEngine.buildMultipleQueries(KsqlEngine.java:125)
io.confluent.ksql.rest.server.resources.streaming.QueryStreamWriter.<init>(QueryStreamWriter.java:53)
io.confluent.ksql.rest.server.resources.streaming.StreamedQueryResource.streamQuery(StreamedQueryResource.java:68)
sun.reflect.GeneratedMethodAccessor51.invoke(Unknown Source)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory$1.invoke(ResourceMethodInvocationHandlerFactory.java:81)
org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:144)
org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:161)
org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$ResponseOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:160)
org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:99)
org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:389)
org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:347)
org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:102)
org.glassfish.jersey.server.ServerRuntime$2.run(ServerRuntime.java:326)
org.glassfish.jersey.internal.Errors$1.call(Errors.java:271)
org.glassfish.jersey.internal.Errors$1.call(Errors.java:267)
org.glassfish.jersey.internal.Errors.process(Errors.java:315)
org.glassfish.jersey.internal.Errors.process(Errors.java:297)
org.glassfish.jersey.internal.Errors.process(Errors.java:267)
org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:317)
org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:305)
org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:1154)
org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:473)
org.glassfish.jersey.servlet.ServletContainer.serviceImpl(ServletContainer.java:408)
org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:583)
org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:524)
org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:461)
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1652)
org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:585)
org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:221)
org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1127)
org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:515)
org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185)
org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1061)
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:110)
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:97)
org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:159)
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:97)
org.eclipse.jetty.server.Server.handle(Server.java:499)
org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:311)
org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:257)
org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:544)
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:635)
org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:555)
java.lang.Thread.run(Thread.java:748)
 (io.confluent.ksql.cli.console.Console:130)

[hjafarpour]

@alexhafner Currently, KSQL only supports Stream to Table LEFT JOIN.