Hi devs! When applying a Java UDF to a data stream which uses the push_twitter adapter, I get the following errors: "Failure while accessing a java record", "Cannot parse list item of type array". I've added the files from a minimal project reproducing the error in the gist below [1], as well as the log files describing the error.
It fails in the produceTuple method of the AssignRuntimeFactory.java class. When looking into the stack trace, there are two switch cases being ran at different times, both checking the typetag. The first time the typetag is a MULTISET, and the last time it is ANY. Connecting the data stream directly to a dataset Tweets (as is the documentation) works just fine, so the error is concerned with applying a Java UDF to the data stream. The following is not necessary for reproducing the bug, so I did not include it in the gist: For testing purposes, I attached a query predicate in the form of a Java UDF ( .. WHERE wordInTweet(TwitterFeed.text) = TRUE;), which checked whether the tweet contained a specific word in its text field, and logged. This query predicate ran just fine, but each time the result was TRUE, and the tweet was sent to the applied Java UDF, the same error as described in [1] occurred. I would be grateful if someone could check if they have the same problem. I am using an AsterixDB version with the decoupled ingestion framework provided by Xikui. Thanks in advance, Sandra [1] https://gist.github.com/sandraskars/4be177ce63d17aeed70e876fc17174f4
