[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353005#comment-14353005
]
Till Rohrmann commented on FLINK-1537:
--
Hi Sachin,
great to hear that you're
[
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-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=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-1652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=14352821#comment-14352821
]
Ufuk Celebi commented on FLINK-1660:
It is not reproducible by just running it. It
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.
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
[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=14353025#comment-14353025
]
Till Rohrmann commented on FLINK-1537:
--
From the algorithmic point of view, it would
[
https://issues.apache.org/jira/browse/FLINK-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353040#comment-14353040
]
Wepngong Ngeh Benaiah commented on FLINK-1617:
--
Hello!
I am interested in
[
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-tabpanelfocusedCommentId=14353144#comment-14353144
]
Sachin Goel commented on FLINK-1537:
Hi Till
One possible idea to work on this would
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
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/459#discussion_r26050008
--- Diff:
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/459#discussion_r26050037
--- Diff:
[
https://issues.apache.org/jira/browse/FLINK-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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
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
[
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
--
[
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-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353179#comment-14353179
]
ASF GitHub Bot commented on FLINK-1622:
---
GitHub user mxm opened a pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-1667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353229#comment-14353229
]
ASF GitHub Bot commented on FLINK-1667:
---
GitHub user StephanEwen opened a pull
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353328#comment-14353328
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user rmetzger commented on the pull
[
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
[
https://issues.apache.org/jira/browse/FLINK-1576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353173#comment-14353173
]
Vasia Kalavri commented on FLINK-1576:
--
I'll take care of what is left for this one,
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
[
https://issues.apache.org/jira/browse/FLINK-1667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353326#comment-14353326
]
ASF GitHub Bot commented on FLINK-1667:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353327#comment-14353327
]
ASF GitHub Bot commented on FLINK-1669:
---
Github user mbalassi 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]
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
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
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
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
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
---
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
[
https://issues.apache.org/jira/browse/FLINK-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353246#comment-14353246
]
Flavio Pompermaier commented on FLINK-1663:
---
Definitely useful! +1
Add a FIFO
[
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
---
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 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
[
https://issues.apache.org/jira/browse/FLINK-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353312#comment-14353312
]
Robert Metzger commented on FLINK-1663:
---
Yep, users often request this.
+1
Add a
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
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
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
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.
scopetest/scope
/dependency
[
https://issues.apache.org/jira/browse/FLINK-1644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353445#comment-14353445
]
Robert Metzger commented on FLINK-1644:
---
Thank you for the bug report.
I hope to
[
https://issues.apache.org/jira/browse/FLINK-1629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353475#comment-14353475
]
ASF GitHub Bot commented on FLINK-1629:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353651#comment-14353651
]
Henry Saputra commented on FLINK-1106:
--
With more new code coming in we should remove
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353571#comment-14353571
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on a diff in
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.
scopetest/scope
/dependency
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353709#comment-14353709
]
joey commented on FLINK-1536:
-
Thank you, I will pay attention to it. Now i am try to get
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353460#comment-14353460
]
Robert Metzger commented on FLINK-1388:
---
Thank you for updating your changes.
There
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:
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 @@
+/*
+ *
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
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353440#comment-14353440
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353399#comment-14353399
]
ASF GitHub Bot commented on FLINK-1622:
---
Github user hsaputra commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353414#comment-14353414
]
ASF GitHub Bot commented on FLINK-1605:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353834#comment-14353834
]
Vasia Kalavri commented on FLINK-1536:
--
Hi [~ayd],
can you please give me some
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353876#comment-14353876
]
joey commented on FLINK-1536:
-
OK, seems no algorithm is listed for graph partition, perhaps
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
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353820#comment-14353820
]
Vasia Kalavri commented on FLINK-1536:
--
Hi [~joey00!]!
It would be great if you
[
https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353989#comment-14353989
]
ASF GitHub Bot commented on FLINK-1628:
---
Github user asfgit closed the pull request
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:
[
https://issues.apache.org/jira/browse/FLINK-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14352772#comment-14352772
]
Jonas Traub commented on FLINK-1660:
Hi,
Just a few words about what this test does:
[
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
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14352685#comment-14352685
]
ASF GitHub Bot commented on FLINK-1637:
---
Github user asfgit closed the pull request
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
72 matches
Mail list logo
