Hi Naehee,
Thanks for reporting the issue. Yes, it is a bug in the ParquetInputFormat.
Would you please create a jira ticket and assign to me. I will try to fix
it by the end of this weekend.
My Jira account name Zhenqiu Huang. Thanks
Best Regards
Peter Huang
On Wed, Nov 4, 2020 at 11:57 PM
Thanks for the great effort to make this happen. It paves us from using
1.12 soon.
Best Regards
Peter Huang
On Mon, Jan 18, 2021 at 8:16 PM Yang Wang wrote:
> Thanks Xintong for the great work as our release manager!
>
>
> Best,
> Yang
>
> Xintong Song 于2021年1月19日周二 上午11:
Kafka lag even about memory tunning. The QPS is also growing very fast. I
am wondering whether we have good guidance for performance tunning
of RocksDB state backend for such kind of large QPS jobs.
Best Regards
Peter Huang
Hi Yun,
Thanks for the info. These materials help a lot.
Best Regards
Peter Huang
On Thu, Jul 2, 2020 at 11:36 PM Yun Tang wrote:
> Hi Peter
>
> This is a general problem and you could refer to RocksDB's tuning
> guides[1][2], you could also refer to Flink built-in Prede
I agree with Steven. This logic can be added in a dynamic config framework
that can bind into Flink operators. We probably don't need to let Flink
runtime handle it.
On Fri, Jun 4, 2021 at 8:11 AM Steven Wu wrote:
> I am not sure if we should solve this problem in Flink. This is more like
> a dy
It is great news for the community. Thanks to everyone who contributed to
the release management. Congratulations!
On Thu, Aug 22, 2019 at 9:14 PM Haibo Sun wrote:
> Great news! Thanks Gordon and Kurt!
>
> Best,
> Haibo
>
>
> At 2019-08-22 20:03:26, "Tzu-Li (Gordon) Tai" wrote:
> >The Apache Fl
Hi Anyang,
Thanks for raising it up. I think it is reasonable as what you requested is
needed for batch. Let's wait for Till to give some more input.
Best Regards
Peter Huang
On Thu, Sep 5, 2019 at 7:02 AM Anyang Hu wrote:
> Hi Peter&Till:
>
> As commented in
rrent implementation, the
MaximumFailedTaskManagerExceedingException is SuppressRestartsException. It
will exit immediately.
Best Regards
Peter Huang
On Sun, Sep 8, 2019 at 1:27 AM Anyang Hu wrote:
> Hi Till,
> Thank you for the reply.
>
> 1. The batch processing may be customized accor
Hi Anyang and Till,
I think we agreed on making the interval configurable in this case. Let me
revise the current PR. You can review it after that.
Best Regards
Peter Huang
On Thu, Sep 12, 2019 at 12:53 AM Anyang Hu wrote:
> Thanks Till, I will continue to follow this issue and see what
skManagers).
*/
public static final String CONTAINERIZED_TASK_MANAGER_ENV_PREFIX =
"containerized.taskmanager.env.";
Best Regards
Peter Huang
On Tue, Sep 24, 2019 at 8:02 AM Richard Deurwaarder wrote:
> Hello,
>
> We have our flink job (1.8.0) running on our hadoop 2.7
Hi Richard,
Good suggestion. I just created a Jira ticket. I will find a time this week
to update docs.
Best Regards
Peter Huang
On Wed, Sep 25, 2019 at 8:05 AM Richard Deurwaarder wrote:
> Hi Peter and Jiayi,
>
> Thanks for the answers this worked perfectly, I j
-0CHbgv16Me-vjaaDMCfhX7TzVVTuifYM/edit?ts=5da1f4d7#heading=h.be92q3uiam4t
Best Regards
Peter Huang
On Thu, Oct 31, 2019 at 8:17 PM bupt_ljy wrote:
> Hi all,
>
>
> Firstly thanks @tison for bring this up and strongly +1 for the overall
> design.
>
>
> I’d like
Hi Hanan,
Thanks for reporting the issue. Would you please attach your test code
here? I may help to investigate.
Best Regards
Peter Huang
On Mon, Nov 18, 2019 at 2:51 AM Hanan Yehudai
wrote:
> I have tried to persist Generic Avro records in a parquet file and then
> read
a/browse/FLINK-14953. Please also add more
insight by comment directly on it.
Best Regards
Peter Huang
On Mon, Nov 18, 2019 at 12:40 PM Hanan Yehudai
wrote:
> HI Peter. Thanks.
>
> This is my code . I used one of the parquet / avro tests as a reference.
>
>
>
> The code wi
Hi Hanan,
I created a fix for the problem. Would you please try it from your side?
https://github.com/apache/flink/pull/10371
Best Regards
Peter Huang
On Tue, Nov 26, 2019 at 8:07 AM Peter Huang
wrote:
> Hi Hanan,
>
> After investigating the issue by using the test case you provided
Congratulations!:)
On Fri, Dec 13, 2019 at 9:45 AM Piotr Nowojski wrote:
> Congratulations! :)
>
> > On 13 Dec 2019, at 18:05, Fabian Hueske wrote:
> >
> > Congrats Zhu Zhu and welcome on board!
> >
> > Best, Fabian
> >
> > Am Fr., 13. Dez. 2019 um 17:51 Uhr schrieb Till Rohrmann <
> > trohrm..
Congratulations, Dian!
Best Regards
Peter Huang
On Thu, Jan 16, 2020 at 11:04 AM Yun Tang wrote:
> Congratulations, Dian!
>
> Best
> Yun Tang
> --
> *From:* Benchao Li
> *Sent:* Thursday, January 16, 2020 22:27
> *To:* Congxian Qiu
>
Congrats Jingsong!
On Fri, Feb 21, 2020 at 8:49 AM Rong Rong wrote:
> Congratulations Jingsong!!
>
> Cheers,
> Rong
>
> On Fri, Feb 21, 2020 at 8:45 AM Bowen Li wrote:
>
>> Congrats, Jingsong!
>>
>> On Fri, Feb 21, 2020 at 7:28 AM Till Rohrmann
>> wrote:
>>
>>> Congratulations Jingsong!
>>>
>
It is a mistake. Thank you :)
On Fri, Mar 22, 2019 at 10:26 AM Pablo Estrada wrote:
> Hi Peter,
> You'll have to email user-subscr...@flink.apache.org to be able to
> subscribe : )
> Best
> -P.
>
> On Fri, Mar 22, 2019 at 10:22 AM Peter Huang
> wrote:
>
>>
>>
Hi Qi,
The current version of PR is runnable in production. But according to
Till's suggestion, It needs one more round of change.
Best Regards
Peter Huang
On Fri, Mar 29, 2019 at 3:42 PM Rong Rong wrote:
> Hi Qi,
>
> I think the problem may be related to another similar probl
batch job in per
job cluster or session cluster? To temporarily mitigate the issue you are
facing, you probable can tune the heartbeat.timecout (default 50s) to a
larger value.
Best Regards
Peter Huang
On Mon, Jul 1, 2019 at 7:50 AM Till Rohrmann wrote:
> Hi Anyang,
>
> as far as I c
Congrats Rong!
On Thu, Jul 11, 2019 at 10:40 AM Becket Qin wrote:
> Congrats, Rong!
>
> On Fri, Jul 12, 2019 at 1:13 AM Xingcan Cui wrote:
>
>> Congrats Rong!
>>
>> Best,
>> Xingcan
>>
>> On Jul 11, 2019, at 1:08 PM, Shuyi Chen wrote:
>>
>> Congratulations, Rong!
>>
>> On Thu, Jul 11, 2019 at
We will handle it asap. Please check the status of this jira
https://issues.apache.org/jira/browse/FLINK-32777
On Mon, Aug 7, 2023 at 8:08 PM Xiaolong Wang
wrote:
> Hi,
>
> I was testing flink-kubernetes-operator in an IPv6 cluster and found out
> the below issues:
>
> *Caused by: javax.net.ssl.
Congratulations
Best Regards
Peter Huang
On Wed, Mar 20, 2024 at 6:56 AM Huajie Wang wrote:
>
> Congratulations
>
>
>
> Best,
> Huajie Wang
>
>
>
> Leonard Xu 于2024年3月20日周三 21:36写道:
>
>> Hi devs and users,
>>
>> We are thrilled to annou
Thanks for the effort, Guyla!
Best Regards
Peter Huang
On Wed, Jul 3, 2024 at 12:48 PM Őrhidi Mátyás
wrote:
> Thank you, Gyula! 🥳
> Cheers
> On Wed, Jul 3, 2024 at 8:00 AM Gyula Fóra wrote:
>
> > The Apache Flink community is very happy to announce the release of
26 matches
Mail list logo