Re: Flink SQL Dates Between and Parallelism

Thank you Yuval! Will look into it first thing Monday morning, much appreciated. In the case where we aren't able to filter by anything else, is there anything else we can could potentially look into to help? Thank you Jason Politis Solutions Architect, Carrera Group carrera.io |

Flink SQL Dates Between and Parallelism

on how to force this to parallelize. Thank you Jason Politis Solutions Architect, Carrera Group carrera.io | jpoli...@carrera.io <http://us.linkedin.com/in/jasonpolitis>

What causes a task to change parallelism?

How can we go about pinpointing which part of our query belongs to that specific task? We have 104 tasks, so quickly pinpointing the exact part of the query would help us out alot. Thank you Jason Politis Solutions Architect, Carrera Group carrera.io | jpoli...@carrera.io <http://us.li

Re: Cannot load user class: avro GenericRecord

I realize those 2 specific ones are commented out, but I believe they are only used in flink-sql, and there's currently an issue when I include them in the pom. I might not have the repos correct. Thank you Jason Politis Solutions Architect, Carrera Group carrera.io | jpoli...@carre

Re: Cannot load user class: avro GenericRecord

'./connectors/flink-sql-avro-confluent-registry-1.14.0.jar:/opt/flink/lib/flink-sql-avro-confluent-registry-1.14.0.jar' - './connectors/flink-sql-connector-kafka_2.11-1.14.0.jar:/opt/flink/lib/flink-sql-connector-kafka_2.11-1.14.0.jar' Thank you Jason Politis Solutions Architect, Carre

Cannot load user class: avro GenericRecord

ectInputStream.java:2187) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1667) at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2405) at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2329) at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2187) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1667) at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503) at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461) at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:617) at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:602) at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:589) at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:543) at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:324) ... 9 more Any help, feedback, or advice would be greatly appreciated. Thank you Jason Politis Solutions Architect, Carrera Group carrera.io | jpoli...@carrera.io <http://us.linkedin.com/in/jasonpolitis>