You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [Discuss] Why different job's tasks can run in the single process. - posted by Jark Wu <wu...@alibaba-inc.com> on 2016/07/01 02:49:50 UTC, 1 replies.
- Re: [Discussion] Query regarding Join and Windows - posted by Vinay Patil <vi...@gmail.com> on 2016/07/01 02:52:19 UTC, 1 replies.
- Re: [DISCUSS] Releasing Flink 1.1.0 - posted by Chesnay Schepler <ch...@apache.org> on 2016/07/01 09:29:17 UTC, 15 replies.
- [jira] [Created] (FLINK-4139) Yarn: Adjust parallelism and task slots correctly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/01 13:12:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4140) CheckpointCoordinator fails to discard completed checkpoint - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 13:35:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 13:43:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.5.0 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 14:30:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4143) Configurable delimiter for metric identifier - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/01 14:56:11 UTC, 0 replies.
- Re: Web dashboard binaries and licensing - posted by Maximilian Michels <mx...@apache.org> on 2016/07/01 15:16:21 UTC, 5 replies.
- [jira] [Created] (FLINK-4144) Yarn properties file: replace hostname/port with Yarn application id - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/01 16:52:11 UTC, 0 replies.
- [Discussion] Query Regarding Operator chaining - posted by Vinay Patil <vi...@gmail.com> on 2016/07/01 17:39:40 UTC, 9 replies.
- [jira] [Created] (FLINK-4145) JmxReporterTest fails due to port conflicts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/03 14:08:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/03 16:42:10 UTC, 0 replies.
- Exception but successfully build - posted by David Herzog <hd...@googlemail.com> on 2016/07/04 07:22:11 UTC, 1 replies.
- Re: DagConnection tempMode vs breakPipeline property - posted by Ufuk Celebi <uc...@apache.org> on 2016/07/04 11:01:28 UTC, 1 replies.
- [jira] [Created] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/04 12:17:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4148) incorrect calculation distance in QuadTree - posted by "Alexey Diomin (JIRA)" <ji...@apache.org> on 2016/07/04 12:34:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4149) Fix Serialization of NFA in AbstractKeyedCEPPatternOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/04 14:55:11 UTC, 0 replies.
- [DISCUSS] Putting Flink user names / logos on the homepage - posted by Stephan Ewen <se...@apache.org> on 2016/07/04 14:57:57 UTC, 9 replies.
- [Discuss] Query regarding Flink 1.1 setup - posted by Vinay Patil <vi...@gmail.com> on 2016/07/04 16:07:54 UTC, 6 replies.
- [jira] [Created] (FLINK-4150) Problem with Blobstore in Yarn HA setting on recovery after cluster shutdown - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/04 16:14:11 UTC, 0 replies.
- Issues while interacting with DynamoDB - posted by Deepak Jha <dk...@gmail.com> on 2016/07/05 00:46:17 UTC, 1 replies.
- [jira] [Created] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 08:17:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4152) TaskManager registration exponential backoff doesn't work - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 12:33:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4153) ExecutionGraphRestartTest Fails - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/05 12:41:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4154) Correction of murmur hash breaks backwards compatibility - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/05 15:06:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/07/05 18:37:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/06 08:38:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4157) FlinkKafkaMetrics cause TaskManager shutdown during cancellation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/06 09:11:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4158) Scala QuickStart StreamingJob fails to compile - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 09:30:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4159) Quickstart poms exclude unused dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 09:53:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4160) YARN session doesn't show input validation errors - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/06 09:58:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 11:52:10 UTC, 0 replies.
- Re: [DISCUSS] Allowed Lateness in Flink - posted by Aljoscha Krettek <al...@apache.org> on 2016/07/06 13:19:15 UTC, 24 replies.
- [jira] [Created] (FLINK-4162) Event-Time CEP Job Fails after Restart - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/06 14:03:11 UTC, 0 replies.
- Re: [DISCUSS] FLIP 1 - Flink Improvement Proposal - posted by Ufuk Celebi <uc...@apache.org> on 2016/07/06 14:24:24 UTC, 15 replies.
- Connecting Flink and Hive - posted by Alan Gates <al...@gmail.com> on 2016/07/06 15:14:03 UTC, 4 replies.
- [DISCUSS] Enhance Window Evictor in Flink - posted by Aljoscha Krettek <al...@apache.org> on 2016/07/06 15:49:29 UTC, 26 replies.
- [jira] [Created] (FLINK-4163) Deadlock during GroupReduce - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/06 19:45:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4164) Use only one rocksdb column family to store all states in an operator - posted by "LiuBiao (JIRA)" <ji...@apache.org> on 2016/07/07 08:08:11 UTC, 0 replies.
- Flink 1.1.0 Preview RC0 - posted by Ufuk Celebi <uc...@apache.org> on 2016/07/07 09:02:17 UTC, 16 replies.
- [jira] [Created] (FLINK-4165) Event-Time CEP Job Sometimes Fails After Restart - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/07 09:06:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4166) Generate automatic different namespaces in Zookeeper for Flink applications - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/07 09:07:11 UTC, 0 replies.
- 答复: [DISCUSS] Enhance Window Evictor in Flink - posted by "吕文龙(吕文龙)" <we...@alibaba-inc.com> on 2016/07/07 09:58:52 UTC, 0 replies.
- [jira] [Created] (FLINK-4167) TaskMetricGroup does not close IOMetricGroup - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/07 10:03:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4168) ForkableFlinkMiniCluster not available in Kinesis connector tests - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/07 12:39:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4169) CEP Does Not Work with RocksDB StateBackend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/07 12:44:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/07 13:05:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4171) StatsD does not accept metrics whose name contains ":" - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/07 13:11:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4172) Don't proxy a ProxiedObject - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/07 13:29:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/07 14:49:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4174) Enhance Window Evictor - posted by "vishnu viswanath (JIRA)" <ji...@apache.org> on 2016/07/07 16:51:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4175) Broadcast data sent increases with # slots per TM - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2016/07/07 23:42:10 UTC, 0 replies.
- Re: Broadcast data sent increases with # slots per TM - posted by Felix Neutatz <ne...@googlemail.com> on 2016/07/07 23:47:02 UTC, 2 replies.
- Contribute to Flink - posted by Kevin <ke...@gmail.com> on 2016/07/08 07:12:21 UTC, 1 replies.
- Contributing - posted by Kevin Jacobs <ke...@cern.ch> on 2016/07/08 08:02:25 UTC, 3 replies.
- [jira] [Created] (FLINK-4176) Travis build fails at flink-connector-kinesis for JDK: openjdk 7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 08:48:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/08 10:06:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4178) CoStreamCheckpointingITCase deadlocks - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/08 10:19:11 UTC, 0 replies.
- [Discuss] Read from S3 using AvroInputFormat - posted by Vinay Patil <vi...@gmail.com> on 2016/07/08 11:50:52 UTC, 2 replies.
- Evaluating Apache Flink - posted by Kevin Jacobs <ke...@cern.ch> on 2016/07/08 12:23:36 UTC, 5 replies.
- [DISCUSS] Move Documentation from Wiki to Documentation - posted by Aljoscha Krettek <al...@apache.org> on 2016/07/08 12:56:53 UTC, 3 replies.
- [jira] [Created] (FLINK-4179) Update TPCHQuery3Table example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:02:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4180) Create a batch SQL example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:06:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4181) Add a basic streaming Table API example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:09:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures. - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/08 14:14:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4183) Move checking for StreamTableEnvironment into validation layer - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:21:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4184) Ganglia and GraphiteReporter report metric names with invalid characters - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/08 14:42:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4185) Reflecting rename from Tachyon to Alluxio - posted by "Jiri Simsa (JIRA)" <ji...@apache.org> on 2016/07/08 16:33:10 UTC, 0 replies.
- sampling function - posted by Le Quoc Do <le...@gmail.com> on 2016/07/09 14:47:54 UTC, 7 replies.
- [jira] [Created] (FLINK-4186) Expose Kafka metrics through Flink metrics - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/10 08:10:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4187) Support for outer joins on DataStream - posted by "Ignacio N. Lucero Ascencio (JIRA)" <ji...@apache.org> on 2016/07/10 14:37:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4188) Support for outer joins on DataStream - posted by "Ignacio N. Lucero Ascencio (JIRA)" <ji...@apache.org> on 2016/07/10 14:38:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4189) Introduce symbols for internal use - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/11 07:38:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4190) Generalise RollingSink to work with arbitrary buckets - posted by "Josh Forman-Gornall (JIRA)" <ji...@apache.org> on 2016/07/11 11:43:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4191) Expose shard information in KinesisDeserializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/11 12:54:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4192) Move Metrics API to separate module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/11 14:02:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4193) Task manager JVM crashes while deploying cancelling jobs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/07/11 14:12:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/11 17:02:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/11 18:33:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4196) Remove "recoveryTimestamp" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/11 19:31:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4197) Allow Kinesis Endpoint to be Overridden via Config - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/07/12 02:32:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4198) Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/12 09:06:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4199) Wrong client behavior when submitting job to non-existing cluster - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/12 09:17:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4200) Kafka consumers should log the offset from which they restore - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/12 13:00:23 UTC, 0 replies.
- [jira] [Created] (FLINK-4201) Checkpoints for jobs in non-terminal state (e.g. suspended) get deleted - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/12 13:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4202) Add JM metric which shows the restart duration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/12 14:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4203) Improve Table API documentation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/12 15:59:20 UTC, 0 replies.
- [DISCUSS] FLIP-1 : Fine grained recovery from task failures - posted by Stephan Ewen <se...@apache.org> on 2016/07/12 17:55:29 UTC, 9 replies.
- [jira] [Created] (FLINK-4204) Clean up gelly-examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/07/12 21:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4205) Implement stratified sampling for DataSet - posted by "Do Le Quoc (JIRA)" <ji...@apache.org> on 2016/07/13 07:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4206) Metric names should alle special characters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/13 08:52:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4207) WindowOperator becomes very slow with allowed lateness - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/13 08:56:20 UTC, 0 replies.
- [DISCUSS] FLIP-2 Extending Window Function Metadata - posted by Aljoscha Krettek <al...@apache.org> on 2016/07/13 11:56:32 UTC, 11 replies.
- [jira] [Created] (FLINK-4208) Support Running Flink processes in foreground mode - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/07/13 13:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4209) Docker image breaks with multiple NICs - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/07/13 13:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/13 13:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4211) Dynamic Properties not working for jobs submitted to Yarn session - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/13 14:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4212) Lock on pid file when starting daemons - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/13 15:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4213) Provide CombineHint in Gelly algorithms - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/14 01:25:20 UTC, 0 replies.
- Restructuring Javadoc and Scaladoc for libraries - posted by Chiwan Park <ch...@apache.org> on 2016/07/14 01:59:02 UTC, 3 replies.
- [jira] [Created] (FLINK-4214) JobExceptionsHandler will return all exceptions - posted by "Sumit Chawla (JIRA)" <ji...@apache.org> on 2016/07/14 03:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4215) timestamp of StreamRecord is lost in WindowOperator - posted by "Cody (JIRA)" <ji...@apache.org> on 2016/07/14 08:20:20 UTC, 0 replies.
- Helping Spread the Word about Apachecon EU 2016 - posted by Sharan Foga <sh...@apache.org> on 2016/07/14 08:52:40 UTC, 0 replies.
- [jira] [Created] (FLINK-4216) WordWithCount example with Java has wrong generics type - posted by "Serhiy Boychenko (JIRA)" <ji...@apache.org> on 2016/07/14 10:14:20 UTC, 0 replies.
- Re: [PROPOSAL] Structure the Flink Open Source Development - posted by Robert Metzger <rm...@apache.org> on 2016/07/14 11:29:39 UTC, 0 replies.
- [jira] [Created] (FLINK-4217) Gelly drivers should read CSV values as strings - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/14 13:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting - posted by "Sergii Koshel (JIRA)" <ji...@apache.org> on 2016/07/14 15:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4219) Quote PDSH opts in start-cluster.sh - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/14 17:40:21 UTC, 0 replies.
- [DISCUSS] Move JIRA creation emails to separate list? - posted by Theodore Vasiloudis <th...@gmail.com> on 2016/07/14 17:56:29 UTC, 4 replies.
- Flink on AWS EMR unable to access S3 files - posted by Ashish Aggarwal <as...@gmail.com> on 2016/07/14 18:09:00 UTC, 0 replies.
- [DISCUSS] Commit tagging - posted by Ufuk Celebi <uc...@apache.org> on 2016/07/15 08:57:31 UTC, 5 replies.
- [jira] [Created] (FLINK-4220) ClientTest fails after port conflict - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/15 09:09:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4221) Show metrics in WebFrontend - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/15 10:31:20 UTC, 0 replies.
- [DISCUSS] FLIP-3 - Organization of Documentation - posted by Stephan Ewen <se...@apache.org> on 2016/07/15 14:09:56 UTC, 5 replies.
- Re: In AbstractRocksDBState, why write a byte 42 between key and namespace? - posted by Stephan Ewen <se...@apache.org> on 2016/07/15 14:31:31 UTC, 9 replies.
- [jira] [Created] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata - posted by "Nick Chadwick (JIRA)" <ji...@apache.org> on 2016/07/15 23:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4223) Rearrange scaladoc and javadoc for Scala API - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/07/16 03:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4224) Exception after successful execution when submitting job through the web interface. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/16 15:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4225) ML On Streaming Operating in Continuous and Micro Backed Mode - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2016/07/16 15:55:20 UTC, 0 replies.
- Re: Apache Flink <=> Apache Ignite integration - posted by Saikat Maitra <sa...@gmail.com> on 2016/07/16 20:09:19 UTC, 2 replies.
- [jira] [Created] (FLINK-4226) Typo: Define Keys using Field Expressions example should use window and not reduce - posted by "Ahmad Ragab (JIRA)" <ji...@apache.org> on 2016/07/17 04:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4227) Add Heron (heronstreaming.io) comparison to features page - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2016/07/17 16:24:20 UTC, 0 replies.
- custom control messages from source - posted by Chen Qin <qi...@gmail.com> on 2016/07/17 22:40:34 UTC, 1 replies.
- DataStream.partitionCustom() - define parallelism - posted by vanekjar <va...@gmail.com> on 2016/07/18 11:48:07 UTC, 3 replies.
- [jira] [Created] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/18 14:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4229) Do not start Metrics Reporter by default - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/18 15:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4230) Session Windowing IT Case - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/18 15:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4231) Switch DistinctOperator from GroupReduceFunction to ReduceFunction - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/18 15:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4232) Flink executable does not return correct pid - posted by "David Moravek (JIRA)" <ji...@apache.org> on 2016/07/19 08:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4233) Simplify leader election / leader session ID assignment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/19 12:57:20 UTC, 0 replies.
- RE: Flink Table & SQL doesn't work in very simple example - posted by Radu Tudoran <ra...@huawei.com> on 2016/07/19 16:14:00 UTC, 7 replies.
- [jira] [Created] (FLINK-4234) CassandraConnectorTest causes travis build to time out - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/20 12:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4235) ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/20 12:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2016/07/20 12:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4237) ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails due to Timeout Futures - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/20 13:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4238) Only allow/require query for Tuple Stream in CassandraSink - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/20 16:10:21 UTC, 0 replies.
- QueryableState, unable to register KvStateRegistryListener - posted by Vishnu Viswanath <vi...@gmail.com> on 2016/07/20 23:56:40 UTC, 2 replies.
- [jira] [Created] (FLINK-4239) Set Default Allowed Lateness to Zero and Make Triggers Non-Purging - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/21 08:23:20 UTC, 0 replies.
- Implementing multi-field "sum" function [FLINK-4029] - posted by Ivan Mushketyk <iv...@gmail.com> on 2016/07/21 10:05:57 UTC, 0 replies.
- [jira] [Created] (FLINK-4240) Cannot use expressions in Scala Table API's groupBy method - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 13:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4241) Cryptic expression parser exceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 13:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4242) Improve validation exception messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 13:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4243) Change "Scope" to "Namespace" for Metrics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 13:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4244) Field names for union operator do not have to be equal - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 14:06:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4245) Metric naming improvements - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 14:24:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4246) Allow Specifying Multiple Metrics Reporters - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/21 15:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 15:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 15:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4249) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 15:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4250) Cannot select column from CsvTableSource - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 17:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue - posted by "Philipp Grulich (JIRA)" <ji...@apache.org> on 2016/07/21 20:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4252) Table program cannot be compiled - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/07/22 03:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4253) Rename "recovery.mode" config key to "high-availability" - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/22 09:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4254) Add file system based high-availability mode - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/22 09:37:20 UTC, 0 replies.
- Re: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink - posted by Vishnu Viswanath <vi...@gmail.com> on 2016/07/22 10:43:03 UTC, 11 replies.
- [DISCUSS] FLIP-5 Only send data to each taskmanager once for broadcasts - posted by Felix Neutatz <ne...@googlemail.com> on 2016/07/22 12:59:59 UTC, 2 replies.
- [jira] [Created] (FLINK-4255) Unstable test WebRuntimeMonitorITCase.testNoEscape - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/22 14:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4256) Fine-grained recovery - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/22 16:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4257) Handle delegating algorithm change of class - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/22 17:28:20 UTC, 0 replies.
- Question about Apache Flink Use Case - posted by Suma Cherukuri <Su...@symantec.com> on 2016/07/22 19:00:39 UTC, 5 replies.
- [DISCUSS] FLIP-6 - Flink Deployment and Process Model - Standalone, Yarn, Mesos, Kubernetes, etc. - posted by Stephan Ewen <se...@apache.org> on 2016/07/22 19:26:56 UTC, 3 replies.
- [jira] [Created] (FLINK-4258) Potential null pointer dereference in SavepointCoordinator#onFullyAcknowledgedCheckpoint - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/07/22 20:09:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/07/22 20:22:20 UTC, 0 replies.
- Cassandra statebackend - posted by Chen Qin <qi...@gmail.com> on 2016/07/25 02:23:46 UTC, 4 replies.
- Supporting Multi-tenancy in a Flink - posted by "Aparup Banerjee (apbanerj)" <ap...@cisco.com> on 2016/07/25 03:38:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4260) Allow SQL's LIKE ESCAPE - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 12:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4261) Setup atomic deployment of snapshots - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/25 14:11:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4262) Consider null handling during sorting - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 14:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4263) SQL's VALUES does not work properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 14:47:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4264) New GraphMetrics driver - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/25 15:01:20 UTC, 0 replies.
- [ANNOUNCE] Flink Forward 2016: First round of speakers and sessions is out - posted by Kostas Tzoumas <kt...@apache.org> on 2016/07/25 15:54:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4265) Add a NoOpOperator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/25 17:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4266) Cassandra Statebackend - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2016/07/25 20:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4267) Adding async I/O flat map - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/27 02:26:20 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.1.0 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/07/27 09:50:22 UTC, 2 replies.
- [jira] [Created] (FLINK-4268) Add a parsers for BigDecimals/BigInteger - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/27 13:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4269) Decrease log level in RuntimeMonitorHandler - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/27 14:28:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4270) 'as' in front of join does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/27 15:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4271) There is no way to set parallelism of operators such as map and window produced by - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/07/28 02:13:20 UTC, 0 replies.
- FlinkKafkaConsumer09 - posted by Kevin Jacobs <ke...@cern.ch> on 2016/07/28 08:14:46 UTC, 7 replies.
- [jira] [Created] (FLINK-4272) Create a JobClient for job control and monitoring - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/28 10:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/28 10:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4274) Expose new JobClient in the DataSet/DataStream API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/28 10:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/07/28 11:56:20 UTC, 0 replies.
- [DISCUSS] FLIP-7 Expose metrics to WebInterface - posted by Chesnay Schepler <ch...@apache.org> on 2016/07/28 13:12:37 UTC, 0 replies.
- [jira] [Created] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/28 13:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4277) TaskManagerConfigurationTest fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/28 13:45:20 UTC, 0 replies.
- Use case - posted by Kevin Jacobs <ke...@cern.ch> on 2016/07/28 15:00:25 UTC, 1 replies.
- Discard out-of-order events - posted by Kevin Jacobs <ke...@cern.ch> on 2016/07/28 16:49:49 UTC, 4 replies.
- [jira] [Created] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/07/28 19:24:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4279) [py] Set flink dependencies to provided - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 09:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/29 09:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/29 10:05:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4282) Add Offset Parameter to WindowAssigners - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/29 10:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4283) ExecutionGraphRestartTest fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 11:28:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4284) DataSet/CEP link to non-existant "Linking with Flink" section - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 11:52:21 UTC, 0 replies.
- Introduction - posted by Neelesh Salian <ns...@cloudera.com> on 2016/07/31 18:07:30 UTC, 0 replies.