[
https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1628.
--
Resolution: Fixed
Fixed with b0a57c32fc68d4a1369e5ece25d3a6e986ee1e2a
> Strange behavior of "wh
[
https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353989#comment-14353989
]
ASF GitHub Bot commented on FLINK-1628:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/458
---
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-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353876#comment-14353876
]
joey commented on FLINK-1536:
-
OK, seems no algorithm is listed for graph partition, perhaps t
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353834#comment-14353834
]
Vasia Kalavri commented on FLINK-1536:
--
Hi [~ayd],
can you please give me some detai
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353820#comment-14353820
]
Vasia Kalavri commented on FLINK-1536:
--
Hi [~joey00!]!
It would be great if you coul
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353709#comment-14353709
]
joey commented on FLINK-1536:
-
Thank you, I will pay attention to it. Now i am try to get fami
[
https://issues.apache.org/jira/browse/FLINK-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353651#comment-14353651
]
Henry Saputra commented on FLINK-1106:
--
With more new code coming in we should remove
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/408#discussion_r26074204
--- Diff: flink-staging/flink-gelly/pom.xml ---
@@ -52,4 +52,35 @@ under the License.
test
+
+
+
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353571#comment-14353571
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on a diff in th
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/468
[FLINK-1629][FLINK-1630][FLINK-1547] Rework Flink on YARN
The main change here is a reworked container scheduling logic in the YARN
ApplicationMaster.
This commit is changing:
[FLINK-1
[
https://issues.apache.org/jira/browse/FLINK-1629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353475#comment-14353475
]
ASF GitHub Bot commented on FLINK-1629:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353460#comment-14353460
]
Robert Metzger commented on FLINK-1388:
---
Thank you for updating your changes.
There
[
https://issues.apache.org/jira/browse/FLINK-1644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353445#comment-14353445
]
Robert Metzger commented on FLINK-1644:
---
Thank you for the bug report.
I hope to fin
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353440#comment-14353440
]
ASF GitHub Bot commented on FLINK-1514:
---
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/408#discussion_r26066814
--- Diff: flink-staging/flink-gelly/pom.xml ---
@@ -52,4 +52,35 @@ under the License.
test
+
+
[
https://issues.apache.org/jira/browse/FLINK-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353414#comment-14353414
]
ASF GitHub Bot commented on FLINK-1605:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/454#issuecomment-77921349
The pull request has been rebased to master.
I'm looking for some feedback for this change.
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353399#comment-14353399
]
ASF GitHub Bot commented on FLINK-1622:
---
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/466#discussion_r26064533
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/operators/base/GroupReducePartialOperatorBase.java
---
@@ -0,0 +1,150 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353328#comment-14353328
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353326#comment-14353326
]
ASF GitHub Bot commented on FLINK-1667:
---
Github user rmetzger commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/459#issuecomment-77912519
A `setNumberOfExecutionRetries(int)` method is really needed in the
`StreamExecutionEnvironment`. I'm adding it to a separate upcoming PR working
on [1].
[1] htt
[
https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353327#comment-14353327
]
ASF GitHub Bot commented on FLINK-1669:
---
Github user mbalassi commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/467#issuecomment-77912062
Nice test ;)
+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 fea
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-77912526
@teabot: We've created this JIRA for the feature you've suggested:
https://issues.apache.org/jira/browse/FLINK-1665
---
If your project is set up for it, you can reply t
[
https://issues.apache.org/jira/browse/FLINK-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353312#comment-14353312
]
Robert Metzger commented on FLINK-1663:
---
Yep, users often request this.
+1
> Add a
Márton Balassi created FLINK-1669:
-
Summary: Streaming tests for recovery with distributed process
failure
Key: FLINK-1669
URL: https://issues.apache.org/jira/browse/FLINK-1669
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353246#comment-14353246
]
Flavio Pompermaier commented on FLINK-1663:
---
Definitely useful! +1
> Add a FIFO
Stephan Ewen created FLINK-1668:
---
Summary: Add a config option to specify delays between restarts
Key: FLINK-1668
URL: https://issues.apache.org/jira/browse/FLINK-1668
Project: Flink
Issue Type
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/465#discussion_r26057220
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingPreReducer.java
---
@@
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/465#discussion_r26056710
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingPreReducer.java
---
@
[
https://issues.apache.org/jira/browse/FLINK-1667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353229#comment-14353229
]
ASF GitHub Bot commented on FLINK-1667:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/467
[FLINK-1667] [runtime] Add test for recovery after TaskManager process
failure
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StephanEwen/i
Stephan Ewen created FLINK-1667:
---
Summary: Add tests for recovery with distributed process failure
Key: FLINK-1667
URL: https://issues.apache.org/jira/browse/FLINK-1667
Project: Flink
Issue Typ
Fabian Hueske created FLINK-1666:
Summary: Clean-up Field Expression Code
Key: FLINK-1666
URL: https://issues.apache.org/jira/browse/FLINK-1666
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1664:
-
Summary: Forbid sorting on POJOs (was: Fix sorting on POJO fields)
> Forbid sorting on POJOs
> --
[
https://issues.apache.org/jira/browse/FLINK-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-1664:
Assignee: Fabian Hueske
> Forbid sorting on POJOs
> ---
>
>
Fabian Hueske created FLINK-1665:
Summary: Add optional annotations for POJOs to specify the order
of fields
Key: FLINK-1665
URL: https://issues.apache.org/jira/browse/FLINK-1665
Project: Flink
Fabian Hueske created FLINK-1664:
Summary: Fix sorting on POJO fields
Key: FLINK-1664
URL: https://issues.apache.org/jira/browse/FLINK-1664
Project: Flink
Issue Type: Bug
Components
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/459#issuecomment-77896633
Thanks for the review, @StephanEwen. We have addressed the issues you have
mentioned and squashed the commits a bit. Hopefully the PR is ready to merge.
---
If your pro
Fabian Hueske created FLINK-1663:
Summary: Add a FIFO job scheduler to the JobManager
Key: FLINK-1663
URL: https://issues.apache.org/jira/browse/FLINK-1663
Project: Flink
Issue Type: New Feat
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353199#comment-14353199
]
Vasia Kalavri commented on FLINK-1536:
--
Hi [~ayd],
for more information on what your
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/466
[FLINK-1622][java-api][scala-api] add a partial GroupReduce operator
The partial GroupReduce operator acts like a regular GroupReduce
operator but does not perform a full group reduce. Instead, it per
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353179#comment-14353179
]
ASF GitHub Bot commented on FLINK-1622:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-1576:
Assignee: Vasia Kalavri (was: Daniel Bali)
> Change the Gelly examples to be consistent wi
[
https://issues.apache.org/jira/browse/FLINK-1576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353173#comment-14353173
]
Vasia Kalavri commented on FLINK-1576:
--
I'll take care of what is left for this one,
[
https://issues.apache.org/jira/browse/FLINK-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra resolved FLINK-1651.
--
Resolution: Fixed
merge to master
> Running mvn test got stuck
> --
>
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/461
---
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-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353163#comment-14353163
]
ASF GitHub Bot commented on FLINK-1651:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/460
---
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
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/459#discussion_r26050008
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/simple/KafkaConsumerIterator.java
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/459#discussion_r26050037
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/simple/KafkaConsumerIterator.java
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/459#discussion_r26049847
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/simple/KafkaConsumerIterator.java
Péter Szabó created FLINK-1662:
--
Summary: NullFieldException is thrown when testing
IterativeDataStream with tuples, windowing and maxBy
Key: FLINK-1662
URL: https://issues.apache.org/jira/browse/FLINK-1662
[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353144#comment-14353144
]
Sachin Goel commented on FLINK-1537:
Hi Till
One possible idea to work on this would b
[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353134#comment-14353134
]
Sachin Goel edited comment on FLINK-1537 at 3/9/15 3:56 PM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353134#comment-14353134
]
Sachin Goel commented on FLINK-1537:
I really like the idea of asynchronous iterations
[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353130#comment-14353130
]
Sachin Goel commented on FLINK-1537:
Hi Till
Thanks for such a detailed description. I
[
https://issues.apache.org/jira/browse/FLINK-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353040#comment-14353040
]
Wepngong Ngeh Benaiah commented on FLINK-1617:
--
Hello!
I am interested in wor
[
https://issues.apache.org/jira/browse/FLINK-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-1641:
--
Assignee: Gabor Gevay
> Make projection operator chainable
> --
[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353025#comment-14353025
]
Till Rohrmann commented on FLINK-1537:
--
>From the algorithmic point of view, it would
[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353019#comment-14353019
]
Till Rohrmann commented on FLINK-1537:
--
Some of the more system-side topics could be:
[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353005#comment-14353005
]
Till Rohrmann edited comment on FLINK-1537 at 3/9/15 2:15 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14353005#comment-14353005
]
Till Rohrmann commented on FLINK-1537:
--
Hi Sachin,
great to hear that you're interest
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/465
Windowing features / fixes
This PR introduces several key optimization features and some fixes for
different windowing JIRA-s
- Parallel count window discretization in case of parallel inputs
[
https://issues.apache.org/jira/browse/FLINK-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Péter Szabó reassigned FLINK-1560:
--
Assignee: Péter Szabó (was: Márton Balassi)
> Add ITCases for streaming examples
> ---
[
https://issues.apache.org/jira/browse/FLINK-1652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14352822#comment-14352822
]
ASF GitHub Bot commented on FLINK-1652:
---
GitHub user vasia opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14352821#comment-14352821
]
Ufuk Celebi commented on FLINK-1660:
It is not reproducible by just running it. It onl
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/464
[FLINK-1652] fixes superstep increment in CollectionExecutor
- The superstep number was not properly incremented and passed
toVertexCentricIteration used in Spargel and Gelly, in Collection mode.
-
[
https://issues.apache.org/jira/browse/FLINK-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14352772#comment-14352772
]
Jonas Traub commented on FLINK-1660:
Hi,
Just a few words about what this test does:
Andra Lungu created FLINK-1661:
--
Summary: No Documentation for the isWeaklyConnected() Method
Key: FLINK-1661
URL: https://issues.apache.org/jira/browse/FLINK-1661
Project: Flink
Issue Type: Wis
Ufuk Celebi created FLINK-1660:
--
Summary: MultiTriggerPolicyTest timeout during test
Key: FLINK-1660
URL: https://issues.apache.org/jira/browse/FLINK-1660
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14352685#comment-14352685
]
ASF GitHub Bot commented on FLINK-1637:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1637.
---
Resolution: Fixed
Fix Version/s: 0.9
Resolved in http://git-wip-us.apache.org/repos/asf
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/450
---
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
76 matches
Mail list logo
