You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-9484) Improve generic type inference for User-Defined Functions - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 00:48:00 UTC, 0 replies.
- Re: [VOTE] Release flink-shaded 4.0, release candidate #2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/06/01 06:32:28 UTC, 2 replies.
- Re: [SQL] [CALCITE] not applicable function for TIME - posted by Viktor Vlasov <vi...@gmail.com> on 2018/06/01 10:12:29 UTC, 2 replies.
- [TABLE][SQL] Unify UniqueKeyExtractor and DataStreamRetractionRules - posted by Piotr Nowojski <pi...@data-artisans.com> on 2018/06/01 11:26:14 UTC, 8 replies.
- [jira] [Created] (FLINK-9485) Improving Flink’s timer management for large state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9486) Introduce TimerState in keyed state backend - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9487) Prepare InternalTimerHeap for asynchronous snapshots - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9488) Create common entry point for master and workers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/01 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9489) Checkpoint timers as part of managed keyed state instead of raw keyed state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9490) Provide backwards compatibility for timer state of Flink 1.5 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9491) Implement timer service based on RocksDB - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 13:11:00 UTC, 0 replies.
- Re: Failure restarting Flink 1.5.0 job from checkpoint - posted by Till Rohrmann <tr...@apache.org> on 2018/06/01 13:17:51 UTC, 0 replies.
- [jira] [Created] (FLINK-9492) Failed to build RexCall with SqlDatetimeSubtractionOperator - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/06/01 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/01 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9494) Race condition in Dispatcher with concurrent granting and revoking of leaderhship - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/01 13:43:00 UTC, 0 replies.
- [ANNOUNCE] Flink Forward Berlin 2018 - Call for Presentations extended until June 11 - posted by Fabian Hueske <fh...@apache.org> on 2018/06/01 16:41:43 UTC, 0 replies.
- [jira] [Created] (FLINK-9495) Implement ResourceManager for Kubernetes - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/06/01 17:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9496) Job created time is reset after restart - posted by "Abhinav Bajaj (JIRA)" <ji...@apache.org> on 2018/06/01 17:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9497) Job Configuration showing the password in plain text - posted by "Vinay (JIRA)" <ji...@apache.org> on 2018/06/01 17:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests" - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/06/01 19:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9499) Allow REST API for running a job to provide job configuration as body of POST request - posted by "Esteban Serrano (JIRA)" <ji...@apache.org> on 2018/06/01 20:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9500) FileUploadHandler does not handle EmptyLastHttpContent - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/01 22:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9501) Allow Object.class type in user-define functions as parameter types but not result types - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 23:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9502) Use generic parameter search for user-define functions when argument contains Object type - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 23:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9503) Migrate integration tests for iterative aggregators - posted by "Deepak Sharma (JIRA)" <ji...@apache.org> on 2018/06/01 23:43:00 UTC, 0 replies.
- [FLINK - 9503] Starter task - posted by Deepak Sharma <de...@gmail.com> on 2018/06/01 23:46:14 UTC, 1 replies.
- [jira] [Created] (FLINK-9504) Change checkpoint duration log level to debug to avoid too much log - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/02 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9505) End-to-end test: Quickstarts for Scala - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/02 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop - posted by "swy (JIRA)" <ji...@apache.org> on 2018/06/03 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/03 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9508) General Spell Check on Flink Docs - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/03 21:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9509) CLI usage are not same as CLI docs - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/03 21:16:00 UTC, 0 replies.
- Re: [Discuss] Proposing FLIP-25 - Support User State TTL Natively in Flink - posted by Andrey Zagrebin <an...@data-artisans.com> on 2018/06/04 07:27:53 UTC, 3 replies.
- [jira] [Created] (FLINK-9510) State TTL API with cleanup on explicit access - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9511) Make StateDescriptor configurable with optional TTL - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9512) StateDescriptor TTL config should be part of versioned meta info snapshot - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9513) Wrap state binder with TTL logic - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9514) Create wrapper with TTL logic for value state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9515) Create wrapper with TTL logic for list state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9516) Create wrapper with TTL logic for map state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 08:02:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #23 - posted by Till Rohrmann <tr...@apache.org> on 2018/06/04 08:26:03 UTC, 0 replies.
- [DISCUSS] Flink 1.6 features - posted by Stephan Ewen <se...@apache.org> on 2018/06/04 09:21:26 UTC, 13 replies.
- [jira] [Created] (FLINK-9517) Fixing broken links on CLI Docs - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/04 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9518) SSL setup Docs config example has wrong keys password - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/04 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9519) table example jar did not copy into example dir - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/04 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9520) JarFileCreator does not support Java MethodReferences - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/04 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9521) Add build plugin to package table example jar - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/04 15:46:00 UTC, 0 replies.
- Re: Ask for SQL using kafka in Flink - posted by Shuyi Chen <su...@gmail.com> on 2018/06/04 18:29:20 UTC, 2 replies.
- Flink Cassandra Sink - Setting TTL for the record - posted by Rohan Thimmappa <ro...@gmail.com> on 2018/06/04 18:32:10 UTC, 2 replies.
- [jira] [Created] (FLINK-9522) Rework Flink website - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/04 20:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9523) Add Kafka examples for Flink Table/SQL API - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/06/04 22:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala - posted by "yan zhou (JIRA)" <ji...@apache.org> on 2018/06/04 23:03:00 UTC, 0 replies.
- Fwd: [DISCUSS] FLIP-6 Problems - posted by Renjie Liu <li...@gmail.com> on 2018/06/05 03:12:46 UTC, 8 replies.
- [jira] [Created] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/06/05 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9526) BucketingSink end-to-end test failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 07:15:00 UTC, 0 replies.
- Re: [DISCUSS] Adding new interfaces in [Stream]ExecutionEnvironment - posted by Fabian Hueske <fh...@gmail.com> on 2018/06/05 08:47:11 UTC, 3 replies.
- [jira] [Created] (FLINK-9527) Paths initialize with URI are not normalized - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 08:50:00 UTC, 0 replies.
- Need help regarding MongoDB oplog tailing using flink. - posted by Amol S - iProgrammer <am...@iprogrammer.com> on 2018/06/05 08:58:02 UTC, 1 replies.
- [jira] [Created] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/05 09:27:00 UTC, 0 replies.
- [WEBSITE] Proposal to rework the Flink website - posted by Fabian Hueske <fh...@gmail.com> on 2018/06/05 09:56:31 UTC, 7 replies.
- [jira] [Created] (FLINK-9529) Do not expose keyed methods on ProcessFunction.Context - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/05 11:55:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9530) Task numRecords metrics broken for chains - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9531) Improve logging during type extraction of the Row type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/05 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9532) Flink Overview of Jobs Documentation Incorrect - posted by "Abdul Qadeer (JIRA)" <ji...@apache.org> on 2018/06/06 01:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9533) CEP - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/06 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9534) CEP - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/06 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9535) log4j.properties specified in env.java.options doesn't get picked. - posted by "SUBRAMANYA SURESH (JIRA)" <ji...@apache.org> on 2018/06/06 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9536) Rolling logs using log4j.properties, prevents them from showing on the UI. - posted by "SUBRAMANYA SURESH (JIRA)" <ji...@apache.org> on 2018/06/06 06:35:00 UTC, 0 replies.
- [RESULT] [VOTE] Release flink-shaded 4.0, release candidate #2 - posted by Chesnay Schepler <c....@web.de> on 2018/06/06 06:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-9537) JobManager isolation in session mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/06 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9538) Make KeyedStateFunction an interface - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/06 07:42:00 UTC, 0 replies.
- [DISCUSS] Flink 1.4 and below STOPS writing to Kinesis after June 12th. - posted by Bowen Li <bo...@gmail.com> on 2018/06/06 08:06:41 UTC, 5 replies.
- [1.4.2] mvn clean package command takes to much time - posted by Marvin777 <xy...@gmail.com> on 2018/06/06 08:27:13 UTC, 4 replies.
- [jira] [Created] (FLINK-9539) Integrate flink-shaded 4.0 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/06 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9540) Apache Flink 1.4.2 S3 Hadooplibrary for Hadoop 2.7 is built for Hadoop 2.8 and fails - posted by "Razvan (JIRA)" <ji...@apache.org> on 2018/06/06 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/06 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9542) ExEnv#registerCachedFile should accept Path - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/06 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9543) Expose JobMaster IDs to metric system - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/06 12:49:00 UTC, 0 replies.
- Need help in understanding flink ordering of records - posted by Amol S - iProgrammer <am...@iprogrammer.com> on 2018/06/06 13:01:17 UTC, 0 replies.
- [jira] [Created] (FLINK-9544) Impossible to downgrade kinesis protocole from CBOR to JSON as required by kinesalite - posted by "Ph.Duveau (JIRA)" <ji...@apache.org> on 2018/06/06 13:37:00 UTC, 0 replies.
- Re: [PROPOSAL] Introduce Elastic Bloom Filter For Flink - posted by sihua zhou <su...@163.com> on 2018/06/06 14:02:10 UTC, 4 replies.
- FINAL REMINDER: Apache EU Roadshow 2018 in Berlin next week! - posted by sh...@apache.org on 2018/06/06 18:57:36 UTC, 0 replies.
- [jira] [Created] (FLINK-9545) Support read file for N times in Flink stream - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/06/06 23:21:00 UTC, 0 replies.
- Is there a Slack channel? - posted by Pablo Estrada <pa...@google.com.INVALID> on 2018/06/06 23:58:01 UTC, 1 replies.
- [jira] [Created] (FLINK-9546) The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0 - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/07 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9547) CEP pattern not called on windowed stream - posted by "Lucas Resch (JIRA)" <ji...@apache.org> on 2018/06/07 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9548) Flink Apache Kudu Connector - posted by "Sandish Kumar HN (JIRA)" <ji...@apache.org> on 2018/06/07 19:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/07 21:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9550) FlinkCEP snippet example has some syntax errors - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/07 21:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9551) FlinkCEP Scala Combining Patterns table has two missing pattern - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/07 22:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/06/08 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9553) Migrate integration tests for DataSinkITCase - posted by "Deepak Sharma (JIRA)" <ji...@apache.org> on 2018/06/08 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9554) flink scala shell doesn't work in yarn mode - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/06/08 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9555) Support table api in scala shell - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/06/08 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9556) Scala TypeAnalyzer does not consider ResultTypeQueryable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/08 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9557) FlinkTypeFactory should support BigInteger type - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/08 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9558) Memory leaks during usage with disabled checkpointing - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/08 14:25:00 UTC, 0 replies.
- [Proposal] Code Reviewer List - posted by Yaz Sh <ya...@gmail.com> on 2018/06/09 01:19:05 UTC, 0 replies.
- [jira] [Created] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/06/09 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9560) RateLimiting for FileSystem - posted by "Etienne CARRIERE (JIRA)" <ji...@apache.org> on 2018/06/09 04:53:00 UTC, 0 replies.
- Re: [Proposal] Code Reviewer List - posted by Chesnay Schepler <ch...@apache.org> on 2018/06/09 09:58:11 UTC, 1 replies.
- [jira] [Created] (FLINK-9561) Lack of the api to set RocksDB Option by flink config - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/09 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9562) Wrong wording in flink-optimizer module - posted by "Alexandr Arkhipov (JIRA)" <ji...@apache.org> on 2018/06/09 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9563) Migrate integration tests for CEP - posted by "Deepak Sharma (JIRA)" <ji...@apache.org> on 2018/06/09 18:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9564) Expose end-to-end module directory to test scripts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9565) Evaluating scalar UDFs in parallel - posted by "yinhua.dai (JIRA)" <ji...@apache.org> on 2018/06/11 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9566) Support listing all jobs in CliFrontend#list - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9567) Flink does not release resource in Yarn Cluster mode - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/06/11 09:53:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #24 - posted by Till Rohrmann <tr...@apache.org> on 2018/06/11 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9568) Wrong error handling for batch input formats with invalid paths - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/11 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9569) Confusing construction of AvroSerializers for generic records - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/12 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9570) SQL Client merging environments uses AbstractMap - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/12 08:43:00 UTC, 0 replies.
- Clarity on Flink 1.5 Rescale mechanism - posted by Sampath Bhat <sa...@gmail.com> on 2018/06/12 09:50:10 UTC, 1 replies.
- [jira] [Created] (FLINK-9571) Switch to internal states in StateBinder - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/12 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9572) Extend InternalAppendingState with internal stored state access - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/12 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9573) Check for leadership with leader session id - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/12 14:10:00 UTC, 0 replies.
- Static code analysis for Flink project - posted by si...@gmail.com on 2018/06/12 21:01:40 UTC, 9 replies.
- how to build the connectors and examples from the source - posted by Chris Kellogg <cc...@umich.edu> on 2018/06/13 00:17:23 UTC, 2 replies.
- Re: WELCOME to dev@flink.apache.org - posted by Sandish Kumar HN <sa...@gmail.com> on 2018/06/13 04:17:00 UTC, 2 replies.
- [DISCUSS] Long-term goal of making flink-table Scala-free - posted by Timo Walther <tw...@apache.org> on 2018/06/13 09:32:59 UTC, 3 replies.
- [jira] [Created] (FLINK-9574) Add a dedicated documentation page for state evolution - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/13 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9575) Potential race condition when removing JobGraph in HA - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/13 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9577) Divide-by-zero in PageRank - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/13 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9576) Wrong contiguity documentation - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9578) Allow to define an auto watermark interval in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/13 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9579) Remove unnecessary check with cep elementQueue - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/13 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/13 19:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9581) Redundant spaces for Collect at sql.md - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/06/13 20:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9582) dist assemblies access files outside of flink-dist - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/13 21:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9583) Wrong number of TaskManagers' slots after recovery. - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/06/14 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9584) Unclosed streams in Bucketing-/RollingSink - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9585) Logger in ZooKeeperStateHandleStore is public and non-final - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9586) Make collection sources parallelisable - posted by "Sina Madani (JIRA)" <ji...@apache.org> on 2018/06/14 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files - posted by "Andrei Shumanski (JIRA)" <ji...@apache.org> on 2018/06/14 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9588) Reuse the same conditionContext with in a same computationState - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/14 14:10:00 UTC, 0 replies.
- [ANNOUNCE] Registration for Flink Forward Berlin is open - posted by Fabian Hueske <fh...@gmail.com> on 2018/06/14 15:48:19 UTC, 0 replies.
- [jira] [Created] (FLINK-9589) PythonOperationInfo should be immutable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9590) HistogramDump should be immutable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 17:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9591) Remove remnants of distributed-cache logic - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9592) Notify on moving into pending/ final state - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/14 20:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/15 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257 - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/06/15 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9595) Add instructions to docs about ceased support of KPL version used in Kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/15 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9596) Ability to configure logging using the same log4j file - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/15 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9597) Flink fail to scale! - posted by "swy (JIRA)" <ji...@apache.org> on 2018/06/15 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure - posted by "Prem Santosh (JIRA)" <ji...@apache.org> on 2018/06/15 15:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9599) Implement generic mechanism to receive files via rest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/15 19:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9600) Add DataStream transformation variants that pass timestamp to the user function - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/06/16 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9601) Snapshot of CopyOnWriteStateTable will failed, when the amount of record is more than MAXIMUM_CAPACITY - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/16 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9602) Extend CommonOption section - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/16 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException) - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/16 14:29:00 UTC, 0 replies.
- v1.5 cancel job rest API - posted by Jake Croft <me...@gmail.com> on 2018/06/16 19:47:45 UTC, 1 replies.
- [jira] [Created] (FLINK-9604) Support KafkaProtoBufTableSource - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9605) Support KafkaProtoBufTableSink - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9606) Support ParquetTableSource - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9607) Support ParquetTableSink - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/18 05:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/18 09:00:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #25. - posted by Till Rohrmann <tr...@apache.org> on 2018/06/18 12:43:07 UTC, 0 replies.
- [jira] [Created] (FLINK-9610) Add Kafka partitioner that uses the key to partition by - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2018/06/18 19:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9611) Allow for user-defined artifacts to be specified as part of a mesos overlay - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2018/06/19 01:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9612) Add option for minimal artifacts being pulled in meseos - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2018/06/19 01:45:00 UTC, 0 replies.
- Improvements to Mesos Deployments Using Docker - posted by Addison Higham <ad...@gmail.com> on 2018/06/19 01:57:16 UTC, 1 replies.
- Why not put "FLIP: Network Stack Improvements" into Confluence page? - posted by Tony Wei <to...@gmail.com> on 2018/06/19 04:22:19 UTC, 2 replies.
- Please review FLINK-9610 Add Kafka partitioner that uses the key to partition by - posted by Niels Basjes <Ni...@basjes.nl> on 2018/06/19 07:26:55 UTC, 2 replies.
- [jira] [Created] (FLINK-9613) YARNSessionCapacitySchedulerITCase failed because YarnTestBase.checkClusterEmpty() - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/19 10:17:00 UTC, 0 replies.
- Ordering of stream from different kafka partitions - posted by Amol S - iProgrammer <am...@iprogrammer.com> on 2018/06/19 11:19:04 UTC, 9 replies.
- Breakage in Flink CLI in 1.5.0 - posted by Sampath Bhat <sa...@gmail.com> on 2018/06/19 12:12:18 UTC, 11 replies.
- [jira] [Created] (FLINK-9614) Improve the error message for Compiler#compile - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/19 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9615) Add - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/19 13:18:00 UTC, 0 replies.
- DataStreamCalcRule$1802" grows beyond 64 KB when execute long sql. - posted by zhangminglei <18...@163.com> on 2018/06/19 14:27:48 UTC, 4 replies.
- [jira] [Created] (FLINK-9616) DatadogHttpReporter fails to be created due to missing shaded dependency - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2018/06/19 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9617) Provide alias for whole records in Table API - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/19 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9618) NullPointerException in FlinkKinesisProducer when aws.region is not set and aws.endpoint is set - posted by "Aaron Langford (JIRA)" <ji...@apache.org> on 2018/06/20 00:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/20 04:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9620) Add an alternative option to choose when deal with eventtime cep - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/20 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9621) Warning when enabling partition discovery - posted by "Olivier Zembri (JIRA)" <ji...@apache.org> on 2018/06/20 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9622) DistributedCacheDfsTest failed on travis - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/20 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9623) Move zipping logic out of blobservice - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/20 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9624) Move jar/artifact upload logic out of JobGraph - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/20 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9625) Enrich the error information to user - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/20 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9626) Possible resource leak in FileSystem - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/20 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9627) Extending - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/20 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9628) Options to tolerate truncate failure in BucketingSink - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/06/20 14:12:00 UTC, 0 replies.
- Am I forgetting to do something to get pull request accepted? - posted by on 2018/06/20 18:50:45 UTC, 2 replies.
- [jira] [Created] (FLINK-9629) Datadog metrics reporter does not have shaded dependencies - posted by "Georgii Gobozov (JIRA)" <ji...@apache.org> on 2018/06/21 00:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException - posted by "Youjun Yuan (JIRA)" <ji...@apache.org> on 2018/06/21 00:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9631) use Files.createDirectories instead of directory.mkdirs - posted by "makeyang (JIRA)" <ji...@apache.org> on 2018/06/21 03:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9632) SlotPool should notify the call when allocateSlot meet an exception - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2018/06/21 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9633) Flink doesn't use the Savepoint path's filesystem to create the OuptutStream on Task. - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/21 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9634) Deactivate previous location based scheduling if local recovery is disabled - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/21 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9635) Local recovery scheduling can cause spread out of tasks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/21 08:07:00 UTC, 0 replies.
- Running a Scala Job doesn't produce print output - posted by Mano Swerts <ma...@ixxus.com> on 2018/06/21 09:27:58 UTC, 2 replies.
- [jira] [Created] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/06/21 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9637) Add public user documentation for TTL feature - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/21 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9638) Add helper script to run single e2e test - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/06/21 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9639) Order "User Configuration" Alphabetically on Flink Dashboard - posted by "Guilherme Nobre (JIRA)" <ji...@apache.org> on 2018/06/21 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9640) Checkpointing is aways aborted if any task has been finished - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/06/21 17:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9641) Pulsar Source Connector - posted by "Chris Kellogg (JIRA)" <ji...@apache.org> on 2018/06/21 22:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9642) Reduce the count to deal with state during a CEP process - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/22 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9643) Flink allowing TLS 1.1 in spite of configuring TLS 1.2 - posted by "Vinay (JIRA)" <ji...@apache.org> on 2018/06/22 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9644) Restore a job from savepoint in a local stream environment - posted by "Manuel Haddadi (JIRA)" <ji...@apache.org> on 2018/06/22 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9645) DispatcherTest.testSubmittedJobGraphListener fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/22 13:10:00 UTC, 0 replies.
- [ANNOUNCE] New committer: Sihua Zhou - posted by Till Rohrmann <tr...@apache.org> on 2018/06/22 13:17:51 UTC, 14 replies.
- FlinkML SVM Predictions are always 1.0 - posted by Mano Swerts <ma...@ixxus.com> on 2018/06/22 13:49:36 UTC, 5 replies.
- [jira] [Created] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/22 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9647) Files uploaded to blobservice during job submission aren't rmeoved on failure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/22 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9648) Do not store distributed cache entries in ExecutionConfig - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/22 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9649) TaskManagers are not scheduled on Mesos - posted by "Leonid Ishimnikov (JIRA)" <ji...@apache.org> on 2018/06/22 18:03:00 UTC, 0 replies.
- [ANNOUNCE] New committer Piotr Nowojski - posted by Till Rohrmann <tr...@apache.org> on 2018/06/22 19:26:42 UTC, 11 replies.
- Re: [Flink-9407] Question about proposed ORC Sink ! - posted by zhangminglei <18...@163.com> on 2018/06/23 02:12:22 UTC, 4 replies.
- [jira] [Created] (FLINK-9650) Support Protocol Buffers formats - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/23 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9651) Add a Kafka table source factory with Protobuf format support - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/23 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9652) Metrics for upstream and downstream - posted by "godfrey johnson (JIRA)" <ji...@apache.org> on 2018/06/24 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9653) Add operator name to latency metrics - posted by "Julian Stephen (JIRA)" <ji...@apache.org> on 2018/06/24 23:56:00 UTC, 0 replies.
- Re: Is it reasonable to use Flink in a local machine - posted by zhangminglei <18...@163.com> on 2018/06/25 01:05:33 UTC, 0 replies.
- Multiple kafka consumers - posted by Amol S - iProgrammer <am...@iprogrammer.com> on 2018/06/25 08:39:51 UTC, 5 replies.
- [jira] [Created] (FLINK-9654) Internal error while deserializing custom Scala TypeSerializer instances - posted by "Zsolt Donca (JIRA)" <ji...@apache.org> on 2018/06/25 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9655) Externalized checkpoint E2E test fails on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9656) Environment java opts for flink run - posted by "Jozef Vilcek (JIRA)" <ji...@apache.org> on 2018/06/25 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9657) Suspicious output from Bucketing sink E2E test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9658) Test data output directories are no longer cleaned up - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 17:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9659) Remove hard-coded sleeps in bucketing sink E2E test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 17:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9660) Allow passing custom artifacts to Mesos workers - posted by "Leonid Ishimnikov (JIRA)" <ji...@apache.org> on 2018/06/26 01:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9661) TTL state should support to do time shift after restoring from checkpoint( savepoint). - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/26 03:40:00 UTC, 0 replies.
- FLINK-9643 Necessity - posted by Viktor Vlasov <vi...@gmail.com> on 2018/06/26 07:01:02 UTC, 2 replies.
- Consuming data from dynamoDB streams to flink - posted by Ying Xu <yx...@lyft.com> on 2018/06/26 07:46:57 UTC, 4 replies.
- [jira] [Created] (FLINK-9662) Task manager isolation for jobs - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/26 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9663) Allow jobs to be scheduled to task managers with special tags - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/26 08:48:00 UTC, 0 replies.
- 回复：[ANNOUNCE] New committer Piotr Nowojski - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/06/26 08:49:33 UTC, 0 replies.
- [jira] [Created] (FLINK-9664) FlinkML Quickstart Loading Data section example doesn't work as described - posted by "Mano Swerts (JIRA)" <ji...@apache.org> on 2018/06/26 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9665) PrometheusReporter does not properly unregister metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/26 16:47:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #26 - posted by Till Rohrmann <tr...@apache.org> on 2018/06/26 21:43:54 UTC, 0 replies.
- [jira] [Created] (FLINK-9666) short-circuit logic should be used in boolean contexts - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2018/06/27 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9667) Scala docs are only generated for flink-scala - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9668) In some case Trigger.onProcessingTime don't exectue - posted by "qi quan (JIRA)" <ji...@apache.org> on 2018/06/27 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9669) Introduce task manager assignment store - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/27 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9670) Introduce slot manager factory - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/27 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9671) Add configuration to enable task manager isolation. - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/27 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9672) Fail fatally if we cannot submit job on added JobGraph signal - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/27 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9673) Improve State efficiency of bounded OVER window operators - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/27 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9674) Remove 65s sleep in QueryableState E2E test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9675) Avoid FileInputStream/FileOutputStream - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/27 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/06/27 09:43:00 UTC, 0 replies.
- Re: Streaming - posted by zhangminglei <18...@163.com> on 2018/06/27 10:23:22 UTC, 1 replies.
- [jira] [Created] (FLINK-9677) RestClient fails for large uploads - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9678) Remove hard-coded sleeps in HA E2E test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9679) Implement AvroSerializationSchema - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/27 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9680) Reduce heartbeat timeout for E2E tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9681) Make sure minRetentionTime not equal to maxRetentionTime - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/06/27 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9682) Add setDescription to execution environment and display it in the UI - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/06/27 16:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9683) inconsistent behaviors when setting historyserver.archive.fs.dir - posted by "Ethan Li (JIRA)" <ji...@apache.org> on 2018/06/27 19:03:00 UTC, 0 replies.
- Re: FLINK-6222 - posted by "Foster, Craig" <fo...@amazon.com.INVALID> on 2018/06/27 19:56:30 UTC, 1 replies.
- [jira] [Created] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster - posted by "Ethan Li (JIRA)" <ji...@apache.org> on 2018/06/27 20:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal - posted by "Ethan Li (JIRA)" <ji...@apache.org> on 2018/06/27 21:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole - posted by "Franz Thoma (JIRA)" <ji...@apache.org> on 2018/06/28 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9687) Delay the state fetch only when the triggerResult is fire - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/28 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9688) ATAN2 Sql Function support - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/06/28 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9689) Flink consumer deserialization example - posted by "Satheesh (JIRA)" <ji...@apache.org> on 2018/06/28 16:56:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9690) Restoring state with FlinkKafkaProducer and Kafka 1.1.0 client fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/06/28 18:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/06/28 21:51:00 UTC, 0 replies.
- [DISCUSS] Feature freeze for Flink 1.6 - posted by Till Rohrmann <tr...@apache.org> on 2018/06/29 16:31:28 UTC, 0 replies.
- [jira] [Created] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/06/29 20:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9693) possible memory link in jobmanager retaining archived checkpoints - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2018/06/29 23:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9694) potentially NPE in CompositeTypeSerializerConfigSnapshot constructor - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/30 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9695) Add option for Mesos executor to forcefully pull Docker images - posted by "Leonid Ishimnikov (JIRA)" <ji...@apache.org> on 2018/06/30 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9696) Deep toString for arrays/map in SQL client - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/06/30 16:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9697) Provide connector for Kafka 2.0.0 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/30 22:00:00 UTC, 0 replies.