Hey Alexander,
I have looked into your issue. You can simply use
env.createInput(InputFormat,TypeInformation) instead of env.readFile()
then you can pass TypeInformation manually without implementing
ResultTypeQueryable.
Regards,
Timo
On 29.01.2015 14:54, Alexander Alexandrov wrote:
The
Vasia Kalavri created FLINK-1462:
Summary: Add documentation guide for the graph API
Key: FLINK-1462
URL: https://issues.apache.org/jira/browse/FLINK-1462
Project: Flink
Issue Type: Task
As a quickfix I implmeented ResultTypeQueryable for the
TypeSerializerInputFormat. A PR for the 0.8 branch can be found here
https://github.com/apache/flink/pull/349
Please check and let me know if there is a way to fix the problem without
breaking the 0.8 line API.
2015-01-29 14:54 GMT+01:00
Yes actually the timeouts should not really matter. However, an exception
in the InputSplitAssigner should happen in the actor thread and thus cause
the actor to stop. This should be logged by the supervisor.
I just checked and the method InputSplitAssigner.getNextInputSplit is not
supposed to
@Till: Yes I’m running the job on cloud-11 or better to say I’m using the yarn
cluster and the flink-yarn package. I’m using flink-0.9-SNAPSHOT from the
following commit [1] together with Timos patch [2]. I’ll send you a separate
email with instructions where you can find the jars on
Fabian Hueske created FLINK-1461:
Summary: Add sortPartition operator
Key: FLINK-1461
URL: https://issues.apache.org/jira/browse/FLINK-1461
Project: Flink
Issue Type: New Feature
Alight, thanks for the hint.
I suggest to close PR 349 and refine the exception with a hint HOW exactly
to pass the TypeInformation instance, e.g.
The type returned by the input format could not be automatically
determined. Please pass the TypeInformation of the produced type explicitly
via
Forget what I just said, didn't realize that it's Scala :)
2015-01-29 16:24 GMT+01:00 Alexander Alexandrov
alexander.s.alexand...@gmail.com:
have you tried declaring your UDF classes (e.g. TotalRankDistribution) as
static?
2015-01-29 16:14 GMT+01:00 Arvid Heise arvid.he...@gmail.com:
Hi
have you tried declaring your UDF classes (e.g. TotalRankDistribution) as
static?
2015-01-29 16:14 GMT+01:00 Arvid Heise arvid.he...@gmail.com:
Hi Flinker,
I'm currently desparetely trying to get a workflow to run remotely on a
server. The workflow works fine in the local execution
The problem seems to be that the reflection analysis cannot determine the
type of the TypeSerializerInputFormat.
One possible solution is to add the ResultTypeQueryable interface and force
clients to explicitly set the TypeInformation.
This might break code which relies on automatic type
Hey guys,
I think the JIRA associated to this discussion needs some attention:
https://issues.apache.org/jira/browse/FLINK-1452
On Mon, Jan 26, 2015 at 2:24 PM, Max Michels m...@data-artisans.com wrote:
+1 for having an optional flink-contrib maven dependency and an
extension repository in
A quick and dirty hack revealed that the loader is null at the time of
failure with and without your patch.
On Thu, Jan 29, 2015 at 5:05 PM, Arvid Heise arvid.he...@gmail.com wrote:
Quickfix did not help :/
Any other idea?
On Thu, Jan 29, 2015 at 4:45 PM, Arvid Heise arvid.he...@gmail.com
No I'm using the maven builds, I could try a nightly if you like.
On Thu, Jan 29, 2015 at 4:34 PM, Aljoscha Krettek aljos...@apache.org
wrote:
Hi Arvid,
this indeed looks like a ClassLoader problem. Are you running a
version that you compiled yourself? If yes, could you try replacing
line 49
Quickfix did not help :/
Any other idea?
On Thu, Jan 29, 2015 at 4:45 PM, Arvid Heise arvid.he...@gmail.com wrote:
Nevermind, I'm going to build it myself and try your patch.
On Thu, Jan 29, 2015 at 4:39 PM, Arvid Heise arvid.he...@gmail.com
wrote:
No I'm using the maven builds, I could
W00t! Congrats guys!
On Thu, Jan 29, 2015 at 4:06 PM, Márton Balassi mbala...@apache.org wrote:
Hi everyone,
Thanks for your support for the Flink talks at the community choice for the
next Hadoop Summit Europe. The results are out. [1]
Our submission Real-Time Stream Processing with Apache
15 matches
Mail list logo
