Github user gyfora closed the pull request at:
https://github.com/apache/flink/pull/526
---
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-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377380#comment-14377380
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user gyfora closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong reassigned FLINK-1770:
-
Assignee: Sibao Hong
> Rename the variable 'contentAdressable' to 'contentAddressable'
>
[
https://issues.apache.org/jira/browse/FLINK-1768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong reassigned FLINK-1768:
-
Assignee: Sibao Hong
> Fix the bug of BlobServerConnection's LOG.
> -
[
https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong reassigned FLINK-1766:
-
Assignee: Sibao Hong
> Fix the bug of equals function of FSKey
>
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/527#issuecomment-85305797
+1 LGTM
---
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
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377067#comment-14377067
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-85285193
@fhueske Hi, Thanks for your kindly advice! I will fix them soon.
About the order of POJO fields, I think also that the option 3 is good.
However, [FLINK-1665](
[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong reassigned FLINK-1739:
-
Assignee: Sibao Hong
> Fix the bug of JobManager and TaskManager Port Check.
> --
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377000#comment-14377000
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-85261367
Hi @chiwanpark, the PR improved a lot! Besides a few inline comments, the
logic and test coverage looks pretty good. Unfortunately, the PR does not seem
to build correctly
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376976#comment-14376976
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r26994167
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/io/CsvReaderWithPOJOITCase.java
---
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376970#comment-14376970
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r26993897
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
---
@@ -247,16 +252,27 @@ class ExecutionEnvironment(javaEnv: JavaE
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376952#comment-14376952
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r26993339
--- Diff:
flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java
---
@@ -219,73 +92,24 @@ public OUT readRecord(OUT reuse, by
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376943#comment-14376943
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r26993011
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/CsvInputFormatTest.java
---
@@ -684,4 +693,249 @@ private void testRemovingTrailingCR(String
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376939#comment-14376939
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r26992871
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/CsvInputFormatTest.java
---
@@ -684,4 +693,249 @@ private void testRemovingTrailingCR(String
[
https://issues.apache.org/jira/browse/FLINK-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376913#comment-14376913
]
Stephan Ewen commented on FLINK-1611:
-
There should only be classes in flink-tests any
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376906#comment-14376906
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r26991431
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -234,9 +301,23 @@ public OUT readRecord(OUT reuse, byte[] bytes, int
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/527
Adds akka configuration description
Adds description of the akka configuration parameters to the configuration
description.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376899#comment-14376899
]
Stephan Ewen commented on FLINK-1319:
-
Very nice result, a very much anticipated featu
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/512#issuecomment-85245168
Ok, I'll close this PR and open a new one only containing the respective
configuration documentation.
---
If your project is set up for it, you can reply to this ema
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/512
---
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-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376885#comment-14376885
]
ASF GitHub Bot commented on FLINK-1650:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/518#issuecomment-85244078
+1 nice find
---
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
en
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376860#comment-14376860
]
ASF GitHub Bot commented on FLINK-1775:
---
GitHub user gyfora opened a pull request:
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/526
[FLINK-1775] BarrierBuffer fix to avoid end of stream deadlock
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/flink FLINK-1775
Alternat
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/518#issuecomment-85239319
Great to hear that you figured out why we could not suppress this error :-)
On Mon, Mar 23, 2015 at 8:33 PM, Robert Metzger
wrote:
> The build pa
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376848#comment-14376848
]
ASF GitHub Bot commented on FLINK-1650:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-1775:
--
Component/s: Streaming
> BarrierBuffers don't correctly handle end of stream events
> --
[
https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376777#comment-14376777
]
ASF GitHub Bot commented on FLINK-1656:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/525
[FLINK-1656] Filter ForwardedField properties for group-at-a-time operators
in Optimizer
Restricts forward field information for group-wise operators.
- For `GroupReduce`, `GroupCombine`, an
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/524#issuecomment-85223415
bad style habits ^^
thanks for reminding me. I also made a minor fix to the test too.
---
If your project is set up for it, you can reply to this email and have y
[
https://issues.apache.org/jira/browse/FLINK-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376698#comment-14376698
]
ASF GitHub Bot commented on FLINK-1472:
---
Github user qmlmoon commented on the pull r
Github user qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/439#issuecomment-85207647
The default key value pairs are added manually. It seems that some of the
keys in `ConfigConstant` is deleted recently.
---
If your project is set up for it, you can repl
[
https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376625#comment-14376625
]
ASF GitHub Bot commented on FLINK-1726:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/505#issuecomment-85194124
Leave it to @rmetzger to be uber meticulous :D
I will add the bullet point! Thanks!
---
If your project is set up for it, you can reply to this email and have your
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/503#issuecomment-85188465
The code looks good. Impressive test coverage, some documentation, amazing
feature.
Once the political issues (name) are resolved, :+1: to merge.
Do you think
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/503#discussion_r26977728
--- Diff:
flink-staging/flink-table/src/test/java/org/apache/flink/api/java/table/test/AggregationsITCase.java
---
@@ -0,0 +1,210 @@
+/*
+ * Licensed
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/503#discussion_r26975267
--- Diff:
flink-staging/flink-table/src/main/java/org/apache/flink/api/java/table/package-info.java
---
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apac
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/503#discussion_r26975057
--- Diff: docs/linq.md ---
@@ -23,58 +23,91 @@ under the License.
* This will be replaced by the TOC
{:toc}
-**Language-Integrated Queries
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/503#discussion_r26974901
--- Diff: docs/linq.md ---
@@ -23,58 +23,91 @@ under the License.
* This will be replaced by the TOC
{:toc}
-**Language-Integrated Queries
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/503#discussion_r26974798
--- Diff: docs/linq.md ---
@@ -23,58 +23,91 @@ under the License.
* This will be replaced by the TOC
{:toc}
-**Language-Integrated Queries
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/503#discussion_r26974832
--- Diff: docs/linq.md ---
@@ -23,58 +23,91 @@ under the License.
* This will be replaced by the TOC
{:toc}
-**Language-Integrated Queries
[
https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376547#comment-14376547
]
ASF GitHub Bot commented on FLINK-1726:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/505#issuecomment-85173349
I didn't see a bigger issue in the code, but @vasia is the authority on
this ;)
It would be nice to add at least another bullet to this list:
http://ci.apache.org/pro
[
https://issues.apache.org/jira/browse/FLINK-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376533#comment-14376533
]
ASF GitHub Bot commented on FLINK-1472:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/439#issuecomment-85170765
According to travis, the code doesn't seem to build.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/512#issuecomment-85169924
+1 for updating the configuration guide with the Akka variables.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376525#comment-14376525
]
ASF GitHub Bot commented on FLINK-1770:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/515#issuecomment-85169638
LGTM
---
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 an
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376463#comment-14376463
]
ASF GitHub Bot commented on FLINK-1650:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/518#issuecomment-85160071
The build passed in my travis:
https://travis-ci.org/rmetzger/flink/builds/55487319
---
If your project is set up for it, you can reply to this email and have your
reply
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/520#issuecomment-85159538
+1 for more streaming tests ;) (... and apparently, they seem to help
finding bugs ;) )
Btw, you don't have to use marton's github repository to open pull
reques
[
https://issues.apache.org/jira/browse/FLINK-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376457#comment-14376457
]
ASF GitHub Bot commented on FLINK-1595:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376441#comment-14376441
]
ASF GitHub Bot commented on FLINK-1595:
---
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/520#discussion_r26969917
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/complex/ComplexIntegrationTest.java
---
@@ -0,0 +1,
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/520#discussion_r26969789
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/complex/ComplexIntegrationTest.java
---
@@ -0,0 +1,
[
https://issues.apache.org/jira/browse/FLINK-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376437#comment-14376437
]
ASF GitHub Bot commented on FLINK-1595:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376427#comment-14376427
]
ASF GitHub Bot commented on FLINK-1687:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/521#issuecomment-85154634
Ah, it would also be good to rebase this PR to the current master to get
some feedback from travis
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376425#comment-14376425
]
ASF GitHub Bot commented on FLINK-1687:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/521#issuecomment-85154551
Would it make sense to add a API completeness checker between the streaming
and batch java API (similar to the java/scala API completeness checker?) The
whitelist is prob
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376413#comment-14376413
]
ASF GitHub Bot commented on FLINK-1687:
---
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/521#discussion_r26968237
--- Diff:
flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ReadFileExample.java
---
@@ -0,0 +1,37 @@
[
https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1774:
--
Assignee: Sibao Hong
> Remove the redundant code in try{} block
> --
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/523#issuecomment-85145673
Great, thank you!
---
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 featu
[
https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376407#comment-14376407
]
Robert Metzger commented on FLINK-1774:
---
Hi [~matadorhong], I gave you "Contributor"
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/523#issuecomment-85144869
Thanks :) I can modify the windowing integation tests slightly to also test
this feature. (Some of them already test it)
And I will make the fixes of course.
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/523#issuecomment-85143338
Very cool feature ;)
I know its annoying, but it would be great if you could quickly mention it
in the documentation and add at least one test for it.
---
If your pr
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/523#discussion_r26967296
--- Diff:
flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/windowing/SessionWindowing.java
---
@@ -0,
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/523#discussion_r26966979
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CentralActiveTrigger.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376379#comment-14376379
]
Gyula Fora commented on FLINK-1773:
---
Thanks, I forgot :)
> Add interface for grouped po
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/523#discussion_r26966951
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CentralActiveTrigger.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376372#comment-14376372
]
ASF GitHub Bot commented on FLINK-1773:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1773:
--
Assignee: Gyula Fora
> Add interface for grouped policies to broadcast information to other grou
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/523#issuecomment-85140059
I'm assigning you to the JIRA:
https://issues.apache.org/jira/browse/FLINK-1773
---
If your project is set up for it, you can reply to this email and have your
reply app
[
https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1773:
--
Affects Version/s: 0.9
> Add interface for grouped policies to broadcast information to other gr
[
https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1773:
--
Component/s: Streaming
> Add interface for grouped policies to broadcast information to other gr
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/524#discussion_r26966049
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/IterateTest.java
---
@@ -87,7 +90,10 @@ public void
GitHub user senorcarbone opened a pull request:
https://github.com/apache/flink/pull/524
[Flink-1686] Streaming Iterations Slot Sharing Fix
Iteration head instances were using the same identifier for slot sharing
which resulted into incorrect execution for streaming iterations. I h
[
https://issues.apache.org/jira/browse/FLINK-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376226#comment-14376226
]
Henry Saputra commented on FLINK-1659:
--
Hi [~StephanEwen], I am assign this to you so
[
https://issues.apache.org/jira/browse/FLINK-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra updated FLINK-1659:
-
Assignee: Stephan Ewen (was: Henry Saputra)
> Rename classes and packages that contains Pact
> --
[
https://issues.apache.org/jira/browse/FLINK-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra updated FLINK-1611:
-
Description:
We have several classes and packages names that have Nephele names:
./flink-tests/sr
[
https://issues.apache.org/jira/browse/FLINK-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra reopened FLINK-1611:
--
Looks like FLINK-441 only covers the compiler/ optimizer scenario
> Rename classes and packages tha
[
https://issues.apache.org/jira/browse/FLINK-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra reassigned FLINK-1659:
Assignee: Henry Saputra
> Rename classes and packages that contains Pact
>
[
https://issues.apache.org/jira/browse/FLINK-1693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376211#comment-14376211
]
Henry Saputra commented on FLINK-1693:
--
Ok, assign it to me now. LMK if anyone wants
[
https://issues.apache.org/jira/browse/FLINK-1693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra reassigned FLINK-1693:
Assignee: Henry Saputra
> Deprecate the Spargel API
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi resolved FLINK-1767.
---
Resolution: Implemented
Fix Version/s: 0.9
Thanks, Gabor. Implemented via e83d1ec.
> S
Fabian Hueske created FLINK-1776:
Summary: APIs provide invalid Semantic Properties for Operators
with SelectorFunction keys
Key: FLINK-1776
URL: https://issues.apache.org/jira/browse/FLINK-1776
Proje
[
https://issues.apache.org/jira/browse/FLINK-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376184#comment-14376184
]
ASF GitHub Bot commented on FLINK-1767:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/516
---
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-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-1775:
-
Assignee: Gyula Fora
> BarrierBuffers don't correctly handle end of stream events
> -
Gyula Fora created FLINK-1775:
-
Summary: BarrierBuffers don't correctly handle end of stream events
Key: FLINK-1775
URL: https://issues.apache.org/jira/browse/FLINK-1775
Project: Flink
Issue Type
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/523
Introduced CentralActiveTrigger with GroupedActiveDiscretizer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/flink session
Alternativel
1 - 100 of 193 matches
Mail list logo
