Ted Yu created FLINK-3301:
-
Summary: Ineffective synchronization in
MessageAcknowledgingSourceBase#restoreState
Key: FLINK-3301
URL: https://issues.apache.org/jira/browse/FLINK-3301
Project: Flink
I
Stephan Ewen created FLINK-3300:
---
Summary: Concurrency Bug in Yarn JobManager
Key: FLINK-3300
URL: https://issues.apache.org/jira/browse/FLINK-3300
Project: Flink
Issue Type: Bug
Comp
Hi Stephan,
thank you for the quick reply and for your feedback; I agree with you that
breaking changes have to taken very seriously.
The rationale behind my proposal is that Scala users are already accustomed
to higher-order functions that manipulate collections and it would
beneficial for them
Ufuk Celebi created FLINK-3299:
--
Summary: Remove ApplicationID from Environment
Key: FLINK-3299
URL: https://issues.apache.org/jira/browse/FLINK-3299
Project: Flink
Issue Type: Improvement
Hi!
Would be nice to support that, agreed.
Such a fundamental break in the API worries me a bit, though - I would opt
for a non-breaking addition.
Wrapping the RichFunctions into Scala functions (which are actually wrapped
as rich functions) with implicits seems like a workaround for something
th
Hello everybody,
as I'm getting familiar with Flink I've found a possible improvement to the
Scala APIs: in Scala it's a common pattern to perform tuple extraction
using pattern matching, making functions working on tuples more readable,
like this:
// referring to the mail count example in the tr
Mohit Sethi created FLINK-3297:
--
Summary: Streaming connector for ZeroMQ
Key: FLINK-3297
URL: https://issues.apache.org/jira/browse/FLINK-3297
Project: Flink
Issue Type: New Feature
Co
Mohit Sethi created FLINK-3298:
--
Summary: Streaming connector for ActiveMQ
Key: FLINK-3298
URL: https://issues.apache.org/jira/browse/FLINK-3298
Project: Flink
Issue Type: New Feature
Robert Metzger created FLINK-3296:
-
Summary: DataStream.write*() methods are not flushing properly
Key: FLINK-3296
URL: https://issues.apache.org/jira/browse/FLINK-3296
Project: Flink
Issue T
