Congratulations! New features look awesome.
On Wed, Sep 1, 2021 at 9:10 AM Till Rohrmann wrote:
> Great news! Thanks a lot for all your work on the new release :-)
>
> Cheers,
> Till
>
> On Wed, Sep 1, 2021 at 9:07 AM Johannes Moser wrote:
>
>> Congratulations, great job.
>>
>> On
Thank you!
On Tue, Aug 10, 2021 at 11:04 AM Jingsong Li wrote:
> Thanks Yun Tang and everyone!
>
> Best,
> Jingsong
>
> On Tue, Aug 10, 2021 at 9:37 AM Xintong Song
> wrote:
>
>> Thanks Yun and everyone~!
>>
>> Thank you~
>>
>> Xintong Song
>>
>>
>>
>> On Mon, Aug 9, 2021 at 10:14 PM Till
found that the limit push down is invalid, is it a bug
> or was it designed like this?
>
> if the sql is 'select * from hivetable limit 1' ,it is ok
>
> thanks
>
--
Arvid Heise | Senior Java Developer
<https://www.ververica.com/>
Follow us @VervericaData
--
Join Flink Forw
>
>
> TM log：Running to Cannceling
> 2020-06-22 15:39:19.816 INFO com.xxx.client.consumer.GroupConsumer -
> consumer xxx to jmq1230:xxx,READ,xxx,NONE is stopped.
> 2020-06-22 15:39:19.816 INFO org.apache.flink.runtime.taskmanager.Task -
> Source: baseInfo (79/90) (4e62a84f2
Hi LakeShen,
you can change the port with
conf.setInteger(RestOptions.PORT, 8082);
or if want to be on the safe side specify a range
conf.setString(RestOptions.BIND_PORT, "8081-8099");
On Mon, Mar 9, 2020 at 10:47 AM LakeShen wrote:
> Hi community,
>now I am moving the flink job to
Hi Eleanore,
the flink runner is maintained by the Beam developers, so it's best to ask
on their user list.
The documentation is, however, very clear. "Flink runner is one of the
runners whose checkpoint semantics are not compatible with current
implementation (hope to provide a solution in near
