Hi Aljoscha,
To pass the time information to Evictor at the same to not expose the
StreamRecord, I suppose we can change the signature of evictBefore and
evictAfter to take Iterable> instead
Iterable>
void evictBefore(Iterable> elements, int size, W window,
EvictorContext evictorContext);
The fi
Zhenzhong Xu created FLINK-4760:
---
Summary: Kafka 09 Consumer failed to initialize state causing job
to restart
Key: FLINK-4760
URL: https://issues.apache.org/jira/browse/FLINK-4760
Project: Flink
Ted Yu created FLINK-4759:
-
Summary: Unclosed DataOutputViewStream in JavaSerializer
Key: FLINK-4759
URL: https://issues.apache.org/jira/browse/FLINK-4759
Project: Flink
Issue Type: Bug
R
Stephan Ewen created FLINK-4758:
---
Summary: Remove IOReadableWritable from classes where not needed
Key: FLINK-4758
URL: https://issues.apache.org/jira/browse/FLINK-4758
Project: Flink
Issue Typ
Stephan Ewen created FLINK-4757:
---
Summary: Unify "GlobalJobParameters" and "Configuration"
Key: FLINK-4757
URL: https://issues.apache.org/jira/browse/FLINK-4757
Project: Flink
Issue Type: Sub-t
Ruwen Moos created FLINK-4756:
-
Summary: NullPointerException on submiting a job with
StreamExecutionEnvironment.createRemoteEnvironment to a flink cluster
Key: FLINK-4756
URL: https://issues.apache.org/jira/browse/FL
Till Rohrmann created FLINK-4755:
Summary: Create ContainerID; Rename ResourceID into ProcessID and
InstanceID into RegistrationID
Key: FLINK-4755
URL: https://issues.apache.org/jira/browse/FLINK-4755
+1 to release (binding)
- checked hashes and signatures
- checked diffs against 1.1.2: no dependencies added or modified
- successfully built Flink from source archive (Maven 3.3.3, Java 1.8.0_25
Oracle, OS X)
- mvn clean install (Scala 2.10)
- mvn clean install (Scala 2.11)
- mvn clean inst
Hi Dennis,
can you give us some details about your setup? e.g. where you are running
your job, your input size, the configured memory, etc. It would also be
helpful if you could share your code. Getting an out of memory error with
just 100 nodes seems weird.
Best,
-Vasia.
On 6 October 2016 at 13
Ufuk Celebi created FLINK-4754:
--
Summary: Make number of retained checkpoints user configurable
Key: FLINK-4754
URL: https://issues.apache.org/jira/browse/FLINK-4754
Project: Flink
Issue Type: I
Dear ladies and gentlemen,
I got a problem using Gelly in Flink. Currently I am loading a Virtuoso Graph
into
Flink's Gelly and I want to analyze it for the different paths one can take to
link
the different nodes. Therefore I am using the ScatterGatherIteration.
However, my code just works
Tzu-Li (Gordon) Tai created FLINK-4753:
--
Summary: Kafka 0.8 connector's Periodic Offset Committer should
synchronize on checkpoint lock
Key: FLINK-4753
URL: https://issues.apache.org/jira/browse/FLINK-4753
Thanks for the information Tzu-Li. I will mock the FlinkKafkaProducer
class until this issue is fixed.
Timo
Am 05/10/16 um 17:57 schrieb Tzu-Li (Gordon) Tai:
Sorry, correction to my last statements:
On the consumer side I think the instantiation was already removed from the
constructor in a
For a new Mesos framework implementation, it seems reasonable to go
with Mesos 1.0 and don't support legacy versions from day 1. I think
most users of Mesos are looking forward to the Mesos 1.0 release.
Still, we probably should check the migration plan of some potential
users.
On Tue, Oct 4, 2016
Dear Flink community,
Please vote on releasing the following candidate as Apache Flink version 1.1.3.
The commit to be voted on:
3264a16 (http://git-wip-us.apache.org/repos/asf/flink/commit/3264a16)
Branch:
release-1.1.3-rc1
(https://git1-us-west.apache.org/repos/asf/flink/repo?p=flink.git;a=sho
Till Rohrmann created FLINK-4752:
Summary: Improve session window documentation
Key: FLINK-4752
URL: https://issues.apache.org/jira/browse/FLINK-4752
Project: Flink
Issue Type: Improvement
16 matches
Mail list logo
