[
https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14361311#comment-14361311
]
ASF GitHub Bot commented on FLINK-1450:
---
Github user akshaydixi commented on the pul
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 email
[
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
org.apache.flink.clien
[
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-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra updated FLINK-1704:
-
Description:
The org.apache.flink.runtime.yarn.AbstractFlinkYarnClient and
org.apache.flink.clien
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
Issue
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360802#comment-14360802
]
ASF GitHub Bot commented on FLINK-1622:
---
Github user hsaputra commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 cre
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
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
Project
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.
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 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 t
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360573#comment-14360573
]
ASF GitHub Bot commented on FLINK-1622:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360531#comment-14360531
]
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-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 project
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
sa
[
https://issues.apache.org/jira/browse/FLINK-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360462#comment-14360462
]
Henry Saputra commented on FLINK-1659:
--
I am kind of lean on Optimizer too since it i
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 inte
[
https://issues.apache.org/jira/browse/FLINK-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360460#comment-14360460
]
ASF GitHub Bot commented on FLINK-1350:
---
Github user uce commented on the pull reque
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 hav
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360439#comment-14360439
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user vasia commented on the pull req
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/482#issuecomment-78996549
No, you are right. These parameters are not in the documentation, not even
in the initial import (June last year). I just got used to them ;-)
I still like the exp
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360398#comment-14360398
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user vasia commented on a diff in th
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 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-tabpanel&focusedCommentId=14360400#comment-14360400
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user vasia commented on a diff in th
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-tabpanel&focusedCommentId=14360393#comment-14360393
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user vasia commented on a diff in th
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
+---
+
+
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360392#comment-14360392
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user vasia commented on a diff in th
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
+---
+
+
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360390#comment-14360390
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user vasia commented on a diff in th
[
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 0
[
https://issues.apache.org/jira/browse/FLINK-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360327#comment-14360327
]
ASF GitHub Bot commented on FLINK-1683:
---
Github user asfgit closed the pull request
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 enabl
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
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360287#comment-14360287
]
Robert Metzger commented on FLINK-1650:
---
Right now, we only shade away Hadoop's nett
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 thi
[
https://issues.apache.org/jira/browse/FLINK-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1390.
---
Resolution: Invalid
Assignee: Robert Metzger
The issue wasn't an issue in Flink itself.
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/477#issuecomment-78944120
Okay.
But there is also something wrong with the deployment of the hadoop2 build
to our snapshot repository. I'll look into that at the same time.
---
If your projec
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/477#issuecomment-78942601
It seems that I accidentally removed the `maven-shade-plugin` section from
the new `pom.xml` while rebasing. Let's see whether the tests pass now.
---
If your projec
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360230#comment-14360230
]
Stephan Ewen commented on FLINK-1650:
-
I this YARN specific?
Does the shading affect
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-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
[
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 flink-yarn
[
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)
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360185#comment-14360185
]
Stephan Ewen commented on FLINK-1659:
-
I am working on getting the configurable data e
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360182#comment-14360182
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user tillrohrmann commented on the p
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 w
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360184#comment-14360184
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user tillrohrmann commented on the p
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-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
> -
[
https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360179#comment-14360179
]
Andra Lungu commented on FLINK-1694:
I would also go for the configuration parameter.
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360159#comment-14360159
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-78897265
Hi,
in Java, the CsvOutputFormat used to only emit Tuples, we know that these
are mutable, therefore they are reused. The ScalaCsvOutputFormat emits case
classes (Sca
[
https://issues.apache.org/jira/browse/FLINK-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360144#comment-14360144
]
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-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 somethi
[
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 so
[
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 so
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360124#comment-14360124
]
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-78876571
Hello. I have a question about object reuse in `readRecord` method of
`ScalaCsvInputFormat`. In java implementation, `CsvInputFormat` reuse result
object. But in `Scala
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
Compon
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
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 proj
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360068#comment-14360068
]
ASF GitHub Bot commented on FLINK-1695:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/479#issuecomment-78853645
Hey @junwucs, thats great to hear.
Please let us know if you need any help to put ALS in use at your company.
The u...@flink.apache.org mailing list is always a goo
[
https://issues.apache.org/jira/browse/FLINK-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360034#comment-14360034
]
Akshay Dixit commented on FLINK-1534:
-
Hi Marton,
To get familiar with the codebase an
70 matches
Mail list logo