Hi-
Has anyone looked into embedding apache siddhi into Flink.
Thanks,
Aparup
zhangjing created FLINK-4516:
Summary: ResourceManager leadership election
Key: FLINK-4516
URL: https://issues.apache.org/jira/browse/FLINK-4516
Project: Flink
Issue Type: Sub-task
Comp
Nagarjun Guraja created FLINK-4515:
--
Summary: org.apache.flink.runtime.jobmanager.JobInfo class is not
backwards compatible with 1.1 released version
Key: FLINK-4515
URL: https://issues.apache.org/jira/browse/FLI
Tzu-Li (Gordon) Tai created FLINK-4514:
--
Summary: ExpiredIteratorException in Kinesis Consumer on long
catch-ups to head of stream
Key: FLINK-4514
URL: https://issues.apache.org/jira/browse/FLINK-4514
Next week Monday evening should be fine to get the Kinesis issue fix in.
On Sat, Aug 27, 2016 at 12:13 AM, Stephan Ewen wrote:
> +1 for 1.1.2
>
> Looks like everything is in the release-1.1 branch already except the
> Kinesis and Quickstart fix.
> For the Kinesis issue Tzu-Liu Tai seems onto it
+1 for 1.1.2
Looks like everything is in the release-1.1 branch already except the
Kinesis and Quickstart fix.
For the Kinesis issue Tzu-Liu Tai seems onto it already.
The quickstart is trivial fix.
Let's aim for patch-freeze next week Monday evening?
On Fri, Aug 26, 2016 at 3:11 PM, Fabian Hue
Fabian Hueske created FLINK-4513:
Summary: Kafka connector documentation refers to Flink 1.1-SNAPSHOT
Key: FLINK-4513
URL: https://issues.apache.org/jira/browse/FLINK-4513
Project: Flink
Issu
Ufuk Celebi created FLINK-4512:
--
Summary: Add option for persistent checkpoints
Key: FLINK-4512
URL: https://issues.apache.org/jira/browse/FLINK-4512
Project: Flink
Issue Type: Sub-task
Ufuk Celebi created FLINK-4511:
--
Summary: Schedule periodic savepoints
Key: FLINK-4511
URL: https://issues.apache.org/jira/browse/FLINK-4511
Project: Flink
Issue Type: Sub-task
Compone
Ufuk Celebi created FLINK-4510:
--
Summary: Always create CheckpointCoordinator
Key: FLINK-4510
URL: https://issues.apache.org/jira/browse/FLINK-4510
Project: Flink
Issue Type: Sub-task
Ufuk Celebi created FLINK-4509:
--
Summary: Specify savepoint directory per savepoint
Key: FLINK-4509
URL: https://issues.apache.org/jira/browse/FLINK-4509
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-4508:
-
Summary: Consolidate DummyEnvironment and MockEnvironment for Tests
Key: FLINK-4508
URL: https://issues.apache.org/jira/browse/FLINK-4508
Project: Flink
Is
That should be solved now. Looking forward to the pull request :)
On Thu, Aug 25, 2016 at 1:26 AM, Pavel Fadeev wrote:
> Hi Maximilian,
> absolutely make sense! Just filed
> https://issues.apache.org/jira/browse/FLINK-4483 for the same.
>
> More than happy to go ahead as an assignee there, but no
+1 for a 1.1.2 release.
I'd like to have the Joda time exclusion removed from the Quickstart POM to
include the dependency in the fat jar.
Otherwise jobs with that dependency (such as the Flink training examples)
fail with ClassNotFound.
Robert fix that on the side in https://github.com/apache/fl
Ufuk Celebi created FLINK-4507:
--
Summary: Deprecate savepoint backend config
Key: FLINK-4507
URL: https://issues.apache.org/jira/browse/FLINK-4507
Project: Flink
Issue Type: Sub-task
C
On Fri, Aug 26, 2016 at 2:40 AM, Greg Hogan wrote:
>
> This sounds like a nice compromise, to include the extra jars in the
> download but off the default classpath. The distinction between lib and
> libraries may be subtle and not as applicable to the other jars. Would
> something like "opt" be t
Michael Wong created FLINK-4506:
---
Summary: CsvOutputFormat defaults allowNullValues to false, even
though doc and declaration says true
Key: FLINK-4506
URL: https://issues.apache.org/jira/browse/FLINK-4506
Hello,
One question (a little bit off-topic but complementary), will the
beam-runner for flink be eventually considered as an official flink addon
(and distributed like discussed here) ?
On Fri, Aug 26, 2016 at 10:39 AM, Stephan Ewen wrote:
> "opt" sounds good to me. I just wrote "libraries
Zhijiang Wang created FLINK-4505:
Summary: Implement abstract TaskManagerFactory to bring up
TaskManager for different modes
Key: FLINK-4505
URL: https://issues.apache.org/jira/browse/FLINK-4505
Proje
"opt" sounds good to me. I just wrote "libraries" out of a lack of
creativity ;-)
On Fri, Aug 26, 2016 at 2:40 AM, Greg Hogan wrote:
> Also the metrics reporters.
>
> The circumstances for this request are that I wanted to use the metrics
> reporters for 1.1.1 and had to go looking on Maven Cent
shuai.xu created FLINK-4504:
---
Summary: Support user to decide whether the result of an operator
is presistent
Key: FLINK-4504
URL: https://issues.apache.org/jira/browse/FLINK-4504
Project: Flink
I
Some addtitional info:
It doesn't seem to happen the first time I start the jobs / restore them
from a savepoint. It happens as jobs are failing over after a task manager
failure.
This could be an issue caused by a non-empty rocks directory (that was
somehow in an inconsistent state) but that sho
22 matches
Mail list logo
