Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/325#issuecomment-71170205
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 well. If your project does not have this feat
[
https://issues.apache.org/jira/browse/FLINK-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289029#comment-14289029
]
ASF GitHub Bot commented on FLINK-1353:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289043#comment-14289043
]
ASF GitHub Bot commented on FLINK-1353:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1353.
Resolution: Fixed
Fixed with a5702b69ed7794abdd44035581077b09fc551450.
> Execution always uses Defa
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/325
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Max Michels reassigned FLINK-1436:
--
Assignee: Max Michels
> Command-line interface verbose option (-v)
> --
[
https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289064#comment-14289064
]
Max Michels commented on FLINK-1436:
If we remove the verbose parameter, we have to ig
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/328#issuecomment-71177177
Yeah you're right that the exponential backoff was the default behaviour
before. I think Stephan's proposal is the best solution. I'll implement it and
also change th
[
https://issues.apache.org/jira/browse/FLINK-1352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289085#comment-14289085
]
ASF GitHub Bot commented on FLINK-1352:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289089#comment-14289089
]
ASF GitHub Bot commented on FLINK-1389:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/301#issuecomment-71178244
Hadoops `FileOutputFormat` has the following method
```java
public static String getUniqueName(JobConf conf, String name) {
int partition = conf.getInt(Job
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/326#issuecomment-71181165
Thanks a lot for looking into this @StephanEwen !
Can you share more details on how you did the filtering? Might be useful
for next time :)
Shouldn't the directo
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289104#comment-14289104
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user vasia commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-1425:
--
Assignee: Ufuk Celebi
> Turn lazy operator execution off for streaming programs
> --
Fabian Hueske created FLINK-1438:
Summary: ClassCastException for Custom InputSplit in local mode
Key: FLINK-1438
URL: https://issues.apache.org/jira/browse/FLINK-1438
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289273#comment-14289273
]
ASF GitHub Bot commented on FLINK-1425:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/330
[FLINK-1425] [streaming] Add scheduling of all tasks at once
See corresponding
[discussion](http://mail-archives.apache.org/mod_mbox/incubator-flink-dev/201501.mbox/%3CCA%2Bfaj9yHzsNDW-6hUVdoL_OY0EoVMRrE
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/326#issuecomment-71204417
Yes. The package seems to be still wrong.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289331#comment-14289331
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/301#issuecomment-71208053
I've updated the pull request. Please review again, I would like to merge
this soon.
---
If your project is set up for it, you can reply to this email and have your
repl
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/331
[Flink-1436] refactor CLiFrontend to provide more identifiable and
meaningful error messages
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/fl
[
https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paris Carbone updated FLINK-1344:
-
Description:
Source definitions in the scala-api pass a collector to the UDF, thus enforcing
an i
[
https://issues.apache.org/jira/browse/FLINK-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289366#comment-14289366
]
ASF GitHub Bot commented on FLINK-1389:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/331#discussion_r23455746
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -945,13 +948,10 @@ private int handleError(Throwable t) {
privat
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/331#discussion_r23455785
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -960,14 +960,15 @@ public int parseParameters(String[] args) {
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/331#discussion_r23455860
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -413,29 +413,33 @@ protected int info(String[] args) {
P
[
https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289394#comment-14289394
]
Max Michels edited comment on FLINK-1427 at 1/23/15 3:36 PM:
-
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/331#discussion_r23456787
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -960,14 +960,15 @@ public int parseParameters(String[] args) {
[
https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289394#comment-14289394
]
Max Michels commented on FLINK-1427:
[~aalexandrov] I changed my mind a bit and actual
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/331#discussion_r23456811
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -413,29 +413,33 @@ protected int info(String[] args) {
Packag
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/331#discussion_r23456818
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -945,13 +948,10 @@ private int handleError(Throwable t) {
private voi
[
https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289416#comment-14289416
]
Max Michels commented on FLINK-1436:
https://github.com/apache/flink/pull/331
> Comma
[
https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1433:
--
Fix Version/s: 0.8.1
> Add HADOOP_CLASSPATH to start scripts
> -
[
https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289426#comment-14289426
]
ASF GitHub Bot commented on FLINK-1436:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/331#issuecomment-71212582
Testing JIRA integration FLINK-1436
Lets see
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
[
https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289427#comment-14289427
]
Ufuk Celebi commented on FLINK-1427:
You could easily check whether the variable is al
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289428#comment-14289428
]
Gianmarco De Francisci Morales commented on FLINK-1421:
---
Great to se
[
https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Max Michels updated FLINK-1436:
---
Summary: Command-line interface verbose option & error reporting (was:
Command-line interface verbose
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289468#comment-14289468
]
Paris Carbone commented on FLINK-1421:
--
:)
Samoa is a really interesting project, we
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289468#comment-14289468
]
Paris Carbone edited comment on FLINK-1421 at 1/23/15 4:29 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289486#comment-14289486
]
Gianmarco De Francisci Morales commented on FLINK-1421:
---
Indeed, hav
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289511#comment-14289511
]
Fridtjof Sander commented on FLINK-1297:
I started to prototype the design for thi
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/326#issuecomment-71230743
Ah, sorry, I forgot that, let me do that in a few hours. I am sort of
having fun with git right now :-)
FYI: What I basically used is the git filter-branch com
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289564#comment-14289564
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user StephanEwen commented on the pu
Robert Metzger created FLINK-1439:
-
Summary: Enable all YARN tests on Travis
Key: FLINK-1439
URL: https://issues.apache.org/jira/browse/FLINK-1439
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1295.
---
Resolution: Fixed
Fix Version/s: 0.9
Resolved in http://git-wip-us.apache.org/repos/asf
[
https://issues.apache.org/jira/browse/FLINK-1385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1385.
---
Resolution: Fixed
Fix Version/s: 0.9
Resolved in http://git-wip-us.apache.org/repos/asf
[
https://issues.apache.org/jira/browse/FLINK-883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-883.
--
Resolution: Fixed
Fix Version/s: 0.9
Resolved in http://git-wip-us.apache.org/repos/asf/fl
[
https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289753#comment-14289753
]
mustafa elbehery commented on FLINK-629:
[~rmetzger] I need this fix into release-0
GitHub user qmlmoon opened a pull request:
https://github.com/apache/flink/pull/332
[FLINK-1381] Allow multiple output splitters for single stream operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/qmlmoon/incubator-flink s
[
https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289834#comment-14289834
]
ASF GitHub Bot commented on FLINK-1381:
---
GitHub user qmlmoon opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-1381:
--
Assignee: Mingliang Qi
> Only one output splitter supported per operator
> -
[
https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1342:
-
Priority: Major (was: Minor)
Fix Version/s: 0.8.1
0.9
> Quickstart's
[
https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289913#comment-14289913
]
Fabian Hueske commented on FLINK-1342:
--
This is also true for all dependencies which
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/332#issuecomment-71260370
Hey!
Thank you for the effort, it looks good. Unfortunately I have recently
pushed the commits that allow operator chaining and I totally reworked the
jobgraphbuil
[
https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289914#comment-14289914
]
ASF GitHub Bot commented on FLINK-1381:
---
Github user gyfora commented on the pull re
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/301#issuecomment-71262094
The change looks good, but do why do we need two parameters for 0- and
1-offset indices?
I would only keep the 1-offset index (current behavior).
If you think
[
https://issues.apache.org/jira/browse/FLINK-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289933#comment-14289933
]
ASF GitHub Bot commented on FLINK-1389:
---
Github user fhueske commented on the pull r
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/314
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14290001#comment-14290001
]
ASF GitHub Bot commented on FLINK-1406:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1406.
--
Resolution: Fixed
Fix Version/s: 0.9
Fixed in 96585f149c8d100f3d8fce2bb737743695f20c12
>
Github user cebe commented on the pull request:
https://github.com/apache/flink/pull/326#issuecomment-71268972
that really sounds like great fun :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14290009#comment-14290009
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user cebe commented on the pull requ
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/328#discussion_r23485570
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -175,62 +175,79 @@ import scala.collection.JavaConverter
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/328#discussion_r23485615
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -175,62 +175,79 @@ import scala.collection.JavaConverter
[
https://issues.apache.org/jira/browse/FLINK-1352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14290137#comment-14290137
]
ASF GitHub Bot commented on FLINK-1352:
---
Github user hsaputra commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14290139#comment-14290139
]
ASF GitHub Bot commented on FLINK-1352:
---
Github user hsaputra commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paris Carbone updated FLINK-1344:
-
Summary: Add implicit conversion from scala streams to DataStreams (was:
Add implicit conversions
[
https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paris Carbone updated FLINK-1344:
-
Summary: Add implicit conversions from scala streams to DataStreams (was:
Add support for lazy co
[
https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paris Carbone updated FLINK-1344:
-
Description:
Source definitions in the scala-api pass a collector to the UDF, thus enforcing
an i
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/264#issuecomment-71285644
That's a good point. I copied the code from the DelimitedInputFormat which
allows to specify the charset for the record delimiter.
So if we go with
1. we should al
[
https://issues.apache.org/jira/browse/FLINK-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14290218#comment-14290218
]
ASF GitHub Bot commented on FLINK-1168:
---
Github user fhueske commented on the pull r
Henry Saputra created FLINK-1440:
Summary: Missing plan visualizer image for
http://flink.apache.org/docs/0.8/programming_guide.html page
Key: FLINK-1440
URL: https://issues.apache.org/jira/browse/FLINK-1440
73 matches
Mail list logo
