Mailing list archives: June 2016

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Tzu-Li (Gordon) Tai Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 01 Jun, 03:46
Aride Chettali (JIRA) [jira] [Created] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure) Wed, 01 Jun, 05:12
Vasiliki Kalavri Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 01 Jun, 07:47
Aljoscha Krettek Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 01 Jun, 08:32
Chesnay Schepler Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 01 Jun, 08:43
Aljoscha Krettek Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 01 Jun, 08:59
Tzu-Li (Gordon) Tai baseurl not overridden in documentation's Jekyll serve for local previewing Wed, 01 Jun, 09:00
Ufuk Celebi Re: baseurl not overridden in documentation's Jekyll serve for local previewing Wed, 01 Jun, 09:08
Tzu-Li (Gordon) Tai Re: baseurl not overridden in documentation's Jekyll serve for local previewing Wed, 01 Jun, 09:31
Robert Metzger (JIRA) [jira] [Created] (FLINK-4001) Add event time support to filesystem connector Wed, 01 Jun, 10:09
Ufuk Celebi Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 01 Jun, 11:14
Gyula Fóra HA Cluster restart behaviour Wed, 01 Jun, 11:42
Omar Alvarez (JIRA) [jira] [Created] (FLINK-4002) [py] Improve testing infraestructure Wed, 01 Jun, 11:58
Ufuk Celebi Re: HA Cluster restart behaviour Wed, 01 Jun, 12:09
Márton Balassi Re: HA Cluster restart behaviour Wed, 01 Jun, 12:13
Gyula Fóra Re: HA Cluster restart behaviour Wed, 01 Jun, 12:21
Maximilian Michels Re: HA Cluster restart behaviour Wed, 01 Jun, 12:43
fschue...@posteo.de Client communication and akka.framesize Wed, 01 Jun, 13:51
Maximilian Michels Re: Client communication and akka.framesize Wed, 01 Jun, 14:34
Greg Hogan (JIRA) [jira] [Created] (FLINK-4003) Use intrinsics for MathUtils logarithms Wed, 01 Jun, 16:28
Fabian Hueske Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 01 Jun, 17:11
Chesnay Schepler Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 01 Jun, 17:59
Robert Metzger (JIRA) [jira] [Created] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings Wed, 01 Jun, 18:11
Greg Hogan Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 01 Jun, 18:59
Stephan Ewen Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 01 Jun, 19:00
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-4005) LocalExecutorITCase.testLocalExecutorWithWordCount fails Wed, 01 Jun, 22:28
ZhengBowen (JIRA) [jira] [Created] (FLINK-4006) ExecutionGraph.restartStrategy field can't be serialized Thu, 02 Jun, 03:54
Akshay Shingote (JIRA) [jira] [Created] (FLINK-4007) Flink Kafka Consumer throws Null Pointer Exception when using DataStream keyBy Thu, 02 Jun, 06:33
Akshay Shingote (JIRA) [jira] [Created] (FLINK-4008) Hello,I am not able to create jar of flink-streaming-connectors ...I am able to create jar of others like twitter,kafka,flume but I am not able to create jar of flink-streaming connectors ?? How can I create this jar ?? Thu, 02 Jun, 06:34
Akshay Thaka Shingote Flink Kafka Consumer throwing Null Pointer Exception Thu, 02 Jun, 10:55
Ufuk Celebi Re: [ANNOUNCE] Build Issues Solved Thu, 02 Jun, 11:14
Maximilian Michels Re: [ANNOUNCE] Build Issues Solved Thu, 02 Jun, 11:26
Ufuk Celebi Re: [ANNOUNCE] Build Issues Solved Thu, 02 Jun, 11:31
Cody Innowhere How to run table api in 1.1-SNAPSHOT Thu, 02 Jun, 11:56
Maximilian Michels (JIRA) [jira] [Created] (FLINK-4009) Scala Shell fails to find library for inclusion in test Thu, 02 Jun, 12:20
Maximilian Michels (JIRA) [jira] [Created] (FLINK-4010) Scala Shell tests may fail because of a locked STDIN Thu, 02 Jun, 13:02
Maximilian Michels Re: [ANNOUNCE] Build Issues Solved Thu, 02 Jun, 13:03
Robert Metzger (JIRA) [jira] [Created] (FLINK-4011) Unable to access completed job in web frontend Thu, 02 Jun, 13:28
Bernd Louis (JIRA) [jira] [Created] (FLINK-4012) Docs: Links to "Iterations" are broken (404) Thu, 02 Jun, 14:26
Aljoscha Krettek Re: Flink Kafka Consumer throwing Null Pointer Exception Thu, 02 Jun, 15:58
Henry Saputra Re: [PROPOSAL] Structure the Flink Open Source Development Thu, 02 Jun, 18:29
Greg Hogan (JIRA) [jira] [Created] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs Thu, 02 Jun, 19:37
Chiwan Park Re: [PROPOSAL] Structure the Flink Open Source Development Fri, 03 Jun, 10:07
ZhengBowen (JIRA) =?utf-8?Q?[jira]_[Created]_(FLINK-4014)_Jobs_ha?= =?utf-8?Q?ng=EF=BC=8C_Maybe_NetworkBufferPool_and_Local=E3=80=81?= Fri, 03 Jun, 10:18
Sebastian Klemke (JIRA) [jira] [Created] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes Fri, 03 Jun, 11:57
Vinay Patil [Issue] Unable to pass VM arguments Fri, 03 Jun, 13:46
RWenden (JIRA) [jira] [Created] (FLINK-4016) FoldApplyWindowFunction is not properly initialized Fri, 03 Jun, 14:50
Ufuk Celebi Re: [Issue] Unable to pass VM arguments Fri, 03 Jun, 14:57
Geoffrey Mon (JIRA) [jira] [Created] (FLINK-4017) [py] Add Aggregation support to Python API Fri, 03 Jun, 15:32
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards Sat, 04 Jun, 02:59
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface Sat, 04 Jun, 09:14
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor Sat, 04 Jun, 09:40
Zhijiang Wang (JIRA) [jira] [Created] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection Sat, 04 Jun, 16:45
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer Sun, 05 Jun, 07:38
Michal Harish (JIRA) [jira] [Created] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open() Sun, 05 Jun, 15:22
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle Sun, 05 Jun, 17:36
Dominik Bruhn (JIRA) [jira] [Created] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue Sun, 05 Jun, 21:28
Vasiliki Kalavri Re: How to run table api in 1.1-SNAPSHOT Mon, 06 Jun, 06:35
Ozan DENZ Apache Flink Web Monitor Api Mon, 06 Jun, 07:57
Ufuk Celebi Re: How to run table api in 1.1-SNAPSHOT Mon, 06 Jun, 08:31
Cody Innowhere Re: How to run table api in 1.1-SNAPSHOT Mon, 06 Jun, 09:17
Ufuk Celebi Re: Apache Flink Web Monitor Api Mon, 06 Jun, 13:57
Dyana Rose (JIRA) [jira] [Created] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation Mon, 06 Jun, 15:18
Ozan DENZ RE: Apache Flink Web Monitor Api Mon, 06 Jun, 17:00
Elias Levy (JIRA) [jira] [Created] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages Mon, 06 Jun, 21:08
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow Tue, 07 Jun, 15:45
CPC DataStream split/select behaviour Tue, 07 Jun, 16:26
CPC Re: DataStream split/select behaviour Tue, 07 Jun, 17:15
Robert Metzger Re: [PROPOSAL] Structure the Flink Open Source Development Tue, 07 Jun, 17:51
Julius Neuffer Future of Python support Wed, 08 Jun, 08:03
Till Rohrmann Re: DataStream split/select behaviour Wed, 08 Jun, 08:32
Rami (JIRA) [jira] [Created] (FLINK-4029) Multi-field "sum" function just like "keyBy" Wed, 08 Jun, 11:11
Kunft, Andreas Broadcast data sent increases with # slots per TM Wed, 08 Jun, 11:45
Maximilian Michels (JIRA) [jira] [Created] (FLINK-4030) ScalaShellITCase Wed, 08 Jun, 13:05
Maximilian Michels (JIRA) [jira] [Created] (FLINK-4031) Nightly Jenkins job doesn't deploy sources Wed, 08 Jun, 13:27
Till Rohrmann Re: Broadcast data sent increases with # slots per TM Wed, 08 Jun, 13:53
Chesnay Schepler Re: Future of Python support Wed, 08 Jun, 14:54
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-4032) Replace all usage of Guava Preconditions Wed, 08 Jun, 15:10
Kunft, Andreas AW: Broadcast data sent increases with # slots per TM Wed, 08 Jun, 15:13
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-4033) Missing Scala example snippets for the Kinesis Connector documentation Wed, 08 Jun, 16:48
Stephan Ewen Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 08 Jun, 17:22
Vladislav Pernin (JIRA) [jira] [Created] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo Wed, 08 Jun, 18:47
Alexander Alexandrov Re: Broadcast data sent increases with # slots per TM Wed, 08 Jun, 19:14
Aljoscha Krettek Re: [PROPOSAL] Structure the Flink Open Source Development Wed, 08 Jun, 19:22
Elias Levy (JIRA) [jira] [Created] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 Wed, 08 Jun, 21:02
Till Rohrmann Re: Broadcast data sent increases with # slots per TM Thu, 09 Jun, 08:17
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-4036) Potential deadlock in StreamIterationSink Thu, 09 Jun, 08:41
Stephan Ewen Re: [PROPOSAL] Structure the Flink Open Source Development Thu, 09 Jun, 08:53
Stephan Ewen Re: Broadcast data sent increases with # slots per TM Thu, 09 Jun, 08:57
Robert Metzger (JIRA) [jira] [Created] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes Thu, 09 Jun, 09:09
Aljoscha Krettek Re: [PROPOSAL] Structure the Flink Open Source Development Thu, 09 Jun, 09:33
Gyula Fora (JIRA) [jira] [Created] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts Thu, 09 Jun, 09:41
Till Rohrmann Re: [PROPOSAL] Structure the Flink Open Source Development Thu, 09 Jun, 09:41
Gyula Fora (JIRA) [jira] [Created] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments Thu, 09 Jun, 09:45
Gyula Fora (JIRA) [jira] [Created] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK Thu, 09 Jun, 09:49
Felix Neutatz Re: Broadcast data sent increases with # slots per TM Thu, 09 Jun, 09:50
Robert Metzger (JIRA) [jira] [Created] (FLINK-4041) Failure while asking ResourceManager for RegisterResource Thu, 09 Jun, 10:46
Till Rohrmann (JIRA) [jira] [Created] (FLINK-4042) TwitterStream example does not work Thu, 09 Jun, 11:23
Robert Metzger (JIRA) [jira] [Created] (FLINK-4043) Generalize RabbitMQ connector into AMQP connector Thu, 09 Jun, 12:39
Robert Metzger (JIRA) [jira] [Created] (FLINK-4044) Rename RabbitMQ connector to AMQP connector Thu, 09 Jun, 12:41
Box list
Jan 201741
Dec 2016366
Nov 2016429
Oct 2016552
Sep 2016426
Aug 2016586
Jul 2016455
Jun 2016386
May 2016405
Apr 2016535
Mar 2016421
Feb 2016502
Jan 2016389
Dec 2015259
Nov 2015589
Oct 2015589
Sep 2015449
Aug 2015478
Jul 2015503
Jun 2015880
May 2015491
Apr 2015583
Mar 2015716
Feb 2015545
Jan 2015600
Dec 2014303
Nov 2014375
Oct 2014283
Sep 2014430
Aug 2014314
Jul 2014390
Jun 2014990