[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-1201:
Assignee: Vasia Kalavri
> Graph API for Flink
>
>
> K
[
https://issues.apache.org/jira/browse/FLINK-1334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266676#comment-14266676
]
Robert Metzger commented on FLINK-1334:
---
I've created the file: http://svn.apache.or
[
https://issues.apache.org/jira/browse/FLINK-1361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266647#comment-14266647
]
ASF GitHub Bot commented on FLINK-1361:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/286#issuecomment-68923148
@tillrohrmann, was there reason why the log file names was changed in the
RPC removal commit?
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1271:
-
Assignee: Felix Neutatz
> Extend HadoopOutputFormat and HadoopInputFormat to handle Void.class
>
[
https://issues.apache.org/jira/browse/FLINK-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1271:
-
Assignee: (was: Fabian Hueske)
> Extend HadoopOutputFormat and HadoopInputFormat to handle Voi
[
https://issues.apache.org/jira/browse/FLINK-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266495#comment-14266495
]
Felix Neutatz commented on FLINK-1271:
--
Since Void is now supported, we can now do th
[
https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266445#comment-14266445
]
Stephan Ewen commented on FLINK-1360:
-
{{env.fromElements()}} cannot work with Void, s
[
https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266435#comment-14266435
]
Felix Neutatz commented on FLINK-1360:
--
I fixed the TypeInfoParser.java and it would
[
https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266419#comment-14266419
]
Felix Neutatz commented on FLINK-1360:
--
it seems, that it is not yet defined in TypeI
[
https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266409#comment-14266409
]
Felix Neutatz commented on FLINK-1360:
--
No, it gives me another error:
List l = Arra
[
https://issues.apache.org/jira/browse/FLINK-1259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1259.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Stephan Ewen
Added description to d
[
https://issues.apache.org/jira/browse/FLINK-1300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1300.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Stephan Ewen
Fixed via 875c6aacc455
[
https://issues.apache.org/jira/browse/FLINK-1169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1169.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Stephan Ewen
Fixed in c52f4cab709ee
Stephan Ewen created FLINK-1362:
---
Summary: Spurious errors in execution state messaging between
TaskManager and JobManager
Key: FLINK-1362
URL: https://issues.apache.org/jira/browse/FLINK-1362
Project:
[
https://issues.apache.org/jira/browse/FLINK-1361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266283#comment-14266283
]
Alexander Alexandrov commented on FLINK-1361:
-
+1. Agree with Stephan. I belie
[
https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266236#comment-14266236
]
Stephan Ewen commented on FLINK-1360:
-
Did my suggestion above solve the issue?
> Aut
[
https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266232#comment-14266232
]
Felix Neutatz commented on FLINK-1360:
--
Yes and No.
The following works:
DataSet> d
[
https://issues.apache.org/jira/browse/FLINK-1357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1357.
-
Resolution: Fixed
Fixed via 0190dd24622169a98be1a6ef518b0fdd018e2d44
> Unsupported Union between
[
https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266219#comment-14266219
]
Stephan Ewen commented on FLINK-1360:
-
Ah, I see. That problem is different. The types
[
https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266200#comment-14266200
]
Felix Neutatz commented on FLINK-1360:
--
Yes, it has already VOID_TYPE_INFO. I guess t
[
https://issues.apache.org/jira/browse/FLINK-1361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266196#comment-14266196
]
ASF GitHub Bot commented on FLINK-1361:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-flink/pull/286
[FLINK-1361] change jobManager log file name
regression of b313eeb76cb5a9ec60923f3c4ab5b47569bc21e6
You can merge this pull request into a Git repository by running:
$ git pull https://git
[
https://issues.apache.org/jira/browse/FLINK-1361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266193#comment-14266193
]
Stephan Ewen commented on FLINK-1361:
-
I agree. We want to be stable in what we expose
Max Michels created FLINK-1361:
--
Summary: log file name of JobManager changed
Key: FLINK-1361
URL: https://issues.apache.org/jira/browse/FLINK-1361
Project: Flink
Issue Type: Bug
Compo
[
https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266189#comment-14266189
]
Stephan Ewen commented on FLINK-1360:
-
Which version are you working with? It should b
Felix Neutatz created FLINK-1360:
Summary: Automatic type extraction for Void is missing
Key: FLINK-1360
URL: https://issues.apache.org/jira/browse/FLINK-1360
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-1359:
--
Summary: Make IntermediateResultPartitionManager aware of consumed
partitions
Key: FLINK-1359
URL: https://issues.apache.org/jira/browse/FLINK-1359
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266136#comment-14266136
]
ASF GitHub Bot commented on FLINK-1354:
---
GitHub user ktzoumas opened a pull request:
GitHub user ktzoumas opened a pull request:
https://github.com/apache/incubator-flink/pull/285
[FLINK-1354] Made test graph for TransitiveClosureITCase smaller
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ktzoumas/incubator-fl
[
https://issues.apache.org/jira/browse/FLINK-1216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1216.
-
Resolution: Duplicate
Fix Version/s: (was: 0.8)
Duplicate of [FLINK-1342]
> Quickstart
[
https://issues.apache.org/jira/browse/FLINK-1246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1246.
-
Resolution: Fixed
Fix Version/s: (was: 0.8)
0.9
Fixed with the intro
[
https://issues.apache.org/jira/browse/FLINK-1268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266102#comment-14266102
]
Stephan Ewen commented on FLINK-1268:
-
I agree, it seems hard to solve this for local
[
https://issues.apache.org/jira/browse/FLINK-1354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266098#comment-14266098
]
Stephan Ewen commented on FLINK-1354:
-
I think the delta iterations have sufficient te
[
https://issues.apache.org/jira/browse/FLINK-1354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266093#comment-14266093
]
Kostas Tzoumas commented on FLINK-1354:
---
OK, I'll do that for now and prepare anothe
[
https://issues.apache.org/jira/browse/FLINK-988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-988.
Resolution: Fixed
Fix Version/s: 0.9
Fixed through the Akka RPC as of 88e64fc7837a3fb081e15b23
[
https://issues.apache.org/jira/browse/FLINK-988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266085#comment-14266085
]
Stephan Ewen commented on FLINK-988:
This should be soved with the new Akka based commu
[
https://issues.apache.org/jira/browse/FLINK-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1027.
-
Resolution: Fixed
Fix Version/s: (was: 0.8)
0.9
Fixed in 93eadca782e
[
https://issues.apache.org/jira/browse/FLINK-1236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1236.
-
Resolution: Fixed
Fix Version/s: 0.9
Fixed in 92ceacd23749fa4113a2f778ff68fa5881313b25
> A
[
https://issues.apache.org/jira/browse/FLINK-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266078#comment-14266078
]
ASF GitHub Bot commented on FLINK-1027:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266080#comment-14266080
]
ASF GitHub Bot commented on FLINK-1357:
---
Github user StephanEwen closed the pull req
[
https://issues.apache.org/jira/browse/FLINK-1236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266079#comment-14266079
]
ASF GitHub Bot commented on FLINK-1236:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-flink/pull/278
---
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 featur
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-flink/pull/267
---
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 featur
Github user StephanEwen closed the pull request at:
https://github.com/apache/incubator-flink/pull/284
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-1236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266030#comment-14266030
]
ASF GitHub Bot commented on FLINK-1236:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/267#issuecomment-68858278
Will merge this now...
---
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 n
[
https://issues.apache.org/jira/browse/FLINK-1357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266024#comment-14266024
]
ASF GitHub Bot commented on FLINK-1357:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/incubator-flink/pull/284
[FLINK-1357] [compiler] Add union between static and dynamic path
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StephanEwen/incub
[
https://issues.apache.org/jira/browse/FLINK-1354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266012#comment-14266012
]
Stephan Ewen commented on FLINK-1354:
-
I think bulk iterations per se are naive in tha
[
https://issues.apache.org/jira/browse/FLINK-1354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14266008#comment-14266008
]
Kostas Tzoumas commented on FLINK-1354:
---
Yes, it's too long compared to the other te
[
https://issues.apache.org/jira/browse/FLINK-1349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1349.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Stephan Ewen
Fixed via cec30ff4f1b7
Github user StephanEwen closed the pull request at:
https://github.com/apache/incubator-flink/pull/283
---
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 f
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/283#discussion_r22517635
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/ActorLogMessages.scala ---
@@ -30,13 +30,15 @@ trait ActorLogMessages {
Márton Balassi created FLINK-1358:
-
Summary: Add streaming to the quickstarts
Key: FLINK-1358
URL: https://issues.apache.org/jira/browse/FLINK-1358
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-1357:
---
Summary: Unsupported Union between static and dynamic path in
Iterations
Key: FLINK-1357
URL: https://issues.apache.org/jira/browse/FLINK-1357
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-997.
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Stephan Ewen
Fixed in 259f10c094292085
[
https://issues.apache.org/jira/browse/FLINK-1355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1355.
-
Resolution: Not a Problem
> Inconsistent Logging/Printing for Examples
> -
[
https://issues.apache.org/jira/browse/FLINK-1355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14265920#comment-14265920
]
Stephan Ewen commented on FLINK-1355:
-
Okay, but I guess this has lower priority. I wi
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/283#discussion_r22515851
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/messages/TaskManagerMessages.scala
---
@@ -113,4 +114,28 @@ object TaskManagerM
[
https://issues.apache.org/jira/browse/FLINK-1355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14265910#comment-14265910
]
Till Rohrmann commented on FLINK-1355:
--
I guess so. If so, I'll disable the sysout by
[
https://issues.apache.org/jira/browse/FLINK-1355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14265904#comment-14265904
]
Stephan Ewen commented on FLINK-1355:
-
That makes sense. Is it possible to add a file
[
https://issues.apache.org/jira/browse/FLINK-1355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14265897#comment-14265897
]
Till Rohrmann commented on FLINK-1355:
--
The reason why one sees the warning about the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/283#discussion_r22514865
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/messages/TaskManagerMessages.scala
---
@@ -113,4 +114,28 @@ object TaskManagerMe
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/283#discussion_r22514812
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/ActorLogMessages.scala ---
@@ -30,13 +30,15 @@ trait ActorLogMessages {
Github user tillrohrmann commented on the pull request:
https://github.com/apache/incubator-flink/pull/283#issuecomment-68842125
Looks good to me.
---
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 h
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/283#discussion_r22514382
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/messages/TaskManagerMessages.scala
---
@@ -113,4 +114,28 @@ object TaskManagerM
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/283#discussion_r22514023
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/ActorLogMessages.scala ---
@@ -30,13 +30,15 @@ trait ActorLogMessages {
[
https://issues.apache.org/jira/browse/FLINK-1228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14265868#comment-14265868
]
Robert Metzger commented on FLINK-1228:
---
I think a subtask is not needed. This issue
Mathias Peters created FLINK-1356:
-
Summary: Add a warning during startup if config files cannot be
found
Key: FLINK-1356
URL: https://issues.apache.org/jira/browse/FLINK-1356
Project: Flink
70 matches
Mail list logo
