[
https://issues.apache.org/jira/browse/FLINK-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587554#comment-14587554
]
ASF GitHub Bot commented on FLINK-2210:
---
Github user Shiti commented on the pull req
Github user Shiti commented on the pull request:
https://github.com/apache/flink/pull/834#issuecomment-112312576
@aljoscha I have made the changes
---
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
Shiti Saxena created FLINK-2230:
---
Summary: Add Support for Null-Values in TupleSerializer
Key: FLINK-2230
URL: https://issues.apache.org/jira/browse/FLINK-2230
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587494#comment-14587494
]
ASF GitHub Bot commented on FLINK-2210:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/834#issuecomment-112295698
I think we need to have a special AST node along with code generation for
it. This means:
- Addition of something like NumericIsNotNull in comparisons.scala
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/830#discussion_r32489670
--- Diff: flink-dist/src/main/flink-bin/NOTICE ---
@@ -407,3 +391,86 @@ LongAdder), which was released with the following
comments:
http://creativeco
Github user Shiti commented on the pull request:
https://github.com/apache/flink/pull/834#issuecomment-112276475
@aljoscha is there a way we can define functions for expressions? I tried
replacing Literal(1) with IsNotNull but I don't know if its possible to define
a function that con
[
https://issues.apache.org/jira/browse/FLINK-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587416#comment-14587416
]
ASF GitHub Bot commented on FLINK-2210:
---
Github user Shiti commented on the pull req
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/830#discussion_r32488023
--- Diff: flink-dist/src/main/flink-bin/NOTICE ---
@@ -407,3 +391,86 @@ LongAdder), which was released with the following
comments:
http://creativ
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/830#discussion_r32487483
--- Diff: LICENSE ---
@@ -218,13 +218,9 @@ conditions of their respective licenses.
The Apache Flink project bundles the following files under the MIT
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/830#discussion_r32487493
--- Diff: flink-dist/src/main/flink-bin/LICENSE ---
@@ -254,20 +285,18 @@ under the Apache License (v 2.0):
The Apache Flink project bundles the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/830#discussion_r32487473
--- Diff: LICENSE ---
@@ -218,13 +218,9 @@ conditions of their respective licenses.
The Apache Flink project bundles the following files under the MIT
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587321#comment-14587321
]
Stephan Ewen commented on FLINK-2213:
-
Does this number influence the number of resour
[
https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587317#comment-14587317
]
Stephan Ewen commented on FLINK-2220:
-
[~fhueske] Can probably comments on how to add
[
https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587315#comment-14587315
]
Stephan Ewen commented on FLINK-2220:
-
It should be possible to put in a check that ve
[
https://issues.apache.org/jira/browse/FLINK-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587312#comment-14587312
]
Stephan Ewen commented on FLINK-2228:
-
I think that is subject to the Google JS librar
[
https://issues.apache.org/jira/browse/FLINK-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587309#comment-14587309
]
Stephan Ewen commented on FLINK-2229:
-
Good catch, thanks!
Do you want to prepare a p
[
https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587101#comment-14587101
]
Matthias J. Sax commented on FLINK-1870:
I had a look into the code and think this
[
https://issues.apache.org/jira/browse/FLINK-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587083#comment-14587083
]
ASF GitHub Bot commented on FLINK-2120:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/840#issuecomment-112232247
My build is green: https://travis-ci.org/mjsax/flink/builds/66925468
IMHO, ready to be merged. It's only a renaming thing.
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned FLINK-1870:
--
Assignee: Matthias J. Sax
> Reintroduce Indexed reader functionality to streaming
> ---
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586754#comment-14586754
]
Matthias J. Sax commented on FLINK-2218:
Sounds reasonable. However, I would add a
[
https://issues.apache.org/jira/browse/FLINK-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586741#comment-14586741
]
ASF GitHub Bot commented on FLINK-2120:
---
GitHub user mjsax opened a pull request:
GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/840
[FLINK-2120] Rename AbstractJobVertex to JobVertex
Renamed AbstractJobVertex to JobVertex
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/flin
[
https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586536#comment-14586536
]
Ronny Bräunlich commented on FLINK-2211:
Sure, why not ;)
> Generalize ALS API
>
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/830#discussion_r32452097
--- Diff: flink-dist/src/main/flink-bin/NOTICE ---
@@ -407,3 +391,86 @@ LongAdder), which was released with the following
comments:
http://creativeco
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/830#discussion_r32452060
--- Diff: flink-dist/src/main/flink-bin/NOTICE ---
@@ -407,3 +391,86 @@ LongAdder), which was released with the following
comments:
http://creativeco
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586450#comment-14586450
]
ASF GitHub Bot commented on FLINK-2221:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/839#issuecomment-112161893
Looks good +1
---
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
Sebastian Kruse created FLINK-2229:
--
Summary: Data sets involving non-primitive arrays cannot be unioned
Key: FLINK-2229
URL: https://issues.apache.org/jira/browse/FLINK-2229
Project: Flink
GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/839
[FLINK-2221] [docs] Docs for not using local filesystem on the clusteâ¦
â¦r as state backup
This is just a clear documentation of the problem for the 0.9 release.
You can merge this pull
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586311#comment-14586311
]
ASF GitHub Bot commented on FLINK-2221:
---
GitHub user mbalassi opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Theodore Vasiloudis updated FLINK-2228:
---
Summary: Web frontend uses two different timezones when reporting the time
for job (w
[
https://issues.apache.org/jira/browse/FLINK-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586306#comment-14586306
]
ASF GitHub Bot commented on FLINK-2226:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/838#issuecomment-112134703
And here as well: https://travis-ci.org/mxm/flink/builds/66881439
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586298#comment-14586298
]
Maximilian Michels commented on FLINK-2218:
---
Oh thanks for pointing that out. Ho
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/837#issuecomment-112131002
A quick call with @rmetzger enlightened me on the possible cause, maybe I
managed to unwillingly disable another transformer. Debugging.
---
If your project is set up f
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/832#discussion_r32439968
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java ---
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache Software Fou
[
https://issues.apache.org/jira/browse/FLINK-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586288#comment-14586288
]
Ufuk Celebi commented on FLINK-2227:
Me neither, see priority of this issue.
> .yarn-
[
https://issues.apache.org/jira/browse/FLINK-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586282#comment-14586282
]
ASF GitHub Bot commented on FLINK-2226:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586287#comment-14586287
]
ASF GitHub Bot commented on FLINK-2152:
---
Github user rmetzger commented on a diff in
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/838#issuecomment-112130543
I think this is by chance. Here it passes:
https://travis-ci.org/mxm/flink/builds/66877782
---
If your project is set up for it, you can reply to this email and have your
re
[
https://issues.apache.org/jira/browse/FLINK-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586278#comment-14586278
]
ASF GitHub Bot commented on FLINK-2226:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/838#issuecomment-112129807
The travis run for the previous commit (before your var name update) failed
with
```
java.lang.RuntimeException: Error while stopping YARN Application Client
[
https://issues.apache.org/jira/browse/FLINK-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586275#comment-14586275
]
ASF GitHub Bot commented on FLINK-2226:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586274#comment-14586274
]
Robert Metzger commented on FLINK-2227:
---
It is a bug, but I would not block the rele
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/838#issuecomment-112129153
Agreed, a bit misleading name. Changed it to `failAppllication`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/834#issuecomment-112127936
OK, I had some offline discussion with @mxm and @fhueske. We thought that
we should have this behaviour:
https://en.wikipedia.org/wiki/Null_(SQL)#Aggregate_functions.
[
https://issues.apache.org/jira/browse/FLINK-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586272#comment-14586272
]
ASF GitHub Bot commented on FLINK-2210:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Theodore Vasiloudis updated FLINK-2228:
---
Description:
When reporting the time of jobs, the time is reported in UTC in the title
[
https://issues.apache.org/jira/browse/FLINK-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Theodore Vasiloudis updated FLINK-2228:
---
Attachment: Screenshot.png
> Web fronted uses two different timezones when reporting t
Theodore Vasiloudis created FLINK-2228:
--
Summary: Web fronted uses two different timezones when reporting
the time for job
Key: FLINK-2228
URL: https://issues.apache.org/jira/browse/FLINK-2228
Pr
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/838#issuecomment-112124731
I agree with Ufuk. You are setting the status of the app to failed, not of
the container.
---
If your project is set up for it, you can reply to this email and have you
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/838#issuecomment-112121112
You are exiting the *application* with status `FAILED` and not the
container. The container is finishing as expected.
The code (naming etc.) make it sound like you ar
[
https://issues.apache.org/jira/browse/FLINK-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586230#comment-14586230
]
ASF GitHub Bot commented on FLINK-2210:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/834#issuecomment-112116663
Yes, I see your point. Also, right now an expression like "a.count, a.sum"
(where a only contains 0 or 1) returns different results if field a is null for
some rows. Thi
[
https://issues.apache.org/jira/browse/FLINK-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586214#comment-14586214
]
Ufuk Celebi commented on FLINK-2227:
[~rmetzger]: bug or feature? ;)
> .yarn-properti
[
https://issues.apache.org/jira/browse/FLINK-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586216#comment-14586216
]
ASF GitHub Bot commented on FLINK-2210:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/834#issuecomment-112114140
For instance, users could wonder that a DataSet containing null values
returns a different result for a count aggregation than for a call to the
`count()` method.
---
If yo
Ufuk Celebi created FLINK-2227:
--
Summary: .yarn-properties file is not cleaned up
Key: FLINK-2227
URL: https://issues.apache.org/jira/browse/FLINK-2227
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586198#comment-14586198
]
Matthias J. Sax commented on FLINK-2218:
Please consider my current PR, too.
http
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/834#issuecomment-11231
But right now the jobs fail with NPEs, that's also not very nice. :smile:
---
If your project is set up for it, you can reply to this email and have your
reply appear o
[
https://issues.apache.org/jira/browse/FLINK-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586200#comment-14586200
]
ASF GitHub Bot commented on FLINK-2210:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586195#comment-14586195
]
Matthias J. Sax commented on FLINK-2218:
Makes sense. However, currently the WebCl
[
https://issues.apache.org/jira/browse/FLINK-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-2224.
Resolution: Fixed
Fix Version/s: master
0.9
Fixed via c4f3f48 (release-0.9
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/834#issuecomment-112104910
I have a funny feeling that this might backfire. Is the null value policy
now to simply ignore them? :)
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586183#comment-14586183
]
ASF GitHub Bot commented on FLINK-2210:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586177#comment-14586177
]
Maximilian Michels commented on FLINK-2218:
---
The -p and -c arguments are parsed
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586173#comment-14586173
]
Matthias J. Sax commented on FLINK-2218:
I see. I will have a look and take care o
[
https://issues.apache.org/jira/browse/FLINK-2152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586170#comment-14586170
]
ASF GitHub Bot commented on FLINK-2152:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/832#discussion_r32430399
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java ---
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586164#comment-14586164
]
Till Rohrmann commented on FLINK-2224:
--
Go ahead.
> JobManager log does not conta
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586160#comment-14586160
]
Ufuk Celebi commented on FLINK-2218:
Yes, the user program has to parse the argument m
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586158#comment-14586158
]
Maximilian Michels commented on FLINK-2218:
---
[~mjsax] I don't think so because t
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/818#issuecomment-112099290
Hi @vasia ,
In essence the `difference` method is just a fancy way of removing
vertices, right?
When you remove a vertex, you also remove the edge for whic
[
https://issues.apache.org/jira/browse/FLINK-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586156#comment-14586156
]
Maximilian Michels commented on FLINK-2226:
---
https://github.com/apache/flink/pul
[
https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586155#comment-14586155
]
ASF GitHub Bot commented on FLINK-2093:
---
Github user andralungu commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586154#comment-14586154
]
Márton Balassi commented on FLINK-2221:
---
Ok, so for the release I am adding some doc
[
https://issues.apache.org/jira/browse/FLINK-2212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-2212.
-
Resolution: Not A Problem
Not a problem but error code signaling can be improved in YARN s
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-2221:
--
Comment: was deleted
(was: After a bit more careful consideration and checking other parts of th
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586148#comment-14586148
]
Márton Balassi commented on FLINK-2221:
---
After a bit more careful consideration and
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586149#comment-14586149
]
Márton Balassi commented on FLINK-2221:
---
After a bit more careful consideration and
[
https://issues.apache.org/jira/browse/FLINK-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586147#comment-14586147
]
Ufuk Celebi commented on FLINK-2224:
Yes, I agree. Access to JM logs is currently easi
Maximilian Michels created FLINK-2226:
-
Summary: Fail YARN application on failed single-job YARN cluster
Key: FLINK-2226
URL: https://issues.apache.org/jira/browse/FLINK-2226
Project: Flink
Till Rohrmann created FLINK-2225:
Summary: Erroneous scheduling of co-located tasks
Key: FLINK-2225
URL: https://issues.apache.org/jira/browse/FLINK-2225
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-2225:
-
Attachment: flink-hduser-taskmanager-node2.log
TaskManager log node2
> Erroneous scheduling of co
[
https://issues.apache.org/jira/browse/FLINK-2225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-2225:
-
Attachment: flink-hduser-jobmanager-node1.log
JobManager log
> Erroneous scheduling of co-located
[
https://issues.apache.org/jira/browse/FLINK-2225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-2225:
-
Attachment: flink-hduser-flink-client-node1.log
Client log
> Erroneous scheduling of co-located t
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/838
[YARN] fail container on failed single job cluster job
Failing jobs executed in the YARN cluster mode leave the application
container in the "SUCCEEDED" final state. While for long-running Flink
Y
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-2221:
--
Comment: was deleted
(was: We can go down the check and retry route, but as it is distributed
s
[
https://issues.apache.org/jira/browse/FLINK-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned FLINK-2120:
--
Assignee: Matthias J. Sax
> Rename AbstractJobVertex to JobVertex
> ---
[
https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586136#comment-14586136
]
ASF GitHub Bot commented on FLINK-2093:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/818#issuecomment-112095145
Hi @andralungu, @shghatge,
I'm a bit confused by your changes.. Why did you add a new `removeVertices`
API method for DataSet?
I thought we had agreed that we'll hav
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586135#comment-14586135
]
Márton Balassi commented on FLINK-2221:
---
We can go down the check and retry route, b
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586134#comment-14586134
]
Márton Balassi commented on FLINK-2221:
---
We can go down the check and retry route, b
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/837#issuecomment-112093450
This seems to break the hadoop-2 builds currently somehow. Does anyone have
an idea why it happens? :) (Same errors occured in the apache and my travis
runs too.)
---
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586126#comment-14586126
]
Gyula Fora commented on FLINK-2221:
---
A workaround would be to actually discard the state
Till Rohrmann created FLINK-2224:
Summary: JobManager log does not contain root cause and stack
trace of exceptions
Key: FLINK-2224
URL: https://issues.apache.org/jira/browse/FLINK-2224
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586119#comment-14586119
]
Ufuk Celebi commented on FLINK-2221:
@Marton: how are you fixing this? Check and retry
[
https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586094#comment-14586094
]
ASF GitHub Bot commented on FLINK-2093:
---
Github user andralungu commented on the pul
1 - 100 of 213 matches
Mail list logo
