Shall I open an issue for that?
The Exception gets thrown when using
RichFlatJoinFunction or RichFlatMapFunction (updated the Gist)
and the first field of the tuple is an array type.
I can look into it once the issue is there.
Cheers,
Martin
On 10.10.2016 13:39, Chesnay Schepler wrote:
Hell
Yakov Goldberg created FLINK-4795:
-
Summary: CsvStringify crashes in case of tuple in tuple, t.e.
("a", True, (1,5))
Key: FLINK-4795
URL: https://issues.apache.org/jira/browse/FLINK-4795
Project: Flin
Yakov Goldberg created FLINK-4794:
-
Summary: partition_by_hash() crashes if no parameter is provided
Key: FLINK-4794
URL: https://issues.apache.org/jira/browse/FLINK-4794
Project: Flink
Issue
Ted Dunning created FLINK-4793:
--
Summary: Using a local method with :: notation in Java 8 causes
index out of bounds
Key: FLINK-4793
URL: https://issues.apache.org/jira/browse/FLINK-4793
Project: Flink
Hello,
Per documentation
(https://ci.apache.org/projects/flink/flink-docs-master/setup/aws.html), it
looks like S3/S3A FS implementation is supported using standard Hadoop S3 FS
client APIs.
In the absence of using standard HCFS and going with S3/S3A,
1) Are there any known limitations/issues?
Thomas FOURNIER created FLINK-4792:
--
Summary: Update documentation - QuickStart - FlinkML
Key: FLINK-4792
URL: https://issues.apache.org/jira/browse/FLINK-4792
Project: Flink
Issue Type: Imp
Dear Flink community,
Please vote on releasing the following candidate as Apache Flink version 1.1.3.
The commit to be voted on:
8e8d454 (http://git-wip-us.apache.org/repos/asf/flink/commit/8e8d454)
Branch:
release-1.1.3-rc2
(https://git1-us-west.apache.org/repos/asf/flink/repo?p=flink.git;a=sho
Timo Walther created FLINK-4791:
---
Summary: Fix issues caused by expression reduction
Key: FLINK-4791
URL: https://issues.apache.org/jira/browse/FLINK-4791
Project: Flink
Issue Type: Bug
Thomas FOURNIER created FLINK-4790:
--
Summary: FlinkML - Error of type while using readCsvFile
Key: FLINK-4790
URL: https://issues.apache.org/jira/browse/FLINK-4790
Project: Flink
Issue Type:
Robert Metzger created FLINK-4789:
-
Summary: Avoid Kafka partition discovery on restore and share
consumer instance for discovery and data consumption
Key: FLINK-4789
URL: https://issues.apache.org/jira/browse/FLI
Hi Chesnay,
added it to the Gist but also here:
10/10/2016 14:00:44 Job execution switched to status FAILING.
java.lang.ClassCastException: java.lang.Long cannot be cast to
[Ljava.lang.Object;
at
org.apache.flink.api.common.typeutils.base.GenericArraySerializer.serialize(GenericArraySeria
Hello Martin,
Could you include the error you are getting?
Regards,
Chesnay
On 10.10.2016 13:31, Martin Junghanns wrote:
Hi,
I ran into a problem when using generic arrays in a tuple. I wrote a
minimal program to reproduce the error [1].
The problem seems to be related to the order of tupl
Hi,
I ran into a problem when using generic arrays in a tuple. I wrote a
minimal program to reproduce the error [1].
The problem seems to be related to the order of tuple fields. When
I switch Tuple2 to Tuple2 and perform the join on field
0, everything works as expected.
Using Flink 1.1.2.
Florian Koenig created FLINK-4788:
-
Summary: State backend class cannot be loaded, because fully
qualified name converted to lower-case
Key: FLINK-4788
URL: https://issues.apache.org/jira/browse/FLINK-4788
Ufuk Celebi created FLINK-4787:
--
Summary: Add REST API call for cancel-with-savepoints
Key: FLINK-4787
URL: https://issues.apache.org/jira/browse/FLINK-4787
Project: Flink
Issue Type: Improvemen
Robert Metzger created FLINK-4786:
-
Summary: BarrierBufferTest test instability
Key: FLINK-4786
URL: https://issues.apache.org/jira/browse/FLINK-4786
Project: Flink
Issue Type: Bug
Affect
Flavio Pompermaier created FLINK-4785:
-
Summary: Flink string parser doesn't handle string fields
containing double quotes
Key: FLINK-4785
URL: https://issues.apache.org/jira/browse/FLINK-4785
Pro
This vote is cancelled in favour of RC2.
On Mon, Oct 10, 2016 at 10:45 AM, Maximilian Michels wrote:
> Thanks for checking out the fix, Stephan. I'll merge it now to the
> release-1.1 branch. Then we should be good to go for a new release
> candidate.
>
> +1 for adding a note to the release notes
Thanks for checking out the fix, Stephan. I'll merge it now to the
release-1.1 branch. Then we should be good to go for a new release
candidate.
+1 for adding a note to the release notes to avoid the "semi async" mode.
-Max
On Sat, Oct 8, 2016 at 2:13 AM, Stephan Ewen wrote:
> Thanks, Max, for
Chesnay Schepler created FLINK-4784:
---
Summary: MetricQueryService actor name collision
Key: FLINK-4784
URL: https://issues.apache.org/jira/browse/FLINK-4784
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-4783:
Summary: Allow to register TypeInfoFactories manually
Key: FLINK-4783
URL: https://issues.apache.org/jira/browse/FLINK-4783
Project: Flink
Issue Type: Improv
Hi Alexander,
I guess that Timo will be able to give a more detailed answer, but I agree
with your assessment. The TypeInfo annotation does not solve all the
problems as you've stated. Thus, making the TypeExtractor.registerFactory
method public would solve the problem. I'm just wondering whether
22 matches
Mail list logo
