Haohui Mai created FLINK-6595:
-
Summary: Nested SQL queries do not expose proctime / rowtime
attributes
Key: FLINK-6595
URL: https://issues.apache.org/jira/browse/FLINK-6595
Project: Flink
Issue
Larry Wu created FLINK-6594:
---
Summary: Implement Flink Dispatcher for Kubernetes
Key: FLINK-6594
URL: https://issues.apache.org/jira/browse/FLINK-6594
Project: Flink
Issue Type: New Feature
Thanks Robert,
Just for the record I think there are still some problems with incremental
snapshots, I think Stefan is still working on it.
I added some comments to https://issues.apache.org/jira/browse/FLINK-6537
Gyula
Robert Metzger ezt írta (időpont: 2017. máj. 15., H,
19:41):
> Hi Devs,
>
Hello Flink Community,
is it possible to force a job into a particular task-node placement?
I want to run a failure scenario, which depends on the machines'
configuration.
To my knowledge the current scheduler deploys tasks in a
first-come-first-serve fashion. In that case the only way to fi
Hi Devs,
This is the second non-voting RC. The last RC had some big issues, making
it hard to start Flink locally. I hope this RC proves to be more stable.
I hope to create the first voting RC by end of this week.
-
The release
Ruidong Li created FLINK-6593:
-
Summary: Fix Bug in ProctimeAttribute or RowtimeAttribute with
join UDTF
Key: FLINK-6593
URL: https://issues.apache.org/jira/browse/FLINK-6593
Project: Flink
Issu
Andrey created FLINK-6592:
-
Summary: RawLocalFileSystem created even if fs.hdfs.hadoopconf
specified
Key: FLINK-6592
URL: https://issues.apache.org/jira/browse/FLINK-6592
Project: Flink
Issue Type:
Timo Walther created FLINK-6591:
---
Summary: Extend functionality of final ConversionMapper
Key: FLINK-6591
URL: https://issues.apache.org/jira/browse/FLINK-6591
Project: Flink
Issue Type: Improv
The Flink version is 1.2.0
On Mon, May 15, 2017 at 10:24 PM, weijie tong
wrote:
> @Till thanks for your reply.
>
> My code is similar to HashTableITCase.testInMemoryMutableHashTable()
> . It just use the MutableHashTable class , there's no other Flink's
> configuration. The main code body is
@Till thanks for your reply.
My code is similar to HashTableITCase.testInMemoryMutableHashTable() .
It just use the MutableHashTable class , there's no other Flink's
configuration. The main code body is:
this.recordBuildSideAccessor = RecordSerializer.get();
> this.recordProbeSideAccessor =
Chesnay Schepler created FLINK-6590:
---
Summary: Integrate generated tables into documentation
Key: FLINK-6590
URL: https://issues.apache.org/jira/browse/FLINK-6590
Project: Flink
Issue Type:
I'll now kick off the RC creation process.
On Sun, May 14, 2017 at 7:14 PM, Stephan Ewen wrote:
> +1 for another RC once the shading fix is merged.
>
> Even if RC1 would have pending issues, users that want to help testing need
> a new RC, because (as Robert said), RC0's shading issues make it v
Fabian Hueske created FLINK-6589:
Summary: ListSerializer should deserialize as ArrayList with size
+ 1
Key: FLINK-6589
URL: https://issues.apache.org/jira/browse/FLINK-6589
Project: Flink
I
Chesnay Schepler created FLINK-6588:
---
Summary: Rename NumberOfFullRestarts metric
Key: FLINK-6588
URL: https://issues.apache.org/jira/browse/FLINK-6588
Project: Flink
Issue Type: Improvemen
Timo Walther created FLINK-6587:
---
Summary: Java Table API cannot parse function names starting with
keywords
Key: FLINK-6587
URL: https://issues.apache.org/jira/browse/FLINK-6587
Project: Flink
Chesnay Schepler created FLINK-6586:
---
Summary: InputGateMetrics#refreshAndGetMin returns
Integer.MAX_VALUE for local channels
Key: FLINK-6586
URL: https://issues.apache.org/jira/browse/FLINK-6586
Pr
Timo Walther created FLINK-6585:
---
Summary: Table examples are not runnable in IDE
Key: FLINK-6585
URL: https://issues.apache.org/jira/browse/FLINK-6585
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-6584:
---
Summary: Support multiple consecutive windows in SQL
Key: FLINK-6584
URL: https://issues.apache.org/jira/browse/FLINK-6584
Project: Flink
Issue Type: New Featu
Hi Weijie,
it might be the case that batching the processing of multiple rows can give
you an improved performance compared to single row processing.
Maybe you could share the exact benchmark base line results and the code
you use to test Flink's MutableHashTable with us. Also the Flink
configura
sunjincheng created FLINK-6583:
--
Summary: Enable QueryConfig in count base GroupWindow
Key: FLINK-6583
URL: https://issues.apache.org/jira/browse/FLINK-6583
Project: Flink
Issue Type: New Featur
Dawid Wysakowicz created FLINK-6582:
---
Summary: Maven archetype is not buildable by default due to
${scala.binary.version}
Key: FLINK-6582
URL: https://issues.apache.org/jira/browse/FLINK-6582
Projec
Till Rohrmann created FLINK-6581:
Summary: Dynamic property parsing broken for YARN
Key: FLINK-6581
URL: https://issues.apache.org/jira/browse/FLINK-6581
Project: Flink
Issue Type: Bug
Robert Metzger created FLINK-6580:
-
Summary: Flink on YARN doesnt start with default parameters
Key: FLINK-6580
URL: https://issues.apache.org/jira/browse/FLINK-6580
Project: Flink
Issue Type
Timo Walther created FLINK-6579:
---
Summary: Add proper support for BasicArrayTypeInfo
Key: FLINK-6579
URL: https://issues.apache.org/jira/browse/FLINK-6579
Project: Flink
Issue Type: Bug
24 matches
Mail list logo
