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

[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:

[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:

[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

[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:

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:

[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

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

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

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

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

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,

[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

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-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

[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-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

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

[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:

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: >

[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

[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-7123) Support timesOrMore in CEP

Dian Fu created FLINK-7123: -- Summary: Support timesOrMore in CEP Key: FLINK-7123 URL: https://issues.apache.org/jira/browse/FLINK-7123 Project: Flink Issue Type: Sub-task Components: CEP