[jira] [Created] (FLINK-7124) Allow to rescale JobGraph on JobManager

Till Rohrmann created FLINK-7124: Summary: Allow to rescale JobGraph on JobManager Key: FLINK-7124 URL: https://issues.apache.org/jira/browse/FLINK-7124 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

Till Rohrmann created FLINK-7125: Summary: Remove configuration loading from AbstractYarnClusterDescriptor Key: FLINK-7125 URL: https://issues.apache.org/jira/browse/FLINK-7125 Project: Flink

Re: [DISCUSS] Release 1.3.2 planning

I think we are pretty close now -- Jira shows that we're down to two blockers: FLINK-7069 and FLINK-6965. FLINK-7069 is being merged and we have a PR for FLINK-6965. ~Haohui On Thu, Jul 6, 2017 at 1:44 AM Aljoscha Krettek wrote: > I’m seeing these remaining blockers: > https://issues.apache.o

[jira] [Created] (FLINK-7126) Support Distinct for Stream SQL and Table API

Jark Wu created FLINK-7126: -- Summary: Support Distinct for Stream SQL and Table API Key: FLINK-7126 URL: https://issues.apache.org/jira/browse/FLINK-7126 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-7127) Remove unnecessary null check or add null check

Ufuk Celebi created FLINK-7127: -- Summary: Remove unnecessary null check or add null check Key: FLINK-7127 URL: https://issues.apache.org/jira/browse/FLINK-7127 Project: Flink Issue Type: Improve

Clarification of TypesSerializers

Hi devs, Currently I am working on some changes to serializer for NFA class in CEP library. I am trying to understand how the TypeSerializer#ensureCompatibility feature works. What I want to do is in a previous version (e.g. in 1.3.0) some information was serialized that now shouldn't. In Type

[jira] [Created] (FLINK-7128) Timestamp types in Table API documenation not correct

Fabian Hueske created FLINK-7128: Summary: Timestamp types in Table API documenation not correct Key: FLINK-7128 URL: https://issues.apache.org/jira/browse/FLINK-7128 Project: Flink Issue Typ

[jira] [Created] (FLINK-7129) Dynamically changing patterns

Dawid Wysakowicz created FLINK-7129: --- Summary: Dynamically changing patterns Key: FLINK-7129 URL: https://issues.apache.org/jira/browse/FLINK-7129 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-7130) Remove eventSerializer from NFA

Dawid Wysakowicz created FLINK-7130: --- Summary: Remove eventSerializer from NFA Key: FLINK-7130 URL: https://issues.apache.org/jira/browse/FLINK-7130 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] FLIP-22: Eager State Declaration

Hi all, Thanks for the proposal I definitely see the value in making eager registration as a requirement for several features that you mentioned (mostly related to state serialization/format etc.). The only problem I see which has been mentioned by others is that the lack of lazy (dynamic) state

[jira] [Created] (FLINK-7131) Streaming wordcount jar does not contain WordCountData

Chesnay Schepler created FLINK-7131: --- Summary: Streaming wordcount jar does not contain WordCountData Key: FLINK-7131 URL: https://issues.apache.org/jira/browse/FLINK-7131 Project: Flink Is

Re: How to set jobmanager.rpc.address in TaskManger node in HA cluster

Cool, thanks for letting us know that you figured it out and what it was! > On 7. Jul 2017, at 05:52, Mu Kong wrote: > > Sorry. I didn't put high-availability: zookeeper in taskmangers' > flink-config.yml. > After I fixed this, everything went well. > > On Fri, Jul 7, 2017 at 11:08 AM, Mu Kong

[jira] [Created] (FLINK-7132) Fix BulkIteration parallelism

Greg Hogan created FLINK-7132: - Summary: Fix BulkIteration parallelism Key: FLINK-7132 URL: https://issues.apache.org/jira/browse/FLINK-7132 Project: Flink Issue Type: Bug Components: J

Re: [DISCUSS]refactor StreamConfig

Hi, Yes, that sounds very good! I like the idea of having an interface that is a view on some of the settings. We could maybe improve the naming, because to me it is not completely clear what the difference between OperatorSettings and OperatorProperties is (I mean just the name, the functional

Re: Clarification of TypesSerializers

Hi Dawid, First of all, one thing to clarify: TypeSerializer#ensureCompatibility is invoked on the new provided state serializer. Also, a reconfigured compatible serializer should NOT have different serialization formats (that would require state migration, i.e. return CompatibilityResult#requi

Re: Clarification of TypesSerializers

Some extra information after understanding your case a bit more: What you would need to do, is to return a `CompatibilityResult#requiresMigration(convertSerializer)`, where the `convertSerializer` is a serializer that does read the extra information. The `convertSerializer` will only ever be use

Request for contributor permissions

Hi devs, I am very interested in Flink and willing to contribute to it. Could anybody give me contributor permissions? My jira username is "ychen". Thanks! Regards, Yueting Chen

[jira] [Created] (FLINK-7133) Fix Elasticsearch version interference

Aljoscha Krettek created FLINK-7133: --- Summary: Fix Elasticsearch version interference Key: FLINK-7133 URL: https://issues.apache.org/jira/browse/FLINK-7133 Project: Flink Issue Type: Bug

Re: [DISCUSS] Release 1.3.2 planning

I think we might have another blocker: https://issues.apache.org/jira/browse/FLINK-7133 > On 7. Jul 2017, at 09:18, Haohui Mai wrote: > > I think we are pretty close now -- Jira shows that we're down to two > blockers: FLINK-7069 and FLINK-696

[jira] [Created] (FLINK-7134) Remove hadoop1.x code in mapreduce.utils.HadoopUtils

mingleizhang created FLINK-7134: --- Summary: Remove hadoop1.x code in mapreduce.utils.HadoopUtils Key: FLINK-7134 URL: https://issues.apache.org/jira/browse/FLINK-7134 Project: Flink Issue Type:

[jira] [Created] (FLINK-7135) Pass in proper Configuration to Dispatcher component

Till Rohrmann created FLINK-7135: Summary: Pass in proper Configuration to Dispatcher component Key: FLINK-7135 URL: https://issues.apache.org/jira/browse/FLINK-7135 Project: Flink Issue Type

[jira] [Created] (FLINK-7136) Docs search can be customized to be more useful

David Anderson created FLINK-7136: - Summary: Docs search can be customized to be more useful Key: FLINK-7136 URL: https://issues.apache.org/jira/browse/FLINK-7136 Project: Flink Issue Type: I

[jira] [Created] (FLINK-7137) Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable

Rong Rong created FLINK-7137: Summary: Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable Key: FLINK-7137 URL: https://issues.apache.org/jira/browse/FLINK-

Re: Request for contributor permissions

Hello, i tried but there is no user named "ychen". Please double check the name. Regards, Chesnay Schepler On 07.07.2017 15:54, Yueting Chen wrote: Hi devs, I am very interested in Flink and willing to contribute to it. Could anybody give me contributor permissions? My jira username is "ychen

[jira] [Created] (FLINK-7138) Storm example jars do not contain WordCountData

Chesnay Schepler created FLINK-7138: --- Summary: Storm example jars do not contain WordCountData Key: FLINK-7138 URL: https://issues.apache.org/jira/browse/FLINK-7138 Project: Flink Issue Typ