Felix Cheung created FLINK-2691:
---
Summary: Broken links to Python script on QuickStart doc
Key: FLINK-2691
URL: https://issues.apache.org/jira/browse/FLINK-2691
Project: Flink
Issue Type: Bug
Hi,
fixed it... After trying (without success) to build a minimum Java 8
example that fails (a new project extern to Flink), it was clear that
JDK 8 is actually not the problem.
I did some more debugging an figured out, that different class loader
are used here (for the external new Java 8 and or
No clue, sorry.
The Storm Mailing list may be able to help you, it looks like deep into
their code...
On Wed, Sep 16, 2015 at 9:00 PM, Matthias J. Sax wrote:
> Hi,
>
> using Java 8 locally, I was able to reproduce the problem. I dug into it
> and could figure out the following. However, I canno
Hi,
using Java 8 locally, I was able to reproduce the problem. I dug into it
and could figure out the following. However, I cannot make any sense out
of it. I have no experience with Java security stuff...
Anyone?
-Matthias
===
Chiwan Park created FLINK-2690:
--
Summary: CsvInputFormat cannot find the field of derived POJO class
Key: FLINK-2690
URL: https://issues.apache.org/jira/browse/FLINK-2690
Project: Flink
Issue Ty
Thanks Fabian! At least now I know the bug is probably not in the driver
where I was looking :)
On 16 September 2015 at 17:33, Fabian Hueske wrote:
> Yes, probing the HashTable with a key that does not exist will yield a join
> function call with a null value (or empty iterator in case of CoGrou
Yes, probing the HashTable with a key that does not exist will yield a join
function call with a null value (or empty iterator in case of CoGroup).
The semantics of the join are the same regardless of the hash table
implementation.
The fact that the error only occurs with the managed HT, indicates
Hi,
thanks a lot Fabian!
I didn't know that join with the solution set is an outer join. That's a
surprise :)
So, if I understand correctly, I should have a null value when my other
input to the join contains some key that doesn't exist in the solution set,
right? That's not the case in my appli
Fabian Hueske created FLINK-2689:
Summary: Reusing null object for joins with SolutionSet
Key: FLINK-2689
URL: https://issues.apache.org/jira/browse/FLINK-2689
Project: Flink
Issue Type: Bug
Hi Vasia,
I looked into the code. A serializer should never return null when
deserializing. Either it does not detect that something went wrong with the
deserialization or it should throw an exception.
Regarding the handling of null returns in the Drivers. If there is no entry
in the HT for a cer
Stephan Ewen created FLINK-2688:
---
Summary: Add documentation about monitoring api
Key: FLINK-2688
URL: https://issues.apache.org/jira/browse/FLINK-2688
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-2687:
---
Summary: Moniroting api / web dashboard: Create request handlers
list subtask details and accumulators
Key: FLINK-2687
URL: https://issues.apache.org/jira/browse/FLINK-2687
Not right now... The ClassCastException occurs deeply inside Storm. I
guess it is a Storm issue.
I just instantiate a (Storm)LocalCluster and it fails internally.
> LocalCluster cluster = new LocalCluster();
Maybe I need to try it locally with Java 8 JDK to be able to debug it...
I will pick up
Do you know between what classes the exception is? What is the original
class and what the cast target class?
Are they both the same, and not castable because of different copies being
loaded from different classloaders, or are they really different types?
On Wed, Sep 16, 2015 at 10:36 AM, Matthi
Hi,
I just hit a issue with Java 8 JDK. It occurs in a new test I added in a
current PR.
> Tests run: 5, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 8.793 sec <<<
> FAILURE! - in
> org.apache.flink.stormcompatibility.wrappers.StormWrapperSetupHelperTest
> testCreateTopologyContext(org.apa
15 matches
Mail list logo
