Using table functions on table source results in NPE #4033
Comments
|
This is happening because the source is a SchemaKTable not a SchemaKStream - but the flat mapping code needs a SchemaKStream and the underlying KS KTable doesn't support FlatMap anyway. We could just explicitly disallow table functions where the source is a table. Easy workaround here is for the user to create the source as a stream, is there any advantage of them using a table here? |
purplefox
pushed a commit
to purplefox/ksql
that referenced
this issue
Dec 9, 2019
2 tasks
purplefox
added a commit
that referenced
this issue
Dec 10, 2019
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
To Reproduce
Steps to reproduce the behavior, include:
Add this test to
table-functions.json:{ "name": "with table source", "statements": [ "CREATE TABLE TEST (ID BIGINT, MY_ARR ARRAY<BIGINT>) WITH (kafka_topic='test_topic', KEY='ID', value_format='JSON');", "CREATE TABLE OUTPUT AS SELECT ID, EXPLODE(MY_ARR) VAL FROM TEST;" ], "inputs": [ {"topic": "test_topic", "key": 0, "value": {"ID": 0, "MY_ARR": [1, 2]}}, {"topic": "test_topic", "key": 1, "value": {"ID": 1, "MY_ARR": [3, 4]}} ], "outputs": [ {"topic": "OUTPUT", "key": "0", "value": {"ID": 0, "VAL": 1}}, {"topic": "OUTPUT", "key": "0", "value": {"ID": 0, "VAL": 2}}, {"topic": "OUTPUT", "key": "1", "value": {"ID": 1, "VAL": 3}}, {"topic": "OUTPUT", "key": "1", "value": {"ID": 1, "VAL": 4}} ] }Expected behavior
For the test case to pass, (may need some tweaking as its just a cut & paste job).
Actual behaviour
NPE thrown :
The text was updated successfully, but these errors were encountered: