Dawid Wysakowicz created FLINK-9866:
---
Summary: Allow passing program arguments to StandaloneJobCluster
Key: FLINK-9866
URL: https://issues.apache.org/jira/browse/FLINK-9866
Project: Flink
Till Rohrmann created FLINK-9867:
Summary: Extend release notes for Flink 1.6
Key: FLINK-9867
URL: https://issues.apache.org/jira/browse/FLINK-9867
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-9855:
---
Summary: KeyedStream.IntervalJoined#process does not work for
lambdas
Key: FLINK-9855
URL: https://issues.apache.org/jira/browse/FLINK-9855
Project: Flink
-- Forwarded message --
From: Sampath Bhat
Date: Fri, Jul 13, 2018 at 3:18 PM
Subject: Flink CLI properties with HA
To: user
Hello
When HA is enabled in the flink cluster and if I've to submit job via flink
CLI then in the flink-conf.yaml of flink CLI should contain this
I’m not sure. As far as I know APIs are already in place for statistics support
and only missing part is actual statistic provider. With this respect it batch
and streaming might be almost completely independent of one another, so it
shouldn’t be matter of “first that then that” but whatever
陈梓立 created FLINK-9859:
--
Summary: Distinguish TM akka config with JM config
Key: FLINK-9859
URL: https://issues.apache.org/jira/browse/FLINK-9859
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-9862:
Summary: Update end-to-end test to use RocksDB backed timers
Key: FLINK-9862
URL: https://issues.apache.org/jira/browse/FLINK-9862
Project: Flink
Issue
Hi Sampath,
Flink CLI need to retrieve the JobManager leader address, so it need to
access the HA specific configuration. Because if based on Zookeeper to
implement the HA, the leader address information will fetch from Zookeeper.
The main use of config item *high-availability.storageDir* is
Aljoscha Krettek created FLINK-9857:
---
Summary: Processing-time timers fire too early
Key: FLINK-9857
URL: https://issues.apache.org/jira/browse/FLINK-9857
Project: Flink
Issue Type: Bug
Andrey Zagrebin created FLINK-9858:
--
Summary: State TTL End-to-End Test
Key: FLINK-9858
URL: https://issues.apache.org/jira/browse/FLINK-9858
Project: Flink
Issue Type: Sub-task
Dear All,
We have 2 independent streams which will receive elements in different
frequency,
DataStream> splittedActivationTuple;
DataStream> unionReloadsStream;
We have a requirement to keep "splittedActivationTuple" stream elements in
a Window of eviction time period of 24 hours. So I created
Chesnay Schepler created FLINK-9856:
---
Summary:
ExecutionGraphCoLocationRestartTest#testConstraintsAfterRestart failed on travis
Key: FLINK-9856
URL: https://issues.apache.org/jira/browse/FLINK-9856
Till Rohrmann created FLINK-9860:
Summary: Netty resource leak on receiver side
Key: FLINK-9860
URL: https://issues.apache.org/jira/browse/FLINK-9860
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-9861:
Summary: Add end-to-end test for reworked BucketingSink
Key: FLINK-9861
URL: https://issues.apache.org/jira/browse/FLINK-9861
Project: Flink
Issue Type:
Hequn Cheng created FLINK-9868:
--
Summary: Expose channel id to ProcessFunction
Key: FLINK-9868
URL: https://issues.apache.org/jira/browse/FLINK-9868
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-9863:
---
Summary: Add a built-in ingestion time TS extractor
Key: FLINK-9863
URL: https://issues.apache.org/jira/browse/FLINK-9863
Project: Flink
Issue Type: New
Timo Walther created FLINK-9864:
---
Summary: Make timestamp extraction more flexible in SQL Client
Key: FLINK-9864
URL: https://issues.apache.org/jira/browse/FLINK-9864
Project: Flink
Issue
Stephan Ewen created FLINK-9865:
---
Summary: flink-hadoop-compatibility should assume Hadoop as
provided
Key: FLINK-9865
URL: https://issues.apache.org/jira/browse/FLINK-9865
Project: Flink
陈梓立 created FLINK-9869:
--
Summary: Send PartitionInfo in batch to Improve perfornance
Key: FLINK-9869
URL: https://issues.apache.org/jira/browse/FLINK-9869
Project: Flink
Issue Type: Improvement
19 matches
Mail list logo
