Well got it working.
The varchars in the database were set too small.
Thanks for your help!
Den fre. 22. maj 2020 kl. 13.30 skrev Martin Frank Hansen <
m...@berlingskemedia.dk>:
> Arh ok thanks, no problem.
>
> My problem is now that nothing is sent, do I need to format it in another
> way? Or
Is the sql-server jdbc jar in the flink dist lib folder?
On Fri, May 22, 2020 at 1:30 PM Martin Frank Hansen
wrote:
> Arh ok thanks, no problem.
>
> My problem is now that nothing is sent, do I need to format it in another
> way? Or did I miss something else?
>
> I tried to include Class.forName
Arh ok thanks, no problem.
My problem is now that nothing is sent, do I need to format it in another
way? Or did I miss something else?
I tried to include Class.forName(
"com.microsoft.sqlserver.jdbc.SQLServerDriver") but that didn't work.
Den fre. 22. maj 2020 kl. 11.57 skrev Flavio Pompermaie
No sorry, you're right. The JDBCOutputFormat should work..I get confused
with the Table API
On Fri, May 22, 2020 at 11:51 AM Martin Frank Hansen <
m...@berlingskemedia.dk> wrote:
> Hi again,
>
> I am a bit confused as to why the generic jdbc connector would not work
> with sql-server?
>
> Can you
Hi again,
I am a bit confused as to why the generic jdbc connector would not work
with sql-server?
Can you explain a bit more?
Den fre. 22. maj 2020 kl. 11.33 skrev Martin Frank Hansen <
m...@berlingskemedia.dk>:
> Hi Flavio,
>
> Thanks for your reply. I will try another way then.
>
>
> Den fr
Hi Flavio,
Thank you so much! Thought i had that import but misread it.
The code does not give any errors, but no data is written to the sql
server. Can you see why that is?
Den fre. 22. maj 2020 kl. 09.02 skrev Flavio Pompermaier <
pomperma...@okkam.it>:
> SQL server should not be supported
Hi Flavio,
Thanks for your reply. I will try another way then.
Den fre. 22. maj 2020 kl. 11.31 skrev Flavio Pompermaier <
pomperma...@okkam.it>:
> I expect you to see some exception somewhere, that sql server dialect is
> not supported yet.
>
> On Fri, May 22, 2020 at 11:29 AM Martin Frank Hans
I expect you to see some exception somewhere, that sql server dialect is
not supported yet.
On Fri, May 22, 2020 at 11:29 AM Martin Frank Hansen <
m...@berlingskemedia.dk> wrote:
> Hi Flavio,
>
> Thank you so much! Thought i had that import but misread it.
>
> The code does not give any errors, b
SQL server should not be supported from what I know..for this I opened a
PR[1] that I should rebase.
If someone is interested in I could do it
[1] https://github.com/apache/flink/pull/12038 (FLINK-14101 )
On Fri, May 22, 2020 at 8:35 AM Timo Walther wrote:
> Hi Martin,
>
> usually, this error o
Hi Martin,
usually, this error occurs when people forget to add
`org.apache.flink.api.scala._` to their imports. It is triggered by the
Scala macro that the DataStream API uses for extracting types.
Can you try to call `result.toAppendStream[Row]` directly? This should
work if you import `or
Hi,
I am trying to write input from Kafka to a SQL server on AWS, but I have
difficulties.
I get the following error could not find implicit value for evidence
parameter of type
org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]
[error] val dsRow = tableEnv.toAppen
11 matches
Mail list logo
