Flink SQL

Hi, I have a silly question about Flink SQL that I cannot seem to find a clear answer to. If I have the following code. Will the "result" from the sql SELECT statement only return and the data then be written to S3 if and only if the statement returns data that matches the criteria? Does "nothing

CEP Dynamic Patterns

Have dynamic patterns been introduced yet? Steve

Exception occurred while processing valve output watermark & NullPointerException

Any guidance would be most appreciated. Thx Steve === java.lang.RuntimeException: Exception occurred while processing valve output watermark: at org.apache.flink.streaming.runtime.io.StreamInputProcessor$ForwardingValveOutputHandler.handleWatermar

Kinesis Connector - NoClassDefFoundError

Hey all... upgrade from Flink 1.5.0 to 1.6.2 and for some reason cannot figure out what I missed in setting up the new environment. I am gettin this error: java.lang.NoClassDefFoundError: Could not initialize class org.apache.flink.kinesis.shaded.com.amazonaws.partitions.PartitionsLoader

Re: Could not find previous entry with key.

ink.streaming.runtime.io.StreamInputProcessor$ForwardingValveOutputHandler.handleWatermark(StreamInputProcessor.java:262) ... 7 more On Thu, Nov 15, 2018 at 8:13 AM Chesnay Schepler wrote: > Does the issue persist if you implement hashCode() in IoTEvent like this: > > @Overridep

Null Pointer Exception

lTimeServiceManager.java:108) at org.apache.flink.streaming.api.operators.AbstractStreamOperator.processWatermark(AbstractStreamOperator.java:734) at org.apache.flink.streaming.runtime.io.StreamInputProcessor$ForwardingValveOutputHandler.handleWatermark(StreamInputProcessor.java:262) ... 7 more Caused by: java.lang.NullPointerException Steve

Re:

scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) java.lang.OutOfMemoryError: Java heap space On Thu, Nov 15, 2018 at 8:23 PM Steve Bistline wrote: > > Well, hopefully the last problem with this project. > > Any thoughts would be appreciated > >

[no subject]

Well, hopefully the last problem with this project. Any thoughts would be appreciated = java.lang.RuntimeException: Exception occurred while processing valve output watermark: at org.apache.flink.streaming.runtime.io.StreamInputProcessor$Forwardin

Re: Writing to S3

> > Which makes me think you’re not excluding those properly. > > — Ken > > > On Nov 15, 2018, at 3:58 PM, Steve Bistline > wrote: > > I am trying to write out to S3 from Flink with the following code and > getting the error below. Tried adding the parser as a dependency

Writing to S3

I am trying to write out to S3 from Flink with the following code and getting the error below. Tried adding the parser as a dependency, etc. Any help would be appreciated Table result = tableEnv.sql("SELECT 'Alert ',t_sKey, t_deviceID, t_sValue FROM SENSORS WHERE t_sKey='TEMPERATURE' AND t_sValue

Could not find previous entry with key.

Any thoughts on where to start with this error would be appreciated. Caused by: java.lang.IllegalStateException: Could not find previous entry with key: first event, value: {"DEVICE_ID":f8a395a0-d3e2-11e8-b050-9779854d8172,"TIME_STAMP":11/15/2018 02:29:30.343 am,"TEMPERATURE":0.0,"HUMIDITY":"0.0"

Flink Question

I am having problems with the Flink Kinesis adapter. I have some native KCL code that works fine. I want to replace the .addSource with the CSV String data that is coming in from my KCL code. How can I do that? // Consume the data streams from AWS Kinesis stream DataStream dataStream = env.addSou

FLINK Kinesis Connector Error - ProvisionedThroughputExceededException

I am getting this error from the Flink Kinesis Connector. I have a native KCL app running in parallel with no problems. Any help would be appreciated Thanks so much!! Steve flink-sbistl919-taskexecutor-0-CACSVML-15736.log:2018-11-09 07:46:11,579 WARN org.apache.flink.streaming.connectors.k

ProvisionedThroughputExceededException

I am trying to use the Kinesis Connector and getting the following error message. I am not getting any data at all because of this. I have a native KCL client running in parallel and it is receiving data fine. Any thoughts? flink-sbistl919-taskexecutor-0-CACSVML-15736.log:2018-11-09 07:46:11,579

Kinesis Connector

I have tried just about everything to get a simple Flink application to consume from Kinesis. The application appears to connect ( I think ), no complaints... never receives any data. Even a very simple JAVA app see attached. Any help would be very much appreciated. Thanks -- Sent from: ht