Lorenz Bühmann created FLINK-9772:
-
Summary: Documentation of Hadoop API outdated
Key: FLINK-9772
URL: https://issues.apache.org/jira/browse/FLINK-9772
Project: Flink
Issue Type: Bug
Yazdan Shirvany created FLINK-9771:
--
Summary: "Show Plan" option under Submit New Job in WebUI not
working
Key: FLINK-9771
URL: https://issues.apache.org/jira/browse/FLINK-9771
Project: Flink
I've identified 2 issues related to the WebUI job submission and opened
a PR for each of them:
FLINK-9770: https://github.com/apache/flink/pull/6269
FLINK-9769: https://github.com/apache/flink/pull/6270
On 05.07.2018 22:13, Chesnay Schepler wrote:
Note that this issue is isolated to the WebUI j
Chesnay Schepler created FLINK-9770:
---
Summary: UI jar list broken
Key: FLINK-9770
URL: https://issues.apache.org/jira/browse/FLINK-9770
Project: Flink
Issue Type: Bug
Components:
Note that this issue is isolated to the WebUI job submission, so feel
free to do other release testing in the meantime.
On 05.07.2018 22:13, Chesnay Schepler wrote:
I'm canceling the RC due to
https://issues.apache.org/jira/browse/FLINK-9769.
On 05.07.2018 21:58, Chesnay Schepler wrote:
I co
I'm canceling the RC due to
https://issues.apache.org/jira/browse/FLINK-9769.
On 05.07.2018 21:58, Chesnay Schepler wrote:
I could reproduce the issue, investigating.
On 05.07.2018 20:55, Yaz Sh wrote:
[-1]
I did follow validation release candidate guide line and when I
tested the examples
Chesnay Schepler created FLINK-9769:
---
Summary: Job submission via WebUI broken
Key: FLINK-9769
URL: https://issues.apache.org/jira/browse/FLINK-9769
Project: Flink
Issue Type: Bug
I could reproduce the issue, investigating.
On 05.07.2018 20:55, Yaz Sh wrote:
[-1]
I did follow validation release candidate guide line and when I tested the
examples via web UI, I got some errors. here are the steps to reproduce the
error.
- Ran the cluster mode (./bin/start-cluster.sh)
-
[-1]
I did follow validation release candidate guide line and when I tested the
examples via web UI, I got some errors. here are the steps to reproduce the
error.
- Ran the cluster mode (./bin/start-cluster.sh)
- Upload the WordCount.jar Example via web UI (I retry this with other examples
als
Chesnay Schepler created FLINK-9768:
---
Summary: Only build flink-dist for binary releases
Key: FLINK-9768
URL: https://issues.apache.org/jira/browse/FLINK-9768
Project: Flink
Issue Type: Imp
Hi everyone,
Please review and vote on the release candidate #1 for the version
1.5.1, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
Chesnay Schepler created FLINK-9767:
---
Summary: Add instructions to generate tag to release guide
Key: FLINK-9767
URL: https://issues.apache.org/jira/browse/FLINK-9767
Project: Flink
Issue T
Hi Stephan,
Thank you very much for the reply and very happy for that!
I'm not sure whether I understood your idea correctly. Does it means 1) we
should add a new operator with the feature of Elastic Bloom Filter? or 2) we
could support it as the current (version <= 1.5) InternalTimerServer
Have you tried increasing the request.timeout.ms parameter (Kafka) ?
Which Flink / Kafka release are you using ?
Cheers
On Thu, Jul 5, 2018 at 5:39 AM Amol S - iProgrammer
wrote:
> Hello,
>
> I am using flink with kafka and getting below exception.
>
> org.apache.kafka.common.errors.TimeoutExc
sorry above logs are not complete.
you can find complete logs in this mail.
Error while emitting latency marker.
java.lang.RuntimeException: Buffer pool is destroyed.
at
org.apache.flink.streaming.runtime.io.RecordWriterOutput.emitLatencyMarker(RecordWriterOutput.java:147)
~[flink-streaming-java
My flink job is failed with below exception
java.lang.RuntimeException: Buffer pool is destroyed.
at
org.apache.flink.streaming.runtime.io.RecordWriterOutput.emitLatencyMarker(RecordWriterOutput.java:147)
~[flink-streaming-java_2.11-1.5.0.jar:1.5.0]
at
org.apache.flink.streaming.api.operators.Abs
Nico Kruber created FLINK-9766:
--
Summary: Incomplete/incorrect cleanup in RemoteInputChannelTest
Key: FLINK-9766
URL: https://issues.apache.org/jira/browse/FLINK-9766
Project: Flink
Issue Type:
Hi Amol,
> On Jul 5, 2018, at 2:23 AM, Amol S - iProgrammer
> wrote:
>
> Hello folks,
>
> I am trying to write my streaming result into mongodb using
> RIchSinkFunction as below.
>
> gonogoCustomerApplicationStream.addSink(mongoSink)
>
> where mongoSink is Autowired i.e. injected object and
Hello,
I am using flink with kafka and getting below exception.
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for
helloworld.t-7: 30525 ms has passed since last append
---
*Amol Suryawanshi*
Java Developer
am...@iprogrammer.com
Timo Walther created FLINK-9765:
---
Summary: Improve CLI responsiveness when cluster is not reachable
Key: FLINK-9765
URL: https://issues.apache.org/jira/browse/FLINK-9765
Project: Flink
Issue Ty
Nico Kruber created FLINK-9764:
--
Summary: Failure in LocalRecoveryRocksDBFullITCase
Key: FLINK-9764
URL: https://issues.apache.org/jira/browse/FLINK-9764
Project: Flink
Issue Type: Bug
Hi Amol,
The implementation of the RichSinkFunction probably contains a field that
is not serializable. To avoid serializable exception, you can:
1. Marking the field as transient. This makes the serialization mechanism
skip the field.
2. If the field is part of the object's persistent state, the
Pavel Shvetsov created FLINK-9763:
-
Summary: Flink SQL Client bat script
Key: FLINK-9763
URL: https://issues.apache.org/jira/browse/FLINK-9763
Project: Flink
Issue Type: Sub-task
Co
Oleksandr Nitavskyi created FLINK-9762:
--
Summary: CoreOptions.TMP_DIRS wrongly managed on Yarn
Key: FLINK-9762
URL: https://issues.apache.org/jira/browse/FLINK-9762
Project: Flink
Issue
I forgot to mention: there are some follow-ups on this but the gravity
is not as high as the deadlock of FLINK-9676 and PRs are not quite ready
yet ...
https://issues.apache.org/jira/browse/FLINK-9755
https://issues.apache.org/jira/browse/FLINK-9756
https://issues.apache.org/jira/browse/FLINK-9761
Nico Kruber created FLINK-9761:
--
Summary: Potential buffer leak in PartitionRequestClientHandler
during job failures
Key: FLINK-9761
URL: https://issues.apache.org/jira/browse/FLINK-9761
Project: Flink
Alright then, I'll start building the artifacts.
On 05.07.2018 12:24, Nico Kruber wrote:
FYI: I just merged this to master as well as release-1.5 (hopefully -
this is my first merge since I became a committer)
On 05/07/18 10:22, Zhijiang(wangzhijiang999) wrote:
I have reviewed FLINK-9676, wish
FYI: I just merged this to master as well as release-1.5 (hopefully -
this is my first merge since I became a committer)
On 05/07/18 10:22, Zhijiang(wangzhijiang999) wrote:
> I have reviewed FLINK-9676, wish it merged soon.
>
> Zhijiang
> --
Dawid Wysakowicz created FLINK-9760:
---
Summary: Return a single element from extractPatterns
Key: FLINK-9760
URL: https://issues.apache.org/jira/browse/FLINK-9760
Project: Flink
Issue Type:
Hello folks,
I am trying to write my streaming result into mongodb using
RIchSinkFunction as below.
gonogoCustomerApplicationStream.addSink(mongoSink)
where mongoSink is Autowired i.e. injected object and it is giving me below
error.
The implementation of the RichSinkFunction is not serializabl
lamber-ken created FLINK-9759:
-
Summary: give an irrelevant answer about the savepoint restore
when stateless operators be added etc
Key: FLINK-9759
URL: https://issues.apache.org/jira/browse/FLINK-9759
P
I have reviewed FLINK-9676, wish it merged soon.
Zhijiang
--
发件人：Chesnay Schepler
发送时间：2018年7月5日(星期四) 15:58
收件人：dev@flink.apache.org ; wangzhijiang999
; zjffdu ; Till Rohrmann
主 题：Re: [DISCUSS] Release Flink 1.5.1
Building the bi
Building the binary releases overnight failed due to a configuration
mistake on my side.
Till has informed me that FLINK-9676 might occur more often than we
initially suspected.
A PR to address the issue was already opened by Nico.
Given that I have to restart the process anyway today I'm dela
33 matches
Mail list logo
