You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [DISCUSS] Table API / SQL indicators for event and processing time - posted by Xingcan Cui <xi...@gmail.com> on 2017/03/01 02:40:41 UTC, 12 replies.
- [Dev] Issue related to using Flink DataSet methods - posted by Pawan Manishka Gunarathna <pa...@gmail.com> on 2017/03/01 04:17:54 UTC, 5 replies.
- Re: [DISCUSS] Gelly planning for release 1.3 and roadmap - posted by Vasiliki Kalavri <va...@gmail.com> on 2017/03/01 06:57:42 UTC, 3 replies.
- [jira] [Created] (FLINK-5940) ZooKeeperCompletedCheckpointStore cannot handle broken state handles - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/01 15:43:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5941) Let handlers take part in job archiving - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/01 16:45:46 UTC, 0 replies.
- Re: [DISCUSS] Code style / checkstyle - posted by Henry Saputra <he...@gmail.com> on 2017/03/01 16:57:58 UTC, 3 replies.
- [jira] [Created] (FLINK-5942) Harden ZooKeeperStateHandleStore to deal with corrupted data - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/01 17:10:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/01 17:34:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5944) Flink should support reading Snappy Files - posted by "Ilya Ganelin (JIRA)" <ji...@apache.org> on 2017/03/01 18:41:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5945) Close function in OuterJoinOperatorBase#executeOnCollections - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/03/01 20:19:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5946) Kinesis Producer uses KPL that orphans threads that consume 100% CPU - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2017/03/02 00:49:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5947) NullPointerException in ContinuousProcessingTimeTrigger.clear() - posted by "Xiaojun Jin (JIRA)" <ji...@apache.org> on 2017/03/02 02:06:45 UTC, 0 replies.
- About the ACL of Zookeeper - posted by Zhangrucong <zh...@huawei.com> on 2017/03/02 02:09:46 UTC, 3 replies.
- [jira] [Created] (FLINK-5948) Error in Python zip_with_index documentation - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2017/03/02 03:48:46 UTC, 0 replies.
- Re: Visualizing topologies - posted by Ken Krugler <kk...@transpac.com> on 2017/03/02 04:30:23 UTC, 0 replies.
- [jira] [Created] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/02 06:15:46 UTC, 0 replies.
- [jira] [Created] (FLINK-5950) create an example for async-io with an http client - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2017/03/02 09:21:45 UTC, 0 replies.
- Re: [DISCUSS] Flink ML roadmap - posted by Roberto Bentivoglio <ro...@radicalbit.io> on 2017/03/02 09:52:25 UTC, 6 replies.
- [jira] [Created] (FLINK-5951) Register legacy windowOp timers with timer service in the restoreState(). - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/03/02 10:22:45 UTC, 0 replies.
- Dataset and eager scheduling - posted by CPC <ac...@gmail.com> on 2017/03/02 10:52:03 UTC, 2 replies.
- Re: [DISCUSS] Side Outputs and Split/Select - posted by Robert Metzger <rm...@apache.org> on 2017/03/02 11:05:39 UTC, 4 replies.
- [jira] [Created] (FLINK-5952) JobCancellationWithSavepointHandlersTest uses deprecated JsonNode#getValuesAsText - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/02 14:32:45 UTC, 0 replies.
- Dataset and select/split functionality - posted by CPC <ac...@gmail.com> on 2017/03/02 15:31:43 UTC, 2 replies.
- [jira] [Created] (FLINK-5953) Sample Kinesis Scala code doesn't work - posted by "Matthew Billson (JIRA)" <ji...@apache.org> on 2017/03/02 17:38:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5954) Always assign names to the window in the Stream SQL APi - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/03/03 01:38:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5955) Merging a list of buffered records will have problem when ObjectReuse is turned on - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/03/03 02:35:45 UTC, 0 replies.
- 回复:Dataset and eager scheduling - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2017/03/03 07:41:05 UTC, 0 replies.
- [jira] [Created] (FLINK-5956) Add retract method into the aggregateFunction - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/03/03 09:06:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5957) Remove `getAccumulatorType` method from `AggregateFunction` - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/03 10:31:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5958) Asyncronous snapshots for heap-based keyed state backends - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/03/03 10:53:45 UTC, 0 replies.
- Machine Learning on Flink - Next steps - posted by Theodore Vasiloudis <th...@gmail.com> on 2017/03/03 12:33:40 UTC, 22 replies.
- [jira] [Created] (FLINK-5959) Verify that mesos-appmaster.sh respects env.java.opts(.jobmanager) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/03 15:13:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5960) Make CheckpointCoordinator less blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/03 16:09:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5961) Queryable State is broken for HeapKeyedStateBackend - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/03/03 17:25:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5962) Cancel checkpoint canceller tasks in CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/03 17:29:45 UTC, 0 replies.
- Incremental checkpoint branch - posted by Vishnu Viswanath <vi...@gmail.com> on 2017/03/03 21:14:04 UTC, 4 replies.
- [jira] [Created] (FLINK-5963) Remove preparation mapper of DataSetAggregate - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/03/03 22:37:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5964) Change TypeSerializers to allow construction of immutable types - posted by "Jayson Minard (JIRA)" <ji...@apache.org> on 2017/03/04 13:05:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5965) Typo on DropWizard wrappers - posted by "Francisco Sokol (JIRA)" <ji...@apache.org> on 2017/03/04 16:38:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5966) Document Running Flink on Kubernetes - posted by "StephenWithPH (JIRA)" <ji...@apache.org> on 2017/03/06 01:40:33 UTC, 0 replies.
- Re: [DISCUSS] Planning Release 1.3 - posted by Robert Metzger <rm...@apache.org> on 2017/03/06 09:55:27 UTC, 1 replies.
- [jira] [Created] (FLINK-5967) Document AggregatingState - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/06 10:16:32 UTC, 0 replies.
- [jira] [Created] (FLINK-5968) Document WindowedStream.aggregate() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/06 10:17:32 UTC, 0 replies.
- [jira] [Created] (FLINK-5969) Add savepoint backwards compatibility tests from 1.2 to 1.3 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/06 10:50:33 UTC, 0 replies.
- [jira] [Created] (FLINK-5970) Job-/TaskManagerStartupTest may run indefinitely - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/06 11:11:32 UTC, 0 replies.
- [DISCUSS] FLIP-17 Side Inputs - posted by Aljoscha Krettek <al...@apache.org> on 2017/03/06 14:18:20 UTC, 18 replies.
- TRAVIS error? - posted by Radu Tudoran <ra...@huawei.com> on 2017/03/06 15:10:21 UTC, 0 replies.
- [jira] [Created] (FLINK-5971) JobLeaderIdService should time out registered jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/06 15:26:32 UTC, 0 replies.
- [jira] [Created] (FLINK-5972) Don't allow shrinking merging windows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/06 16:09:32 UTC, 0 replies.
- [jira] [Created] (FLINK-5973) check whether the direct memory size is always correctly calculated - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/03/06 17:45:33 UTC, 0 replies.
- [jira] [Created] (FLINK-5974) Support Mesos DNS - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/03/06 20:01:32 UTC, 0 replies.
- [jira] [Created] (FLINK-5975) Mesos should support adding volumes to launched taskManagers - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2017/03/07 03:49:32 UTC, 0 replies.
- [jira] [Created] (FLINK-5976) refactoring remove duplicate Tokenizer in flink-test - posted by "liuyuzhong7 (JIRA)" <ji...@apache.org> on 2017/03/07 07:28:32 UTC, 0 replies.
- [jira] [Created] (FLINK-5977) Rename MAX_ATTEMPTS_HISTORY_SIZE key - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/07 10:39:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5978) JM WebFrontend address ConfigOption is defined in ConfigConstants - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/07 10:41:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5979) Backwards compatibility for HeapKeyedStateBackend serialization format (1.2 -> 1.3) - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/03/07 10:59:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5980) Expose max-parallelism value in RuntimeContext - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2017/03/07 11:12:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5981) SSL version and ciper suites cannot be constrained as configured - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/03/07 11:22:37 UTC, 0 replies.
- [jira] [Created] (FLINK-5982) Refactor AbstractInvokable and StatefulTask - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/03/07 12:28:37 UTC, 0 replies.
- [jira] [Created] (FLINK-5983) Replace for/foreach/map in aggregates by while loops - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/03/07 14:50:38 UTC, 0 replies.
- Re: FLINK-5734 : Code Generation for NormalizedKeySorter - posted by "pat.chormai" <pa...@gmail.com> on 2017/03/07 15:06:05 UTC, 1 replies.
- [jira] [Created] (FLINK-5984) Allow reusing of accumulators in AggregateFunction - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/03/07 15:43:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2017/03/07 16:07:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5986) Add forwarded field annotations to batch (window) aggregate operators - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/03/07 16:46:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5987) Upgrade zookeeper dependency to 3.4.8 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/07 17:14:37 UTC, 0 replies.
- [jira] [Created] (FLINK-5988) Show start-cluster.sh failures - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2017/03/07 22:22:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5989) Protobuf in akka needs to be shaded - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/03/08 03:39:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5990) Add event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/08 06:17:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5991) Expose Broadcast Operator State through public APIs - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/08 06:41:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5992) Enable file registration at distributed cache in stream execution environment - posted by "Zohar Mizrahi (JIRA)" <ji...@apache.org> on 2017/03/08 08:16:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5993) Add section about Azure deployment - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/03/08 09:41:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5994) Add Janino to flink-table JAR file - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/03/08 09:48:37 UTC, 0 replies.
- [jira] [Created] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/08 10:01:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5996) Jobmanager HA should not crash on lost ZK node - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2017/03/08 10:03:38 UTC, 0 replies.
- [jira] [Created] (FLINK-5997) Docker build tools should inline GPG key to verify HTTP Flink release download - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2017/03/08 11:26:37 UTC, 0 replies.
- [jira] [Created] (FLINK-5998) Un-fat Hadoop from Flink fat jar - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/03/08 14:10:37 UTC, 0 replies.
- [jira] [Created] (FLINK-5999) MiniClusterITCase.runJobWithMultipleRpcServices fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/03/08 14:26:38 UTC, 0 replies.
- [jira] [Created] (FLINK-6000) Can not start HA cluster with start-cluster.sh - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/03/08 15:06:38 UTC, 0 replies.
- [jira] [Created] (FLINK-6001) NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness - posted by "Vladislav Pernin (JIRA)" <ji...@apache.org> on 2017/03/08 17:00:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6002) Setup: Download and Start Flink/MacOS X in Quickstart page is not rendered correctly - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/03/08 18:33:38 UTC, 0 replies.
- Flink 1.2 / YARN on Secure MapR Cluster - posted by dschexna <ds...@mapr.com> on 2017/03/08 22:50:54 UTC, 1 replies.
- [jira] [Created] (FLINK-6003) Change docker image to be based on the openjdk one (debian+alpine) - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2017/03/08 22:51:38 UTC, 0 replies.
- [jira] [Created] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/09 06:21:37 UTC, 0 replies.
- [jira] [Created] (FLINK-6005) unit test ArrayList initializations without default size - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/03/09 11:23:38 UTC, 0 replies.
- [jira] [Created] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/09 12:16:38 UTC, 0 replies.
- [jira] [Created] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/03/09 15:39:37 UTC, 0 replies.
- [jira] [Created] (FLINK-6008) collection of BlobServer improvements - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/03/09 17:42:37 UTC, 0 replies.
- [jira] [Created] (FLINK-6009) Deprecate DataSetUtils#checksumHashCode - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/03/09 20:19:38 UTC, 0 replies.
- [jira] [Created] (FLINK-6010) Documentation: correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/03/09 20:51:38 UTC, 0 replies.
- [jira] [Created] (FLINK-6011) Support TUMBLE, HOP, SESSION window in streaming SQL - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/03/09 22:05:38 UTC, 0 replies.
- [jira] [Created] (FLINK-6012) Support WindowStart / WindowEnd functions in stream SQL - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/03/09 22:25:37 UTC, 0 replies.
- [jira] [Created] (FLINK-6013) Add Datadog HTTP metrics reporter - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/03/10 01:35:37 UTC, 0 replies.
- [jira] [Created] (FLINK-6014) Allow the registration of state objects in checkpoints - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/03/10 02:13:37 UTC, 0 replies.
- [jira] [Created] (FLINK-6015) "Row too short" when reading CSV line with empty last field (i.e. ending in comma) - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/10 03:29:37 UTC, 0 replies.
- [jira] [Created] (FLINK-6016) Newlines should be valid in quoted strings in CSV - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/10 03:51:37 UTC, 0 replies.
- Streaming Exception - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2017/03/10 04:25:14 UTC, 0 replies.
- [jira] [Created] (FLINK-6017) CSV reader does not support quoted double quotes - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/10 04:32:37 UTC, 0 replies.
- [jira] [Created] (FLINK-6018) Minor improvements about `AbstractKeyedStateBackend#getPartitionedState` method - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/10 04:34:38 UTC, 0 replies.
- [jira] [Created] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/10 08:12:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6020) Blob Server cannot hanlde multiple job sumits(with same content) parallelly - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/03/10 08:33:04 UTC, 0 replies.
- Flink CSV parsing - posted by Flavio Pompermaier <po...@okkam.it> on 2017/03/10 10:28:21 UTC, 3 replies.
- [jira] [Created] (FLINK-6021) Downloads page references "Hadoop 1 version" which isn't an option - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2017/03/10 10:29:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6022) Improve support for Avro GenericRecord - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/03/10 10:51:04 UTC, 0 replies.
- Re: [DISCUSS] Project build time and possible restructuring - posted by Till Rohrmann <tr...@apache.org> on 2017/03/10 11:20:41 UTC, 24 replies.
- [jira] [Created] (FLINK-6023) Fix Scala snippet into Process Function (Low-level Operations) Doc - posted by "Mauro Cortellazzi (JIRA)" <ji...@apache.org> on 2017/03/10 11:55:04 UTC, 0 replies.
- Scala / Java window issue - posted by Radu Tudoran <ra...@huawei.com> on 2017/03/10 17:46:14 UTC, 1 replies.
- [jira] [Created] (FLINK-6024) Need more fine-grained info for "InvalidProgramException: This type (...) cannot be used as key" - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/11 07:32:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6025) User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/11 10:59:04 UTC, 0 replies.
- How to register and send custom metrics from Flink? - posted by Bowen Li <bo...@offerupnow.com> on 2017/03/13 07:48:55 UTC, 2 replies.
- [jira] [Created] (FLINK-6026) Cannot name flatMap operations - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/13 08:09:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6027) Ignore the exception thrown by the subsuming of old completed checkpoints - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/03/13 08:49:11 UTC, 0 replies.
- [jira] [Created] (FLINK-6028) Unnamed operations in main method logged as "main(null:-1)" - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/13 08:53:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6029) Strange linebreaks in web dashboard graph view make it hard to read text - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/13 09:04:04 UTC, 0 replies.
- Request permissions for wiki - posted by Pattarawat Chormai <pa...@gmail.com> on 2017/03/13 10:29:54 UTC, 1 replies.
- [jira] [Created] (FLINK-6030) Job metrics are not updated correctly - posted by "Avihai Berkovitz (JIRA)" <ji...@apache.org> on 2017/03/13 12:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6031) Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/03/13 13:32:41 UTC, 0 replies.
- Re: Frontend classpath issue - posted by Robert Metzger <rm...@apache.org> on 2017/03/13 13:33:16 UTC, 1 replies.
- Wrong argument used in StreamTask when user-defined backend is used - posted by Vladislav Pernin <vl...@gmail.com> on 2017/03/13 15:28:40 UTC, 1 replies.
- [jira] [Created] (FLINK-6032) CEP-Clean up the operator state when not needed. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/03/13 19:36:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6033) Support UNNEST query in the stream SQL api - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/03/13 20:47:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6034) Add KeyedStateHandle for the snapshots in keyed streams - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/03/14 03:38:41 UTC, 0 replies.
- Flink as a Service (FaaS) - posted by Chen Qin <qi...@gmail.com> on 2017/03/14 06:13:22 UTC, 6 replies.
- [jira] [Created] (FLINK-6035) The method name(String) is undefined for the type UnsortedGrouping - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/14 06:25:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6036) Let catalog support partition - posted by "jingzhang (JIRA)" <ji...@apache.org> on 2017/03/14 06:59:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6037) the estimateRowCount method of DataSetCalc didn't work in SQL - posted by "jingzhang (JIRA)" <ji...@apache.org> on 2017/03/14 07:01:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6038) Add links to Apache Bahir Flink streaming connectors - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/14 07:43:41 UTC, 0 replies.
- [DISCUSS] Official policy for release maintenance - posted by Ismaël Mejía <ie...@gmail.com> on 2017/03/14 08:30:43 UTC, 5 replies.
- [jira] [Created] (FLINK-6039) Row of TableFunction should support flexible number of fields - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/03/14 08:41:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6040) DataStreamUserDefinedFunctionITCase occasionally fails - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/03/14 10:06:41 UTC, 0 replies.
- [DISCUSS] Release Flink 1.1.5 / Flink 1.2.1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/03/14 11:02:53 UTC, 21 replies.
- FLINK-5860 assign to me - posted by Yaroslav Mykhaylov <ya...@gmail.com> on 2017/03/14 12:10:24 UTC, 1 replies.
- [jira] [Created] (FLINK-6041) Move StreamingFunctionUtils to org.apache.flink.streaming.util - posted by "liuyuzhong7 (JIRA)" <ji...@apache.org> on 2017/03/14 12:21:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6042) Display last n exceptions/causes for job restarts in Web UI - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/14 12:23:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6043) Display time when exceptions/root cause of failure happened - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/14 12:35:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6044) TypeSerializerSerializationProxy.read() doesn't verify the read buffer length - posted by "Avihai Berkovitz (JIRA)" <ji...@apache.org> on 2017/03/14 12:48:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6045) FLINK_CONF_DIR has to be set even though specifying --configDir - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/14 12:49:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6046) Add support for oversized messages during deployment - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/03/14 13:44:41 UTC, 0 replies.
- [DISCUSS] FLIP-18: Code Generation for improving sorting performance - posted by Pattarawat Chormai <pa...@gmail.com> on 2017/03/14 15:10:14 UTC, 1 replies.
- [jira] [Created] (FLINK-6047) Master Jira for "Retraction for Flink Streaming" - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/03/14 15:50:41 UTC, 0 replies.
- [Discuss] Retraction for Flink Streaming - posted by Shaoxuan Wang <ws...@gmail.com> on 2017/03/14 15:53:14 UTC, 2 replies.
- [jira] [Created] (FLINK-6048) Asynchronous snapshots for heap-based operator state backends - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/03/14 15:53:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6049) Parallelize execution of (async) snapshots in AsyncCheckpointRunnable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/03/14 16:07:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6050) Improve failure reporting when using Future.thenAccept - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/14 16:27:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6051) Wrong metric scope names in documentation - posted by "Joshua Griffith (JIRA)" <ji...@apache.org> on 2017/03/14 17:02:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/14 19:30:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/03/14 22:13:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6054) Add new state backend that dynamically stores data in memory and external storage - posted by "Sergio Esteves (JIRA)" <ji...@apache.org> on 2017/03/14 23:24:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6055) Supported setting timers on a Non-Keyed Stream - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/15 02:42:41 UTC, 0 replies.
- Question: RemoteStreamEnvironment submit in detach mode. - posted by Liangfei Su <su...@gmail.com> on 2017/03/15 07:19:01 UTC, 3 replies.
- [jira] [Created] (FLINK-6056) apache-rat exclude flink directory in tools - posted by "jinkuishi (JIRA)" <ji...@apache.org> on 2017/03/15 08:04:49 UTC, 0 replies.
- [jira] [Created] (FLINK-6057) Better default needed for num network buffers - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/15 09:01:41 UTC, 0 replies.
- 回复:[jira] [Created] (FLINK-6057) Better default needed for num network buffers - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2017/03/15 09:21:53 UTC, 0 replies.
- [jira] [Created] (FLINK-6058) Don't read DEFAULT_PARALLELISM from GlobalConfiguration - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/15 10:02:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6059) Reject DataSet and DataStream without RowTypeInformation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/03/15 10:15:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6060) not exist class referance in the scala function annotation - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/03/15 10:41:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6061) NPE on TypeSerializer.serialize with a RocksDBStateBackend calling state.entries in the open() function - posted by "Vladislav Pernin (JIRA)" <ji...@apache.org> on 2017/03/15 10:44:41 UTC, 1 replies.
- [POLL] Who still uses Java 7 with Flink ? - posted by Stephan Ewen <se...@apache.org> on 2017/03/15 11:30:24 UTC, 5 replies.
- [jira] [Created] (FLINK-6062) Re-read a Kafka topic at the reception of an event - posted by "Julien Preisner (JIRA)" <ji...@apache.org> on 2017/03/15 12:28:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6063) HA Configuration doesn't work with Flink 1.2 - posted by "Razvan (JIRA)" <ji...@apache.org> on 2017/03/15 14:35:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6064) wrong BlobServer hostname in TaskExecutor - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/03/15 15:17:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6065) Make TransportClient for ES5 pluggable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/03/15 17:48:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6066) Separate logical and physical RelNode layer in Flink - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/03/16 06:38:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6067) ProjectNode and FilterNode cannot merge in Batch TableAPI - posted by "jingzhang (JIRA)" <ji...@apache.org> on 2017/03/16 06:52:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6068) Support If() in built in function of TableAPI - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/03/16 08:07:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6069) Add documentation CEP - Watermarks - posted by "Patrick Pircher (JIRA)" <ji...@apache.org> on 2017/03/16 08:34:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6070) Suggestion: add ComparableTuple types - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/16 08:54:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6071) Savepoints should not count in the number of retained checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/03/16 09:41:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6072) TestCase CheckpointStateRestoreTest::testSetState should be fail - posted by "Guowei Ma (JIRA)" <ji...@apache.org> on 2017/03/16 10:04:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6073) Support for SQL inner queries for proctime - posted by "radu (JIRA)" <ji...@apache.org> on 2017/03/16 13:20:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6074) Fix - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/16 13:26:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL - posted by "radu (JIRA)" <ji...@apache.org> on 2017/03/16 13:52:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6076) Let the HeartbeatManager interface extend HeartbeatTarget - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/16 13:58:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL - posted by "radu (JIRA)" <ji...@apache.org> on 2017/03/16 14:02:41 UTC, 0 replies.
- Future of Queryable State Feature - posted by Joe Olson <jo...@outlook.com> on 2017/03/16 14:33:36 UTC, 2 replies.
- Bumping API stability check version - posted by Greg Hogan <co...@greghogan.com> on 2017/03/16 14:37:43 UTC, 3 replies.
- [jira] [Created] (FLINK-6078) ZooKeeper based high availability services should not close the underlying CuratorFramework - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/16 14:50:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/16 14:58:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6080) Unclosed ObjectOutputStream in NFA#serialize() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/16 15:04:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6081) Offset/Fetch support for SQL Streaming - posted by "radu (JIRA)" <ji...@apache.org> on 2017/03/16 15:31:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition - posted by "radu (JIRA)" <ji...@apache.org> on 2017/03/16 15:39:41 UTC, 0 replies.
- Extended SQL support for Streaming - posted by Radu Tudoran <ra...@huawei.com> on 2017/03/16 15:46:38 UTC, 0 replies.
- [DISCUSS] Could we Improve tests time and stability? - posted by Dmytro Shkvyra <Dm...@epam.com> on 2017/03/16 16:06:31 UTC, 6 replies.
- [jira] [Created] (FLINK-6083) [TaskManager] Support readiness/liveness probes - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/03/16 16:21:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6084) Cassandra connector does not declare all dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/03/16 17:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6085) flink as micro service - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2017/03/16 18:16:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6086) Rework PythonSender/-Streamer generics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/16 22:25:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6087) The file-filter is only applied to directories in ContinuousFileMonitoringFunction - posted by "Yassine Marzougui (JIRA)" <ji...@apache.org> on 2017/03/16 22:53:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6088) java.lang.NoSuchFieldError: INSTANCE Issue with classloading - posted by "prabhat kumar (JIRA)" <ji...@apache.org> on 2017/03/17 00:40:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6089) Implement decoration phase for rewriting predicated logical plan after volcano optimization phase - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/03/17 03:59:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6090) Implement optimizer for retraction and turn on retraction for over window aggregate - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/03/17 04:00:43 UTC, 0 replies.
- [jira] [Created] (FLINK-6091) Implement and turn on the retraction for grouping window aggregate - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/03/17 04:01:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6093) Implement and turn on retraction for table sink - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/03/17 04:02:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6092) Implement and turn on retraction for table source - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/03/17 04:02:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6094) Implement and turn on retraction for stream-stream inner join - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/03/17 04:03:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6095) Introduce the SlotPoolOptions to config parameters for SlotPool - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/03/17 07:40:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6096) Refactor the migration of old versioned savepoints - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/03/17 08:09:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6097) Guaranteed the order of the extracted field references - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/17 08:20:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6098) Cassandra sink freezes after write error - posted by "Jakub Nowacki (JIRA)" <ji...@apache.org> on 2017/03/17 09:42:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6099) not able to auto infer the row type when getting informationn from jdbc vertica - posted by "naveen holla U (JIRA)" <ji...@apache.org> on 2017/03/17 09:45:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6100) Add documentation for Projectable and Filterable TableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/03/17 10:10:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6101) GroupBy fields with expression can not be selected either using original name or expression - posted by "lincoln.lee (JIRA)" <ji...@apache.org> on 2017/03/17 10:55:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6102) Update protobuf to latest version - posted by "Su Ralph (JIRA)" <ji...@apache.org> on 2017/03/17 11:09:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6103) LocalFileSystem rename() uses File.renameTo() - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2017/03/17 15:20:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6104) Unclosed WriteOptions in ListViaRangeSpeedMiniBenchmark#main() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/17 15:29:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6105) Properly handle InterruptedException - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/17 15:36:41 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.1.5 (RC1) - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/03/17 17:57:32 UTC, 3 replies.
- [jira] [Created] (FLINK-6106) Blob Server doesn't delete tmp fold when exit in HA mode. - posted by "Syinchwun Leo (JIRA)" <ji...@apache.org> on 2017/03/18 03:28:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6107) Add custom checkstyle for flink-streaming-java - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/18 06:59:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6108) Add sum(fieldName) to sum based on named POJO fields - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/18 07:00:47 UTC, 0 replies.
- [jira] [Created] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/18 07:23:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6110) Flink unnecessarily repeats shared work triggered by different blocking sinks, leading to massive inefficiency - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/18 09:12:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6111) Remove sleep after python process generation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/18 12:00:43 UTC, 0 replies.
- [jira] [Created] (FLINK-6112) Support new numerical functions when calcite release - posted by "Tao Meng (JIRA)" <ji...@apache.org> on 2017/03/18 12:43:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6113) Implement split/select with OutputTag - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2017/03/18 15:00:45 UTC, 0 replies.
- [jira] [Created] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/19 06:06:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/19 06:49:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6116) Watermarks don't work when unioning with same DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/19 06:59:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6117) 'zookeeper.sasl.disable' not takes effet when starting CuratorFramework - posted by "canbinzheng (JIRA)" <ji...@apache.org> on 2017/03/19 08:23:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6118) Chained operators forward watermark without checking - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/19 20:06:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6119) ClusterClient Detach Mode configurable in client-api - posted by "Su Ralph (JIRA)" <ji...@apache.org> on 2017/03/20 02:24:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6120) Implement heartbeat logic between JobMaster and ResourceManager - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/03/20 02:41:41 UTC, 0 replies.
- [Disuss]Permission of checkpoint directory - posted by "Wangtao (WangTao)" <wa...@huawei.com> on 2017/03/20 03:34:20 UTC, 1 replies.
- [jira] [Created] (FLINK-6121) Include TravisCI build status to README.md - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/03/20 07:33:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6122) Include TravisCI build status to README.md - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/03/20 07:33:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6123) Add support for the NOT pattern. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/03/20 09:20:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6124) support max/min aggregations for string type - posted by "Zhenghua Gao (JIRA)" <ji...@apache.org> on 2017/03/20 09:30:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6125) Commons httpclient is not shaded anymore in Flink 1.2 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/03/20 09:34:41 UTC, 0 replies.
- Re: [DISCUSS] deprecated function need more detail - posted by Stephan Ewen <se...@apache.org> on 2017/03/20 10:33:15 UTC, 1 replies.
- [jira] [Created] (FLINK-6126) Yet another conflict - posted by "Su Ralph (JIRA)" <ji...@apache.org> on 2017/03/20 10:36:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6127) Add MissingDeprecatedCheck to checkstyle - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/03/20 10:41:41 UTC, 0 replies.
- Fwd: [jira] [Updated] (FLINK-6126) Yet another conflict : guava - posted by Liangfei Su <su...@gmail.com> on 2017/03/20 10:59:39 UTC, 5 replies.
- [jira] [Created] (FLINK-6128) Optimize JVM options for improve test performance - posted by "Dmytro Shkvyra (JIRA)" <ji...@apache.org> on 2017/03/20 11:02:41 UTC, 0 replies.
- [DISCUSS] TravisCI status on GitHub Page - posted by Greg Hogan <co...@greghogan.com> on 2017/03/20 13:12:49 UTC, 6 replies.
- [jira] [Created] (FLINK-6129) MetricQueryService does not stop query actor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/20 13:22:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/20 15:17:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6131) Add side inputs for DataStream API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/20 15:43:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6132) Remove redundant code in CliFrontend.java - posted by "canbinzheng (JIRA)" <ji...@apache.org> on 2017/03/20 16:16:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6133) fix build status in README.md - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/03/20 16:52:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6134) Set UUID(0L, 0L) as default leader session id - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/20 17:19:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6135) Allowing adding inputs to StreamOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/20 17:29:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6136) Separate EmbeddedNonHaServices and NonHaServices - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/20 17:34:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6137) Add custom checkstyle for flink-cep - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/03/20 19:24:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6138) Improve UnboundedNonPartitionedProcessingOverProcessFunction - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/21 04:40:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6139) Documentation for building / preparing Flink for MapR - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/21 05:54:42 UTC, 0 replies.
- [ANNOUNCE] New committer: Theodore Vasiloudis - posted by Robert Metzger <rm...@apache.org> on 2017/03/21 08:35:11 UTC, 13 replies.
- Issue assign right - posted by zhengcanbin <zh...@huawei.com> on 2017/03/21 15:19:28 UTC, 3 replies.
- [jira] [Created] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/21 15:45:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6144) Port job manager related configuration options to ConfigOption - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/21 16:06:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6145) Add [non-partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/21 16:09:41 UTC, 0 replies.
- Re: [DISCUSS] FLIP-18: Code Generation for improving sorting performance - posted by Fabian Hueske <fh...@gmail.com> on 2017/03/21 19:46:02 UTC, 2 replies.
- [jira] [Created] (FLINK-6146) Incorrect function name given in exception thrown by DataSet.getType() - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/22 00:17:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6147) flink client can't detect cluster is down - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/03/22 03:10:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6148) The Zookeeper client occur SASL error when the sasl is disable - posted by "zhangrucong1982 (JIRA)" <ji...@apache.org> on 2017/03/22 03:58:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6149) add additional flink logical relation nodes - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/03/22 06:02:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6150) change DataSetCost to FlinkRelOptCost - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/03/22 06:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6151) The zookeeper occur a warning when one node of zookeeper server is down - posted by "zhangrucong1982 (JIRA)" <ji...@apache.org> on 2017/03/22 06:10:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6152) Yarn session CLI tries to shut cluster down too agressively in interative mode - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/03/22 06:12:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6153) Fix documentation about which version to download if don't care hadoop version - posted by "Tao Meng (JIRA)" <ji...@apache.org> on 2017/03/22 06:13:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6154) Refine code reusing between logical and physical operators - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/03/22 06:14:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6159) Add Java/Scala FlinkLauncher - posted by "zhengcanbin (JIRA)" <ji...@apache.org> on 2017/03/22 11:00:45 UTC, 0 replies.
- [jira] [Created] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/22 11:09:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6161) Retry connection in case of a ResourceManager heartbeat timeout - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/22 11:12:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/03/22 13:16:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6163) Document per-window state in ProcessWindowFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/22 13:16:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6164) Make ProcessWindowFunction a RichFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/22 13:20:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6165) Implement internal continuity for looping states. - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/03/22 13:28:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6166) Broken quickstart for snapshots - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/03/22 13:37:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6167) Consider removing ArchivedExecutionGraph classes - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/22 14:11:41 UTC, 1 replies.
- Question about flink client - posted by Yelei Feng <fe...@outlook.com> on 2017/03/22 14:42:01 UTC, 3 replies.
- [RESULT] [VOTE] Release Apache Flink 1.1.5 (RC1) - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/03/22 15:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-6168) Make flink-core independent of Avro - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/03/22 15:38:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6169) yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/22 15:56:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6170) Some checkpoint metrics rely on latest stat snapshot - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/03/22 16:45:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6171) Some checkpoint metrics rely on latest stat snapshot - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/03/22 16:46:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6172) Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/22 22:39:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414 - posted by "Zhenghua Gao (JIRA)" <ji...@apache.org> on 2017/03/23 02:47:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6174) Introduce a leader election service in yarn mode to make JobManager always available - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/03/23 03:01:42 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.1.5 Released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/03/23 08:34:18 UTC, 2 replies.
- [jira] [Created] (FLINK-6175) HistoryServerTest.testFullArchiveLifecycle fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/03/23 08:38:41 UTC, 0 replies.
- Can someone help look over my patch - posted by zhengcanbin <zh...@huawei.com> on 2017/03/23 08:49:27 UTC, 0 replies.
- Flink AUR package is available - posted by Tao Meng <oa...@gmail.com> on 2017/03/23 09:36:27 UTC, 1 replies.
- [jira] [Created] (FLINK-6176) Add JARs to CLASSPATH deterministically - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2017/03/23 15:58:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6177) Add support for "Distributed Cache" in streaming applications - posted by "Zohar Mizrahi (JIRA)" <ji...@apache.org> on 2017/03/24 00:55:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6178) Allow upgrades to state serializers - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/24 07:59:49 UTC, 0 replies.
- [jira] [Created] (FLINK-6179) Create SerialMainThreadValidatorUtil to support TestingSerialRpcService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/24 09:37:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6180) Remove TestingSerialRpcService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/03/24 10:29:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6181) Zookeeper scripts use invalid regex - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/03/24 10:46:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6182) Fix possible NPE in SourceStreamTask - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/03/24 11:23:41 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.2.1 (RC1) - posted by Robert Metzger <rm...@apache.org> on 2017/03/24 14:05:21 UTC, 15 replies.
- [jira] [Created] (FLINK-6183) TaskMetricGroup may not be cleanup when Task.run() is never called or exits early - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/24 17:14:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6184) Buffer metrics can cause NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/24 17:17:41 UTC, 0 replies.
- [ANNOUNCE] Flink Forward San Francisco 10-11 Apr 2017 community discount codes - posted by Robert Metzger <rm...@apache.org> on 2017/03/24 19:45:16 UTC, 0 replies.
- [jira] [Created] (FLINK-6185) Input readers and output writers/formats need to support gzip - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/03/25 00:42:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6186) Remove unused import - posted by "CanBin Zheng (JIRA)" <ji...@apache.org> on 2017/03/25 04:46:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6187) Cancel job failed with option -m on yarn session - posted by "Yuhong Hong (JIRA)" <ji...@apache.org> on 2017/03/25 06:40:41 UTC, 0 replies.
- [DISCUSS] Flink dist directory management - posted by shijinkui <sh...@huawei.com> on 2017/03/25 07:46:50 UTC, 4 replies.
- [jira] [Created] (FLINK-6188) Some setParallelism() method can't cope with default parallelism - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/03/25 08:28:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6189) Do not use yarn client config to do sanity check - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/03/25 10:00:48 UTC, 0 replies.
- [DISCUSS] TravisCI auto cancellation - posted by Greg Hogan <co...@greghogan.com> on 2017/03/26 21:22:16 UTC, 4 replies.
- [jira] [Created] (FLINK-6190) Write "Serializer Configurations" metainfo along with state - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/27 05:39:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/03/27 06:01:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6192) reuse zookeeer client created by CuratorFramework - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/03/27 07:35:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6193) Flink dist directory normalize - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/03/27 07:59:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6194) More broken links in docs - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2017/03/27 09:10:41 UTC, 0 replies.
- Java library for Flink-Kudu integration - posted by ru...@accenture.com on 2017/03/27 13:35:12 UTC, 5 replies.
- [jira] [Created] (FLINK-6195) Move gelly-examples jar from opt to examples - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/03/27 13:42:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6196) Support dynamic schema in Table Function - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/03/27 14:24:42 UTC, 0 replies.
- [CANCEL][VOTE] Release Apache Flink 1.2.1 (RC1) - posted by Robert Metzger <rm...@apache.org> on 2017/03/27 14:37:37 UTC, 0 replies.
- [jira] [Created] (FLINK-6197) Add support for iterative conditions. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/03/27 14:54:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6198) Update the documentation of the CEP library to include all the new features. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/03/27 15:01:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6199) Single outstanding Async I/O operation per key - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2017/03/27 18:22:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6200) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/28 00:51:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6201) move python example files to the examples dir - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/03/28 04:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6202) YarnSessionCli couldn't submit jobs when using -z option - posted by "Syinchwun Leo (JIRA)" <ji...@apache.org> on 2017/03/28 06:29:41 UTC, 0 replies.
- Re: Figuring out when a job has successfully restored state - posted by Gyula Fóra <gy...@gmail.com> on 2017/03/28 08:55:06 UTC, 2 replies.
- [jira] [Created] (FLINK-6203) DataSet Transformations - posted by "苏拓 (JIRA)" <ji...@apache.org> on 2017/03/28 09:30:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/28 10:02:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6205) Put late elements in side output. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/03/28 12:10:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6206) As an Engineer, I want task state transition log to be warn/error for FAILURE scenarios - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2017/03/28 14:57:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6207) Duplicate type serializers for async snapshots of CopyOnWriteStateTable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/03/28 16:14:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6208) Implement skip till next match strategy - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/03/28 16:59:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1 - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/03/28 21:55:41 UTC, 0 replies.
- Flink on yarn passing yarn config params. - posted by praveen kanamarlapudi <kp...@gmail.com> on 2017/03/28 23:18:53 UTC, 1 replies.
- [jira] [Created] (FLINK-6210) RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/03/28 23:51:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6211) Validation error in Kinesis Consumer when using AT_TIMESTAMP as start position - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/03/29 06:41:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6212) Missing reference to flink-avro dependency - posted by "Omar Erminy (JIRA)" <ji...@apache.org> on 2017/03/29 07:13:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6213) When number of failed containers exceeds maximum failed containers and application is stopped, the AM container will be released 10 minutes later - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/03/29 08:45:41 UTC, 0 replies.
- TumblingEventTimeWindows with negative offset / Wrong documentation - posted by Vladislav Pernin <vl...@gmail.com> on 2017/03/29 14:57:33 UTC, 2 replies.
- [jira] [Created] (FLINK-6214) WindowAssigners do not allow negative offsets - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/03/29 15:15:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6215) Make the StatefulSequenceSource scalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/03/29 15:57:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6216) DataStream unbounded groupby aggregate with early firing - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/03/29 19:22:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6217) ContaineredTaskManagerParameters sets off heap memory size incorrectly - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/03/29 23:21:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6218) Not able to access the rows in table after converting dataset to table after using registerdataset - posted by "naveen holla U (JIRA)" <ji...@apache.org> on 2017/03/30 05:03:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6219) Add a state backend which supports sorting - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/30 09:44:41 UTC, 0 replies.
- [Bug]Question about StreamExecutionEnvironment.createRemoteEnvironment - posted by canbinzheng <20...@qq.com> on 2017/03/30 12:41:17 UTC, 0 replies.
- [jira] [Created] (FLINK-6220) Fine-grained copy-on-write for Heap(Map/List)States in CopyOnWriteStateTable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/03/30 13:01:41 UTC, 0 replies.
- Re: [Bug]Question about StreamExecutionEnvironment.createRemoteEnvironment - posted by Till Rohrmann <tr...@apache.org> on 2017/03/30 13:47:53 UTC, 2 replies.
- [jira] [Created] (FLINK-6221) Add Promethus support to metrics - posted by "Joshua Griffith (JIRA)" <ji...@apache.org> on 2017/03/30 16:15:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6222) YARN: setting environment variables in an easier fashion - posted by "Craig Foster (JIRA)" <ji...@apache.org> on 2017/03/30 18:38:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6223) Rework PythonPlanBinder generics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/30 21:20:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6224) RemoteStreamEnvironment not resolve hostname of JobManager - posted by "CanBin Zheng (JIRA)" <ji...@apache.org> on 2017/03/31 00:54:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6225) Support Row Stream for CassandraSink - posted by "Jing Fan (JIRA)" <ji...@apache.org> on 2017/03/31 04:24:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6226) ScalarFunction and TableFunction do not support parameters of byte, short and float - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/03/31 07:57:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/03/31 08:56:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6228) Integrating the OVER windows in the Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/03/31 09:19:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6229) Rework setup&configuration of PythonPlanBinder/operators - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/31 09:23:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6230) Make mmap size configurable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/03/31 09:25:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6231) completed PendingCheckpoint not release state caused oom - posted by "Chao Zhao (JIRA)" <ji...@apache.org> on 2017/03/31 09:35:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API - posted by "hongyuhong (JIRA)" <ji...@apache.org> on 2017/03/31 09:35:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API - posted by "hongyuhong (JIRA)" <ji...@apache.org> on 2017/03/31 09:40:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6234) HTTP/HTTPS WebServer Extension - posted by "Abey Sam Alex (JIRA)" <ji...@apache.org> on 2017/03/31 11:24:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6235) Broken link in documentation - posted by "Rami (JIRA)" <ji...@apache.org> on 2017/03/31 13:50:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6236) Savepoint page needs to include web console possibility - posted by "Rami (JIRA)" <ji...@apache.org> on 2017/03/31 14:00:47 UTC, 0 replies.