[jira] [Created] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-01-23 Thread yanxiaobin (JIRA)
yanxiaobin created FLINK-8500: - Summary: Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Key: FLINK-8500 URL: https://issues.apache.org/jira/browse/FLINK-8500 Project: Flink

[jira] [Created] (FLINK-8499) Kryo must not be child-first loaded

2018-01-23 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8499: --- Summary: Kryo must not be child-first loaded Key: FLINK-8499 URL: https://issues.apache.org/jira/browse/FLINK-8499 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-8498) GetExecutionPlan fails with IllegalArgumentException in Comparator

2018-01-23 Thread JIRA
Julian Bauß created FLINK-8498: -- Summary: GetExecutionPlan fails with IllegalArgumentException in Comparator Key: FLINK-8498 URL: https://issues.apache.org/jira/browse/FLINK-8498 Project: Flink

[jira] [Created] (FLINK-8497) KafkaConsumer throws NPE if topic doesn't exist

2018-01-23 Thread chris snow (JIRA)
chris snow created FLINK-8497: - Summary: KafkaConsumer throws NPE if topic doesn't exist Key: FLINK-8497 URL: https://issues.apache.org/jira/browse/FLINK-8497 Project: Flink Issue Type: Bug

Re: Ordering in ProcessFunction after emitting multiple events from WindowFunction

2018-01-23 Thread Aljoscha Krettek
Hi, I think if you're keying by the same key the order should be preserved. If not, then events from different upstream operations can arrive in arbitrary order. Best, Aljoscha > On 12. Jan 2018, at 12:57, Michał Stępień > wrote: > > Hello, > > I have dev related question. > > How will Fli

[jira] [Created] (FLINK-8496) WebUI does not display TM MemorySegment metrics

2018-01-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8496: --- Summary: WebUI does not display TM MemorySegment metrics Key: FLINK-8496 URL: https://issues.apache.org/jira/browse/FLINK-8496 Project: Flink Issue Typ

[jira] [Created] (FLINK-8495) Serve main cluster components log and stdout file

2018-01-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8495: Summary: Serve main cluster components log and stdout file Key: FLINK-8495 URL: https://issues.apache.org/jira/browse/FLINK-8495 Project: Flink Issue Type: S

[jira] [Created] (FLINK-8494) Migrate CC#DEFAULT_PARALLELISM_KEY

2018-01-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8494: --- Summary: Migrate CC#DEFAULT_PARALLELISM_KEY Key: FLINK-8494 URL: https://issues.apache.org/jira/browse/FLINK-8494 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8493) Integrate queryable state with Flip-6

2018-01-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8493: Summary: Integrate queryable state with Flip-6 Key: FLINK-8493 URL: https://issues.apache.org/jira/browse/FLINK-8493 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8492) Fix unsupported exception for udtf with multi calc

2018-01-23 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-8492: -- Summary: Fix unsupported exception for udtf with multi calc Key: FLINK-8492 URL: https://issues.apache.org/jira/browse/FLINK-8492 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8491) Deprecate ConfigConstants#HA_MODE

2018-01-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8491: --- Summary: Deprecate ConfigConstants#HA_MODE Key: FLINK-8491 URL: https://issues.apache.org/jira/browse/FLINK-8491 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8490) Allow custom docker parameters for docker tasks on Mesos

2018-01-23 Thread JIRA
Jörg Schad created FLINK-8490: - Summary: Allow custom docker parameters for docker tasks on Mesos Key: FLINK-8490 URL: https://issues.apache.org/jira/browse/FLINK-8490 Project: Flink Issue Type:

[jira] [Created] (FLINK-8489) Data is not emitted by second ElasticSearch connector

2018-01-23 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8489: Summary: Data is not emitted by second ElasticSearch connector Key: FLINK-8489 URL: https://issues.apache.org/jira/browse/FLINK-8489 Project: Flink Issue Typ

[jira] [Created] (FLINK-8488) Dispatcher does not recover jobs

2018-01-23 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8488: --- Summary: Dispatcher does not recover jobs Key: FLINK-8488 URL: https://issues.apache.org/jira/browse/FLINK-8488 Project: Flink Issue Type: Bug Components: Di

[jira] [Created] (FLINK-8487) State loss after multiple restart attempts

2018-01-23 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8487: Summary: State loss after multiple restart attempts Key: FLINK-8487 URL: https://issues.apache.org/jira/browse/FLINK-8487 Project: Flink Issue Type: Bug

Re: filesystem output partitioning

2018-01-23 Thread Fabian Hueske
In DataSet (batch) programs, FileOutputFormats write one output file for each parallel operator instance. If your operator runs with a parallelism of 8, the output is split across 8 files. 2018-01-22 23:42 GMT+01:00 cw7k : > Hi, I ran the WordCount batch program and noticed the output was split

[jira] [Created] (FLINK-8486) Connector for SOLR

2018-01-23 Thread Davide Gesino (JIRA)
Davide Gesino created FLINK-8486: Summary: Connector for SOLR Key: FLINK-8486 URL: https://issues.apache.org/jira/browse/FLINK-8486 Project: Flink Issue Type: New Feature Reporte