Márton Balassi created FLINK-2125:
-
Summary: String delimiter for SocketTextStream
Key: FLINK-2125
URL: https://issues.apache.org/jira/browse/FLINK-2125
Project: Flink
Issue Type:
Robert Metzger created FLINK-2126:
-
Summary: Scala shell tests sporadically fail on travis
Key: FLINK-2126
URL: https://issues.apache.org/jira/browse/FLINK-2126
Project: Flink
Issue Type:
Ufuk Celebi created FLINK-2123:
--
Summary: Fix CLI client logging
Key: FLINK-2123
URL: https://issues.apache.org/jira/browse/FLINK-2123
Project: Flink
Issue Type: Bug
Components: Core
Aljoscha Krettek created FLINK-2122:
---
Summary: Make all internal streaming operators Checkpointable
Key: FLINK-2122
URL: https://issues.apache.org/jira/browse/FLINK-2122
Project: Flink
+1
I like it. We are a streaming system underneath after all.
On Jun 1, 2015 10:02 AM, Ufuk Celebi u...@apache.org wrote:
I would like to get this done with the upcoming release to have a stable
name for the documentation.
Thinking about the names with Stephan, he had a great suggestion to
Aljoscha Krettek created FLINK-2124:
---
Summary: FromElementsFunction is not really Serializable
Key: FLINK-2124
URL: https://issues.apache.org/jira/browse/FLINK-2124
Project: Flink
Issue
Hi,
I want to use MultipleLinearRegression, but I got really strange results.
So I tested it with the housing price dataset:
http://archive.ics.uci.edu/ml/machine-learning-databases/housing/housing.data
And here I get negative house prices - even when I use the training set as
dataset:
I would like to get this done with the upcoming release to have a stable
name for the documentation.
Thinking about the names with Stephan, he had a great suggestion to rename
them to streams.
I like this idea very much. The supported result variants make more sense
when you think about them as
I've seen some work on adaptive learning rates in the past days.
Maybe we can think about extending the base algorithm and comparing the use
case setting for the IMPRO-3 project.
@Felix you can discuss this with the others on Wednesday, Manu will be also
there and can give some feedback, I'll
+1
Good list and choices, Marton!
On Mon, Jun 1, 2015 at 5:45 PM, Fabian Hueske fhue...@gmail.com wrote:
Thanks for bringing up this point!
+1 for the renaming.
@Marton: Is this a complete list, i.e., did you go through both APIs or
might there be more methods that are semantically
Thanks for bringing up this point!
+1 for the renaming.
@Marton: Is this a complete list, i.e., did you go through both APIs or
might there be more methods that are semantically identical but named
differently?
2015-06-01 17:31 GMT+02:00 Gyula Fóra gyf...@apache.org:
+1 for the changes
Found the solution: Creating the TypeInformation in Scala and then
passing it to Java where it is used explicitly in the returns method
resolved the issue.
Op Maandag, 01/06/2015 om 16:59 schreef Pieter-Jan Van Aeken:
From the Java API, I get an instance of_ DataSet_ which I wrap with
the
Great, good to hear!
On Jun 1, 2015 5:39 PM, Pieter-Jan Van Aeken
pieterjan.vanae...@euranova.eu wrote:
Found the solution: Creating the TypeInformation in Scala and then
passing it to Java where it is used explicitly in the returns method
resolved the issue.
Op Maandag, 01/06/2015 om 16:59
Yes, these renamings make sense. The partitionBy() is not yet in the
master for streaming, though.
On Mon, Jun 1, 2015 at 4:10 PM, Márton Balassi balassi.mar...@gmail.com wrote:
Looking at the DataSet and DataStream APIs we have come to the conclusion
with Aljoscha that there are a few methods
Thanks for posting this. From what I've found online, this seems to be a
problem related to Akka. For example there is this PR to fix this:
https://github.com/akka/akka/issues/16623
Can you check whether this should have been fixed in the Akka version we are
using and post to the Akka ML if
Andra Lungu created FLINK-2127:
--
Summary: The GSA Documentation has trailing /p s
Key: FLINK-2127
URL: https://issues.apache.org/jira/browse/FLINK-2127
Project: Flink
Issue Type: Bug
Looking at the DataSet and DataStream APIs we have come to the conclusion
with Aljoscha that there are a few methods that although providing the same
functionality are named differently. These are the following:
1. rebalance (batch) / distribute (streaming): Rebalances the data sent
to the
From the Java API, I get an instance of_ DataSet_ which I wrap with
the method available in _org.apache.flink.api.scala.package. _This
works fine when I print out the result, but when I try to write as
CSV, I get an exception:
java.lang.IllegalArgumentException: requirement failed: CSV output
Hi all,
last year I've been working on a web interface for Flink 0.7. It
combines the web interface from the Job Manager and web client, an
additional user management and scheduling jobs. I want to bring my work
up to date and have heard it's a new web interface for the Job Manager
in
we need to add published links to javadoc/scaladoc stuff. Nice job btw
sorting this out.
http://apache.github.io/mahout/0.10.1/docs/mahout-math/
http://apache.github.io/mahout/0.10.1/docs/mahout-math/index.html
http://apache.github.io/mahout/0.10.1/docs/mahout-math-scala
+1 to add this.
On Fri, May 29, 2015 at 12:02 PM, Ufuk Celebi u...@apache.org wrote:
Hey Alexander,
no, it's not possible at the moment. +1 for the idea. I also needed it
once.
I think you will have to look at RuntimeEnvironment, Task, RuntimeContext.
– Ufuk
Ufuk Celebi created FLINK-2128:
--
Summary: ScalaShellITSuite failing
Key: FLINK-2128
URL: https://issues.apache.org/jira/browse/FLINK-2128
Project: Flink
Issue Type: Bug
Components:
The stack trace looks really like the class UserCodeObjectWrapper was not
found.
That is a core Flink runtime class and the fact that it is missing
indicates that there is something inconsistent with your libraries. Either
some JAR files are missing or damaged.
Did you use a downloaded binary
Stephan Ewen created FLINK-2130:
---
Summary: RabbitMQ source does not fail when failing to retrieve
elements
Key: FLINK-2130
URL: https://issues.apache.org/jira/browse/FLINK-2130
Project: Flink
24 matches
Mail list logo
