Henry Saputra created FLINK-1704:
Summary: Change AbstractFlinkYarnClient from abstract to interface
Key: FLINK-1704
URL: https://issues.apache.org/jira/browse/FLINK-1704
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360794#comment-14360794
]
ASF GitHub Bot commented on FLINK-1622:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/466#issuecomment-79188765
Thanks @mxm ! I add couple more comments about documentation. I am trying
to promote habit of adding JavaDoc comment for new classes to help indicate why
it has to be
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360802#comment-14360802
]
ASF GitHub Bot commented on FLINK-1622:
---
Github user hsaputra commented on the pull
Emmanuel Leroy created FLINK-1703:
-
Summary: option to balance load according to CPU available rather
than slots available
Key: FLINK-1703
URL: https://issues.apache.org/jira/browse/FLINK-1703
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/466#discussion_r26407753
--- Diff:
flink-compiler/src/main/java/org/apache/flink/compiler/operators/GroupCombineProperties.java
---
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra updated FLINK-1704:
-
Description:
The org.apache.flink.runtime.yarn.AbstractFlinkYarnClient and
[
https://issues.apache.org/jira/browse/FLINK-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra updated FLINK-1704:
-
Summary: Change AbstractFlinkYarnClient and AbstractFlinkYarnCluster from
abstract to interface
[
https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14361311#comment-14361311
]
ASF GitHub Bot commented on FLINK-1450:
---
Github user akshaydixi commented on the
Github user akshaydixi commented on the pull request:
https://github.com/apache/flink/pull/481#issuecomment-79525790
Thanks @gyfora . I've added fold into GroupedDataStream and
WindowedDataStream in subsequent commits.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gábor Hermann updated FLINK-1699:
-
Description:
Connecting two grouped data stream coMapping them and sinking it in a custom
sink
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/454#issuecomment-78889015
Hey Henry,
I'm sorry that the change is making your builds so much slower. My linux
machine needs 5 minutes to build the current master.
I suspect there is
[
https://issues.apache.org/jira/browse/FLINK-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360144#comment-14360144
]
ASF GitHub Bot commented on FLINK-1605:
---
Github user rmetzger commented on the pull
Gábor Hermann created FLINK-1699:
Summary: Co-task sometimes returns null
Key: FLINK-1699
URL: https://issues.apache.org/jira/browse/FLINK-1699
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mustafa elbehery resolved FLINK-1615.
-
Resolution: Fixed
https://github.com/apache/flink/pull/442
Introduces a new InputFormat
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/482#issuecomment-78868258
Its true, the parameters are not necessarily needed, but they don't harm
either. In fact, I like it to explicitly specify parameters. I do not see a
need to break the API
[
https://issues.apache.org/jira/browse/FLINK-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gábor Hermann updated FLINK-1699:
-
Description:
Connecting two grouped data stream coMapping them and sinking it in a custom
sink
[
https://issues.apache.org/jira/browse/FLINK-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360185#comment-14360185
]
Stephan Ewen commented on FLINK-1659:
-
I am working on getting the configurable data
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360184#comment-14360184
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360182#comment-14360182
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/479#issuecomment-78909506
But let's do it on the u...@flink.apache.org mailing list.
---
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-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reopened FLINK-1650:
---
I'm reopening the issue because the exceptions still occur in the current
master.
The
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-78876571
Hello. I have a question about object reuse in `readRecord` method of
`ScalaCsvInputFormat`. In java implementation, `CsvInputFormat` reuse result
object. But in
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360124#comment-14360124
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user chiwanpark commented on the
[
https://issues.apache.org/jira/browse/FLINK-441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-441:
---
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-1659
Renaming in pact-compiler
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/479#issuecomment-78909366
@junwucs great to here that you're using the ALS implementation. Could you
give us some more information about the occurring error? Curious to understand
why you saw
[
https://issues.apache.org/jira/browse/FLINK-82?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-82:
Component/s: Local Runtime
(Hash) Aggregators (fold style)
---
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/482#issuecomment-78858625
You can still use the `-a` and `-j` arguments. But its certainly nicer to
just specify the name of the jar file and the arguments.
+1 to merge.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360159#comment-14360159
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360179#comment-14360179
]
Andra Lungu commented on FLINK-1694:
I would also go for the configuration parameter.
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/477#issuecomment-78953629
I manually deployed the current master to apache's snapshot repository
because travis has failed to upload it.
---
If your project is set up for it, you can reply to
Péter Szabó created FLINK-1701:
--
Summary: Serialization problems with TestStreamEnvironment
Key: FLINK-1701
URL: https://issues.apache.org/jira/browse/FLINK-1701
Project: Flink
Issue Type: Bug
Robert Metzger created FLINK-1700:
-
Summary: Include Google Analytics in Javadocs
Key: FLINK-1700
URL: https://issues.apache.org/jira/browse/FLINK-1700
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360439#comment-14360439
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user vasia commented on the pull
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/479#issuecomment-79001996
Really great work @tillrohrmann!
---
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
[
https://issues.apache.org/jira/browse/FLINK-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360460#comment-14360460
]
ASF GitHub Bot commented on FLINK-1350:
---
Github user uce commented on the pull
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/471#issuecomment-79017193
I've rebased this on the latest master and set the default I/O mode to
synchronous, i.e. we currently use the simpler synchronous spilled subpartition
view when consuming
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/476
---
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-tabpanelfocusedCommentId=14360287#comment-14360287
]
Robert Metzger commented on FLINK-1650:
---
Right now, we only shade away Hadoop's
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360230#comment-14360230
]
Stephan Ewen commented on FLINK-1650:
-
I this YARN specific?
Does the shading affect
[
https://issues.apache.org/jira/browse/FLINK-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360327#comment-14360327
]
ASF GitHub Bot commented on FLINK-1683:
---
Github user asfgit closed the pull request
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/477#issuecomment-79048001
The scala-2.11 build
```bash
mvn -Dscala-2.11 clean install
```
fails on travis when trying to build the quickstart (@rmetzger reported the
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360531#comment-14360531
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user chiwanpark commented on the
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-79066240
@aljoscha Thanks! I understand about it.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1683.
--
Resolution: Fixed
Fixed in 0.9 with 07a9a56c1726b4a7aeb3e682b887d77ab1b0e440
Fixed in 0.8 with
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360392#comment-14360392
]
ASF GitHub Bot commented on FLINK-1695:
---
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/479#discussion_r26388420
--- Diff: docs/ml/polynomial_base_feature_mapper.md ---
@@ -0,0 +1,91 @@
+---
+mathjax: include
+title: Polynomial Base Feature Mapper
+---
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360400#comment-14360400
]
ASF GitHub Bot commented on FLINK-1695:
---
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/479#discussion_r26388007
--- Diff: docs/ml/alternating_least_squares.md ---
@@ -0,0 +1,157 @@
+---
+mathjax: include
+title: Alternating Least Squares
+---
+!--
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/479#discussion_r26387939
--- Diff: docs/ml/alternating_least_squares.md ---
@@ -0,0 +1,157 @@
+---
+mathjax: include
+title: Alternating Least Squares
+---
+!--
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/479#discussion_r26388040
--- Diff: docs/ml/alternating_least_squares.md ---
@@ -0,0 +1,157 @@
+---
+mathjax: include
+title: Alternating Least Squares
+---
+!--
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/479#discussion_r26388389
--- Diff: docs/ml/polynomial_base_feature_mapper.md ---
@@ -0,0 +1,91 @@
+---
+mathjax: include
+title: Polynomial Base Feature Mapper
+---
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360398#comment-14360398
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360390#comment-14360390
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360393#comment-14360393
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user vasia commented on a diff in
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/482#issuecomment-78991357
The issue is that those params are not in command line doc. Or maybe I
misread ?
Removing unnecessary param will make it easier to read.
On Friday, March
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/466#issuecomment-79096322
@aljoscha @fhueske @hsaputra Thanks for the feedback. Some people suggested
that the name is confusing and that my pull request involved too much code
duplication. I propose
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360573#comment-14360573
]
ASF GitHub Bot commented on FLINK-1622:
---
Github user mxm commented on the pull
Maximilian Michels created FLINK-1702:
-
Summary: Authenticate via Kerberos from the client only
Key: FLINK-1702
URL: https://issues.apache.org/jira/browse/FLINK-1702
Project: Flink
Issue
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/482#issuecomment-79140904
Thanks for the input @fhueske. I am trying to make all the example
consistent and removing the parameters seem to be consistent with examples in
the command line page.
60 matches
Mail list logo
