Apache Flink

I’m getting:
```Exception in thread "main" java.lang.RuntimeException: JavaCodeSplitter failed. This is a bug. Please file an issue.```
It’s a POC for a flink query that is quite big - 2MiB in size.
It’s doing a a UNION ALL on 100 kafka tables (topics), and to align them all in the same schema - I added `CASET(NULL AS STRING) AS X` (so it adds up to 300 field selects on each table).

I’m having trouble troubleshooting this, since it’s working when doing on 3 tables, but doesn’t work on all 100.

Any suggestions?

If so, then probably the query is too big 

If you could file an issue, it would be great. Don’t know if you could share the query, but that would be helpful