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

---

- [jira] [Closed] (FLINK-2338) Shut down "Storm Topologies" cleanly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/04/01 00:41:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/04/01 01:24:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3523] [Storm-Compatibility] Added Split... - posted by mjsax <gi...@git.apache.org> on 2016/04/01 01:28:07 UTC, 11 replies.
- [jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 01:28:25 UTC, 12 replies.
- [GitHub] flink pull request: [FLINK-3635] Potential null deference in Twitt... - posted by skyahead <gi...@git.apache.org> on 2016/04/01 04:42:27 UTC, 3 replies.
- [jira] [Commented] (FLINK-3635) Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 04:43:25 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3541] [Kafka Connector] Clean up workar... - posted by skyahead <gi...@git.apache.org> on 2016/04/01 06:36:04 UTC, 10 replies.
- [jira] [Commented] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 06:36:25 UTC, 10 replies.
- [GitHub] flink pull request: Refactor rolling sink writer - posted by dalegaard <gi...@git.apache.org> on 2016/04/01 08:02:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/04/01 09:23:25 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3678] Make Flink logs directory configu... - posted by stefanobaghino <gi...@git.apache.org> on 2016/04/01 10:07:29 UTC, 4 replies.
- [jira] [Commented] (FLINK-3678) Make Flink logs directory configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 10:08:25 UTC, 3 replies.
- [jira] [Created] (FLINK-3686) resourcemanager.ClusterShutdownITCase sometimes fails - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/01 10:57:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3686) resourcemanager.ClusterShutdownITCase sometimes fails - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/01 10:59:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3687) runtime.leaderelection.ZooKeeperLeaderElectionTest fails - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/01 11:01:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3687) runtime.leaderelection.ZooKeeperLeaderElectionTest fails - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/01 11:02:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3687) runtime.leaderelection.ZooKeeperLeaderElectionTest fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/01 11:05:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3687) org.apache.flink.runtime.net.ConnectionUtilsTest fails - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/01 11:10:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3687) org.apache.flink.runtime.net.ConnectionUtilsTest fails - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/01 11:10:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/04/01 11:36:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1159] Case style anonymous functions no... - posted by stefanobaghino <gi...@git.apache.org> on 2016/04/01 11:54:46 UTC, 6 replies.
- [jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 11:55:25 UTC, 6 replies.
- [jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/01 12:04:25 UTC, 13 replies.
- [GitHub] flink pull request: FLINK-3579 Improve String concatenation (Ram) - posted by ramkrish86 <gi...@git.apache.org> on 2016/04/01 13:02:09 UTC, 8 replies.
- [jira] [Commented] (FLINK-3579) Improve String concatenation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 13:02:25 UTC, 9 replies.
- [jira] [Commented] (FLINK-2946) Add orderBy() to Table API - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/04/01 13:29:25 UTC, 18 replies.
- [jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/04/01 13:34:25 UTC, 35 replies.
- [jira] [Updated] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/01 13:59:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3633] Fix user code de/serialization in... - posted by tillrohrmann <gi...@git.apache.org> on 2016/04/01 13:59:59 UTC, 3 replies.
- [jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 14:00:28 UTC, 3 replies.
- [jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/01 14:01:25 UTC, 24 replies.
- [jira] [Comment Edited] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/01 14:06:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/01 14:26:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3689] fix shutdown of JM when RM is not... - posted by mxm <gi...@git.apache.org> on 2016/04/01 14:28:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 14:28:25 UTC, 5 replies.
- [jira] [Updated] (FLINK-3633) Job submission silently fails when using user code types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/01 14:34:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3678) Make Flink logs directory configurable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/01 15:55:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3667) Generalize client<->cluster communication - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2016/04/01 17:29:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3690) Create documentation on the new ResourceManager component - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2016/04/01 17:32:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3633) Job submission silently fails when using user code types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/01 18:11:25 UTC, 0 replies.
- [GitHub] flink pull request: [docs] Add first version of "Concepts" documen... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/01 18:49:14 UTC, 1 replies.
- [jira] [Commented] (FLINK-3690) Create documentation on the new ResourceManager component - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/01 20:03:25 UTC, 1 replies.
- [jira] [Closed] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/01 20:38:25 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3428: Adds a fixed time trailing waterma... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/01 20:38:38 UTC, 12 replies.
- [jira] [Commented] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 20:39:25 UTC, 12 replies.
- [GitHub] flink pull request: [FLINK-3560] [examples] Remove unchecked outpu... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/01 20:41:36 UTC, 4 replies.
- [jira] [Commented] (FLINK-3560) Examples shouldn't always print usage statement - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 20:42:25 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3519] [core] Add warning about subclass... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/01 20:48:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/01 20:48:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3691) Extend AvroInputFormat to support Avro GenericRecord - posted by "Gna Phetsarath (JIRA)" <ji...@apache.org> on 2016/04/01 21:44:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3691) Extend AvroInputFormat to support Avro GenericRecord - posted by "Gna Phetsarath (JIRA)" <ji...@apache.org> on 2016/04/01 21:46:25 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3657: Change access of DataSetUtils.coun... - posted by mbalassi <gi...@git.apache.org> on 2016/04/02 00:09:21 UTC, 10 replies.
- [jira] [Commented] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public' - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/02 00:09:25 UTC, 12 replies.
- [jira] [Commented] (FLINK-3664) Create a method to easily Summarize a DataSet - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/02 00:31:25 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-3665] Implemented sort orders support i... - posted by dawidwys <gi...@git.apache.org> on 2016/04/02 13:16:44 UTC, 34 replies.
- [jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat - posted by "Tian Li (JIRA)" <ji...@apache.org> on 2016/04/02 18:18:25 UTC, 6 replies.
- [jira] [Closed] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public' - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/04/02 19:27:25 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2375] Add Approximate Adamic Adar Simil... - posted by shghatge <gi...@git.apache.org> on 2016/04/03 22:10:42 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2310] Add an Adamic Adar Similarity exa... - posted by shghatge <gi...@git.apache.org> on 2016/04/03 22:10:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-2375) Add Approximate Adamic Adar Similarity method using BloomFilters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/03 22:11:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-2310) Add an Adamic-Adar Similarity example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/03 22:11:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3035) Redis as State Backend - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/04/04 02:53:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3692) Develop a Kafka state backend - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/04/04 03:45:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3691) Extend AvroInputFormat to support Avro GenericRecord - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/04 10:14:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-3692) Develop a Kafka state backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/04 10:25:25 UTC, 1 replies.
- [GitHub] flink pull request: Updates the AssignerWithPunctuatedWatermarks a... - posted by kl0u <gi...@git.apache.org> on 2016/04/04 11:03:32 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2522] Streaming support for Flink-Scala... - posted by mxm <gi...@git.apache.org> on 2016/04/04 11:07:40 UTC, 17 replies.
- [jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 11:08:25 UTC, 17 replies.
- [GitHub] flink pull request: [FLINK-2157] [ml] Create evaluation framework ... - posted by thvasilo <gi...@git.apache.org> on 2016/04/04 11:38:19 UTC, 10 replies.
- [jira] [Commented] (FLINK-2157) Create evaluation framework for ML library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 11:38:25 UTC, 10 replies.
- [GitHub] flink pull request: [hotfix][examples] Add zookeeper.connect to us... - posted by rmetzger <gi...@git.apache.org> on 2016/04/04 12:25:44 UTC, 3 replies.
- [jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 12:37:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3635) Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/04 12:53:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3635) Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/04 12:54:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Josep Rubió (JIRA)" <ji...@apache.org> on 2016/04/04 13:06:25 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard - posted by mxm <gi...@git.apache.org> on 2016/04/04 14:13:14 UTC, 5 replies.
- [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 14:13:25 UTC, 5 replies.
- [jira] [Created] (FLINK-3693) JobManagerHAJobGraphRecoveryITCase.testClientNonDetachedListeningBehaviour is unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 14:15:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3693) JobManagerHAJobGraphRecoveryITCase.testClientNonDetachedListeningBehaviour is unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 14:15:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3619) SavepointCoordinator test failure - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 14:17:25 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3693) JobManagerHAJobGraphRecoveryITCase.testClientNonDetachedListeningBehaviour is unstable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 14:18:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3693) JobManagerHAJobGraphRecoveryITCase.testClientNonDetachedListeningBehaviour is unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 14:19:25 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3638) Invalid default ports in documentation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/04 14:32:25 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3529 Add template for pull requests - posted by mxm <gi...@git.apache.org> on 2016/04/04 14:36:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-3529) Add pull request template - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 14:36:25 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3644] WebRuntimMonitor set java.io.tmpd... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/04 14:44:10 UTC, 9 replies.
- [jira] [Commented] (FLINK-3644) WebRuntimMonitor set java.io.tmpdir does not work for change upload dir. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 14:44:25 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-3623] [runtime] Adjust MurmurHash Algor... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/04 14:50:21 UTC, 1 replies.
- [jira] [Closed] (FLINK-3686) resourcemanager.ClusterShutdownITCase sometimes fails - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/04 14:50:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3623) Adjust MurmurHash algorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 14:50:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-3283) Failed Kafka 0.9 test on duplicate message - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 14:51:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-3619) SavepointCoordinator test failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 14:56:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3174] Add MergingWindowAssigner and Ses... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/04 15:23:50 UTC, 4 replies.
- [jira] [Commented] (FLINK-3174) Add merging WindowAssigner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 15:24:25 UTC, 4 replies.
- [jira] [Commented] (FLINK-2685) TaskManager deadlock on NetworkBufferPool - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 15:32:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3451) NettyServer port is determined via NetUtils.getAvailablePort() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 15:33:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3451) NettyServer port is determined via NetUtils.getAvailablePort() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 15:33:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3595] [runtime] Eagerly destroy buffer ... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/04 15:41:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-3595) Kafka09 consumer thread does not interrupt when stuck in record emission - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 15:41:25 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3524] [kafka] Add JSONDeserializationSc... - posted by rmetzger <gi...@git.apache.org> on 2016/04/04 15:50:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-3524) Provide a JSONDeserialisationSchema in the kafka connector package - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 15:50:25 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3524) Provide a JSONDeserialisationSchema in the kafka connector package - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 15:51:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3492] Configurable interval between Che... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/04 15:52:21 UTC, 9 replies.
- [jira] [Commented] (FLINK-3492) Allow users to define a min pause between checkpoints - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 15:52:25 UTC, 10 replies.
- [jira] [Commented] (FLINK-3571) SavepointITCase.testRestoreFailure fails on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 16:03:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 16:04:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 16:04:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2609] [streaming] auto-register types - posted by StephanEwen <gi...@git.apache.org> on 2016/04/04 16:04:25 UTC, 5 replies.
- [jira] [Commented] (FLINK-2609) Automatic type registration is only called from the batch execution environment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 16:04:26 UTC, 5 replies.
- [jira] [Closed] (FLINK-3443) JobManager cancel and clear everything fails jobs instead of cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 16:05:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/04 16:06:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3694) Document stoppable function interface for custom sources - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/04 16:11:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3693) JobManagerHAJobGraphRecoveryITCase.testClientNonDetachedListeningBehaviour is unstable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 16:35:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3685) Logical error in code for DateSerializer deserialize with reuse - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 16:38:25 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3634] [docs] Fix documentation for Data... - posted by greghogan <gi...@git.apache.org> on 2016/04/04 16:38:44 UTC, 2 replies.
- [jira] [Commented] (FLINK-3634) Fix documentation for DataSetUtils.zipWithUniqueId() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 16:39:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/04 16:42:25 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/04 16:42:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2909] [Gelly] Graph generators - posted by greghogan <gi...@git.apache.org> on 2016/04/04 16:44:42 UTC, 18 replies.
- [jira] [Commented] (FLINK-2909) Gelly Graph Generators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 16:45:25 UTC, 19 replies.
- [jira] [Updated] (FLINK-3576) Upgrade Snappy Java to 1.1.2.1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/04 16:47:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/04 16:53:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2674) Rework windowing logic - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/04 16:54:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3654] Disable Write-Ahead-Log in RocksD... - posted by aljoscha <gi...@git.apache.org> on 2016/04/04 16:58:27 UTC, 8 replies.
- [jira] [Commented] (FLINK-3654) Disable Write-Ahead-Log in RocksDB State - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 16:59:25 UTC, 8 replies.
- [jira] [Commented] (FLINK-3576) Upgrade Snappy Java to 1.1.2.1 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/04 17:10:26 UTC, 0 replies.
- [jira] [Created] (FLINK-3695) ValueArray types - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/04 17:14:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3589] Allow setting Operator parallelis... - posted by greghogan <gi...@git.apache.org> on 2016/04/04 17:26:55 UTC, 4 replies.
- [jira] [Commented] (FLINK-3589) Allow setting Operator parallelism to default value - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/04 17:27:25 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat - posted by "Tian, Li (JIRA)" <ji...@apache.org> on 2016/04/04 17:45:25 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3576) Upgrade Snappy Java to 1.1.2.1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/04 17:49:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3619) SavepointCoordinator test failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 17:55:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3696) Some Union tests fail for TableConfigMode.EFFICIENT - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/04 17:58:25 UTC, 0 replies.
- [GitHub] flink pull request: - posted by uce <gi...@git.apache.org> on 2016/04/04 18:02:37 UTC, 7 replies.
- [jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 19:44:25 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/04/04 20:13:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes - posted by "Ron Crocker (JIRA)" <ji...@apache.org> on 2016/04/04 21:11:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3595) Kafka09 consumer thread does not interrupt when stuck in record emission - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/04 21:29:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1159) Case style anonymous functions not supported by Scala API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/04 21:33:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3623) Adjust MurmurHash algorithm - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/04 21:34:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3623) Adjust MurmurHash algorithm - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/04 21:34:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes - posted by "Ron Crocker (JIRA)" <ji...@apache.org> on 2016/04/04 22:10:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3698) Scala Option can't be used as a key - posted by "Timur Fayruzov (JIRA)" <ji...@apache.org> on 2016/04/05 00:12:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3698) Scala Option can't be used as a key - posted by "Timur Fayruzov (JIRA)" <ji...@apache.org> on 2016/04/05 01:11:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3699) Allow per-job Kerberos authentication - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/04/05 10:20:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/05 11:40:25 UTC, 12 replies.
- [jira] [Created] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/05 12:38:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/05 13:47:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/05 13:55:25 UTC, 14 replies.
- [jira] [Created] (FLINK-3701) Cant call execute after first execution - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/05 13:55:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3701) Cant call execute after first execution - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/05 13:57:25 UTC, 4 replies.
- [jira] [Created] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/05 14:19:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3703) Add sequence matching semantics to discard matched events - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/05 14:21:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3697] Properly access type information ... - posted by rmetzger <gi...@git.apache.org> on 2016/04/05 14:51:22 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3689] do not shutdown test ActorSystem - posted by mxm <gi...@git.apache.org> on 2016/04/05 15:18:32 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3700] [core] Add 'Preconditions' utilit... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/05 15:30:10 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-3700] [core] Remove Guava as a dependen... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/05 15:33:44 UTC, 3 replies.
- [GitHub] flink pull request: FLINK-3398: Allow for opting-out from Kafka of... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/05 15:58:42 UTC, 2 replies.
- [jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/05 15:59:25 UTC, 2 replies.
- [jira] [Created] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/05 16:18:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto... - posted by rmetzger <gi...@git.apache.org> on 2016/04/05 16:35:01 UTC, 24 replies.
- [jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/05 16:35:26 UTC, 24 replies.
- [GitHub] flink pull request: [FLINK-3614] Remove Non-Keyed Window Operator - posted by aljoscha <gi...@git.apache.org> on 2016/04/05 17:20:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-3614) Remove Non-Keyed Window Operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/05 17:20:25 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3614) Remove Non-Keyed Window Operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/05 17:21:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3174) Add merging WindowAssigner - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/05 17:22:26 UTC, 0 replies.
- [jira] [Created] (FLINK-3705) Provide explanation for Hadoop dependencies and how to configure it - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/05 17:26:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/05 17:44:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/05 17:44:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-1337) Create an Amazon EMR Bootstrap Action - posted by "Timur Fayruzov (JIRA)" <ji...@apache.org> on 2016/04/05 17:59:25 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3283) Failed Kafka 0.9 test on duplicate message - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/05 18:18:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ... - posted by aljoscha <gi...@git.apache.org> on 2016/04/05 18:21:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/05 18:22:25 UTC, 24 replies.
- [GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE... - posted by aljoscha <gi...@git.apache.org> on 2016/04/05 18:24:24 UTC, 6 replies.
- [jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/05 18:24:25 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3637] Refactor rolling sink writer - posted by aljoscha <gi...@git.apache.org> on 2016/04/05 18:25:20 UTC, 7 replies.
- [jira] [Commented] (FLINK-3637) Change RollingSink Writer interface to allow wider range of outputs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/05 18:25:25 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2143] Added ReduceFunctionWithInverse - posted by aljoscha <gi...@git.apache.org> on 2016/04/05 18:26:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/05 18:27:25 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/05 18:51:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3696) Some Union tests fail for TableConfigMode.EFFICIENT - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/05 19:42:25 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3664] Create method to easily summarize... - posted by tlisonbee <gi...@git.apache.org> on 2016/04/05 23:31:36 UTC, 9 replies.
- [jira] [Commented] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2016/04/06 05:05:25 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2016/04/06 05:06:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/04/06 06:55:25 UTC, 6 replies.
- [GitHub] flink pull request: FLINK-3650 Add maxBy/minBy to Scala DataSet AP... - posted by ramkrish86 <gi...@git.apache.org> on 2016/04/06 08:38:53 UTC, 6 replies.
- [jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/06 08:39:25 UTC, 6 replies.
- [jira] [Updated] (FLINK-1337) Create an Amazon EMR Bootstrap Action - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/06 10:01:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3444] env.fromElements relies on the fi... - posted by gallenvara <gi...@git.apache.org> on 2016/04/06 10:10:06 UTC, 14 replies.
- [jira] [Commented] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/06 10:10:25 UTC, 21 replies.
- [jira] [Closed] (FLINK-3529) Add pull request template - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/06 10:17:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3707) Add missing Rich(Flat)JoinCoGroupFunction - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/06 11:18:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3637) Change RollingSink Writer interface to allow wider range of outputs - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/06 11:34:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3707) Add missing Rich(Flat)JoinCoGroupFunction - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/06 11:36:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3705) Provide explanation for Hadoop dependencies and how to configure it - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/06 11:57:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3708) Scala API for CEP - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/06 13:48:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/06 15:22:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/04/06 16:45:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3709) [streaming] Graph event rates over time - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2016/04/06 18:49:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3589) Allow setting Operator parallelism to default value - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/06 21:28:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3469) Improve documentation for grouping keys - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/06 21:44:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3469] Improve documentation for groupin... - posted by greghogan <gi...@git.apache.org> on 2016/04/06 22:08:33 UTC, 3 replies.
- [jira] [Commented] (FLINK-3469) Improve documentation for grouping keys - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/06 22:09:25 UTC, 3 replies.
- [jira] [Updated] (FLINK-3395) Polishing the web UI - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/06 22:09:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/04/07 00:11:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3711) Scala fold() example syntax incorrect - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/04/07 06:00:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-3711) Scala fold() example syntax incorrect - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/04/07 06:00:28 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3711][docs] Documentation of Scala fold... - posted by rehevkor5 <gi...@git.apache.org> on 2016/04/07 06:32:31 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3699) Allow per-job Kerberos authentication - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/04/07 10:55:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3711) Scala fold() example syntax incorrect - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/07 10:57:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3712) YARN client dynamic properties are not passed correctly to the leader election service on the client - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/07 11:17:26 UTC, 0 replies.
- [jira] [Created] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/07 11:47:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/07 11:48:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/07 12:14:25 UTC, 6 replies.
- [jira] [Resolved] (FLINK-3654) Disable Write-Ahead-Log in RocksDB State - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/07 12:23:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3688] WindowOperator.trigger() does not... - posted by knaufk <gi...@git.apache.org> on 2016/04/07 12:31:40 UTC, 3 replies.
- [jira] [Updated] (FLINK-3643) Improve Windowing - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/07 14:03:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3714) Add Support for "Allowed Lateness" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/07 14:17:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/07 14:26:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/07 16:04:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3640] Add support for SQL in DataSet pr... - posted by vasia <gi...@git.apache.org> on 2016/04/07 17:13:59 UTC, 11 replies.
- [jira] [Commented] (FLINK-3640) Add support for SQL queries in DataSet programs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/07 17:14:25 UTC, 25 replies.
- [jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/07 17:45:25 UTC, 2 replies.
- [jira] [Updated] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/07 17:46:25 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3712] Make all dynamic properties avail... - posted by rmetzger <gi...@git.apache.org> on 2016/04/07 17:58:05 UTC, 3 replies.
- [jira] [Commented] (FLINK-3712) YARN client dynamic properties are not passed correctly to the leader election service on the client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/07 17:58:25 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/04/07 22:24:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3716) Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/07 22:41:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3716) Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/07 22:43:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-3716) Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/07 22:44:25 UTC, 6 replies.
- [jira] [Commented] (FLINK-3709) [streaming] Graph event rates over time - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/08 11:03:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-2314) Make Streaming File Sources Persistent - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/08 12:25:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3717) Add functionality to get the current offset of a source with a FileInputFormat - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/08 12:31:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3670) Kerberos: Improving long-running streaming jobs - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/04/08 13:41:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3718) Add Option For Completely Async Backup in RocksDB State Backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/08 13:43:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3719) WebInterface: Moving the barrier between graph and stats - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/04/08 13:53:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3584) WebInterface: Broken graphical display in Chrome - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/04/08 13:54:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/04/08 13:55:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3717) Add functionality to get the current offset of a source with a FileInputFormat - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/08 15:48:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/08 15:52:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3720) Add warm starts for models - posted by "Trevor Grant (JIRA)" <ji...@apache.org> on 2016/04/08 16:58:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3716] Kafka08ITCase.testFailOnNoBroker(... - posted by tlisonbee <gi...@git.apache.org> on 2016/04/08 17:54:54 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/04/08 18:19:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-1404) Add support to cache intermediate results - posted by "Ovidiu Marcu (JIRA)" <ji...@apache.org> on 2016/04/08 20:16:25 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3279) Optionally disable DistinctOperator combiner - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/08 20:19:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al... - posted by hsaputra <gi...@git.apache.org> on 2016/04/08 20:26:14 UTC, 19 replies.
- [jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/08 20:26:25 UTC, 19 replies.
- [jira] [Commented] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20 - posted by "Soila Kavulya (JIRA)" <ji...@apache.org> on 2016/04/08 20:43:25 UTC, 8 replies.
- [jira] [Created] (FLINK-3721) Min and max accumulators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/08 21:03:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK][3720] Added Warm Starts - posted by rawkintrevo <gi...@git.apache.org> on 2016/04/08 21:56:05 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3721] Min and max accumulators - posted by greghogan <gi...@git.apache.org> on 2016/04/08 23:15:12 UTC, 4 replies.
- [jira] [Commented] (FLINK-3721) Min and max accumulators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/08 23:15:25 UTC, 4 replies.
- [jira] [Created] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/04/09 12:40:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/04/10 11:07:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/04/10 11:48:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine ... - posted by aalexandrov <gi...@git.apache.org> on 2016/04/11 00:21:20 UTC, 4 replies.
- [jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/11 00:21:25 UTC, 4 replies.
- [GitHub] flink pull request: Flink-3429: adds a histogram-based watermark e... - posted by kl0u <gi...@git.apache.org> on 2016/04/11 11:24:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-3429) Add histogram-based timestamp/watermark extractor - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/11 11:26:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3724) testJoinPushThroughJoin fails for TableConfigMode=EFFICIENT - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 11:30:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3712) YARN client dynamic properties are not passed correctly to the leader election service on the client - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/11 11:39:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/11 11:40:25 UTC, 10 replies.
- [jira] [Commented] (FLINK-3724) testJoinPushThroughJoin fails for TableConfigMode=EFFICIENT - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/11 11:52:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3725) Exception in thread "main" scala.MatchError: ... (of class scala.Tuple4) - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/04/11 13:18:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/11 13:51:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3726) Error while reading configuration: Cannot read property 0 - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/04/11 14:08:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3634) Fix documentation for DataSetUtils.zipWithUniqueId() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/11 14:22:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3469) Improve documentation for grouping keys - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/11 14:24:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3640] [docs] extend the Table API docs ... - posted by vasia <gi...@git.apache.org> on 2016/04/11 15:22:56 UTC, 13 replies.
- [jira] [Updated] (FLINK-2909) Gelly Graph Generators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/11 15:25:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3727) Add support for embedded streaming SQL (projection, filter, union) - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 15:33:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3728) Find a way to exclude unsupported SQL features - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 15:48:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3721) Min and max accumulators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/11 16:39:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3712) YARN client dynamic properties are not passed correctly to the leader election service on the client - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/11 16:51:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2998] Support range partition compariso... - posted by fhueske <gi...@git.apache.org> on 2016/04/11 17:55:06 UTC, 34 replies.
- [jira] [Commented] (FLINK-2998) Support range partition comparison for multi input nodes. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/11 17:55:25 UTC, 34 replies.
- [jira] [Resolved] (FLINK-3579) Improve String concatenation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 18:05:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3640) Add support for SQL queries in DataSet programs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 18:05:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3729) Several SQL tests fail on Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/11 18:08:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3729) Several SQL tests fail on Windows OS - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/04/11 18:19:25 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/04/11 18:24:25 UTC, 3 replies.
- [jira] [Closed] (FLINK-3492) Allow users to define a min pause between checkpoints - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/11 18:38:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3730) Fix RocksDB Local Directory Initialization - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/11 18:55:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3731) Embedded SQL outer joins should fail during translation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 19:06:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3732) Potential null deference in ExecutionConfig#equals() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/11 19:42:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3126) Remove accumulator type from "value" in web frontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/11 19:45:25 UTC, 2 replies.
- [GitHub] flink pull request: FLINK-3126 : Remove accumulator type from "val... - posted by ZackPierce <gi...@git.apache.org> on 2016/04/11 19:45:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/11 19:46:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/11 19:54:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/11 19:57:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3735) Embedded SQL union should fail during translation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 19:58:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3731] make embedded SQL outer joins fai... - posted by vasia <gi...@git.apache.org> on 2016/04/11 20:01:06 UTC, 3 replies.
- [jira] [Created] (FLINK-3736) Move toRexNode and toAggCall logic into Expressions - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/04/11 20:01:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3736) Move toRexNode and toAggCall logic into Expressions - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/04/11 20:01:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-3731) Embedded SQL outer joins should fail during translation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/11 20:01:25 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3736][TableAPI]Move toRexNode & toAggCa... - posted by yjshen <gi...@git.apache.org> on 2016/04/11 20:04:52 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3732] [Core] Potential null deference i... - posted by skyahead <gi...@git.apache.org> on 2016/04/11 20:05:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-3736) Move toRexNode and toAggCall logic into Expressions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/11 20:05:25 UTC, 8 replies.
- [jira] [Commented] (FLINK-3732) Potential null deference in ExecutionConfig#equals() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/11 20:05:25 UTC, 3 replies.
- [jira] [Created] (FLINK-3737) WikipediaEditsSourceTest.testWikipediaEditsSource() fails locally - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/11 20:37:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3737) WikipediaEditsSourceTest.testWikipediaEditsSource() fails locally - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/11 20:39:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3738) Refactor TableEnvironment and TranslationContext - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/11 21:58:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3737) WikipediaEditsSourceTest.testWikipediaEditsSource() fails locally - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 00:19:25 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-3737] testWikipediaEditsSource() adding... - posted by tlisonbee <gi...@git.apache.org> on 2016/04/12 00:49:08 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3730] Fix RocksDB Local Directory Initi... - posted by aljoscha <gi...@git.apache.org> on 2016/04/12 10:50:47 UTC, 2 replies.
- [jira] [Commented] (FLINK-3730) Fix RocksDB Local Directory Initialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/12 10:51:25 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3731) Embedded SQL outer joins should fail during translation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/12 11:27:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3735) Embedded SQL union should fail during translation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/12 11:28:25 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3738) Refactor TableEnvironment and TranslationContext - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/12 11:57:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3739) Add a null literal to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/12 12:11:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3581) Add Special Aligned Event-Time WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/12 12:40:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3581) Add Special Aligned Event-Time WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/12 12:45:25 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3735) Embedded SQL union should fail during translation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/12 14:58:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3735] Make DataSetUnionRule match only ... - posted by vasia <gi...@git.apache.org> on 2016/04/12 15:15:01 UTC, 4 replies.
- [jira] [Commented] (FLINK-3735) Embedded SQL union should fail during translation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/12 15:15:25 UTC, 4 replies.
- [jira] [Created] (FLINK-3740) Session Window State is Not Checkpointed - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/12 16:11:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3739) Add a null literal to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/12 16:28:25 UTC, 22 replies.
- [jira] [Closed] (FLINK-3736) Move toRexNode and toAggCall logic into Expressions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/12 18:52:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found. - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 19:05:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found. - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 19:06:25 UTC, 4 replies.
- [jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/12 19:36:25 UTC, 12 replies.
- [jira] [Created] (FLINK-3742) Add Multi Layer Perceptron Predictor - posted by "Trevor Grant (JIRA)" <ji...@apache.org> on 2016/04/12 20:15:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3742] Add Multilayer Perceptron - posted by rawkintrevo <gi...@git.apache.org> on 2016/04/12 20:20:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3742) Add Multi Layer Perceptron Predictor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/12 20:21:25 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3126] Remove accumulator type from "val... - posted by StephanEwen <gi...@git.apache.org> on 2016/04/12 21:18:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3721) Min and max accumulators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/12 22:03:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3721) Min and max accumulators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/12 22:04:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3743) Upgrate breeze from 0.11.2 to 0.12 - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 23:22:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3743) Upgrate breeze from 0.11.2 to 0.12 - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 23:23:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-3743) Upgrade breeze from 0.11.2 to 0.12 - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 23:24:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3743] upgrading breeze from 0.11.2 to 0... - posted by tlisonbee <gi...@git.apache.org> on 2016/04/12 23:26:06 UTC, 2 replies.
- [jira] [Commented] (FLINK-3743) Upgrade breeze from 0.11.2 to 0.12 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/12 23:26:25 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found. - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 23:29:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3744) LocalFlinkMiniClusterITCase times out occasionally when building locally - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 23:33:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3744) LocalFlinkMiniClusterITCase times out occasionally when building locally - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 23:33:25 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3742][ml] Add Multilayer Perceptron - posted by tlisonbee <gi...@git.apache.org> on 2016/04/13 00:14:21 UTC, 2 replies.
- [jira] [Created] (FLINK-3745) TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/13 00:54:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3746) WebRuntimeMonitorITCase.testNoCopyFromJar failing intermittently - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/13 01:21:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3745) TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/13 01:22:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3738) Refactor TableEnvironment and TranslationContext - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/04/13 08:51:25 UTC, 19 replies.
- [GitHub] flink pull request: Adds watermark emission to the Kafka source by... - posted by asfgit <gi...@git.apache.org> on 2016/04/13 10:31:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-3375) Allow Watermark Generation in the Kafka Source - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/13 10:32:25 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3730) Fix RocksDB Local Directory Initialization - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/13 10:38:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3126) Remove accumulator type from "value" in web frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:41:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3126) Remove accumulator type from "value" in web frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:41:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3737) WikipediaEditsSourceTest.testWikipediaEditsSource() fails locally - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:42:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3737) WikipediaEditsSourceTest.testWikipediaEditsSource() fails locally - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:43:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3737) WikipediaEditsSourceTest.testWikipediaEditsSource() fails locally - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:43:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3644) WebRuntimMonitor set java.io.tmpdir does not work for change upload dir. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:44:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3644) WebRuntimMonitor set java.io.tmpdir does not work for change upload dir. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:45:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:46:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:46:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:47:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:47:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3716) Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:50:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3716) Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 10:50:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3747) Consolidate TimestampAssigner Methods in Kafka Consumer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/13 10:57:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 11:02:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 11:02:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3747) Consolidate TimestampAssigner Methods in Kafka Consumer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 11:03:25 UTC, 4 replies.
- [jira] [Commented] (FLINK-3744) LocalFlinkMiniClusterITCase times out occasionally when building locally - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 11:19:25 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3747) Consolidate TimestampAssigner Methods in Kafka Consumer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/13 11:27:25 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3738) Refactor TableEnvironment and TranslationContext - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/13 11:40:25 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3747] Consolidate TimestampAssigner Met... - posted by aljoscha <gi...@git.apache.org> on 2016/04/13 11:42:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-3745) TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 12:26:25 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3740] Make Session Window State Checkpo... - posted by aljoscha <gi...@git.apache.org> on 2016/04/13 12:27:24 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3745) TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 12:27:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3740) Session Window State is Not Checkpointed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/13 12:27:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3718] Add Option For Completely Async B... - posted by aljoscha <gi...@git.apache.org> on 2016/04/13 12:39:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-3718) Add Option For Completely Async Backup in RocksDB State Backend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/13 12:39:25 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3739] [table] Add a null literal to Tab... - posted by twalthr <gi...@git.apache.org> on 2016/04/13 12:41:14 UTC, 19 replies.
- [jira] [Created] (FLINK-3748) Add CASE function to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/13 12:59:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3749) Improve decimal handling - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/13 14:35:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3750) Make JDBCInputFormat a parallel source - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/04/13 16:02:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3751) default Operator names are inconsistent - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/13 16:02:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3376) Add an illustration of Event Time and Watermarks to the docs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/13 16:24:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3376) Add an illustration of Event Time and Watermarks to the docs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/13 16:24:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3749] [table] Improve decimal handling - posted by twalthr <gi...@git.apache.org> on 2016/04/13 16:24:26 UTC, 10 replies.
- [jira] [Commented] (FLINK-3749) Improve decimal handling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/13 16:25:25 UTC, 10 replies.
- [jira] [Commented] (FLINK-3750) Make JDBCInputFormat a parallel source - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/13 16:27:25 UTC, 42 replies.
- [jira] [Commented] (FLINK-3751) default Operator names are inconsistent - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/13 16:29:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3664) Create a method to easily Summarize a DataSet - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/13 16:29:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3358) Create constructors for FsStateBackend in RocksDBBackens - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 17:18:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3358) Create constructors for FsStateBackend in RocksDBBackens - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 17:18:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3589) Allow setting Operator parallelism to default value - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/13 18:15:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-1579) Create a Flink History Server - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 20:34:25 UTC, 1 replies.
- [jira] [Closed] (FLINK-2909) Gelly Graph Generators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/13 20:36:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3745) TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 20:52:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3747) Consolidate TimestampAssigner Methods in Kafka Consumer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 20:53:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3747) Consolidate TimestampAssigner Methods in Kafka Consumer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 20:53:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3745) TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 20:53:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3375) Allow Watermark Generation in the Kafka Source - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 20:54:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3375) Allow Watermark Generation in the Kafka Source - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 20:54:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3752) Add Per-Kafka-Partition Watermark Generation to the docs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 21:05:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2544] Add Java 8 version for building P... - posted by skavulya <gi...@git.apache.org> on 2016/04/13 21:09:26 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-1979] Lossfunctions - posted by skavulya <gi...@git.apache.org> on 2016/04/13 21:43:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-1979) Implement Loss Functions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/13 21:44:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3753) KillerWatchDog should not use kill on toKill thread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/14 03:53:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/04/14 04:06:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/14 11:05:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3756) Introduce state hierarchy in CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/14 11:12:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3756] [state] Add state hierarchy to Ch... - posted by tillrohrmann <gi...@git.apache.org> on 2016/04/14 11:18:29 UTC, 23 replies.
- [jira] [Commented] (FLINK-3756) Introduce state hierarchy in CheckpointCoordinator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/14 11:19:25 UTC, 11 replies.
- [jira] [Created] (FLINK-3757) addAccumulator does not throw Exception on duplicate accumulator name - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/04/14 12:03:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3758) Add possibility to register accumulators in custom triggers - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/04/14 12:14:25 UTC, 0 replies.
- [GitHub] flink pull request: Improved JDBCInputFormat (FLINK-3570), fixed t... - posted by fpompermaier <gi...@git.apache.org> on 2016/04/14 12:37:15 UTC, 3 replies.
- [jira] [Commented] (FLINK-3570) Replace random NIC selection heuristic by InetAddress.getLocalHost - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/14 12:37:25 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3698) Scala Option can't be used as a key - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/04/14 12:57:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3141) Design of NULL values handling in operation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/14 13:23:25 UTC, 0 replies.
- [GitHub] flink pull request: Improved JDBCInputFormat (FLINK-3750), fixed t... - posted by fpompermaier <gi...@git.apache.org> on 2016/04/14 14:04:21 UTC, 0 replies.
- [GitHub] flink pull request: Improved JDBCInputFormat (FLINK-3750) and othe... - posted by fpompermaier <gi...@git.apache.org> on 2016/04/14 14:26:39 UTC, 40 replies.
- [GitHub] flink pull request: Refactor StreamSourceContext - posted by zentol <gi...@git.apache.org> on 2016/04/14 15:13:31 UTC, 0 replies.
- [jira] [Created] (FLINK-3759) Table API should throw exception is null value is encountered in non-null mode. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/14 15:34:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/14 15:39:25 UTC, 21 replies.
- [GitHub] flink pull request: [FLINK-3738] [tableAPI] Refactor TableEnvironm... - posted by fhueske <gi...@git.apache.org> on 2016/04/14 15:56:45 UTC, 9 replies.
- [jira] [Assigned] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/14 15:57:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3760) Fix StateDescriptor.readObject - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/14 16:01:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3760] Fix StateDescriptor.readObject - posted by aljoscha <gi...@git.apache.org> on 2016/04/14 16:11:08 UTC, 6 replies.
- [jira] [Commented] (FLINK-3760) Fix StateDescriptor.readObject - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/14 16:11:25 UTC, 6 replies.
- [GitHub] flink pull request: Refactor MockStreamSourceContext - posted by zentol <gi...@git.apache.org> on 2016/04/14 16:28:25 UTC, 0 replies.
- [GitHub] flink pull request: Add util for TDD instantiation - posted by zentol <gi...@git.apache.org> on 2016/04/14 18:10:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3760) Fix StateDescriptor.readObject - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/14 18:13:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3761) Introduce key group state backend - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/14 18:59:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3744) LocalFlinkMiniClusterITCase times out occasionally when building locally - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/14 19:22:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3762) Kryo StackOverflowError due to disabled Kryo Reference tracking - posted by "Andrew Palumbo (JIRA)" <ji...@apache.org> on 2016/04/14 20:00:29 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3762: StackOverflowError due to disabled... - posted by andrewpalumbo <gi...@git.apache.org> on 2016/04/14 20:31:38 UTC, 6 replies.
- [jira] [Commented] (FLINK-3762) Kryo StackOverflowError due to disabled Kryo Reference tracking - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/14 20:32:25 UTC, 6 replies.
- [jira] [Created] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters - posted by "Robert Batts (JIRA)" <ji...@apache.org> on 2016/04/15 05:57:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3708) Scala API for CEP - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/15 09:34:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3739) Add a null literal to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/15 10:34:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3759] [table] Table API should throw ex... - posted by twalthr <gi...@git.apache.org> on 2016/04/15 11:09:36 UTC, 2 replies.
- [jira] [Commented] (FLINK-3759) Table API should throw exception is null value is encountered in non-null mode. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/15 11:10:25 UTC, 2 replies.
- [jira] [Updated] (FLINK-3762) Kryo StackOverflowError due to disabled Kryo Reference tracking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/15 12:10:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3748] [table] Add CASE function to Tabl... - posted by twalthr <gi...@git.apache.org> on 2016/04/15 12:16:01 UTC, 3 replies.
- [jira] [Commented] (FLINK-3748) Add CASE function to Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/15 12:16:25 UTC, 3 replies.
- [jira] [Created] (FLINK-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/15 12:23:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/15 12:23:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3765) ScalaShellITCase deadlocks spuriously - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/15 12:25:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3764] [tests] Improve LeaderChangeState... - posted by tillrohrmann <gi...@git.apache.org> on 2016/04/15 12:37:34 UTC, 5 replies.
- [jira] [Commented] (FLINK-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/15 12:38:25 UTC, 5 replies.
- [jira] [Created] (FLINK-3766) Add a new tab for monitoring metrics in the web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/15 14:22:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3766) Add a new tab for monitoring metrics in the web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/15 14:23:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-2944) Collect, expose and display operator-specific stats - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/15 14:25:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3767) Show timeline also for running tasks, not only for finished ones - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/15 14:26:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3479) Add hash-based strategy for CombineFunction - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/04/15 14:28:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3717) Add functionality to be a able to restore from specific point in a FileInputFormat - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/15 14:46:25 UTC, 1 replies.
- [GitHub] flink pull request: FLINK-3717 - Be able to re-start reading from ... - posted by kl0u <gi...@git.apache.org> on 2016/04/15 14:48:45 UTC, 19 replies.
- [jira] [Commented] (FLINK-3717) Add functionality to be a able to restore from specific point in a FileInputFormat - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/15 14:49:25 UTC, 10 replies.
- [jira] [Created] (FLINK-3768) Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/15 18:57:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3738) Refactor TableEnvironment and TranslationContext - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/15 19:47:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3759) Table API should throw exception is null value is encountered in non-null mode. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/15 19:50:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3762) Kryo StackOverflowError due to disabled Kryo Reference tracking - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/15 20:59:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/15 21:00:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/15 21:01:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3732) Potential null deference in ExecutionConfig#equals() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/15 21:04:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3768] [gelly] Clustering Coefficient - posted by greghogan <gi...@git.apache.org> on 2016/04/15 22:05:44 UTC, 4 replies.
- [jira] [Commented] (FLINK-3768) Clustering Coefficient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/15 22:06:25 UTC, 10 replies.
- [jira] [Updated] (FLINK-3768) Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/15 22:07:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange - posted by "Robert Batts (JIRA)" <ji...@apache.org> on 2016/04/15 22:44:28 UTC, 0 replies.
- [jira] [Updated] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange - posted by "Robert Batts (JIRA)" <ji...@apache.org> on 2016/04/15 22:45:25 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3587] Bump Calcite version to 1.7.0 - posted by fhueske <gi...@git.apache.org> on 2016/04/15 23:06:45 UTC, 3 replies.
- [jira] [Commented] (FLINK-3587) Bump Calcite version to 1.7.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/15 23:07:25 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2259][ml] Add Train-Testing Splitters - posted by rawkintrevo <gi...@git.apache.org> on 2016/04/16 00:49:01 UTC, 27 replies.
- [jira] [Commented] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/16 00:49:25 UTC, 27 replies.
- [jira] [Commented] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Marut Singh (JIRA)" <ji...@apache.org> on 2016/04/16 03:47:25 UTC, 4 replies.
- [jira] [Commented] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/04/16 05:47:25 UTC, 49 replies.
- [jira] [Updated] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/04/16 05:51:25 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/04/16 05:54:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/04/16 05:58:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange - posted by "Subhankar Biswas (JIRA)" <ji...@apache.org> on 2016/04/16 07:31:25 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters - posted by "Subhankar Biswas (JIRA)" <ji...@apache.org> on 2016/04/16 07:47:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3770) Fix TriangleEnumerator performance - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/16 12:03:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3771) Methods for translating Graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/16 13:02:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3771) Methods for translating Graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/16 13:14:25 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3770] [gelly] Fix TriangleEnumerator pe... - posted by greghogan <gi...@git.apache.org> on 2016/04/16 14:55:30 UTC, 6 replies.
- [jira] [Commented] (FLINK-3770) Fix TriangleEnumerator performance - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/16 14:56:25 UTC, 7 replies.
- [jira] [Created] (FLINK-3772) Graph algorithms for vertex and edge degree - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/16 16:28:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3771] [gelly] Methods for translating G... - posted by greghogan <gi...@git.apache.org> on 2016/04/16 16:36:10 UTC, 35 replies.
- [jira] [Commented] (FLINK-3771) Methods for translating Graphs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/16 16:36:25 UTC, 36 replies.
- [GitHub] flink pull request: [FLINK-3772] [gelly] Graph algorithms for vert... - posted by greghogan <gi...@git.apache.org> on 2016/04/17 01:39:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-3772) Graph algorithms for vertex and edge degree - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/17 01:39:25 UTC, 6 replies.
- [jira] [Created] (FLINK-3773) Scanners are left unclosed in SqlExplainTest - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/17 02:34:25 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3773 Scanners are left unclosed in SqlEx... - posted by samaitra <gi...@git.apache.org> on 2016/04/17 08:57:17 UTC, 3 replies.
- [jira] [Commented] (FLINK-3773) Scanners are left unclosed in SqlExplainTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/17 08:57:25 UTC, 6 replies.
- [jira] [Created] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/18 10:32:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/04/18 10:36:25 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/04/18 10:37:25 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/04/18 10:43:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-2051) Fix disabled test in ComplexIntegrationTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/18 11:16:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/04/18 11:17:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3775) Flink Scala shell does not respect Flink configuration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/18 11:27:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/18 11:29:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3726) Error while reading configuration: Cannot read property 0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/18 11:29:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3776) Flink Scala shell does not allow to set configuration for local execution - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/18 11:31:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3230) Kinesis streaming producer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/18 11:32:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-2051) Fix disabled test in ComplexIntegrationTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/18 11:58:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3777) Add open and close methods to manage IF lifecycle - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/04/18 12:04:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/18 12:15:26 UTC, 25 replies.
- [jira] [Updated] (FLINK-3773) Scanners are left unclosed in SqlExplainTest - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/18 12:23:25 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3777) Add open and close methods to manage IF lifecycle - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/04/18 12:24:25 UTC, 2 replies.
- [jira] [Updated] (FLINK-3777) Add open and close methods to manage IF lifecycle - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/04/18 12:30:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3777) Add open and close methods to manage IF lifecycle - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/04/18 12:31:25 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public' - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/18 12:44:25 UTC, 0 replies.
- [GitHub] flink pull request: Managed closeInputFormat() - posted by fpompermaier <gi...@git.apache.org> on 2016/04/18 13:47:22 UTC, 1 replies.
- [jira] [Closed] (FLINK-3773) Scanners are left unclosed in SqlExplainTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/18 16:38:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3664) Create a method to easily Summarize a DataSet - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/18 16:49:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3587) Bump Calcite version to 1.7.0 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/18 16:58:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3770) Fix TriangleEnumerator performance - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/18 17:41:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3774] [shell] Forwards Flink configurat... - posted by tillrohrmann <gi...@git.apache.org> on 2016/04/18 17:44:43 UTC, 10 replies.
- [jira] [Created] (FLINK-3778) ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/18 18:03:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/04/18 18:05:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3708] Scala API for CEP (initial). - posted by StefanRRichter <gi...@git.apache.org> on 2016/04/18 18:12:36 UTC, 64 replies.
- [jira] [Commented] (FLINK-3708) Scala API for CEP - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/18 18:13:25 UTC, 53 replies.
- [jira] [Created] (FLINK-3779) Add support for queryable state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/18 18:23:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3778] [shell] Forward configuration fro... - posted by tillrohrmann <gi...@git.apache.org> on 2016/04/18 18:39:04 UTC, 5 replies.
- [jira] [Commented] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Chenguang He (JIRA)" <ji...@apache.org> on 2016/04/18 18:39:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3778) ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/18 18:39:25 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Chenguang He (JIRA)" <ji...@apache.org> on 2016/04/18 18:40:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3780) Jaccard Similarity - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/18 18:48:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3779) Add support for queryable state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/18 18:49:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/18 19:20:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3781] BlobClient may be left unclosed i... - posted by gaoyike <gi...@git.apache.org> on 2016/04/18 19:47:03 UTC, 9 replies.
- [jira] [Commented] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/18 19:47:25 UTC, 12 replies.
- [jira] [Assigned] (FLINK-3068) Add a Table API configuration to TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/18 23:23:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3068) Add a Table API configuration to TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/18 23:24:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close - posted by "Chenguang He (JIRA)" <ji...@apache.org> on 2016/04/18 23:39:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close - posted by "Chenguang He (JIRA)" <ji...@apache.org> on 2016/04/18 23:39:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/19 00:24:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/19 00:24:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3783) Support weighted random sampling with reservoir - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2016/04/19 08:15:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3783] [core] Support weighted random sa... - posted by gallenvara <gi...@git.apache.org> on 2016/04/19 08:32:53 UTC, 3 replies.
- [jira] [Commented] (FLINK-3783) Support weighted random sampling with reservoir - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/19 08:33:25 UTC, 3 replies.
- [jira] [Resolved] (FLINK-3748) Add CASE function to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/19 10:10:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3784) Unexpected results using collect() in RichMapPartitionFunction - posted by "Sergio Ramírez (JIRA)" <ji...@apache.org> on 2016/04/19 10:31:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S... - posted by rmetzger <gi...@git.apache.org> on 2016/04/19 11:41:46 UTC, 26 replies.
- [jira] [Commented] (FLINK-3230) Kinesis streaming producer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/19 11:42:25 UTC, 26 replies.
- [GitHub] flink pull request: [FLINK-3229] Flink streaming consumer for AWS ... - posted by tzulitai <gi...@git.apache.org> on 2016/04/19 12:17:04 UTC, 62 replies.
- [jira] [Updated] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/19 12:26:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-1146) Add a way to provide types for generic type variables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/19 12:51:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-1394) TachyonFileSystemWrapperTest fails if the HADOOP_HOME variable is set - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/19 12:54:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3785) Add REST resource to query information about checkpointing - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/04/19 12:54:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-1427) Configuration through environment variables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/19 12:55:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-2265) Tachyon Tests sometimes fail with pre-mature process exists - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/19 13:00:29 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2344) Deprecate/Remove the old Pact Pair type - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/19 13:04:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-2848) Refactor Flink benchmarks with JMH and move to flink-benchmark module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/19 13:13:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3086] [table] ExpressionParser does not... - posted by twalthr <gi...@git.apache.org> on 2016/04/19 13:49:00 UTC, 5 replies.
- [jira] [Closed] (FLINK-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/19 13:54:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-1427) Configuration through environment variables - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/19 13:55:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3786) Add BigDecimal and BigInteger as Basic types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/19 14:15:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3701) Cant call execute after first execution - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/19 14:23:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3701) Cant call execute after first execution - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/19 14:23:25 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3701] reuse serializer lists in Executi... - posted by mxm <gi...@git.apache.org> on 2016/04/19 14:25:26 UTC, 4 replies.
- [jira] [Commented] (FLINK-3786) Add BigDecimal and BigInteger as Basic types - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/19 14:33:25 UTC, 25 replies.
- [jira] [Created] (FLINK-3787) Yarn client does not report unfulfillable container constraints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/19 14:46:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3775) Flink Scala shell does not respect Flink configuration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/19 15:20:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3775] [shell] Load Flink configuration ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/04/19 15:22:55 UTC, 8 replies.
- [jira] [Commented] (FLINK-3775) Flink Scala shell does not respect Flink configuration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/19 15:23:25 UTC, 2 replies.
- [jira] [Created] (FLINK-3788) Local variable values are not distributed to task runners - posted by "Andreas C. Osowski (JIRA)" <ji...@apache.org> on 2016/04/19 16:28:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3788) Local variable values are not distributed to task runners - posted by "Andreas C. Osowski (JIRA)" <ji...@apache.org> on 2016/04/19 16:29:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3788) Local variable values are not distributed to job runners - posted by "Andreas C. Osowski (JIRA)" <ji...@apache.org> on 2016/04/19 16:47:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3789) Overload methods which trigger program execution to allow naming job - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/19 16:48:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3788) Local variable values are not distributed to job runners - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/04/19 16:56:25 UTC, 2 replies.
- [jira] [Updated] (FLINK-3789) Overload methods which trigger program execution to allow naming job - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/19 18:37:25 UTC, 2 replies.
- [GitHub] flink pull request: Flink 1827 and small fixes in some tests - posted by stefanobortoli <gi...@git.apache.org> on 2016/04/19 18:39:13 UTC, 4 replies.
- [jira] [Closed] (FLINK-1528) Add local clustering coefficient library method and example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/19 19:04:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1528) Add local clustering coefficient library method and example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/19 19:04:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3780) Jaccard Similarity - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/19 19:07:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-3789) Overload methods which trigger program execution to allow naming job - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/20 09:45:25 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3230) Kinesis streaming producer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/20 09:51:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3785) Add REST resource to query information about checkpointing - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/20 11:46:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/20 14:01:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3790) Rolling File sink does not pick up hadoop configuration - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/20 15:34:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3790) Rolling File sink does not pick up hadoop configuration - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/20 15:35:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-3790) Rolling File sink does not pick up hadoop configuration - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/20 15:43:25 UTC, 9 replies.
- [jira] [Resolved] (FLINK-3718) Add Option For Completely Async Backup in RocksDB State Backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/20 16:17:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3791) Flink CLI must has arguments to specify zookeeper cluster required to work with Standalone HA cluster - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/04/20 16:21:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3791) Flink CLI must has arguments to specify zookeeper cluster required to work with Standalone HA cluster - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/20 16:35:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3792) RowTypeInfo equality should not depend on field names - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/20 16:35:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3791) Flink CLI must has arguments to specify zookeeper cluster required to work with Standalone HA cluster - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/20 16:35:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3754][Table]Add a validation phase befo... - posted by yjshen <gi...@git.apache.org> on 2016/04/20 16:42:41 UTC, 22 replies.
- [jira] [Commented] (FLINK-3792) RowTypeInfo equality should not depend on field names - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/20 16:45:25 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-3758) Add possibility to register accumulators in custom triggers - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/04/20 17:43:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3777] Managed closeInputFormat() - posted by fhueske <gi...@git.apache.org> on 2016/04/20 17:44:25 UTC, 22 replies.
- [GitHub] flink pull request: [FLINK-3727] Embedded streaming SQL projection... - posted by vasia <gi...@git.apache.org> on 2016/04/20 18:30:37 UTC, 15 replies.
- [jira] [Commented] (FLINK-3727) Add support for embedded streaming SQL (projection, filter, union) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/20 18:31:25 UTC, 15 replies.
- [jira] [Created] (FLINK-3793) Re-organize the Table API and SQL docs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/20 18:53:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3794) Add checks for unsupported operations in streaming table API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/20 19:01:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3795) Cancel button is hidden on MacBook Pro 13'' - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/04/20 19:06:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3796) FileSourceFunction doesn't respect InputFormat's life cycle methods - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/20 19:10:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3797) Restart flow button - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/04/20 19:11:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3798) Clean up RocksDB state backend access modifiers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/20 21:26:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3798] [streaming] Clean up RocksDB back... - posted by gyfora <gi...@git.apache.org> on 2016/04/20 21:36:08 UTC, 9 replies.
- [jira] [Commented] (FLINK-3798) Clean up RocksDB state backend access modifiers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/20 21:36:25 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-3790] [streaming] Use proper hadoop con... - posted by gyfora <gi...@git.apache.org> on 2016/04/20 21:46:56 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3798) Clean up RocksDB state backend access modifiers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/20 21:48:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3790) Rolling File sink does not pick up hadoop configuration - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/20 21:49:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3794) Add checks for unsupported operations in streaming table API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/20 22:05:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3665) Range partitioning lacks support to define sort orders - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/20 23:20:25 UTC, 0 replies.
- [GitHub] flink pull request: Flink 3691 extend avroinputformat to support g... - posted by gna-phetsarath <gi...@git.apache.org> on 2016/04/21 00:19:18 UTC, 6 replies.
- [jira] [Updated] (FLINK-2998) Support range partition comparison for multi input nodes. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/21 01:40:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/21 01:40:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2998) Support range partition comparison for multi input nodes. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/21 01:41:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3665) Range partitioning lacks support to define sort orders - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/21 01:42:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3629) In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()" - posted by "Li Fanxi (JIRA)" <ji...@apache.org> on 2016/04/21 03:07:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/21 08:27:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3796) FileSourceFunction doesn't respect InputFormat's life cycle methods - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/21 10:27:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3790) Rolling File sink does not pick up hadoop configuration - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/21 11:50:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3798) Clean up RocksDB state backend access modifiers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/21 12:02:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3794] add checks for unsupported operat... - posted by vasia <gi...@git.apache.org> on 2016/04/21 14:09:54 UTC, 5 replies.
- [jira] [Commented] (FLINK-3794) Add checks for unsupported operations in streaming table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/21 14:10:25 UTC, 5 replies.
- [jira] [Created] (FLINK-3799) Graph checksum should execute single job - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/21 14:27:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3799) Graph checksum should execute single job - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/21 14:38:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3727) Add support for embedded streaming SQL (projection, filter, union) - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/21 15:37:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3794) Add checks for unsupported operations in streaming table API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/21 15:38:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3799] [gelly] Graph checksum should exe... - posted by greghogan <gi...@git.apache.org> on 2016/04/21 16:54:37 UTC, 4 replies.
- [jira] [Commented] (FLINK-3799) Graph checksum should execute single job - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/21 16:55:25 UTC, 4 replies.
- [jira] [Created] (FLINK-3800) ExecutionGraphs can become orphans - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/21 17:05:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3800] [jobmanager] Terminate ExecutionG... - posted by tillrohrmann <gi...@git.apache.org> on 2016/04/21 17:18:16 UTC, 7 replies.
- [jira] [Commented] (FLINK-3800) ExecutionGraphs can become orphans - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/21 17:18:25 UTC, 6 replies.
- [jira] [Created] (FLINK-3801) Upgrade Joda-Time library to 2.9.3 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/21 19:20:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3802) Add Very Fast Reservoir Sampling - posted by "Chenguang He (JIRA)" <ji...@apache.org> on 2016/04/21 22:31:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3802) Add Very Fast Reservoir Sampling - posted by "Chenguang He (JIRA)" <ji...@apache.org> on 2016/04/21 22:32:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3802] Add Very Fast Reservoir Sampling - posted by gaoyike <gi...@git.apache.org> on 2016/04/21 23:45:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3802) Add Very Fast Reservoir Sampling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/21 23:46:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-1749) Add Boosting algorithm for ensemble learning to machine learning library - posted by "David E Drummond (JIRA)" <ji...@apache.org> on 2016/04/22 01:43:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-1729) Assess performance of classification algorithms - posted by "hoa nguyen (JIRA)" <ji...@apache.org> on 2016/04/22 03:00:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-1746) Add linear discriminant analysis to machine learning library - posted by "Ronak Nathani (JIRA)" <ji...@apache.org> on 2016/04/22 03:07:12 UTC, 2 replies.
- [GitHub] flink pull request: FunctionAnnotation example should match docs - posted by NathanHowell <gi...@git.apache.org> on 2016/04/22 04:49:39 UTC, 4 replies.
- [jira] [Commented] (FLINK-1743) Add multinomial logistic regression to machine learning library - posted by "David E Drummond (JIRA)" <ji...@apache.org> on 2016/04/22 07:25:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-1284) Uniform random sampling operator over windows - posted by "Austin Ouyang (JIRA)" <ji...@apache.org> on 2016/04/22 07:41:12 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3793) Re-organize the Table API and SQL docs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/22 08:29:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1749) Add Boosting algorithm for ensemble learning to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/22 11:09:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1743) Add multinomial logistic regression to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/22 11:14:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1746) Add linear discriminant analysis to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/22 11:52:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1729) Assess performance of classification algorithms - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/22 11:56:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1729) Assess performance of classification algorithms - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/22 11:56:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3193) Add optional bloomfilter to sql state backend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/22 12:02:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3072) DbStateBackendTest - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/22 12:02:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3803) Checkpoint Stats Tracker Reads from Wrong Configuration - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/22 13:46:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3804) Update YARN documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/22 14:17:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2828) Add interfaces for Table API input formats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/22 14:36:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/22 15:09:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-2715) Benchmark Triangle Count methods - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/22 16:55:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3805) BloomFilter initialized with no memory available - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/22 17:50:12 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1284) Uniform random sampling operator over windows - posted by "Austin Ouyang (JIRA)" <ji...@apache.org> on 2016/04/22 18:41:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3806) Revert use of DataSet.count() in Gelly - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/22 19:50:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2946] Add orderBy() to Table API - posted by dawidwys <gi...@git.apache.org> on 2016/04/22 20:11:21 UTC, 34 replies.
- [jira] [Updated] (FLINK-3753) KillerWatchDog should not use kill on toKill thread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/22 23:51:12 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3740) Session Window State is Not Checkpointed - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/25 10:22:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3560) Examples shouldn't always print usage statement - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/25 11:09:13 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3678) Make Flink logs directory configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/25 12:19:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3678) Make Flink logs directory configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/25 12:19:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3678) Make Flink logs directory configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/25 12:19:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3803) Checkpoint Stats Tracker Reads from Wrong Configuration - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/25 12:32:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3803) Checkpoint Stats Tracker Reads from Wrong Configuration - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/25 12:33:12 UTC, 6 replies.
- [jira] [Created] (FLINK-3807) FastFailuresITCase deadlocks on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/25 14:06:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3803] [runtime] Pass CheckpointStatsTra... - posted by uce <gi...@git.apache.org> on 2016/04/25 15:32:07 UTC, 2 replies.
- [jira] [Closed] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/25 15:32:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3786] [core] [api-extending] Add BigDec... - posted by twalthr <gi...@git.apache.org> on 2016/04/25 15:39:28 UTC, 25 replies.
- [GitHub] flink pull request: [FLINK-3257] Add Exactly-Once Processing Guara... - posted by uce <gi...@git.apache.org> on 2016/04/25 15:58:43 UTC, 1 replies.
- [jira] [Created] (FLINK-3808) Refactor the whole file monitoring source to take a fileInputFormat as an argument. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/25 16:41:12 UTC, 0 replies.
- [GitHub] flink pull request: Watch type proper - posted by kl0u <gi...@git.apache.org> on 2016/04/25 16:42:38 UTC, 3 replies.
- [jira] [Commented] (FLINK-3808) Refactor the whole file monitoring source to take a fileInputFormat as an argument. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/25 16:45:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-3806) Revert use of DataSet.count() in Gelly - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/25 16:57:12 UTC, 0 replies.
- [GitHub] flink pull request: Refactoring the File Monitoring Source. - posted by zentol <gi...@git.apache.org> on 2016/04/25 16:59:58 UTC, 59 replies.
- [jira] [Closed] (FLINK-3778) ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/25 18:01:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1827] and small fixes in some tests - posted by tillrohrmann <gi...@git.apache.org> on 2016/04/25 18:11:03 UTC, 5 replies.
- [jira] [Created] (FLINK-3809) Missing break in ZooKeeperLeaderRetrievalService#handleStateChange() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/25 18:36:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3810) Missing break in ZooKeeperLeaderElectionService#handleStateChange() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/25 18:39:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3811) Refactor ExecutionEnvironment in TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/25 21:39:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3811] [tableAPI] Use only Java Executio... - posted by fhueske <gi...@git.apache.org> on 2016/04/26 00:06:29 UTC, 3 replies.
- [jira] [Commented] (FLINK-3811) Refactor ExecutionEnvironment in TableEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 00:07:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 09:16:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-3765) ScalaShellITCase deadlocks spuriously - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/26 10:18:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3812) Kafka09ITCase testAllDeletes fails on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/26 10:20:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3743) Upgrade breeze from 0.11.2 to 0.12 - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/04/26 10:26:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3803) Checkpoint Stats Tracker Reads from Wrong Configuration - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/26 10:37:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2673) Scala API does not support Option type as key - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/04/26 10:48:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3698) Scala Option can't be used as a key - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/04/26 10:49:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 10:53:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3775) Flink Scala shell does not respect Flink configuration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 11:13:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3212) JobManagerCheckpointRecoveryITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 11:51:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3741] [build] Replace maven-scala-plugi... - posted by tillrohrmann <gi...@git.apache.org> on 2016/04/26 11:59:24 UTC, 5 replies.
- [jira] [Closed] (FLINK-3756) Introduce state hierarchy in CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 12:24:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3811) Refactor ExecutionEnvironment in TableEnvironment - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 12:35:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3814) Update code style guide regarding Preconditions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 12:50:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3815) Replace Guava Preconditions usage in flink-gelly - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:10:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3815] Replace Guava Preconditions usage... - posted by zentol <gi...@git.apache.org> on 2016/04/26 13:11:06 UTC, 3 replies.
- [jira] [Commented] (FLINK-3815) Replace Guava Preconditions usage in flink-gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 13:11:13 UTC, 6 replies.
- [jira] [Created] (FLINK-3816) Replace Guava Preconditions usage in flink-clients - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:12:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3815] - Replace Guava Preconditions usa... - posted by zentol <gi...@git.apache.org> on 2016/04/26 13:13:02 UTC, 2 replies.
- [jira] [Created] (FLINK-3817) Remove unused Guava dependency from RocksDB StateBackend - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:14:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3817] - Remove unused guava dependency ... - posted by zentol <gi...@git.apache.org> on 2016/04/26 13:14:35 UTC, 2 replies.
- [jira] [Commented] (FLINK-3817) Remove unused Guava dependency from RocksDB StateBackend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 13:15:12 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3810) Missing break in ZooKeeperLeaderElectionService#handleStateChange() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:18:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3809) Missing break in ZooKeeperLeaderRetrievalService#handleStateChange() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:18:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3809/FLINK-3810] Add missing breaks in ... - posted by zentol <gi...@git.apache.org> on 2016/04/26 13:22:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-3809) Missing break in ZooKeeperLeaderRetrievalService#handleStateChange() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 13:23:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3818) Remove Guava dependency from flink-gelly-examples - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:26:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3818] Remove Guava dependency from flin... - posted by zentol <gi...@git.apache.org> on 2016/04/26 13:27:03 UTC, 2 replies.
- [jira] [Commented] (FLINK-3818) Remove Guava dependency from flink-gelly-examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 13:27:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3819) Replace Guava Preconditions usage in flink-gelly-scala - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:30:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3819] Replace Guava Preconditions usage... - posted by zentol <gi...@git.apache.org> on 2016/04/26 13:31:30 UTC, 2 replies.
- [jira] [Commented] (FLINK-3819) Replace Guava Preconditions usage in flink-gelly-scala - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 13:32:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3820) ScalaShellITCase.testPreventRecreationBatch deadlocks on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 13:48:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3809) Missing break in ZooKeeperLeaderRetrievalService#handleStateChange() - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 13:56:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3810) Missing break in ZooKeeperLeaderElectionService#handleStateChange() - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 13:56:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/26 14:30:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3821) Reduce Guava usage in flink-java - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 14:31:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3821] Reduce Guava usage in flink-java - posted by zentol <gi...@git.apache.org> on 2016/04/26 14:46:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-3821) Reduce Guava usage in flink-java - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 14:47:12 UTC, 3 replies.
- [jira] [Created] (FLINK-3822) Document checksum functions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/26 15:04:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3799) Graph checksum should execute single job - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/26 15:11:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf... - posted by fhueske <gi...@git.apache.org> on 2016/04/26 15:23:25 UTC, 20 replies.
- [jira] [Closed] (FLINK-3777) Add open and close methods to manage IF lifecycle - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 16:01:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3804) Update YARN documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/26 17:01:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3199) KafkaITCase.testOneToOneSources - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 17:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 18:17:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2220] Join on Pojo without hashCode() s... - posted by gallenvara <gi...@git.apache.org> on 2016/04/26 18:18:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 18:18:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3824) ResourceManager may repeatedly connect to outdated JobManager in HA mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/26 18:50:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3825) Update CEP documentation to include Scala API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 18:51:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3708) Scala API for CEP - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 18:52:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3800) ExecutionGraphs can become orphans - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 19:06:12 UTC, 0 replies.
- [GitHub] flink pull request: Flink 3750 fixed - posted by fpompermaier <gi...@git.apache.org> on 2016/04/26 19:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-3825) Update CEP documentation to include Scala API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 19:20:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/26 20:09:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-951] Reworking of Iteration Synchroniza... - posted by markus-h <gi...@git.apache.org> on 2016/04/26 20:14:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 20:15:13 UTC, 1 replies.
- [jira] [Updated] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Saumitra Shahapure (JIRA)" <ji...@apache.org> on 2016/04/26 20:48:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/26 22:56:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2971) Add outer joins to the Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/27 00:12:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-1284) Uniform random sampling operator over windows - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 10:05:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3826) Broken test: StreamCheckpointingITCase - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/27 10:51:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3816) Replace Guava Preconditions usage in flink-clients - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/27 11:27:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3815) Replace Guava Preconditions usage in flink-gelly - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/27 11:27:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3818) Remove Guava dependency from flink-gelly-examples - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/27 11:28:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3817) Remove unused Guava dependency from RocksDB StateBackend - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/27 11:28:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3819) Replace Guava Preconditions usage in flink-gelly-scala - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/27 11:28:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3827) Flink modules include unused dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:36:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3829) flink-java - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:38:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3830) flink-scala - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:38:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3828) flink-runtime - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:38:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3833) flink-test-utils - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3834) flink-statebackend-rocksdb - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3831) flink-streaming-java - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3832) flink-streaming-scala - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:39:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/27 12:59:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-2971) Add outer joins to the Table API - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/04/27 13:28:12 UTC, 9 replies.
- [jira] [Commented] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/04/27 13:39:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3601) JobManagerTest times out on StopSignal test - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/04/27 13:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3835) JSON execution plan not helpful to debug plans with KeySelectors - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/27 14:44:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3824) ResourceManager may repeatedly connect to outdated JobManager in HA mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/27 15:07:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3601) JobManagerTest times out on StopSignal test - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/27 15:07:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3834) flink-statebackend-rocksdb - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/27 15:40:12 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-3691] extend avroinputformat to support... - posted by gna-phetsarath <gi...@git.apache.org> on 2016/04/27 15:57:06 UTC, 6 replies.
- [jira] [Closed] (FLINK-3835) JSON execution plan not helpful to debug plans with KeySelectors - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/27 16:09:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-2828) Add interfaces for Table API input formats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/27 16:17:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3836) Change Histogram to enable Long counters - posted by "Maximilian Bode (JIRA)" <ji...@apache.org> on 2016/04/27 16:26:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3836) Change Histogram to enable Long counters - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/27 16:37:13 UTC, 3 replies.
- [jira] [Created] (FLINK-3837) Create FLOOR/CEIL function - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/27 16:53:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3836) Change Histogram to enable Long counters - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/27 18:11:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3838) CLI parameter parser is munging application params - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2016/04/27 18:49:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3839) Support wildcards in classpath parameters - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2016/04/27 19:00:17 UTC, 0 replies.
- [jira] [Created] (FLINK-3840) RocksDB local parent dir is polluted with empty folders with random names - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/28 08:41:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/28 08:46:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3840) RocksDB local parent dir is polluted with empty folders with random names - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/28 10:01:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3840] Remove Testing Files in RocksDB B... - posted by aljoscha <gi...@git.apache.org> on 2016/04/28 10:04:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-3840) RocksDB local parent dir is polluted with empty folders with random names - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/28 10:05:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/28 10:07:13 UTC, 2 replies.
- [jira] [Updated] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/28 10:15:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3840) RocksDB local parent dir is polluted with empty folders with random names - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/28 10:15:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3842) Fix handling null record/row in generated code - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/04/28 10:47:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3837] [table] Create FLOOR/CEIL functio... - posted by twalthr <gi...@git.apache.org> on 2016/04/28 10:54:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-3837) Create FLOOR/CEIL function - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/28 10:55:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3842) Fix handling null record/row in generated code - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/28 11:01:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3842) Fix handling null record/row in generated code - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/28 11:14:13 UTC, 3 replies.
- [GitHub] flink pull request: Refactor the whole file monitoring source to t... - posted by aljoscha <gi...@git.apache.org> on 2016/04/28 12:11:56 UTC, 0 replies.
- [GitHub] flink pull request: Timer coalescing across keys and cleanup of un... - posted by knaufk <gi...@git.apache.org> on 2016/04/28 13:26:23 UTC, 3 replies.
- [jira] [Created] (FLINK-3843) StreamFaultToleranceTestBase hangs in case of test failure. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/28 13:42:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3840) RocksDB local parent dir is polluted with empty folders with random names - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/28 14:19:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3776] Flink Scala shell does not allow ... - posted by eastcirclek <gi...@git.apache.org> on 2016/04/28 15:04:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-3776) Flink Scala shell does not allow to set configuration for local execution - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/28 15:05:12 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3808: Refactor the whole file monitoring... - posted by kl0u <gi...@git.apache.org> on 2016/04/28 15:11:28 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3834] POM Cleanup statebackend-rocksdb - posted by zentol <gi...@git.apache.org> on 2016/04/28 15:31:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-3834) flink-statebackend-rocksdb - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/28 15:32:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3844) Checkpoint failures should not always lead to job failures - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/28 15:39:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3844) Checkpoint failures should not always lead to job failures - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/28 15:39:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/28 15:50:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1502] Basic Metric System - posted by zentol <gi...@git.apache.org> on 2016/04/28 16:20:44 UTC, 7 replies.
- [jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/28 16:21:13 UTC, 7 replies.
- [jira] [Created] (FLINK-3845) Gelly allows duplicate vertices in Graph.addVertices - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/28 17:01:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0 - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/04/28 17:04:12 UTC, 5 replies.
- [jira] [Created] (FLINK-3846) Graph.removeEdges also removes duplicate edges - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/28 17:13:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3845) Gelly allows duplicate vertices in Graph.addVertices - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/28 17:24:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3846) Graph.removeEdges also removes duplicate edges - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/28 17:38:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3845) Gelly allows duplicate vertices in Graph.addVertices - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/28 17:38:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3454] Add test dependencies on packaged... - posted by greghogan <gi...@git.apache.org> on 2016/04/28 17:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0 - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/04/28 17:45:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3454) Add test dependencies on packaged jars - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/28 17:45:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3277] Use Value types in Gelly API - posted by greghogan <gi...@git.apache.org> on 2016/04/28 17:51:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-3277) Use Value types in Gelly API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/28 17:52:13 UTC, 3 replies.
- [jira] [Created] (FLINK-3847) Reorganize package structure of flink-table - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 17:53:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3848) Add ProjectableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 17:58:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3447) Package Gelly algorithms by framework - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/28 17:59:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3849) Add FilterableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:02:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3848) Add ProjectableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:02:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:09:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-2166) Add fromCsvFile() to TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:14:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2168) Add HBaseTableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:15:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-2168) Add HBaseTableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:33:12 UTC, 2 replies.
- [jira] [Updated] (FLINK-2169) Add fromParquet() to TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:35:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2169) Add ParquetTableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:36:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2170) Add OrcTableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:36:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-2170) Add OrcTableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:38:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-2169) Add ParquetTableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:38:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3851) Add interface to register external catalogs in the TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:44:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2167) Register HCatalog as external catalog in TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:45:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-2167) Register HCatalog as external catalog in TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:47:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3846] [gelly] Graph.removeEdges also re... - posted by greghogan <gi...@git.apache.org> on 2016/04/28 19:46:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-3846) Graph.removeEdges also removes duplicate edges - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/28 19:46:13 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3845] [gelly] Gelly allows duplicate ve... - posted by greghogan <gi...@git.apache.org> on 2016/04/28 23:06:57 UTC, 1 replies.
- [jira] [Commented] (FLINK-3845) Gelly allows duplicate vertices in Graph.addVertices - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/28 23:07:12 UTC, 1 replies.
- [jira] [Closed] (FLINK-2946) Add orderBy() to Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/29 09:13:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3790) Rolling File sink does not pick up hadoop configuration - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/29 10:05:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/29 11:01:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/04/29 11:08:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-2926) Add a Strongly Connected Components Library Method - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2016/04/29 11:17:12 UTC, 3 replies.
- [jira] [Reopened] (FLINK-3800) ExecutionGraphs can become orphans - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/29 11:25:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3848) Add ProjectableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/29 12:17:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3849) Add FilterableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/29 12:17:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3844) Checkpoint failures should not always lead to job failures - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/29 13:50:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3847] Restructure flink-table test pack... - posted by fhueske <gi...@git.apache.org> on 2016/04/29 13:50:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-3847) Reorganize package structure of flink-table - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/29 13:51:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2016/04/29 14:24:13 UTC, 2 replies.
- [jira] [Updated] (FLINK-2926) Add a Strongly Connected Components Library Method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/29 14:31:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3853) Reduce object creation in Gelly utility mappers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/29 14:49:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3853) Reduce object creation in Gelly utility mappers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/29 14:56:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/04/29 15:59:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/04/29 16:02:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3853] [gelly] Reduce object creation in... - posted by greghogan <gi...@git.apache.org> on 2016/04/29 17:44:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-3853) Reduce object creation in Gelly utility mappers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/29 17:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3801) Upgrade Joda-Time library to 2.9.3 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/29 18:17:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3854) Support Avro key-value rolling sink - posted by "Igor Berman (JIRA)" <ji...@apache.org> on 2016/04/30 00:45:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3854) Support Avro key-value rolling sink writer - posted by "Igor Berman (JIRA)" <ji...@apache.org> on 2016/04/30 00:47:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3855) Upgrade Jackson version - posted by "Tatu Saloranta (JIRA)" <ji...@apache.org> on 2016/04/30 05:29:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3855) Upgrade Jackson version - posted by "Tatu Saloranta (JIRA)" <ji...@apache.org> on 2016/04/30 05:29:12 UTC, 2 replies.
- [GitHub] flink pull request: Jackson version upgrade: default from 2.4.2 to... - posted by cowtowncoder <gi...@git.apache.org> on 2016/04/30 05:31:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-3855) Upgrade Jackson version - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/30 05:32:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3854] Support Avro key-value rolling si... - posted by IgorBerman <gi...@git.apache.org> on 2016/04/30 17:02:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/30 17:03:12 UTC, 0 replies.