RE: Problems to use toAppendStream
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
at
java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at
java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at
sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)
at
java.lang.ClassLoader.loadClass(ClassLoader.java:357)
What would be the reason for that ?
BR Esa
From: Esa Heikkinen [mailto:esa.heikki...@student.tut.fi]
Sent: Thursday, February 22, 2018 1:01 PM
To: Xingcan Cui
Cc: Fabian Hueske ; user@flink.apache.org
Subject: RE: Problems to use toAppendStream
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
mailto:esa.heikki...@student.tut.fi>>
Cc: Fabian Hueske mailto:fhue...@gmail.com>>;
user@flink.apache.org<mailto:user@flink.apache.org>
Subject: Re: Problems to use toAppendStream
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 5:20 PM, Xingcan Cui
mailto:xingc...@gmail.com>> wrote:
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
objects (e.g., org.apache.flink.table.api.scala._) and they are the same.
@Esa, you can temporarily solve the problem by importing
org.apache.flink.streaming.api.scala.asScalaStream in your code and we'll
continue working on this issue.
Best,
Xingcan
On 22 Feb 2018, at 4:47 PM, Esa Heikkinen
mailto:esa.heikki...@student.tut.fi>> wrote:
Hi
How to check versions ?
In pom.xml there are lines:
UTF-8
1.4.0
1.7.7
1.2.17
2.11
2.11.11
BR Esa
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Thursday, February 22, 2018 10:35 AM
To: Esa Heikkinen
mailto:esa.heikki...@student.tut.fi>>
Cc: Xingcan Cui mailto:xingc...@gmail.com>>;
user@flink.apache.org<mailto:user@flink.apache.org>
Subject: Re: Problems to use toAppendStream
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
mailto:esa.heikki...@student.tut.fi>>:
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.StreamExecutionEnvironment
import org.apache.flink.streaming.api.windowing.time.Time
import org.apache.flink.cep.scala.{CEP, PatternStream}
import org.apache.flink.cep.scala.pattern.Pattern
import org.apache.flink.cep.{PatternFlatSelectFunction,
PatternFlatTimeoutFunction}
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction
import
org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext
import org.apache.flink.util.Collector
import org.apache.flink.streaming.api.scala._
import org.apache.flink.api.scala._
import org.apache.flink.table.api.scala._
import org.apache.flink.table.api.scala.StreamTableEnvironment
import org.apache.flink.table.api.java.StreamTableEnvironment
import org.apache.flink.types.Row
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.{DataStream,
StreamExecutionEnvironment}
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.table.sources.CsvTableSource
import org.apache.flink.api.common.typeinfo.Types
BR Esa
From: Xingcan Cui [mailto:xingc...@gmail.com<mailto:xingc...@gmail.com>]
Sent: Thursday, February 22, 2018 10:09 AM
To: Esa Heikkinen
mailto:esa.heikki...@student.tut.fi>>
Cc: user@flink.apache.org&
RE: Problems to use toAppendStream
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 toAppendStream
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 5:20 PM, Xingcan Cui
mailto:xingc...@gmail.com>> wrote:
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
objects (e.g., org.apache.flink.table.api.scala._) and they are the same.
@Esa, you can temporarily solve the problem by importing
org.apache.flink.streaming.api.scala.asScalaStream in your code and we'll
continue working on this issue.
Best,
Xingcan
On 22 Feb 2018, at 4:47 PM, Esa Heikkinen
mailto:esa.heikki...@student.tut.fi>> wrote:
Hi
How to check versions ?
In pom.xml there are lines:
UTF-8
1.4.0
1.7.7
1.2.17
2.11
2.11.11
BR Esa
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Thursday, February 22, 2018 10:35 AM
To: Esa Heikkinen
mailto:esa.heikki...@student.tut.fi>>
Cc: Xingcan Cui mailto:xingc...@gmail.com>>;
user@flink.apache.org<mailto:user@flink.apache.org>
Subject: Re: Problems to use toAppendStream
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
mailto:esa.heikki...@student.tut.fi>>:
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.StreamExecutionEnvironment
import org.apache.flink.streaming.api.windowing.time.Time
import org.apache.flink.cep.scala.{CEP, PatternStream}
import org.apache.flink.cep.scala.pattern.Pattern
import org.apache.flink.cep.{PatternFlatSelectFunction,
PatternFlatTimeoutFunction}
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction
import
org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext
import org.apache.flink.util.Collector
import org.apache.flink.streaming.api.scala._
import org.apache.flink.api.scala._
import org.apache.flink.table.api.scala._
import org.apache.flink.table.api.scala.StreamTableEnvironment
import org.apache.flink.table.api.java.StreamTableEnvironment
import org.apache.flink.types.Row
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.{DataStream,
StreamExecutionEnvironment}
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.table.sources.CsvTableSource
import org.apache.flink.api.common.typeinfo.Types
BR Esa
From: Xingcan Cui [mailto:xingc...@gmail.com<mailto:xingc...@gmail.com>]
Sent: Thursday, February 22, 2018 10:09 AM
To: Esa Heikkinen
mailto:esa.heikki...@student.tut.fi>>
Cc: user@flink.apache.org<mailto:user@flink.apache.org>
Subject: Re: Problems to use toAppendStream
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
mailto:esa.heikki...@student.tut.fi>> 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 IntelliJ
editor. What does this mean ?
But the same errors will still be generated.
Esa
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Wednesday, February 21, 2018 9:41 PM
To: Esa Heikkinen
mailto:esa.heikki...@student.tut.fi>>
Cc: user@flink.apache.org<mailto:user@flink.apache.org>
Subject: Re: Problems to use toAppendStream
Hi Esa,
whenever you observe the error "could not find implicit value for evidence
parameter of type X" in a streaming program, you need to add the following
import:
import org.apache.flink.streaming.api.scala._
Best, Fabian
2018-0
Re: Problems to use toAppendStream
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 5:20 PM, Xingcan Cui wrote:
>
> 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
> objects (e.g., org.apache.flink.table.api.scala._) and they are the same.
>
> @Esa, you can temporarily solve the problem by importing
> org.apache.flink.streaming.api.scala.asScalaStream in your code and we'll
> continue working on this issue.
>
> Best,
> Xingcan
>
>> On 22 Feb 2018, at 4:47 PM, Esa Heikkinen > <mailto:esa.heikki...@student.tut.fi>> wrote:
>>
>> Hi
>>
>> How to check versions ?
>>
>> In pom.xml there are lines:
>>
>>
>>
>> UTF-8
>>
>> 1.4.0
>>
>> 1.7.7
>>
>> 1.2.17
>>
>> 2.11
>>
>> 2.11.11
>>
>>
>> BR Esa
>>
>> From: Fabian Hueske [mailto:fhue...@gmail.com <mailto:fhue...@gmail.com>]
>> Sent: Thursday, February 22, 2018 10:35 AM
>> To: Esa Heikkinen > <mailto:esa.heikki...@student.tut.fi>>
>> Cc: Xingcan Cui mailto:xingc...@gmail.com>>;
>> user@flink.apache.org <mailto:user@flink.apache.org>
>> Subject: Re: Problems to use toAppendStream
>>
>> 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 > <mailto:esa.heikki...@student.tut.fi>>:
>>
>>
>> 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.StreamExecutionEnvironment
>> import org.apache.flink.streaming.api.windowing.time.Time
>> import org.apache.flink.cep.scala.{CEP, PatternStream}
>> import org.apache.flink.cep.scala.pattern.Pattern
>> import org.apache.flink.cep.{PatternFlatSelectFunction,
>> PatternFlatTimeoutFunction}
>> import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
>> import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction
>> import
>> org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext
>> import org.apache.flink.util.Collector
>> import org.apache.flink.streaming.api.scala._
>> import org.apache.flink.api.scala._
>> import org.apache.flink.table.api.scala._
>> import org.apache.flink.table.api.scala.StreamTableEnvironment
>> import org.apache.flink.table.api.java.StreamTableEnvironment
>>
>>
>> import org.apache.flink.types.Row
>> import org.apache.flink.streaming.api.TimeCharacteristic
>> import org.apache.flink.streaming.api.scala.{DataStream,
>> StreamExecutionEnvironment}
>> import org.apache.flink.table.api.TableEnvironment
>> import org.apache.flink.table.sources.CsvTableSource
>> import org.apache.flink.api.common.typeinfo.Types
>>
>> BR Esa
>>
>> From: Xingcan Cui [mailto:xingc...@gmail.com <mailto:xingc...@gmail.com>]
>> Sent: Thursday, February 22, 2018 10:09 AM
>>
>> To: Esa Heikkinen > <mailto:esa.heikki...@student.tut.fi>>
>> Cc: user@flink.apache.org <mailto:user@flink.apache.org>
>> Subject: Re: Problems to use toAppendStream
>>
>> 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 > <mailto:esa.heikki...@student.tut.fi>> wrote:
>>
>> Hi
>>
>> Actually I have also line “import org
Re: Problems to use toAppendStream
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
objects (e.g., org.apache.flink.table.api.scala._) and they are the same.
@Esa, you can temporarily solve the problem by importing
org.apache.flink.streaming.api.scala.asScalaStream in your code and we'll
continue working on this issue.
Best,
Xingcan
> On 22 Feb 2018, at 4:47 PM, Esa Heikkinen
> wrote:
>
> Hi
>
> How to check versions ?
>
> In pom.xml there are lines:
>
>
>
> UTF-8
>
> 1.4.0
>
> 1.7.7
>
> 1.2.17
>
> 2.11
>
> 2.11.11
>
>
> BR Esa
>
> From: Fabian Hueske [mailto:fhue...@gmail.com]
> Sent: Thursday, February 22, 2018 10:35 AM
> To: Esa Heikkinen
> Cc: Xingcan Cui ; user@flink.apache.org
> Subject: Re: Problems to use toAppendStream
>
> 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 <mailto:esa.heikki...@student.tut.fi>>:
>
>
> 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.StreamExecutionEnvironment
> import org.apache.flink.streaming.api.windowing.time.Time
> import org.apache.flink.cep.scala.{CEP, PatternStream}
> import org.apache.flink.cep.scala.pattern.Pattern
> import org.apache.flink.cep.{PatternFlatSelectFunction,
> PatternFlatTimeoutFunction}
> import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
> import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction
> import
> org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext
> import org.apache.flink.util.Collector
> import org.apache.flink.streaming.api.scala._
> import org.apache.flink.api.scala._
> import org.apache.flink.table.api.scala._
> import org.apache.flink.table.api.scala.StreamTableEnvironment
> import org.apache.flink.table.api.java.StreamTableEnvironment
>
>
> import org.apache.flink.types.Row
> import org.apache.flink.streaming.api.TimeCharacteristic
> import org.apache.flink.streaming.api.scala.{DataStream,
> StreamExecutionEnvironment}
> import org.apache.flink.table.api.TableEnvironment
> import org.apache.flink.table.sources.CsvTableSource
> import org.apache.flink.api.common.typeinfo.Types
>
> BR Esa
>
> From: Xingcan Cui [mailto:xingc...@gmail.com <mailto:xingc...@gmail.com>]
> Sent: Thursday, February 22, 2018 10:09 AM
>
> To: Esa Heikkinen <mailto:esa.heikki...@student.tut.fi>>
> Cc: user@flink.apache.org <mailto:user@flink.apache.org>
> Subject: Re: Problems to use toAppendStream
>
> 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 <mailto:esa.heikki...@student.tut.fi>> 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 IntelliJ
> editor. What does this mean ?
>
> But the same errors will still be generated.
>
> Esa
>
> From: Fabian Hueske [mailto:fhue...@gmail.com <mailto:fhue...@gmail.com>]
> Sent: Wednesday, February 21, 2018 9:41 PM
> To: Esa Heikkinen <mailto:esa.heikki...@student.tut.fi>>
> Cc: user@flink.apache.org <mailto:user@flink.apache.org>
> Subject: Re: Problems to use toAppendStream
>
> Hi Esa,
>
> whenever you observe the error "could not find implicit value for evidence
> parameter of type X" in a streaming program, you need to add the following
> import:
>
> import org.apache.flink.streaming.api.scala._
>
> Best, Fabian
>
> 2018-02-21 19:49 GMT+01:00 Esa Heikkinen <mailto:heikk...@student.tut.fi>>:
>
> Hi
>
>
> I have tried to so
RE: Problems to use toAppendStream
Hi
How to check versions ?
In pom.xml there are lines:
UTF-8
1.4.0
1.7.7
1.2.17
2.11
2.11.11
BR Esa
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Thursday, February 22, 2018 10:35 AM
To: Esa Heikkinen
Cc: Xingcan Cui ; user@flink.apache.org
Subject: Re: Problems to use toAppendStream
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
mailto:esa.heikki...@student.tut.fi>>:
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.StreamExecutionEnvironment
import org.apache.flink.streaming.api.windowing.time.Time
import org.apache.flink.cep.scala.{CEP, PatternStream}
import org.apache.flink.cep.scala.pattern.Pattern
import org.apache.flink.cep.{PatternFlatSelectFunction,
PatternFlatTimeoutFunction}
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction
import
org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext
import org.apache.flink.util.Collector
import org.apache.flink.streaming.api.scala._
import org.apache.flink.api.scala._
import org.apache.flink.table.api.scala._
import org.apache.flink.table.api.scala.StreamTableEnvironment
import org.apache.flink.table.api.java.StreamTableEnvironment
import org.apache.flink.types.Row
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.{DataStream,
StreamExecutionEnvironment}
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.table.sources.CsvTableSource
import org.apache.flink.api.common.typeinfo.Types
BR Esa
From: Xingcan Cui [mailto:xingc...@gmail.com<mailto:xingc...@gmail.com>]
Sent: Thursday, February 22, 2018 10:09 AM
To: Esa Heikkinen
mailto:esa.heikki...@student.tut.fi>>
Cc: user@flink.apache.org<mailto:user@flink.apache.org>
Subject: Re: Problems to use toAppendStream
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
mailto:esa.heikki...@student.tut.fi>> 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 IntelliJ
editor. What does this mean ?
But the same errors will still be generated.
Esa
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Wednesday, February 21, 2018 9:41 PM
To: Esa Heikkinen
mailto:esa.heikki...@student.tut.fi>>
Cc: user@flink.apache.org<mailto:user@flink.apache.org>
Subject: Re: Problems to use toAppendStream
Hi Esa,
whenever you observe the error "could not find implicit value for evidence
parameter of type X" in a streaming program, you need to add the following
import:
import org.apache.flink.streaming.api.scala._
Best, Fabian
2018-02-21 19:49 GMT+01:00 Esa Heikkinen
mailto:heikk...@student.tut.fi>>:
Hi
I have tried to solve below Errors for long time, but no succeed yet. Could you
give some hint how to solve it ?
Errors in compiling:
--
Error:(56, 46) could not find implicit value for evidence parameter of type
org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]
val stream = tableEnv.toAppendStream[Row](tableTest)
Error:(56, 46) not enough arguments for method toAppendStream: (implicit
evidence$3:
org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row])org.apache.flink.streaming.api.scala.DataStream[org.apache.flink.types.Row].
Unspecified value parameter evidence$3.
val stream = tableEnv.toAppendStream[Row](tableTest)
Code:
-
import org.apache.flink.types.Row
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.{DataStream,
StreamExecutionEnvironment}
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.table.sources.CsvTableSource
import org.apache.flink.api.common.typeinfo.Types
object CepTest2 {
def main(args: Array[String]) {
println("Start ...")
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
//val tableEnv
Re: Problems to use toAppendStream
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.
>
>
>
> import org.apache.flink.streaming.api.windowing.time.Time
>
> import org.apache.flink.api.java.utils.ParameterTool
>
> import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
>
> import org.apache.flink.streaming.api.windowing.time.Time
>
> import org.apache.flink.cep.scala.{CEP, PatternStream}
>
> import org.apache.flink.cep.scala.pattern.Pattern
>
> import org.apache.flink.cep.{PatternFlatSelectFunction,
> PatternFlatTimeoutFunction}
>
> import org.apache.flink.streaming.api.datastream.
> SingleOutputStreamOperator
>
> import org.apache.flink.streaming.api.functions.source.
> ParallelSourceFunction
>
> import org.apache.flink.streaming.api.functions.source.
> SourceFunction.SourceContext
>
> import org.apache.flink.util.Collector
>
> import org.apache.flink.streaming.api.scala._
>
> import org.apache.flink.api.scala._
>
> import org.apache.flink.table.api.scala._
>
> import org.apache.flink.table.api.scala.StreamTableEnvironment
>
> import org.apache.flink.table.api.java.StreamTableEnvironment
>
>
>
>
>
> import org.apache.flink.types.Row
>
> import org.apache.flink.streaming.api.TimeCharacteristic
>
> import org.apache.flink.streaming.api.scala.{DataStream,
> StreamExecutionEnvironment}
>
> import org.apache.flink.table.api.TableEnvironment
>
> import org.apache.flink.table.sources.CsvTableSource
>
> import org.apache.flink.api.common.typeinfo.Types
>
>
>
> BR Esa
>
>
>
> *From:* Xingcan Cui [mailto:xingc...@gmail.com]
> *Sent:* Thursday, February 22, 2018 10:09 AM
>
> *To:* Esa Heikkinen
> *Cc:* user@flink.apache.org
> *Subject:* Re: Problems to use toAppendStream
>
>
>
> 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
> IntelliJ editor. What does this mean ?
>
>
>
> But the same errors will still be generated.
>
>
>
> Esa
>
>
>
> *From:* Fabian Hueske [mailto:fhue...@gmail.com ]
> *Sent:* Wednesday, February 21, 2018 9:41 PM
> *To:* Esa Heikkinen
> *Cc:* user@flink.apache.org
> *Subject:* Re: Problems to use toAppendStream
>
>
>
> Hi Esa,
>
> whenever you observe the error "could not find implicit value for evidence
> parameter of type X" in a streaming program, you need to add the following
> import:
>
> import org.apache.flink.streaming.api.scala._
>
> Best, Fabian
>
>
>
> 2018-02-21 19:49 GMT+01:00 Esa Heikkinen :
>
>
>
> Hi
>
>
>
>
>
> I have tried to solve below Errors for long time, but no succeed yet. Could
> you give some hint how to solve it ?
>
>
>
> Errors in compiling:
>
> --
>
> Error:(56, 46) could not find implicit value for evidence parameter of type
> org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]
>
> val stream = tableEnv.toAppendStream[Row](tableTest)
>
>
>
> Error:(56, 46) not enough arguments for method toAppendStream: (implicit
> evidence$3:
> org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row])org.apache.flink.streaming.api.scala.DataStream[org.apache.flink.types.Row].
>
> Unspecified value parameter evidence$3.
>
> val stream = tableEnv.toAppendStream[Row](tableTest)
>
>
>
> Code:
>
> -
>
> import org.apache.flink.types.Row
>
> import org.apache.flink.streaming.api.TimeCharacteristic
>
> import org.apache.flink.streaming.api.scala.{DataStream,
> StreamExecutionEnvironment}
>
> import org.apache.flink.table.api.TableEnvironment
>
> import org.apache.flink.table.sources.CsvTableSource
>
> import org.apache.flink.api.common.typeinfo.Types
>
>
>
> object CepTest2 {
>
>
>
> def main(args: Array[String]) {
>
>
>
> println("Start ...")
>
>
>
> val env = StreamExecutionEnvironment.getExecutionEnvironment
>
> env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
>
>
>
> //val tableEnv = StreamTableEnvironment.getTableEnvironment
RE: Problems to use toAppendStream
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.StreamExecutionEnvironment
import org.apache.flink.streaming.api.windowing.time.Time
import org.apache.flink.cep.scala.{CEP, PatternStream}
import org.apache.flink.cep.scala.pattern.Pattern
import org.apache.flink.cep.{PatternFlatSelectFunction,
PatternFlatTimeoutFunction}
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction
import
org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext
import org.apache.flink.util.Collector
import org.apache.flink.streaming.api.scala._
import org.apache.flink.api.scala._
import org.apache.flink.table.api.scala._
import org.apache.flink.table.api.scala.StreamTableEnvironment
import org.apache.flink.table.api.java.StreamTableEnvironment
import org.apache.flink.types.Row
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.{DataStream,
StreamExecutionEnvironment}
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.table.sources.CsvTableSource
import org.apache.flink.api.common.typeinfo.Types
BR Esa
From: Xingcan Cui [mailto:xingc...@gmail.com]
Sent: Thursday, February 22, 2018 10:09 AM
To: Esa Heikkinen
Cc: user@flink.apache.org
Subject: Re: Problems to use toAppendStream
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
mailto:esa.heikki...@student.tut.fi>> 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 IntelliJ
editor. What does this mean ?
But the same errors will still be generated.
Esa
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Wednesday, February 21, 2018 9:41 PM
To: Esa Heikkinen
mailto:esa.heikki...@student.tut.fi>>
Cc: user@flink.apache.org<mailto:user@flink.apache.org>
Subject: Re: Problems to use toAppendStream
Hi Esa,
whenever you observe the error "could not find implicit value for evidence
parameter of type X" in a streaming program, you need to add the following
import:
import org.apache.flink.streaming.api.scala._
Best, Fabian
2018-02-21 19:49 GMT+01:00 Esa Heikkinen
mailto:heikk...@student.tut.fi>>:
Hi
I have tried to solve below Errors for long time, but no succeed yet. Could you
give some hint how to solve it ?
Errors in compiling:
--
Error:(56, 46) could not find implicit value for evidence parameter of type
org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]
val stream = tableEnv.toAppendStream[Row](tableTest)
Error:(56, 46) not enough arguments for method toAppendStream: (implicit
evidence$3:
org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row])org.apache.flink.streaming.api.scala.DataStream[org.apache.flink.types.Row].
Unspecified value parameter evidence$3.
val stream = tableEnv.toAppendStream[Row](tableTest)
Code:
-
import org.apache.flink.types.Row
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.{DataStream,
StreamExecutionEnvironment}
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.table.sources.CsvTableSource
import org.apache.flink.api.common.typeinfo.Types
object CepTest2 {
def main(args: Array[String]) {
println("Start ...")
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
//val tableEnv = StreamTableEnvironment.getTableEnvironment(env)
val tableEnv = TableEnvironment.getTableEnvironment(env)
val csvtable = CsvTableSource
.builder
.path("/home/esa/Log_EX1_gen_track_5.csv")
.ignoreFirstLine
.fieldDelimiter(",")
.field("time", Types.INT)
.field("id", Types.STRING)
.field("sources", Types.STRING)
.field("targets", Types.STRING)
.field("attr", Types.STRING)
.field("data", Types.STRING)
.build
tableEnv.registerTableSource("test", csvtable)
val tableTest =
tableEnv.scan("test").where("id='5'").select("id,sources,targets")
val stream = tableEnv.toAppendStream[Row](tableTest)
stream.print
env.execute()
}
}
Re: Problems to use toAppendStream
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 IntelliJ
> editor. What does this mean ?
>
> But the same errors will still be generated.
>
> Esa
>
> From: Fabian Hueske [mailto:fhue...@gmail.com <mailto:fhue...@gmail.com>]
> Sent: Wednesday, February 21, 2018 9:41 PM
> To: Esa Heikkinen <mailto:esa.heikki...@student.tut.fi>>
> Cc: user@flink.apache.org <mailto:user@flink.apache.org>
> Subject: Re: Problems to use toAppendStream
>
> Hi Esa,
>
> whenever you observe the error "could not find implicit value for evidence
> parameter of type X" in a streaming program, you need to add the following
> import:
>
> import org.apache.flink.streaming.api.scala._
>
> Best, Fabian
>
> 2018-02-21 19:49 GMT+01:00 Esa Heikkinen <mailto:heikk...@student.tut.fi>>:
>
> Hi
>
>
> I have tried to solve below Errors for long time, but no succeed yet. Could
> you give some hint how to solve it ?
>
> Errors in compiling:
> --
> Error:(56, 46) could not find implicit value for evidence parameter of type
> org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]
> val stream = tableEnv.toAppendStream[Row](tableTest)
>
> Error:(56, 46) not enough arguments for method toAppendStream: (implicit
> evidence$3:
> org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row])org.apache.flink.streaming.api.scala.DataStream[org.apache.flink.types.Row].
> Unspecified value parameter evidence$3.
> val stream = tableEnv.toAppendStream[Row](tableTest)
>
> Code:
> -
> import org.apache.flink.types.Row
> import org.apache.flink.streaming.api.TimeCharacteristic
> import org.apache.flink.streaming.api.scala.{DataStream,
> StreamExecutionEnvironment}
> import org.apache.flink.table.api.TableEnvironment
> import org.apache.flink.table.sources.CsvTableSource
> import org.apache.flink.api.common.typeinfo.Types
>
> object CepTest2 {
>
> def main(args: Array[String]) {
>
> println("Start ...")
>
> val env = StreamExecutionEnvironment.getExecutionEnvironment
> env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
>
> //val tableEnv = StreamTableEnvironment.getTableEnvironment(env)
> val tableEnv = TableEnvironment.getTableEnvironment(env)
>
> val csvtable = CsvTableSource
> .builder
> .path("/home/esa/Log_EX1_gen_track_5.csv")
> .ignoreFirstLine
> .fieldDelimiter(",")
> .field("time", Types.INT)
> .field("id", Types.STRING)
> .field("sources", Types.STRING)
> .field("targets", Types.STRING)
> .field("attr", Types.STRING)
> .field("data", Types.STRING)
> .build
>
> tableEnv.registerTableSource("test", csvtable)
>
> val tableTest =
> tableEnv.scan("test").where("id='5'").select("id,sources,targets")
>
> val stream = tableEnv.toAppendStream[Row](tableTest)
>
> stream.print
> env.execute()
> }
> }
>
RE: Problems to use toAppendStream
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 IntelliJ
editor. What does this mean ?
But the same errors will still be generated.
Esa
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Wednesday, February 21, 2018 9:41 PM
To: Esa Heikkinen
Cc: user@flink.apache.org
Subject: Re: Problems to use toAppendStream
Hi Esa,
whenever you observe the error "could not find implicit value for evidence
parameter of type X" in a streaming program, you need to add the following
import:
import org.apache.flink.streaming.api.scala._
Best, Fabian
2018-02-21 19:49 GMT+01:00 Esa Heikkinen
mailto:heikk...@student.tut.fi>>:
Hi
I have tried to solve below Errors for long time, but no succeed yet. Could you
give some hint how to solve it ?
Errors in compiling:
--
Error:(56, 46) could not find implicit value for evidence parameter of type
org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]
val stream = tableEnv.toAppendStream[Row](tableTest)
Error:(56, 46) not enough arguments for method toAppendStream: (implicit
evidence$3:
org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row])org.apache.flink.streaming.api.scala.DataStream[org.apache.flink.types.Row].
Unspecified value parameter evidence$3.
val stream = tableEnv.toAppendStream[Row](tableTest)
Code:
-
import org.apache.flink.types.Row
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.{DataStream,
StreamExecutionEnvironment}
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.table.sources.CsvTableSource
import org.apache.flink.api.common.typeinfo.Types
object CepTest2 {
def main(args: Array[String]) {
println("Start ...")
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
//val tableEnv = StreamTableEnvironment.getTableEnvironment(env)
val tableEnv = TableEnvironment.getTableEnvironment(env)
val csvtable = CsvTableSource
.builder
.path("/home/esa/Log_EX1_gen_track_5.csv")
.ignoreFirstLine
.fieldDelimiter(",")
.field("time", Types.INT)
.field("id", Types.STRING)
.field("sources", Types.STRING)
.field("targets", Types.STRING)
.field("attr", Types.STRING)
.field("data", Types.STRING)
.build
tableEnv.registerTableSource("test", csvtable)
val tableTest =
tableEnv.scan("test").where("id='5'").select("id,sources,targets")
val stream = tableEnv.toAppendStream[Row](tableTest)
stream.print
env.execute()
}
}
Re: Problems to use toAppendStream
Hi Esa,
whenever you observe the error "could not find implicit value for evidence
parameter of type X" in a streaming program, you need to add the following
import:
import org.apache.flink.streaming.api.scala._
Best, Fabian
2018-02-21 19:49 GMT+01:00 Esa Heikkinen :
>
> Hi
> I have tried to solve below Errors for long time, but no succeed yet. Could
> you give some hint how to solve it ?
> Errors in compiling:
> --Error:(56, 46) could not find implicit value for evidence
> parameter of type
> org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]
> val stream = tableEnv.toAppendStream[Row](tableTest)
> Error:(56, 46) not enough arguments for method toAppendStream: (implicit
> evidence$3:
> org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row])org.apache.flink.streaming.api.scala.DataStream[org.apache.flink.types.Row].Unspecified
> value parameter evidence$3.
> val stream = tableEnv.toAppendStream[Row](tableTest)
>
> Code:
> -
> import org.apache.flink.types.Rowimport
> org.apache.flink.streaming.api.TimeCharacteristicimport
> org.apache.flink.streaming.api.scala.{DataStream,
> StreamExecutionEnvironment}import
> org.apache.flink.table.api.TableEnvironmentimport
> org.apache.flink.table.sources.CsvTableSourceimport
> org.apache.flink.api.common.typeinfo.Types
> object CepTest2 {
>
> def main(args: Array[String]) {
>
> println("Start ...")
>
> val env = StreamExecutionEnvironment.getExecutionEnvironment
> env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
>
> //val tableEnv = StreamTableEnvironment.getTableEnvironment(env)
> val tableEnv = TableEnvironment.getTableEnvironment(env)
>
> val csvtable = CsvTableSource
> .builder
> .path("/home/esa/Log_EX1_gen_track_5.csv")
> .ignoreFirstLine
> .fieldDelimiter(",")
> .field("time", Types.INT)
> .field("id", Types.STRING)
> .field("sources", Types.STRING)
> .field("targets", Types.STRING)
> .field("attr", Types.STRING)
> .field("data", Types.STRING)
> .build
>
> tableEnv.registerTableSource("test", csvtable)
>
> val tableTest =
> tableEnv.scan("test").where("id='5'").select("id,sources,targets")
>
> val stream = tableEnv.toAppendStream[Row](tableTest)
>
> stream.print
> env.execute()
> }}
>
>
>
>
