It is good now. Sorry, my fault. I had multiple applications running and
both were using the socket stream . Thanks.
On Sun, Jul 22, 2018 at 8:22 PM, vino yang wrote:
> Hi anna,
>
> From the stack trace you provided, it's socket connect error not about
> Flink.
>
> So, Have you start a socket se
Hi anna,
>From the stack trace you provided, it's socket connect error not about
Flink.
So, Have you start a socket server at "localhost:"? Using a program or
CLI tool, such as "nc -l "
There is a example you can have a look[1].
[1]:
https://ci.apache.org/projects/flink/flink-docs-relea
It is not the code, but I don't know what the problem is.
A simple word count with socketTextStream used to work but now gives the
same error.
Apps with kafka source which used to work is giving the same error.
When I have a source generator within the app itself works good.
So, with socketTextSt
My object name is CreateUserNotificationRequests, thats why you see
CreateUserNotificationRequests
in the Error message.
I edited the object name after pasting the code...Hope there is no
confusion and I get some help.
Thanks
On Fri, Jul 20, 2018 at 10:10 AM, anna stax wrote:
> Hello all,
>
Hello all,
This is my code, just trying to make the code example in
https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/stream/
operators/process_function.html work
object ProcessFunctionTest {
def main(args: Array[String]) {
val env = StreamExecutionEnvironment.getExecutionEn
Hi anna,
Can you share your program and the exception stack trace and more details
about what's your source and state backend?
>From the information you provided, it seems Flink started a network connect
but timed out.
Thanks, vino.
2018-07-20 14:14 GMT+08:00 anna stax :
> Hi all,
>
> I am new
Hi, i've created a PR to fix scala and java examples and the error
suggested by Philippe.
Hope it will be helpful!!
Mauro
Il 09/03/2017 10:30, Kostas Kloudas ha scritto:
Hi Philippe,
You are right!
Thanks for reporting it!
We will fix it asap.
Kostas
On Mar 9, 2017, at 8:38 AM, Philippe C
Hi Philippe,
You are right!
Thanks for reporting it!
We will fix it asap.
Kostas
> On Mar 9, 2017, at 8:38 AM, Philippe Caparroy
> wrote:
>
> I think there is an error in the code snippet describing the ProcessFunction
> time out example :
> https://ci.apache.org/projects/flink/flink-docs
