+1
Looking forward this release !
Regards
JB
On Oct 25, 2016, 14:43, at 14:43, Robert Metzger wrote:
>+1 for a bugfix release soon.
>
>On Tue, Oct 25, 2016 at 10:53 AM, Stephan Ewen
>wrote:
>
>> Thanks fort starting this Ufuk.
>>
>> I would like to add the following issues to 1.1.4:
>>
>>
zhuhaifeng created FLINK-4923:
-
Summary: Expose input/output queued buffers and buffer usage as a
metric for a Task
Key: FLINK-4923
URL: https://issues.apache.org/jira/browse/FLINK-4923
Project: Flink
Eron Wright created FLINK-4922:
---
Summary: Write documentation
Key: FLINK-4922
URL: https://issues.apache.org/jira/browse/FLINK-4922
Project: Flink
Issue Type: Sub-task
Reporter: Er
Eron Wright created FLINK-4921:
---
Summary: Upgrade to Mesos 1.0.1
Key: FLINK-4921
URL: https://issues.apache.org/jira/browse/FLINK-4921
Project: Flink
Issue Type: Sub-task
Reporter:
Hello,
I am trying to run the SVMITSuite in the Flink-ML library. When I build the
package it seems to skip all tests in SVMITSuite - I'm assuming it's
because there's no ExecutionEnvironment set up to use the DataSet API.
I can't seem to find any documentation on how to run this either. Any help
Stephan Ewen created FLINK-4920:
---
Summary: Add a Scala Function Gauge
Key: FLINK-4920
URL: https://issues.apache.org/jira/browse/FLINK-4920
Project: Flink
Issue Type: Improvement
Comp
FYI.I was using Redis as a state backend in my benchmarking Beam.It proved to
be a bottleneck. Perhaps due to high frequency of updating state components.I
replaced it with Java 8 ConcurrentHashmaps and it settled down
tremendously.Amir-
From: Ovidiu-Cristian MARCU
To: dev@flink.apache.
Vijay Srinivasaraghavan created FLINK-4919:
--
Summary: Add secure cookie support for the cluster deployed in
Mesos environment
Key: FLINK-4919
URL: https://issues.apache.org/jira/browse/FLINK-4919
Vijay Srinivasaraghavan created FLINK-4918:
--
Summary: Add SSL support to Mesos artifact server
Key: FLINK-4918
URL: https://issues.apache.org/jira/browse/FLINK-4918
Project: Flink
Is
Hey Geoffrey,
that's great to hear!
Random.nextInt() should suffice; but this is only done twice per
operator anyway so i wouldn't worry too much about it.
Regards,
Chesnay
On 25.10.2016 17:52, Geoffrey Mon wrote:
Hello Chesnay,
Thank you, this solves the last problem that I had with my pr
Hey folks,
Please give feedback on FLIP-13!
https://cwiki.apache.org/confluence/display/FLINK/FLIP-13+Side+Outputs+in+Flink
JIRA task link to google doc
https://issues.apache.org/jira/browse/FLINK-4460
Thanks,
Chen Qin
Hello Chesnay,
Thank you, this solves the last problem that I had with my project!
I added code to append a random UUID to each data channel. (see
https://github.com/GEOFBOT/flink/commit/b94b1249c4a014d8d1e412f7647ff192f3621b10)
However, is a UUID overkill? We only need the channel to be unique f
Hi Maciek,
Your use case will be covered by the FLIP-6 "Sessions". Sessions are
similar to how the on-premise Flink or the Yarn session operates
today. We will have a long-running dispatcher, resource manager, and
task managers. We will bring up a job manager for each job but the
overhead for this
Stephan Ewen created FLINK-4917:
---
Summary: Deprecate "CheckpointedAsynchronously" interface
Key: FLINK-4917
URL: https://issues.apache.org/jira/browse/FLINK-4917
Project: Flink
Issue Type: Impr
Stephan Ewen created FLINK-4916:
---
Summary: BufferSpiller should distribute files across temp
directories
Key: FLINK-4916
URL: https://issues.apache.org/jira/browse/FLINK-4916
Project: Flink
Is
Stephan Ewen created FLINK-4915:
---
Summary: Define parameters for reconciliation
Key: FLINK-4915
URL: https://issues.apache.org/jira/browse/FLINK-4915
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4914:
---
Summary: Define parameters for reconciliation
Key: FLINK-4914
URL: https://issues.apache.org/jira/browse/FLINK-4914
Project: Flink
Issue Type: Sub-task
Maximilian Michels created FLINK-4913:
-
Summary: Per-job Yarn clusters: include user jar in system class
loader
Key: FLINK-4913
URL: https://issues.apache.org/jira/browse/FLINK-4913
Project: Flin
Stephan Ewen created FLINK-4912:
---
Summary: Introduce RECONCILIATING state in ExecutionGraph
Key: FLINK-4912
URL: https://issues.apache.org/jira/browse/FLINK-4912
Project: Flink
Issue Type: Sub-
+1 the schedule proposed so far.
Do we also want to get in the "Trigger DSL" that we've had brewing for a
while now?
On Mon, 17 Oct 2016 at 16:17 Stephan Ewen wrote:
> I think this sounds very reasonable, +1 to the schedule.
>
> I would definitely add
> - FLIP-10 (unify checkpoints and savepo
Stephan Ewen created FLINK-4911:
---
Summary: Non-disruptive JobManager Failures
Key: FLINK-4911
URL: https://issues.apache.org/jira/browse/FLINK-4911
Project: Flink
Issue Type: New Feature
Stefan Richter created FLINK-4910:
-
Summary: Introduce safety net for closing file system streams
Key: FLINK-4910
URL: https://issues.apache.org/jira/browse/FLINK-4910
Project: Flink
Issue Ty
Stefano Bortoli created FLINK-4909:
--
Summary: JDBC Input format cast exception management
Key: FLINK-4909
URL: https://issues.apache.org/jira/browse/FLINK-4909
Project: Flink
Issue Type: Imp
I've added the following fix to the 1.1 branch
* [FLINK-4875] [metrics] Use correct operator name
It is a crucial fix for streaming topologies that involve multi-chains.
2 users already ran into this.
On 25.10.2016 14:43, Robert Metzger wrote:
+1 for a bugfix release soon.
On Tue, Oct 25, 20
Theodore Vasiloudis created FLINK-4908:
--
Summary: Add docs about evaluate operation to all predictors
Key: FLINK-4908
URL: https://issues.apache.org/jira/browse/FLINK-4908
Project: Flink
+1 for a bugfix release soon.
On Tue, Oct 25, 2016 at 10:53 AM, Stephan Ewen wrote:
> Thanks fort starting this Ufuk.
>
> I would like to add the following issues to 1.1.4:
>
> Build errors due to Storm dependencies *(fix pending)*
> - [FLINK-4298] [storm compatibility] Add proper repository
Aljoscha Krettek created FLINK-4907:
---
Summary: Add Test for Timers/State Provided by
AbstractStreamOperator
Key: FLINK-4907
URL: https://issues.apache.org/jira/browse/FLINK-4907
Project: Flink
Chesnay Schepler created FLINK-4906:
---
Summary: Use constants for the name of system-defined metrics
Key: FLINK-4906
URL: https://issues.apache.org/jira/browse/FLINK-4906
Project: Flink
Issu
Robert Metzger created FLINK-4905:
-
Summary: Kafka test instability IllegalStateException: Client is
not started
Key: FLINK-4905
URL: https://issues.apache.org/jira/browse/FLINK-4905
Project: Flink
Thanks fort starting this Ufuk.
I would like to add the following issues to 1.1.4:
Build errors due to Storm dependencies *(fix pending)*
- [FLINK-4298] [storm compatibility] Add proper repository for Closure
dependencies.
Stability on S3 considering eventual consistency *(fix pending)*
Stephan Ewen created FLINK-4904:
---
Summary: Add a limit for how much data may be spilled in
checkpoint alignments
Key: FLINK-4904
URL: https://issues.apache.org/jira/browse/FLINK-4904
Project: Flink
Till Rohrmann created FLINK-4903:
Summary: Introduce non async future methods
Key: FLINK-4903
URL: https://issues.apache.org/jira/browse/FLINK-4903
Project: Flink
Issue Type: Improvement
Thank you!
Best,
Ovidiu
> On 24 Oct 2016, at 16:11, Aljoscha Krettek wrote:
>
> Hi,
> regarding RocksDB, yes this is possible because RocksDB is essentially only
> used as an out-of-core hash table. When checkpointing we write everything
> from RocksDB to HDFS. When restoring we repopulate an e
33 matches
Mail list logo
