IIRC, that was recently fixed.
Might come out with 1.6.2 / 1.7.0.
Cheers, Fabian
Flavio Pompermaier schrieb am Do., 25. Okt. 2018,
14:09:
> Ok thanks! I wasn't aware of this..that would be undoubtedly useful ;)
> On Thu, Oct 25, 2018 at 2:00 PM Timo Walther wrote:
>
>> Hi Flavio,
>>
>> the
Ok thanks! I wasn't aware of this..that would be undoubtedly useful ;)
On Thu, Oct 25, 2018 at 2:00 PM Timo Walther wrote:
> Hi Flavio,
>
> the external catalog support is not feature complete yet. I think you can
> only specify the catalog when reading from a table but `insertInto` does
> not
Hi Flavio,
the external catalog support is not feature complete yet. I think you
can only specify the catalog when reading from a table but `insertInto`
does not consider the catalog name.
Regards,
TImo
Am 25.10.18 um 10:04 schrieb Flavio Pompermaier:
Any other help here? is this a bug or
Any other help here? is this a bug or something wrong in my code?
On Tue, Oct 23, 2018 at 9:02 AM Flavio Pompermaier
wrote:
> I've tried with t2, test.t2 and test.test.t2.
>
> On Mon, 22 Oct 2018, 19:26 Zhang, Xuefu, wrote:
>
>> Have you tried "t2" instead of "test.t2"? There is a possibility
I've tried with t2, test.t2 and test.test.t2.
On Mon, 22 Oct 2018, 19:26 Zhang, Xuefu, wrote:
> Have you tried "t2" instead of "test.t2"? There is a possibility that
> catalog name isn't part of the table name in the table API.
>
> Thanks,
> Xuefu
>
>
Have you tried "t2" instead of "test.t2"? There is a possibility that catalog
name isn't part of the table name in the table API.
Thanks,
Xuefu
--
Sender:Flavio Pompermaier
Sent at:2018 Oct 22 (Mon) 23:06
Recipient:user
Hi to all,
I've tried to register an external catalog and use it with the Table API in
Flink 1.6.1.
The following (Java) test job cannot write to a sink using insertInto
because Flink cannot find the table by id (test.t2). Am I doing something
wrong or is this a bug?
This is my Java test class:
