You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Making state in streaming more explicit - posted by Aljoscha Krettek <al...@apache.org> on 2015/05/01 17:39:40 UTC, 1 replies.
- Re: [DISCUSS] Flink and Ignite integration - posted by Dmitriy Setrakyan <ds...@apache.org> on 2015/05/01 18:42:58 UTC, 0 replies.
- Error in eclipse - posted by Yi ZHOU <zh...@gmail.com> on 2015/05/04 00:14:01 UTC, 4 replies.
- RE: Gzip support - posted by "Kruse, Sebastian" <Se...@hpi.de> on 2015/05/04 10:37:43 UTC, 1 replies.
- [jira] [Created] (FLINK-1966) Add support for predictive model markup language (PMML) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/05/04 11:23:06 UTC, 0 replies.
- Flink Benchmark: comparing flink's performance in different environments - posted by Tobias Wiens <to...@gmail.com> on 2015/05/04 14:05:22 UTC, 2 replies.
- [jira] [Created] (FLINK-1967) Introduce (Event)time in Streaming - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/04 14:24:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1968) Make Distributed Cache more robust - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/04 15:13:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1969) Remove old profile code - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/04 15:20:07 UTC, 0 replies.
- [jira] [Created] (FLINK-1970) how can implemented subquery in flink - posted by "hagersaleh (JIRA)" <ji...@apache.org> on 2015/05/04 16:37:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1971) Add user function type to StreamOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/04 17:14:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1972) Remove instanceID in streaming tasks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/04 20:20:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1973) JobManager log does not contain state change messages on INFO level - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/05 00:29:06 UTC, 0 replies.
- [DISCUSS] Change Streaming Operators to be Push-Only - posted by Aljoscha Krettek <al...@apache.org> on 2015/05/05 13:37:37 UTC, 16 replies.
- [jira] [Created] (FLINK-1974) JobExecutionResult NetRuntime - document the type or the result - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/05/05 16:56:01 UTC, 0 replies.
- NioEventLoop consumes most of the CPU - posted by "Kruse, Sebastian" <Se...@hpi.de> on 2015/05/05 17:51:09 UTC, 4 replies.
- how can implemented subquery in flink - posted by hager sallah <lo...@yahoo.com.INVALID> on 2015/05/05 18:01:23 UTC, 2 replies.
- [jira] [Created] (FLINK-1975) Graph getUndirected improvement - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/05/05 19:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1976) Add ForwardedFields* hints for the optimizer - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/05/05 19:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1977) Rework Stream Operators to always be push based - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/06 09:56:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1978) POJO serialization NPE - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/05/06 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1979) Implement Loss Functions - posted by "Johannes Günther (JIRA)" <ji...@apache.org> on 2015/05/06 14:08:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1980) Allowing users to decorate input streams - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/05/06 16:58:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1981) Add GZip support - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/05/06 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1982) Remove dependencies of Record for Flink runtime and core - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/05/06 20:37:01 UTC, 0 replies.
- [jira] [Created] (FLINK-1983) Remove dependencies on Record APIs for Spargel - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/05/06 20:38:00 UTC, 0 replies.
- Re: [Documentation] Broken links - posted by Robert Metzger <rm...@apache.org> on 2015/05/07 11:20:13 UTC, 2 replies.
- [jira] [Created] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/07 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/07 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1986) Group by fails on iterative data streams - posted by "Daniel Bali (JIRA)" <ji...@apache.org> on 2015/05/07 17:11:01 UTC, 1 replies.
- [jira] [Created] (FLINK-1987) Broken links in the add_operator section of the documentation - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/05/07 22:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1988) Port Record API based tests in the common.io - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/05/07 23:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/08 01:02:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1990) Uppercase "AS" keyword not allowed in select expression - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/08 01:10:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1991) Return Table as DataSet - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/08 01:35:00 UTC, 0 replies.
- [DISCUSS] Behaviour of Streaming Sources - posted by Aljoscha Krettek <al...@apache.org> on 2015/05/08 10:16:41 UTC, 7 replies.
- [DISCUSS] Naming and Functionality of Stream Operators and Tasks - posted by Aljoscha Krettek <al...@apache.org> on 2015/05/08 11:38:17 UTC, 8 replies.
- [jira] [Created] (FLINK-1992) Add convergence criterion to SGD optimizer - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/05/08 11:52:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1993) Replace MultipleLinearRegression's custom SGD with optimization framework's SGD - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/05/08 11:57:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1994) Add stepsize calculation schemes to SGD - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/05/08 12:18:03 UTC, 0 replies.
- [jira] [Created] (FLINK-1995) The Flink project is categorized under "Incubator" in the Apache JIRA tracker - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/08 12:25:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1996) Add output methods to Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/08 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1997) Neither "<>" nor "!=" supported for non-equals predicates in .filter() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/08 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1998) Equality filter predicate not correctly evaluated by Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/08 14:53:00 UTC, 0 replies.
- SparseVector.fromCOO keeps zero entries - posted by Christoph Alt <ch...@posteo.de> on 2015/05/08 15:20:50 UTC, 1 replies.
- Generat DataSet gaussian distribution - posted by Yi ZHOU <zh...@hotmail.com> on 2015/05/08 21:45:46 UTC, 1 replies.
- Hello Everyone - posted by Lokesh Rajaram <ra...@gmail.com> on 2015/05/10 04:49:15 UTC, 15 replies.
- [jira] [Created] (FLINK-1999) TF-IDF transformer - posted by "Ronny Bräunlich (JIRA)" <ji...@apache.org> on 2015/05/10 13:13:59 UTC, 0 replies.
- New project website - posted by Ufuk Celebi <uc...@apache.org> on 2015/05/11 09:51:45 UTC, 29 replies.
- Re: Parquet Article / Tutorial - posted by Flavio Pompermaier <po...@okkam.it> on 2015/05/11 12:19:31 UTC, 1 replies.
- [jira] [Created] (FLINK-2000) Add SQL-style aggregations for Table API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/11 17:41:59 UTC, 0 replies.
- Setup development enviroment - posted by 程浩 <ch...@gmail.com> on 2015/05/11 17:42:06 UTC, 5 replies.
- Re: Migrating our website from SVN to Git - posted by Maximilian Michels <mx...@apache.org> on 2015/05/11 18:56:08 UTC, 6 replies.
- [jira] [Created] (FLINK-2001) DistanceMetric cannot be serialized - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/05/12 05:43:00 UTC, 0 replies.
- Gelly and ML for Streaming - posted by sirinath <si...@gmail.com> on 2015/05/12 07:37:02 UTC, 4 replies.
- [DISCUSS] Merging Storm compatibility to Flink-contrib - posted by Márton Balassi <ba...@gmail.com> on 2015/05/12 09:52:33 UTC, 5 replies.
- [jira] [Created] (FLINK-2002) Iterative test fails when ran with other tests in the same environment - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/05/12 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2003) Building on some encrypted filesystems leads to "File name too long" error - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/12 11:42:00 UTC, 0 replies.
- About Interplay of Merged Streams, Output Selectors and Checkpoint Barriers (and Watermarks) - posted by Aljoscha Krettek <al...@apache.org> on 2015/05/12 14:40:09 UTC, 6 replies.
- [DISCUSS] Access to Time and Window in Streaming Operations - posted by Aljoscha Krettek <al...@apache.org> on 2015/05/12 18:30:27 UTC, 6 replies.
- [jira] [Created] (FLINK-2004) Memory leack in presence of failed checkpoints in KafkaSource - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/12 21:57:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2005) Remove dependencies on Record APIs for flink-jdbc module - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/05/13 00:27:59 UTC, 0 replies.
- [Question]Test failed in cluster mode - posted by Yi ZHOU <zh...@hotmail.com> on 2015/05/13 00:44:41 UTC, 5 replies.
- Flink on Tez Test stuck - posted by Stephan Ewen <se...@apache.org> on 2015/05/13 01:13:23 UTC, 3 replies.
- [jira] [Created] (FLINK-2006) TaskManagerTest.testRunJobWithForwardChannel:432 expected: but was: - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/13 09:50:00 UTC, 0 replies.
- Re: Flink's multi-user support - posted by Maximilian Michels <mx...@apache.org> on 2015/05/13 10:34:51 UTC, 2 replies.
- [jira] [Created] (FLINK-2007) Initial data point in Delta function needs to be serializable - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/05/13 10:53:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2008) PersistentKafkaSource is sometimes emitting tuples multiple times - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/13 11:03:00 UTC, 0 replies.
- Planning the 0.9 Release - posted by Stephan Ewen <se...@apache.org> on 2015/05/13 13:37:44 UTC, 1 replies.
- [jira] [Created] (FLINK-2009) Time-Based Windows fail with Chaining Disabled - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/13 14:22:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2010) Add test that verifies that chained tasks are properly checkpointed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/13 14:52:02 UTC, 0 replies.
- [jira] [Created] (FLINK-2011) Improve error message when user-defined serialization logic is wrong - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/13 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2012) addVertices, addEdges, removeVertices, removeEdges methods - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/05/14 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2013) Create generalized linear model framework - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/14 16:36:02 UTC, 0 replies.
- [jira] [Created] (FLINK-2014) Add LASSO regression - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/14 16:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2015) Add ridge regression - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/14 16:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2016) Add elastic net regression - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/14 16:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2017) Add predefinde required parameters to ParameterTool - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/15 10:08:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/15 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2019) Grouping by Joda DateTime field fails with Kryo exception - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/15 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2020) Table API JoinITCase fails non-deterministically - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/15 11:49:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2021) Rework examples to use new ParameterTool - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/15 14:17:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2022) log4j.properties are not in quickstart projects - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/15 14:27:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/15 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2024) Table API mentioned twice in the small stack image in the Flink homepage - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/05/15 17:23:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2025) Support booleans in CSV reader - posted by "Sebastian Schelter (JIRA)" <ji...@apache.org> on 2015/05/15 21:29:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2026) Error message in count() only jobs - posted by "Sebastian Schelter (JIRA)" <ji...@apache.org> on 2015/05/15 21:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2027) Flink website does not provide link to source repo - posted by "Sebb (JIRA)" <ji...@apache.org> on 2015/05/16 01:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2028) Download pages must not link to snapshots - posted by "Sebb (JIRA)" <ji...@apache.org> on 2015/05/16 01:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2029) DOAP has disappeared - posted by "Sebb (JIRA)" <ji...@apache.org> on 2015/05/16 01:13:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2030) Implement an online histogram with Merging and equalization features - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/05/16 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2031) Missing images in blog posts - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/17 08:18:59 UTC, 0 replies.
- Re: Package multiple jobs in a single jar - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/05/17 22:38:31 UTC, 15 replies.
- [jira] [Created] (FLINK-2032) Migrate integration tests from temp output files to collect() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/18 10:46:00 UTC, 0 replies.
- Gelly Roadmap - posted by Andra Lungu <lu...@gmail.com> on 2015/05/18 11:01:39 UTC, 13 replies.
- [jira] [Created] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly - posted by "PJ Van Aeken (JIRA)" <ji...@apache.org> on 2015/05/18 11:44:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2034) Add vision and roadmap for ML library to docs - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/18 14:42:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2035) Update 0.9 roadmap with ML issues - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/18 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/05/18 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2037) Unable to start Python API using ./bin/pyflink*.sh - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/18 15:50:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2038) Extend headline of website - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/18 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2039) Streaming API's sum(String) does not work for Tuples - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/05/18 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2040) TaskTest.testCancelDuringInvoke:434->validateListenerMessage:712 expected: but was: - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/18 16:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2041) Optimizer plans with memory for pipeline breakers, even though they are not used any more - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/18 16:52:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2042) Increase font size for stack figure on website home - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/19 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2043) Change the KMeansDataGenerator to allow passing a custom path - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/19 12:20:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2044) Implementation of Gelly Algorithm HITS - posted by "Ahamd Javid (JIRA)" <ji...@apache.org> on 2015/05/19 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2045) JobManager webinterface is unresponsive with many TaskManagers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/19 12:39:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2046) Quickstarts are missing on the new Website - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/19 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2047) Rename CoCoA to SVM - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/19 14:05:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2048) Enhance Twitter Stream support - posted by "Hilmi Yildirim (JIRA)" <ji...@apache.org> on 2015/05/19 14:49:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2049) KafkaSink sporadically fails to send message - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/19 16:14:59 UTC, 0 replies.
- Problems building the current master - posted by Tamara Mendt <ta...@gmail.com> on 2015/05/19 16:53:08 UTC, 9 replies.
- [jira] [Created] (FLINK-2050) Add pipelining mechanism for chainable transformers and estimators - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/05/19 17:17:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2051) Fix disabled test in ComplexIntegrationTest - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/05/19 19:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2052) Clear up Serializable warnings in streaming operators - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/05/19 19:16:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2053) Preregister ML types for Kryo serialization - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/05/20 09:50:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2054) StreamOperator rework removed copy calls when passing output to a chained operator - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/05/20 10:34:59 UTC, 0 replies.
- [DISCUSS] Re-add record copy to chained operator calls - posted by Gyula Fóra <gy...@apache.org> on 2015/05/20 10:50:00 UTC, 19 replies.
- [jira] [Created] (FLINK-2055) Implement Streaming HBaseSink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/20 11:00:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2056) Add guide to create a chainable predictor in docs - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/20 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2057) Remove IOReadableWritable interface from input splits - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/20 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2058) Hadoop Input Splits do not use proper UserCodeClassloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/20 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2059) Rename modules flink-compiler to flink-optimizer in pom.xml - posted by "Tamara (JIRA)" <ji...@apache.org> on 2015/05/20 14:36:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2060) Let maven fail on travis when modules reference to outdated internal dependency - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/20 14:47:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2061) CSVReader: quotedStringParsing and includeFields yields ParseException - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/20 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2062) Fix names of memory segment config parameter - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/20 16:21:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2063) Streaming checkpoints consider only input and output vertices - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/20 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2064) Set Tez version to 0.6.1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/20 17:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2065) Cancelled jobs finish with final state FAILED - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/20 18:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2066) Make delay between execution retries configurable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/20 20:21:59 UTC, 0 replies.
- Fwd: [GitHub] incubator-zeppelin pull request: ZEPPELIN-44 Interpreter for Apach... - posted by Fabian Hueske <fh...@gmail.com> on 2015/05/21 11:25:00 UTC, 4 replies.
- [jira] [Created] (FLINK-2067) Chained streaming operators should not throw chained exceptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/21 12:46:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2068) WebUI support multiple jobs per jar file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/05/21 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file - posted by "Faye Beligianni (JIRA)" <ji...@apache.org> on 2015/05/21 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2070) Confusing methods print() that print on client vs on TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/21 14:00:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2071) Projection function can fail non serializable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/21 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2072) Add a quickstart guide for FlinkML - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/21 15:01:59 UTC, 0 replies.
- [jira] [Created] (FLINK-2073) Add contribution guide for FlinkML - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/21 15:02:59 UTC, 0 replies.
- [DISCUSS] Dedicated streaming mode - posted by Stephan Ewen <se...@apache.org> on 2015/05/21 15:12:24 UTC, 14 replies.
- [jira] [Created] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/21 15:38:59 UTC, 0 replies.
- difference between reducefunction and GroupReduceFunction - posted by santosh_rajaguru <sa...@gmail.com> on 2015/05/21 16:42:23 UTC, 4 replies.
- [jira] [Created] (FLINK-2075) Shade akka and protobuf dependencies away - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/05/21 17:32:17 UTC, 0 replies.
- Debugging non-heap memory usage in Java (and Flink) - posted by Stephan Ewen <se...@apache.org> on 2015/05/21 19:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-2076) Bug in re-openable hash join - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/21 21:14:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2077) Rework Path class and add extend support for Windows paths - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/22 01:10:17 UTC, 0 replies.
- question please - posted by Eng Fawzya <en...@gmail.com> on 2015/05/22 08:02:43 UTC, 1 replies.
- [jira] [Created] (FLINK-2078) Document type registration at the ExecutionEnvironment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/05/22 11:03:18 UTC, 0 replies.
- Changed the behavior of "DataSet.print()" - posted by Stephan Ewen <se...@apache.org> on 2015/05/22 11:08:58 UTC, 11 replies.
- [jira] [Created] (FLINK-2079) Add watcher to YARN TM containers to detect stopped actor system - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/22 11:49:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2080) Execute Flink with sbt - posted by "Christian Wuertz (JIRA)" <ji...@apache.org> on 2015/05/22 12:07:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2081) Change order of restore state and open for Streaming Operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/22 13:33:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2082) Chained stream tasks share the same RuntimeEnvironment - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/05/22 14:14:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2083) Ensure high quality docs for FlinkML in 0.9 - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/22 15:29:18 UTC, 0 replies.
- [jira] [Created] (FLINK-2084) Create a dedicated streaming mode - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/22 17:23:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2085) Add an option to the MemoryManager to allocate memory as needed, rather than preallocating it - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/22 18:33:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2086) how main difference betwwen Hadoop and Apache Flink - posted by "hagersaleh (JIRA)" <ji...@apache.org> on 2015/05/22 19:19:17 UTC, 0 replies.
- [DISCUSS] Behaviour of startNewChain() in Streaming - posted by Aljoscha Krettek <al...@apache.org> on 2015/05/25 10:26:13 UTC, 4 replies.
- [jira] [Created] (FLINK-2087) Add streaming mode to YARN as well - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/25 15:16:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2088) change return type of name function in DataStream scala class - posted by "Faye Beligianni (JIRA)" <ji...@apache.org> on 2015/05/25 17:05:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2089) "Buffer recycled" IllegalStateException during cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/05/26 09:42:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/05/26 09:42:18 UTC, 0 replies.
- [jira] [Created] (FLINK-2091) Lock contention during release of network buffer pools - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/05/26 09:45:17 UTC, 0 replies.
- Gelly Blog Post - posted by Andra Lungu <lu...@gmail.com> on 2015/05/26 10:03:48 UTC, 2 replies.
- [jira] [Created] (FLINK-2092) Document (new) behavior of print() and execute() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/05/26 11:11:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2093) Add a difference method to Gelly's Graph class - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/05/26 11:30:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2094) Implement Word2Vec - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2015/05/26 14:05:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2095) Screenshots missing in webcient documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/26 16:47:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2096) Remove implicit conversions in Streaming Scala API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/26 17:42:17 UTC, 0 replies.
- SQL on Flink - posted by Timo Walther <tw...@apache.org> on 2015/05/26 21:38:12 UTC, 11 replies.
- [DISCUSS] Canceling Streaming Jobs - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/05/27 01:17:58 UTC, 5 replies.
- Tuple project method - posted by Flavio Pompermaier <po...@okkam.it> on 2015/05/27 11:51:32 UTC, 2 replies.
- [jira] [Created] (FLINK-2097) Add support for JobSessions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/27 12:09:17 UTC, 0 replies.
- Greetings and help regarding my first issue - posted by Vijendra Singh Aswal <vi...@gmail.com> on 2015/05/27 12:57:10 UTC, 1 replies.
- [jira] [Created] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/27 14:21:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2099) Add a SQL API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/05/27 14:32:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2100) Add ITCases for all Table API examples - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/05/27 15:42:17 UTC, 0 replies.
- Storm compatibility layer currently does not support Storm's SimpleJoin example - posted by Szabó Péter <ne...@gmail.com> on 2015/05/27 15:48:29 UTC, 4 replies.
- [jira] [Created] (FLINK-2101) Scheme Inference doesn't work for Tuple5 - posted by "Rico Bergmann (JIRA)" <ji...@apache.org> on 2015/05/27 16:16:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2102) Add predict operation for LabeledVector - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/27 17:47:17 UTC, 0 replies.
- Adding custom Tuple to a DataSet - posted by Amit Pawar <am...@gmail.com> on 2015/05/28 01:30:59 UTC, 2 replies.
- [jira] [Created] (FLINK-2103) Expose partitionBy to the user in Stream API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/05/28 10:34:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2104) Fallback implicit values for PredictOperation and TransformOperation don't work if Nothing is inferred as the output type - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/05/28 12:41:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2105) Implement Sort-Merge Outer Join algorithm - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/28 14:03:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2106) Add outer joins to API, Optimizer, and Runtime - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/28 14:10:19 UTC, 0 replies.
- Memleak in the SessionWindowing example - posted by Gábor Gévay <gg...@gmail.com> on 2015/05/28 15:01:40 UTC, 5 replies.
- Re: Some feedback on the Gradient Descent Code - posted by Till Rohrmann <ti...@data-artisans.com> on 2015/05/28 15:04:10 UTC, 9 replies.
- [jira] [Created] (FLINK-2107) Implement Hash Outer Join algorithm - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/28 16:44:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2108) Add score function for Predictors - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/05/28 17:38:18 UTC, 0 replies.
- [jira] [Created] (FLINK-2109) CancelTaskException leads to FAILED task state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/05/28 17:56:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2110) Early slot release after Execution failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/05/28 18:07:18 UTC, 0 replies.
- [ANNOUNCE] Introducing Bay Area Apache Flink meetup - posted by Henry Saputra <he...@gmail.com> on 2015/05/28 20:49:38 UTC, 0 replies.
- [jira] [Created] (FLINK-2111) Add "terminate" signal to cleanly stop streaming jobs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/05/29 11:05:17 UTC, 0 replies.
- Bug in flink-connector-kafka ? - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/05/29 11:31:50 UTC, 1 replies.
- Get the current TM hostname from the ExecutionContext - posted by Alexander Alexandrov <al...@gmail.com> on 2015/05/29 11:53:39 UTC, 1 replies.
- [jira] [Created] (FLINK-2112) Wrong package statement in KafkaITCase and KafkaLocalSystemTime - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/05/29 12:03:17 UTC, 0 replies.
- [DISCUSS] State Management API for Streaming - posted by Paris Carbone <pa...@kth.se> on 2015/05/29 14:13:29 UTC, 0 replies.
- [jira] [Created] (FLINK-2113) env.execute() is no longer needed after a call to print() - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/05/29 15:04:29 UTC, 0 replies.
- [jira] [Created] (FLINK-2114) PunctuationPolicy.toString() throws NullPointerException if extractor is null - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/05/29 15:50:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2115) TableAPI throws ExpressionException for "Dangling GroupBy operation" - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/29 16:50:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2116) Make pipeline extension require less coding - posted by "Mikio Braun (JIRA)" <ji...@apache.org> on 2015/05/29 17:56:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2117) Add a set of data generators - posted by "Mikio Braun (JIRA)" <ji...@apache.org> on 2015/05/29 17:58:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2118) Table API fails on composite filter conditions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/05/29 18:48:17 UTC, 0 replies.
- [DISCUSS] Streaming Sources (again) - posted by Aljoscha Krettek <al...@apache.org> on 2015/05/29 18:51:43 UTC, 5 replies.
- [ANNOUNCE] First event for Apache Flink Bay Area meetup - posted by Henry Saputra <he...@gmail.com> on 2015/05/30 03:09:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/05/30 13:12:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2120) Rename AbstractJobVertex to JobVertex - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/05/31 00:06:17 UTC, 0 replies.
- ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while trying to run locally - posted by santosh_rajaguru <sa...@gmail.com> on 2015/05/31 00:47:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2121) FileInputFormat.addFilesInDir miscalculates total size - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/05/31 13:27:17 UTC, 0 replies.
- [ANNOUNCE] Apache Mahout 0.10.1 Released - posted by Suneel Marthi <sm...@apache.org> on 2015/05/31 22:58:36 UTC, 0 replies.