We are planning to go to 1.5.0 next week ( from 1.4.0 ). I could not get a
list of jira issues that would be addressed in the 1.5.1 release which
seems imminent. Could anyone inform the forum of the 1.5.1 bug fixes and
tell us a time line for the 1.5.1 release ?
Thanks much
2 issues we are seeing on 1.5.1 on a streaming pipe line
org.apache.flink.util.FlinkException: The assigned slot
208af709ef7be2d2dfc028ba3bbf4600_10 was removed.
and
java.util.concurrent.TimeoutException: Heartbeat of TaskManager with
id 208af709ef7be2d2dfc028ba3bbf4600 timed out.
Not sure
.5.0 next week ( from 1.4.0 ). I could not
get a list of jira issues that would be addressed in the 1.5.1 release
which seems imminent. Could anyone inform the forum of the 1.5.1 bug
fixes and tell us a time line for the 1.5.1 release ?
Thanks much
e. It is
probably a
good idea to find out why the heartbeats cannot be answered by the TM.
Best,
Gary
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/config.html#heartbeat-manager
On Sun, Jul 22, 2018 at 1:36 AM, Vishal Santoshi
wrote:
> 2 issues we are seeing on 1.
l 22, 2018 at 1:36 AM, Vishal Santoshi <
> vishal.santo...@gmail.com> wrote:
>
>> 2 issues we are seeing on 1.5.1 on a streaming pipe line
>>
>> org.apache.flink.util.FlinkException: The assigned slot
>> 208af709ef7be2d2dfc028ba3bbf4600_10 was removed.
>>
>>
rtbeats cannot be answered by the TM.
>>
>> Best,
>> Gary
>>
>> [1]
>> https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/config.html#heartbeat-manager
>>
>>
>> On Sun, Jul 22, 2018 at 1:36 AM, Vishal Santoshi <
>> visha
ed via heartbeat.interval and hearbeat.timeout
>>> [1].
>>> The default timeout is 50s, which should be a generous value. It is
>>> probably a
>>> good idea to find out why the heartbeats cannot be answered by the TM.
>>>
>>> Best,
&g
n be configured via heartbeat.interval and
>>>> hearbeat.timeout [1].
>>>> The default timeout is 50s, which should be a generous value. It is
>>>> probably a
>>>> good idea to find out why the heartbeats cannot be answered by the TM.
&g
Vishal, from which version did you upgrade to 1.5.1? Maybe from 1.5.0
(release)? Knowing that might help narrowing down the source of this.
On Wed, Aug 15, 2018 at 11:38 AM Juho Autio wrote:
> Thanks Gary..
>
> What could be blocking the RPC threads? Slow checkpointing?
>
> In p
/ops/config.html#web-timeout
Cheers,
Juho
On Wed, Aug 15, 2018 at 11:43 AM Juho Autio wrote:
> Vishal, from which version did you upgrade to 1.5.1? Maybe from 1.5.0
> (release)? Knowing that might help narrowing down the source of this.
>
> On Wed, Aug 15, 2018 at 11:38 AM Juho Aut
pretty generous value.
>>>>
>>>> On Sun, Jul 22, 2018 at 6:55 AM, Gary Yao
>>>> wrote:
>>>>
>>>>> Hi,
>>>>>
>>>>> The first exception should be only logged on info level. It's expected
>>>>>
gt;>>> will exhaust all slots on a TM rather then distributing them equitably.
>>>>> TMs selectively are under more stress then in a pure RR distribution I
>>>>> think. We may have to lower the slots on each TM to define a good upper
>>>&
Hi to all,
I'm trying to migrate a job from Flink 1.3.1 to 1.5.1 but it seems that
RequiredParameters and ParameterTool works differently from before...
My code is the following:
ParameterTool parameters = ParameterTool.fromArgs(args);
RequiredParameters required = new RequiredParam
The Apache Flink community is very happy to announce the release of Apache
Flink 1.5.1, which is the first bugfix release for the Apache Flink 1.5 series.
Apache Flink® is an open-source stream processing framework for distributed,
high-performing, always-available, and accurate data streaming
Great to hear. Big thank you to the community for the hard work and to
Chesnay for being our release manager.
Cheers,
Till
On Fri, Jul 13, 2018 at 12:05 PM Chesnay Schepler
wrote:
> The Apache Flink community is very happy to announce the release of Apache
> Flink 1.5.1, which is the
; wrote:
>
>> The Apache Flink community is very happy to announce the release of
>> Apache Flink 1.5.1, which is the first bugfix release for the Apache Flink
>> 1.5 series.
>>
>> Apache Flink® is an open-source stream processing framework for
>> distributed,
gt; Chesnay for being our release manager.
>>
>> Cheers,
>> Till
>>
>> On Fri, Jul 13, 2018 at 12:05 PM Chesnay Schepler
>> wrote:
>>
>>> The Apache Flink community is very happy to announce the release of
>>> Apache Flink 1.5.1, which is t
,
> Till
>
> On Fri, Jul 13, 2018 at 12:05 PM Chesnay Schepler
> mailto:ches...@apache.org>> wrote:
>
> The Apache Flink community is very happy to announce the
> release of Apache Flink 1.5.1, which is the first bugfix
Hi all,
The Apache Kyuubi (Incubating) community is pleased to announce that
Apache Kyuubi (Incubating) 1.5.1-incubating has been released!
Apache Kyuubi (Incubating) is a distributed multi-tenant JDBC server for
large-scale data processing and analytics, built on top of Apache Spark
and
Hi Fu,
I think the mail might have been sent to Flink user mail list by mistake?
Best,
Paul Lam
> 2022年4月22日 11:00，Fu Chen 写道：
>
> Hi all,
>
> The Apache Kyuubi (Incubating) community is pleased to announce that
> Apache Kyuubi (Incubating) 1.5.1-incubating has been rel
22年4月22日 11:00，Fu Chen 写道：
>
> Hi all,
>
> The Apache Kyuubi (Incubating) community is pleased to announce that
> Apache Kyuubi (Incubating) 1.5.1-incubating has been released!
>
> Apache Kyuubi (Incubating) is a distributed multi-tenant JDBC server for
> large-scale data pr
21 matches
Mail list logo
