You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Scala 2.10/2.11 Maven dependencies - posted by Maximilian Michels <mx...@apache.org> on 2015/11/01 18:29:19 UTC, 9 replies.
- Re: Broken link for master Javadocs - posted by Henry Saputra <he...@gmail.com> on 2015/11/02 00:53:59 UTC, 2 replies.
- [jira] [Created] (FLINK-2951) Add Union operator to Table API. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/02 08:32:27 UTC, 0 replies.
- job failed while initiating Transport client for Elasticsearch - posted by santosh_rajaguru <sa...@gmail.com> on 2015/11/02 10:02:44 UTC, 5 replies.
- [jira] [Created] (FLINK-2952) Runtimes > 24 hours are reported incorrectly in the web frontend - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/11/02 11:21:27 UTC, 0 replies.
- Re: Flink "Material" - posted by Robert Metzger <rm...@apache.org> on 2015/11/02 11:34:53 UTC, 4 replies.
- Re: [DISCUSS] Java code style - posted by Fabian Hueske <fh...@gmail.com> on 2015/11/02 12:14:20 UTC, 6 replies.
- [jira] [Created] (FLINK-2953) Chained sortPartition() calls produce incorrect results in Scala DataSet API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/02 14:17:27 UTC, 0 replies.
- Re: [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc4) - posted by Fabian Hueske <fh...@gmail.com> on 2015/11/02 14:27:46 UTC, 14 replies.
- Re: [DISCUSS] flink-external - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/11/02 14:48:46 UTC, 0 replies.
- [Webpage update] New Slides - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/11/02 17:59:13 UTC, 0 replies.
- Vector(DenseVector) as a type? - posted by Daniel Blazevski <da...@gmail.com> on 2015/11/02 22:10:59 UTC, 1 replies.
- [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.0-rc4) - posted by Maximilian Michels <mx...@apache.org> on 2015/11/02 22:50:16 UTC, 0 replies.
- errors after updating master branch - posted by Daniel Blazevski <da...@gmail.com> on 2015/11/02 23:21:11 UTC, 5 replies.
- [jira] [Created] (FLINK-2954) Not able to pass custom environment variables in cluster to processes that spawning TaskManager - posted by "Jian Jiang (JIRA)" <ji...@apache.org> on 2015/11/02 23:35:27 UTC, 0 replies.
- Re: neo4j - Flink connector - posted by Stephan Ewen <se...@apache.org> on 2015/11/03 01:18:17 UTC, 8 replies.
- Re: [gelly] Spargel model rework - posted by Stephan Ewen <se...@apache.org> on 2015/11/03 01:35:27 UTC, 13 replies.
- [jira] [Created] (FLINK-2955) Add operations introduction in Table API page. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/03 03:30:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2956) Migrate integration tests for Table API - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/03 08:16:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2957) Make cancel button look less like a label - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 11:09:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2958) StreamingJobGraphGenerator sets hard coded number execution retry - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/03 11:42:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2959) Remove number of execution retries configuration from Environment - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/03 11:46:27 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc5) - posted by Maximilian Michels <mx...@apache.org> on 2015/11/03 12:24:53 UTC, 3 replies.
- [jira] [Created] (FLINK-2960) Communicate with JobManager through YARN proxy - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 13:03:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2961) Add support for basic type Date in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/03 13:42:27 UTC, 0 replies.
- Question about limitations of iterative algorithms - posted by André Petermann <pe...@informatik.uni-leipzig.de> on 2015/11/03 13:47:05 UTC, 6 replies.
- [Summary] Homepage and Docu - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/11/03 14:13:32 UTC, 0 replies.
- [jira] [Created] (FLINK-2962) Cluster startup script refers to unused variable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/03 14:56:28 UTC, 0 replies.
- Filter on computed value - posted by "Kirschnick, Johannes" <jo...@tu-berlin.de> on 2015/11/03 22:39:34 UTC, 2 replies.
- [jira] [Created] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/04 01:15:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2964) MutableHashTable fails when spilling partitions without overflow segments - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/04 02:12:27 UTC, 0 replies.
- [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.0-rc5) - posted by Maximilian Michels <mx...@apache.org> on 2015/11/04 11:00:36 UTC, 2 replies.
- Failure in KafkaIT case - posted by Gyula Fóra <gy...@apache.org> on 2015/11/04 11:14:27 UTC, 5 replies.
- [jira] [Created] (FLINK-2965) KafkaITCase failure - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/04 12:00:31 UTC, 0 replies.
- [jira] [Created] (FLINK-2966) Improve the way job duration is reported on web frontend. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/04 13:23:27 UTC, 0 replies.
- Error with window fold - posted by Gyula Fóra <gy...@apache.org> on 2015/11/04 13:49:52 UTC, 7 replies.
- [jira] [Created] (FLINK-2967) TM address detection might not always detect the right interface on slow networks / overloaded JMs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/04 14:21:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2968) Windowed fold operation fails because the initial value was not serialized - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/04 16:39:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2969) FlinkYarnSessionCli with recovery enabled fails when killing TaskManager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/04 16:44:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2970) Yarn client cannot connect to new job manager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/04 16:48:27 UTC, 0 replies.
- How to use static data with streams? - posted by "Kashmar, Ali" <Al...@emc.com> on 2015/11/04 16:54:43 UTC, 9 replies.
- [jira] [Created] (FLINK-2971) Add outer joins to the Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/04 17:27:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2972) Remove Twitter Chill dependency from flink-java module - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/04 21:36:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2973) Remove OpenJDK JMH dependency from flink-benchmark - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/04 22:19:27 UTC, 0 replies.
- Web interface to submit jobs - posted by Sachin Goel <sa...@gmail.com> on 2015/11/05 05:23:43 UTC, 21 replies.
- [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc6) - posted by Maximilian Michels <mx...@apache.org> on 2015/11/05 10:28:17 UTC, 7 replies.
- [jira] [Created] (FLINK-2974) Add periodic offset commit to Kafka Consumer if checkpointing is disabled - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/05 11:47:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2975) Exclude logging dependencies from shaded Hadoop jar. - posted by "Jan Thomä (JIRA)" <ji...@apache.org> on 2015/11/05 12:00:30 UTC, 0 replies.
- [jira] [Created] (FLINK-2976) Save and load checkpoints manually - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/05 12:25:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2015/11/05 13:37:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2978) Integrate web submission interface into the new dashboard - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/05 14:36:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/05 15:07:27 UTC, 0 replies.
- 0.10 streaming state documentation out of date - posted by Martin Neumann <mn...@sics.se> on 2015/11/05 16:41:31 UTC, 4 replies.
- Error when building the docs - posted by Martin Junghanns <m....@mailbox.org> on 2015/11/05 20:58:11 UTC, 2 replies.
- [jira] [Created] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/06 04:34:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2981) Update README for building docs - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/11/06 08:25:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2982) CLI info option throws ClassCastException for streaming jobs - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/06 08:31:27 UTC, 0 replies.
- Roadmap for the 1.0 release - posted by Stephan Ewen <se...@apache.org> on 2015/11/06 10:37:06 UTC, 1 replies.
- [jira] [Created] (FLINK-2983) Add StateLoader as an alternative to default KvState - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/06 13:43:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2984) Support lenient parsing of SVMLight input files - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/11/06 14:48:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2985) Allow different field names for unionAll() in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/06 19:29:11 UTC, 0 replies.
- Question on Task Chaining - posted by Isha Arkatkar <ic...@gmail.com> on 2015/11/07 02:26:03 UTC, 2 replies.
- Accessing TM metrics - posted by Gyula Fóra <gy...@gmail.com> on 2015/11/07 19:39:56 UTC, 2 replies.
- Flink deployment fabric script - posted by Le Quoc Do <le...@gmail.com> on 2015/11/08 19:52:53 UTC, 3 replies.
- Long cannot be cast to org.apache.flink.types.CopyableValue - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/11/08 21:20:50 UTC, 2 replies.
- Function input type validation - posted by Gyula Fóra <gy...@apache.org> on 2015/11/08 21:28:53 UTC, 5 replies.
- [jira] [Created] (FLINK-2986) Typo in KvState interface snapshot method name - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/09 10:40:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2987) Flink 0.10 fails to start on YARN 2.6.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/09 14:17:10 UTC, 0 replies.
- [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.0-rc6) - posted by Maximilian Michels <mx...@apache.org> on 2015/11/09 14:41:04 UTC, 2 replies.
- [jira] [Created] (FLINK-2988) Cannot load DataSet[Row] from CSV file - posted by "Johann Kovacs (JIRA)" <ji...@apache.org> on 2015/11/09 16:06:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2989) Job Cancel button doesn't work on Yarn - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/09 16:45:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2990) Scala 2.11 build fails to start on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/09 17:50:11 UTC, 0 replies.
- Re: Using Flink Streaming to write to multiple output files in HDFS - posted by Robert Metzger <rm...@apache.org> on 2015/11/09 19:11:05 UTC, 1 replies.
- [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc7) - posted by Maximilian Michels <mx...@apache.org> on 2015/11/09 22:02:12 UTC, 1 replies.
- [jira] [Created] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/10 10:39:11 UTC, 0 replies.
- Python Examples - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/11/10 11:53:36 UTC, 1 replies.
- [jira] [Created] (FLINK-2992) New Windowing code is using SerializationUtils with wrong classloader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/10 12:14:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2993) Set default elayBetweenExecutionRetries to 0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/10 13:58:11 UTC, 0 replies.
- [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.0-rc7) - posted by Maximilian Michels <mx...@apache.org> on 2015/11/10 15:53:52 UTC, 0 replies.
- [jira] [Created] (FLINK-2994) Client sysout logging does not report exceptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/10 17:22:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2995) Set default number of retries to larger than 0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/10 17:33:10 UTC, 0 replies.
- Core Memory Error - posted by "Kashmar, Ali" <Al...@emc.com> on 2015/11/10 18:25:33 UTC, 11 replies.
- Re: Tagging Flink classes with InterfaceAudience and InterfaceStability - posted by Robert Metzger <rm...@apache.org> on 2015/11/10 20:04:36 UTC, 14 replies.
- [jira] [Created] (FLINK-2996) Add config entry to define BlobServer port - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/10 21:16:11 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc8) - posted by Maximilian Michels <mx...@apache.org> on 2015/11/10 21:41:23 UTC, 11 replies.
- [jira] [Created] (FLINK-2997) Support range partition with user customized data distribution. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/11 07:58:10 UTC, 0 replies.
- [jira] [Created] (FLINK-2998) Support range partition comparison for multi input nodes. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/11 08:04:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2999) Support connected keyed streams - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/11 10:21:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3000) Add ShutdownHook to YARN CLI to prevent lingering sessions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/11 10:58:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3001) Add Support for Java 8 Optional type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 11:02:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3002) Add an EitherType to the Java API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 11:05:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3003) Add container allocation timeout to YARN CLI - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/11 11:06:10 UTC, 0 replies.
- Fixing the ExecutionConfig - posted by Stephan Ewen <se...@apache.org> on 2015/11/11 11:59:56 UTC, 5 replies.
- [DISCUSSION] Consistent shutdown of streaming jobs - posted by Gyula Fóra <gy...@apache.org> on 2015/11/11 15:19:41 UTC, 5 replies.
- [DISCUSSION] Type hints versus TypeInfoParser - posted by Stephan Ewen <se...@apache.org> on 2015/11/11 15:52:33 UTC, 8 replies.
- Streaming statefull operator with hashmap - posted by Martin Neumann <mn...@sics.se> on 2015/11/11 16:29:58 UTC, 5 replies.
- [jira] [Created] (FLINK-3004) ForkableMiniCluster does not call RichFunction#open - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/11/11 23:33:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3005) Commons-collections object deserialization remote command execution vulnerability - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/12 04:02:10 UTC, 0 replies.
- Error in during TypeExtraction - posted by Gyula Fóra <gy...@apache.org> on 2015/11/12 13:16:04 UTC, 2 replies.
- Flink managed memory in cluster mode - posted by Gyula Fóra <gy...@apache.org> on 2015/11/12 13:37:17 UTC, 2 replies.
- [jira] [Created] (FLINK-3006) TypeExtractor fails on custom type - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/12 15:37:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3007) Implement a parallel version of the Hidden Markov Model - posted by "Hilmi Yildirim (JIRA)" <ji...@apache.org> on 2015/11/12 16:19:10 UTC, 0 replies.
- Release notes for 0.10.0 - posted by Fabian Hueske <fh...@gmail.com> on 2015/11/12 21:25:30 UTC, 7 replies.
- [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.0-rc8) - posted by Maximilian Michels <mx...@apache.org> on 2015/11/13 00:01:49 UTC, 5 replies.
- [jira] [Created] (FLINK-3008) Failing/restarting streaming jobs are buggy in the webfrontend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/13 10:59:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3009) Cannot build docs with Jekyll 3.0.0 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/13 11:49:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3010) Add link to powered-by wiki page to project website - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/13 12:28:10 UTC, 0 replies.
- Canceling a failing/restarting job - posted by Gyula Fóra <gy...@gmail.com> on 2015/11/13 15:07:07 UTC, 1 replies.
- [jira] [Created] (FLINK-3011) Cannot cancel failing/restarting streaming job from the command line - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/13 15:09:10 UTC, 0 replies.
- Fwd: Re: Storm Compatibility - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/11/14 17:13:10 UTC, 8 replies.
- Connection reset by peer - posted by Gyula Fóra <gy...@apache.org> on 2015/11/14 18:14:27 UTC, 4 replies.
- [jira] [Created] (FLINK-3012) Refactor boilerplate code of while and if statements in DataSourceTask - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/11/15 19:44:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3013) Incorrect package declaration in GellyScalaAPICompletenessTest.scala - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/15 20:01:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3014) Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/15 21:30:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3015) Bring Features Web Page up to speed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/15 23:06:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3016) Update Flink roadmap - posted by "Slim Baltagi (JIRA)" <ji...@apache.org> on 2015/11/16 05:34:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3017) Broken link 'Slots' on Streaming Programming Guide - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/16 05:49:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3018) Job state discarded from web interface for restarting jobs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/16 10:34:11 UTC, 0 replies.
- Apache Flink 0.10.0 released - posted by Fabian Hueske <fh...@gmail.com> on 2015/11/16 14:53:48 UTC, 1 replies.
- [jira] [Created] (FLINK-3019) CLI does not list running/restarting jobs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/16 17:42:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3020) Local execution: set number of task manager slots to the maximum parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/16 18:39:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3021) Job submission times out due to classloading issue on JobManager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 09:24:10 UTC, 0 replies.
- Failing kafka consumer unable to cancel - posted by Gyula Fóra <gy...@apache.org> on 2015/11/17 09:24:22 UTC, 8 replies.
- [jira] [Created] (FLINK-3022) Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/17 09:33:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 10:17:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3024) TimestampExtractor Does not Work When returning Long.MIN_VALUE - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/17 10:47:11 UTC, 0 replies.
- Redis connector for Flink - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/11/17 11:41:20 UTC, 2 replies.
- [jira] [Created] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/17 11:48:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3026) Publish the flink docker container to the docker registry - posted by "Omer Katz (JIRA)" <ji...@apache.org> on 2015/11/17 13:36:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3027) Cancel button in Flink job dashboard does not work - posted by "Krzysztof Zarzycki (JIRA)" <ji...@apache.org> on 2015/11/17 13:56:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3028) Cannot cancel restarting job via web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/17 14:35:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3029) JobGraph is not connected correctly in webfrontend for streaming job - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/17 15:01:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3030) Enhance Dashboard to show Execution Attempts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 15:21:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3031) Consistent Shutdown of Streaming Jobs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/17 17:46:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3032) Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 17:48:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3033) Redis Source Connector - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/17 17:49:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3034) Redis SInk Connector - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/17 17:50:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3035) Redis as State Backend - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/17 18:06:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3036) Gelly's Graph.fromCsvReader method returns wrongly parameterized Graph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/17 18:20:11 UTC, 0 replies.
- [DISCUSS] Include import statements in documentation code examples - posted by Robert Metzger <rm...@apache.org> on 2015/11/18 12:09:08 UTC, 6 replies.
- [DISCUSS] Release Flink 0.10.1 soon - posted by Robert Metzger <rm...@apache.org> on 2015/11/18 12:24:35 UTC, 28 replies.
- [jira] [Created] (FLINK-3037) Make the behavior of the Kafka consumer configurable if the offsets to restore from are not available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/18 14:49:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/18 15:28:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3039) Trigger KeyValueState cannot be Scala Int - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/18 17:40:11 UTC, 0 replies.
- Add BigDecimal and BigInteger as types - posted by Timo Walther <tw...@apache.org> on 2015/11/18 17:55:13 UTC, 3 replies.
- [jira] [Created] (FLINK-3040) Add docs describing how to configure State Backends - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 18:36:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3041) Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal' - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/18 18:47:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3042) Define a way to let types create their own TypeInformation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 18:56:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3043) Kafka Connector description in Streaming API guide is wrong/outdated - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 20:33:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3044) In YARN mode, configure FsStateBackend by default. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 23:54:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3045) Properly expose the key of a kafka message - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/19 10:15:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3046) Integrate the Either Java type with the TypeExtractor - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/19 10:50:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3047) Local batch execution: set number of task manager slots to the maximum parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/19 12:18:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3048) DataSinkTaskTest.testCancelDataSinkTask - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/19 13:58:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3049) Move "Either" type to package "org.apache.flink.types" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 14:45:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3050) Add custom Exception type to suppress job restarts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 14:55:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3051) Define a maximum number of concurrent inflight checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 18:01:10 UTC, 0 replies.
- SETUP ISSUES - posted by JOHN MILLER <jm...@gmail.com> on 2015/11/19 21:19:41 UTC, 1 replies.
- Apache Tinkerpop & Geode Integration? - posted by James Thornton <ja...@gmail.com> on 2015/11/20 08:32:44 UTC, 3 replies.
- [jira] [Created] (FLINK-3052) Optimizer does not push properties out of bulk iterations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/20 12:21:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/20 14:17:10 UTC, 0 replies.
- How to modify TestBaseUtils.TASK_MANAGER_MEMORY_SIZE - posted by André Petermann <pe...@informatik.uni-leipzig.de> on 2015/11/20 16:11:34 UTC, 1 replies.
- [jira] [Created] (FLINK-3054) Remove R (return) type variable from SerializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/20 16:14:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3055) ExecutionVertex has duplicate method getParallelSubtaskIndex and getSubTaskIndex - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/20 17:14:11 UTC, 0 replies.
- Null Pointer Exception in tests but only in COLLECTION mode - posted by André Petermann <pe...@informatik.uni-leipzig.de> on 2015/11/20 18:41:45 UTC, 4 replies.
- how to write dataset in a file? - posted by jun aoki <ja...@apache.org> on 2015/11/21 04:06:32 UTC, 6 replies.
- [jira] [Created] (FLINK-3056) Show bytes sent/received as MBs/GB and so on in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/21 12:12:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3057) Provide a way to pass informaiton back to the plan - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/22 12:34:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3058) Add Kafka consumer for new 0.9.0.0 Kafka API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/22 18:17:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3059) Javadoc fix for DataSet.writeAsText() - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/11/23 04:25:12 UTC, 0 replies.
- Either left() vs left(value) - posted by Gyula Fóra <gy...@gmail.com> on 2015/11/23 09:55:37 UTC, 6 replies.
- Re: ReduceByKeyAndWindow in Flink - posted by Gyula Fóra <gy...@apache.org> on 2015/11/23 11:51:42 UTC, 2 replies.
- [VOTE] Release Apache Flink 0.10.1 (release-0.10.0-rc1) - posted by Robert Metzger <rm...@apache.org> on 2015/11/23 13:45:08 UTC, 18 replies.
- [jira] [Created] (FLINK-3060) Add possibility to integrate custom types into the TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/23 15:33:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3061) Kafka Consumer is not failing if broker is not available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/23 17:47:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3062) Kafka Producer is not failing if broker is not available/no partitions available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/23 18:11:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3063) [py] Remove combiner - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/23 18:51:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3064) Missing size check in GroupReduceOperatorBase leads to NPE - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/11/23 20:03:11 UTC, 0 replies.
- Slinding Window Join (without duplicates) - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/11/23 20:36:26 UTC, 4 replies.
- [jira] [Created] (FLINK-3065) Can't cancel failing jobs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 09:53:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3066) Kafka source fails on leader change - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 09:55:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 09:58:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3068) Add a Table API configuration to TableEnvironment - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/24 12:20:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3069) Make state materialization asynchronous - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/24 13:43:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3070) Create an asynchronous state handle interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/24 13:47:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3071) Add asynchronous materialization thread - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/24 13:49:10 UTC, 0 replies.
- withParameters() for Streaming API - posted by Timo Walther <tw...@apache.org> on 2015/11/24 14:14:46 UTC, 6 replies.
- Flink Master on Travis - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/11/24 15:48:21 UTC, 1 replies.
- [jira] [Created] (FLINK-3072) DbStateBackendTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/24 16:00:17 UTC, 0 replies.
- Union a data stream with a product of itself - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/11/24 16:46:52 UTC, 7 replies.
- [jira] [Created] (FLINK-3073) Activate streaming mode by default - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/24 16:48:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/24 16:53:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 19:07:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3076) Display channel exchange mode in the plan visualizer - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/24 21:53:11 UTC, 0 replies.
- could you please add me Contributor list? - posted by jun aoki <ja...@apache.org> on 2015/11/25 02:18:06 UTC, 3 replies.
- RE: The null in Flink - posted by "Li, Chengxiang" <ch...@intel.com> on 2015/11/25 11:31:50 UTC, 5 replies.
- [jira] [Created] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 12:24:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3078) JobManager does not shutdown when checkpointed jobs are running - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 14:30:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3079) Add utility for measuring the raw read throughput from a Kafka topic - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 16:03:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3080) Cannot union a data stream with a product of itself - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/25 16:13:10 UTC, 0 replies.
- [ANNOUNCE] CFP open for ApacheCon North America 2016 - posted by Rich Bowen <rb...@rcbowen.com> on 2015/11/25 18:32:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3081) Kafka Periodic Offset Committer does not properly terminate on canceling - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/26 12:12:11 UTC, 0 replies.
- [VOTE][RESULT] Release Apache Flink 0.10.1 (release-0.10.0-rc1) - posted by Robert Metzger <rm...@apache.org> on 2015/11/26 14:36:52 UTC, 0 replies.
- [jira] [Created] (FLINK-3082) Confusing error about ManualTimestampSourceFunction - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2015/11/26 15:06:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3083) Add docs how to configure streaming fault tolerance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/26 17:05:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3084) File State Backend should not write very small state into files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/26 17:23:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3085) Move State Backend Initialization from "registerInputOutput()" to "invoke()" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/26 17:31:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/26 20:24:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3087) Table API do not support multi count in aggregation. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/27 07:40:10 UTC, 0 replies.
- Serialization problem in CollectionEnvironment - posted by Martin Junghanns <m....@mailbox.org> on 2015/11/27 10:20:10 UTC, 5 replies.
- [jira] [Created] (FLINK-3088) WritableSerializer cannot copy writable object - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/27 12:37:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3089) OperatorState timeout - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2015/11/27 14:03:11 UTC, 0 replies.
- [ANNOUNCE] Flink 0.10.1 released - posted by Robert Metzger <rm...@apache.org> on 2015/11/27 15:27:38 UTC, 4 replies.
- [jira] [Created] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/11/28 19:21:10 UTC, 0 replies.
- Either not NotSerializableException and InvalidTypesException - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/11/28 20:18:22 UTC, 4 replies.
- [jira] [Created] (FLINK-3091) Provide ZooKeeper root path in startup scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/30 10:53:11 UTC, 0 replies.
- Task Parallelism in a Cluster - posted by "Kashmar, Ali" <Al...@emc.com> on 2015/11/30 17:47:51 UTC, 1 replies.