git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Limitations with Retract Streams on SQL


I'm trying to get a stream of data from a Table I've formed with roughly this SQL:

SELECT
    user_id,
    count(msg),
    HOP_END(rowtime, INTERVAL '1' second, INTERVAL '1' minute)
FROM (SELECT rowtime, user_id, action_name AS msg FROM
          event_client_action
        WHERE /* various clauses */
        UNION SELECT rowtime, user_id, action_type AS msg FROM
           event_server_action
           WHERE /* various clauses */
      )
GROUP BY
HOP(rowtime, INTERVAL '1' second, INTERVAL '1' minute), user_id

If I try to get an append stream it tells me the table is not append only. If I try to get a retract stream it tells me:

Retraction on windowed GroupBy aggregation is not supported yet. Note: Windowed GroupBy aggregation should not follow a non-windowed GroupBy aggregation.

Note: The same query without the union clause works just fine.

The error message doesn't make sense to me because I do not think I'm doing a non-windowed GroupBy anywhere. Can anyone help me?

--
Gregory Fee
Engineer


( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-flink-users/msg09387.html on line 70
Call Stack
#TimeMemoryFunctionLocation
10.0007363544{main}( ).../msg09387.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-flink-users/msg09387.html on line 70
Call Stack
#TimeMemoryFunctionLocation
10.0007363544{main}( ).../msg09387.html:0