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
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
[
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-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:
-
Summary: Add implicit conversion from scala streams to DataStreams (was:
Add implicit conversions
[
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-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
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
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
[
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 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-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
>
[
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
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-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 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-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 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-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
[
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-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-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:
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-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
[
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-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-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
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-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
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-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
[
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-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=14289468#comment-14289468
]
Paris Carbone commented on FLINK-1421:
--
:)
Samoa is a really interesting project, we
[
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=14289428#comment-14289428
]
Gianmarco De Francisci Morales commented on FLINK-1421:
---
Great to se
[
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
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-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
[
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=14289416#comment-14289416
]
Max Michels commented on FLINK-1436:
https://github.com/apache/flink/pull/331
> Comma
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-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_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 edited comment on FLINK-1427 at 1/23/15 3:36 PM:
-
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
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_r23455746
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -945,13 +948,10 @@ private int handleError(Throwable t) {
privat
[
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
[
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 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
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
[
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/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
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
[
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:
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:all-tabpanel
]
Gyula Fora updated FLINK-1425:
--
Assignee: Ufuk Celebi
> Turn lazy operator execution off for streaming programs
> --
[
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
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-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
[
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
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-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
[
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-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-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:comment-tabpanel&focusedCommentId=14289029#comment-14289029
]
ASF GitHub Bot commented on FLINK-1353:
---
Github user tillrohrmann commented on the p
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
73 matches
Mail list logo
