Radoslaw Gruchalski created FLINK-7673:
--
Summary: Flink Kinesis connector - remove dependency on the ASL
code
Key: FLINK-7673
URL: https://issues.apache.org/jira/browse/FLINK-7673
Project: Flink
Radoslaw Gruchalski created FLINK-7672:
--
Summary: Publish Kinesis connector to Maven Central?
Key: FLINK-7672
URL: https://issues.apache.org/jira/browse/FLINK-7672
Project: Flink
Issue T
Bowen Li created FLINK-7671:
---
Summary: JobManagerCleanupITCase failed in build
Key: FLINK-7671
URL: https://issues.apache.org/jira/browse/FLINK-7671
Project: Flink
Issue Type: Bug
Compone
*(Note: I originally sent this to the users list but it seems better suited
for this list*, *sorry if it is not*)
I'm new to Flink and in the process of trying to write a few functions and
tests for them. I have a feeling some of terminology is off, so please
correct me where I am wrong. One of th
We are using 1.3.2
Gyula
On Fri, Sep 22, 2017, 17:13 Ted Yu wrote:
> Which release are you using ?
>
> Flink 1.3.2 uses Curator 2.12.0 which solves some leader election issues.
>
> Mind giving 1.3.2 a try ?
>
> On Fri, Sep 22, 2017 at 4:54 AM, Gyula Fóra wrote:
>
> > Hi all,
> >
> > We have ob
Which release are you using ?
Flink 1.3.2 uses Curator 2.12.0 which solves some leader election issues.
Mind giving 1.3.2 a try ?
On Fri, Sep 22, 2017 at 4:54 AM, Gyula Fóra wrote:
> Hi all,
>
> We have observed that in case some nodes of the ZK cluster are restarted
> (for a rolling restart)
Kewei SHANG created FLINK-7670:
--
Summary: typo in docs runtime section
Key: FLINK-7670
URL: https://issues.apache.org/jira/browse/FLINK-7670
Project: Flink
Issue Type: Bug
Components:
Hi Gordon,
Thank you for your help. That clarifies the steps for me.
Cheers,
Kewei
On Fri, Sep 22, 2017 at 12:22 PM, Tzu-Li (Gordon) Tai
wrote:
> Hi Kewei,
>
> Welcome to the community and contributing!
>
> Normally, for fixes that apply only to specific release branches, you can
> simply open
Hi all,
We have observed that in case some nodes of the ZK cluster are restarted
(for a rolling restart) the Flink Streaming jobs fail (and restart).
Log excerpt:
2017-09-22 12:54:41,426 INFO org.apache.zookeeper.ClientCnxn
- Unable to read additional data from server
sessi
Hi Kewei,
Welcome to the community and contributing!
Normally, for fixes that apply only to specific release branches, you can
simply open a pull request against that branch, and not against master branch.
For example, to fix something for Flink 1.3.x, open a pull request against the
`release-1
Hi,
I'm new to Flink documentation contribution.
I've noticed there is a typo error in the lastest stable version of
documentation, which makes a File not found error when linking to another
page:
https://ci.apache.org/projects/flink/flink-docs-release-1.3/
The lastest Flink documentation v1.4-
Raymond Tay created FLINK-7669:
--
Summary: org.apache.flink.api.common.ExecutionConfig cannot be
cast to org.apache.flink.api.common.ExecutionConfig
Key: FLINK-7669
URL: https://issues.apache.org/jira/browse/FLINK-766
Till Rohrmann created FLINK-7667:
Summary: Add serializable AccessExecutionGraph implementation
Key: FLINK-7667
URL: https://issues.apache.org/jira/browse/FLINK-7667
Project: Flink
Issue Type
Till Rohrmann created FLINK-7668:
Summary: Add AccessExecutionGraph refresh interval to
ExecutionGraphHolder
Key: FLINK-7668
URL: https://issues.apache.org/jira/browse/FLINK-7668
Project: Flink
Stephan and I discussed this for a bit and we came to the conclusion that there
are actually two different (orthogonal) settings at play here: "object reuse"
and "object forwarding behaviour". The former specifies whether we reuse
objects when deserialising records from the network, the latter s
15 matches
Mail list logo
