[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15129042#comment-15129042
]
ASF GitHub Bot commented on FLINK-3226:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/1579
[FLINK-3226] Add DataSet scan and conversion to DataSet[Row]
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fhueske/flink dataSetTrans
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-178836268
> I had some more comments concerning the failure case handling of stop
calls. The first problem is still the handling of exceptions when calling stop
on the Invokable in
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1574#issuecomment-178823650
Thanks for the comments. @gumchum: Internally it is stored as a Java
`Iterator` and that is the reason why left it so, but it definitely make sense
to convert it to
[
https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128681#comment-15128681
]
Ufuk Celebi commented on FLINK-3310:
Sorry, I didn't see it. I would like to close it as superseded by
Github user gumchum commented on the pull request:
https://github.com/apache/flink/pull/1574#issuecomment-178783922
Looks good. It looks like collect is returning a Java iterator instead of a
Scala one. Is there a reason for this given that the code is for Scala users?
---
If your
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1514#issuecomment-178453684
Cool, I'll rebase and merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
[
https://issues.apache.org/jira/browse/FLINK-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15127920#comment-15127920
]
ASF GitHub Bot commented on FLINK-3208:
---
Github user vasia commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128374#comment-15128374
]
Till Rohrmann commented on FLINK-3316:
--
In fact, all links in the first paragraph on the landing page
[
https://issues.apache.org/jira/browse/FLINK-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-3316:
Assignee: Till Rohrmann
> Links to Gelly and FlinkML libraries on main site broken
>
[
https://issues.apache.org/jira/browse/FLINK-3247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3247.
---
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/360f02b1
>
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3287.
---
Resolution: Fixed
Fix Version/s: 1.0.0
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Subhobrata Dey reassigned FLINK-3035:
-
Assignee: Subhobrata Dey
> Redis as State Backend
> --
>
>
Gabor Gevay created FLINK-3322:
--
Summary: MemoryManager creates too much GC pressure with iterative
jobs
Key: FLINK-3322
URL: https://issues.apache.org/jira/browse/FLINK-3322
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-3321:
---
Labels: starter (was: )
> TupleSerializerBase.getLength should know the length when all fields know
[
https://issues.apache.org/jira/browse/FLINK-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3316.
--
Resolution: Fixed
Fixed via ffe31bf53ca28a842d4a352a568f288251d56490
> Links to Gelly and
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-3322:
---
Fix Version/s: 1.0.0
> MemoryManager creates too much GC pressure with iterative jobs
>
Gabor Gevay created FLINK-3321:
--
Summary: TupleSerializerBase.getLength should know the length when
all fields know it
Key: FLINK-3321
URL: https://issues.apache.org/jira/browse/FLINK-3321
Project:
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128328#comment-15128328
]
ASF GitHub Bot commented on FLINK-3287:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1573
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128367#comment-15128367
]
Subhobrata Dey commented on FLINK-3035:
---
Hello [~mjsax],
Yes, I'm interested in the issue & would
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1572
[FLINK-3049] move Either type to org.apache.flink.types
I went for option 2, i.e. creating the package in `flink-java`. Let me know
if you think it makes more sense to move the type to `flink-core`.
[
https://issues.apache.org/jira/browse/FLINK-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15127992#comment-15127992
]
ASF GitHub Bot commented on FLINK-3049:
---
GitHub user vasia opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15127998#comment-15127998
]
Robert Metzger commented on FLINK-2600:
---
One more:
[
https://issues.apache.org/jira/browse/FLINK-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3208.
--
Resolution: Fixed
Fix Version/s: 1.0.0
> Rename Gelly vertex-centric model to
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1514
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128035#comment-15128035
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1566#discussion_r51551151
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArrayComparator.java
---
@@ -0,0 +1,205 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128043#comment-15128043
]
ASF GitHub Bot commented on FLINK-3303:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1572#issuecomment-178503870
Ah, I actually included this already in #1570
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128040#comment-15128040
]
ASF GitHub Bot commented on FLINK-3049:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128045#comment-15128045
]
Matthias J. Sax commented on FLINK-3034:
[~sbcd90], if the PR gets opened, please help to review.
Github user f-sander commented on the pull request:
https://github.com/apache/flink/pull/1565#issuecomment-178487703
Are the build failures related to us? I don't really understand how...
The first failure happens in oraclejd8 with hadoop 2.7.1:
```
Tests run: 2,
[
https://issues.apache.org/jira/browse/FLINK-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128001#comment-15128001
]
ASF GitHub Bot commented on FLINK-3128:
---
Github user f-sander commented on the pull request:
Robert Metzger created FLINK-3313:
-
Summary: Kafka08ITCase.testOneSourceMultiplePartitions fails with
EOFException
Key: FLINK-3313
URL: https://issues.apache.org/jira/browse/FLINK-3313
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128007#comment-15128007
]
ASF GitHub Bot commented on FLINK-3208:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-2736.
---
Resolution: Won't Fix
The issue didn't occur in a while.
> Failing
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1570#issuecomment-178504289
Merging this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128050#comment-15128050
]
Matthias J. Sax commented on FLINK-3035:
[~sbcd90], maybe you are interested in this ticket ;)
>
[
https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128048#comment-15128048
]
Matthias J. Sax commented on FLINK-3033:
[~sbcd90], if the PR gets opened, please help to review.
[
https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128057#comment-15128057
]
ASF GitHub Bot commented on FLINK-2380:
---
Github user kl0u commented on the pull request:
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1575
[FLINK-3207] [gelly] adds the vertex-centric iteration abstraction
As per the mailing list discussion, this PR adds the vertex-centric /
pregel iteration abstraction to gelly. In this model,
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1577
[FLINK-3313] [kafka] Fix concurrent TypeInformationSerializationSchema
usage in LegacyFetcher
The LegacyFetcher used the given KeyedDeserializationSchema across multiple
threads even though
Github user cmonty commented on the pull request:
https://github.com/apache/flink/pull/1574#issuecomment-178683549
The Scala interface looks good to me and gets rid of the need to call
`getJavaStream` directly.
Thanks!
---
If your project is set up for it, you can reply to
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1577#issuecomment-178683735
Good catch & fix!
+1 to merge asap (too many tests are failing on this one right now)
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128536#comment-15128536
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user rmetzger commented on the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1577#discussion_r51597662
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/LegacyFetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128549#comment-15128549
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1577#issuecomment-178685691
Thanks for the review. Will merge it once Travis gives green light.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128546#comment-15128546
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128559#comment-15128559
]
Maximilian Michels commented on FLINK-3310:
---
I also created an issue some time ago: FLINK-3127
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128491#comment-15128491
]
Till Rohrmann commented on FLINK-3313:
--
The problem ist that the
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-3313:
Assignee: Till Rohrmann
> Kafka08ITCase.testOneSourceMultiplePartitions fails with
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128515#comment-15128515
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128513#comment-15128513
]
ASF GitHub Bot commented on FLINK-3313:
---
GitHub user tillrohrmann opened a pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1577#discussion_r51595056
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/LegacyFetcher.java
---
@@
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1577#issuecomment-178680229
Good catch! :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128072#comment-15128072
]
Robert Metzger commented on FLINK-3287:
---
The user confirmed that shading curator into the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1557#issuecomment-178515178
The Scala problem seems to be related to missing suffixes in the pom file.
I fixed it. Once travis gives green light, I'll merge the PR.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-3216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128080#comment-15128080
]
ASF GitHub Bot commented on FLINK-3216:
---
Github user tillrohrmann commented on the pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1573
[FLINK-3287][FLINK-3247] Fix curator shading for Kafka connector
Some maven versions are not properly evaluating star * excludes. Therefore,
I've manually listed our shaded artifacts in
Aljoscha Krettek created FLINK-3315:
---
Summary: Fix Slot Sharing in Streaming API
Key: FLINK-3315
URL: https://issues.apache.org/jira/browse/FLINK-3315
Project: Flink
Issue Type:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1470#discussion_r51556295
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -237,53 +236,26 @@ public ExecutionConfig setParallelism(int
[
https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128092#comment-15128092
]
ASF GitHub Bot commented on FLINK-3187:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128123#comment-15128123
]
Andrea Sella commented on FLINK-3311:
-
Hi,
I am already working on to cassandra-connector into a
[
https://issues.apache.org/jira/browse/FLINK-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128066#comment-15128066
]
ASF GitHub Bot commented on FLINK-3049:
---
Github user vasia closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128065#comment-15128065
]
ASF GitHub Bot commented on FLINK-3049:
---
Github user vasia commented on the pull request:
Github user vasia closed the pull request at:
https://github.com/apache/flink/pull/1572
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Stephan Ewen created FLINK-3314:
---
Summary: Early cancel calls can cause Tasks to not cancel properly
Key: FLINK-3314
URL: https://issues.apache.org/jira/browse/FLINK-3314
Project: Flink
Issue
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1470#discussion_r51556358
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FixedDelayRestartStrategy.java
---
@@ -0,0 +1,113 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128093#comment-15128093
]
ASF GitHub Bot commented on FLINK-3187:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1470#discussion_r51557132
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1524#issuecomment-178507931
Could you explain what more tests do you have in mind? So far I am testing
1) if the scheme provided in the configuration is used when one is not
explicitly provided, 2)
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1572#issuecomment-178509129
Then I'll close it :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128086#comment-15128086
]
ASF GitHub Bot commented on FLINK-3287:
---
GitHub user rmetzger opened a pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1573#issuecomment-178518689
Thanks for fixing this, this was a critical issue.
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128091#comment-15128091
]
ASF GitHub Bot commented on FLINK-3287:
---
Github user StephanEwen commented on the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1470#discussion_r51557088
--- Diff: docs/apis/fault_tolerance.md ---
@@ -193,73 +193,169 @@ state updates) of Flink coupled with bundled sinks:
[Back to top](#top)
[
https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128108#comment-15128108
]
ASF GitHub Bot commented on FLINK-3187:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128109#comment-15128109
]
ASF GitHub Bot commented on FLINK-3187:
---
Github user tillrohrmann commented on a diff in the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1573#issuecomment-178527480
There is one issue I need to figure out, then, I'll merge it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128133#comment-15128133
]
ASF GitHub Bot commented on FLINK-3287:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128243#comment-15128243
]
Gabor Gevay commented on FLINK-3291:
> `ReduceDriver.run` owns two objects but is not tracking the
GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/1574
Scala DataStream accessors fix
The PR contains two orthogonal approaches of fixing the access to
`DataStreamUtils.collect` for a scala environment. One or both of the
approaches can be merged.
Till Rohrmann created FLINK-3317:
Summary: Add timeout handler to CEP operator
Key: FLINK-3317
URL: https://issues.apache.org/jira/browse/FLINK-3317
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-3318:
Summary: Add support for quantifiers to CEP's pattern API
Key: FLINK-3318
URL: https://issues.apache.org/jira/browse/FLINK-3318
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128602#comment-15128602
]
ASF GitHub Bot commented on FLINK-3310:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1578
[FLINK-3310] [runtime, runtime-web] Add back pressure statistics
This PR introduces back pressure statistics to the web frontend.
The idea is that tasks, which are back pressured by the network
[
https://issues.apache.org/jira/browse/FLINK-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128580#comment-15128580
]
Lokesh Ravindranathan commented on FLINK-2803:
--
Hi Stephen,
Thanks so much for the
[
https://issues.apache.org/jira/browse/FLINK-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3049.
-
Resolution: Fixed
Fixed via 54743866e86cbe7689ae1dcf001deb559629747b
Sorry for the confusion...
[
https://issues.apache.org/jira/browse/FLINK-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3049.
---
> Move "Either" type to package "org.apache.flink.types"
>
[
https://issues.apache.org/jira/browse/FLINK-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3303.
---
> Move all non-batch specific classes in flink-java to flink-core
>
[
https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2348.
-
Resolution: Fixed
Assignee: Stephan Ewen
Stabilized in
[
https://issues.apache.org/jira/browse/FLINK-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3303.
-
Resolution: Done
Done in 21a715867d655bb61df9a9f7eef37e42b99e206a
> Move all non-batch specific
[
https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2348.
---
> IterateExampleITCase failing
>
>
> Key: FLINK-2348
>
[
https://issues.apache.org/jira/browse/FLINK-3314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3314.
-
Resolution: Fixed
Fixed via 8fc7e7af2c7decb8e531b76e3edcc2601f73fe9d
> Early cancel calls can
[
https://issues.apache.org/jira/browse/FLINK-3314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3314.
---
> Early cancel calls can cause Tasks to not cancel properly
>
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1576
[hotfix][yarn] Shutdown JVM when Flink-on-yarn is shutting down
With this change, we call System.exit() when the YARN session is shutting
down.
On some Linux distributions, YARN is not
[
https://issues.apache.org/jira/browse/FLINK-3207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128467#comment-15128467
]
ASF GitHub Bot commented on FLINK-3207:
---
GitHub user vasia opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128517#comment-15128517
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user uce commented on the pull request:
1 - 100 of 126 matches
Mail list logo
