[
https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14325060#comment-14325060
]
ASF GitHub Bot commented on FLINK-947:
--
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14325088#comment-14325088
]
Fay Beligianni commented on FLINK-1421:
---
Hello,
I am trying to run a SAMOA task on
[
https://issues.apache.org/jira/browse/FLINK-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324364#comment-14324364
]
Robert Metzger edited comment on FLINK-1556 at 2/17/15 4:15 PM:
[
https://issues.apache.org/jira/browse/FLINK-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324356#comment-14324356
]
Gyula Fora commented on FLINK-1566:
---
it is a concurrency issue while adding to an
[
https://issues.apache.org/jira/browse/FLINK-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324364#comment-14324364
]
Robert Metzger commented on FLINK-1556:
---
Also, it seems that these failearily jobs
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/414#discussion_r24829996
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/SingleSourceShortestPathsExample.java
---
@@ -56,4 +63,77 @@ public static
Robert Metzger created FLINK-1573:
-
Summary: Add per-job metrics to flink.
Key: FLINK-1573
URL: https://issues.apache.org/jira/browse/FLINK-1573
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324359#comment-14324359
]
Robert Metzger commented on FLINK-1556:
---
I think showing the whole stacktrace of the
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/411#discussion_r24833839
--- Diff:
flink-staging/flink-hcatalog/src/main/java/org/apache/flink/hcatalog/HCatInputFormatBase.java
---
@@ -0,0 +1,413 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324237#comment-14324237
]
Daniel Bali commented on FLINK-1522:
Hi Andra!
Vasia said you have other issues to
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Bali updated FLINK-1522:
---
Comment: was deleted
(was: Hi Andra!
Vasia said you have other issues to work on, so I'd happily
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324238#comment-14324238
]
Daniel Bali commented on FLINK-1522:
Hi Andra!
Vasia said you have other issues to
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Bali reassigned FLINK-1522:
--
Assignee: Daniel Bali (was: Andra Lungu)
Add tests for the library methods and examples
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324239#comment-14324239
]
Daniel Bali commented on FLINK-1522:
Hi Andra!
Vasia said you have other issues to
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/393#issuecomment-74744132
What exactly are you running? TPC-H Query 3? Maybe we should test how fast
Kryo would be with the PojoComparator.
---
If your project is set up for it, you can reply to
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/414#issuecomment-74719038
@rmetzger , thanks for the heads up!
Now, instead of returining null, I have a default vertex data set and a
default edge data set. Tell me what you think :).
Fabian Hueske created FLINK-1574:
Summary: Flink fails due to non-initialized RuntimeContext in
CombiningUnilateralSortMerger
Key: FLINK-1574
URL: https://issues.apache.org/jira/browse/FLINK-1574
Andra Lungu created FLINK-1576:
--
Summary: Change the examples to be consistent with the other Flink
examples
Key: FLINK-1576
URL: https://issues.apache.org/jira/browse/FLINK-1576
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu updated FLINK-1576:
---
Summary: Change the Gelly examples to be consistent with the other Flink
examples (was: Change the
Till Rohrmann created FLINK-1566:
Summary: WindowIntegrationTest fails
Key: FLINK-1566
URL: https://issues.apache.org/jira/browse/FLINK-1566
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324893#comment-14324893
]
ASF GitHub Bot commented on FLINK-1417:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324948#comment-14324948
]
ASF GitHub Bot commented on FLINK-947:
--
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/405#discussion_r24858527
--- Diff: docs/linq.md ---
@@ -0,0 +1,65 @@
+---
+title: Language-Integrated Queries
+---
+!--
+Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323931#comment-14323931
]
ASF GitHub Bot commented on FLINK-1549:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/403#issuecomment-74633642
Ok, 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
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/406#issuecomment-74633679
Ok, 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
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324987#comment-14324987
]
Adnan Khan edited comment on FLINK-1388 at 2/17/15 10:11 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14325020#comment-14325020
]
Adnan Khan commented on FLINK-1388:
---
Hey thanks.
* What exactly do you mean by
[
https://issues.apache.org/jira/browse/FLINK-1557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1557.
-
Resolution: Fixed
Fixed via c1e326707a6c5b3cc550945f010eb4cabea24ad3
Move WebFrontend out of
Robert Metzger created FLINK-1567:
-
Summary: Add option to switch between Avro and Kryo serialization
for GenericTypes
Key: FLINK-1567
URL: https://issues.apache.org/jira/browse/FLINK-1567
Project:
Stephan Ewen created FLINK-1561:
---
Summary: Improve build server robustness by not reusing JVMs in
integration tests
Key: FLINK-1561
URL: https://issues.apache.org/jira/browse/FLINK-1561
Project: Flink
Stephan Ewen created FLINK-1563:
---
Summary: NullPointer during state update call
Key: FLINK-1563
URL: https://issues.apache.org/jira/browse/FLINK-1563
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-1564:
Priority: Minor (was: Major)
Make sure BLOB client downloads files only once
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/410#issuecomment-74638095
Cool.
Lets merge this also to master and document it there.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/410#discussion_r24804242
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManager.java
---
@@ -374,6 +375,8 @@ public JobSubmissionResult submitJob(JobGraph
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/410#issuecomment-74642763
Right now, the user has to set the parallelism to
`ExecutionConfig.PARALLELISM_AUTO_MAX`. Why not use all available task slots by
default? I understand, that we shouldn't
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/410#issuecomment-74643785
I agree with Fabian that it is not a good default behavior to grab
everything that is possible.
It should be an explicit request by the user. For YARN single job
Stephan Ewen created FLINK-1562:
---
Summary: Introduce retries for fetching data from the BLOB manager
Key: FLINK-1562
URL: https://issues.apache.org/jira/browse/FLINK-1562
Project: Flink
Issue
Stephan Ewen created FLINK-1564:
---
Summary: Make sure BLOB client downloads files only once
Key: FLINK-1564
URL: https://issues.apache.org/jira/browse/FLINK-1564
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324027#comment-14324027
]
ASF GitHub Bot commented on FLINK-1561:
---
GitHub user StephanEwen opened a pull
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/412
[FLINK-1561] [build system] Use a fresh fork for each integration test run
Helps the build stability on Travis for integration tests.
You can merge this pull request into a Git repository by
Fabian Hueske created FLINK-1565:
Summary: Document object reuse behavior
Key: FLINK-1565
URL: https://issues.apache.org/jira/browse/FLINK-1565
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324120#comment-14324120
]
ASF GitHub Bot commented on FLINK-1549:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324122#comment-14324122
]
ASF GitHub Bot commented on FLINK-1556:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324121#comment-14324121
]
ASF GitHub Bot commented on FLINK-1554:
---
Github user asfgit closed the pull request
Github user martinkiefer commented on the pull request:
https://github.com/apache/flink/pull/402#issuecomment-74660459
I could change `PageRank` to read the number of vertices by broadcasting
the result of `numberofVertices()` instead of providing it in the constructor
of the
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324128#comment-14324128
]
ASF GitHub Bot commented on FLINK-1515:
---
Github user martinkiefer commented on the
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/412#issuecomment-74660789
Looks good to me. +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
Robert Metzger created FLINK-1569:
-
Summary: Object reuse mode is not working with KeySelector
functions.
Key: FLINK-1569
URL: https://issues.apache.org/jira/browse/FLINK-1569
Project: Flink
Ufuk Celebi created FLINK-1571:
--
Summary: Add failure-case tests for blocking data exchange
Key: FLINK-1571
URL: https://issues.apache.org/jira/browse/FLINK-1571
Project: Flink
Issue Type:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/393#issuecomment-74665100
Thank you for reviewing the pull request.
I've addressed your remark, added a fix for another issue (FLINK-1567) and
now I'll run the performance tests.
---
If
[
https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324162#comment-14324162
]
ASF GitHub Bot commented on FLINK-1417:
---
Github user rmetzger commented on the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/403
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/397
---
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-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1549.
Resolution: Fixed
Fixed via 447ce0aa60358212a9716f6b4319f7e9566d6eaa
Add proper exception
[
https://issues.apache.org/jira/browse/FLINK-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1556.
Resolution: Fixed
Fixed via ac7bf427900e60abef3ff4344a5873349e6d108e
JobClient does not wait
[
https://issues.apache.org/jira/browse/FLINK-1554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1554.
Resolution: Fixed
Fixed via 649f158391aebcefcaabcdaa02d5c8b95be45777
LocalFlinkMiniCluster cannot
Ufuk Celebi created FLINK-1568:
--
Summary: Add failure-case tests for data exchange
Key: FLINK-1568
URL: https://issues.apache.org/jira/browse/FLINK-1568
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324134#comment-14324134
]
ASF GitHub Bot commented on FLINK-1561:
---
Github user uce commented on the pull
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/410#issuecomment-74661555
But currently the system does not support multi-user/multi-job scenarios so
well either. If I'm not mistaken, then the scheduler schedules the tasks
eagerly
[
https://issues.apache.org/jira/browse/FLINK-952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-952:
---
Assignee: (was: Till Rohrmann)
TypeExtractor requires the argument types of the UDF to
Ufuk Celebi created FLINK-1570:
--
Summary: Add failure-case tests for pipelined data exchange
Key: FLINK-1570
URL: https://issues.apache.org/jira/browse/FLINK-1570
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1351.
Resolution: Cannot Reproduce
Once we can reproduce this error, we'll open the issue again.
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324164#comment-14324164
]
ASF GitHub Bot commented on FLINK-1567:
---
GitHub user rmetzger opened a pull request:
64 matches
Mail list logo