Márton Balassi created FLINK-1560:
-
Summary: Add ITCases for streaming examples
Key: FLINK-1560
URL: https://issues.apache.org/jira/browse/FLINK-1560
Project: Flink
Issue Type: Test
[
https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323372#comment-14323372
]
ASF GitHub Bot commented on FLINK-947:
--
Github user mbalassi commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323370#comment-14323370
]
ASF GitHub Bot commented on FLINK-947:
--
Github user mbalassi commented on a diff in th
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/405#discussion_r24778932
--- Diff: flink-staging/flink-linq/pom.xml ---
@@ -0,0 +1,227 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSch
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/405#issuecomment-74579541
Great additions! Really looking to trying it out. :)
---
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 fhueske opened a pull request:
https://github.com/apache/flink/pull/411
[FLINK-1466] Add HCatInputFormats to read from HCatalog tables.
Right now the Flink-tuple mode is restricted to primitive types (no ARRAY,
STRUCT, and MAP types) and the max Java/Scala tuple width.
[
https://issues.apache.org/jira/browse/FLINK-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323344#comment-14323344
]
ASF GitHub Bot commented on FLINK-1466:
---
GitHub user fhueske opened a pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/410
Add auto-parallelism to Jobs (0.8 branch)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StephanEwen/incubator-flink autopar
Alternatively
[
https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323225#comment-14323225
]
ASF GitHub Bot commented on FLINK-785:
--
Github user StephanEwen commented on the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/392#issuecomment-74565272
At this point, we also have to worry about efficiency and performance.
This is also something that the user can easily mitigate in the UDF, at a
fraction of the cos
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/370#issuecomment-74565386
I think we should use the chained reducer from this pull request and drop
the chained combiner change.
---
If your project is set up for it, you can reply to this ema
[
https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323223#comment-14323223
]
ASF GitHub Bot commented on FLINK-1521:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/406#issuecomment-74565029
Looks good to me!
---
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 fe
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/409
[FLINK-1557] Move JobManager web frontend server out of JobManager actor
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StephanEwen/incubato
[
https://issues.apache.org/jira/browse/FLINK-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323219#comment-14323219
]
ASF GitHub Bot commented on FLINK-1556:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-1557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323218#comment-14323218
]
ASF GitHub Bot commented on FLINK-1557:
---
GitHub user StephanEwen opened a pull reque
[
https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1542.
-
Resolution: Fixed
Fix Version/s: 0.9
Fixed via 5ab1f1f197b4ab86382e7e20b4964e991663b62c
>
[
https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323208#comment-14323208
]
ASF GitHub Bot commented on FLINK-1542:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/396
---
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-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323205#comment-14323205
]
ASF GitHub Bot commented on FLINK-1454:
---
Github user StephanEwen closed the pull req
[
https://issues.apache.org/jira/browse/FLINK-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323204#comment-14323204
]
ASF GitHub Bot commented on FLINK-1454:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/404#issuecomment-74563335
Manually merged in b941cf2d091bb38b9a45e1f2412136acae2b0f3f
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/404
---
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-1559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1559.
-
Resolution: Fixed
Fixed via 2dcff4c122f37ca58a485e886fec9295fef0c832
> Normalize all Akka URLs to
[
https://issues.apache.org/jira/browse/FLINK-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1454.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Stephan Ewen
Fixed via b941cf2d091b
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/396#issuecomment-74558015
Thanks for the review Ufuk and Stephan.
Also thx for Stephan for merging it.
---
If your project is set up for it, you can reply to this email and have your
repl
[
https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323150#comment-14323150
]
ASF GitHub Bot commented on FLINK-1542:
---
Github user hsaputra commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323147#comment-14323147
]
ASF GitHub Bot commented on FLINK-1542:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/396#issuecomment-74556700
Looks good to me as well. Will merge it with the next batch...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
Stephan Ewen created FLINK-1559:
---
Summary: Normalize all Akka URLs to use IP addresses, not hostnames
Key: FLINK-1559
URL: https://issues.apache.org/jira/browse/FLINK-1559
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323032#comment-14323032
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user balidani commented on a diff in
Github user balidani commented on a diff in the pull request:
https://github.com/apache/flink/pull/408#discussion_r24763748
--- Diff:
flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java
---
@@ -0,0 +1,212 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14323029#comment-14323029
]
ASF GitHub Bot commented on FLINK-1514:
---
GitHub user balidani opened a pull request:
GitHub user balidani opened a pull request:
https://github.com/apache/flink/pull/408
[FLINK-1514][Gelly] Add a Gather-Sum-Apply iteration method
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/balidani/flink gelly-gsa
Alternativ
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/389#issuecomment-74535643
Subsumed by #407.
---
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
Github user uce closed the pull request at:
https://github.com/apache/flink/pull/389
---
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 enabled
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/407
[builds] Allow to upload build artifacts to S3
This PR includes #389.
Currently, logging of Travis builds is disabled as the log files are
discarded after a build and stdout logging is limited i
Stephan Ewen created FLINK-1558:
---
Summary: Spurious failure in PipelinedPartitionQueueTest
Key: FLINK-1558
URL: https://issues.apache.org/jira/browse/FLINK-1558
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322906#comment-14322906
]
ASF GitHub Bot commented on FLINK-1528:
---
Github user vasia commented on the pull req
Stephan Ewen created FLINK-1557:
---
Summary: Move WebFrontend out of JobManager Actor
Key: FLINK-1557
URL: https://issues.apache.org/jira/browse/FLINK-1557
Project: Flink
Issue Type: Improvement
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/400#issuecomment-74527767
Right, so let me copy:
The problem is here:
```
DataSet>> neighborhoods = input.reduceOnEdges(new
NeighborhoodEdgesFunction(), EdgeDirection.OUT);
```
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322886#comment-14322886
]
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/402#issuecomment-74525590
Hi @martinkiefer! Thanks a lot for this pull request!
The change looks good :)
I was only thinking that it would be nice to have an example that
demonstrates how
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/406
[FLINK-1556] Corrects faulty JobClient behaviour in case of a submission
failure
If an error occurred during job submission, a ```SubmissionFailure``` is
sent to the ```JobClient```. As a react
[
https://issues.apache.org/jira/browse/FLINK-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322884#comment-14322884
]
ASF GitHub Bot commented on FLINK-1556:
---
GitHub user tillrohrmann opened a pull requ
Till Rohrmann created FLINK-1556:
Summary: JobClient does not wait until a job failed completely if
submission exception
Key: FLINK-1556
URL: https://issues.apache.org/jira/browse/FLINK-1556
Project:
[
https://issues.apache.org/jira/browse/FLINK-1554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322860#comment-14322860
]
ASF GitHub Bot commented on FLINK-1554:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/403#issuecomment-74523049
Perfect. I've justed the code and its working now.
---
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
Robert Metzger created FLINK-1555:
-
Summary: Add utility to log the serializers of composite types
Key: FLINK-1555
URL: https://issues.apache.org/jira/browse/FLINK-1555
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322816#comment-14322816
]
ASF GitHub Bot commented on FLINK-947:
--
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/405
[FLINK-947] Add a declarative expression API
This one is quite big. So you should check out the documentation, skaldic,
examples and test cases to see how the API works.
You can merge this pull req
[
https://issues.apache.org/jira/browse/FLINK-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1539.
-
Resolution: Fixed
Fixed via 4470207
> Runtime context not initialized when running streaming Pojo
[
https://issues.apache.org/jira/browse/FLINK-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1176.
-
Resolution: Implemented
Implemented via 1146f64 and c560d76.
> Add operator for global reduce/agg
[
https://issues.apache.org/jira/browse/FLINK-1231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1231.
-
Resolution: Fixed
Implemented via 26ae979
> Add test for streaming remote execution
> ---
[
https://issues.apache.org/jira/browse/FLINK-1231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322808#comment-14322808
]
ASF GitHub Bot commented on FLINK-1231:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/395
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/303
---
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-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322803#comment-14322803
]
ASF GitHub Bot commented on FLINK-1454:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/404
[FLINK-1454] [job client] Improve error handling for failed connections
between JobClient and JobManager
- Decreases time until connection failure is discovered.
- Improves error messages
[
https://issues.apache.org/jira/browse/FLINK-1554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322797#comment-14322797
]
ASF GitHub Bot commented on FLINK-1554:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/403
[FLINK-1554] Allows the LocalFlinkMiniCluster to start multiple TaskManager
in the same ActorSystem
Allows the ```LocalFlinkMiniCluster``` to start multiple ```TaskManager```
in the same ```Act
Till Rohrmann created FLINK-1554:
Summary: LocalFlinkMiniCluster cannot start multiple local
TaskManagers
Key: FLINK-1554
URL: https://issues.apache.org/jira/browse/FLINK-1554
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322791#comment-14322791
]
ASF GitHub Bot commented on FLINK-1542:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/396#issuecomment-74511789
Thanks, Henry. The change 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 projec
[
https://issues.apache.org/jira/browse/FLINK-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322787#comment-14322787
]
ASF GitHub Bot commented on FLINK-1549:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/397#issuecomment-74511630
Looks good. Very much needed for our YARN deployment.
---
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 p
[
https://issues.apache.org/jira/browse/FLINK-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322766#comment-14322766
]
Vasia Kalavri commented on FLINK-1552:
--
This would be very useful to have! Would you
[
https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322743#comment-14322743
]
ASF GitHub Bot commented on FLINK-1417:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322741#comment-14322741
]
ASF GitHub Bot commented on FLINK-1528:
---
Github user balidani commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/393#issuecomment-74505787
Looks good except for the one remark I had.
Did you run any performance tests on this? What is the overhead of using an
Avro POJO vs. a plain POJO vs. using the K
Github user balidani commented on the pull request:
https://github.com/apache/flink/pull/400#issuecomment-74505722
Hi!
Sorry for the messed up commit history, hopefully my next PR will be better.
I have the following exception when running
`LocalClusteringCoefficientE
[
https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322736#comment-14322736
]
ASF GitHub Bot commented on FLINK-1417:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/393#discussion_r24749284
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -292,7 +360,76 @@ public void registerKryoType(Class type) {
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/401
---
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-1362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1362.
Resolution: Fixed
Fixed via 4046819b380b8dfa57d52c6d314f389546a159a3
> Spurious errors in execution
[
https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322699#comment-14322699
]
ASF GitHub Bot commented on FLINK-1542:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/396#issuecomment-74500203
Ping for review?
---
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 featur
[
https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322649#comment-14322649
]
ASF GitHub Bot commented on FLINK-1528:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/400#issuecomment-74493011
Hi @balidani! Thanks for the PR. The commit history is a bit messed up, but
we'll fix that. It's just the last commit that's relevant, right?
If I recall correctly,
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/303#issuecomment-74480487
Sorry for the late reply. Thanks for the great PR, I wanted to merge it for
quite some time. It turns out that this test is redundant given the 6bec228
I've pushed last w
[
https://issues.apache.org/jira/browse/FLINK-1231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322565#comment-14322565
]
ASF GitHub Bot commented on FLINK-1231:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1551.
Resolution: Fixed
Fixed via 055f6dc3eb8705dbbfb04e44965a85cbfc0b10db
> Fix History view of JobManag
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/395#discussion_r24737554
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/StreamWindowTypeInfo.java
---
@@ -0,0 +1,
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/395#discussion_r24737330
--- Diff: docs/streaming_guide.md ---
@@ -857,7 +895,7 @@ After installing Docker an image can be pulled for each
connector. Containers ca
For the easies
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/395#discussion_r24737233
--- Diff: docs/streaming_guide.md ---
@@ -383,9 +389,40 @@
dataStream.groupBy(groupingField).window(Count.of(100)).every(â¦).max(field);
This will
Gábor Hermann created FLINK-1553:
Summary: Kafka connectors rework
Key: FLINK-1553
URL: https://issues.apache.org/jira/browse/FLINK-1553
Project: Flink
Issue Type: Bug
Components: S
86 matches
Mail list logo
