Henry Saputra created FLINK-1603:
Summary: Update how to contribute doc to include information to
send Github PR instead of attaching patch
Key: FLINK-1603
URL: https://issues.apache.org/jira/browse/FLINK-1603
Henry Saputra created FLINK-1602:
Summary: Remove 0.6-incubating from Flink website SVN
Key: FLINK-1602
URL: https://issues.apache.org/jira/browse/FLINK-1602
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-1383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra updated FLINK-1383:
-
Summary: Move the hadoopcompatibility package name to just hadoop (was:
Move the hadoopcompatibil
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333623#comment-14333623
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-75600898
I didn't fully understand that you wanted to have one chart containing all
task managers' load. That's a good thing. If it is only one chart, the overhead
to update it should
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri closed FLINK-1515.
Resolution: Implemented
> [Gelly] Enable access to aggregators and broadcast sets in vertex-centric
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333583#comment-14333583
]
ASF GitHub Bot commented on FLINK-1515:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/402
---
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-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333538#comment-14333538
]
ASF GitHub Bot commented on FLINK-1528:
---
Github user balidani commented on the pull
Github user balidani commented on the pull request:
https://github.com/apache/flink/pull/420#issuecomment-75588338
Hi!
I agree. I will change the example then :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/402#issuecomment-75588051
Thank you @tillrohrmann! Then, I'll go ahead and merge this :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333535#comment-14333535
]
ASF GitHub Bot commented on FLINK-1515:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/420#issuecomment-75586167
Does anyone have an idea about this? Is there a way to pass the
`HashSet` type?
In any case, even if not, I think it doesn't matter in this case.
I believe we sh
[
https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333524#comment-14333524
]
ASF GitHub Bot commented on FLINK-1528:
---
Github user vasia commented on the pull req
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-75578714
I am not sure about that. Would you like to scroll through say 100 detailed
charts where only 5 fit on a screen to check whether there is one ore more
misbehaving nodes?
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333478#comment-14333478
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reopened FLINK-1526:
--
Hi Andra, thanks for working on this issue and opening the PR!
I am reopening this issue for now, be
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333445#comment-14333445
]
ASF GitHub Bot commented on FLINK-1526:
---
GitHub user andralungu opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu resolved FLINK-1526.
Resolution: Implemented
> Add Minimum Spanning Tree library method and example
> ---
GitHub user andralungu opened a pull request:
https://github.com/apache/flink/pull/434
[FLINK-1526] Added MinSpanningTree example, library and test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/andralungu/flink dmst
Alternativ
[
https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1342:
-
Assignee: Robert Metzger
> Quickstart's assembly can possibly filter out user's code
> --
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-75566621
@fhueske The user could do so by selecting "Show all task managers" and
then identify the struggling task manager. For large cluster setups, it makes
sense to sample just from
[
https://issues.apache.org/jira/browse/FLINK-1255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-1255.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Aljoscha Krettek
Fixed by a
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333406#comment-14333406
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user mxm commented on the pull reque
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-75564012
Thanks for the detailed response.
I am not sure how helpful it is to show three random TMs (incl. a shuffling
button to show other random ones). I think it is not uncom
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1490#comment-1490
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user fhueske commented on the pull r
Till Rohrmann created FLINK-1601:
Summary: Sometimes the YARNSessionFIFOITCase fails on Travis
Key: FLINK-1601
URL: https://issues.apache.org/jira/browse/FLINK-1601
Project: Flink
Issue Type:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/408#issuecomment-75557616
I had an offline discussion with @balidani and we figured that the
exception was actually coming from the test, not the GatherSumApplyIteration.
So, no issue here.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/405
---
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-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1474#comment-1474
]
ASF GitHub Bot commented on FLINK-947:
--
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1473#comment-1473
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on the pull req
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-75554187
Looks really nice and informative :+1:
Some suggestions:
- It would be great if one could specify the number of task managers to
see. If the number of task m
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1466#comment-1466
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-1370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Max Michels reassigned FLINK-1370:
--
Assignee: Max Michels
> Build website automatically
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1433#comment-1433
]
ASF GitHub Bot commented on FLINK-1555:
---
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/415#discussion_r25165611
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeType.java
---
@@ -132,7 +133,31 @@ public CompositeType(Class typeClass) {
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1431#comment-1431
]
ASF GitHub Bot commented on FLINK-1567:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1432#comment-1432
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user balidani commented on the pull
Github user balidani commented on the pull request:
https://github.com/apache/flink/pull/408#issuecomment-75546102
Hi @vasia!
Thanks for the review! I started making the changed, but I got stuck. I get
an exception about `GatherUdf` not being Serializable. I tried copying from
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/413#issuecomment-75545980
Exactly, the change is only for 0.8.
For 0.9 its already merged to master using the ExecutionConfig.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1430#comment-1430
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-75545711
Thanks everybody for the positive feedback!
> What does the OS load mean? It would be really awesome to show the CPU
load, too. I think this is a helpful indicator.
Stephan Ewen created FLINK-1600:
---
Summary: Failure when submitting a job leaves user code libraries
in the BLOB manager
Key: FLINK-1600
URL: https://issues.apache.org/jira/browse/FLINK-1600
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1414#comment-1414
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/427#issuecomment-75542199
@tillrohrmann: Thank you for the good feedback!
I'll continue working on this once https://github.com/apache/flink/pull/410
is merged to master.
---
If your project
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/410#issuecomment-75542112
Are there any plans to merge this to master as well?
I need this feature to implement a testcase.
---
If your project is set up for it, you can reply to this email an
[
https://issues.apache.org/jira/browse/FLINK-1599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Max Michels updated FLINK-1599:
---
Summary: TypeComperator with no keys and comparators matches some elements
(was: TypeComperator)
> T
Max Michels created FLINK-1599:
--
Summary: TypeComperator
Key: FLINK-1599
URL: https://issues.apache.org/jira/browse/FLINK-1599
Project: Flink
Issue Type: Bug
Components: Distributed Ru
[
https://issues.apache.org/jira/browse/FLINK-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333295#comment-14333295
]
ASF GitHub Bot commented on FLINK-1553:
---
GitHub user gaborhermann opened a pull requ
GitHub user gaborhermann opened a pull request:
https://github.com/apache/flink/pull/433
[FLINK-1553] [streaming] Reworked Kafka connectors
I refactored the Kafka connectors. It works parallelly: output gets
distributed between Kafka partitions by default, and users can also add a
[
https://issues.apache.org/jira/browse/FLINK-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gábor Hermann updated FLINK-1553:
-
Description: The Kafka connectors should be reworked and tested because it
is not fully functionin
Stephan Ewen created FLINK-1598:
---
Summary: Give better error messages when serializers run out of
space.
Key: FLINK-1598
URL: https://issues.apache.org/jira/browse/FLINK-1598
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333264#comment-14333264
]
ASF GitHub Bot commented on FLINK-1596:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/431#issuecomment-75532734
Will merge this...
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333259#comment-14333259
]
ASF GitHub Bot commented on FLINK-1589:
---
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/427#discussion_r25159356
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ExecutionEnvironmentITCase.java
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333167#comment-14333167
]
Stephan Ewen commented on FLINK-1162:
-
Yep, this one should be resolved.
> Cannot ser
[
https://issues.apache.org/jira/browse/FLINK-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martin Kiefer closed FLINK-1597.
Resolution: Not a Problem
The execution plans are fine. There is no bug.
> VertexCentricIterations
[
https://issues.apache.org/jira/browse/FLINK-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333162#comment-14333162
]
Martin Kiefer commented on FLINK-1597:
--
It appears that the magic word in the executi
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333164#comment-14333164
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333161#comment-14333161
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r25152263
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ExecutionEnvironmentITCase.java
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed t
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r25152294
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ExecutionEnvironmentITCase.java
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed t
[
https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333158#comment-14333158
]
ASF GitHub Bot commented on FLINK-1596:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/431#issuecomment-75513462
Good catch, +1 to merge
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333157#comment-14333157
]
ASF GitHub Bot commented on FLINK-1567:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/413#issuecomment-75513308
I assume that this is targeted at the 0.8 branch?
For the 0.9 branch, it would be nice to use the execution config instead to
define which serializer to instan
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/430#issuecomment-75513013
Looks very good, Vasia!
Big +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
[
https://issues.apache.org/jira/browse/FLINK-1462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333154#comment-14333154
]
ASF GitHub Bot commented on FLINK-1462:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-1505.
Resolution: Implemented
Implemented in 5232c56
> Separate buffer reader and channel consumption log
[
https://issues.apache.org/jira/browse/FLINK-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333140#comment-14333140
]
ASF GitHub Bot commented on FLINK-1505:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/428
---
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-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333139#comment-14333139
]
ASF GitHub Bot commented on FLINK-1505:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/428#issuecomment-75510701
Ok, thanks. I will merge this then.
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1590:
--
Component/s: YARN Client
> Log environment information also in YARN mode
> -
[
https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1590:
--
Affects Version/s: 0.9
> Log environment information also in YARN mode
> ---
[
https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1590:
-
Assignee: Robert Metzger
> Log environment information also in YARN mode
> --
[
https://issues.apache.org/jira/browse/FLINK-1289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1289.
---
Resolution: Fixed
Fix Version/s: 0.8.1
The links are working in the current documentati
[
https://issues.apache.org/jira/browse/FLINK-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1308.
---
Resolution: Fixed
The issue has been resolved in
https://github.com/apache/flink/commit/74bc7
[
https://issues.apache.org/jira/browse/FLINK-567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-567.
Resolution: Invalid
The issue is very old.
The current YARN client is reporting that the YARN session
[
https://issues.apache.org/jira/browse/FLINK-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333101#comment-14333101
]
Robert Metzger commented on FLINK-1162:
---
I guess we can close this issue because we
[
https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1521:
--
Priority: Minor (was: Major)
> Some Chained Drivers do not respect object-reuse/non-reuse flag
[
https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1582:
--
Assignee: Mingliang Qi
> SocketStream gets stuck when socket closes
> --
[
https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333096#comment-14333096
]
Robert Metzger commented on FLINK-1582:
---
I've assigned [~qmlmoon] to the issue, beca
84 matches
Mail list logo
