You are viewing a plain text version of this content. The canonical link for it is here.
- RE: [jira] [Created] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL - posted by Stefano Bortoli <st...@huawei.com> on 2017/02/01 12:43:27 UTC, 4 replies.
- [jira] [Created] (FLINK-5695) Optimize table type systems based on database semantics - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/02/01 15:44:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5696) Access to REAPER_THREAD lacks proper synchronization in SafetyNetCloseableRegistry#doRegister - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/02/01 17:33:51 UTC, 0 replies.
- Support for Auto scaling - posted by Meghashyam Sandeep V <vr...@gmail.com> on 2017/02/02 00:39:35 UTC, 0 replies.
- [jira] [Created] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/02/02 08:19:51 UTC, 0 replies.
- [RESULT][VOTE] Release Apache Flink 1.2.0 (RC3) - posted by Robert Metzger <rm...@apache.org> on 2017/02/02 10:43:28 UTC, 4 replies.
- [jira] [Created] (FLINK-5698) Add NestedFieldsProjectableTableSource interface - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2017/02/02 11:30:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5699) Cancel with savepoint fails with a NPE if savepoint target directory not set - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/02 14:44:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5700) Document akka.client.timeout - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/02 14:50:51 UTC, 0 replies.
- Re: Flink with Yarn on MapR - posted by "ani.desh1512" <an...@gmail.com> on 2017/02/02 16:05:17 UTC, 2 replies.
- Re: STREAM SQL inner queries - posted by Fabian Hueske <fh...@gmail.com> on 2017/02/02 23:14:53 UTC, 1 replies.
- [jira] [Created] (FLINK-5701) FlinkKafkaPrdocuer violates at-least-once by not handling failed records - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/02/03 05:47:52 UTC, 0 replies.
- [jira] [Created] (FLINK-5702) Kafka Producer docs should warn if using setLogFailuresOnly, at-least-once is compromised - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/02/03 06:12:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2017/02/03 07:28:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/02/03 08:04:52 UTC, 0 replies.
- [jira] [Created] (FLINK-5705) webmonitor's request/response use UTF-8 explicitly - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/02/03 09:17:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5706) Implement Flink's own S3 filesystem - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/03 09:57:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5707) Find better keys for backend configuration parameters - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/02/03 11:08:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5708) we should remove duplicated configuration options - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/02/03 12:24:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5709) Add Max Parallelism to Parallel Execution Doc - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/03 14:14:52 UTC, 0 replies.
- Task assignment - posted by Dmitrii Kniazev <my...@ya.ru> on 2017/02/03 14:21:15 UTC, 1 replies.
- [jira] [Created] (FLINK-5710) Add ProcTime() function to indicate StreamSQL - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2017/02/03 16:40:51 UTC, 2 replies.
- Apache IoT - posted by Trevor Grant <tr...@gmail.com> on 2017/02/03 20:25:54 UTC, 0 replies.
- [jira] [Created] (FLINK-5711) Deserialization schema that gives has full kafka log information - posted by "Mukesh Jha (JIRA)" <ji...@apache.org> on 2017/02/03 20:27:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5712) update several deprecated configuration options - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/02/04 09:15:52 UTC, 0 replies.
- [jira] [Created] (FLINK-5713) Protect against NPE in WindowOperator window cleanup - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/05 14:29:41 UTC, 0 replies.
- 答复: [DISCUSS] Development of SQL OVER / Table API Row Windows for streaming tables - posted by shijinkui <sh...@huawei.com> on 2017/02/06 02:24:08 UTC, 1 replies.
- [jira] [Created] (FLINK-5714) Use a builder pattern for creating CsvTableSource - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/02/06 08:57:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5715) Asynchronous snapshotting for HeapKeyedStateBackend - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/02/06 09:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5716) Make streaming SourceContexts aware of source idleness - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/02/06 09:18:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5717) NPE on SessionWindows with ContinuousProcessingTimeTrigger - posted by "Oriol Orellana (JIRA)" <ji...@apache.org> on 2017/02/06 09:28:41 UTC, 0 replies.
- Re: New Flink team member - Kate Eri. - posted by Katherin Eri <ka...@gmail.com> on 2017/02/06 09:49:14 UTC, 16 replies.
- [jira] [Created] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/06 11:10:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5719) Let LatencyMarkers completely bypass operators / chains - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/02/06 13:07:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5720) Deprecate "Folding" in all of DataStream API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/06 13:39:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5721) Add FoldingState to State Documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/06 13:51:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5722) Implement DISTINCT as dedicated operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/02/06 13:55:41 UTC, 1 replies.
- Re: [DISCUSS] Development of SQL OVER / Table API Row Windows for streaming tables - posted by Shaoxuan Wang <ws...@gmail.com> on 2017/02/06 15:04:32 UTC, 1 replies.
- [jira] [Created] (FLINK-5723) Use "Used" instead of "Initial" to make taskmanager tag more readable - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/02/06 15:18:42 UTC, 0 replies.
- [Discuss] Organizing Documentation for Configuration Options - posted by Greg Hogan <co...@greghogan.com> on 2017/02/06 18:21:21 UTC, 5 replies.
- [DISCUSS] Planning Release 1.3 - posted by Robert Metzger <rm...@apache.org> on 2017/02/06 19:19:22 UTC, 1 replies.
- [jira] [Created] (FLINK-5724) Error in the 'Zipping Elements' docs - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2017/02/06 20:06:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5725) Support JOIN between two streams in the SQL API - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/02/06 22:30:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5726) Add the RocketMQ plugin for the Apache Spark - posted by "Longda Feng (JIRA)" <ji...@apache.org> on 2017/02/07 03:58:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5727) Unify some API of batch and stream TableEnvironment - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/02/07 05:17:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/02/07 07:36:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5729) add hostname option in SocketWindowWordCount example to be more convenient - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/02/07 08:34:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5730) User can concurrently modify state metadata of RocksDB asynchronous snapshots - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/02/07 09:32:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5731) Split up CI builds - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/07 10:32:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5732) Java quick start mvn command line is incorrect - posted by "Colin Breame (JIRA)" <ji...@apache.org> on 2017/02/07 12:23:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5733) Link to Bahir connectors - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/02/07 13:38:41 UTC, 0 replies.
- ecosystem proposal, Temporal graph analytics on Flink with Gelly - posted by Wouter Ligtenberg <wo...@onzichtbaar.net> on 2017/02/07 14:41:01 UTC, 3 replies.
- [jira] [Created] (FLINK-5734) Implement code generation for NormalizedKeySorter - posted by "Pattarawat Chormai (JIRA)" <ji...@apache.org> on 2017/02/07 14:45:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5735) Non-overlapping sliding window is not deterministic - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/02/07 15:35:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5736) Fix Javadocs / Scaladocs build (Feb 2017) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/02/07 17:43:42 UTC, 0 replies.
- RE: Stream SQL and Dynamic tables - posted by Radu Tudoran <ra...@huawei.com> on 2017/02/07 18:27:19 UTC, 0 replies.
- [ANNOUNCE] Welcome Jark Wu and Kostas Kloudas as committers - posted by Fabian Hueske <fh...@gmail.com> on 2017/02/07 20:16:20 UTC, 20 replies.
- FLINK-5734 : Code Generation for NormalizedKeySorter - posted by Pattarawat Chormai <pa...@gmail.com> on 2017/02/07 21:34:00 UTC, 9 replies.
- [jira] [Created] (FLINK-5737) Let flink table support byte[] field type - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2017/02/08 02:11:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5738) Destroy created backend when task is canceled - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/02/08 02:52:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5739) NullPointerException in CliFrontend - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/02/08 08:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5740) Make WrappingFunction an interface and move to flink-core - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/08 10:08:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5741) Add tests for window function wrappers with RichFunctions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/08 10:11:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5742) Breakpoints on documentation website - posted by "Colin Breame (JIRA)" <ji...@apache.org> on 2017/02/08 10:22:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5743) Mark WindowedStream.aggregate* methods as PublicEvolving - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/08 10:28:41 UTC, 0 replies.
- flink-shell remote - posted by Anton Solovev <An...@epam.com> on 2017/02/08 11:27:34 UTC, 2 replies.
- [jira] [Created] (FLINK-5744) Checking remote connection in Flink-shell - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2017/02/08 13:37:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5745) Set uncaught exception handler for Netty threads - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/08 13:47:41 UTC, 0 replies.
- FINAL REMINDER: CFP for ApacheCon closes February 11th - posted by Rich Bowen <rb...@apache.org> on 2017/02/08 14:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5746) Add acceptEither and applyToEither to Flink's Future - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/08 17:38:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5747) Eager Scheduling should deploy all Tasks together - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/08 19:39:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5748) Make the ExecutionGraph's FutureExecutor a ScheduledExecutionService - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/08 19:41:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5749) Unset HADOOP_HOME and HADOOP_CONF_DIR from system environment when building flink - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/02/09 03:20:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5750) Incorrect parse of brackets inside VALUES subquery - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2017/02/09 09:09:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5751) 404 in documentation - posted by "Colin Breame (JIRA)" <ji...@apache.org> on 2017/02/09 10:28:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5752) Support push down projections for HBaseTableSource - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2017/02/09 10:39:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5753) CEP timeout handler. - posted by "Michał Jurkiewicz (JIRA)" <ji...@apache.org> on 2017/02/09 10:40:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5754) released tag missing .gitigonore .travis.yml .gitattributes - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/02/09 11:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5755) Flink with Kafka connection - posted by "Fábio Dias (JIRA)" <ji...@apache.org> on 2017/02/09 11:38:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor - posted by "Syinchwun Leo (JIRA)" <ji...@apache.org> on 2017/02/09 11:47:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5757) Initial JobManager address required during access from cli to HA cluster - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/02/09 11:49:41 UTC, 0 replies.
- RE: flink-ml test - posted by Anton Solovev <An...@epam.com> on 2017/02/09 11:54:08 UTC, 1 replies.
- [jira] [Created] (FLINK-5758) Port-range for the web interface via YARN - posted by "Kanstantsin Kamkou (JIRA)" <ji...@apache.org> on 2017/02/09 12:14:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/09 13:18:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5760) "Introduction to Apache Flink" links to 1.1 release - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/02/09 13:44:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5761) ClassNotFoundException during cancel job - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/02/09 14:04:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5762) Execute initializeState() and open() "atomically" - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/02/09 15:01:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5763) Make savepoints self-contained and relocatable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/09 16:24:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5764) Don't serve ancient docs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/09 17:05:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5765) Add noindex meta tag for older docs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/09 17:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5766) Unify NoAvailableResourceException handling on ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/09 18:27:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5767) Add a new aggregate function interface - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/02/10 03:52:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5769) Apply new aggregation functions for dataset tables - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/02/10 03:53:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5768) Apply new aggregation functions and aggregate DataStream API for streaming tables - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/02/10 03:53:41 UTC, 0 replies.
- Fwd: Setup Flink on windows link not accessible - posted by kush batra <ku...@gmail.com> on 2017/02/10 04:52:56 UTC, 1 replies.
- [jira] [Created] (FLINK-5770) Flink yarn session stop in non-detached model - posted by "zhangrucong1982 (JIRA)" <ji...@apache.org> on 2017/02/10 06:31:42 UTC, 0 replies.
- Running multiple streaming jobs in same cluster - posted by Ozan DENİZ <oz...@outlook.com> on 2017/02/10 08:39:45 UTC, 1 replies.
- [jira] [Created] (FLINK-5771) DelimitedInputFormat does not correctly handle muli-byte delimiters - posted by "Colin Breame (JIRA)" <ji...@apache.org> on 2017/02/10 09:53:42 UTC, 0 replies.
- [ANNOUNCE] Welcome Stefan Richter as a new committer - posted by Ufuk Celebi <uc...@apache.org> on 2017/02/10 10:00:09 UTC, 17 replies.
- [jira] [Created] (FLINK-5772) Instability with embedded Elasticsearch node in ElasticsearchSink test - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/02/10 10:24:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge - posted by "Colin Breame (JIRA)" <ji...@apache.org> on 2017/02/10 11:51:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5774) ContinuousFileProcessingTest has test instability - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/10 13:52:41 UTC, 0 replies.
- 回复：[ANNOUNCE] Welcome Stefan Richter as a new committer - posted by Zhuoluo Yang <zh...@alibaba-inc.com> on 2017/02/10 14:15:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5775) NullReferenceException when running job on local cluster - posted by "Colin Breame (JIRA)" <ji...@apache.org> on 2017/02/10 14:36:42 UTC, 0 replies.
- Using QueryableState inside Flink jobs (and Parameter Server implementation) - posted by Gábor Hermann <ma...@gaborhermann.com> on 2017/02/10 15:00:46 UTC, 7 replies.
- [jira] [Created] (FLINK-5776) Improve XXMapRunner support create instance by carrying constructor parameters - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/02/10 15:12:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5777) Pass savepoint information to CheckpointingOperation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/10 16:12:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5778) Split FileStateHandle into fileName and basePath - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/10 16:15:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5779) Auto generate configuration docs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/10 16:21:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5780) Extend ConfigOption with descriptions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/10 16:24:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5781) Generation HTML from ConfigOption - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/10 16:28:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5782) Support GPU calculations - posted by "Kate Eri (JIRA)" <ji...@apache.org> on 2017/02/10 16:54:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5783) flink-connector-kinesis java.lang.NoClassDefFoundError: org/apache/http/conn/ssl/SSLSocketFactory - posted by "Huy Huynh (JIRA)" <ji...@apache.org> on 2017/02/10 20:57:41 UTC, 0 replies.
- Flink ML - NaN Handling - posted by Stavros Kontopoulos <st...@gmail.com> on 2017/02/10 22:48:19 UTC, 4 replies.
- Re: [jira] [Commented] (FLINK-5316) Make the GenericWriteAheadSink backwards compatible. - posted by Kostas Kloudas <k....@data-artisans.com> on 2017/02/12 14:18:14 UTC, 0 replies.
- [jira] [Created] (FLINK-5784) TaskExecutor may register JobManagerLeaderListener in LeaderRetrievalService multiple times - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2017/02/13 02:59:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5785) Add an Imputer for preparing data - posted by "Stavros Kontopoulos (JIRA)" <ji...@apache.org> on 2017/02/13 11:00:43 UTC, 0 replies.
- [jira] [Created] (FLINK-5786) Add support GetClusterStatus message for standalong flink cluster - posted by "Dmitrii Kniazev (JIRA)" <ji...@apache.org> on 2017/02/13 14:04:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5787) Unable to run jobs uploaded from IE - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/02/13 16:18:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5788) Document assumptions about File Systems and persistence - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/13 19:57:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSysten - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/13 20:27:41 UTC, 0 replies.
- [DISCUSS] Table API / SQL indicators for event and processing time - posted by Fabian Hueske <fh...@gmail.com> on 2017/02/14 00:00:31 UTC, 14 replies.
- [jira] [Created] (FLINK-5790) Use list types when ListStateDescriptor extends StateDescriptor - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/02/14 02:46:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5791) Resource should be strictly matched when allocating for yarn - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/02/14 03:05:41 UTC, 0 replies.
- [DISCUSS] Support Incremental Checkpointing in Flink - posted by SHI Xiaogang <sh...@gmail.com> on 2017/02/14 03:18:25 UTC, 2 replies.
- [jira] [Created] (FLINK-5792) Improve “UDF/UDTF" to support with parameter constructor - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/02/14 03:19:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5793) Running slot may not be add to AllocatedMap in SlotPool - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/02/14 06:50:41 UTC, 0 replies.
- Support for daylight saving timezone changes in Flink - posted by Swapnil Chougule <th...@gmail.com> on 2017/02/14 07:41:42 UTC, 1 replies.
- [jira] [Created] (FLINK-5794) Improve “UDF" to support with parameter constructor - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/02/14 13:07:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5795) Improve “UDTF" to support with parameter constructor - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/02/14 13:19:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5796) broken links in the docs - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/02/14 14:36:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5797) incorrect use of port range selector in BootstrapTool - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/02/14 15:32:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5798) Let the RPCService provide a ScheduledExecutorService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/14 19:27:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5799) Let RpcService.scheduleRunnable return ScheduledFuture - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/14 19:43:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5800) Make sure that the CheckpointStreamFactory is instantiated once per operator only - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/14 21:17:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5801) Queryable State from Scala job/client fails with key of type Long - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2017/02/14 23:55:42 UTC, 0 replies.
- Handling skewness and Heterogeniety - posted by Anis Nasir <aa...@gmail.com> on 2017/02/15 01:12:38 UTC, 2 replies.
- [jira] [Created] (FLINK-5802) Flink SQL calling Hive User-Defined Functions - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/02/15 03:58:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5803) Add [partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/02/15 06:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5804) Add [non-partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/02/15 06:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5805) improve docs for ProcessFunction - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2017/02/15 09:51:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5806) TaskExecutionState toString format have wrong key - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/02/15 12:33:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5807) improved wording for doc home page - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2017/02/15 12:48:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5808) Missing verification for setParallelism and setMaxParallelism - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/15 14:35:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5809) Add registerNextWatermarkCallback() to TimerService - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/15 14:49:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5810) Harden SlotManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/15 15:58:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5811) Harden YarnClusterDescriptorTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/15 16:53:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5812) Clean up FileSystem - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/15 17:43:42 UTC, 0 replies.
- Reliable Distributed FS support (HCFS) - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2017/02/15 19:28:18 UTC, 2 replies.
- Flink Job Exception - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2017/02/15 23:50:07 UTC, 2 replies.
- [jira] [Created] (FLINK-5813) code generation for user-defined aggregate functions - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/02/16 07:04:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5814) flink-dist creates wrong symlink when not used with cleaned before - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/02/16 08:38:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5815) Add resource files configuration for Yarn Mode - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/02/16 08:50:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5816) I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you. - posted by "Pedro Lima Monteiro (JIRA)" <ji...@apache.org> on 2017/02/16 08:59:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts. - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/02/16 09:10:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5818) change checkpoint dir permission to 700 for security reason - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/02/16 11:30:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5819) Improve metrics reporting - posted by "Paul Nelligan (JIRA)" <ji...@apache.org> on 2017/02/16 12:49:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5820) Extend State Backend Abstraction to support Global Cleanup Hooks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/16 13:05:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5821) Create StateBackend root interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/16 13:06:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5822) Make Checkpoint Coordinator aware of State Backend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/16 13:07:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/16 13:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5824) Fix String/byte conversion without explicit encodings - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/16 13:34:42 UTC, 0 replies.
- Wish to Contribute - Andrea Spina - posted by Andrea Spina <an...@radicalbit.io> on 2017/02/16 22:11:16 UTC, 5 replies.
- [jira] [Created] (FLINK-5825) In yarn mode, a small pic can not be loaded - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/02/17 06:47:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5826) UDF/UDTF should support variable types and variable arguments - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/02/17 07:20:41 UTC, 0 replies.
- Contribute Flink - posted by Riccardo Diomedi <ri...@radicalbit.io> on 2017/02/17 08:44:42 UTC, 3 replies.
- [jira] [Created] (FLINK-5827) Compile error when do filter after join a udtf which returns a POJO type - posted by "kaibo.zhou (JIRA)" <ji...@apache.org> on 2017/02/17 09:28:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5828) BlobServer create cache dir has concurrency safety problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2017/02/17 09:32:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5829) Bump Calcite version to 1.12 once available - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/02/17 11:14:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5830) OutOfMemoryError during notify final state in TaskExecutor may cause job stuck - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2017/02/17 11:14:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5831) Sort metrics in metric selector and add search box - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/02/17 13:00:43 UTC, 0 replies.
- Re: [DISCUSS] Time-based releases in Flink - posted by Jin Mingjian <ji...@gmail.com> on 2017/02/17 13:11:13 UTC, 0 replies.
- [jira] [Created] (FLINK-5832) Support for simple hive UDF - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/02/17 13:23:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5833) Support for Hive GenericUDF - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/02/17 13:24:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5834) Support for Hive User-defined Table-generating Function (UDTF) - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/02/17 13:36:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5835) Support for Hive's User-defined Aggregation Function (UDAF) - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/02/17 13:39:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5836) Race condition between slot offering and task deployment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/17 13:39:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5837) improve readability of the queryable state docs - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2017/02/17 16:45:41 UTC, 0 replies.
- compiling flink - posted by Ameet BD <am...@gmail.com> on 2017/02/17 17:02:39 UTC, 1 replies.
- [jira] [Created] (FLINK-5838) Fix jobmanager.sh usage - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/02/17 19:07:41 UTC, 0 replies.
- Interested to Contribute to Flink - posted by Karthik Ramakrishnan <ka...@gmail.com> on 2017/02/17 22:01:04 UTC, 1 replies.
- [jira] [Created] (FLINK-5839) Flink Security in Huawei's use case - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/02/18 03:50:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5840) Aggregation functions problem - posted by "Kursat Kurt (JIRA)" <ji...@apache.org> on 2017/02/18 11:23:44 UTC, 0 replies.
- disabling checkstyle - posted by Ameet BD <am...@gmail.com> on 2017/02/18 12:37:05 UTC, 1 replies.
- [jira] [Created] (FLINK-5841) Algorithms for each pipeline stage should handle NaN, infinity like in scikit-learn - posted by "Stavros Kontopoulos (JIRA)" <ji...@apache.org> on 2017/02/18 17:54:44 UTC, 0 replies.
- Flink ML - posted by Stavros Kontopoulos <st...@gmail.com> on 2017/02/19 17:03:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5842) Wrong 'since' version for ElasticSearch 5.x connector - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/02/19 18:01:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5843) Website/docs missing Cache-Control HTTP header, can serve stale data - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2017/02/19 21:15:44 UTC, 0 replies.
- 回复：[DISCUSS] Support Incremental Checkpointing in Flink - posted by "施晓罡(星罡)" <xi...@alibaba-inc.com> on 2017/02/20 02:21:21 UTC, 0 replies.
- [jira] [Created] (FLINK-5844) jobmanager was killed when disk less 10% and restart fail - posted by "jing lining (JIRA)" <ji...@apache.org> on 2017/02/20 03:44:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5845) CEP: unify key and non-keyed operators - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/02/20 08:49:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5846) CEP: make the operators backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/02/20 09:01:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5847) Not able to deploy Flink 1.3-SNAPSHOT on Openshit Paas - posted by "xinyang gao (JIRA)" <ji...@apache.org> on 2017/02/20 09:46:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5848) make Flink Web Backend a little bit more restful - posted by "Fabian Wollert (JIRA)" <ji...@apache.org> on 2017/02/20 09:53:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5849) Kafka Consumer checkpointed state may contain undefined offsets - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/02/20 09:57:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5850) implement OAuth 2.0 check in Web Backend API - posted by "Fabian Wollert (JIRA)" <ji...@apache.org> on 2017/02/20 10:06:44 UTC, 0 replies.
- [DISCUSS] Flink ML roadmap - posted by Stavros Kontopoulos <st...@gmail.com> on 2017/02/20 10:43:20 UTC, 25 replies.
- KeyGroupRangeAssignment ? - posted by Ovidiu-Cristian MARCU <ov...@inria.fr> on 2017/02/20 10:46:04 UTC, 12 replies.
- Contribute to Flink - posted by Jin Mingjian <ji...@gmail.com> on 2017/02/20 13:47:35 UTC, 2 replies.
- Question about Async IO - posted by Gyula Fóra <gy...@apache.org> on 2017/02/20 13:53:57 UTC, 4 replies.
- [jira] [Created] (FLINK-5851) Renaming AsyncCollector into ResultPromise/ResultFuture - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/20 15:01:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5852) Move JSON generation code into static methods - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/02/20 15:36:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5853) Add consecutive event based filters - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/02/20 15:50:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5854) Introduce some Flink-specific base Exception types - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/20 17:25:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/02/20 20:56:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5856) Need return redundant containers to yarn for yarn mode - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/02/21 02:16:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5857) Recycle idle containers in time for yarn mode - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/02/21 02:34:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5858) Support multiple sinks in same execution DAG - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/02/21 02:43:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5859) support partition pruning on Table API & SQL - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/02/21 02:58:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/02/21 03:07:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5861) TaskManager's components support updating JobManagerGateway - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2017/02/21 07:43:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5862) When JobManager fails, TaskManagers do not cancel tasks, but attempt to reconnect to the JobManager, and report states of tasks deployed in - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2017/02/21 08:07:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5863) Unify the serialization of queryable list states in different backends - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/02/21 08:27:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5864) CEP: fix duplicate output patterns problem. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/02/21 09:21:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5865) Throw original exception in RocksDB states - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/02/21 10:10:57 UTC, 0 replies.
- [jira] [Created] (FLINK-5866) The implementation of FailoverRegion. - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/02/21 10:42:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5867) The implementation of FailoverCoordinator - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/02/21 10:50:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5868) Implement a new RestartStrategy that works for the FailoverRegion. - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/02/21 10:57:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5869) ExecutionGraph use FailoverCoordinator to manage the failover of execution vertexes - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/02/21 11:11:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5870) Make handlers aware of their REST URLs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/02/21 11:56:44 UTC, 0 replies.
- [DISCUSS] Project build time and possible restructuring - posted by Till Rohrmann <tr...@apache.org> on 2017/02/21 12:44:47 UTC, 10 replies.
- [jira] [Created] (FLINK-5871) Enforce uniqueness of pattern names in CEP. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/02/21 12:56:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5872) WebUI shows "(null)" root-exception even without exception - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/02/21 13:29:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5873) KeyedStream: expose an user defined function for key group assignment - posted by "Ovidiu Marcu (JIRA)" <ji...@apache.org> on 2017/02/21 14:08:44 UTC, 0 replies.
- [DISCUSS] Should we supply a new Iterator instance for Functions with Iterable input(s) like CoGroupFunction ? - posted by Lin Li <li...@gmail.com> on 2017/02/21 15:13:37 UTC, 6 replies.
- [jira] [Created] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/02/21 17:36:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5875) Use TypeComparator.hash instead of Object.hashCode() for keying in DataStream API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/02/21 17:40:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5876) Mention Scala type fallacies for queryable state client serializers - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/21 18:13:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5877) Fix Scala snippet in Async I/O API doc - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2017/02/21 20:14:44 UTC, 0 replies.
- [DISCUSS] Code style / checkstyle - posted by Dawid Wysakowicz <wy...@gmail.com> on 2017/02/21 21:50:08 UTC, 24 replies.
- Visualizing topologies - posted by Ken Krugler <kk...@transpac.com> on 2017/02/21 22:59:16 UTC, 6 replies.
- [jira] [Created] (FLINK-5878) Add stream-stream inner join on TableAPI - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/02/22 01:08:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5879) ExecutionAttemptID should invoke super() in constructor - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2017/02/22 09:12:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5880) Add documentation for object reuse for DataStream API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/22 10:16:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5881) Scalar should support variable types and variable arguments - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/02/22 10:30:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5882) TableFunction (UDTF) should support variable types and variable arguments - posted by "Zhuoluo Yang (JIRA)" <ji...@apache.org> on 2017/02/22 10:34:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5883) Re-adding the Exception-thrown code for ListKeyGroupedIterator when the iterator is requested the second time - posted by "lincoln.lee (JIRA)" <ji...@apache.org> on 2017/02/22 13:26:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5884) Integrate time indicators for Table API & SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/02/22 13:56:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5885) Java code snippet instead of scala in documentation - posted by "Evgeny Vanslov (JIRA)" <ji...@apache.org> on 2017/02/22 14:24:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5886) Python API for streaming applications - posted by "Zohar Mizrahi (JIRA)" <ji...@apache.org> on 2017/02/22 15:21:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5887) Make CheckpointBarrier type immutable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/22 16:12:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5888) ForwardedFields annotation is not generating optimised execution plan in example KMeans job - posted by "Ziyad Muhammed Mohiyudheen (JIRA)" <ji...@apache.org> on 2017/02/22 16:19:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5889) Improving the Flink Python batch API test framework - posted by "Lior Amar (JIRA)" <ji...@apache.org> on 2017/02/22 20:46:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5890) GatherSumApply broken when object reuse enabled - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/02/22 21:07:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5891) ConnectedComponents is broken when object reuse enabled - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/02/22 21:26:44 UTC, 0 replies.
- [DISCUSS] Per-key event time - posted by Jamie Grier <ja...@data-artisans.com> on 2017/02/23 00:01:48 UTC, 6 replies.
- [jira] [Created] (FLINK-5892) Recover job state at the granularity of operator - posted by "MaGuowei (JIRA)" <ji...@apache.org> on 2017/02/23 07:07:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5893) Race condition in removing previous JobManagerRegistration in ResourceManager - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/02/23 07:27:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5894) HA docs are misleading re: state backends - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2017/02/23 10:23:44 UTC, 0 replies.
- [DISCUSS] Side Outputs and Split/Select - posted by Aljoscha Krettek <al...@apache.org> on 2017/02/23 14:42:11 UTC, 12 replies.
- [jira] [Created] (FLINK-5895) Reduce logging aggressiveness of FileSystemSafetyNet - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/23 15:16:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5896) Improve readability of the event time docs - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2017/02/23 15:22:44 UTC, 0 replies.
- FLINK-4565 Support for SQL IN operator - posted by Dmytro Shkvyra <Dm...@epam.com> on 2017/02/23 16:25:21 UTC, 0 replies.
- Re: FLINK-4565 Support for SQL IN operator - posted by Fabian Hueske <fh...@gmail.com> on 2017/02/23 16:31:54 UTC, 0 replies.
- [jira] [Created] (FLINK-5897) Untie Checkpoint Externalization from FileSystems - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/23 16:53:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5898) Race-Condition with Amazon Kinesis KPL - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2017/02/23 23:45:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5899) Fix the bug in initializing the DataSetTumbleTimeWindowAggReduceGroupFunction - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/02/24 03:33:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5900) Add non-partial merge Aggregates and unit tests - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/02/24 03:38:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5901) DAG can not show properly in IE - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/02/24 06:25:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5902) Some images can not show in IE - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/02/24 06:42:44 UTC, 0 replies.
- Redis sink in Flink 2.0 - posted by lmalds <li...@sina.com> on 2017/02/24 06:42:51 UTC, 4 replies.
- [jira] [Created] (FLINK-5903) taskmanager.numberOfTaskSlots and yarn.containers.vcores did not work well in YARN mode - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/02/24 07:22:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5904) jobmanager.heap.mb and taskmanager.heap.mb not work in YARN mode - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/02/24 09:00:54 UTC, 0 replies.
- [jira] [Created] (FLINK-5906) Add support to register UDAGGs in TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/02/24 09:58:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5905) Add user-defined aggregation functions to documentation. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/02/24 09:58:44 UTC, 0 replies.
- Re: Frontend classpath issue - posted by Gyula Fóra <gy...@gmail.com> on 2017/02/24 10:05:34 UTC, 4 replies.
- [jira] [Created] (FLINK-5907) RowCsvInputFormat bug on parsing tsv - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2017/02/24 10:43:44 UTC, 0 replies.
- [DISCUSS] Gelly planning for release 1.3 and roadmap - posted by Vasiliki Kalavri <va...@gmail.com> on 2017/02/24 15:39:19 UTC, 3 replies.
- [jira] [Created] (FLINK-5908) Blob Cache can (rarely) get corrupted on failed blob downloads - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/02/24 16:37:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5909) Interface for GraphAlgorithm results - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/02/24 21:50:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5910) Framework for Gelly examples - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/02/24 21:53:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5911) Command-line parameters - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/02/24 21:55:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5912) Inputs for CSV and graph generators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/02/24 21:56:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5913) Example drivers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/02/24 21:58:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5914) remove aggregateResultType from streaming.api.datastream.aggregate - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/02/25 03:43:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5915) Add support for the aggregate on multi fields - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/02/25 06:14:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5916) make env.java.opts.jobmanager and env.java.opts.taskmanager working in YARN mode - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/02/25 07:10:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5917) Remove MapState.size() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/25 07:28:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5918) port range support for config taskmanager.rpc.port - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/02/25 07:49:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5919) port range support for config taskmanager.data.port - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/02/25 07:50:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5920) port range support for config query.server.port - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/02/25 07:52:44 UTC, 0 replies.
- ElasticsearchSink Exception - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2017/02/25 07:58:16 UTC, 5 replies.
- [jira] [Created] (FLINK-5921) Adapt time mode indicator functions return custom data types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/02/25 23:27:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5922) Remove FlinkAggregateJoinTransposeRule when upgrading to Calcite 1.12 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/02/27 09:36:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5923) Test instability in SavepointITCase testTriggerSavepointAndResume - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/27 09:43:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5924) Support asynchronous checkpointing of operator state - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/27 09:51:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5925) Clean up extracted RocksDB JNI library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/27 09:58:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5926) Show state backend information in web UI - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/27 11:16:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5927) Remove old Aggregate interface and built-in functions - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/02/27 11:19:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5928) Externalized checkpoints overwritting each other - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/02/27 11:34:53 UTC, 0 replies.
- [jira] [Created] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/27 16:33:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5930) Allow Access to Job Id from Runtime Context - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2017/02/27 17:04:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5931) Make Flink highly available even if defaultFS is unavailable - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/02/27 19:58:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5932) Order of legacy vs new state initialization in the AbstractStreamOperator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/02/28 09:38:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5933) Allow Evictor for merging windows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/02/28 09:52:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5934) Scheduler in ExecutionGraph null if failure happens in ExecutionGraph.restoreLatestCheckpointedState - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/28 11:21:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5935) confusing/misleading error message when failing to restore savepoint - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2017/02/28 11:53:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5936) Can't pass keyed vectors to KNN join algorithm - posted by "Alex DeCastro (JIRA)" <ji...@apache.org> on 2017/02/28 12:16:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5937) Add documentation about the task lifecycle. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/02/28 15:16:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5938) Replace ExecutionContext by Executor in Scheduler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/02/28 16:25:45 UTC, 0 replies.
- [jira] [Created] (FLINK-5939) Wrong version in README.md for several Apache Flink extensions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/02/28 17:19:45 UTC, 0 replies.