You are viewing a plain text version of this content. The canonical link for it is here.
- Re:[DISCUSS] Automated code quality check in Flink - posted by 时某人 <sh...@163.com> on 2016/09/01 02:45:54 UTC, 1 replies.
- [jira] [Created] (FLINK-4546) Remove STREAM keyword and use batch sql parser for stream jobs - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/01 05:04:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4547) Return same object when call connect method in AkkaRpcService using same address and same rpc gateway class - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 06:55:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4548) Refactor ContinuousFileMonitoringTest to use OneShotLatch - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 08:09:20 UTC, 0 replies.
- Extending FLIP template - posted by Fabian Hueske <fh...@gmail.com> on 2016/09/01 08:37:48 UTC, 2 replies.
- Re: NullPointerException in beam stream runner - posted by Maximilian Michels <mx...@apache.org> on 2016/09/01 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-4549) Test and document implicitly supported SQL functions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 08:55:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4550) Clearly define SQL operator table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 09:04:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4551) Heartbeat Manager integration with JobMaster - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 09:05:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4552) Refactor WindowOperator/Trigger Tests - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 09:20:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4553) Add support for table sampling - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 09:44:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4554) Add support for array types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 09:49:20 UTC, 0 replies.
- Re: Scheduling of Flink jobs - posted by Stephan Ewen <se...@apache.org> on 2016/09/01 10:02:40 UTC, 2 replies.
- [jira] [Created] (FLINK-4555) Explicitly kill TaskManager on YARN when ApplicationMaster is shutting down - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/01 11:02:20 UTC, 0 replies.
- Queryable state deactivated on current master branch - posted by Stefan Richter <s....@data-artisans.com> on 2016/09/01 12:20:02 UTC, 0 replies.
- [jira] [Created] (FLINK-4556) Make Queryable State Key-Group Aware - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 12:53:20 UTC, 0 replies.
- [ANNOUNCE] Queryable State is Broken on Master - posted by Aljoscha Krettek <al...@apache.org> on 2016/09/01 12:55:02 UTC, 0 replies.
- Re: [VOTE] Release Apache Flink 1.1.2 (RC1) - posted by Aljoscha Krettek <al...@apache.org> on 2016/09/01 13:08:48 UTC, 1 replies.
- [jira] [Created] (FLINK-4557) Table API Stream Aggregations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 13:55:20 UTC, 0 replies.
- [DISCUSS] FLIP-11: Table API Stream Aggregations - posted by Timo Walther <tw...@apache.org> on 2016/09/01 14:12:21 UTC, 8 replies.
- [jira] [Created] (FLINK-4558) Add support for synchronizing streams - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/09/01 16:24:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO" - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/01 17:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4560) enforcer java version as 1.7 - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/02 02:38:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4561) replace all the scala version as a property - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/02 03:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4562) table example make an divided module in flink-examples - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/02 06:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/02 09:10:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4564) [metrics] Delimiter should be configured per reporter - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/02 09:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4565) Support for SQL IN operator - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/02 09:28:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 09:49:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 09:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4568) Replace ActorGateway in WebRuntimeMonitor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/02 09:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/02 10:21:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4570) Scalastyle Maven plugin fails undeterministically - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/02 12:44:21 UTC, 0 replies.
- Re: Reducing the JIRA PR message verbosity - posted by Maximilian Michels <mx...@apache.org> on 2016/09/02 13:08:08 UTC, 5 replies.
- [DISCUSS] Storm 1.x.x support in the compatibility layer - posted by Maximilian Michels <mx...@apache.org> on 2016/09/02 13:25:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4571) Configurable little parallelism in Gelly drivers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/02 15:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4572) Convert to negative in LongValueToIntValue - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/02 16:00:22 UTC, 0 replies.
- Yarn Test Timeout - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2016/09/02 16:24:20 UTC, 6 replies.
- [jira] [Created] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler# - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/02 17:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/03 14:37:20 UTC, 0 replies.
- [RESULT][VOTE] Release Apache Flink 1.1.2 (RC1) - posted by Robert Metzger <rm...@apache.org> on 2016/09/04 08:25:41 UTC, 1 replies.
- [jira] [Created] (FLINK-4575) DataSet aggregate methods should support POJOs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/09/04 16:25:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/04 17:01:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4577) Re-enable transparent reshard handling in Kinesis Consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/04 17:20:20 UTC, 0 replies.
- [SUGGESTION] Stack Overflow Documentation for Apache Flink - posted by Vishnu Viswanath <vi...@gmail.com> on 2016/09/04 18:11:37 UTC, 0 replies.
- [jira] [Created] (FLINK-4578) AggregateOperator incorrectly sets ForwardedField with nested composite types - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/09/04 19:06:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4579) Add StateBackendFactory for RocksDB Backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/05 08:06:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4580) Check that the RpcEndpoint supports the specified RpcGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/05 08:59:21 UTC, 0 replies.
- Sharing Java Collections within Flink Cluster - posted by Chakravarthy varaga <ch...@gmail.com> on 2016/09/05 15:48:30 UTC, 0 replies.
- [jira] [Created] (FLINK-4581) Table API throws "No suitable driver found for jdbc:calcite" - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/06 12:26:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/06 13:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4583) NullPointerException in CliFrontend - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/06 15:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4584) Fix broken links on flink.apache.org - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/06 19:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4585) Fix broken links on flink.apache.org - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/06 19:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue - posted by "Johannes (JIRA)" <ji...@apache.org> on 2016/09/06 21:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/09/07 04:31:20 UTC, 0 replies.
- [DISCUSS] how choose Scala and Java - posted by 时某人 <sh...@163.com> on 2016/09/07 06:21:50 UTC, 3 replies.
- Assign tasks from JIRA - posted by Kirill Morozov <Ki...@epam.com> on 2016/09/07 07:46:02 UTC, 1 replies.
- [jira] [Created] (FLINK-4588) Fix Merging of Covering Window in MergingWindowSet - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/07 11:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/07 11:43:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/07 11:46:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4591) Select star does not work with grouping - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/07 12:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4592) Fix flaky test ScalarFunctionsTest.testCurrentTimePoint - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/07 15:31:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4593) Fix PageRank algorithm example - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/07 18:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4594) Validate lower bound in MathUtils.checkedDownCast - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/07 19:32:21 UTC, 0 replies.
- release-1.1.2 does not exist on github - posted by Alexander Pivovarov <ap...@gmail.com> on 2016/09/07 21:09:30 UTC, 1 replies.
- [jira] [Created] (FLINK-4595) Close FileOutputStream in ParameterTool - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/07 21:10:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4596) Class not found exception when RESTART_STRATEGY is configured with fully qualified class name in the yaml - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2016/09/08 01:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4597) Improve Scalar Function section in Table API documentation - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/08 06:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4598) Support NULLIF in Table API - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/08 06:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/08 08:01:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4600) Support min/max aggregations for Date/Time/Timestamp/Intervals - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/08 09:40:21 UTC, 0 replies.
- Flink HA on AWS: Network related issue - posted by Deepak Jha <dk...@gmail.com> on 2016/09/08 17:08:03 UTC, 5 replies.
- [jira] [Created] (FLINK-4601) Check for empty string properly - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/09 06:58:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4602) Move RocksDB backed to proper package - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/09 09:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4603) KeyedStateBackend cannot restore user code classes - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/09 10:04:21 UTC, 0 replies.
- Contribution - posted by Hasan Gürcan <ha...@unbelievable-machine.com> on 2016/09/09 11:40:03 UTC, 6 replies.
- [jira] [Created] (FLINK-4604) Add support for standard deviation/variance - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/09 11:48:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4605) Add an expression that returns the return type of an expression - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/09 15:06:20 UTC, 0 replies.
- Implementing FLIP-2 and FLIP-4 - posted by AJ Heller <aj...@drfloob.com> on 2016/09/09 18:46:02 UTC, 4 replies.
- [jira] [Created] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/10 03:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4607) Close FileInputStream in ParameterTool and other - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/10 03:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/10 04:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4609) Remove redundant check for null in CrossOperator - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/10 05:24:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4610) Replace keySet/getValue with entrySet in UdfAnalyzerUtils - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/10 06:09:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/11 04:54:20 UTC, 0 replies.
- [DISCUSS] Proposal for Asynchronous I/O in FLINK - posted by Jeffery David <dw...@gmail.com> on 2016/09/12 02:56:07 UTC, 9 replies.
- [jira] [Created] (FLINK-4612) Close FileWriter using try with resources - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/12 05:45:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4613) Extend ALS to handle implicit feedback datasets - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2016/09/12 07:50:22 UTC, 0 replies.
- ML contributions - posted by Gábor Hermann <ma...@gaborhermann.com> on 2016/09/12 08:34:47 UTC, 2 replies.
- Savepoint and restart in the same command? - posted by Ron Crocker <rc...@newrelic.com> on 2016/09/12 12:39:40 UTC, 2 replies.
- checkpointing a OneInputStreamOperator/AbstractStreamOperator - posted by dan bress <da...@gmail.com> on 2016/09/12 18:30:35 UTC, 4 replies.
- [jira] [Created] (FLINK-4614) CLONE - Kafka connector documentation refers to Flink 1.2-SNAPSHOT - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/12 21:45:21 UTC, 0 replies.
- Re: Posting Flink Cluster questions - posted by Henry Saputra <he...@gmail.com> on 2016/09/13 00:41:16 UTC, 0 replies.
- Flink Cluster Load Distribution Question - posted by amir bahmanyari <am...@yahoo.com.INVALID> on 2016/09/13 04:35:36 UTC, 2 replies.
- [jira] [Created] (FLINK-4615) Reusing the memory allocated for the drivers and iterators - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/09/13 13:38:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state - posted by "Yuri Makhno (JIRA)" <ji...@apache.org> on 2016/09/13 14:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4617) Kafka & Flink duplicate messages on restart - posted by "Matthew Barlocker (JIRA)" <ji...@apache.org> on 2016/09/13 20:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4618) Last kafka message gets consumed twice when restarting job - posted by "Melmoth (JIRA)" <ji...@apache.org> on 2016/09/14 09:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4620) Automatically creating savepoints - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/09/14 12:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails - posted by "Maciej Prochniak (JIRA)" <ji...@apache.org> on 2016/09/14 12:22:20 UTC, 0 replies.
- Gelly Library. Need an example - posted by Olga Golovneva <me...@gmail.com> on 2016/09/14 19:49:30 UTC, 7 replies.
- Kafka v 0.10 Support - posted by Mariano Gonzalez <ma...@uptake.com> on 2016/09/15 00:55:19 UTC, 1 replies.
- [jira] [Created] (FLINK-4621) Improve decimal literals of SQL API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/15 09:50:20 UTC, 0 replies.
- build error - posted by Ameet BD <am...@gmail.com> on 2016/09/15 11:30:24 UTC, 4 replies.
- [jira] [Created] (FLINK-4622) CLI help message should include 'savepoint' action - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/09/15 14:40:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4623) Create Physical Execution Plan of a DataStream - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/15 16:00:23 UTC, 0 replies.
- [jira] [Created] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/15 17:03:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4625) Guard Flink processes against blocking shutdown hooks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/15 17:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4626) Missing break in MetricStore#add() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/15 22:19:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/16 03:47:20 UTC, 0 replies.
- Performance and Latency Chart for Flink - posted by "Chawla,Sumit " <su...@gmail.com> on 2016/09/16 03:54:59 UTC, 17 replies.
- [jira] [Created] (FLINK-4628) User class loader unavailable during input split assignment - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/16 10:16:20 UTC, 0 replies.
- DataStream of Future - posted by Albert Gimenez <al...@gmail.com> on 2016/09/16 11:16:05 UTC, 3 replies.
- [jira] [Created] (FLINK-4629) Kafka v 0.10 Support - posted by "Mariano Gonzalez (JIRA)" <ji...@apache.org> on 2016/09/16 19:25:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4630) add netty tcp source support - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/18 08:04:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4631) NullPointerException during stream task cleanup - posted by "Avihai Berkovitz (JIRA)" <ji...@apache.org> on 2016/09/18 14:51:20 UTC, 0 replies.
- Re: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink - posted by Vishnu Viswanath <vi...@gmail.com> on 2016/09/18 16:13:34 UTC, 1 replies.
- [jira] [Created] (FLINK-4632) when yarn nodemanager lost, flink hung - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/09/19 01:12:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4633) Implement new Client - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/19 01:54:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4634) TaskStopTest.testStopExecution() times out - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/19 07:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4635) Implement Data Transfer Authentication using shared secret configuration - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/09/19 18:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4636) AbstractCEPPatternOperator fails to restore state - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/19 18:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4637) Address Yarn proxy incompatibility with Flink Web UI when service level authorization is enabled - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/09/19 18:39:20 UTC, 0 replies.
- Exception from in-progress implementation of Python API bulk iterations - posted by Geoffrey Mon <ge...@gmail.com> on 2016/09/20 00:38:52 UTC, 4 replies.
- [jira] [Created] (FLINK-4638) Fix exception message for MemorySegment - posted by "Liwei Lin (JIRA)" <ji...@apache.org> on 2016/09/20 06:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4639) Make Calcite features more pluggable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/20 07:49:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/20 09:16:20 UTC, 0 replies.
- Assign issue - posted by Anton Mushin <An...@epam.com> on 2016/09/20 12:40:34 UTC, 3 replies.
- [jira] [Created] (FLINK-4641) Support branching CEP patterns - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/20 13:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4642) Remove unnecessary Guava dependency from flink-streaming-java - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/20 14:58:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4643) Average Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 15:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/20 16:52:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4645) Hard to register Kryo Serializers due to generics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/20 17:48:20 UTC, 0 replies.
- Get Flink ExecutionGraph Programmatically - posted by "Chawla,Sumit " <su...@gmail.com> on 2016/09/21 04:11:33 UTC, 8 replies.
- [jira] [Created] (FLINK-4646) Add BipartiteGraph class - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4647) Implement BipartiteGraph reader - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:45:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4648) Implement bipartite graph generators - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4649) Implement bipartite graph metrics - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4650) Frequent task manager disconnects from JobManager - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2016/09/21 07:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/09/21 08:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4652) Don't pass credentials explicitly to AmazonClient - use credentials provider instead - posted by "Kristian Frøhlich Hansen (JIRA)" <ji...@apache.org> on 2016/09/21 08:38:20 UTC, 0 replies.
- [discuss] merge module flink-yarn and flink-yarn-test - posted by shijinkui <sh...@huawei.com> on 2016/09/21 09:04:31 UTC, 1 replies.
- [jira] [Created] (FLINK-4653) Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/21 09:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4654) clean up docs - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/09/21 09:55:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4655) Add tests for validation of Expressions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/21 13:17:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4656) Port existing code to use Flink's future abstraction - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/21 13:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/21 14:52:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4658) Allow RpcService to execute Callables in the RpcService executor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/21 16:01:20 UTC, 0 replies.
- On (FLINK-1526) JIRA issue - posted by Olga Golovneva <me...@gmail.com> on 2016/09/21 16:50:43 UTC, 5 replies.
- [jira] [Created] (FLINK-4659) Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/21 18:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/09/21 19:45:21 UTC, 0 replies.
- 答复: [discuss] merge module flink-yarn and flink-yarn-test - posted by shijinkui <sh...@huawei.com> on 2016/09/22 00:58:25 UTC, 2 replies.
- [jira] [Created] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/22 09:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4662) Bump Calcite version up to 1.9 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/22 10:07:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message - posted by "Swapnil Chougule (JIRA)" <ji...@apache.org> on 2016/09/22 10:48:20 UTC, 0 replies.
- [DISCUSS] Merge batch and stream connector modules - posted by Fabian Hueske <fh...@gmail.com> on 2016/09/22 13:05:50 UTC, 7 replies.
- Flink Scala data load from CSV to postgress database. - posted by Jagan <ja...@gmail.com> on 2016/09/22 18:19:27 UTC, 0 replies.
- Fwd: Flink Scala - data load from CSV to postgress database. - posted by Jagan <ja...@gmail.com> on 2016/09/22 19:01:53 UTC, 6 replies.
- FailureRate Restart Strategy is not picked from Config file - posted by Deepak Jha <dk...@gmail.com> on 2016/09/22 20:01:54 UTC, 2 replies.
- [jira] [Created] (FLINK-4664) Add translator to NullValue - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/22 20:47:20 UTC, 0 replies.
- Flink Accumulators vs Metrics - posted by "Chawla,Sumit " <su...@gmail.com> on 2016/09/22 22:48:47 UTC, 1 replies.
- [jira] [Created] (FLINK-4665) Remove boxing/unboxing to parse a primitive - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/23 03:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4666) Make constants final in ParameterTool - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/23 05:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4667) Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/09/23 06:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4668) Fix positive random int generation - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/23 06:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/23 09:38:20 UTC, 0 replies.
- Flink scala data sink code from CSV to postgres. - posted by Jagan <ja...@gmail.com> on 2016/09/23 09:52:12 UTC, 1 replies.
- [jira] [Created] (FLINK-4670) Add watch mechanism on current RPC framework - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/23 11:19:20 UTC, 0 replies.
- No support for request PutMappingRequest - posted by Ozan DENİZ <oz...@outlook.com> on 2016/09/23 11:41:56 UTC, 5 replies.
- [jira] [Created] (FLINK-4671) Table API can not be built - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/23 15:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4672) TaskManager accidentally decorates Kill messages - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 16:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4673) TypeFactory for Either type - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/23 18:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4674) File Descriptors not being released after Completion of Flink Job Run via Flink Web Portal - posted by "Abey Sam Alex (JIRA)" <ji...@apache.org> on 2016/09/24 10:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/24 12:54:20 UTC, 0 replies.
- JDBC connection in Flink using Scala - posted by ram kumar <ra...@gmail.com> on 2016/09/24 13:29:59 UTC, 1 replies.
- Questions on flink - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2016/09/24 17:32:06 UTC, 1 replies.
- Flink: How to handle external app configuration changes in flink - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2016/09/26 02:34:44 UTC, 2 replies.
- Flink JDBCOutputFormat - Flush last batch enhancement - posted by Swapnil Chougule <th...@gmail.com> on 2016/09/26 07:29:57 UTC, 5 replies.
- 答复: 答复: [discuss] merge module flink-yarn and flink-yarn-test - posted by shijinkui <sh...@huawei.com> on 2016/09/26 11:14:36 UTC, 0 replies.
- [jira] [Created] (FLINK-4676) Merge flink-batch-con - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 11:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4677) Jars with no job executions produces NullPointerException in ClusterClient - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/26 13:00:22 UTC, 0 replies.
- [DISCUSS] add netty tcp/restful pushed source support - posted by shijinkui <sh...@huawei.com> on 2016/09/26 13:01:08 UTC, 1 replies.
- [jira] [Created] (FLINK-4678) Add SessionRow row-windows for streaming tables (FLIP-11) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4679) Add TumbleRow row-windows for streaming tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4680) Add SlidingRow row-windows for streaming tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4681) Add SessionRow row-windows for batch tables. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4682) Add TumbleRow row-windows for batch tables. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4683) Add SlideRow row-windows for batch tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 15:10:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 16:00:23 UTC, 0 replies.
- [jira] [Created] (FLINK-4686) Add possibility to get column names - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/26 16:20:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4687) Add getAddress method to RpcService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/26 17:06:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 18:21:20 UTC, 0 replies.
- [DISCUSS] Mesos Dispatcher (FF2016) - posted by "Wright, Eron" <ew...@live.com> on 2016/09/26 21:37:55 UTC, 2 replies.
- [jira] [Created] (FLINK-4689) Implement a simple slot provider for the new job manager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/27 02:00:26 UTC, 0 replies.
- [jira] [Created] (FLINK-4690) Replace SlotAllocationFuture with flink's own future - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/27 03:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4691) Add group-windows for streaming tables - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/27 08:39:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4692) Add tumbling and sliding group-windows for batch tables - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/27 08:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4693) Add session group-windows for batch tables - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/27 08:44:20 UTC, 0 replies.
- Regarding `flink-streaming` project dependencies - posted by Liwei Lin <lw...@gmail.com> on 2016/09/27 08:45:36 UTC, 4 replies.
- [jira] [Created] (FLINK-4694) Add wait for termination function to RpcEndpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/27 08:47:20 UTC, 0 replies.
- [DISCUSS] Timely User Functions and Watermarks - posted by Aljoscha Krettek <al...@apache.org> on 2016/09/27 09:27:45 UTC, 1 replies.
- 答复: [DISCUSS] add netty tcp/restful pushed source support - posted by shijinkui <sh...@huawei.com> on 2016/09/27 12:38:25 UTC, 1 replies.
- [jira] [Created] (FLINK-4695) Separate configuration parsing from MetricRegistry - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/27 12:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 12:53:20 UTC, 0 replies.
- 答复: 答复: [DISCUSS] add netty tcp/restful pushed source support - posted by shijinkui <sh...@huawei.com> on 2016/09/27 13:31:08 UTC, 1 replies.
- [DISCUSS] Removing delete*Timer from the WindowOperator.Context - posted by Kostas Kloudas <k....@data-artisans.com> on 2016/09/27 13:43:02 UTC, 1 replies.
- [jira] [Created] (FLINK-4697) Gather more detailed checkpoint stats in CheckpointStatsTracker - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 15:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4698) Visualize additional checkpoint information - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 15:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4699) Convert Kafka TableSource/TableSink tests to unit tests - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/27 15:51:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4700) Harden the TimeProvider test - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/09/27 16:07:20 UTC, 0 replies.
- flink 1.1.2 RichFunction not working - posted by Chen Bekor <ch...@gmail.com> on 2016/09/27 16:56:11 UTC, 4 replies.
- [jira] [Created] (FLINK-4701) Unprotected access to cancelables in StreamTask - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/27 18:04:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4702) Kafka consumer must commit offsets asynchronously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 19:08:20 UTC, 0 replies.
- scala api createLocalEnvironment() function add default Configuration parameter - posted by shijinkui <sh...@huawei.com> on 2016/09/28 00:54:47 UTC, 0 replies.
- How to interact with a running flink application? - posted by Anchit Jatana <de...@gmail.com> on 2016/09/28 07:36:31 UTC, 0 replies.
- DataInputStream read vs. readFully - posted by Ufuk Celebi <uc...@apache.org> on 2016/09/28 10:34:25 UTC, 1 replies.
- [jira] [Created] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasss - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/28 10:38:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4704) Move Table API to org.apache.flink.table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/28 13:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4705) Instrument FixedLengthRecordSorter - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/28 18:24:20 UTC, 0 replies.
- ClassNotFoundException - posted by Olga Golovneva <me...@gmail.com> on 2016/09/28 18:58:20 UTC, 2 replies.
- Use specific worker for heavy computations - posted by Mariano Gonzalez <ma...@uptake.com> on 2016/09/28 19:40:25 UTC, 0 replies.
- [jira] [Created] (FLINK-4706) Is there a way to load user classes first? - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/09/29 02:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4707) Including flink-connector-filesystem as dependency fails build - posted by "Melmoth (JIRA)" <ji...@apache.org> on 2016/09/29 05:58:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4708) Scope Mini Kerberos Cluster dependencies as test dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/29 08:58:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream - posted by "Holger Frydrych (JIRA)" <ji...@apache.org> on 2016/09/29 09:01:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4710) Remove transitive Guice dependency from Hadoop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/29 09:04:20 UTC, 0 replies.
- Releasing Flink 1.1.3 - posted by Stephan Ewen <se...@apache.org> on 2016/09/29 13:15:21 UTC, 4 replies.
- [jira] [Created] (FLINK-4711) TaskManager can crash due to failing onPartitionStateUpdate call - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/29 14:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4712) Implementing ranking predictions for ALS - posted by "Domokos Miklós Kelen (JIRA)" <ji...@apache.org> on 2016/09/29 15:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4713) Implementing ranking evaluation scores for recommender systems - posted by "Domokos Miklós Kelen (JIRA)" <ji...@apache.org> on 2016/09/29 15:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4714) Set task state to RUNNING after state has been restored - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/29 17:28:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4715) TaskManager should commit suicide after cancellation failure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/29 17:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4716) Add trigger full recovery button to web UI - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/29 17:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4717) Naive version of atomic stop signal with savepoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/29 18:07:20 UTC, 0 replies.
- Does the job name affect checkpointing? - posted by dan bress <da...@gmail.com> on 2016/09/29 20:58:39 UTC, 2 replies.
- currentLowWatermark metric not reported for all tasks? - posted by dan bress <da...@gmail.com> on 2016/09/29 21:03:14 UTC, 3 replies.
- Re: Use specific Task Manager for heavy computations - posted by Mariano Gonzalez <ma...@uptake.com> on 2016/09/29 22:07:56 UTC, 2 replies.
- [jira] [Created] (FLINK-4718) Confusing label in Parallel Streams Diagram - posted by "Neil Derraugh (JIRA)" <ji...@apache.org> on 2016/09/30 02:32:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4719) KryoSerializer random exception - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/09/30 09:27:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4720) Implement an archived version of the execution graph - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/30 10:29:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4721) Getting exception when using a key of type Option[String] in distinct operation - posted by "Ashish Walia (JIRA)" <ji...@apache.org> on 2016/09/30 19:52:20 UTC, 0 replies.