Ufuk Celebi created FLINK-5603:
--
Summary: Use Flink's futures in QueryableStateClient
Key: FLINK-5603
URL: https://issues.apache.org/jira/browse/FLINK-5603
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-5604:
--
Summary: Replace QueryableStateClient constructor
Key: FLINK-5604
URL: https://issues.apache.org/jira/browse/FLINK-5604
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-5605:
--
Summary: Make KvStateRequestSerializer package private
Key: FLINK-5605
URL: https://issues.apache.org/jira/browse/FLINK-5605
Project: Flink
Issue Type: Improvem
Ufuk Celebi created FLINK-5606:
--
Summary: Remove magic number in key and namespace serialization
Key: FLINK-5606
URL: https://issues.apache.org/jira/browse/FLINK-5606
Project: Flink
Issue Type:
Ufuk Celebi created FLINK-5607:
--
Summary: Move location lookup retry out of
KvStateLocationLookupService
Key: FLINK-5607
URL: https://issues.apache.org/jira/browse/FLINK-5607
Project: Flink
Iss
Hey All,
I am trying to port some of my streaming jobs to Flink 1.2 from 1.1.4 and I
have noticed some very strange segfaults. (I am running in test
environments - with the minicluster)
It is a fairly complex job so I wouldnt go into details but the interesting
part is that adding/removing a simpl
Hey!
I am actually a bit puzzled how these segfaults could come, unless via a
native library, or a JVM bug.
Can you try how it behaves when not using RocksDB or using a newer JVM
version?
Stephan
On Sun, Jan 22, 2017 at 7:51 PM, Gyula Fóra wrote:
> Hey All,
>
> I am trying to port some of my
Shannon Carey created FLINK-5608:
Summary: Cancel button not always visible
Key: FLINK-5608
URL: https://issues.apache.org/jira/browse/FLINK-5608
Project: Flink
Issue Type: Bug
Comp
Hi,
I am trying to use the GlobFilePathFIlter with Flink 1.2-SNAPSHOT have also
tried using the latest 1.3-SNAPSHOT code and get the same error. Basically
if using the GlobFilePathFilter there is a serialization exception due to
the inner class in sun.nio.fs.UnixFileSystem not being serializable. I
Hi,
When we are implementing that Flink *InputFormat* Interface, if we have that*
input split creation* part in our data analytics server APIs can we
directly go to the second phase of the flink InputFormat Interface
execution.
Basically I need to know that can we read those InputSplits directly,
10 matches
Mail list logo