Something seems to be off with the user code class loader. The only way I
can get my job to start is if I drop the job into the lib folder in the JM
and configure the JM's classloader.resolve-order to parent-first.
Suggestions?
On Thu, Feb 22, 2018 at 12:52 PM, Elias Levy
wrote:
> I am current
I am currently suffering through similar issues.
Had a job running happily, but when it the cluster tried to restarted it
would not find the JSON serializer in it. The job kept trying to restart in
a loop.
Just today I was running a job I built locally. The job ran fine. I added
two commits and
An update - I was able to overcome these issues by setting the preallocate
flag to true. Not sure why this fixes the problem. Need to dig a bit deeper.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi Fabian,
Thank you for your suggestion. In the meantime I rethought this problem and
implemented alternative solution without using windows at all.
I used plain ProcessFunction with
1. Keyed state (by companyId) - to keep ratings per key
2. EventTime timers - to remove outdated ratings from stat
Hey, I am new to flink and I have a question and want to see if anyone can
help here.
How to use Dimension table in Flink TableAPI with StreamExecutionEnvironment ?
I use TableFuncion to deal this question, but it have some problem in debug
like this:
LogicalProject(col_1=[$0])
LogicalJoin(con
Hi
But next problem ☹
When I try to run I got error:
Exception in thread "main" java.lang.NoClassDefFoundError: scala/collection/Seq
at pack.CepTest2.main(CepTest2.scala)
Caused by: java.lang.ClassNotFoundException: scala.collection.Seq
a
Hello everyone,
I'm consuming from a Kafka topic, on which I'm writing with a
FlinkKafkaProducer, with the timestamp relative flag set to true.
>From what I gather from the documentation [1], Flink is aware of Kafka
Record's timestamp and only the watermark should be set with an appropriate
Times
Hi
It works now. Thank you ☺
How to know what the imports are incompatible or something like that ?
BR Esa
From: Xingcan Cui [mailto:xingc...@gmail.com]
Sent: Thursday, February 22, 2018 12:00 PM
To: Esa Heikkinen
Cc: Fabian Hueske ; user@flink.apache.org
Subject: Re: Problems to use toAppendS
Hi Esa and Fabian,
sorry for my inaccurate conclusion before, but I think the reason is clear now.
The org.apache.flink.streaming.api.scala._ and org.apache.flink.api.scala._
should not be imported simultaneously due to conflict. Just remove either of
them.
Best,
Xingcan
> On 22 Feb 2018, at
I have created a java application using flink api and table api. I can
provide the source code if needed.
The application works perfectly locally. But when I tried to upload the
created jar in aws lambda and execute it I'm being thrown with the following
error:
*reference.conf: 804: Could not res
Hi Fabian and Esa,
I ran the code myself and also noticed the strange behavior. It seems that only
I explicitly import the function i.e.,
org.apache.flink.streaming.api.scala.asScalaStream, can it works. In other
words, the underscore import becomes useless. I also checked other package
object
Hi
How to check versions ?
In pom.xml there are lines:
UTF-8
1.4.0
1.7.7
Hi Krzysztof,
you could compute the stats in two stages:
1) compute an daily window. You should use a ReduceFunction or
AggreagteFunction here if possible to perform the computation eagerly.
2) compute a sliding window of 90 days with a 1 day hop (or 90 rows with a
1 row hop).
That will crunch d
Hi Esa,
which Scala version do you use?
Flink supports Scala 2.11 (and Scala 2.10 support was dropped with Flink
1.4.0).
Fabian
2018-02-22 9:28 GMT+01:00 Esa Heikkinen :
>
>
>
> It should be ok. This is the list of my all imports. First part of it has
> been highlighted weaker. I don’t know why
It should be ok. This is the list of my all imports. First part of it has been
highlighted weaker. I don’t know why.
import org.apache.flink.streaming.api.windowing.time.Time
import org.apache.flink.api.java.utils.ParameterTool
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironm
Hi Esa,
just to remind that don’t miss the dot and underscore.
Best,
Xingcan
> On 22 Feb 2018, at 3:59 PM, Esa Heikkinen
> wrote:
>
> Hi
>
> Actually I have also line “import org.apache.flink.streaming.api.scala” on my
> code, but this line seems to be highlighted weaker in window of IDEA
16 matches
Mail list logo
