dev@flink.apache.org, 2016-05

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

- RE: Data locality and scheduler - posted by Eron Wright <ew...@live.com> on 2016/05/01 04:56:03 UTC, 1 replies.
- [jira] [Created] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 11:14:12 UTC, 0 replies.
- [DISCUSS] Add Side Input/Broadcast Set For Streaming API - posted by Aljoscha Krettek <al...@apache.org> on 2016/05/02 11:28:14 UTC, 1 replies.
- [jira] [Created] (FLINK-3857) Add reconnect attempt to Elasticsearch host - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/02 12:12:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3858) Date is wrongly serialized - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 15:48:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3859) Add BigDecimal/BigInteger support to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 17:11:12 UTC, 0 replies.
- Re: [DISCUSS] Macro-benchmarking for performance tuning and regression detection - posted by Stephan Ewen <se...@apache.org> on 2016/05/03 11:41:32 UTC, 0 replies.
- [jira] [Created] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/03 11:52:12 UTC, 0 replies.
- Get TaskManger Memory Configuration from ExecutionEnvironment - posted by Brücke, Christoph <ch...@campus.tu-berlin.de> on 2016/05/03 12:46:21 UTC, 1 replies.
- [jira] [Created] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/03 14:20:12 UTC, 0 replies.
- Re: [VOTE] Release Apache Flink 1.0.3 (RC2) - posted by Fabian Hueske <fh...@gmail.com> on 2016/05/03 15:44:35 UTC, 4 replies.
- Increasing MSE with additional iterations - posted by Trevor Grant <tr...@gmail.com> on 2016/05/03 16:58:11 UTC, 1 replies.
- [jira] [Created] (FLINK-3862) Restructure community slide - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/05/03 17:37:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3863) Yarn Cluster shutdown may fail if leader changed recently - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/03 18:00:14 UTC, 0 replies.
- [jira] [Created] (FLINK-3864) Yarn tests don't check for prohibited strings in log output - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/03 19:12:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3865) ExecutionConfig NullPointerException with second execution - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/03 21:58:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't - posted by "Tatu Saloranta (JIRA)" <ji...@apache.org> on 2016/05/04 01:36:13 UTC, 0 replies.
- Re: Intellij code style - posted by Henry Saputra <he...@gmail.com> on 2016/05/04 06:08:34 UTC, 8 replies.
- [jira] [Created] (FLINK-3867) Provide virtualized Flink architecture for testing purposes - posted by "Andreas Kempa-Liehr (JIRA)" <ji...@apache.org> on 2016/05/04 11:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3868) Specialized CopyableValue serializers and comparators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/04 13:33:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/04 14:04:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3870) Add IntelliJ code style file - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/05/04 15:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3871) Add Kafka TableSource with Avro serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 16:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3872) Add Kafka TableSource with JSON serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 16:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3873) Add a Kafka TableSink with Avro serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 16:41:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3874) Add a Kafka TableSink with JSON serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 16:42:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3875) Add a TableSink for Elasticsearch - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 16:42:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3876) Improve documentation of Scala Shell - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/04 17:50:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3877) Create TranslateFunction interface for Graph translators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/04 20:17:12 UTC, 0 replies.
- Using secure cluster resources without authentication - posted by Stefano Baghino <st...@radicalbit.io> on 2016/05/05 09:57:08 UTC, 4 replies.
- [jira] [Created] (FLINK-3878) File cache doesn't support multiple duplicate temp directories - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2016/05/05 23:27:12 UTC, 0 replies.
- License check failing - posted by Ken Krugler <kk...@transpac.com> on 2016/05/06 00:00:41 UTC, 0 replies.
- License check no longer failing (in master) - posted by Ken Krugler <kk...@transpac.com> on 2016/05/06 03:30:33 UTC, 1 replies.
- [RESULT] [VOTE] Release Apache Flink 1.0.3 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/05/06 12:53:38 UTC, 0 replies.
- [jira] [Created] (FLINK-3879) Native implementation of HITS algorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/06 15:11:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3880) Use ConcurrentHashMap for Accumulators - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2016/05/06 15:41:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3881) Error in Java 8 Documentation Sample - posted by "Mans Singh (JIRA)" <ji...@apache.org> on 2016/05/07 16:23:12 UTC, 0 replies.
- Janino related question - posted by Gábor Horváth <xa...@gmail.com> on 2016/05/08 12:59:02 UTC, 4 replies.
- [jira] [Created] (FLINK-3882) Errors in sample Java code for the Elasticsearch 2.x sink - posted by "Mark Reddy (JIRA)" <ji...@apache.org> on 2016/05/08 20:31:12 UTC, 0 replies.
- Installing Flink with Homebrew - posted by "Wright, Eron" <ew...@live.com> on 2016/05/08 20:38:44 UTC, 2 replies.
- [jira] [Created] (FLINK-3883) Rename flink clients for inclusion on system path - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/08 23:26:12 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.0.3 (RC3) - posted by Ufuk Celebi <uc...@apache.org> on 2016/05/09 08:24:22 UTC, 3 replies.
- [jira] [Created] (FLINK-3884) Snapshot quickstart projects don't include snapshot repository - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/09 09:49:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3885) Revisit parallelism logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/05/09 10:22:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3886) Give a better error when the application Main class is not public. - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/05/09 14:40:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3887) Improve dependency management for building docs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/09 15:09:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2016/05/09 18:54:12 UTC, 0 replies.
- Service frontend as a source and sink - posted by Maxim <mf...@gmail.com> on 2016/05/09 21:38:03 UTC, 1 replies.
- Guide for Flink Source/Sinks - posted by M Singh <ma...@yahoo.com.INVALID> on 2016/05/09 21:54:23 UTC, 5 replies.
- [PROPOSAL] Structure the Flink Open Source Development - posted by Stephan Ewen <se...@apache.org> on 2016/05/10 09:24:15 UTC, 27 replies.
- [jira] [Created] (FLINK-3889) Make File Monitoring Function checkpointable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/10 11:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3890) Deprecate streaming mode flag from Yarn CLI - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/10 12:04:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3891) Add a class containing all supported Table API types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/10 12:19:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3892) ConnectionUtils may die with NullPointerException - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/10 13:34:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3893) LeaderChangeStateCleanupTest times out - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/10 14:22:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3894) Remove Program Packaging via Plans - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/10 14:36:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3895) Remove Focs for Program Packaging via Plans - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/10 14:37:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3896) Allow a StreamTask to be Externally Cancelled. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/10 16:08:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3897) why does jobmanager process has too many ForkJoinTask object - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/11 03:56:12 UTC, 0 replies.
- [DISCUSS] Secure Flink clusters - posted by "Wright, Eron" <ew...@live.com> on 2016/05/11 07:09:52 UTC, 5 replies.
- RequiredParameters vs ParameterTool - posted by Flavio Pompermaier <po...@okkam.it> on 2016/05/11 09:04:55 UTC, 2 replies.
- [jira] [Created] (FLINK-3898) Adamic-Adar Similarity - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/11 14:03:13 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.0.3 (RC3) - posted by Ufuk Celebi <uc...@apache.org> on 2016/05/11 14:39:39 UTC, 5 replies.
- [QUESTION] thread model in Flink makes me confused - posted by Jark Wu <wu...@alibaba-inc.com> on 2016/05/11 15:32:28 UTC, 4 replies.
- How to specify dependencies for an application that needs to use modified version of Flink - posted by Saiph Kappa <sa...@gmail.com> on 2016/05/11 18:33:05 UTC, 4 replies.
- [ANNOUNCE] Flink 1.0.3 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/05/12 08:16:50 UTC, 0 replies.
- Dataset split/demultiplex - posted by CPC <ac...@gmail.com> on 2016/05/12 14:03:50 UTC, 6 replies.
- [jira] [Created] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/12 14:15:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3900) Set nullCheck=true as default in TableConfig - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/12 16:27:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3901) Create a RowCsvInputFormat to use as default CSV IF in Table API - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/12 16:33:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3902) Discarded FileSystem checkpoints are lingering around - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/12 16:38:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3903) Homebrew Installation - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/12 18:03:12 UTC, 0 replies.
- flink Kafka connector - posted by Arun Balan <ar...@gmail.com> on 2016/05/12 23:18:30 UTC, 0 replies.
- [jira] [Created] (FLINK-3904) GlobalConfiguration doesn't ensure config has been loaded - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/13 08:59:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3905) Add KafkaOutputFormat (DataSet API) - posted by "Maximilian Bode (JIRA)" <ji...@apache.org> on 2016/05/13 09:21:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3906) Global Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/13 13:45:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3907) Directed Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/13 14:38:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3908) FieldParsers error state is not reset correctly to NONE - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/13 15:18:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/13 16:12:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3910) New self-join operator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/13 18:18:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3911) Sort operation before a group reduce doesn't seem to be implemented on 1.0.2 - posted by "Patrice Freydiere (JIRA)" <ji...@apache.org> on 2016/05/13 20:33:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3912) Typos in Batch Scala API Documentation - posted by "Ignacio N. Lucero Ascencio (JIRA)" <ji...@apache.org> on 2016/05/13 21:38:12 UTC, 0 replies.
- Re: Partition problem - posted by Andrew Palumbo <ap...@outlook.com> on 2016/05/14 19:25:38 UTC, 4 replies.
- [jira] [Created] (FLINK-3913) Clean up documentation typos - posted by "Mark Reddy (JIRA)" <ji...@apache.org> on 2016/05/15 23:51:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3914) BlobServer.createTemporaryFilename() has concurrency safety problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/16 03:55:12 UTC, 0 replies.
- Performance and accuracy of Flink iterations - posted by Greg Hogan <co...@greghogan.com> on 2016/05/16 13:10:23 UTC, 3 replies.
- remote debugging - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2016/05/16 16:43:09 UTC, 18 replies.
- [jira] [Created] (FLINK-3915) Updating a Dataset in Flink using Flink's Table API - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/05/17 06:56:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3916) Allow generic types passing the Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/17 08:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3917) Remove mouse focus from plan visualizer - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/17 09:20:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3918) Not configuring any time characteristic leads to a ClassCastException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/17 10:14:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3919) Distributed Linear Algebra: row-based matrix - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/05/17 12:34:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3920) Distributed Linear Algebra: block-based matrix - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/05/17 12:35:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3921) StringParser not specifying encoding to use - posted by "Tatu Saloranta (JIRA)" <ji...@apache.org> on 2016/05/17 20:13:13 UTC, 0 replies.
- ITCases in the Table API - posted by Stephan Ewen <se...@apache.org> on 2016/05/18 08:23:51 UTC, 2 replies.
- [jira] [Created] (FLINK-3922) Infinite recursion on TypeExtractor - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/18 10:18:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/18 13:13:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3924) Remove protobuf shading from Kinesis connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/18 13:22:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3925) GraphAlgorithm to filter by maximum degree - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/18 15:28:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3926) Incorrect implementation of getFieldIndex in TupleTypeInfo - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/18 15:34:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3927) TaskManager registration may fail if Yarn versions don't match - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/18 15:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3928) Potential overflow due to 32-bit int arithmetic - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/18 16:08:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 19:07:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3930) Implement Service-Level Authorization - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 20:42:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3931) Implement Transport Encryption (SSL/TLS) - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 21:01:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3932) Implement State Backend Security - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 21:13:14 UTC, 0 replies.
- [QUESTION] the differences between DataStream.join() and DataStream.coGroup() - posted by Jark Wu <wu...@alibaba-inc.com> on 2016/05/19 07:05:13 UTC, 2 replies.
- [jira] [Created] (FLINK-3933) Add an auto-type-extracting DeserializationSchema - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/19 10:35:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3934) Prevent translation of non-equi joins in DataSetJoinRule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/19 12:08:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3935) Invalid check of key and ordering fields in PartitionNode - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/19 12:11:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3936) Add MIN / MAX aggregations function for BOOLEAN types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/19 13:12:12 UTC, 0 replies.
- buffering in operators, implementing statistics - posted by Stavros Kontopoulos <st...@gmail.com> on 2016/05/19 14:38:25 UTC, 7 replies.
- [jira] [Created] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/05/19 14:50:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3938) Yarn tests don't run on the current master - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/19 15:36:12 UTC, 0 replies.
- Preparing Table API & SQL for Flink 1.1.0 - posted by Fabian Hueske <fh...@gmail.com> on 2016/05/19 15:59:51 UTC, 7 replies.
- [jira] [Created] (FLINK-3939) Prevent distinct aggregates and grouping sets from being translated - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/19 22:53:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3940) Add support for ORDER BY OFFSET FETCH - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 09:22:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3941) Add support for UNION (with duplicate elimination) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 09:27:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3942) Add support for INTERSECT - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 09:31:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3943) Add support for EXCEPT (set minus) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 09:35:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3944) Add optimization rules to reorder Cartesian products and joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 12:59:13 UTC, 0 replies.
- Blogpost on Flink's SQL support - posted by Fabian Hueske <fh...@gmail.com> on 2016/05/20 15:12:18 UTC, 10 replies.
- [jira] [Created] (FLINK-3945) Degree annotation for directed graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/20 16:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3946) State API Should Support Data Expiration - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/05/20 20:44:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3947) Provide low level access to RocksDB state backend - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/05/20 21:32:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/21 06:40:12 UTC, 0 replies.
- Develop/Test within IDE - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2016/05/21 19:07:43 UTC, 1 replies.
- Re: XGBoost on DataFlow and Flink - posted by Henry Saputra <he...@gmail.com> on 2016/05/22 05:58:53 UTC, 0 replies.
- [jira] [Created] (FLINK-3949) Collect Metrics in Runtime Operators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/22 19:24:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3950) Add Meter Metric Type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/22 19:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3951) Add Histogram Metric Type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/22 19:26:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3952) Bump Netty to 4.1 - posted by "rektide de la fey (JIRA)" <ji...@apache.org> on 2016/05/22 22:53:12 UTC, 0 replies.
- Re: Master test stability poor - posted by Ufuk Celebi <uc...@apache.org> on 2016/05/23 07:53:33 UTC, 3 replies.
- [jira] [Created] (FLINK-3953) Surefire plugin executes unit tests twice - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/23 10:04:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3954) Installing Flink on EMR using EMR bootstrap action - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/05/23 11:31:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3955) Change Table.toSink() to Table.writeToSink() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/23 13:13:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3956) Make FileInputFormats in Streaming independent from the Configuration object - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/23 13:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3957) Breaking API changes for Flink 2.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/23 14:07:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/23 14:14:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3959) Remove implicit sinks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/23 14:29:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3960) EventTimeCheckpointingITCase fails with a segmentation fault - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/23 16:29:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3961) Possibility to write output to multiple locations based on partitions - posted by "Kirsti Laurila (JIRA)" <ji...@apache.org> on 2016/05/24 05:44:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/24 09:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3963) AbstractReporter uses shaded dependency - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/24 10:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3964) Job submission times out with recursive.file.enumeration - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2016/05/24 11:04:14 UTC, 0 replies.
- [jira] [Created] (FLINK-3965) Delegating GraphAlgorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/24 17:42:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3966) AvroTypeInfo does not work with readonly avro specific records - posted by "Matthew Burghoffer (JIRA)" <ji...@apache.org> on 2016/05/24 18:37:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3967) Provide RethinkDB Sink for Flink - posted by "Mans Singh (JIRA)" <ji...@apache.org> on 2016/05/25 00:53:12 UTC, 0 replies.
- Junit Issue while testing Kafka Source - posted by Vinay Patil <vi...@gmail.com> on 2016/05/25 02:29:15 UTC, 7 replies.
- [jira] [Created] (FLINK-3968) Cancel button on a running job not available on smaller screens - posted by "Lokesh Ravindranathan (JIRA)" <ji...@apache.org> on 2016/05/25 04:16:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3969) Log Exceptions Thrown by Invokable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/25 09:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3970) How to deal with "resouce isolation" problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/25 11:22:12 UTC, 0 replies.
- Error related to JMX and metrics - posted by Simone Robutti <si...@radicalbit.io> on 2016/05/25 12:22:43 UTC, 7 replies.
- [jira] [Created] (FLINK-3971) Aggregates handle null values incorrectly. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 14:51:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3972) Subclasses of ResourceID may not to be serializable - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/25 15:18:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3973) Table API documentation is "hidden" in Programming Guide menu list - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 16:25:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3974) enableObjectReuse fails when an operator chains to multiple downstream operators - posted by "B Wyatt (JIRA)" <ji...@apache.org> on 2016/05/25 16:28:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3975) docs build script isn't serving the preview on the correct base url - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2016/05/25 19:33:13 UTC, 0 replies.
- Motivation for Delta Iterations - posted by Trevor Grant <tr...@gmail.com> on 2016/05/25 23:57:24 UTC, 3 replies.
- [jira] [Created] (FLINK-3976) Alias fields of physical plan node to avoid name collision with Calcite protected fields - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/26 03:11:12 UTC, 0 replies.
- Fold error when window evictor is set - posted by Erik <er...@gmail.com> on 2016/05/26 07:13:17 UTC, 1 replies.
- [jira] [Created] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/26 07:47:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3978) Add contains methods to RuntimeContext - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/26 13:50:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3979) [documentation]add missed import classes in run_example_quickstart - posted by "Jia Zhai (JIRA)" <ji...@apache.org> on 2016/05/26 15:15:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3980) Remove ExecutionConfig.PARALLELISM_UNKNOWN - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/26 19:19:12 UTC, 0 replies.
- Iteration Intermediate Output - posted by Greg Hogan <co...@greghogan.com> on 2016/05/26 20:41:53 UTC, 5 replies.
- Hotfixes on the master - posted by Maximilian Michels <mx...@apache.org> on 2016/05/27 10:10:56 UTC, 3 replies.
- Savepoints and memory statebackend - posted by Gyula Fóra <gy...@gmail.com> on 2016/05/27 16:09:05 UTC, 4 replies.
- [jira] [Created] (FLINK-3981) Don't log duplicate TaskManager registrations as exceptions - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/27 19:10:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3982) Multiple ResourceManagers register at JobManager in standalone HA mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/27 19:49:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3983) Allow users to set any (relevant) configuration parameter of the KinesisProducerConfiguration - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/27 21:10:14 UTC, 0 replies.
- [jira] [Created] (FLINK-3984) Event time of stream transformations is undocumented - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/05/28 01:53:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3985) A metric with the name * was already registered - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/28 07:10:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3986) Rename the readFileStream(String filePath, long intervalMillis, WatchType watchType) from the StreamExecutionEnvironment - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/28 10:56:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3987) Add data stream connector to DistributedLog - posted by "Jia Zhai (JIRA)" <ji...@apache.org> on 2016/05/29 03:04:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3988) Add data set connector to DistributedLog - posted by "Jia Zhai (JIRA)" <ji...@apache.org> on 2016/05/29 03:05:12 UTC, 0 replies.
- Would like to add a connector to DistributedLog. - posted by Jia Zhai <zh...@gmail.com> on 2016/05/29 03:33:20 UTC, 5 replies.
- [jira] [Created] (FLINK-3989) Add guide to write a custom streaming source / sink in DataStream API documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/05/29 05:09:12 UTC, 0 replies.
- Re: GSoC Project Proposal Draft: Code Generation in Serializers - posted by Gábor Horváth <xa...@gmail.com> on 2016/05/29 09:59:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/29 18:00:15 UTC, 0 replies.
- Side-effects of DataSet::count - posted by Eron Wright <ew...@live.com> on 2016/05/29 21:28:20 UTC, 9 replies.
- Re: [DISCUSS] Allowed Lateness in Flink - posted by Aljoscha Krettek <al...@apache.org> on 2016/05/30 08:33:44 UTC, 2 replies.
- NLP & Constraint Programming - posted by "Debusmann, Ralph" <ra...@sap.com> on 2016/05/30 11:18:10 UTC, 1 replies.
- [jira] [Created] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/30 13:18:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3992) Remove Key interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/05/30 13:27:12 UTC, 0 replies.
- PojoComparator question - posted by Gábor Horváth <xa...@gmail.com> on 2016/05/30 17:13:34 UTC, 2 replies.
- [ANNOUNCE] Build Issues Solved - posted by Stephan Ewen <se...@apache.org> on 2016/05/30 21:03:18 UTC, 11 replies.
- [jira] [Created] (FLINK-3993) [py] Add generateSequence() support to Python AP - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/05/31 08:16:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3994) Instable KNNITSuite - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/05/31 09:42:12 UTC, 0 replies.
- Collision of task number values for the same task - posted by Alexander Alexandrov <al...@gmail.com> on 2016/05/31 09:53:18 UTC, 4 replies.
- [jira] [Created] (FLINK-3995) Properly Structure Test Utils and Dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/31 10:29:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3996) Add addition, subtraction and multiply by scalar to DenseVector.scala and SparseVector.scala - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2016/05/31 10:57:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3997) PRNG Skip-ahead - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/31 14:02:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3998) Access to gauges and counters in StatsDReporter#report() is not properly synchronized - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/31 16:28:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3999) Rename the `running` flag in the drivers to `canceled` - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/31 17:54:13 UTC, 0 replies.