issues@flink.apache.org, 2016-12

You are viewing a plain text version of this content. The canonical link for it is here.

- [GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ... - posted by EronWright <gi...@git.apache.org> on 2016/12/01 01:27:02 UTC, 14 replies.
- [jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 01:27:59 UTC, 15 replies.
- [jira] [Commented] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/12/01 01:42:58 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/01 02:44:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/01 02:44:58 UTC, 11 replies.
- [jira] [Assigned] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp / Date - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2016/12/01 03:03:58 UTC, 0 replies.
- [GitHub] flink issue #2811: [FLINK-5159] Improve perfomance of inner joins with a sin... - posted by AlexanderShoshin <gi...@git.apache.org> on 2016/12/01 07:39:43 UTC, 2 replies.
- [jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 07:39:58 UTC, 4 replies.
- [GitHub] flink pull request #2916: [FLINK-4523] [kinesis] Allow Kinesis Consumer to s... - posted by tony810430 <gi...@git.apache.org> on 2016/12/01 08:00:12 UTC, 18 replies.
- [jira] [Commented] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp / Date - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 08:01:11 UTC, 20 replies.
- [GitHub] flink issue #2768: [FLINK-5023][FLINK-5024] Add SimpleStateDescriptor to cla... - posted by shixiaogang <gi...@git.apache.org> on 2016/12/01 08:16:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-5023) Add get() method in State interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 08:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5217) Deprecated interface Checkpointed make clear suggestion - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/01 09:29:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5217) Deprecated interface Checkpointed make clear suggestion - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/01 09:31:59 UTC, 1 replies.
- [jira] [Closed] (FLINK-5194) Log heartbeats on TRACE level - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/01 09:47:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5201) Promote loaded config properties to INFO - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/01 09:48:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5196) Don't log InputChannelDescriptor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/01 09:49:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5198) Overwrite TaskState toString - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/01 09:49:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2016/12/01 09:49:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5199) Improve logging of submitted job graph actions in HA case - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/01 09:50:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5207) Decrease HadoopFileSystem logging - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/01 09:51:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5192) Provide better log config templates - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/01 09:51:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/12/01 10:24:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5173) Upgrade RocksDB dependency - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/01 10:43:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/01 11:12:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5218) Eagerly close checkpoint streams on cancellation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/01 11:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5219) Add non-grouped session windows for batch tables - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/12/01 11:47:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5218) Eagerly close checkpoint streams on cancellation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/01 11:48:58 UTC, 8 replies.
- [GitHub] flink issue #2905: [FLINK-5190] [runtime] fix ZooKeeperLeaderRetrievalServic... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/01 13:06:26 UTC, 2 replies.
- [jira] [Commented] (FLINK-5190) ZooKeeperLeaderRetrievalService should not close the zk client when stop - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 13:06:58 UTC, 3 replies.
- [GitHub] flink pull request #2653: [FLINK-4469] [table] Add support for user defined ... - posted by twalthr <gi...@git.apache.org> on 2016/12/01 13:12:46 UTC, 18 replies.
- [jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 13:12:58 UTC, 22 replies.
- [GitHub] flink pull request #2910: [backport] [FLINK-5193] [jm] Harden job recovery i... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/01 13:33:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 13:33:58 UTC, 5 replies.
- [jira] [Closed] (FLINK-5215) Close checkpoint streams upon cancellation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/01 13:37:58 UTC, 0 replies.
- [GitHub] flink issue #2901: [FLINK-3921] StringParser encoding - posted by fhueske <gi...@git.apache.org> on 2016/12/01 13:50:05 UTC, 9 replies.
- [jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 13:50:58 UTC, 15 replies.
- [GitHub] flink pull request #2790: [FLINK-4491] Handle index.number_of_shards in the ... - posted by ddolzan <gi...@git.apache.org> on 2016/12/01 14:08:12 UTC, 0 replies.
- [GitHub] flink issue #2790: [FLINK-4491] Handle index.number_of_shards in the ES conn... - posted by ddolzan <gi...@git.apache.org> on 2016/12/01 14:08:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-4491) Handle index.number_of_shards in the ES connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 14:08:58 UTC, 2 replies.
- [GitHub] flink issue #2842: [FLINK-5097][gelly] Add missing input type information to... - posted by twalthr <gi...@git.apache.org> on 2016/12/01 14:11:22 UTC, 4 replies.
- [jira] [Commented] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 14:11:58 UTC, 5 replies.
- [GitHub] flink issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio... - posted by fhueske <gi...@git.apache.org> on 2016/12/01 14:24:57 UTC, 11 replies.
- [jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 14:24:58 UTC, 16 replies.
- [jira] [Issue Comment Deleted] (FLINK-4604) Add support for standard deviation/variance - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/12/01 14:28:58 UTC, 0 replies.
- [GitHub] flink pull request #2917: [FLINK-2821] use custom Akka build to listen on al... - posted by mxm <gi...@git.apache.org> on 2016/12/01 14:57:52 UTC, 15 replies.
- [jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 14:57:58 UTC, 35 replies.
- [GitHub] flink issue #2902: [FLINK-5209] [webfrontend] Fix TaskManager metrics - posted by zentol <gi...@git.apache.org> on 2016/12/01 15:28:06 UTC, 0 replies.
- [GitHub] flink pull request #2908: [maven] properly attach the CEP Scala source code - posted by mxm <gi...@git.apache.org> on 2016/12/01 15:28:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-5209) Fix TaskManager metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 15:28:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/01 16:41:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/01 16:41:58 UTC, 0 replies.
- [GitHub] flink pull request #2918: [FLINK-5214] Clean up checkpoint data in case of a... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/01 16:47:12 UTC, 1 replies.
- [GitHub] flink pull request #2919: [FLINK-4554] [table] Add support for array types - posted by twalthr <gi...@git.apache.org> on 2016/12/01 16:48:22 UTC, 15 replies.
- [GitHub] flink issue #2910: [backport] [FLINK-5193] [jm] Harden job recovery in case ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/01 16:48:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-4554) Add support for array types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 16:48:58 UTC, 18 replies.
- [GitHub] flink issue #2873: [backport] [FLINK-5158] [ckPtCoord] Handle exceptions fro... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/01 16:56:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 16:56:58 UTC, 4 replies.
- [jira] [Commented] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/12/01 17:06:58 UTC, 18 replies.
- [GitHub] flink pull request #2870: [FLINK-4565] Support for SQL IN operator - posted by fhueske <gi...@git.apache.org> on 2016/12/01 17:52:40 UTC, 3 replies.
- [jira] [Commented] (FLINK-4565) Support for SQL IN operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 17:52:58 UTC, 7 replies.
- [jira] [Closed] (FLINK-4918) Add SSL support to Mesos artifact server - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/01 18:11:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4826) Add keytab based kerberos support for Mesos environment - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/01 18:12:58 UTC, 0 replies.
- [GitHub] flink pull request #2762: [FLINK-3871] Add Kafka TableSource with Avro seria... - posted by mushketyk <gi...@git.apache.org> on 2016/12/01 18:16:45 UTC, 4 replies.
- [GitHub] flink pull request #2920: [FLINK-5218] [state backends] Eagerly close checkp... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/01 18:41:35 UTC, 1 replies.
- [GitHub] flink issue #2920: [FLINK-5218] [state backends] Eagerly close checkpoint st... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/01 18:43:22 UTC, 3 replies.
- [GitHub] flink issue #2917: [FLINK-2821] use custom Akka build to listen on all inter... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/01 19:08:49 UTC, 8 replies.
- [GitHub] flink issue #2766: [FLINK-4898] Refactor HTTP handlers and Netty server/clie... - posted by EronWright <gi...@git.apache.org> on 2016/12/01 19:22:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-4898) Refactor HTTP handlers and Netty server/client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/01 19:22:58 UTC, 0 replies.
- [GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit... - posted by asfgit <gi...@git.apache.org> on 2016/12/01 19:49:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-5159) Improve perfomance of inner joins with a single row input - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/01 19:57:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/01 20:09:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4541) Support for SQL NOT IN operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/01 20:10:58 UTC, 0 replies.
- [GitHub] flink pull request #2921: [FLINK-5185] [Table API & SQL] Decouple BatchTable... - posted by beyond1920 <gi...@git.apache.org> on 2016/12/02 01:44:16 UTC, 4 replies.
- [jira] [Created] (FLINK-5220) Flink SQL projection pushdown - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/12/02 01:48:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5220) Flink SQL projection pushdown - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/12/02 01:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5221) Checkpointed workless in Window Operator - posted by "Syinchwun Leo (JIRA)" <ji...@apache.org> on 2016/12/02 01:57:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5221) Checkpointed workless in Window Operator - posted by "Syinchwun Leo (JIRA)" <ji...@apache.org> on 2016/12/02 01:58:58 UTC, 3 replies.
- [jira] [Created] (FLINK-5222) Rename StateBackend interface to StateBinder - posted by "MaGuowei (JIRA)" <ji...@apache.org> on 2016/12/02 02:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5223) Add documentation of UDTF in Table API & SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/02 03:05:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5223) Add documentation of UDTF in Table API & SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/02 03:06:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5224) Improve UDTF: emit rows directly instead of buffering them - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/02 03:11:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5224) Improve UDTF: emit rows directly instead of buffering them - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/02 03:11:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5225) Add interface to override parameter types of UDTF's eval method - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/02 03:22:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5225) Add interface to override parameter types of UDTF's eval method - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/02 03:22:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5188) Shade dependency - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/02 07:19:59 UTC, 1 replies.
- [GitHub] flink pull request #2922: Initial try - posted by vipul1409 <gi...@git.apache.org> on 2016/12/02 07:36:35 UTC, 3 replies.
- [jira] [Updated] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API - posted by "Alexander Shoshin (JIRA)" <ji...@apache.org> on 2016/12/02 07:51:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5169) Make consumption of input channels fair - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 08:45:58 UTC, 0 replies.
- [GitHub] flink issue #2922: Initial try - posted by zentol <gi...@git.apache.org> on 2016/12/02 08:50:59 UTC, 1 replies.
- [GitHub] flink issue #2893: [FLINK-5128]Get Kafka partitions in FlinkKafkaProducer on... - posted by tzulitai <gi...@git.apache.org> on 2016/12/02 08:57:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 08:57:59 UTC, 4 replies.
- [jira] [Created] (FLINK-5226) Eagerly project unused attributes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 09:10:58 UTC, 0 replies.
- [GitHub] flink pull request #2744: [FLINK-4928] [yarn] Implement FLIP-6 YARN Applicat... - posted by shuai-xu <gi...@git.apache.org> on 2016/12/02 09:11:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-4928) Implement FLIP-6 YARN Application Master Runner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 09:11:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-5220) Flink SQL projection pushdown - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 09:17:58 UTC, 27 replies.
- [jira] [Created] (FLINK-5227) Add warning to include flink-table in job fat jars - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 10:02:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/12/02 10:09:58 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/12/02 10:10:58 UTC, 4 replies.
- [jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/02 10:14:58 UTC, 2 replies.
- [GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra... - posted by fhueske <gi...@git.apache.org> on 2016/12/02 10:30:53 UTC, 18 replies.
- [jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 10:30:58 UTC, 37 replies.
- [GitHub] flink issue #2916: [FLINK-4523] [kinesis] Allow Kinesis Consumer to start fr... - posted by tony810430 <gi...@git.apache.org> on 2016/12/02 10:36:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 10:45:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-2435) Add support for custom CSV field parsers - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 10:45:58 UTC, 0 replies.
- [GitHub] flink issue #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG lifecycle - posted by rmetzger <gi...@git.apache.org> on 2016/12/02 11:00:34 UTC, 12 replies.
- [GitHub] flink issue #2897: [FLINK-4676] [connectors] Merge batch and streaming conne... - posted by fhueske <gi...@git.apache.org> on 2016/12/02 11:00:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 11:01:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-5179) MetricRegistry life-cycle issues with HA - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 11:01:03 UTC, 16 replies.
- [jira] [Commented] (FLINK-5108) Remove ClientShutdownHook during job execution - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/02 11:01:58 UTC, 12 replies.
- [jira] [Commented] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/02 11:04:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5228) LocalInputChannel re-trigger request and release deadlock - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 11:07:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/02 11:12:59 UTC, 2 replies.
- [GitHub] flink issue #2921: [FLINK-5185] [Table API & SQL] Decouple BatchTableSourceS... - posted by fhueske <gi...@git.apache.org> on 2016/12/02 11:14:54 UTC, 1 replies.
- [jira] [Updated] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/02 11:16:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/02 11:17:58 UTC, 8 replies.
- [jira] [Commented] (FLINK-4859) Clearly Separate Responsibilities of StreamOperator and StreamTask - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/02 11:20:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 11:29:59 UTC, 0 replies.
- [GitHub] flink pull request #2923: [FLINK-5220] [Table API & SQL] Flink SQL projectio... - posted by beyond1920 <gi...@git.apache.org> on 2016/12/02 11:34:08 UTC, 17 replies.
- [GitHub] flink issue #2870: [FLINK-4565] Support for SQL IN operator - posted by NickolayVasilishin <gi...@git.apache.org> on 2016/12/02 11:44:18 UTC, 3 replies.
- [jira] [Updated] (FLINK-4632) when yarn nodemanager lost, flink hung - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/02 11:54:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4303) Add CEP examples - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/12/02 11:56:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-5226) Eagerly project unused attributes - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/12/02 12:10:59 UTC, 11 replies.
- [jira] [Comment Edited] (FLINK-5226) Eagerly project unused attributes - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/12/02 12:12:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5218) Eagerly close checkpoint streams on cancellation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 12:23:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5218) Eagerly close checkpoint streams on cancellation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 12:23:59 UTC, 0 replies.
- [GitHub] flink issue #2617: [FLINK-4705] Instrument FixedLengthRecordSorter - posted by StephanEwen <gi...@git.apache.org> on 2016/12/02 12:30:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-4705) Instrument FixedLengthRecordSorter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 12:30:58 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (FLINK-4632) when yarn nodemanager lost, flink hung - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/12/02 12:52:59 UTC, 0 replies.
- [GitHub] flink pull request #2897: [FLINK-4676] [connectors] Merge batch and streamin... - posted by asfgit <gi...@git.apache.org> on 2016/12/02 13:36:07 UTC, 0 replies.
- [jira] [Closed] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 13:37:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 13:38:58 UTC, 0 replies.
- [GitHub] flink pull request #2871: [FLINK-5163] Ports the production functions to the... - posted by aljoscha <gi...@git.apache.org> on 2016/12/02 13:43:59 UTC, 6 replies.
- [jira] [Commented] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 13:44:58 UTC, 10 replies.
- [jira] [Created] (FLINK-5229) Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/02 13:53:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5227) Add warning to include flink-table in job fat jars - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:01:03 UTC, 1 replies.
- [jira] [Updated] (FLINK-4859) Clearly Separate Responsibilities of StreamOperator and StreamTask - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/02 14:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5230) Safety nets against leaving dysfunctional JobManagers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:09:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4492) Cleanup files from canceled snapshots - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/02 14:09:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5231) JobManager should exit on "OutOfMemoryError" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:12:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5229) Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/02 14:12:59 UTC, 6 replies.
- [jira] [Closed] (FLINK-5228) LocalInputChannel re-trigger request and release deadlock - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5233) Upgrade Jackson version because of class loader leak - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/02 14:20:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4540) Detached job execution may prevent cluster shutdown - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:24:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-4636) AbstractCEPPatternOperator fails to restore state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:25:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:25:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4460) Side Outputs in Flink - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:25:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:25:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery. - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:26:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-4829) Accumulators are not thread safe - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:26:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5090) Expose optionally detailed metrics about network queue lengths - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:27:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5102) Connection establishment does not react to interrupt - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:27:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5115) Minimum time between checkpoints computed from trigger timestamp - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:28:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5172) In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:29:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5172) In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:29:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5205) Asynchronous remove job messages can interfere with recovered or resubmitted jobs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:30:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4904) Add a limit for how much data may be spilled in checkpoint alignments - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:33:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:35:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 14:35:58 UTC, 0 replies.
- [GitHub] flink pull request #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG li... - posted by uce <gi...@git.apache.org> on 2016/12/02 14:37:54 UTC, 3 replies.
- [jira] [Created] (FLINK-5234) Inform user about classpath configuration - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/02 14:37:58 UTC, 0 replies.
- [GitHub] flink pull request #2924: [FLINK-5229] [tm] Discard completed checkpoints if... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/02 14:39:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics - posted by "Jared Stehler (JIRA)" <ji...@apache.org> on 2016/12/02 14:53:58 UTC, 2 replies.
- [jira] [Assigned] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:55:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5234) Inform user about classpath configuration - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:55:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:56:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5226) Eagerly project unused attributes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 14:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5235) HBase classpath automatically added to Flink classpath - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/02 15:04:58 UTC, 0 replies.
- [GitHub] flink pull request #2925: [FLINK-4574] [kinesis]Strengthen fetch interval im... - posted by tony810430 <gi...@git.apache.org> on 2016/12/02 15:10:21 UTC, 0 replies.
- [jira] [Created] (FLINK-5236) User jar classpath should come first in classpath - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/02 15:10:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 15:10:58 UTC, 4 replies.
- [GitHub] flink pull request #2893: [FLINK-5128]Get Kafka partitions in FlinkKafkaProd... - posted by asfgit <gi...@git.apache.org> on 2016/12/02 15:13:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/12/02 15:15:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5237) Consolidate and harmonize Window Translation Tests - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/02 15:39:58 UTC, 0 replies.
- [GitHub] flink pull request #2216: [FLINK-4173] Use shade-plugin in flink-metrics - posted by zentol <gi...@git.apache.org> on 2016/12/02 15:44:15 UTC, 0 replies.
- [jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 15:44:58 UTC, 0 replies.
- [GitHub] flink pull request #2902: [FLINK-5209] [webfrontend] Fix TaskManager metrics - posted by asfgit <gi...@git.apache.org> on 2016/12/02 15:47:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/12/02 15:49:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5209) Fix TaskManager metrics - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/02 15:50:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4836) Implement Mini Cluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 16:02:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4836) Implement Mini Cluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 16:02:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5238) Flip-6 mini cluster should start local TaskManagers if there is only one TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 16:06:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4959) Write Documentation for ProcessFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/02 16:09:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4547) when call connect method in AkkaRpcService using same address and same rpc gateway class, the returned gateways are equal with respect to equals and hashCode - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 16:29:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5239) Properly unpack thrown exceptions in RPC methods - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 16:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/02 17:09:59 UTC, 0 replies.
- [GitHub] flink pull request #2926: [FLINK-5226] [table] Use correct DataSetCostFactor... - posted by fhueske <gi...@git.apache.org> on 2016/12/02 17:11:34 UTC, 3 replies.
- [jira] [Created] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/02 17:30:59 UTC, 0 replies.
- [GitHub] flink issue #2924: [FLINK-5229] [tm] Discard completed checkpoints if a subs... - posted by uce <gi...@git.apache.org> on 2016/12/02 17:53:51 UTC, 1 replies.
- [GitHub] flink pull request #1963: [FLINK-3870][docs] Added IntelliJ code style - posted by dawidwys <gi...@git.apache.org> on 2016/12/02 17:54:37 UTC, 0 replies.
- [jira] [Commented] (FLINK-3870) Add IntelliJ code style file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 17:54:58 UTC, 0 replies.
- [GitHub] flink issue #2903: [FLINK-5074] [runtime] add a zookeeper based running job ... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/02 18:08:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-5074) Implement a RunningJobRegistry based on Zookeeper - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 18:08:58 UTC, 2 replies.
- [GitHub] flink issue #2808: [FLINK-4927] [yarn]Implement FLI-6 YARN Resource Manager - posted by StephanEwen <gi...@git.apache.org> on 2016/12/02 18:14:26 UTC, 1 replies.
- [jira] [Commented] (FLINK-4927) Implement FLI-6 YARN Resource Manager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/02 18:14:58 UTC, 5 replies.
- [jira] [Commented] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 18:19:58 UTC, 5 replies.
- [GitHub] flink pull request #2927: [docs] Replace broken link. - posted by mindprince <gi...@git.apache.org> on 2016/12/02 23:02:19 UTC, 1 replies.
- [jira] [Closed] (FLINK-5220) Flink SQL projection pushdown - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/12/03 00:44:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4460) Side Outputs in Flink - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2016/12/03 02:08:58 UTC, 4 replies.
- [GitHub] flink issue #2927: [docs] Replace broken link. - posted by mindprince <gi...@git.apache.org> on 2016/12/03 04:22:58 UTC, 1 replies.
- [jira] [Closed] (FLINK-5146) Improved resource cleanup in RocksDB keyed state backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/03 07:58:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5173) Upgrade RocksDB dependency - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/03 07:58:58 UTC, 0 replies.
- [GitHub] flink issue #2857: [FLINK-5146] Improved resource cleanup in RocksDB keyed s... - posted by aljoscha <gi...@git.apache.org> on 2016/12/03 07:59:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-5146) Improved resource cleanup in RocksDB keyed state backend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/03 07:59:58 UTC, 2 replies.
- [GitHub] flink pull request #2857: [FLINK-5146] Improved resource cleanup in RocksDB ... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/03 09:29:19 UTC, 0 replies.
- [GitHub] flink issue #2898: [FLINK-5109] fix invalid content-encoding header of webmo... - posted by Hapcy <gi...@git.apache.org> on 2016/12/03 10:45:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-5109) Invalid Content-Encoding Header in REST API responses - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/03 10:45:58 UTC, 2 replies.
- [GitHub] flink pull request #2928: [FLINK-5108] Remove ClientShutdownHook during job ... - posted by Renkai <gi...@git.apache.org> on 2016/12/03 15:40:10 UTC, 1 replies.
- [jira] [Created] (FLINK-5242) Implement Scala API for BipartiteGraph - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/03 16:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5243) Implement an example for BipartiteGraph - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/03 16:20:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5244) Implement methods for BipartiteGraph transformations - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/03 16:25:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5245) Add support for BipartiteGraph mutations - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/03 16:27:58 UTC, 0 replies.
- [GitHub] flink pull request #2898: [FLINK-5109] fix invalid content-encoding header o... - posted by asfgit <gi...@git.apache.org> on 2016/12/03 17:20:16 UTC, 0 replies.
- [jira] [Updated] (FLINK-5109) Invalid Content-Encoding Header in REST API responses - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/03 17:30:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5109) Invalid Content-Encoding Header in REST API responses - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/03 17:31:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5246) Don't discard unknown checkpoint messages in the CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/03 19:20:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5247) Setting allowedLateness to a non-zero value should throw exception for processing-time windows - posted by "Rohit Agarwal (JIRA)" <ji...@apache.org> on 2016/12/03 20:13:58 UTC, 0 replies.
- [GitHub] flink pull request #2929: [FLINK-5247] Fix check to make sure that we throw ... - posted by mindprince <gi...@git.apache.org> on 2016/12/03 20:17:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-5247) Setting allowedLateness to a non-zero value should throw exception for processing-time windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/03 20:17:58 UTC, 9 replies.
- [GitHub] flink issue #2929: [FLINK-5247] Fix check to make sure that we throw error w... - posted by mindprince <gi...@git.apache.org> on 2016/12/03 20:19:50 UTC, 0 replies.
- [GitHub] flink pull request #2930: [FLINK-5246] Don't discard checkpoint messages if ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/03 20:32:24 UTC, 4 replies.
- [jira] [Commented] (FLINK-5246) Don't discard unknown checkpoint messages in the CheckpointCoordinator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/03 20:32:58 UTC, 5 replies.
- [jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken - posted by "Dave Torok (JIRA)" <ji...@apache.org> on 2016/12/03 21:05:58 UTC, 10 replies.
- [GitHub] flink issue #2930: [FLINK-5246] Don't discard checkpoint messages if they ar... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/04 11:38:12 UTC, 0 replies.
- [GitHub] flink pull request #2729: [FLINK-4883]Prevent UDFs implementations through S... - posted by Renkai <gi...@git.apache.org> on 2016/12/04 11:41:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/04 11:41:58 UTC, 11 replies.
- [jira] [Created] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/04 11:58:58 UTC, 0 replies.
- [GitHub] flink issue #2806: [FLINK-5066] Prevent LocalInputChannel#getNextBuffer from... - posted by uce <gi...@git.apache.org> on 2016/12/04 12:52:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-5066) prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/04 12:52:58 UTC, 1 replies.
- [GitHub] flink pull request #2805: [FLINK-5059] only serialise events once in RecordW... - posted by uce <gi...@git.apache.org> on 2016/12/04 14:03:45 UTC, 5 replies.
- [jira] [Commented] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/04 14:03:58 UTC, 6 replies.
- [GitHub] flink issue #2829: [hotfix] prevent RecordWriter#flush() to clear the serial... - posted by uce <gi...@git.apache.org> on 2016/12/04 14:15:48 UTC, 2 replies.
- [jira] [Created] (FLINK-5249) description of datastream rescaling doesn't match the figure - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/04 14:42:59 UTC, 0 replies.
- [GitHub] flink pull request #2931: In the example of rescaling, updated the descripti... - posted by alpinegizmo <gi...@git.apache.org> on 2016/12/04 14:43:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-2844) Remove old web interface and default to the new one - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/04 14:48:58 UTC, 0 replies.
- [GitHub] flink pull request #2932: [FLINK-5249] [docs] description of datastream resc... - posted by alpinegizmo <gi...@git.apache.org> on 2016/12/04 15:03:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-5249) description of datastream rescaling doesn't match the figure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/04 15:03:59 UTC, 3 replies.
- [GitHub] flink pull request #2933: [FLINK-5016] [checkpointing] Split EventTimeWindow... - posted by uce <gi...@git.apache.org> on 2016/12/04 15:07:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-5016) EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/04 15:07:58 UTC, 4 replies.
- [GitHub] flink issue #2786: [FLINK-5016] [ci] Increase no output timeout to 10 mins - posted by uce <gi...@git.apache.org> on 2016/12/04 15:08:17 UTC, 0 replies.
- [GitHub] flink pull request #2786: [FLINK-5016] [ci] Increase no output timeout to 10... - posted by uce <gi...@git.apache.org> on 2016/12/04 15:08:31 UTC, 0 replies.
- [GitHub] flink issue #2761: [FLINK-3551] [examples] Sync Scala Streaiming Examples - posted by ch33hau <gi...@git.apache.org> on 2016/12/04 15:49:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/04 15:49:58 UTC, 8 replies.
- [GitHub] flink issue #2933: [FLINK-5016] [checkpointing] Split EventTimeWindowCheckpo... - posted by uce <gi...@git.apache.org> on 2016/12/04 17:48:46 UTC, 0 replies.
- [jira] [Created] (FLINK-5250) Make AbstractUdfStreamOperator aware of WrappingFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/05 00:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5251) Decouple StreamTableSourceScan with TableSourceTable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/05 01:15:58 UTC, 0 replies.
- [GitHub] flink pull request #2934: [FLINK-5251] [Table] Decouple StreamTableSourceSca... - posted by KurtYoung <gi...@git.apache.org> on 2016/12/05 01:47:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-5251) Decouple StreamTableSourceScan with TableSourceTable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 01:47:59 UTC, 3 replies.
- [jira] [Created] (FLINK-5252) Migrate all YARN related configurations to ConfigOptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/05 01:55:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5253) Remove special treatment of "dynamic properties" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/05 01:59:58 UTC, 0 replies.
- [GitHub] flink issue #2744: [FLINK-4928] [yarn] Implement FLIP-6 YARN Application Mas... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/05 02:07:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5254) Implement Yarn HA Services - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/05 02:07:58 UTC, 0 replies.
- [GitHub] flink issue #2878: [FLINK-4929] [yarn] Implement FLIP-6 YARN TaskExecutor Ru... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/05 02:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4929) Implement FLIP-6 YARN TaskManager Runner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 02:08:58 UTC, 1 replies.
- [GitHub] flink pull request #2808: [FLINK-4927] [yarn]Implement FLI-6 YARN Resource M... - posted by shuai-xu <gi...@git.apache.org> on 2016/12/05 04:04:22 UTC, 0 replies.
- [GitHub] flink pull request #2905: [FLINK-5190] [runtime] fix ZooKeeperLeaderRetrieva... - posted by shuai-xu <gi...@git.apache.org> on 2016/12/05 04:05:02 UTC, 0 replies.
- [GitHub] flink pull request #2878: [FLINK-4929] [yarn] Implement FLIP-6 YARN TaskExec... - posted by shuai-xu <gi...@git.apache.org> on 2016/12/05 04:05:14 UTC, 0 replies.
- [GitHub] flink pull request #2935: [FLINK-4930] [client, yarn] Implement FLIP-6 YARN ... - posted by shuai-xu <gi...@git.apache.org> on 2016/12/05 06:41:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-4930) Implement FLIP-6 YARN client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 06:41:58 UTC, 0 replies.
- [GitHub] flink pull request #2936: [FLINK-4927] [yarn] refine YARN Resource manager a... - posted by shuai-xu <gi...@git.apache.org> on 2016/12/05 07:56:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-4704) Move Table API to org.apache.flink.table - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 07:59:58 UTC, 11 replies.
- [jira] [Updated] (FLINK-4704) Move Table API to org.apache.flink.table - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 08:01:11 UTC, 2 replies.
- [jira] [Commented] (FLINK-5186) Move Row and RowTypeInfo into Flink core - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 08:01:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-5186) Move Row and RowTypeInfo into Flink core - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 08:01:58 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-5186) Move Row and RowTypeInfo into Flink core - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 08:04:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4704) Move Table API to org.apache.flink.table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/05 08:11:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 08:15:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 08:17:58 UTC, 13 replies.
- [jira] [Created] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 08:22:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 08:23:58 UTC, 16 replies.
- [jira] [Commented] (FLINK-4300) Improve error message for different Scala versions of JM and Client - posted by "Sergio Fernández (JIRA)" <ji...@apache.org> on 2016/12/05 09:17:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5188) Adjust all the imports referencing Row and RowTypeInfo - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/05 09:24:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5188) Adjust all the imports referencing Row - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/05 09:25:58 UTC, 0 replies.
- [GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/05 09:30:08 UTC, 5 replies.
- [jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 09:30:58 UTC, 10 replies.
- [jira] [Created] (FLINK-5257) Display optimized logical plan when explaining table - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/05 09:39:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5251) Decouple StreamTableSourceScan with TableSourceTable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/05 09:41:58 UTC, 0 replies.
- [GitHub] flink pull request #2937: [FLINK-4303] Examples for CEP library. - posted by chermenin <gi...@git.apache.org> on 2016/12/05 09:51:10 UTC, 0 replies.
- [GitHub] flink pull request #2938: [FLINK-4692] [tableApi] Add tumbling group-windows... - posted by wuchong <gi...@git.apache.org> on 2016/12/05 09:51:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 09:51:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5258) reorganize the docs to improve navigation and reduce duplication - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/05 09:57:58 UTC, 0 replies.
- [GitHub] flink pull request #2939: [FLINK-5113] Ports all functions in the tests to t... - posted by kl0u <gi...@git.apache.org> on 2016/12/05 10:03:08 UTC, 16 replies.
- [jira] [Commented] (FLINK-5113) Make all Testing Functions implement CheckpointedFunction Interface. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 10:03:58 UTC, 22 replies.
- [jira] [Assigned] (FLINK-3320) Add not operator to CEP's pattern API - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/12/05 10:08:58 UTC, 0 replies.
- [GitHub] flink pull request #2940: [FLINK-5258] [docs] reorganize the docs to improve... - posted by alpinegizmo <gi...@git.apache.org> on 2016/12/05 10:19:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-5258) reorganize the docs to improve navigation and reduce duplication - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 10:19:59 UTC, 7 replies.
- [GitHub] flink pull request #2941: [FLINK-3555] Web interface does not render job inf... - posted by bitchelov <gi...@git.apache.org> on 2016/12/05 10:29:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-3555) Web interface does not render job information properly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 10:29:58 UTC, 2 replies.
- [GitHub] flink pull request #2942: [FLINK-4693][tableApi] Add session group-windows f... - posted by sunjincheng121 <gi...@git.apache.org> on 2016/12/05 10:36:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-4693) Add session group-windows for batch tables - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 10:36:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5259) wrong execution environment in retry delays example - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/05 10:38:59 UTC, 0 replies.
- [GitHub] flink issue #2928: [FLINK-5108] Remove ClientShutdownHook during job executi... - posted by mxm <gi...@git.apache.org> on 2016/12/05 10:39:53 UTC, 7 replies.
- [GitHub] flink pull request #2943: [FLINK-5259] [docs] wrong execution environment in... - posted by alpinegizmo <gi...@git.apache.org> on 2016/12/05 10:42:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-5259) wrong execution environment in retry delays example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 10:42:59 UTC, 3 replies.
- [jira] [Closed] (FLINK-5246) Don't discard unknown checkpoint messages in the CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/05 10:56:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5233) Upgrade Jackson version because of class loader leak - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 10:59:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 11:01:03 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule - posted by "Alexander Shoshin (JIRA)" <ji...@apache.org> on 2016/12/05 11:12:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins - posted by "Alexander Shoshin (JIRA)" <ji...@apache.org> on 2016/12/05 11:30:59 UTC, 1 replies.
- [jira] [Created] (FLINK-5260) Add docs about how to react to cancellation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 11:39:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/05 12:44:59 UTC, 0 replies.
- [GitHub] flink pull request #2944: [FLINK-5261] Clean up meters in ScheduledDropwizar... - posted by zentol <gi...@git.apache.org> on 2016/12/05 13:08:36 UTC, 4 replies.
- [jira] [Commented] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 13:08:58 UTC, 6 replies.
- [jira] [Updated] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/05 13:28:58 UTC, 1 replies.
- [jira] [Reopened] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 13:29:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 13:29:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 13:29:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5262) Docs: Introduce a Gemfile.lock to avoid dependency range conflicts - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/05 13:48:58 UTC, 0 replies.
- [GitHub] flink issue #2729: [FLINK-4883]Prevent UDFs implementations through Scala si... - posted by Renkai <gi...@git.apache.org> on 2016/12/05 13:49:48 UTC, 9 replies.
- [GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a... - posted by liuyuzhong <gi...@git.apache.org> on 2016/12/05 13:49:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-4450) update storm version to 1.0.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 13:49:58 UTC, 2 replies.
- [jira] [Updated] (FLINK-5262) Docs: Introduce a Gemfile.lock to avoid dependency range conflicts - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/05 13:50:58 UTC, 0 replies.
- [GitHub] flink pull request #2945: [FLINK-5262][docs] Introduce Gemfile.lock to avoid... - posted by mxm <gi...@git.apache.org> on 2016/12/05 13:54:51 UTC, 1 replies.
- [jira] [Commented] (FLINK-5262) Docs: Introduce a Gemfile.lock to avoid dependency range conflicts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 13:54:58 UTC, 2 replies.
- [GitHub] flink issue #2945: [FLINK-5262][docs] Introduce Gemfile.lock to avoid depend... - posted by mxm <gi...@git.apache.org> on 2016/12/05 13:58:19 UTC, 0 replies.
- [GitHub] flink issue #2944: [FLINK-5261] Clean up meters in ScheduledDropwizardReport... - posted by zentol <gi...@git.apache.org> on 2016/12/05 14:10:09 UTC, 1 replies.
- [jira] [Updated] (FLINK-5179) MetricRegistry life-cycle issues with HA - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/05 14:14:58 UTC, 1 replies.
- [GitHub] flink pull request #2946: [FLINK-5157] [streaming] Extend AllWindow function... - posted by VenturaDelMonte <gi...@git.apache.org> on 2016/12/05 14:24:00 UTC, 0 replies.
- [GitHub] flink pull request #2947: [hotfix] [metris] [docs] Correct scope format keys - posted by zentol <gi...@git.apache.org> on 2016/12/05 14:24:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-5157) Extending AllWindow Function Metadata - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 14:24:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5263) Add docs about JVM sharing between tasks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 14:26:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5039) Avro GenericRecord support is broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/05 14:45:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-5264) Improve error message when assigning uid to intermediate operator. - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 14:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5264) Improve error message when assigning uid to intermediate operator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/05 14:45:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5264) Improve error message when assigning uid to intermediate operator. - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 14:46:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5264) Improve error message when assigning uid to intermediate operator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 14:46:58 UTC, 1 replies.
- [GitHub] flink issue #2934: [FLINK-5251] [Table] Decouple StreamTableSourceScan with ... - posted by fhueske <gi...@git.apache.org> on 2016/12/05 14:47:56 UTC, 1 replies.
- [GitHub] flink issue #2932: [FLINK-5249] [docs] description of datastream rescaling d... - posted by fhueske <gi...@git.apache.org> on 2016/12/05 14:52:11 UTC, 1 replies.
- [GitHub] flink issue #2943: [FLINK-5259] [docs] wrong execution environment in batch ... - posted by fhueske <gi...@git.apache.org> on 2016/12/05 14:56:04 UTC, 1 replies.
- [jira] [Updated] (FLINK-4469) Add support for user defined table function in Table API & SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/05 17:01:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5262) Docs: Introduce a Gemfile.lock to avoid dependency range conflicts - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/05 17:14:58 UTC, 0 replies.
- [GitHub] flink pull request #2861: [FLINK-5122] Index requests will be retried if the... - posted by rmetzger <gi...@git.apache.org> on 2016/12/05 17:47:23 UTC, 12 replies.
- [GitHub] flink issue #2940: [FLINK-5258] [docs] reorganize the docs to improve naviga... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/05 17:54:22 UTC, 3 replies.
- [GitHub] flink issue #2913: [backport] [FLINK-5114] [network] Handle partition produc... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/05 17:59:09 UTC, 3 replies.
- [jira] [Commented] (FLINK-5114) PartitionState update with finished execution fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 18:00:00 UTC, 12 replies.
- [GitHub] flink issue #2915: [FLINK-5091] Formalize the Mesos AppMaster environment fo... - posted by mxm <gi...@git.apache.org> on 2016/12/05 18:55:52 UTC, 0 replies.
- [GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class - posted by greghogan <gi...@git.apache.org> on 2016/12/05 19:40:22 UTC, 25 replies.
- [jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 19:41:00 UTC, 35 replies.
- [jira] [Created] (FLINK-5265) Introduce state handle replication mode for CheckpointCoordinator - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/05 20:10:58 UTC, 0 replies.
- [GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class - posted by mushketyk <gi...@git.apache.org> on 2016/12/05 20:11:02 UTC, 9 replies.
- [GitHub] flink pull request #2901: [FLINK-3921] StringParser encoding - posted by fhueske <gi...@git.apache.org> on 2016/12/05 20:11:39 UTC, 4 replies.
- [jira] [Assigned] (FLINK-5265) Introduce state handle replication mode for CheckpointCoordinator - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/05 20:14:58 UTC, 0 replies.
- [GitHub] flink pull request #2948: [FLINK-5265] Introduce state handle replication mo... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/05 20:15:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-5265) Introduce state handle replication mode for CheckpointCoordinator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/05 20:15:59 UTC, 1 replies.
- [GitHub] flink issue #2948: [FLINK-5265] Introduce state handle replication mode for ... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/05 20:44:44 UTC, 0 replies.
- [GitHub] flink pull request #2949: [FLINK-5257] [table] display optimized logical pla... - posted by KurtYoung <gi...@git.apache.org> on 2016/12/06 01:24:41 UTC, 4 replies.
- [jira] [Commented] (FLINK-5257) Display optimized logical plan when explaining table - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/06 01:24:59 UTC, 6 replies.
- [jira] [Commented] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/06 01:27:58 UTC, 4 replies.
- [jira] [Created] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/06 01:39:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/06 01:40:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4930) Implement FLIP-6 YARN client - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/12/06 03:05:58 UTC, 0 replies.
- [GitHub] flink issue #2653: [FLINK-4469] [table] Add support for user defined table f... - posted by wuchong <gi...@git.apache.org> on 2016/12/06 03:19:47 UTC, 3 replies.
- [jira] [Commented] (FLINK-5221) Checkpointed workless in Window Operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/06 04:18:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/06 07:38:58 UTC, 19 replies.
- [GitHub] flink issue #2949: [FLINK-5257] [table] display optimized logical plan when ... - posted by fhueske <gi...@git.apache.org> on 2016/12/06 08:48:37 UTC, 1 replies.
- [GitHub] flink pull request #2950: [hotfix] Check for null in OperatorSnapshotResult#... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/06 09:10:20 UTC, 1 replies.
- [GitHub] flink issue #2950: [hotfix] Check for null in OperatorSnapshotResult#cancel - posted by rmetzger <gi...@git.apache.org> on 2016/12/06 09:25:47 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/06 11:10:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-5252) Migrate all YARN related configurations to ConfigOptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/06 11:11:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-5239) Properly unpack thrown exceptions in RPC methods - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/06 11:11:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-5238) Flip-6 mini cluster should start local TaskManagers if there is only one TaskManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/06 11:11:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-5254) Implement Yarn HA Services - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/06 11:11:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-5253) Remove special treatment of "dynamic properties" - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/06 11:11:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/06 11:11:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-5141) Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/06 11:11:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/06 11:11:33 UTC, 0 replies.
- [jira] [Closed] (FLINK-4492) Cleanup files from canceled snapshots - posted by "Nikolay Vasilishin (JIRA)" <ji...@apache.org> on 2016/12/06 11:11:35 UTC, 0 replies.
- [GitHub] flink issue #2912: [FLINK-5114] [network] Handle partition producer state ch... - posted by uce <gi...@git.apache.org> on 2016/12/06 11:37:06 UTC, 2 replies.
- [GitHub] flink issue #2947: [hotfix] [metris] [docs] Correct scope format keys - posted by uce <gi...@git.apache.org> on 2016/12/06 12:29:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-5249) description of datastream rescaling doesn't match the figure - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/06 13:01:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5257) Display optimized logical plan when explaining table - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/06 13:01:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5251) Decouple StreamTableSourceScan with TableSourceTable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/06 13:01:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5259) wrong execution environment in retry delays example - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/06 13:02:58 UTC, 0 replies.
- [GitHub] flink pull request #2951: [docs] clarify default restart behavior when check... - posted by mxm <gi...@git.apache.org> on 2016/12/06 14:11:39 UTC, 1 replies.
- [GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/06 14:31:08 UTC, 25 replies.
- [jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/06 14:31:59 UTC, 31 replies.
- [GitHub] flink pull request #2952: [FLINK-5011] [types] TraversableSerializer does no... - posted by twalthr <gi...@git.apache.org> on 2016/12/06 14:41:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-4982) quickstart example: Can't see the output - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/12/06 14:47:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/06 14:48:59 UTC, 4 replies.
- [jira] [Closed] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/06 14:49:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5179) MetricRegistry life-cycle issues with HA - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/06 14:50:58 UTC, 0 replies.
- [GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ... - posted by fhueske <gi...@git.apache.org> on 2016/12/06 15:11:23 UTC, 18 replies.
- [jira] [Assigned] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/12/06 15:12:00 UTC, 0 replies.
- [GitHub] flink issue #2865: [FLINK-5002] Renamed getNumberOfUsedBuffers() method to b... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/06 15:24:24 UTC, 2 replies.
- [GitHub] flink issue #2923: [FLINK-5220] [Table API & SQL] Flink SQL projection pushd... - posted by fhueske <gi...@git.apache.org> on 2016/12/06 15:33:46 UTC, 5 replies.
- [GitHub] flink pull request #2737: [FLINK-4983] Web UI: Add favicon - posted by asfgit <gi...@git.apache.org> on 2016/12/06 15:50:51 UTC, 0 replies.
- [jira] [Updated] (FLINK-4983) Web UI: Add favicon - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/06 15:50:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4983) Web UI: Add favicon - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/06 15:50:58 UTC, 1 replies.
- [jira] [Closed] (FLINK-4983) Web UI: Add favicon - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/06 15:53:58 UTC, 0 replies.
- [GitHub] flink issue #2750: [FLINK-5007] [checkpointing] Retain externalized checkpoi... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/06 16:00:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-5007) Retain externalized checkpoint on suspension - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/06 16:01:00 UTC, 3 replies.
- [GitHub] flink pull request #2761: [FLINK-3551] [examples] Sync Scala Streaiming Exam... - posted by thvasilo <gi...@git.apache.org> on 2016/12/06 16:51:01 UTC, 3 replies.
- [jira] [Assigned] (FLINK-5052) Changing the maximum parallelism (number of key groups) of a job - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/06 16:53:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5051) Backwards compatibility for serializers in backend state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/06 16:54:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5052) Changing the maximum parallelism (number of key groups) of a job - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/06 16:54:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5091) Formalize the AppMaster environment for docker compability - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/06 17:57:58 UTC, 0 replies.
- [GitHub] flink issue #2832: [FLINK-4936] [gelly] Operator names for Gelly inputs - posted by greghogan <gi...@git.apache.org> on 2016/12/06 18:43:05 UTC, 2 replies.
- [jira] [Commented] (FLINK-4936) Operator names for Gelly inputs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/06 18:43:58 UTC, 3 replies.
- [GitHub] flink issue #2951: [docs] clarify default restart behavior when checkpointin... - posted by mindprince <gi...@git.apache.org> on 2016/12/06 18:50:38 UTC, 2 replies.
- [jira] [Created] (FLINK-5267) TaskManager logs not scrollable - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/12/06 19:22:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5035) Don't Write TypeSerializer to Heap State Snapshot - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/06 19:53:59 UTC, 2 replies.
- [GitHub] flink pull request #2953: [FLINK-5039] Bump Avro version - posted by rmetzger <gi...@git.apache.org> on 2016/12/06 20:04:46 UTC, 1 replies.
- [GitHub] flink pull request #2954: [docs] Note that numberOfExecutionRetries and exec... - posted by mindprince <gi...@git.apache.org> on 2016/12/06 20:23:28 UTC, 3 replies.
- [GitHub] flink issue #2737: [FLINK-4983] Web UI: Add favicon - posted by rmetzger <gi...@git.apache.org> on 2016/12/06 20:23:55 UTC, 0 replies.
- [GitHub] flink issue #2954: [docs] Note that numberOfExecutionRetries and executionRe... - posted by mindprince <gi...@git.apache.org> on 2016/12/06 20:24:46 UTC, 2 replies.
- [jira] [Commented] (FLINK-5253) Remove special treatment of "dynamic properties" - posted by "Mariusz Wojakowski (JIRA)" <ji...@apache.org> on 2016/12/07 00:25:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-1102) Projection operator for streaming - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/07 05:34:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/12/07 08:57:58 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/12/07 08:58:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/12/07 09:01:16 UTC, 1 replies.
- [GitHub] flink issue #2781: [FLINK-5041] Savepoint backwards compatibility 1.1 -> 1.2 - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/07 09:19:29 UTC, 2 replies.
- [jira] [Created] (FLINK-5268) Split TableProgramsTestBase into TableProgramsCollectionTestBase and TableProgramsClusterTestBase - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:25:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3656) Rework Table API tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5269) Convert string-based Table API tests into unit tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:33:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5270) Refactor the batch Scala-expression Table API tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5271) Refactor the batch SQL tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:46:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5272) Refactor the stream Scala-expression Table API tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:51:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5271) Refactor the batch SQL tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:54:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5273) Refactor stream SQL tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:54:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API - posted by "Nikolay Vasilishin (JIRA)" <ji...@apache.org> on 2016/12/07 11:37:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 12:05:58 UTC, 4 replies.
- [jira] [Created] (FLINK-5274) LocalInputChannel throws NPE if partition reader is released - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 12:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5275) InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 12:18:58 UTC, 0 replies.
- [GitHub] flink pull request #2955: [backport] Improve some follow up exceptions - posted by uce <gi...@git.apache.org> on 2016/12/07 12:55:28 UTC, 1 replies.
- [jira] [Created] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 13:01:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5042) Convert old savepoints to new savepoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 13:07:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5043) Converting keyed state from Flink 1.1 backend implementations to their new counterparts in 1.2 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 13:07:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 13:20:58 UTC, 1 replies.
- [GitHub] flink pull request #2956: [FLINK-5223] [doc] Add documentation of UDTF in Ta... - posted by wuchong <gi...@git.apache.org> on 2016/12/07 13:23:37 UTC, 1 replies.
- [jira] [Commented] (FLINK-5223) Add documentation of UDTF in Table API & SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/07 13:23:58 UTC, 3 replies.
- [jira] [Assigned] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 13:23:58 UTC, 0 replies.
- [GitHub] flink pull request #2957: [FLINK-5276] [eg] Check for null when archiving pr... - posted by uce <gi...@git.apache.org> on 2016/12/07 13:28:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/07 13:28:58 UTC, 2 replies.
- [GitHub] flink issue #2957: [FLINK-5276] [eg] Check for null when archiving prior exe... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/07 13:29:19 UTC, 0 replies.
- [GitHub] flink pull request #2958: [FLINK-4704] Move Table API to org.apache.flink.ta... - posted by ex00 <gi...@git.apache.org> on 2016/12/07 13:29:28 UTC, 1 replies.
- [jira] [Created] (FLINK-5277) missing unit test for ensuring ResultPartition#add always recycles buffers - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/07 14:40:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5277) missing unit test for ensuring ResultPartition#add always recycles buffers - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/07 14:41:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5278) Improve Task and checkpoint logging - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/07 15:22:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 16:06:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5275) InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 16:18:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5274) LocalInputChannel throws NPE if partition reader is released - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 16:18:59 UTC, 0 replies.
- [GitHub] flink pull request #2959: [FLINK-5278] Improve task and checkpoint related l... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/07 16:20:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-5278) Improve Task and checkpoint logging - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/07 16:20:58 UTC, 8 replies.
- [GitHub] flink pull request #2960: [backport] [FLINK-5278] Improve task and checkpoin... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/07 16:21:17 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4469) Add support for user defined table function in Table API & SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/07 16:33:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5279) Improve error message when trying to access keyed state in non-keyed operator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 16:51:59 UTC, 0 replies.
- [GitHub] flink issue #2960: [backport] [FLINK-5278] Improve task and checkpoint relat... - posted by uce <gi...@git.apache.org> on 2016/12/07 17:06:42 UTC, 1 replies.
- [jira] [Created] (FLINK-5280) Extend TableSource to support nested data - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 17:40:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5281) Extend KafkaJsonTableSources to support nested data - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 17:46:58 UTC, 0 replies.
- [GitHub] flink issue #2919: [FLINK-4554] [table] Add support for array types - posted by twalthr <gi...@git.apache.org> on 2016/12/07 17:54:04 UTC, 2 replies.
- [jira] [Updated] (FLINK-3871) Add Kafka TableSource with Avro serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 17:58:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4554) Add support for array types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/07 18:01:07 UTC, 0 replies.
- [jira] [Created] (FLINK-5283) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/07 18:53:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/07 18:53:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5283) InputStream should be closed in RocksDBKeyedStateBackend#restoreOldSavepointKeyedState - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/07 18:55:59 UTC, 4 replies.
- [jira] [Assigned] (FLINK-5283) InputStream should be closed in RocksDBKeyedStateBackend#restoreOldSavepointKeyedState - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/07 18:59:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/12/07 23:30:58 UTC, 0 replies.
- [GitHub] flink issue #2926: [FLINK-5226] [table] Use correct DataSetCostFactory and i... - posted by KurtYoung <gi...@git.apache.org> on 2016/12/08 01:25:57 UTC, 3 replies.
- [GitHub] flink pull request #2961: [FLINK-5266] [table] eagerly project unused fields... - posted by KurtYoung <gi...@git.apache.org> on 2016/12/08 02:47:57 UTC, 8 replies.
- [GitHub] flink issue #2756: [FLINK-4997] Extending Window Function Metadata - posted by manuzhang <gi...@git.apache.org> on 2016/12/08 05:14:29 UTC, 5 replies.
- [jira] [Commented] (FLINK-4997) Extending Window Function Metadata - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 05:14:58 UTC, 5 replies.
- [jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/08 08:30:58 UTC, 6 replies.
- [GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con... - posted by tzulitai <gi...@git.apache.org> on 2016/12/08 09:09:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 09:09:59 UTC, 1 replies.
- [jira] [Assigned] (FLINK-5187) Create analog of Row in core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/08 09:37:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-5187) Create analog of Row in core - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/08 09:42:58 UTC, 46 replies.
- [jira] [Created] (FLINK-5284) Make output of bucketing sink compatible with other processing framework like mapreduce - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/12/08 10:01:09 UTC, 0 replies.
- [jira] [Created] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/08 10:14:58 UTC, 0 replies.
- [GitHub] flink pull request #2962: [FLINK-5051] Backwards compatibility for serialize... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/08 10:30:16 UTC, 5 replies.
- [jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 10:30:58 UTC, 13 replies.
- [GitHub] flink issue #2863: [FLINK-5051] Backwards compatibility for serializers in b... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/08 10:31:01 UTC, 0 replies.
- [GitHub] flink pull request #2863: [FLINK-5051] Backwards compatibility for serialize... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/08 10:31:01 UTC, 0 replies.
- [GitHub] flink issue #2962: [FLINK-5051] Backwards compatibility for serializers in b... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/08 10:33:18 UTC, 4 replies.
- [jira] [Updated] (FLINK-5187) Create analog of Row in core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/08 10:33:58 UTC, 1 replies.
- [GitHub] flink pull request #2963: [FLINK-5285] Abort checkpoint only once in Barrier... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/08 10:34:56 UTC, 2 replies.
- [jira] [Commented] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 10:34:58 UTC, 9 replies.
- [jira] [Assigned] (FLINK-5254) Implement Yarn HA Services - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/08 10:34:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5187) Create analog of Row in core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/08 10:35:58 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2186) Rework CSV import to support very wide files - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/08 10:37:59 UTC, 0 replies.
- [GitHub] flink pull request #2964: [backport] [FLINK-5285] Abort checkpoint only once... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/08 10:39:20 UTC, 3 replies.
- [GitHub] flink issue #2953: [FLINK-5039] Bump Avro version - posted by rmetzger <gi...@git.apache.org> on 2016/12/08 11:06:31 UTC, 3 replies.
- [jira] [Created] (FLINK-5286) Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/08 11:15:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/08 11:16:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5286) Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/08 11:19:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-5191) ConnectedComponentsWithDeferredUpdateITCase failed - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/08 11:20:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5287) Test randomly fails with wrong result: testWithAtomic2[Execution mode = CLUSTER](org.apache.flink.api.scala.operators.JoinITCase) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/08 11:20:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5206) Flakey PythonPlanBinderTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/08 11:23:59 UTC, 2 replies.
- [jira] [Commented] (FLINK-5206) Flakey PythonPlanBinderTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/08 11:23:59 UTC, 4 replies.
- [jira] [Commented] (FLINK-4631) NullPointerException during stream task cleanup - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/08 11:23:59 UTC, 4 replies.
- [GitHub] flink issue #2759: [FLINK-5020] Make the GenericWriteAheadSink rescalable. - posted by zentol <gi...@git.apache.org> on 2016/12/08 11:24:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-5020) Make the GenericWriteAheadSink rescalable. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 11:24:58 UTC, 1 replies.
- [GitHub] flink pull request #2965: [FLINK-2980] [table] Support for SQL GROUPING SETS... - posted by chermenin <gi...@git.apache.org> on 2016/12/08 11:53:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 11:53:58 UTC, 2 replies.
- [jira] [Closed] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/08 12:55:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5164) Hadoop-compat IOFormat tests fail on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/08 12:55:58 UTC, 0 replies.
- [GitHub] flink pull request #2889: [FLINK-5164] Disable some Hadoop-compat tests on W... - posted by asfgit <gi...@git.apache.org> on 2016/12/08 12:56:13 UTC, 0 replies.
- [GitHub] flink pull request #2759: [FLINK-5020] Make the GenericWriteAheadSink rescal... - posted by asfgit <gi...@git.apache.org> on 2016/12/08 12:56:13 UTC, 0 replies.
- [GitHub] flink pull request #2650: [FLINK-4563] [metrics] scope caching not adjusted ... - posted by asfgit <gi...@git.apache.org> on 2016/12/08 12:56:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-5164) Hadoop-compat IOFormat tests fail on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 12:56:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 12:56:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5020) Make the GenericWriteAheadSink rescalable. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/08 12:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5288) Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/08 13:04:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/08 13:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5289) NPE when using value state on non-keyed stream - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/08 13:45:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/08 13:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/08 13:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5291) Ensure backwards compatibility of the hashes used to generate JobVertexIds - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/08 13:50:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5291) Ensure backwards compatibility of the hashes used to generate JobVertexIds - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/08 13:51:58 UTC, 0 replies.
- [GitHub] flink pull request #2966: [FLINK-5290] Ensure backwards compatibility of the... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/08 13:54:29 UTC, 8 replies.
- [jira] [Commented] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 13:54:59 UTC, 12 replies.
- [GitHub] flink issue #2966: [FLINK-5290] Ensure backwards compatibility of the hashes... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/08 13:56:18 UTC, 3 replies.
- [jira] [Updated] (FLINK-5066) add more efficient isEvent check to EventSerializer - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/08 13:56:58 UTC, 1 replies.
- [GitHub] flink pull request #2967: [FLINK-5169] Fix String.format() wildcards - posted by BorisOsipov <gi...@git.apache.org> on 2016/12/08 14:00:36 UTC, 1 replies.
- [jira] [Commented] (FLINK-5169) Make consumption of input channels fair - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 14:01:05 UTC, 2 replies.
- [jira] [Assigned] (FLINK-5289) NPE when using value state on non-keyed stream - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/08 14:08:58 UTC, 0 replies.
- [GitHub] flink issue #2967: [FLINK-5169] Fix String.format() wildcards - posted by uce <gi...@git.apache.org> on 2016/12/08 14:16:24 UTC, 0 replies.
- [GitHub] flink issue #2761: [FLINK-3551] [examples] Sync Scala Streaming Examples - posted by ch33hau <gi...@git.apache.org> on 2016/12/08 14:26:47 UTC, 3 replies.
- [GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy... - posted by wuchong <gi...@git.apache.org> on 2016/12/08 14:54:20 UTC, 35 replies.
- [GitHub] flink pull request #2969: [FLINK-5289] Meaningful exception when using value... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/08 16:07:21 UTC, 3 replies.
- [GitHub] flink issue #2969: [FLINK-5289] Meaningful exception when using value state ... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/08 16:07:29 UTC, 2 replies.
- [jira] [Commented] (FLINK-5289) NPE when using value state on non-keyed stream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 16:07:58 UTC, 6 replies.
- [jira] [Created] (FLINK-5292) Make the remaining operators backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/08 16:32:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5293) Make the Kafka consumer backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/08 16:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5294) Make the WindowOperator backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/08 16:36:58 UTC, 0 replies.
- [GitHub] flink issue #2968: [FLINK-5187] [core] Create analog of Row and RowTypeInfo ... - posted by twalthr <gi...@git.apache.org> on 2016/12/08 16:38:25 UTC, 8 replies.
- [jira] [Created] (FLINK-5295) Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/08 16:40:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/08 16:41:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/08 16:50:58 UTC, 0 replies.
- [GitHub] flink issue #2964: [backport] [FLINK-5285] Abort checkpoint only once in Bar... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/08 16:54:42 UTC, 1 replies.
- [jira] [Created] (FLINK-5298) Web UI crashes when TM log not existant - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/12/08 16:56:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5298) TaskManager crashes when TM log not existant - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/12/08 16:58:58 UTC, 4 replies.
- [jira] [Commented] (FLINK-5298) TaskManager crashes when TM log not existant - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/12/08 16:59:58 UTC, 5 replies.
- [jira] [Created] (FLINK-5299) DataStream support for arrays as keys - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/08 17:01:01 UTC, 0 replies.
- [GitHub] flink issue #2959: [FLINK-5278] Improve task and checkpoint related logging - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/08 17:03:23 UTC, 1 replies.
- [GitHub] flink issue #2909: [FLINK-5193] [jm] Harden job recovery in case of recovery... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/08 17:07:31 UTC, 1 replies.
- [GitHub] flink issue #2872: [FLINK-5158] [ckPtCoord] Handle exceptions from Completed... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/08 17:08:17 UTC, 1 replies.
- [jira] [Created] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/08 17:28:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/08 17:34:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5280) Extend TableSource to support nested data - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/08 17:45:59 UTC, 88 replies.
- [jira] [Created] (FLINK-5301) Can't upload job via Web UI when using a proxy - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/12/08 17:52:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/08 17:53:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/08 17:55:58 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-1536) Graph partitioning operators for Gelly - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/08 18:01:58 UTC, 1 replies.
- [GitHub] flink pull request #2970: [FLINK-5300] Add more gentle file deletion procedu... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/08 18:06:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 18:06:58 UTC, 15 replies.
- [jira] [Assigned] (FLINK-5298) TaskManager crashes when TM log not existant - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/08 18:06:59 UTC, 0 replies.
- [GitHub] flink pull request #2971: [backport] [FLINK-5300] Add more gentle file delet... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/08 18:08:23 UTC, 1 replies.
- [jira] [Closed] (FLINK-3902) Discarded FileSystem checkpoints are lingering around - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/08 18:09:59 UTC, 0 replies.
- [GitHub] flink pull request #2972: [FLINK-5211] [metrics] [docs] Include example repo... - posted by zentol <gi...@git.apache.org> on 2016/12/08 18:24:31 UTC, 6 replies.
- [jira] [Commented] (FLINK-5211) Include an example configuration for all reporters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/08 18:24:58 UTC, 8 replies.
- [GitHub] flink pull request #2973: [FLINK-5206] [py] Use random file names in tests - posted by zentol <gi...@git.apache.org> on 2016/12/08 18:29:51 UTC, 1 replies.
- [GitHub] flink pull request #2974: [FLINK-5298] TM checks that log file exists - posted by zentol <gi...@git.apache.org> on 2016/12/08 18:31:42 UTC, 0 replies.
- [GitHub] flink pull request #2060: [FLINK-3921] StringParser encoding - posted by asfgit <gi...@git.apache.org> on 2016/12/08 20:24:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-5226) Eagerly project unused attributes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/08 20:25:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3921) StringParser not specifying encoding to use - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/08 20:27:58 UTC, 0 replies.
- [GitHub] flink issue #2972: [FLINK-5211] [metrics] [docs] Include example reporter co... - posted by uce <gi...@git.apache.org> on 2016/12/08 20:59:01 UTC, 1 replies.
- [jira] [Assigned] (FLINK-5280) Extend TableSource to support nested data - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/08 21:03:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5039) Avro GenericRecord support is broken - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/08 21:10:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5288) Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/08 21:15:58 UTC, 0 replies.
- [GitHub] flink pull request #2913: [backport] [FLINK-5114] [network] Handle partition... - posted by uce <gi...@git.apache.org> on 2016/12/08 23:04:00 UTC, 0 replies.
- [GitHub] flink pull request #2975: [backport] [FLINK-5114] [network] Handle partition... - posted by uce <gi...@git.apache.org> on 2016/12/08 23:05:42 UTC, 2 replies.
- [jira] [Created] (FLINK-5302) Log failure cause at Execution - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/08 23:08:58 UTC, 0 replies.
- [GitHub] flink issue #2961: [FLINK-5266] [table] eagerly project unused fields when s... - posted by KurtYoung <gi...@git.apache.org> on 2016/12/09 03:58:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-5299) DataStream support for arrays as keys - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/09 04:05:58 UTC, 5 replies.
- [jira] [Assigned] (FLINK-5188) Adjust all the imports referencing Row - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/09 07:20:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/12/09 07:21:58 UTC, 0 replies.
- [GitHub] flink pull request #2965: [FLINK-5303] [table] Support for SQL GROUPING SETS... - posted by chermenin <gi...@git.apache.org> on 2016/12/09 07:39:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/09 07:39:58 UTC, 10 replies.
- [GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS... - posted by chermenin <gi...@git.apache.org> on 2016/12/09 07:40:08 UTC, 6 replies.
- [GitHub] flink issue #2965: [FLINK-5303] [table] Support for SQL GROUPING SETS clause... - posted by chermenin <gi...@git.apache.org> on 2016/12/09 07:41:50 UTC, 0 replies.
- [jira] [Created] (FLINK-5304) Change method name from crossApply to join in Table API - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/09 09:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5305) Documentation of collect() should mention parameter akka.framesize - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2016/12/09 09:55:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5304) Change method name from crossApply to join in Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/09 09:59:59 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule - posted by "Alexander Shoshin (JIRA)" <ji...@apache.org> on 2016/12/09 10:32:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/09 10:34:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/09 11:22:58 UTC, 0 replies.
- [GitHub] flink pull request #2977: Flink 5084 - posted by mtunique <gi...@git.apache.org> on 2016/12/09 11:30:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/09 11:30:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/09 11:31:58 UTC, 2 replies.
- [GitHub] flink issue #2970: [FLINK-5300] Add more gentle file deletion procedure - posted by StephanEwen <gi...@git.apache.org> on 2016/12/09 11:38:52 UTC, 5 replies.
- [GitHub] flink issue #2971: [backport] [FLINK-5300] Add more gentle file deletion pro... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/09 11:39:36 UTC, 5 replies.
- [jira] [Closed] (FLINK-5269) Convert string-based Table API tests into unit tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/09 11:44:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5288) Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/09 11:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5307) Log configuration for every reporter - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/09 12:13:58 UTC, 0 replies.
- [GitHub] flink pull request #2978: [FLINK-5304] [table] Change method name from cross... - posted by wuchong <gi...@git.apache.org> on 2016/12/09 12:14:25 UTC, 4 replies.
- [GitHub] flink pull request #2979: [FLINK-5307] [metrics] Log reporter configuration - posted by zentol <gi...@git.apache.org> on 2016/12/09 12:46:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-5307) Log configuration for every reporter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/09 12:46:59 UTC, 2 replies.
- [jira] [Updated] (FLINK-2609) Automatic type registration is only called from the batch execution environment - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/09 12:55:58 UTC, 0 replies.
- [GitHub] flink issue #2890: [hotfix] properly encapsulate the original exception in J... - posted by rmetzger <gi...@git.apache.org> on 2016/12/09 13:08:48 UTC, 1 replies.
- [GitHub] flink issue #2975: [backport] [FLINK-5114] [network] Handle partition produc... - posted by uce <gi...@git.apache.org> on 2016/12/09 13:08:59 UTC, 0 replies.
- [GitHub] flink pull request #2980: [FLINK-4906] [metrics] Introduce constants for IO ... - posted by zentol <gi...@git.apache.org> on 2016/12/09 13:15:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-4906) Use constants for the name of system-defined metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/09 13:15:59 UTC, 3 replies.
- [GitHub] flink issue #2963: [FLINK-5285] Abort checkpoint only once in BarrierTracker - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/09 13:40:05 UTC, 0 replies.
- [GitHub] flink issue #2980: [FLINK-4906] [metrics] Introduce constants for IO metrics - posted by StephanEwen <gi...@git.apache.org> on 2016/12/09 13:53:09 UTC, 1 replies.
- [GitHub] flink issue #2973: [FLINK-5206] [py] Use random file names in tests - posted by StephanEwen <gi...@git.apache.org> on 2016/12/09 13:54:49 UTC, 1 replies.
- [GitHub] flink issue #2877: [FLINK-5141] Implement Flip6LocalStreamEnvironment to run... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/09 13:59:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-5141) Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/09 13:59:58 UTC, 2 replies.
- [jira] [Assigned] (FLINK-5189) deprecate and delete Row in table api - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/09 14:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5308) download links to previous releases are incomplete - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/09 14:44:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5308) download links to previous releases are incomplete - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/09 15:01:07 UTC, 1 replies.
- [GitHub] flink pull request #2909: [FLINK-5193] [jm] Harden job recovery in case of r... - posted by asfgit <gi...@git.apache.org> on 2016/12/09 16:48:22 UTC, 0 replies.
- [GitHub] flink pull request #2872: [FLINK-5158] [ckPtCoord] Handle exceptions from Co... - posted by asfgit <gi...@git.apache.org> on 2016/12/09 16:48:22 UTC, 0 replies.
- [jira] [Created] (FLINK-5309) documentation links on the home page point to 1.2-SNAPSHOT - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/09 16:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5310) Harden the RocksDB JNI library loading - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/09 16:49:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/09 16:51:58 UTC, 0 replies.
- [GitHub] flink pull request #2873: [backport] [FLINK-5158] [ckPtCoord] Handle excepti... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/09 16:52:36 UTC, 0 replies.
- [GitHub] flink issue #2977: [FLINK-5084] Replace Java Table API integration tests by ... - posted by fhueske <gi...@git.apache.org> on 2016/12/09 16:53:14 UTC, 3 replies.
- [jira] [Closed] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/09 16:53:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/09 16:53:58 UTC, 23 replies.
- [jira] [Closed] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/09 16:54:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5278) Improve Task and checkpoint logging - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/09 16:55:59 UTC, 0 replies.
- [GitHub] flink pull request #2890: [hotfix] properly encapsulate the original excepti... - posted by asfgit <gi...@git.apache.org> on 2016/12/09 17:03:39 UTC, 0 replies.
- [GitHub] flink issue #2859: [FLINK-5147] Prevent NPE in LocalFS#delete() - posted by rmetzger <gi...@git.apache.org> on 2016/12/09 18:12:40 UTC, 1 replies.
- [GitHub] flink pull request #2981: [docker] improve Dockerfile host configuration - posted by mxm <gi...@git.apache.org> on 2016/12/09 19:11:39 UTC, 2 replies.
- [GitHub] flink issue #2974: [FLINK-5298] TM checks that log file exists - posted by EronWright <gi...@git.apache.org> on 2016/12/09 20:05:11 UTC, 3 replies.
- [jira] [Closed] (FLINK-4646) Add BipartiteGraph class - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/09 20:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5311) Write user documentation for BipartiteGraph - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/09 22:21:58 UTC, 0 replies.
- [GitHub] flink pull request #2982: [FLINK-4460] Side Outputs in Flink - posted by chenqin <gi...@git.apache.org> on 2016/12/10 01:51:11 UTC, 0 replies.
- [GitHub] flink pull request #2983: [FLINK-4693][tableApi] Add session group-windows f... - posted by sunjincheng121 <gi...@git.apache.org> on 2016/12/10 02:22:47 UTC, 0 replies.
- [GitHub] flink issue #2982: [FLINK-4460] Side Outputs in Flink - posted by chenqin <gi...@git.apache.org> on 2016/12/10 04:46:58 UTC, 2 replies.
- [jira] [Assigned] (FLINK-5223) Add documentation of UDTF in Table API & SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/10 05:53:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5225) Add interface to override parameter types of UDTF's eval method - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/10 05:54:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2016/12/10 09:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5312) Implement Standalone Setup v2.0 - posted by "Manu Zhang (JIRA)" <ji...@apache.org> on 2016/12/10 11:26:59 UTC, 0 replies.
- [GitHub] flink pull request #2984: [FLINK-5311] Add user documentation for bipartite ... - posted by mushketyk <gi...@git.apache.org> on 2016/12/10 17:42:18 UTC, 19 replies.
- [jira] [Commented] (FLINK-5311) Write user documentation for BipartiteGraph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/10 17:42:58 UTC, 25 replies.
- [GitHub] flink pull request #2985: [FLINK-5104] Bipartite graph validation - posted by mushketyk <gi...@git.apache.org> on 2016/12/10 18:22:04 UTC, 5 replies.
- [jira] [Commented] (FLINK-5104) Implement BipartiteGraph validator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/10 18:22:58 UTC, 12 replies.
- [GitHub] flink pull request #2986: [FLINK-4648] Implement BipartiteGraph generator - posted by mushketyk <gi...@git.apache.org> on 2016/12/11 09:10:42 UTC, 4 replies.
- [jira] [Commented] (FLINK-4648) Implement bipartite graph generators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/11 09:10:58 UTC, 5 replies.
- [GitHub] flink issue #2985: [FLINK-5104] Bipartite graph validation - posted by mushketyk <gi...@git.apache.org> on 2016/12/11 09:13:49 UTC, 6 replies.
- [jira] [Commented] (FLINK-4647) Implement BipartiteGraph reader - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/11 17:20:58 UTC, 3 replies.
- [GitHub] flink pull request #2987: [FLINK-4647] Read bipartite graph - posted by mushketyk <gi...@git.apache.org> on 2016/12/11 17:20:58 UTC, 0 replies.
- [GitHub] flink pull request #2988: [FLINK-4649] Implement bipartite graph metrics - posted by mushketyk <gi...@git.apache.org> on 2016/12/11 18:12:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-4649) Implement bipartite graph metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/11 18:12:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/12 00:28:58 UTC, 0 replies.
- [GitHub] flink issue #2987: [FLINK-4647] Read bipartite graph - posted by greghogan <gi...@git.apache.org> on 2016/12/12 01:28:19 UTC, 2 replies.
- [jira] [Created] (FLINK-5313) Supporting all tpch queries - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/12 01:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5314) Add tpch query explain test - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/12 05:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5315) Support distinct aggregations in table api - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/12 05:43:58 UTC, 0 replies.
- [GitHub] flink pull request #2989: [FLINK-5314] [table] add tpch functionality test - posted by KurtYoung <gi...@git.apache.org> on 2016/12/12 05:51:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-5314) Add tpch query explain test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/12 05:51:58 UTC, 3 replies.
- [jira] [Updated] (FLINK-5188) Adjust all the imports referencing types.Row and deprecate table.Row - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/12 08:31:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5189) Delete table.Row - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/12 08:31:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5189) delete Row in table api - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/12 08:31:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5314) Add tpch query explain test - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/12 08:39:59 UTC, 0 replies.
- [GitHub] flink issue #2989: [FLINK-5314] [table] add tpch functionality test - posted by KurtYoung <gi...@git.apache.org> on 2016/12/12 08:40:55 UTC, 0 replies.
- [jira] [Updated] (FLINK-5188) Adjust all the imports referencing types.Row and move RowCsvInputFormat - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/12 08:55:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/12 09:30:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-5035) Don't Write TypeSerializer to Heap State Snapshot - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/12 09:32:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4797) Add Flink 1.1 savepoint backwards compatability - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/12 09:49:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3475) DISTINCT aggregate function support - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/12 09:52:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3475) DISTINCT aggregate function support for SQL queries - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/12 09:53:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-5315) Support distinct aggregations in table api - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/12 09:55:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/12 09:58:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4714) Set task state to RUNNING after state has been restored - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/12/12 10:50:58 UTC, 0 replies.
- [GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I... - posted by senorcarbone <gi...@git.apache.org> on 2016/12/12 11:05:19 UTC, 9 replies.
- [jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/12 11:05:58 UTC, 9 replies.
- [jira] [Comment Edited] (FLINK-3475) DISTINCT aggregate function support for SQL queries - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/12 11:10:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2435) Add support for custom CSV field parsers - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/12/12 11:32:59 UTC, 0 replies.
- [GitHub] flink issue #2805: [FLINK-5059] only serialise events once in RecordWriter#b... - posted by uce <gi...@git.apache.org> on 2016/12/12 11:41:07 UTC, 0 replies.
- [GitHub] flink issue #2806: [FLINK-5066] add more efficient isEvent check to EventSer... - posted by uce <gi...@git.apache.org> on 2016/12/12 12:15:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-5066) add more efficient isEvent check to EventSerializer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/12 12:15:59 UTC, 0 replies.
- [GitHub] flink issue #2883: [FLINK-5088] [network] Add capacity limit option to parti... - posted by uce <gi...@git.apache.org> on 2016/12/12 12:20:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-5088) Add option to limit subpartition queue length - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/12 12:20:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-4005) LocalExecutorITCase.testLocalExecutorWithWordCount fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/12 13:25:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5034) Don't Write StateDescriptor to RocksDB Snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/12 13:26:58 UTC, 1 replies.
- [GitHub] flink pull request #2990: Backport [FLINK-5071] - posted by gyfora <gi...@git.apache.org> on 2016/12/12 13:49:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/12 13:49:59 UTC, 1 replies.
- [GitHub] flink pull request #2859: [FLINK-5147] Prevent NPE in LocalFS#delete() - posted by asfgit <gi...@git.apache.org> on 2016/12/12 14:02:53 UTC, 0 replies.
- [jira] [Closed] (FLINK-5206) Flakey PythonPlanBinderTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/12 14:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5316) Make the GenericWriteAheadSink backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/12 14:03:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4906) Use constants for the name of system-defined metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/12 14:03:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5211) Include an example configuration for all reporters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/12 14:04:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/12 14:05:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5317) Make the continuous file processing code backwards compatible, - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/12 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5318) Make the Rolling/Bucketing sink backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/12 14:06:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5189) Delete table.Row - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/12 14:11:58 UTC, 0 replies.
- [GitHub] flink issue #2871: [FLINK-5163] Ports the production functions to the new st... - posted by aljoscha <gi...@git.apache.org> on 2016/12/12 14:21:26 UTC, 3 replies.
- [GitHub] flink issue #2939: [FLINK-5113] Ports all functions in the tests to the new ... - posted by kl0u <gi...@git.apache.org> on 2016/12/12 14:40:05 UTC, 5 replies.
- [jira] [Created] (FLINK-5319) ClassCastException when reusing an inherited method as KeySelector for different classes - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/12/12 16:07:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5319) ClassCastException when reusing an inherited method as KeySelector for different classes - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/12/12 16:31:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5319) ClassCastException when reusing an inherited method reference as KeySelector for different classes - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/12/12 16:32:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction) - posted by "Yassine Marzougui (JIRA)" <ji...@apache.org> on 2016/12/12 16:43:59 UTC, 0 replies.
- [GitHub] flink pull request #2912: [FLINK-5114] [network] Handle partition producer s... - posted by asfgit <gi...@git.apache.org> on 2016/12/12 16:44:19 UTC, 0 replies.
- [jira] [Closed] (FLINK-5114) PartitionState update with finished execution fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/12 16:44:58 UTC, 0 replies.
- [GitHub] flink pull request #2883: [FLINK-5088] [network] Add capacity limit option t... - posted by uce <gi...@git.apache.org> on 2016/12/12 16:57:54 UTC, 0 replies.
- [jira] [Closed] (FLINK-5088) Add option to limit subpartition queue length - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/12 16:58:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction) - posted by "Yassine Marzougui (JIRA)" <ji...@apache.org> on 2016/12/12 17:01:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5321) FlinkMiniCluster does not start Jobmanager MetricQueryService - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/12 17:13:58 UTC, 0 replies.
- [GitHub] flink pull request #2991: [FLINK-5321] [metrics] LocalFlinkMiniCluster start... - posted by zentol <gi...@git.apache.org> on 2016/12/12 17:18:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-5321) FlinkMiniCluster does not start Jobmanager MetricQueryService - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/12 17:18:58 UTC, 4 replies.
- [jira] [Commented] (FLINK-5319) ClassCastException when reusing an inherited method reference as KeySelector for different classes - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/12 17:19:58 UTC, 9 replies.
- [jira] [Commented] (FLINK-4858) Remove Legacy Checkpointing Interfaces - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/12 17:26:58 UTC, 3 replies.
- [GitHub] flink issue #2752: [FLINK-4814] [checkpointing] Use checkpoint directory for... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/12 17:41:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/12 17:41:58 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4973) Flakey Yarn tests due to recently added latency marker - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/12 17:45:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5293) Make the Kafka consumer backwards compatible. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/12 17:46:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-5318) Make the Rolling/Bucketing sink backwards compatible. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/12 17:46:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5295) Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/12 17:46:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/12 17:46:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5294) Make the WindowOperator backwards compatible. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/12 17:46:58 UTC, 1 replies.
- [GitHub] flink issue #2984: [FLINK-5311] Add user documentation for bipartite graph - posted by mushketyk <gi...@git.apache.org> on 2016/12/12 17:53:57 UTC, 5 replies.
- [jira] [Assigned] (FLINK-5245) Add support for BipartiteGraph mutations - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/12 17:54:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4858) Remove Legacy Checkpointing Interfaces - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/12 18:10:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5322) yarn.taskmanager.env value does not appear in System.getenv - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/12/12 18:10:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5322) yarn.taskmanager.env value does not appear in System.getenv - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/12/12 18:11:58 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-4858) Remove Legacy Checkpointing Interfaces - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/12 18:11:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5245) Add support for BipartiteGraph mutations - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/12 18:35:58 UTC, 7 replies.
- [jira] [Closed] (FLINK-4631) NullPointerException during stream task cleanup - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/12 19:13:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5322) yarn.taskmanager.env value does not appear in System.getenv - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/12 19:22:58 UTC, 2 replies.
- [jira] [Updated] (FLINK-5189) Deprecate table.Row - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/12 19:44:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4091) flink-connector-cassandra has conflicting guava version - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/12/12 21:44:58 UTC, 0 replies.
- [GitHub] flink issue #2956: [FLINK-5223] [doc] Add documentation of UDTF in Table API... - posted by fhueske <gi...@git.apache.org> on 2016/12/12 21:56:01 UTC, 1 replies.
- [jira] [Created] (FLINK-5323) CheckpointNotifier should be removed from docs - posted by "Abhishek Singh (JIRA)" <ji...@apache.org> on 2016/12/12 23:09:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/13 02:06:58 UTC, 0 replies.
- [GitHub] flink issue #2986: [FLINK-4648] Implement BipartiteGraph generator - posted by mushketyk <gi...@git.apache.org> on 2016/12/13 07:29:46 UTC, 0 replies.
- [jira] [Created] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2016/12/13 07:54:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2016/12/13 07:55:58 UTC, 1 replies.
- [GitHub] flink pull request #2750: [FLINK-5007] [checkpointing] Retain externalized c... - posted by uce <gi...@git.apache.org> on 2016/12/13 08:40:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-5007) Retain externalized checkpoint on suspension - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/13 08:40:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5325) Introduce interface for CloseableRegistry to separate user from system-facing functionality - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/13 08:59:58 UTC, 0 replies.
- [GitHub] flink pull request #2992: [FLINK-5325] Splitting user/system-facing API of C... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/13 09:03:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-5325) Introduce interface for CloseableRegistry to separate user from system-facing functionality - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/13 09:03:58 UTC, 4 replies.
- [GitHub] flink issue #2992: [FLINK-5325] Splitting user/system-facing API of Closeabl... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/13 09:04:04 UTC, 2 replies.
- [jira] [Created] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/13 09:07:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5327) Remove IOException from StateObject::getStateSize - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/13 09:11:58 UTC, 0 replies.
- [GitHub] flink pull request #2993: [FLINK-5327] Remove IOEXception from StateObject::... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/13 09:14:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-5327) Remove IOException from StateObject::getStateSize - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/13 09:14:59 UTC, 4 replies.
- [GitHub] flink issue #2993: [FLINK-5327] Remove IOEXception from StateObject::getStat... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/13 09:15:55 UTC, 2 replies.
- [jira] [Updated] (FLINK-5327) Remove IOException from StateObject::getStateSize - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/13 09:15:58 UTC, 1 replies.
- [GitHub] flink pull request #2994: [FLINK-5324] [yarn] JVM Opitons will work for both... - posted by hzyuemeng1 <gi...@git.apache.org> on 2016/12/13 09:27:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/13 09:27:59 UTC, 4 replies.
- [GitHub] flink issue #2994: [FLINK-5324] [yarn] JVM Opitons will work for both YarnAp... - posted by hzyuemeng1 <gi...@git.apache.org> on 2016/12/13 09:29:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/13 09:46:58 UTC, 6 replies.
- [jira] [Commented] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/13 10:03:58 UTC, 4 replies.
- [jira] [Updated] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/13 10:06:58 UTC, 0 replies.
- [GitHub] flink pull request #2995: [FLINK-5320] Fix result TypeInformation in Windowe... - posted by ymarzougui <gi...@git.apache.org> on 2016/12/13 10:15:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-5310) Harden the RocksDB JNI library loading - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/13 10:28:58 UTC, 0 replies.
- [GitHub] flink pull request #2996: [FLINK-5326] [network] Check release flag of paren... - posted by uce <gi...@git.apache.org> on 2016/12/13 10:38:49 UTC, 1 replies.
- [GitHub] flink pull request #2752: [FLINK-4814] [checkpointing] Use checkpoint direct... - posted by uce <gi...@git.apache.org> on 2016/12/13 11:01:06 UTC, 0 replies.
- [GitHub] flink issue #2867: [FLINK-5145] WebInterface only polls selected metrics - posted by rmetzger <gi...@git.apache.org> on 2016/12/13 12:16:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-5145) WebInterface to aggressive in pulling metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/13 12:16:58 UTC, 2 replies.
- [GitHub] flink issue #2978: [FLINK-5304] [table] Change method name from crossApply t... - posted by fhueske <gi...@git.apache.org> on 2016/12/13 12:32:32 UTC, 0 replies.
- [jira] [Created] (FLINK-5328) ConnectedComponentsITCase testJobWithoutObjectReuse fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/13 12:36:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5328) ConnectedComponentsITCase testJobWithoutObjectReuse fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/13 12:37:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5328) ConnectedComponentsITCase testJobWithoutObjectReuse fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/13 12:39:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks) - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/13 12:49:58 UTC, 0 replies.
- [GitHub] flink issue #2996: [FLINK-5326] [network] Check release flag of parent in re... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/13 12:52:43 UTC, 0 replies.
- [jira] [Created] (FLINK-5329) MetricList is being cut off - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/13 12:54:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5329) MetricList is being cut off - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/13 12:55:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5329) Metric list is being cut off in the WebFrontend - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/13 12:55:59 UTC, 0 replies.
- [GitHub] flink pull request #2867: [FLINK-5145] WebInterface only polls selected metr... - posted by asfgit <gi...@git.apache.org> on 2016/12/13 12:58:53 UTC, 0 replies.
- [jira] [Closed] (FLINK-5145) WebInterface to aggressive in pulling metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/13 12:58:58 UTC, 0 replies.
- [GitHub] flink issue #2995: [FLINK-5320] Fix result TypeInformation in WindowedStream... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/13 13:01:47 UTC, 3 replies.
- [GitHub] flink issue #2991: [FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM Me... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/13 13:04:43 UTC, 3 replies.
- [jira] [Closed] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/13 13:04:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5304) Change method name from crossApply to join in Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/13 13:38:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5223) Add documentation of UDTF in Table API & SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/13 13:39:58 UTC, 0 replies.
- [GitHub] flink pull request #2997: [FLINK-5240][tests] ensure state backends are prop... - posted by mxm <gi...@git.apache.org> on 2016/12/13 14:28:54 UTC, 1 replies.
- [jira] [Created] (FLINK-5330) Harden KafkaConsumer08Test - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/13 14:44:58 UTC, 0 replies.
- [GitHub] flink pull request #2998: [FLINK-5330] [tests] Harden KafkaConsumer08Test to... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/13 14:50:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-5330) Harden KafkaConsumer08Test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/13 14:50:58 UTC, 3 replies.
- [GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts - posted by greghogan <gi...@git.apache.org> on 2016/12/13 14:53:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-4861) Package optional project artifacts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/13 14:53:58 UTC, 19 replies.
- [GitHub] flink issue #2764: [FLINK-5008] Update quickstart documentation - posted by NicoK <gi...@git.apache.org> on 2016/12/13 15:36:09 UTC, 2 replies.
- [jira] [Commented] (FLINK-5008) Update quickstart documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/13 15:36:58 UTC, 24 replies.
- [jira] [Created] (FLINK-5331) PythonPlanBinderTest idling extremely long - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/13 15:51:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/13 15:54:58 UTC, 0 replies.
- [GitHub] flink issue #2958: [FLINK-4704] Move Table API to org.apache.flink.table - posted by fhueske <gi...@git.apache.org> on 2016/12/13 17:06:44 UTC, 8 replies.
- [jira] [Updated] (FLINK-5331) PythonPlanBinderTest idling extremely long - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/13 17:11:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5189) Deprecate table.Row - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/13 17:16:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5108) Remove ClientShutdownHook during job execution - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/13 18:12:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5322) yarn.taskmanager.env value does not appear in System.getenv - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/13 19:31:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5322) Clean up yarn configuration documentation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/13 19:32:58 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-5322) Clean up yarn configuration documentation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/13 19:32:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5332) Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/13 19:48:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5287) Test randomly fails with wrong result: testWithAtomic2[Execution mode = CLUSTER](org.apache.flink.api.scala.operators.JoinITCase) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/13 19:49:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5287) Test randomly fails with wrong result: testWithAtomic2[Execution mode = CLUSTER](org.apache.flink.api.scala.operators.JoinITCase) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/13 19:49:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5288) Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/13 19:52:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5288) Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/13 19:52:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/13 19:54:58 UTC, 5 replies.
- [jira] [Issue Comment Deleted] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/13 19:54:58 UTC, 0 replies.
- [GitHub] flink pull request #2999: [FLINK-5332] [core] Synchronize FileSystem::initOu... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/13 20:05:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-5332) Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/13 20:05:59 UTC, 5 replies.
- [GitHub] flink issue #2999: [FLINK-5332] [core] Synchronize FileSystem::initOutPathLo... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/13 20:06:10 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-5245) Add support for BipartiteGraph mutations - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/13 20:23:58 UTC, 0 replies.
- [GitHub] flink pull request #3000: [FLINK-4861] [build] Package optional project arti... - posted by greghogan <gi...@git.apache.org> on 2016/12/13 21:41:40 UTC, 0 replies.
- [GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa... - posted by tony810430 <gi...@git.apache.org> on 2016/12/14 02:30:29 UTC, 6 replies.
- [jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/14 02:30:58 UTC, 12 replies.
- [GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper... - posted by bjlovegithub <gi...@git.apache.org> on 2016/12/14 02:58:01 UTC, 4 replies.
- [GitHub] flink pull request #3002: Fix typo in variable name - posted by rboorgapally <gi...@git.apache.org> on 2016/12/14 05:35:28 UTC, 1 replies.
- [GitHub] flink pull request #3003: [Flink-5188] Create analog of RowCsvInputFormat in... - posted by tonycox <gi...@git.apache.org> on 2016/12/14 07:23:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-5189) Delete Row in table api - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/14 08:01:10 UTC, 0 replies.
- [jira] [Created] (FLINK-5333) Keep Windows scripts in sync with shell scripts - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/14 08:09:58 UTC, 0 replies.
- [GitHub] flink pull request #3004: [Flink-5189] Delete Row and its related classes fr... - posted by tonycox <gi...@git.apache.org> on 2016/12/14 08:28:47 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5319) ClassCastException when reusing an inherited method reference as KeySelector for different classes - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/14 08:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5334) outdated scala SBT quickstart example - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/14 09:16:00 UTC, 0 replies.
- [GitHub] flink pull request #3003: [FLINK-5188] Create analog of RowCsvInputFormat in... - posted by fhueske <gi...@git.apache.org> on 2016/12/14 10:14:24 UTC, 14 replies.
- [jira] [Commented] (FLINK-5188) Adjust all the imports referencing types.Row and move RowCsvInputFormat - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/14 10:15:00 UTC, 15 replies.
- [GitHub] flink issue #2998: [FLINK-5330] [tests] Harden KafkaConsumer08Test to fail r... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/14 10:32:18 UTC, 1 replies.
- [GitHub] flink issue #3000: [FLINK-4861] [build] Package optional project artifacts - posted by StephanEwen <gi...@git.apache.org> on 2016/12/14 10:55:58 UTC, 2 replies.
- [GitHub] flink issue #3002: Fix typo in variable name - posted by StephanEwen <gi...@git.apache.org> on 2016/12/14 10:57:52 UTC, 0 replies.
- [GitHub] flink issue #3004: [FLINK-5189] Delete Row and its related classes from tabl... - posted by fhueske <gi...@git.apache.org> on 2016/12/14 10:59:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-5189) Delete Row in table api - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/14 10:59:59 UTC, 2 replies.
- [GitHub] flink issue #2979: [FLINK-5307] [metrics] Log reporter configuration - posted by StephanEwen <gi...@git.apache.org> on 2016/12/14 11:07:31 UTC, 0 replies.
- [GitHub] flink issue #2952: [FLINK-5011] [types] TraversableSerializer does not perfo... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/14 11:10:32 UTC, 2 replies.
- [jira] [Created] (FLINK-5335) Allow ListCheckpointed user functions to return null - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/14 11:12:58 UTC, 0 replies.
- [GitHub] flink issue #2941: [FLINK-3555] Web interface does not render job informatio... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/14 11:13:17 UTC, 1 replies.
- [GitHub] flink issue #2925: [FLINK-4574] [kinesis] Strengthen fetch interval implemen... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/14 11:14:12 UTC, 3 replies.
- [GitHub] flink pull request #3005: [FLINK-5335] Allow ListCheckpointed user functions... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/14 11:17:15 UTC, 7 replies.
- [GitHub] flink issue #3005: [FLINK-5335] Allow ListCheckpointed user functions to ret... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/14 11:17:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-5335) Allow ListCheckpointed user functions to return null - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/14 11:17:59 UTC, 9 replies.
- [GitHub] flink issue #2914: [FLINK-4611] [kinesis] Make "AUTO" credential provider as... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/14 11:19:15 UTC, 4 replies.
- [jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/14 11:19:58 UTC, 7 replies.
- [GitHub] flink pull request #2887: [FLINK-4870] [FLINK-5162] Fix issues on windows re... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/14 11:23:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/14 11:23:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4870) ContinuousFileMonitoringFunction does not properly handle absolut Windows paths - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/14 11:23:58 UTC, 0 replies.
- [GitHub] flink issue #2849: [FLINK-4631] Fixed stream task that was interrupted befor... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/14 11:28:00 UTC, 0 replies.
- [GitHub] flink pull request #2849: [FLINK-4631] Fixed stream task that was interrupte... - posted by chermenin <gi...@git.apache.org> on 2016/12/14 11:41:51 UTC, 0 replies.
- [GitHub] flink issue #2836: [FLINK-5092] Add maven profile with code coverage report ... - posted by BorisOsipov <gi...@git.apache.org> on 2016/12/14 11:54:03 UTC, 2 replies.
- [jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/14 11:54:58 UTC, 2 replies.
- [GitHub] flink issue #3003: [FLINK-5188] Create analog of RowCsvInputFormat in java a... - posted by tonycox <gi...@git.apache.org> on 2016/12/14 12:00:20 UTC, 1 replies.
- [GitHub] flink pull request #2865: [FLINK-5002] Renamed getNumberOfUsedBuffers() meth... - posted by asfgit <gi...@git.apache.org> on 2016/12/14 12:11:31 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:14:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5330) Harden KafkaConsumer08Test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:14:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:14:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5330) Harden KafkaConsumer08Test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:14:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5307) Log configuration for every reporter - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:15:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5289) NPE when using value state on non-keyed stream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:16:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5307) Log configuration for every reporter - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5289) NPE when using value state on non-keyed stream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:16:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5289) NPE when using value state on non-keyed stream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:16:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5332) Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:17:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5332) Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:17:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:18:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:21:58 UTC, 0 replies.
- [GitHub] flink issue #2843: [FLINK-4798] CEPITCase.testSimpleKeyedPatternCEP test fai... - posted by BorisOsipov <gi...@git.apache.org> on 2016/12/14 12:22:29 UTC, 0 replies.
- [GitHub] flink pull request #2843: [FLINK-4798] CEPITCase.testSimpleKeyedPatternCEP t... - posted by BorisOsipov <gi...@git.apache.org> on 2016/12/14 12:22:29 UTC, 0 replies.
- [jira] [Closed] (FLINK-5327) Remove IOException from StateObject::getStateSize - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:22:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5327) Remove IOException from StateObject::getStateSize - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5336) Make Path immutable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:27:58 UTC, 0 replies.
- [GitHub] flink issue #2997: [FLINK-5240][tests] ensure state backends are properly cl... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/14 12:56:10 UTC, 2 replies.
- [jira] [Created] (FLINK-5337) Introduce backwards compatible state to task assignment - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/14 13:15:58 UTC, 0 replies.
- [GitHub] flink pull request #3006: [FLINK-5323] CheckpointNotifier should be removed ... - posted by abhishsi <gi...@git.apache.org> on 2016/12/14 14:08:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-5323) CheckpointNotifier should be removed from docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/14 14:08:58 UTC, 4 replies.
- [jira] [Closed] (FLINK-5258) reorganize the docs to improve navigation and reduce duplication - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 14:12:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5258) reorganize the docs to improve navigation and reduce duplication - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 14:12:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4922) Write documentation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/14 14:13:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/14 14:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5338) Make printing sinks non-parallel - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 14:26:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/14 14:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5339) Ensure Flink works with Log4j version 2 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/14 14:27:58 UTC, 0 replies.
- [GitHub] flink pull request #3007: [FLINK-4922][docs] document how to use Flink on Me... - posted by mxm <gi...@git.apache.org> on 2016/12/14 14:35:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-4922) Write documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/14 14:35:58 UTC, 1 replies.
- [GitHub] flink pull request #2764: [FLINK-5008] Update quickstart documentation - posted by fhueske <gi...@git.apache.org> on 2016/12/14 14:38:59 UTC, 21 replies.
- [GitHub] flink issue #3006: [FLINK-5323] CheckpointNotifier should be removed from do... - posted by rmetzger <gi...@git.apache.org> on 2016/12/14 14:48:07 UTC, 3 replies.
- [jira] [Updated] (FLINK-3551) Sync Scala and Java Streaming Examples - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/12/14 15:03:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4429) Move Redis Sink from Flink to Bahir - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/14 15:04:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/14 15:53:58 UTC, 0 replies.
- [GitHub] flink pull request #3008: [FLINK-4973] Let LatencyMarksEmitter use StreamTas... - posted by tillrohrmann <gi...@git.apache.org> on 2016/12/14 15:55:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/14 15:55:59 UTC, 6 replies.
- [jira] [Closed] (FLINK-5034) Don't Write StateDescriptor to RocksDB Snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/14 16:58:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4782) log4j & slf4j-log4j are present in jar-with-dependencies artifacts - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/14 18:47:58 UTC, 1 replies.
- [GitHub] flink pull request #2832: [FLINK-4936] [gelly] Operator names for Gelly inpu... - posted by asfgit <gi...@git.apache.org> on 2016/12/14 21:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-4936) Operator names for Gelly inputs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/14 21:14:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4936) Operator names for Gelly inputs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/14 21:14:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5340) I would like a metric exposing job uptime - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/12/14 23:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5340) I would like a metric exposing job uptime - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/12/14 23:03:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5340) Add a metric exposing jobs uptimes - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/12/14 23:04:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5341) Add a metric exposing how many times a job has been restarted - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/12/14 23:05:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/15 02:07:58 UTC, 1 replies.
- [jira] [Assigned] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/15 02:07:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5342) Setting the parallelism automatically for DataSet Operators base on cost model - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/12/15 05:58:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5342) Setting the parallelism automatically for DataSet Operators base on cost model - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/12/15 05:58:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5342) Setting the parallelism automatically for Operators base on cost model - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/12/15 05:59:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5342) Setting the parallelism automatically for operators base on cost model - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/12/15 05:59:58 UTC, 2 replies.
- [GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition... - posted by tony810430 <gi...@git.apache.org> on 2016/12/15 07:32:02 UTC, 5 replies.
- [jira] [Assigned] (FLINK-5336) Make Path immutable - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 07:59:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-5336) Make Path immutable - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 08:07:59 UTC, 0 replies.
- [GitHub] flink pull request #3009: [FLINK-5255] Improve single row check in DataSetSi... - posted by AlexanderShoshin <gi...@git.apache.org> on 2016/12/15 08:12:46 UTC, 1 replies.
- [jira] [Assigned] (FLINK-5186) Move Row and RowTypeInfo into Flink core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 08:25:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3109) Join two streams with two different buffer time - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 08:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5343) Add option to CsvTableSink to overwrite files - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/15 09:07:58 UTC, 0 replies.
- [GitHub] flink pull request #3010: [minor] Fix String formats in FlinkDistributionOve... - posted by BorisOsipov <gi...@git.apache.org> on 2016/12/15 09:17:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-3109) Join two streams with two different buffer time - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 09:21:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3109) Join two streams with two different buffer time - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 09:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-4610) Replace keySet/getValue with entrySet in UdfAnalyzerUtils - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 09:39:58 UTC, 0 replies.
- [GitHub] flink pull request #: - posted by uce <gi...@git.apache.org> on 2016/12/15 10:22:18 UTC, 3 replies.
- [jira] [Closed] (FLINK-5335) Allow ListCheckpointed user functions to return null - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/15 10:25:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5342) Setting the parallelism automatically for operators base on cost model - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/15 10:34:58 UTC, 4 replies.
- [jira] [Updated] (FLINK-5338) Make printing sinks non-parallel - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 10:50:58 UTC, 0 replies.
- [GitHub] flink pull request #3004: [FLINK-5189] Delete Row and its related classes fr... - posted by asfgit <gi...@git.apache.org> on 2016/12/15 10:51:08 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4446) Move Flume Sink from Flink to Bahir - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/15 11:04:58 UTC, 0 replies.
- [GitHub] flink pull request #3011: [FLINK-5343] [table] Add support to overwrite file... - posted by fhueske <gi...@git.apache.org> on 2016/12/15 11:07:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-5343) Add option to CsvTableSink to overwrite files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/15 11:07:59 UTC, 0 replies.
- [GitHub] flink pull request #2723: [FLINK-3617] Fix for OptionSerializer. - posted by StephanEwen <gi...@git.apache.org> on 2016/12/15 11:13:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/15 11:13:58 UTC, 14 replies.
- [jira] [Closed] (FLINK-5189) Delete Row in table api - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 11:15:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5189) Delete Row in table api - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 11:15:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5187) Create analog of Row in core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 11:16:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5186) Move Row and RowTypeInfo into Flink core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 11:16:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5188) Adjust all the imports referencing types.Row and move RowCsvInputFormat - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/15 11:16:58 UTC, 0 replies.
- [GitHub] flink pull request #3012: [FLINK-2186] Add readCsvAsRow methods to CsvReader... - posted by tonycox <gi...@git.apache.org> on 2016/12/15 11:28:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2186) Rework CSV import to support very wide files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/15 11:28:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-5338) Make printing sinks non-parallel - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/15 11:40:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/15 11:51:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/15 11:55:58 UTC, 0 replies.
- [GitHub] flink issue #3008: [FLINK-4973] Let LatencyMarksEmitter use StreamTask's Pro... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/15 12:46:40 UTC, 4 replies.
- [GitHub] flink issue #2936: [FLINK-4927] [yarn] refine YARN Resource manager accordin... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/15 12:49:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-5343) Add more option to CsvTableSink - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/15 12:50:58 UTC, 1 replies.
- [GitHub] flink pull request #2914: [FLINK-4611] [kinesis] Make "AUTO" credential prov... - posted by tony810430 <gi...@git.apache.org> on 2016/12/15 13:15:31 UTC, 1 replies.
- [GitHub] flink pull request #2903: [FLINK-5074] [runtime] add a zookeeper based runni... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/15 13:33:02 UTC, 0 replies.
- [GitHub] flink pull request #2717: [FLINK-4956] Enhance StreamTaskTestHarness with ea... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/15 13:38:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-4956) Introduce convenient methods for testing checkpoint/restore in StreamTaskTestHarness - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/15 13:38:58 UTC, 0 replies.
- [GitHub] flink issue #2723: [FLINK-3617] Fixed NPE from CaseClassSerializer - posted by chermenin <gi...@git.apache.org> on 2016/12/15 13:46:19 UTC, 7 replies.
- [jira] [Created] (FLINK-5344) docs don't build in dockerized jekyll - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/15 14:37:58 UTC, 0 replies.
- [GitHub] flink pull request #3013: [FLINK-5344] relax spec for requested ruby version... - posted by alpinegizmo <gi...@git.apache.org> on 2016/12/15 14:47:59 UTC, 4 replies.
- [jira] [Commented] (FLINK-5344) docs don't build in dockerized jekyll - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/15 14:48:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5344) docs don't build in dockerized jekyll - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/15 14:49:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/15 15:09:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5345) IOManager failed to properly clean up temp file directory - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/15 15:20:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5344) docs don't build in dockerized jekyll; -p option is broken - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/15 15:44:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5345) IOManager failed to properly clean up temp file directory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/15 15:56:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-5345) IOManager failed to properly clean up temp file directory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/15 15:56:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/15 16:52:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5344) docs don't build in dockerized jekyll; -p option is broken - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/15 17:15:58 UTC, 13 replies.
- [jira] [Created] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/15 20:02:59 UTC, 0 replies.
- [GitHub] flink issue #3013: [FLINK-5344] relax spec for requested ruby version so the... - posted by alpinegizmo <gi...@git.apache.org> on 2016/12/15 20:11:26 UTC, 1 replies.
- [GitHub] flink pull request #3014: [FLINK-4861] [build] Package optional project arti... - posted by greghogan <gi...@git.apache.org> on 2016/12/15 22:32:44 UTC, 1 replies.
- [GitHub] flink issue #3011: [FLINK-5343] [table] Add support to overwrite files with ... - posted by twalthr <gi...@git.apache.org> on 2016/12/15 22:35:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-5343) Add more option to CsvTableSink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/15 22:35:58 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write() - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/15 22:54:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write() - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/15 22:54:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/15 23:08:58 UTC, 0 replies.
- [GitHub] flink issue #3009: [FLINK-5255] Improve single row check in DataSetSingleRow... - posted by fhueske <gi...@git.apache.org> on 2016/12/15 23:28:31 UTC, 1 replies.
- [jira] [Created] (FLINK-5348) Support custom field names for RowTypeInfo - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/16 02:13:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3746) WebRuntimeMonitorITCase.testNoCopyFromJar failing intermittently - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/12/16 07:17:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4255) Unstable test WebRuntimeMonitorITCase.testNoEscape - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/12/16 07:17:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5349) Fix code sample for Twitter connector - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/16 07:56:59 UTC, 0 replies.
- [GitHub] flink pull request #3015: [FLINK-5349] Fix typos in Twitter connector code s... - posted by mushketyk <gi...@git.apache.org> on 2016/12/16 07:57:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-5349) Fix code sample for Twitter connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/16 07:57:58 UTC, 1 replies.
- [GitHub] flink pull request #3016: [FLINK-5344] Fixed the dockerized doc build, which... - posted by alpinegizmo <gi...@git.apache.org> on 2016/12/16 08:01:17 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4681) Add SessionRow row-windows for batch tables. - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/16 08:08:58 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4683) Add SlideRow row-windows for batch tables - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/16 08:08:58 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4682) Add TumbleRow row-windows for batch tables. - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/16 08:08:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4682) Add TumbleRow row-windows for batch tables. - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/16 08:37:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5350) Don't overwrite existing Jaas config property - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/16 09:47:58 UTC, 0 replies.
- [GitHub] flink pull request #3017: [FLINK-5350] don't overwrite an existing JAAS conf... - posted by mxm <gi...@git.apache.org> on 2016/12/16 09:49:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-5350) Don't overwrite existing Jaas config property - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/16 09:49:58 UTC, 5 replies.
- [GitHub] flink pull request #3018: [FLINK-5336] Remove IOReadableWritable interface f... - posted by tonycox <gi...@git.apache.org> on 2016/12/16 09:49:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5336) Make Path immutable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/16 09:50:58 UTC, 1 replies.
- [GitHub] flink pull request #3019: [FLINK-4255] Unstable test WebRuntimeMonitorITCase... - posted by BorisOsipov <gi...@git.apache.org> on 2016/12/16 09:55:26 UTC, 5 replies.
- [GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for... - posted by wuchong <gi...@git.apache.org> on 2016/12/16 09:55:41 UTC, 12 replies.
- [jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/16 09:55:59 UTC, 18 replies.
- [jira] [Commented] (FLINK-4255) Unstable test WebRuntimeMonitorITCase.testNoEscape - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/16 09:55:59 UTC, 6 replies.
- [GitHub] flink pull request #2842: [FLINK-5097][gelly] Add missing input type informa... - posted by asfgit <gi...@git.apache.org> on 2016/12/16 10:26:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-5311) Write user documentation for BipartiteGraph - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/12/16 10:28:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5311) Write user documentation for BipartiteGraph - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/12/16 10:28:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/12/16 10:29:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5351) Make the TypeExtractor support functions with more than 2 inputs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/12/16 10:34:58 UTC, 0 replies.
- [GitHub] flink issue #3020: [FLINK-5348] [core] Support custom field names for RowTyp... - posted by tonycox <gi...@git.apache.org> on 2016/12/16 10:53:37 UTC, 5 replies.
- [GitHub] flink pull request #2723: [FLINK-3617] Fixed NPE from CaseClassSerializer - posted by chermenin <gi...@git.apache.org> on 2016/12/16 10:53:56 UTC, 0 replies.
- [GitHub] flink issue #3018: [FLINK-5336] Remove IOReadableWritable interface from Pat... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/16 11:21:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5352) Restore RocksDB 1.1.3 memory behavior - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/16 11:34:58 UTC, 0 replies.
- [GitHub] flink pull request #3021: [FLINK-3617] Prevent NPE in CaseClassSerializer an... - posted by chermenin <gi...@git.apache.org> on 2016/12/16 11:52:23 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/12/16 12:06:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins - posted by "Alexander Shoshin (JIRA)" <ji...@apache.org> on 2016/12/16 12:42:58 UTC, 0 replies.
- [GitHub] flink issue #3015: [FLINK-5349] Fix typos in Twitter connector code sample - posted by zentol <gi...@git.apache.org> on 2016/12/16 12:48:12 UTC, 0 replies.
- [jira] [Created] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/12/16 12:54:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/12/16 12:56:58 UTC, 3 replies.
- [jira] [Resolved] (FLINK-3661) Make Scala 2.11.x the default Scala version - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/16 13:52:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5352) Restore RocksDB 1.1.3 memory behavior - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/16 13:53:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/16 13:53:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-3661) Make Scala 2.11.x the default Scala version - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/16 13:54:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/16 13:55:58 UTC, 0 replies.
- [GitHub] flink issue #3017: [FLINK-5350] don't overwrite an existing JAAS config - posted by theomega <gi...@git.apache.org> on 2016/12/16 14:01:38 UTC, 2 replies.
- [GitHub] flink issue #3014: [FLINK-4861] [build] Package optional project artifacts - posted by greghogan <gi...@git.apache.org> on 2016/12/16 14:14:28 UTC, 9 replies.
- [jira] [Created] (FLINK-5354) Split up Table API documentation into multiple pages - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/16 14:44:58 UTC, 0 replies.
- [GitHub] flink issue #3016: [FLINK-5344] Fixed the dockerized doc build, which has be... - posted by greghogan <gi...@git.apache.org> on 2016/12/16 14:55:21 UTC, 5 replies.
- [jira] [Updated] (FLINK-4896) PageRank algorithm for directed graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/12/16 15:07:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5355) Handle AmazonKinesisException gracefully in Kinesis Streaming Connector - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/12/16 15:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5356) librocksdbjni*.so is not deleted from /tmp directory - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/16 15:25:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5356) librocksdbjni*.so is not deleted from /tmp directory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/16 15:29:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-5355) Handle AmazonKinesisException gracefully in Kinesis Streaming Connector - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/12/16 15:36:58 UTC, 2 replies.
- [jira] [Resolved] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/16 15:39:58 UTC, 0 replies.
- [GitHub] flink issue #3019: [FLINK-4255] Unstable test WebRuntimeMonitorITCase.testNo... - posted by BorisOsipov <gi...@git.apache.org> on 2016/12/16 15:42:36 UTC, 0 replies.
- [jira] [Closed] (FLINK-5008) Update quickstart documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/16 15:50:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5343) Add more option to CsvTableSink - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/16 15:50:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4704) Move Table API to org.apache.flink.table - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/16 15:51:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-3848) Add ProjectableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/16 15:51:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/16 15:52:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5357) WordCountTable fails - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/16 15:55:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5358) Support Row in TypeExtractor - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/16 16:24:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5358) Support Row in TypeExtractor - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/16 16:26:00 UTC, 4 replies.
- [jira] [Closed] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/16 17:04:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4922) Write documentation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/16 17:06:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5350) Don't overwrite existing Jaas config property - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/16 17:06:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5344) docs don't build in dockerized jekyll; -p option is broken - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/16 17:07:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5356) librocksdbjni*.so is not deleted from /tmp directory - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/16 17:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5359) Job Exceptions view doesn't scroll - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/16 21:54:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5359) Job Exceptions view doesn't scroll - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/16 22:01:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5360) Fix arguments names in WindowedStream - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/16 22:58:58 UTC, 0 replies.
- [GitHub] flink pull request #3022: [FLINK-5360] Fix argument names in WindowedStream - posted by mushketyk <gi...@git.apache.org> on 2016/12/16 23:01:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-5360) Fix arguments names in WindowedStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/16 23:01:58 UTC, 2 replies.
- [jira] [Assigned] (FLINK-5030) Support hostname verification - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/17 01:58:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5030) Support hostname verification - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/17 02:05:58 UTC, 2 replies.
- [GitHub] flink pull request #3023: [FLINK-5030] Support hostname verification - posted by EronWright <gi...@git.apache.org> on 2016/12/17 02:07:12 UTC, 0 replies.
- [GitHub] flink issue #3023: [FLINK-5030] Support hostname verification - posted by EronWright <gi...@git.apache.org> on 2016/12/17 02:08:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-5182) Implement SSL file-shipping - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/17 02:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5361) Flink shouldn't require Kerberos credentials - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/17 02:21:59 UTC, 0 replies.
- [jira] [Reopened] (FLINK-5350) Don't overwrite existing Jaas config property - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/17 20:37:59 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5350) Don't overwrite existing Jaas config property - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/17 21:49:58 UTC, 0 replies.
- [GitHub] flink issue #2864: [FLINK-5055][security] skip Hadoop UGI login if unsecured - posted by EronWright <gi...@git.apache.org> on 2016/12/17 22:50:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/17 22:50:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4029) Multi-field "sum" function just like "keyBy" - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/18 08:58:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3427) Add watermark monitoring to JobManager web frontend - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/18 08:59:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/18 09:01:09 UTC, 2 replies.
- [jira] [Closed] (FLINK-3298) Streaming connector for ActiveMQ - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/18 09:01:10 UTC, 0 replies.
- [jira] [Created] (FLINK-5362) Implement methods to access BipartiteGraph properties - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/18 09:02:59 UTC, 0 replies.
- [GitHub] flink pull request #3024: [FLINK-5362] Implement methods to access Bipartite... - posted by mushketyk <gi...@git.apache.org> on 2016/12/18 09:05:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-5362) Implement methods to access BipartiteGraph properties - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/18 09:05:59 UTC, 0 replies.
- [GitHub] flink pull request #2314: [FLINK-3298] Implement ActiveMQ streaming connecto... - posted by mushketyk <gi...@git.apache.org> on 2016/12/18 10:07:19 UTC, 0 replies.
- [GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector - posted by mushketyk <gi...@git.apache.org> on 2016/12/18 10:07:19 UTC, 0 replies.
- [jira] [Created] (FLINK-5363) Fire timers when window state is currently empty - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/18 17:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5364) Rework JAAS configuration to support user-supplied entries - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/19 00:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5365) Mesos AppMaster/TaskManager should obey sigterm - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/19 01:10:58 UTC, 0 replies.
- [GitHub] flink pull request #3025: [FLINK-5365] Mesos AppMaster/TaskManager should ob... - posted by EronWright <gi...@git.apache.org> on 2016/12/19 01:23:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-5365) Mesos AppMaster/TaskManager should obey sigterm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/19 01:23:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5313) Supporting all tpch queries - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/19 02:44:59 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-5342) Setting the parallelism automatically for operators base on cost model - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/12/19 03:32:58 UTC, 2 replies.
- [GitHub] flink pull request #2877: [FLINK-5141] Implement Flip6LocalStreamEnvironment... - posted by ifndef-SleePy <gi...@git.apache.org> on 2016/12/19 08:57:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-5358) Support Row in TypeExtractor - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/19 09:48:58 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-5358) Support Row in TypeExtractor - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/19 09:49:58 UTC, 5 replies.
- [jira] [Created] (FLINK-5366) Add end-to-end tests for Savepoint Backwards Compatibility - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/19 10:45:58 UTC, 0 replies.
- [GitHub] flink pull request #3026: [FLINK-2980] [table] Support for GROUPING SETS cla... - posted by chermenin <gi...@git.apache.org> on 2016/12/19 10:48:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5280) Extend TableSource to support nested data - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/19 11:05:59 UTC, 4 replies.
- [jira] [Updated] (FLINK-5358) Support RowTypeInfo extraction in TypeExtractor by Row instance - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/19 12:22:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5358) Support RowTypeInfo extraction in TypeExtractor by Row instance - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/19 12:24:58 UTC, 10 replies.
- [jira] [Created] (FLINK-5367) restore updates lost when merging recent doc refactoring - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/19 12:29:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3150) Make YARN container invocation configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/19 12:51:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3150) Make YARN container invocation configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/19 12:51:58 UTC, 0 replies.
- [GitHub] flink pull request #3027: [FLINK-5358] add RowTypeInfo exctraction in TypeEx... - posted by tonycox <gi...@git.apache.org> on 2016/12/19 13:30:08 UTC, 5 replies.
- [GitHub] flink issue #2767: [FLINK-4988] Elasticsearch 5.x support - posted by StephanEwen <gi...@git.apache.org> on 2016/12/19 14:05:03 UTC, 2 replies.
- [jira] [Commented] (FLINK-4988) Elasticsearch 5.x support - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/19 14:05:58 UTC, 4 replies.
- [GitHub] flink issue #2861: [FLINK-5122] Index requests will be retried if the error ... - posted by rmetzger <gi...@git.apache.org> on 2016/12/19 14:29:02 UTC, 4 replies.
- [jira] [Created] (FLINK-5368) Let Kafka consumer show something when it fails to read one topic out of topic list - posted by "Sendoh (JIRA)" <ji...@apache.org> on 2016/12/19 15:08:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5368) Let Kafka consumer show something when it fails to read one topic out of topic list - posted by "Sendoh (JIRA)" <ji...@apache.org> on 2016/12/19 15:08:58 UTC, 4 replies.
- [GitHub] flink pull request #2767: [FLINK-4988] Elasticsearch 5.x support - posted by rmetzger <gi...@git.apache.org> on 2016/12/19 15:28:20 UTC, 1 replies.
- [GitHub] flink pull request #3028: [FLINK-5367] Restore doc changes that were lost wh... - posted by alpinegizmo <gi...@git.apache.org> on 2016/12/19 15:33:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-5367) restore updates lost when merging recent doc refactoring - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/19 15:33:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5369) jsr305 and logging dependencies should be 'provided' by default - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/19 16:40:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/19 17:21:58 UTC, 2 replies.
- [GitHub] flink pull request #3029: [FLINK-5369] [build] Set jsr305 and logging depend... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/19 17:23:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-5369) jsr305 and logging dependencies should be 'provided' by default - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/19 17:23:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5364) Rework JAAS configuration to support user-supplied entries - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/19 18:32:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/19 18:42:58 UTC, 2 replies.
- [jira] [Closed] (FLINK-4782) log4j & slf4j-log4j are present in jar-with-dependencies artifacts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/19 19:55:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5369) jsr305 and logging dependencies should be 'provided' by default - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/19 19:55:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5369) Rework jsr305 and logging dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/19 19:56:58 UTC, 0 replies.
- [GitHub] flink issue #3029: [FLINK-5369] [build] Rework jsr305 and logging dependenci... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/19 20:31:31 UTC, 2 replies.
- [jira] [Commented] (FLINK-5369) Rework jsr305 and logging dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/19 20:31:58 UTC, 3 replies.
- [GitHub] flink pull request #3030: Updated version of #3014 - posted by StephanEwen <gi...@git.apache.org> on 2016/12/19 21:12:56 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/20 02:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5370) build failure for unit test of FileInputFormatTest and GlobFilePathFilterTest - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/20 02:41:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5370) build failure for unit test of FileInputFormatTest and GlobFilePathFilterTest - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/20 02:46:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4391) Provide support for asynchronous operations over streams - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/20 05:05:58 UTC, 0 replies.
- [GitHub] flink pull request #3031: [FLINK-4616] Added functionality through which wat... - posted by MayerRoman <gi...@git.apache.org> on 2016/12/20 07:48:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/20 07:48:58 UTC, 1 replies.
- [GitHub] flink pull request #3032: [FLINK-5245] Implement BipartiteGraph mutations - posted by mushketyk <gi...@git.apache.org> on 2016/12/20 09:35:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-5370) build failure for unit test of FileInputFormatTest and GlobFilePathFilterTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/20 09:37:58 UTC, 2 replies.
- [jira] [Assigned] (FLINK-5244) Implement methods for BipartiteGraph transformations - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/20 09:38:58 UTC, 0 replies.
- [GitHub] flink issue #3021: [FLINK-3617] Prevent NPE in CaseClassSerializer and infor... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/20 09:54:19 UTC, 2 replies.
- [GitHub] flink issue #3028: [FLINK-5367] Restore doc changes that were lost when merg... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/20 10:03:47 UTC, 0 replies.
- [GitHub] flink issue #2541: [FLINK-4669] scala api createLocalEnvironment() function ... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/20 10:07:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/20 10:07:58 UTC, 1 replies.
- [GitHub] flink pull request #3029: [FLINK-5369] [build] Rework jsr305 and logging dep... - posted by rmetzger <gi...@git.apache.org> on 2016/12/20 10:12:38 UTC, 0 replies.
- [GitHub] flink issue #3030: Updated version of #3014 - posted by rmetzger <gi...@git.apache.org> on 2016/12/20 10:48:56 UTC, 0 replies.
- [jira] [Created] (FLINK-5371) Add documentation for async I/O - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/20 11:48:58 UTC, 0 replies.
- [GitHub] flink pull request #3033: [FLINK-5256] Extend DataSetSingleRowJoin to suppor... - posted by ex00 <gi...@git.apache.org> on 2016/12/20 14:05:24 UTC, 3 replies.
- [jira] [Closed] (FLINK-5366) Add end-to-end tests for Savepoint Backwards Compatibility - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 15:11:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5294) Make the WindowOperator backwards compatible. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 15:12:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5317) Make the continuous file processing code backwards compatible, - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 15:12:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5295) Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 15:12:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5293) Make the Kafka consumer backwards compatible. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 15:13:58 UTC, 0 replies.
- [GitHub] flink pull request #3034: [FLINK-5363] Fire timers when window state is curr... - posted by aljoscha <gi...@git.apache.org> on 2016/12/20 16:15:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-5363) Fire timers when window state is currently empty - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/20 16:15:58 UTC, 1 replies.
- [GitHub] flink issue #3034: [FLINK-5363] Fire timers when window state is currently e... - posted by aljoscha <gi...@git.apache.org> on 2016/12/20 16:17:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 16:47:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4973) Flakey Yarn tests due to recently added latency marker - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/20 16:49:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4973) Flakey Yarn tests due to recently added latency marker - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/20 16:49:58 UTC, 0 replies.
- [GitHub] flink pull request #2541: [FLINK-4669] scala api createLocalEnvironment() fu... - posted by asfgit <gi...@git.apache.org> on 2016/12/20 16:50:32 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5369) Rework jsr305 and logging dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/20 16:52:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5369) Rework jsr305 and logging dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/20 16:52:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/20 16:53:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/20 16:53:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5367) restore updates lost when merging recent doc refactoring - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/20 16:54:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5367) restore updates lost when merging recent doc refactoring - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/20 16:54:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5373) Extend Unit Tests for StateAssignmentOperation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 17:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5374) Extend Unit Tests for RegisteredBackendStateMetaInfo - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 17:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5375) Fix watermark documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/20 17:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/20 18:45:58 UTC, 0 replies.
- [GitHub] flink pull request #3035: [ FLINK-4905] Kafka test instability IllegalStateE... - posted by BrainLogic <gi...@git.apache.org> on 2016/12/21 01:03:28 UTC, 0 replies.
- [GitHub] flink issue #3026: [FLINK-2980] [table] Support for GROUPING SETS clause in ... - posted by KurtYoung <gi...@git.apache.org> on 2016/12/21 01:31:24 UTC, 0 replies.
- [GitHub] flink issue #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS clause... - posted by KurtYoung <gi...@git.apache.org> on 2016/12/21 01:32:42 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-5370) build failure for unit test of FileInputFormatTest and GlobFilePathFilterTest - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/21 03:52:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5247) Fix incorrect check in allowedLateness() method. Make it a no-op for non-event time windows. - posted by "Rohit Agarwal (JIRA)" <ji...@apache.org> on 2016/12/21 04:31:58 UTC, 0 replies.
- [GitHub] flink issue #3012: [FLINK-2186] Add readCsvAsRow methods to CsvReader and sc... - posted by tonycox <gi...@git.apache.org> on 2016/12/21 07:24:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints - posted by "Roman Maier (JIRA)" <ji...@apache.org> on 2016/12/21 08:42:58 UTC, 0 replies.
- [GitHub] flink pull request #3036: [FLINK-5368] Throw exception if kafka topic doesn'... - posted by HungUnicorn <gi...@git.apache.org> on 2016/12/21 10:26:52 UTC, 4 replies.
- [jira] [Commented] (FLINK-5368) Let Kafka consumer show something when it fails to read one topic out of topic list - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/21 10:26:58 UTC, 5 replies.
- [jira] [Created] (FLINK-5377) Improve savepoint docs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/21 11:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5378) Update Scopt version to 3.5.0 - posted by "Lorenz Bühmann (JIRA)" <ji...@apache.org> on 2016/12/21 11:34:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5378) Update Scopt version to 3.5.0 - posted by "Lorenz Bühmann (JIRA)" <ji...@apache.org> on 2016/12/21 11:36:58 UTC, 0 replies.
- [GitHub] flink issue #3036: [FLINK-5368] Throw exception if kafka topic doesn't exist - posted by DieBauer <gi...@git.apache.org> on 2016/12/21 12:03:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/21 13:29:58 UTC, 3 replies.
- [jira] [Updated] (FLINK-1583) TaskManager reregistration in case of a restart - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/21 13:33:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5379) Flink CliFrontend does not return when not logged in with kerberos - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 13:57:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5379) Flink CliFrontend does not return when not logged in with kerberos - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 13:58:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5380) Number of outgoing records not reported in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 14:33:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5380) Number of outgoing records not reported in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 14:34:58 UTC, 0 replies.
- [GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te... - posted by fhueske <gi...@git.apache.org> on 2016/12/21 15:26:20 UTC, 19 replies.
- [jira] [Updated] (FLINK-1439) Enable all YARN tests on Travis - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/21 15:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5381) Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 15:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5382) Taskmanager log download button causes 404 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 15:39:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5383) TaskManager fails with SIGBUS when loading RocksDB - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 16:07:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4987) Harden slot pool logic - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/21 16:23:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4339) Implement Slot Pool Core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/21 16:23:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3150) Make YARN container invocation configurable - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/21 16:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5384) clean up jira issues - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/21 17:23:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5175) StreamExecutionEnvironment's set function return `this` instead of void - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/22 00:27:58 UTC, 0 replies.
- [GitHub] flink pull request #3037: Flink-4450 update storm version to 1.0 - posted by liuyuzhong7 <gi...@git.apache.org> on 2016/12/22 05:10:07 UTC, 0 replies.
- [jira] [Created] (FLINK-5385) Add a help function to create Row - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/22 06:10:58 UTC, 0 replies.
- [GitHub] flink pull request #3038: [FLINK-5385] [core] Add a help function to create ... - posted by wuchong <gi...@git.apache.org> on 2016/12/22 06:26:05 UTC, 3 replies.
- [jira] [Commented] (FLINK-5385) Add a help function to create Row - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/22 06:26:58 UTC, 5 replies.
- [jira] [Updated] (FLINK-5384) clean up jira issues - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/22 07:19:58 UTC, 8 replies.
- [jira] [Created] (FLINK-5386) Refacturing Window Clause - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/12/22 07:43:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5386) Refacturing Window Clause - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/12/22 07:50:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5387) Lightweight Event Time Window - posted by "Syinchwun Leo (JIRA)" <ji...@apache.org> on 2016/12/22 08:44:58 UTC, 0 replies.
- [GitHub] flink issue #3031: [FLINK-4616] Added functionality through which watermarks... - posted by MayerRoman <gi...@git.apache.org> on 2016/12/22 09:01:54 UTC, 0 replies.
- [GitHub] flink issue #2891: [FLINK-5129] make the BlobServer use a distributed file s... - posted by NicoK <gi...@git.apache.org> on 2016/12/22 09:30:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-5129) make the BlobServer use a distributed file system - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/22 09:30:58 UTC, 0 replies.
- [GitHub] flink issue #3038: [FLINK-5385] [core] Add a help function to create Row - posted by fhueske <gi...@git.apache.org> on 2016/12/22 09:54:56 UTC, 1 replies.
- [jira] [Closed] (FLINK-5308) download links to previous releases are incomplete - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/22 15:57:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5348) Support custom field names for RowTypeInfo - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/22 16:55:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5385) Add a help function to create Row - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/22 16:55:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5386) Refactoring Window Clause - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/12/23 02:59:58 UTC, 0 replies.
- [GitHub] flink issue #3027: [FLINK-5358] add RowTypeInfo exctraction in TypeExtractor - posted by tonycox <gi...@git.apache.org> on 2016/12/23 07:20:14 UTC, 2 replies.
- [jira] [Updated] (FLINK-5360) Fix arguments names in WindowedStream - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 08:31:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 08:45:59 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 08:45:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4719) KryoSerializer random exception - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 09:04:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 09:15:58 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4042) TwitterStream example does not work - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 09:23:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 09:25:58 UTC, 0 replies.
- [GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ... - posted by mushketyk <gi...@git.apache.org> on 2016/12/23 10:34:13 UTC, 55 replies.
- [jira] [Comment Edited] (FLINK-4042) TwitterStream example does not work - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 12:25:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4042) TwitterStream example does not work - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 12:25:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/23 12:30:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 12:32:58 UTC, 0 replies.
- [GitHub] flink issue #3039: [FLINK-5280] Update TableSource to support nested data - posted by mushketyk <gi...@git.apache.org> on 2016/12/23 12:50:15 UTC, 4 replies.
- [jira] [Created] (FLINK-5388) Remove private access of edges and vertices of Gelly Graph class - posted by "wouter ligtenberg (JIRA)" <ji...@apache.org> on 2016/12/23 13:25:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/23 13:28:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 14:06:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 14:06:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 14:06:58 UTC, 0 replies.
- [GitHub] flink pull request #3040: [FLINK-3850] Add forward field annotations to Data... - posted by NickolayVasilishin <gi...@git.apache.org> on 2016/12/23 14:16:48 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5382) Taskmanager log download button causes 404 - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2016/12/23 14:47:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5380) Number of outgoing records not reported in web interface - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2016/12/23 14:47:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5375) Fix watermark documentation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/23 15:02:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5233) Upgrade Jackson version because of class loader leak - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/23 15:02:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5227) Add warning to include flink-table in job fat jars - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/23 15:03:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5302) Log failure cause at Execution - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/23 15:03:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5210) Failing performCheckpoint method causes task to fail - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/23 15:04:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery. - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/23 15:04:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 15:16:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 15:16:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 15:39:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5388) Remove private access of edges and vertices of Gelly Graph class - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 15:41:58 UTC, 4 replies.
- [GitHub] flink pull request #3041: Flink 5084 tmp - posted by mtunique <gi...@git.apache.org> on 2016/12/23 17:27:18 UTC, 1 replies.
- [jira] [Closed] (FLINK-5180) Include blocked on bounded queue length in back pressure stats - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/23 19:25:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4131) Confusing error for out dated RequestPartitionState - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/23 19:27:58 UTC, 0 replies.
- [GitHub] flink pull request #3042: [FLINK-4410] Expose more fine grained checkpoint s... - posted by uce <gi...@git.apache.org> on 2016/12/23 20:39:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4410) Report more information about operator checkpoints - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/23 20:39:58 UTC, 4 replies.
- [jira] [Assigned] (FLINK-5388) Remove private access of edges and vertices of Gelly Graph class - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 20:50:58 UTC, 0 replies.
- [GitHub] flink issue #3042: [FLINK-4410] Expose more fine grained checkpoint statisti... - posted by StephanEwen <gi...@git.apache.org> on 2016/12/23 21:01:48 UTC, 3 replies.
- [jira] [Commented] (FLINK-4088) Add interface to save and load TableSources - posted by "Minudika Malshan (JIRA)" <ji...@apache.org> on 2016/12/23 21:10:58 UTC, 3 replies.
- [jira] [Created] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 22:30:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 22:35:58 UTC, 2 replies.
- [GitHub] flink issue #3040: [FLINK-3850] Add forward field annotations to DataSet - posted by fhueske <gi...@git.apache.org> on 2016/12/23 23:05:03 UTC, 0 replies.
- [jira] [Updated] (FLINK-4088) Add interface to save and load TableSources - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/23 23:12:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5379) Flink CliFrontend does not return when not logged in with kerberos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/23 23:29:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/24 00:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/24 01:05:58 UTC, 0 replies.
- [GitHub] flink pull request #3043: Bugfix/flink dist opt scala version - posted by whitelilis <gi...@git.apache.org> on 2016/12/25 13:44:31 UTC, 1 replies.
- [jira] [Created] (FLINK-5392) flink-dist build failed when change scala version to 2.11 - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/12/26 01:56:58 UTC, 0 replies.
- [GitHub] flink pull request #3043: [FLINK-5392] flink-dist build failed when change s... - posted by whitelilis <gi...@git.apache.org> on 2016/12/26 02:18:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-5392) flink-dist build failed when change scala version to 2.11 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/26 02:18:58 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-5392) flink-dist build failed when change scala version to 2.11 - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/12/26 02:20:58 UTC, 0 replies.
- [GitHub] flink issue #3022: [FLINK-5360] Fix argument names in WindowedStream - posted by xhumanoid <gi...@git.apache.org> on 2016/12/26 06:12:12 UTC, 1 replies.
- [jira] [Created] (FLINK-5393) Apache flink for IOT - posted by "suhasjk (JIRA)" <ji...@apache.org> on 2016/12/26 06:59:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4042) TwitterStream example does not work - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/26 07:37:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints - posted by "Roman Maier (JIRA)" <ji...@apache.org> on 2016/12/26 09:11:58 UTC, 0 replies.
- [GitHub] flink pull request #3044: [FLINK-5388] Change private Graph.() to prot... - posted by tonycox <gi...@git.apache.org> on 2016/12/26 09:13:35 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph() - posted by "Roman Maier (JIRA)" <ji...@apache.org> on 2016/12/26 09:23:58 UTC, 0 replies.
- [GitHub] flink pull request #3045: [FLINK-5390] [yarn] Fix for proper closing input a... - posted by MayerRoman <gi...@git.apache.org> on 2016/12/26 13:31:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/26 13:31:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3849) Add FilterableTableSource interface and translation rule - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/26 14:53:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5382) Taskmanager log download button causes 404 - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2016/12/26 16:27:58 UTC, 1 replies.
- [GitHub] flink pull request #3046: [FLINK-5386][Table API & SQL] refactoring Window C... - posted by sunjincheng121 <gi...@git.apache.org> on 2016/12/27 05:16:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-5386) Refactoring Window Clause - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/27 05:16:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4670) Add watch mechanism on current RPC framework - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/12/27 09:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5394) the estimateRowCount method of DataSetCalc didn't work - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/12/27 11:05:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5394) the estimateRowCount method of DataSetCalc didn't work - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/12/27 11:09:58 UTC, 4 replies.
- [jira] [Created] (FLINK-5395) support locally build distribution by script create_release_files.sh - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/27 12:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5396) flink-dist replace scala version in opt.xml by change-scala-version.sh - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/27 12:26:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5396) flink-dist replace scala version in opt.xml by change-scala-version.sh - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/27 12:29:58 UTC, 0 replies.
- [GitHub] flink pull request #3047: [FLINK-5396] [Build System] flink-dist replace sca... - posted by shijinkui <gi...@git.apache.org> on 2016/12/27 12:33:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-5396) flink-dist replace scala version in opt.xml by change-scala-version.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/27 12:33:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5396) flink-dist replace scala version in opt.xml by change-scala-version.sh - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/27 14:39:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/27 14:57:58 UTC, 0 replies.
- [GitHub] flink pull request #3048: Clarified the import path of the Breeze DenseVecto... - posted by Fokko <gi...@git.apache.org> on 2016/12/27 15:10:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-5395) support locally build distribution by script create_release_files.sh - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/27 15:50:58 UTC, 0 replies.
- [GitHub] flink pull request #3049: [FLINK-5395] [Build System] support locally build ... - posted by shijinkui <gi...@git.apache.org> on 2016/12/27 15:53:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-5395) support locally build distribution by script create_release_files.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/27 15:53:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4920) Add a Scala Function Gauge - posted by "Pattarawat Chormai (JIRA)" <ji...@apache.org> on 2016/12/27 21:03:58 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4920) Add a Scala Function Gauge - posted by "Pattarawat Chormai (JIRA)" <ji...@apache.org> on 2016/12/27 21:04:58 UTC, 0 replies.
- [GitHub] flink issue #3048: Clarified the import path of the Breeze DenseVector - posted by Fokko <gi...@git.apache.org> on 2016/12/27 23:01:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-4758) Remove IOReadableWritable from classes where not needed - posted by "jiwengang (JIRA)" <ji...@apache.org> on 2016/12/28 06:46:58 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4758) Remove IOReadableWritable from classes where not needed - posted by "jiwengang (JIRA)" <ji...@apache.org> on 2016/12/28 06:50:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-3615) Add support for non-native SQL types - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/12/28 08:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5397) Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/12/28 08:56:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5397) Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/12/28 08:58:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4540) Detached job execution may prevent cluster shutdown - posted by "Roman Maier (JIRA)" <ji...@apache.org> on 2016/12/28 09:39:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4641) Support branching CEP patterns - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/12/28 10:03:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5397) Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/28 11:50:58 UTC, 0 replies.
- [GitHub] flink pull request #3050: [FLINK-5397] Do not replace ObjectStreamClass on d... - posted by StefanRRichter <gi...@git.apache.org> on 2016/12/28 11:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-5397) Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/28 11:55:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5398) Exclude generated files in module flink-batch-connectors in license checking - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/12/29 02:18:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5399) Add more information to checkpoint result of TriggerSavepointSuccess - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/29 04:52:58 UTC, 0 replies.
- [GitHub] flink pull request #3051: Flink 5399 - posted by shijinkui <gi...@git.apache.org> on 2016/12/29 06:50:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-5399) Add more information to checkpoint result of TriggerSavepointSuccess - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/29 06:50:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5345) IOManager failed to properly clean up temp file directory - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/29 10:10:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5398) Exclude generated files in module flink-batch-connectors in license checking - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/29 11:02:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3 - posted by "Martin Grotzke (JIRA)" <ji...@apache.org> on 2016/12/29 13:49:58 UTC, 2 replies.
- [GitHub] flink pull request #3052: Swap the pattern matching order - posted by Fokko <gi...@git.apache.org> on 2016/12/29 22:53:29 UTC, 0 replies.
- [GitHub] flink issue #2885: [FLINK-1707] Affinity propagation - posted by joseprupi <gi...@git.apache.org> on 2016/12/30 00:55:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/30 00:55:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5400) Add accessor to folding states in RuntimeContext - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/12/30 02:10:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5400) Add accessor to folding states in RuntimeContext - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/12/30 02:10:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/30 02:43:58 UTC, 0 replies.
- [GitHub] flink pull request #3053: [FLINK-5400] Add accessor to folding states in Run... - posted by shixiaogang <gi...@git.apache.org> on 2016/12/30 03:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-5400) Add accessor to folding states in RuntimeContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/30 03:38:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5398) Exclude generated files in module flink-batch-connectors in license checking - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/12/30 03:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5401) Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/30 09:29:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/30 09:32:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/30 09:33:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5401) Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/30 09:33:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4920) Add a Scala Function Gauge - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/30 15:14:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3 - posted by "Martin Grotzke (JIRA)" <ji...@apache.org> on 2016/12/30 16:54:58 UTC, 1 replies.