Mailing list archives: September 2015

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Ufuk Celebi [ANNOUNCE] Apache Flink 0.9.1 released Tue, 01 Sep, 08:22
Till Rohrmann (JIRA) [jira] [Created] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case Tue, 01 Sep, 08:49
Robert Metzger (JIRA) [jira] [Created] (FLINK-2601) IOManagerAsync may produce NPE during shutdown Tue, 01 Sep, 09:18
Stephan Ewen (JIRA) [jira] [Created] (FLINK-2602) Gelly algorithms obtain new execution environments. Tue, 01 Sep, 10:39
Kostas Tzoumas =?UTF-8?Q?Re=3A_=E7=AD=94=E5=A4=8D=3A_Some_questions_about_storm_metrics?= Tue, 01 Sep, 10:49
huangwei (G) Re: Some questions about storm metrics Tue, 01 Sep, 11:20
Theodore Vasiloudis Re: SGD Effective Learning Rate Tue, 01 Sep, 15:23
Johann Kovacs Outer-join operator integration with DataSet API (FLINK-2576) Tue, 01 Sep, 16:02
Till Rohrmann Re: Outer-join operator integration with DataSet API (FLINK-2576) Tue, 01 Sep, 16:34
Greg Hogan (JIRA) [jira] [Created] (FLINK-2603) Flink hangs before starting execution Tue, 01 Sep, 17:51
Ted Yu (JIRA) [jira] [Created] (FLINK-2604) Access to SessionID without holding lock in ZooKeeperLeaderElectionService Tue, 01 Sep, 22:39
Ted Yu (JIRA) [jira] [Created] (FLINK-2605) Unclosed RandomAccessFile may leak resource in StaticFileServerHandler Wed, 02 Sep, 00:44
huangwei (G) =?utf-8?B?562U5aSNOiBTb21lIHF1ZXN0aW9ucyBhYm91dCBzdG9ybSBtZXRyaWNz?= Wed, 02 Sep, 06:36
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-2606) Extend StormFileSpout to handle HDFS Wed, 02 Sep, 08:51
Kostas Tzoumas =?UTF-8?Q?Re=3A_=E7=AD=94=E5=A4=8D=3A_Some_questions_about_storm_metrics?= Wed, 02 Sep, 08:55
Maximilian Michels (JIRA) [jira] [Created] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar Wed, 02 Sep, 10:23
Maximilian Michels (JIRA) [jira] [Created] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat Wed, 02 Sep, 10:55
Kostas Tzoumas [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 11:30
Chiwan Park Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 11:32
Timo Walther Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 11:34
Robert Metzger Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 12:01
Till Rohrmann Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 12:08
Stephan Ewen Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 12:29
Maximilian Michels Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 13:39
Fabian Hueske Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 13:53
Robert Metzger (JIRA) [jira] [Created] (FLINK-2609) Automatic type registration is only called from the batch execution environment Wed, 02 Sep, 15:17
Aljoscha Krettek Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 15:21
Márton Balassi Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 15:24
Ufuk Celebi Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 15:41
Matthias J. Sax To much changed file build Flink web page Wed, 02 Sep, 16:44
Matthias J. Sax Too many changed files building Flink web page Wed, 02 Sep, 16:53
Matthias J. Sax Re: How to force the parallelism on small streams? Wed, 02 Sep, 18:00
Vasiliki Kalavri Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 18:13
Boyang Jerry Peng (JIRA) [jira] [Created] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE Wed, 02 Sep, 18:46
Paris Carbone Re: [ANNOUNCE] Welcome Matthias Sax as new committer Wed, 02 Sep, 18:54
╗¬╬─ =?gb18030?B?u9i4tKO6W0FOTk9VTkNFXSBXZWxjb21lIE1hdHRo?= =?gb18030?B?aWFzIFNheCBhcyBuZXcgY29tbWl0dGVy?= Thu, 03 Sep, 00:56
Maximilian Michels Re: Too many changed files building Flink web page Thu, 03 Sep, 07:56
Ufuk Celebi Re: Too many changed files building Flink web page Thu, 03 Sep, 08:50
Robert Metzger (JIRA) [jira] [Created] (FLINK-2611) YARN reports failed final state for successful jobs Thu, 03 Sep, 08:51
Maximilian Michels Re: Too many changed files building Flink web page Thu, 03 Sep, 08:53
Matthias J. Sax Re: Too many changed files building Flink web page Thu, 03 Sep, 09:07
Sachin Goel (JIRA) [jira] [Created] (FLINK-2612) ZooKeeperLeaderElectionITCase failure Thu, 03 Sep, 09:18
Maximilian Michels (JIRA) [jira] [Created] (FLINK-2613) Print usage information for Scala Shell Thu, 03 Sep, 09:24
Maximilian Michels (JIRA) [jira] [Created] (FLINK-2614) Scala Shell's default local execution mode is broken Thu, 03 Sep, 09:32
Sachin Goel (JIRA) [jira] [Created] (FLINK-2615) Multiple restarts of Local Cluster for a single program Thu, 03 Sep, 11:20
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest Thu, 03 Sep, 12:01
Aljoscha Krettek Re: How to force the parallelism on small streams? Thu, 03 Sep, 13:04
Fabian Hueske Re: Outer-join operator integration with DataSet API (FLINK-2576) Thu, 03 Sep, 13:05
Arnaud Linz (JIRA) [jira] [Created] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table Thu, 03 Sep, 13:11
Matthias J. Sax Re: How to force the parallelism on small streams? Thu, 03 Sep, 13:22
Fabian Hueske Re: How to force the parallelism on small streams? Thu, 03 Sep, 13:28
Matthias J. Sax Re: How to force the parallelism on small streams? Thu, 03 Sep, 13:53
Fabian Hueske Re: How to force the parallelism on small streams? Thu, 03 Sep, 14:06
Matthias J. Sax Re: How to force the parallelism on small streams? Thu, 03 Sep, 14:29
Sachin Goel (JIRA) [jira] [Created] (FLINK-2618) ExternalSortITCase failure Thu, 03 Sep, 15:19
Behrouz Derakhshan Advice on [FLINK-2021]: Rework examples to use new ParameterTool Thu, 03 Sep, 15:50
Maximilian Michels Re: Advice on [FLINK-2021]: Rework examples to use new ParameterTool Fri, 04 Sep, 08:55
Behrouz Derakhshan Re: Advice on [FLINK-2021]: Rework examples to use new ParameterTool Fri, 04 Sep, 09:17
Maximilian Michels Re: Advice on [FLINK-2021]: Rework examples to use new ParameterTool Fri, 04 Sep, 09:29
Chiwan Park Re: Several Scala Tests not being executed by Maven Fri, 04 Sep, 09:43
Niklas Semmler Updating the flink JAR with a single module Fri, 04 Sep, 09:46
Chiwan Park (JIRA) [jira] [Created] (FLINK-2619) Some Scala Tests not being executed by Maven Fri, 04 Sep, 10:02
Chiwan Park Re: Several Scala Tests not being executed by Maven Fri, 04 Sep, 10:03
Fabian Hueske Re: Updating the flink JAR with a single module Fri, 04 Sep, 10:24
Matthias J. Sax Re: Updating the flink JAR with a single module Fri, 04 Sep, 10:59
Behrouz Derakhshan Re: Advice on [FLINK-2021]: Rework examples to use new ParameterTool Fri, 04 Sep, 11:05
Matthias J. Sax Re: [ANNOUNCE] Welcome Matthias Sax as new committer Fri, 04 Sep, 11:38
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-2620) StreamPartitioner is not properly initialized for shuffle and rebalance Fri, 04 Sep, 11:53
Behrouz Derakhshan (JIRA) [jira] [Created] (FLINK-2621) Add support for positional arguments to ParameterTool Fri, 04 Sep, 12:12
Till Rohrmann (JIRA) [jira] [Created] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode Fri, 04 Sep, 12:22
Robert Metzger Re: Advice on [FLINK-2021]: Rework examples to use new ParameterTool Fri, 04 Sep, 12:34
Behrouz Derakhshan Re: Advice on [FLINK-2021]: Rework examples to use new ParameterTool Fri, 04 Sep, 12:46
Till Rohrmann (JIRA) [jira] [Created] (FLINK-2623) Extend API completeness check to check signatures Fri, 04 Sep, 13:52
Stephan Ewen (JIRA) [jira] [Created] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing Fri, 04 Sep, 14:43
Niklas Semmler Re: Updating the flink JAR with a single module Fri, 04 Sep, 15:58
Greg Hogan (JIRA) [jira] [Created] (FLINK-2625) Configuration not passed to JobGraphGenerator Sat, 05 Sep, 13:14
Devang Gupta Interested in implementing Machine learning Libraries as my undergraduate final project Sat, 05 Sep, 13:37
Sachin Goel Scala Utils Sat, 05 Sep, 13:38
Aljoscha Krettek Re: Scala Utils Sat, 05 Sep, 16:44
Huang Wei (JIRA) [jira] [Created] (FLINK-2626) Add a AverageAccumulator for FLINK-Accumulator Sun, 06 Sep, 03:12
gkrastev Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while trying to run locally Sun, 06 Sep, 11:40
Matthias J. Sax Configuring UDFs with user defined parameters Sun, 06 Sep, 16:29
Aljoscha Krettek Re: Configuring UDFs with user defined parameters Sun, 06 Sep, 20:51
Sachin Goel Re: Scala Utils Mon, 07 Sep, 07:25
Sachin Goel (JIRA) [jira] [Created] (FLINK-2627) Make Scala Data Set utils easier to access Mon, 07 Sep, 07:28
Till Rohrmann Re: Interested in implementing Machine learning Libraries as my undergraduate final project Mon, 07 Sep, 08:16
Martin Liesenberg (JIRA) [jira] [Created] (FLINK-2628) Failing Test: StreamFaultToleranceTestBase.runCheckpointedProgram Mon, 07 Sep, 08:50
Robert Metzger =?UTF-8?B?UmU6IOetlOWkjTogTmVlZCBoZWxwIHdpdGggQ0kgcHJvYmxlbQ==?= Mon, 07 Sep, 09:05
Stephan Ewen Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while trying to run locally Mon, 07 Sep, 11:05
Stephan Ewen Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while trying to run locally Mon, 07 Sep, 11:06
huangwei (G) Re: Need help with CI problem Mon, 07 Sep, 11:29
Matthias J. Sax Re: Configuring UDFs with user defined parameters Mon, 07 Sep, 11:39
Matthias J. Sax Failing Test: KafkaITCase and KafkaProducerITCase Mon, 07 Sep, 12:41
huangwei (G) Re: Some questions about storm metrics Mon, 07 Sep, 12:51
Stephan Ewen Re: Configuring UDFs with user defined parameters Mon, 07 Sep, 13:05
Stephan Ewen Re: Failing Test: KafkaITCase and KafkaProducerITCase Mon, 07 Sep, 13:35
Matthias J. Sax Re: Some questions about storm metrics Mon, 07 Sep, 13:41
Robert Metzger (JIRA) [jira] [Created] (FLINK-2629) Refactor YARN ApplicationMasterActor to use the async AM<-->RM client Mon, 07 Sep, 14:22
Till Rohrmann (JIRA) [jira] [Created] (FLINK-2630) Scala DataStream API does not have a project method Mon, 07 Sep, 14:25
Till Rohrmann (JIRA) [jira] [Created] (FLINK-2631) StreamFold operator does not respect returns type and stores non serializable values Mon, 07 Sep, 14:53
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