Great, thanks for reporting back!
Best, Fabian
2018-03-20 22:40 GMT+01:00 karim amer :
> Never mind I found the error and has nothing to do with flink.
> Sorry
>
> On Tue, Mar 20, 2018 at 12:12 PM, karim amer
> wrote:
>
>> here is the output after fixing the scala issues
>>
>> https://gist.gith
Never mind I found the error and has nothing to do with flink.
Sorry
On Tue, Mar 20, 2018 at 12:12 PM, karim amer
wrote:
> here is the output after fixing the scala issues
>
> https://gist.github.com/karimamer/9e3bcf0a6d9110c01caa2ebd14aa7a8c
>
> On Tue, Mar 20, 2018 at 11:39 AM, karim amer
> w
here is the output after fixing the scala issues
https://gist.github.com/karimamer/9e3bcf0a6d9110c01caa2ebd14aa7a8c
On Tue, Mar 20, 2018 at 11:39 AM, karim amer
wrote:
> Never mind after importing
>
> import org.apache.flink.api.scala._
>
> theses errors went away and i still have the original
Never mind after importing
import org.apache.flink.api.scala._
theses errors went away and i still have the original problem.
Sorry my bad
On Tue, Mar 20, 2018 at 11:04 AM, karim amer
wrote:
> To clarify should i file a bug report on sbt hiding the errors in the
> previous email ?
>
> On Tue,
To clarify should i file a bug report on sbt hiding the errors in the
previous email ?
On Tue, Mar 20, 2018 at 9:44 AM, karim amer wrote:
> After switching to Maven from Sbt I got these errors
> Error:(63, 37) could not find implicit value for evidence parameter of
> type org.apache.flink.api.co
After switching to Maven from Sbt I got these errors
Error:(63, 37) could not find implicit value for evidence parameter of type
org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.quickstart.DataStreamtotableapi.Calls]
val namedStream = dataStream.map((value:String) => {
Er
Hi Fabian
Sorry if i confused you The first error is from Nico's code Not my code or
snippet
I am still having the original problem in my snippet where it's writing a
blank csv file even though i get
[success] Total time: 26 s, completed Mar 20, 2018 9:28:06 AM
After running the job
Cheers,
karim
Hi Karim,
I cannot find a method invocation "tableEnv.registerDataStream("myTable2",
set, 'A, 'B, 'C )" as shown in the error message in your example.
It would help if you would keep error message and code consistent.
Otherwise it's not possible to figure out what's going on.
Best, Fabian
2018-0
Hi Nico,
I tried to reproduce your code but registerDataStream keeps failing to
register the fields even though i am following your code and the Docs.
here is the error
[error] found : Symbol
[error] required: org.apache.flink.table.expressions.Expression
[error] tableEnv.registerDataStrea
Hi Karim,
when I was trying to reproduce your code, I got an exception with the
name 'table' being used - by replacing it and completing the job with
some input, I did see the csv file popping up. Also, the job was
crashing when the file 1.txt already existed.
The code I used (running Flink 1.5-SN
10 matches
Mail list logo
