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

---

- [GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector - posted by subhankarb <gi...@git.apache.org> on 2016/07/01 04:31:35 UTC, 43 replies.
- [jira] [Commented] (FLINK-3034) Redis SInk Connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 04:32:11 UTC, 55 replies.
- [jira] [Commented] (FLINK-3294) KafkaConsumer (0.8) commit offsets using SimpleConsumer.commitOffsets() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/01 07:20:11 UTC, 0 replies.
- [GitHub] flink issue #2078: [FLINK-2985] Allow different field names for unionAll() i... - posted by gallenvara <gi...@git.apache.org> on 2016/07/01 07:48:04 UTC, 6 replies.
- [jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 07:48:11 UTC, 8 replies.
- [GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation - posted by aljoscha <gi...@git.apache.org> on 2016/07/01 07:57:20 UTC, 8 replies.
- [jira] [Commented] (FLINK-4062) Update Windowing Documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 07:58:11 UTC, 10 replies.
- [GitHub] flink issue #2154: [FLINK-4062] Update Windowing Documentation - posted by aljoscha <gi...@git.apache.org> on 2016/07/01 08:18:42 UTC, 1 replies.
- [GitHub] flink issue #2128: [FLINK-4053] Return value from Connection should be check... - posted by mushketyk <gi...@git.apache.org> on 2016/07/01 08:27:42 UTC, 4 replies.
- [jira] [Commented] (FLINK-4053) Return value from Connection should be checked against null - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 08:28:10 UTC, 5 replies.
- [GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex... - posted by mushketyk <gi...@git.apache.org> on 2016/07/01 08:29:25 UTC, 10 replies.
- [jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 08:30:11 UTC, 10 replies.
- [GitHub] flink pull request #2177: [FLINK-4127] Check API compatbility for 1.1 in fli... - posted by rmetzger <gi...@git.apache.org> on 2016/07/01 08:38:22 UTC, 4 replies.
- [jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 08:39:11 UTC, 16 replies.
- [GitHub] flink issue #2177: [FLINK-4127] Check API compatbility for 1.1 in flink-core - posted by rmetzger <gi...@git.apache.org> on 2016/07/01 09:06:48 UTC, 11 replies.
- [GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation - posted by zentol <gi...@git.apache.org> on 2016/07/01 09:07:19 UTC, 12 replies.
- [jira] [Commented] (FLINK-4116) Document metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 09:08:11 UTC, 13 replies.
- [GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon... - posted by rmetzger <gi...@git.apache.org> on 2016/07/01 09:39:13 UTC, 10 replies.
- [jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 09:40:10 UTC, 15 replies.
- [GitHub] flink issue #2158: [FLINK-4116] Metrics documentation - posted by zentol <gi...@git.apache.org> on 2016/07/01 10:13:02 UTC, 0 replies.
- [GitHub] flink issue #2183: [FLINK-4123] Cassandra sink checks for exceptions in ack ... - posted by zentol <gi...@git.apache.org> on 2016/07/01 11:14:33 UTC, 6 replies.
- [GitHub] flink issue #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics - posted by zentol <gi...@git.apache.org> on 2016/07/01 11:15:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-4123) CassandraWriteAheadSink can hang on cassandra failure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 11:15:11 UTC, 8 replies.
- [jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 11:15:11 UTC, 1 replies.
- [GitHub] flink issue #2176: [FLINK-4118] The docker-flink image is outdated (1.0.2) a... - posted by iemejia <gi...@git.apache.org> on 2016/07/01 11:26:51 UTC, 7 replies.
- [jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 11:27:11 UTC, 14 replies.
- [GitHub] flink issue #2189: [FLINK-3667] delay connection to JobManager until job exe... - posted by zentol <gi...@git.apache.org> on 2016/07/01 11:38:34 UTC, 2 replies.
- [jira] [Commented] (FLINK-3667) Generalize client<->cluster communication - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 11:39:10 UTC, 4 replies.
- [GitHub] flink issue #2167: [FLINK-4122] Disable root shading in Cassandra jar - posted by rmetzger <gi...@git.apache.org> on 2016/07/01 12:48:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-4122) Cassandra jar contains 2 guava versions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 12:48:10 UTC, 2 replies.
- [jira] [Resolved] (FLINK-4062) Update Windowing Documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/01 12:51:11 UTC, 0 replies.
- [GitHub] flink pull request #2172: [FLINK-4096] Ensure JarOutputStream is always clos... - posted by zentol <gi...@git.apache.org> on 2016/07/01 12:55:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-4096) Nested FileOutputStream is not closed in JarFileCreator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 12:56:11 UTC, 4 replies.
- [GitHub] flink issue #2131: [FLINK-3231][streaming-connectors] FlinkKinesisConsumer r... - posted by rmetzger <gi...@git.apache.org> on 2016/07/01 13:07:49 UTC, 3 replies.
- [GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics - posted by asfgit <gi...@git.apache.org> on 2016/07/01 13:10:23 UTC, 0 replies.
- [jira] [Closed] (FLINK-1550) Show JVM Metrics for JobManager - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/01 13:11:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-4057) Expose JobManager Metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/01 13:12:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4139) Yarn: Adjust parallelism and task slots correctly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/01 13:12:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-4122) Cassandra jar contains 2 guava versions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/01 13:20:10 UTC, 0 replies.
- [GitHub] flink pull request #2167: [FLINK-4122] Disable root shading in Cassandra jar - posted by zentol <gi...@git.apache.org> on 2016/07/01 13:20:13 UTC, 0 replies.
- [GitHub] flink pull request #2189: [FLINK-3667] delay connection to JobManager until ... - posted by asfgit <gi...@git.apache.org> on 2016/07/01 13:22:54 UTC, 0 replies.
- [GitHub] flink pull request #2168: [FLINK-3964] add hint to job submission timeout ex... - posted by asfgit <gi...@git.apache.org> on 2016/07/01 13:22:54 UTC, 0 replies.
- [GitHub] flink pull request #2187: [FLINK-3675][yarn] improvements to library shippin... - posted by asfgit <gi...@git.apache.org> on 2016/07/01 13:22:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-3675) YARN ship folder incosistent behavior - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 13:23:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-4139) Yarn: Adjust parallelism and task slots correctly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/01 13:23:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3964) Job submission times out with recursive.file.enumeration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 13:23:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3675) YARN ship folder incosistent behavior - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/01 13:28:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4140) CheckpointCoordinator fails to discard completed checkpoint - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 13:35:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4140) CheckpointCoordinator fails to discard completed checkpoint - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 13:36:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4140) CheckpointCoordinator fails to discard completed checkpoint - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 13:36:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 13:43:11 UTC, 0 replies.
- [GitHub] flink pull request #2176: [FLINK-4118] The docker-flink image is outdated (1... - posted by aljoscha <gi...@git.apache.org> on 2016/07/01 14:08:14 UTC, 6 replies.
- [jira] [Created] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.5.0 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 14:30:11 UTC, 0 replies.
- [GitHub] flink issue #2115: [FLINK-4017] [py] Add Aggregation support to Python API - posted by zentol <gi...@git.apache.org> on 2016/07/01 14:34:04 UTC, 4 replies.
- [jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 14:34:11 UTC, 6 replies.
- [jira] [Updated] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.5.0 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 14:35:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 14:35:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/01 14:47:10 UTC, 5 replies.
- [jira] [Created] (FLINK-4143) Configurable delimiter for metric identifier - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/01 14:56:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4143) Configurable delimiter for metric identifier - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/01 14:56:11 UTC, 0 replies.
- [GitHub] flink pull request #2190: [FLINK-4141] remove leaderUpdated() method from Re... - posted by mxm <gi...@git.apache.org> on 2016/07/01 14:59:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 15:00:14 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/01 15:52:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3753) KillerWatchDog should not use kill on toKill thread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/07/01 16:49:11 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/07/01 16:49:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4144) Yarn properties file: replace hostname/port with Yarn application id - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/01 16:52:11 UTC, 0 replies.
- [GitHub] flink pull request #2191: [FLINK-4144] Yarn properties file: replace hostnam... - posted by mxm <gi...@git.apache.org> on 2016/07/01 16:55:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-4144) Yarn properties file: replace hostname/port with Yarn application id - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 16:56:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-3630) Little mistake in documentation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/01 17:21:11 UTC, 5 replies.
- [jira] [Resolved] (FLINK-4144) Yarn properties file: replace hostname/port with Yarn application id - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/01 18:13:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/01 18:13:11 UTC, 0 replies.
- [GitHub] flink pull request #2032: [FLINK-3965] [gelly] Delegating GraphAlgorithm - posted by asfgit <gi...@git.apache.org> on 2016/07/01 19:14:56 UTC, 0 replies.
- [GitHub] flink pull request #2188: [FLINK-4135] [gelly] Replace ChecksumHashCode as G... - posted by asfgit <gi...@git.apache.org> on 2016/07/01 19:14:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-3965) Delegating GraphAlgorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 19:15:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4135) Replace ChecksumHashCode as GraphAnalytic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/01 19:15:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-4135) Replace ChecksumHashCode as GraphAnalytic - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/01 19:16:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3965) Delegating GraphAlgorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/01 19:16:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4098) Iteration support in Python API - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/07/02 17:33:11 UTC, 2 replies.
- [GitHub] flink pull request #2192: Flink 4034 Maven dependency convergence - posted by vpernin <gi...@git.apache.org> on 2016/07/02 19:53:16 UTC, 0 replies.
- [GitHub] flink issue #2192: Flink 4034 Maven dependency convergence - posted by vpernin <gi...@git.apache.org> on 2016/07/02 21:56:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/07/03 11:37:10 UTC, 18 replies.
- [jira] [Created] (FLINK-4145) JmxReporterTest fails due to port conflicts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/03 14:08:11 UTC, 0 replies.
- [GitHub] flink pull request #2193: [FLINK-4145] [core] Configure port range for JMXRe... - posted by uce <gi...@git.apache.org> on 2016/07/03 14:20:59 UTC, 3 replies.
- [jira] [Commented] (FLINK-4145) JmxReporterTest fails due to port conflicts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/03 14:21:10 UTC, 10 replies.
- [jira] [Created] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/03 16:42:10 UTC, 0 replies.
- [GitHub] flink pull request #2194: [FLINK-4067] [runtime] Add savepoint headers - posted by uce <gi...@git.apache.org> on 2016/07/03 17:08:35 UTC, 32 replies.
- [jira] [Commented] (FLINK-4067) Add version header to savepoints - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/03 17:09:11 UTC, 41 replies.
- [GitHub] flink issue #2193: [FLINK-4145] [core] Configure port range for JMXReporterT... - posted by zentol <gi...@git.apache.org> on 2016/07/03 20:55:11 UTC, 3 replies.
- [GitHub] flink pull request #2078: [FLINK-2985] Allow different field names for union... - posted by wuchong <gi...@git.apache.org> on 2016/07/04 02:21:40 UTC, 1 replies.
- [GitHub] flink issue #1813: [FLINK-3034] Redis Sink Connector - posted by tzulitai <gi...@git.apache.org> on 2016/07/04 06:11:18 UTC, 11 replies.
- [GitHub] flink issue #2186: [licenses] Remove not included dependency from LICENSE - posted by rmetzger <gi...@git.apache.org> on 2016/07/04 07:36:10 UTC, 1 replies.
- [GitHub] flink issue #1954: [FLINK-3190] failure rate restart strategy - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/04 08:07:57 UTC, 8 replies.
- [jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 08:08:11 UTC, 23 replies.
- [jira] [Resolved] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/04 08:23:10 UTC, 0 replies.
- [GitHub] flink pull request #2058: Not able to create flink-streaming-connectors jar - posted by asfgit <gi...@git.apache.org> on 2016/07/04 09:56:06 UTC, 0 replies.
- [GitHub] flink pull request #2108: [FLINK-4027] Flush FlinkKafkaProducer on checkpoin... - posted by asfgit <gi...@git.apache.org> on 2016/07/04 09:56:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/04 09:56:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 09:56:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/04 10:43:10 UTC, 0 replies.
- [GitHub] flink pull request #2183: [FLINK-4123] Cassandra sink checks for exceptions ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/04 10:43:12 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4133) Reflect streaming file source changes in documentation - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/04 10:46:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-939) Distribute required JAR files with seperate service - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/04 11:10:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-972) Run Flink on Tez - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/04 11:10:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1219) Add support for Apache Tez as execution engine - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/04 11:11:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1725) New Partitioner for better load balancing for skewed data - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/04 11:11:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/04 11:12:11 UTC, 0 replies.
- [GitHub] flink pull request #2195: FLINK-3397 Failed streaming jobs should fall back ... - posted by ramkrish86 <gi...@git.apache.org> on 2016/07/04 11:37:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 11:38:10 UTC, 15 replies.
- [GitHub] flink issue #2195: FLINK-3397 Failed streaming jobs should fall back to the ... - posted by ramkrish86 <gi...@git.apache.org> on 2016/07/04 11:39:24 UTC, 3 replies.
- [jira] [Updated] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/04 11:40:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3319) Add or operator to CEP's pattern API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/04 11:46:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/04 11:53:11 UTC, 0 replies.
- [GitHub] flink issue #2153: [FLINK-4110] Add testing skeleton to quickstart - posted by uce <gi...@git.apache.org> on 2016/07/04 12:05:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-4110) Provide testing skeleton in quickstarts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 12:06:10 UTC, 0 replies.
- [GitHub] flink issue #2135: [hotfix] [metrics] Prevent log flooding from collisions - posted by uce <gi...@git.apache.org> on 2016/07/04 12:08:19 UTC, 11 replies.
- [GitHub] flink issue #2123: [FLINK-3904] GlobalConfiguration doesn't ensure config ha... - posted by uce <gi...@git.apache.org> on 2016/07/04 12:11:27 UTC, 6 replies.
- [jira] [Commented] (FLINK-3904) GlobalConfiguration doesn't ensure config has been loaded - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 12:12:10 UTC, 14 replies.
- [jira] [Created] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/04 12:17:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4148) incorrect calculation distance in QuadTree - posted by "Alexey Diomin (JIRA)" <ji...@apache.org> on 2016/07/04 12:34:10 UTC, 0 replies.
- [GitHub] flink pull request #2196: [FLINK-4134] empty session windows fire for late e... - posted by StefanRRichter <gi...@git.apache.org> on 2016/07/04 12:38:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-4134) EventTimeSessionWindows trigger for empty windows when dropping late events - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 12:38:10 UTC, 3 replies.
- [jira] [Updated] (FLINK-4148) incorrect calculation distance in QuadTree - posted by "Alexey Diomin (JIRA)" <ji...@apache.org> on 2016/07/04 12:45:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/04 12:58:11 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/04 12:58:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4136) Add a JobHistory Server service - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/04 13:21:11 UTC, 0 replies.
- [GitHub] flink issue #2194: [FLINK-4067] [runtime] Add savepoint headers - posted by StephanEwen <gi...@git.apache.org> on 2016/07/04 14:27:48 UTC, 7 replies.
- [GitHub] flink pull request #2197: [FLINK-3916] [table] Allow generic types passing t... - posted by twalthr <gi...@git.apache.org> on 2016/07/04 14:28:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-3916) Allow generic types passing the Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 14:29:11 UTC, 5 replies.
- [GitHub] flink issue #2197: [FLINK-3916] [table] Allow generic types passing the Tabl... - posted by twalthr <gi...@git.apache.org> on 2016/07/04 14:32:24 UTC, 3 replies.
- [GitHub] flink pull request #2198: [FLINK-4133] Reflect streaming file source changes... - posted by kl0u <gi...@git.apache.org> on 2016/07/04 14:38:28 UTC, 11 replies.
- [jira] [Commented] (FLINK-4133) Reflect streaming file source changes in documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 14:39:11 UTC, 14 replies.
- [jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/07/04 14:40:11 UTC, 0 replies.
- [GitHub] flink issue #2173: [FLINK-4109] [tableAPI] Change the name of ternary condit... - posted by twalthr <gi...@git.apache.org> on 2016/07/04 14:42:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-4109) Change the name of ternary condition operator 'eval' to '?' - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 14:43:10 UTC, 1 replies.
- [jira] [Created] (FLINK-4149) Fix Serialization of NFA in AbstractKeyedCEPPatternOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/04 14:55:11 UTC, 0 replies.
- [GitHub] flink pull request #2173: [FLINK-4109] [tableAPI] Change the name of ternary... - posted by asfgit <gi...@git.apache.org> on 2016/07/04 15:02:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4109) Change the name of ternary condition operator 'eval' to '?' - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/04 15:04:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/04 15:06:11 UTC, 0 replies.
- [GitHub] flink pull request #2120: [FLINK-4070] [tableApi] Support literals on left s... - posted by twalthr <gi...@git.apache.org> on 2016/07/04 15:13:55 UTC, 2 replies.
- [jira] [Commented] (FLINK-4070) Support literals on left side of binary expressions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 15:14:11 UTC, 4 replies.
- [GitHub] flink issue #2196: [FLINK-4134] empty session windows fire for late events - posted by aljoscha <gi...@git.apache.org> on 2016/07/04 15:16:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/04 15:25:11 UTC, 4 replies.
- [jira] [Resolved] (FLINK-4134) EventTimeSessionWindows trigger for empty windows when dropping late events - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/04 15:26:11 UTC, 0 replies.
- [GitHub] flink issue #2148: [FLINK-3995] [build] Make test utils properly available a... - posted by StephanEwen <gi...@git.apache.org> on 2016/07/04 15:26:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-3995) Properly Structure Test Utils and Dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 15:27:11 UTC, 3 replies.
- [GitHub] flink issue #2126: [FLINK-4086] [tableAPI] Hide internal methods of Expressi... - posted by twalthr <gi...@git.apache.org> on 2016/07/04 15:34:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-4086) Hide internal Expression methods from Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/04 15:35:11 UTC, 1 replies.
- [jira] [Created] (FLINK-4150) Problem with Blobstore in Yarn HA setting on recovery after cluster shutdown - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/04 16:14:11 UTC, 0 replies.
- [GitHub] flink pull request #2126: [FLINK-4086] [tableAPI] Hide internal methods of E... - posted by asfgit <gi...@git.apache.org> on 2016/07/04 16:22:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3559) Don't print pid file check if no active PID - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/04 16:24:10 UTC, 0 replies.
- [GitHub] flink pull request #: - posted by StephanEwen <gi...@git.apache.org> on 2016/07/04 16:33:21 UTC, 8 replies.
- [jira] [Resolved] (FLINK-4086) Hide internal Expression methods from Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/04 16:35:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/04 19:10:11 UTC, 1 replies.
- [GitHub] flink pull request #1954: [FLINK-3190] failure rate restart strategy - posted by fijolekProjects <gi...@git.apache.org> on 2016/07/04 20:50:11 UTC, 14 replies.
- [GitHub] flink issue #2120: [FLINK-4070] [tableApi] Support literals on left side of ... - posted by wuchong <gi...@git.apache.org> on 2016/07/05 02:31:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-4111) Flink Table & SQL doesn't work in very simple example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/05 07:39:10 UTC, 13 replies.
- [jira] [Assigned] (FLINK-4111) Flink Table & SQL doesn't work in very simple example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/05 07:40:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4145) JmxReporterTest fails due to port conflicts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/05 07:50:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4145) JmxReporterTest fails due to port conflicts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/05 07:50:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4145) JmxReporterTest fails due to port conflicts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/05 07:51:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-4150) Problem with Blobstore in Yarn HA setting on recovery after cluster shutdown - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/05 07:57:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-4115) FsStateBackend filesystem verification can cause classpath exceptions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/05 07:57:11 UTC, 1 replies.
- [jira] [Created] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 08:17:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 08:19:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 08:20:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 08:38:10 UTC, 9 replies.
- [GitHub] flink issue #2129: [FLINK-1003] [WIP] Spread out scheduling of tasks - posted by StephanEwen <gi...@git.apache.org> on 2016/07/05 08:59:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-1003) Spread out scheduling strategy - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/05 09:00:21 UTC, 1 replies.
- [GitHub] flink pull request #2199: [FLINK-3648] Introduce Trigger Test Harness - posted by kl0u <gi...@git.apache.org> on 2016/07/05 09:23:10 UTC, 4 replies.
- [jira] [Commented] (FLINK-3648) Introduce Trigger Test Harness - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/05 09:23:11 UTC, 7 replies.
- [GitHub] flink pull request #2115: [FLINK-4017] [py] Add Aggregation support to Pytho... - posted by zentol <gi...@git.apache.org> on 2016/07/05 09:53:33 UTC, 1 replies.
- [GitHub] flink pull request #2200: [FLINK-4146] Fix YARN test failure - posted by rmetzger <gi...@git.apache.org> on 2016/07/05 10:28:33 UTC, 1 replies.
- [GitHub] flink pull request #2201: [FLINK-4151] Split test execution on travis into t... - posted by rmetzger <gi...@git.apache.org> on 2016/07/05 10:29:34 UTC, 1 replies.
- [GitHub] flink pull request #2157: [FLINK-4115] FsStateBackend filesystem verificatio... - posted by asfgit <gi...@git.apache.org> on 2016/07/05 11:51:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-4115) FsStateBackend filesystem verification can cause classpath exceptions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/05 11:52:10 UTC, 2 replies.
- [GitHub] flink issue #2157: [FLINK-4115] FsStateBackend filesystem verification can c... - posted by aljoscha <gi...@git.apache.org> on 2016/07/05 11:52:16 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4115) FsStateBackend filesystem verification can cause classpath exceptions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/05 11:54:11 UTC, 0 replies.
- [GitHub] flink issue #2199: [FLINK-3648] Introduce Trigger Test Harness - posted by aljoscha <gi...@git.apache.org> on 2016/07/05 12:18:44 UTC, 2 replies.
- [jira] [Created] (FLINK-4152) TaskManager registration exponential backoff doesn't work - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 12:33:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-4152) TaskManager registration exponential backoff doesn't work - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 12:34:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-4152) TaskManager registration exponential backoff doesn't work - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 12:41:11 UTC, 49 replies.
- [jira] [Created] (FLINK-4153) ExecutionGraphRestartTest Fails - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/05 12:41:11 UTC, 0 replies.
- [GitHub] flink issue #2198: [FLINK-4133] Reflect streaming file source changes in doc... - posted by kl0u <gi...@git.apache.org> on 2016/07/05 13:52:42 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4149) Fix Serialization of NFA in AbstractKeyedCEPPatternOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/05 14:11:10 UTC, 0 replies.
- [GitHub] flink pull request #2148: [FLINK-3995] [build] Make test utils properly avai... - posted by asfgit <gi...@git.apache.org> on 2016/07/05 14:39:28 UTC, 0 replies.
- [GitHub] flink pull request #2092: [FLINK-3395] [build] Make test utils properly avai... - posted by asfgit <gi...@git.apache.org> on 2016/07/05 14:39:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-3395) Polishing the web UI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/05 14:40:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3995) Properly Structure Test Utils and Dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 14:40:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4154) Correction of murmur hash breaks backwards compatibility - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/05 15:06:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4154) Correction of murmur hash breaks backwards compatibility - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/05 15:11:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4149) Fix Serialization of NFA in AbstractKeyedCEPPatternOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/05 15:15:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-4154) Correction of murmur hash breaks backwards compatibility - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/05 15:40:10 UTC, 5 replies.
- [jira] [Resolved] (FLINK-4133) Reflect streaming file source changes in documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 15:44:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 15:46:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/05 16:06:11 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/05 16:07:11 UTC, 0 replies.
- [GitHub] flink pull request #2202: [FLINK-4149] Fix Serialization of NFA in AbstractK... - posted by aljoscha <gi...@git.apache.org> on 2016/07/05 16:25:24 UTC, 5 replies.
- [jira] [Commented] (FLINK-4149) Fix Serialization of NFA in AbstractKeyedCEPPatternOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/05 16:26:11 UTC, 8 replies.
- [jira] [Created] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/07/05 18:37:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 18:40:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/05 18:41:10 UTC, 0 replies.
- [GitHub] flink issue #2201: [FLINK-4151] Split test execution on travis into two grou... - posted by rmetzger <gi...@git.apache.org> on 2016/07/06 08:20:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/06 08:25:11 UTC, 1 replies.
- [jira] [Created] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/06 08:38:11 UTC, 0 replies.
- [GitHub] flink issue #2202: [FLINK-4149] Fix Serialization of NFA in AbstractKeyedCEP... - posted by aljoscha <gi...@git.apache.org> on 2016/07/06 08:42:01 UTC, 2 replies.
- [GitHub] flink pull request #2203: [hotfix] Quickstart docs respect artifactId - posted by zentol <gi...@git.apache.org> on 2016/07/06 08:56:15 UTC, 1 replies.
- [jira] [Created] (FLINK-4157) FlinkKafkaMetrics cause TaskManager shutdown during cancellation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/06 09:11:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4158) Scala QuickStart StreamingJob fails to compile - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 09:30:11 UTC, 0 replies.
- [GitHub] flink pull request #2204: [FLINK-4158] Fix Scala QS StreamingJob import - posted by zentol <gi...@git.apache.org> on 2016/07/06 09:32:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-4158) Scala QuickStart StreamingJob fails to compile - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/06 09:33:11 UTC, 3 replies.
- [jira] [Created] (FLINK-4159) Quickstart poms exclude unused dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 09:53:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4160) YARN session doesn't show input validation errors - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/06 09:58:11 UTC, 0 replies.
- [GitHub] flink pull request #2205: [FLINK-4137] Tell Akka to shut down the JVM on fat... - posted by rmetzger <gi...@git.apache.org> on 2016/07/06 10:18:11 UTC, 1 replies.
- [GitHub] flink pull request #2206: [FLINK-4157] Catch Kafka metrics serialization exc... - posted by rmetzger <gi...@git.apache.org> on 2016/07/06 10:29:46 UTC, 4 replies.
- [jira] [Commented] (FLINK-4157) FlinkKafkaMetrics cause TaskManager shutdown during cancellation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/06 10:30:11 UTC, 9 replies.
- [jira] [Commented] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/06 10:31:10 UTC, 2 replies.
- [jira] [Resolved] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/06 11:44:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 11:52:10 UTC, 0 replies.
- [GitHub] flink issue #2205: [FLINK-4137] Tell Akka to shut down the JVM on fatal erro... - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/06 11:55:46 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 11:58:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy" - posted by "Rami (JIRA)" <ji...@apache.org> on 2016/07/06 12:01:11 UTC, 4 replies.
- [jira] [Assigned] (FLINK-4160) YARN session doesn't show input validation errors - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 12:15:11 UTC, 0 replies.
- [GitHub] flink issue #2203: [hotfix] Quickstart docs respect artifactId - posted by rmetzger <gi...@git.apache.org> on 2016/07/06 12:20:44 UTC, 1 replies.
- [GitHub] flink issue #2204: [FLINK-4158] Fix Scala QS StreamingJob import - posted by rmetzger <gi...@git.apache.org> on 2016/07/06 12:20:59 UTC, 1 replies.
- [GitHub] flink issue #2083: [FLINK-3713] [clients, runtime] Use user code class loade... - posted by uce <gi...@git.apache.org> on 2016/07/06 12:40:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/06 12:41:11 UTC, 2 replies.
- [jira] [Resolved] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/06 12:44:11 UTC, 0 replies.
- [GitHub] flink issue #2206: [FLINK-4157] Catch Kafka metrics serialization exceptions - posted by StephanEwen <gi...@git.apache.org> on 2016/07/06 12:48:06 UTC, 3 replies.
- [jira] [Closed] (FLINK-4158) Scala QuickStart StreamingJob fails to compile - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 13:04:11 UTC, 0 replies.
- [GitHub] flink pull request #2207: [FLINK-4160][yarn] Show input validation errors - posted by zentol <gi...@git.apache.org> on 2016/07/06 13:09:14 UTC, 1 replies.
- [GitHub] flink issue #2207: [FLINK-4160][yarn] Show input validation errors - posted by zentol <gi...@git.apache.org> on 2016/07/06 13:09:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-4160) YARN session doesn't show input validation errors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/06 13:10:11 UTC, 4 replies.
- [jira] [Closed] (FLINK-4160) YARN session doesn't show input validation errors - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 13:59:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4162) Event-Time CEP Job Fails after Restart - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/06 14:03:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4162) Event-Time CEP Job Fails after Restart - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/06 14:16:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-4162) Event-Time CEP Job Fails after Restart - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/06 14:58:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list - posted by "Faye Beligianni (JIRA)" <ji...@apache.org> on 2016/07/06 15:32:11 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-1815) Add methods to read and write a Graph as adjacency list - posted by "Faye Beligianni (JIRA)" <ji...@apache.org> on 2016/07/06 15:33:11 UTC, 0 replies.
- [GitHub] flink pull request #2208: Sync apache/flink master - posted by thormanrd <gi...@git.apache.org> on 2016/07/06 17:57:01 UTC, 1 replies.
- [GitHub] flink pull request #2209: [FLINK-4111] [table] Flink Table & SQL doesn't wor... - posted by twalthr <gi...@git.apache.org> on 2016/07/06 18:22:54 UTC, 7 replies.
- [jira] [Created] (FLINK-4163) Deadlock during GroupReduce - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/06 19:45:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4163) Deadlock during GroupReduce - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/06 19:46:11 UTC, 8 replies.
- [jira] [Commented] (FLINK-4163) Deadlock during GroupReduce - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 19:51:11 UTC, 18 replies.
- [jira] [Issue Comment Deleted] (FLINK-4163) Deadlock during GroupReduce - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 19:51:11 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4163) Deadlock during GroupReduce - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/06 19:53:11 UTC, 2 replies.
- [jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found. - posted by "Sumit Chawla (JIRA)" <ji...@apache.org> on 2016/07/06 23:42:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3034) Redis SInk Connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/07 08:04:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4164) Use only one rocksdb column family to store all states in an operator - posted by "LiuBiao (JIRA)" <ji...@apache.org> on 2016/07/07 08:08:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4165) Event-Time CEP Job Sometimes Fails After Restart - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/07 09:06:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4166) Generate automatic different namespaces in Zookeeper for Flink applications - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/07 09:07:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4167) TaskMetricGroup does not close IOMetricGroup - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/07 10:03:10 UTC, 0 replies.
- [GitHub] flink pull request #2210: [FLINK-4167] [metrics] Close IOMetricGroup in Task... - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/07 10:04:06 UTC, 3 replies.
- [jira] [Commented] (FLINK-4167) TaskMetricGroup does not close IOMetricGroup - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/07 10:04:11 UTC, 13 replies.
- [GitHub] flink issue #2210: [FLINK-4167] [metrics] Close IOMetricGroup in TaskMetricG... - posted by zentol <gi...@git.apache.org> on 2016/07/07 10:17:08 UTC, 9 replies.
- [jira] [Commented] (FLINK-3671) Code generation for POJO serializer - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/07/07 10:28:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3672) Code generation for POJO comparators - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/07/07 10:29:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3673) Annotations for code generation - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/07/07 10:31:11 UTC, 1 replies.
- [GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ... - posted by Xazax-hun <gi...@git.apache.org> on 2016/07/07 10:41:10 UTC, 5 replies.
- [jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/07 10:41:11 UTC, 5 replies.
- [jira] [Updated] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/07 11:50:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4165) Event-Time CEP Job Sometimes Fails After Restart - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/07 12:03:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-4164) Use only one rocksdb column family to store all states in an operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/07 12:22:11 UTC, 2 replies.
- [jira] [Commented] (FLINK-4165) Event-Time CEP Job Sometimes Fails After Restart - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/07 12:32:11 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4165) Event-Time CEP Job Sometimes Fails After Restart - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/07 12:33:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4168) ForkableFlinkMiniCluster not available in Kinesis connector tests - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/07 12:39:11 UTC, 2 replies.
- [jira] [Created] (FLINK-4168) ForkableFlinkMiniCluster not available in Kinesis connector tests - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/07 12:39:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4169) CEP Does Not Work with RocksDB StateBackend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/07 12:44:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4169) CEP Does Not Work with RocksDB StateBackend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/07 12:44:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4168) ForkableFlinkMiniCluster not available in Kinesis connector tests - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/07 12:45:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-4168) ForkableFlinkMiniCluster not available in Kinesis connector tests - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/07 12:47:11 UTC, 0 replies.
- [GitHub] flink issue #2209: [FLINK-4111] [table] Flink Table & SQL doesn't work in ve... - posted by rmetzger <gi...@git.apache.org> on 2016/07/07 13:01:55 UTC, 4 replies.
- [jira] [Created] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/07 13:05:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/07 13:06:11 UTC, 19 replies.
- [jira] [Comment Edited] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/07 13:11:10 UTC, 3 replies.
- [jira] [Created] (FLINK-4171) StatsD does not accept metrics whose name contains ":" - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/07 13:11:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4154) Correction of murmur hash breaks backwards compatibility - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/07 13:21:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4169) CEP Does Not Work with RocksDB StateBackend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/07 13:28:10 UTC, 1 replies.
- [jira] [Created] (FLINK-4172) Don't proxy a ProxiedObject - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/07 13:29:11 UTC, 0 replies.
- [GitHub] flink pull request #2212: [FLINK-4171] [metrics] Replace : chars in StatsD m... - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/07 13:31:25 UTC, 3 replies.
- [jira] [Commented] (FLINK-4171) StatsD does not accept metrics whose name contains ":" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/07 13:32:11 UTC, 5 replies.
- [GitHub] flink pull request #2213: [FLINK-4172] [gelly] Don't proxy a ProxiedObject - posted by greghogan <gi...@git.apache.org> on 2016/07/07 13:39:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-4172) Don't proxy a ProxiedObject - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/07 13:40:11 UTC, 4 replies.
- [GitHub] flink issue #2071: [FLINK-4018][streaming-connectors] Configurable idle time... - posted by tzulitai <gi...@git.apache.org> on 2016/07/07 13:41:07 UTC, 7 replies.
- [jira] [Commented] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/07 13:41:11 UTC, 13 replies.
- [GitHub] flink issue #2212: [FLINK-4171] [metrics] Replace : chars in StatsD metric n... - posted by zentol <gi...@git.apache.org> on 2016/07/07 13:43:21 UTC, 1 replies.
- [GitHub] flink pull request #1555: [FLINK-3295][Kafka 0.8] Improve ZK error behavior - posted by rmetzger <gi...@git.apache.org> on 2016/07/07 13:51:26 UTC, 0 replies.
- [GitHub] flink issue #1555: [FLINK-3295][Kafka 0.8] Improve ZK error behavior - posted by rmetzger <gi...@git.apache.org> on 2016/07/07 13:51:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-3295) Flink Kafka consumer fails with NoNodeException if zkConnect string contains chroot-path - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/07 13:52:11 UTC, 1 replies.
- [jira] [Created] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/07 14:49:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3648) Introduce Trigger Test Harness - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/07 15:28:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/07/07 16:08:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4174) Enhance Window Evictor - posted by "vishnu viswanath (JIRA)" <ji...@apache.org> on 2016/07/07 16:51:10 UTC, 0 replies.
- [GitHub] flink issue #2169: [FLINK-3943] Add support for EXCEPT operator - posted by mushketyk <gi...@git.apache.org> on 2016/07/07 20:42:16 UTC, 5 replies.
- [jira] [Commented] (FLINK-3943) Add support for EXCEPT (set minus) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/07 20:43:10 UTC, 14 replies.
- [jira] [Created] (FLINK-4175) Broadcast data sent increases with # slots per TM - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2016/07/07 23:42:11 UTC, 0 replies.
- [GitHub] flink pull request #2214: [FLINK-4019][kinesis-connector] Use Kinesis record... - posted by tzulitai <gi...@git.apache.org> on 2016/07/08 00:57:09 UTC, 9 replies.
- [jira] [Commented] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 00:57:11 UTC, 14 replies.
- [GitHub] flink issue #2214: [FLINK-4019][kinesis-connector] Use Kinesis records' appr... - posted by tzulitai <gi...@git.apache.org> on 2016/07/08 01:34:01 UTC, 4 replies.
- [jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 01:51:11 UTC, 2 replies.
- [jira] [Commented] (FLINK-3924) Remove protobuf shading from Kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 01:52:10 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 02:02:10 UTC, 4 replies.
- [jira] [Assigned] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 08:21:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4176) Travis build fails at flink-connector-kinesis for JDK: openjdk 7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 08:48:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4176) Travis build fails at flink-connector-kinesis for JDK: openjdk 7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 08:48:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4176) Travis build fails at flink-connector-kinesis for JDK: openjdk 7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 08:50:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4176) Travis build fails at flink-connector-kinesis for JDK: openjdk7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 08:51:10 UTC, 2 replies.
- [GitHub] flink pull request #2215: [FLINK-4176][kinesis-connector] Remove Java8-speci... - posted by tzulitai <gi...@git.apache.org> on 2016/07/08 08:55:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-4176) Travis build fails at flink-connector-kinesis for JDK: openjdk7 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 08:56:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-3924) Remove protobuf shading from Kinesis connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/08 09:30:11 UTC, 0 replies.
- [GitHub] flink issue #2215: [FLINK-4176][kinesis-connector] Remove Java8-specific 'Lo... - posted by rmetzger <gi...@git.apache.org> on 2016/07/08 09:31:23 UTC, 0 replies.
- [jira] [Created] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/08 10:06:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4178) CoStreamCheckpointingITCase deadlocks - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/08 10:19:11 UTC, 0 replies.
- [GitHub] flink issue #2159: [FLINK-3942] [tableAPI] Add support for INTERSECT - posted by twalthr <gi...@git.apache.org> on 2016/07/08 10:19:42 UTC, 2 replies.
- [jira] [Commented] (FLINK-3942) Add support for INTERSECT - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 10:20:11 UTC, 3 replies.
- [jira] [Resolved] (FLINK-4176) Travis build fails at flink-connector-kinesis for JDK: openjdk7 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/08 10:22:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 10:50:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/08 10:51:11 UTC, 0 replies.
- [GitHub] flink pull request #2216: [FLINK-4173] Use shade-plugin in flink-metrics - posted by zentol <gi...@git.apache.org> on 2016/07/08 11:13:36 UTC, 5 replies.
- [jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 11:14:11 UTC, 7 replies.
- [GitHub] flink pull request #2071: [FLINK-4018][streaming-connectors] Configurable id... - posted by rmetzger <gi...@git.apache.org> on 2016/07/08 11:17:46 UTC, 5 replies.
- [jira] [Updated] (FLINK-4159) Quickstart poms exclude unused dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/08 11:23:11 UTC, 0 replies.
- [GitHub] flink pull request #2217: [FLINK-4159] Remove Quickstart exclusions for unus... - posted by zentol <gi...@git.apache.org> on 2016/07/08 11:30:30 UTC, 6 replies.
- [jira] [Commented] (FLINK-4159) Quickstart poms exclude unused dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 11:31:11 UTC, 8 replies.
- [GitHub] flink pull request #2218: [FLINK-4161] Add Quickstart exclusion for flink-di... - posted by zentol <gi...@git.apache.org> on 2016/07/08 11:39:53 UTC, 1 replies.
- [jira] [Commented] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 11:40:10 UTC, 7 replies.
- [jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/07/08 11:48:11 UTC, 0 replies.
- [GitHub] flink issue #2213: [FLINK-4172] [gelly] Don't proxy a ProxiedObject - posted by greghogan <gi...@git.apache.org> on 2016/07/08 12:14:24 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4143) Configurable delimiter for metric identifier - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/08 12:18:10 UTC, 0 replies.
- [GitHub] flink pull request #2219: [FLINK-4143][metrics] Configurable delimiter - posted by zentol <gi...@git.apache.org> on 2016/07/08 12:23:53 UTC, 7 replies.
- [jira] [Commented] (FLINK-4143) Configurable delimiter for metric identifier - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 12:24:10 UTC, 10 replies.
- [GitHub] flink pull request #2159: [FLINK-3942] [tableAPI] Add support for INTERSECT - posted by asfgit <gi...@git.apache.org> on 2016/07/08 12:54:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3942) Add support for INTERSECT - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 12:57:10 UTC, 0 replies.
- [GitHub] flink pull request #2169: [FLINK-3943] Add support for EXCEPT operator - posted by twalthr <gi...@git.apache.org> on 2016/07/08 13:03:02 UTC, 8 replies.
- [jira] [Created] (FLINK-4179) Update TPCHQuery3Table example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:02:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4179) Update TPCHQuery3Table example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:03:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-4180) Create a batch SQL example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:06:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4180) Create a batch SQL example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:06:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4181) Add a basic streaming Table API example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:09:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-4181) Add a basic streaming Table API example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:12:11 UTC, 1 replies.
- [jira] [Created] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures. - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/08 14:14:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures. - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/08 14:16:11 UTC, 1 replies.
- [jira] [Created] (FLINK-4183) Move checking for StreamTableEnvironment into validation layer - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/08 14:21:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/08 14:24:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4184) Ganglia and GraphiteReporter report metric names with invalid characters - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/08 14:42:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-4171) StatsD does not accept metrics whose name contains ":" - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/08 14:53:11 UTC, 0 replies.
- [GitHub] flink pull request #2220: [FLINK-4184] [metrics] Replace invalid characters ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/08 14:54:19 UTC, 10 replies.
- [jira] [Commented] (FLINK-4184) Ganglia and GraphiteReporter report metric names with invalid characters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 14:55:11 UTC, 18 replies.
- [jira] [Commented] (FLINK-4181) Add a basic streaming Table API example - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/08 15:31:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4180) Create a batch SQL example - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/08 15:31:11 UTC, 7 replies.
- [jira] [Assigned] (FLINK-4180) Create a batch SQL example - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/08 15:31:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4181) Add a basic streaming Table API example - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/08 15:31:11 UTC, 0 replies.
- [GitHub] flink pull request #2221: [FLINK-4183] [table] Move checking for StreamTable... - posted by twalthr <gi...@git.apache.org> on 2016/07/08 15:57:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4183) Move checking for StreamTableEnvironment into validation layer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 15:58:11 UTC, 3 replies.
- [GitHub] flink issue #2220: [FLINK-4184] [metrics] Replace invalid characters in Sche... - posted by zentol <gi...@git.apache.org> on 2016/07/08 16:01:10 UTC, 7 replies.
- [jira] [Created] (FLINK-4185) Reflecting rename from Tachyon to Alluxio - posted by "Jiri Simsa (JIRA)" <ji...@apache.org> on 2016/07/08 16:33:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-4185) Reflecting rename from Tachyon to Alluxio - posted by "Jiri Simsa (JIRA)" <ji...@apache.org> on 2016/07/08 16:34:10 UTC, 0 replies.
- [GitHub] flink pull request #2222: [FLINK-4185] Reflecting rename from Tachyon to All... - posted by jsimsa <gi...@git.apache.org> on 2016/07/08 16:36:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-4185) Reflecting rename from Tachyon to Alluxio - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 16:36:11 UTC, 2 replies.
- [GitHub] flink pull request #2223: [FLINK-4154] [core] Correction of murmur hash brea... - posted by greghogan <gi...@git.apache.org> on 2016/07/08 18:25:55 UTC, 1 replies.
- [jira] [Closed] (FLINK-4172) Don't proxy a ProxiedObject - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/08 19:32:11 UTC, 0 replies.
- [GitHub] flink pull request #1517: [FLINK-3477] [runtime] Add hash-based combine stra... - posted by greghogan <gi...@git.apache.org> on 2016/07/08 20:58:50 UTC, 7 replies.
- [jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/08 20:59:11 UTC, 9 replies.
- [jira] [Updated] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/09 09:13:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/09 09:13:11 UTC, 3 replies.
- [jira] [Resolved] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/09 09:25:11 UTC, 0 replies.
- [GitHub] flink issue #2172: [FLINK-4096] Ensure JarOutputStream is always closed - posted by mushketyk <gi...@git.apache.org> on 2016/07/09 22:25:28 UTC, 2 replies.
- [GitHub] flink pull request #2224: {hotfix} fix errors and formatting in NiFi documen... - posted by smarthi <gi...@git.apache.org> on 2016/07/10 05:21:01 UTC, 0 replies.
- [jira] [Created] (FLINK-4186) Expose Kafka metrics through Flink metrics - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/10 08:10:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4187) Support for outer joins on DataStream - posted by "Ignacio N. Lucero Ascencio (JIRA)" <ji...@apache.org> on 2016/07/10 14:37:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4188) Support for outer joins on DataStream - posted by "Ignacio N. Lucero Ascencio (JIRA)" <ji...@apache.org> on 2016/07/10 14:38:10 UTC, 0 replies.
- [GitHub] flink issue #1517: [FLINK-3477] [runtime] Add hash-based combine strategy fo... - posted by ggevay <gi...@git.apache.org> on 2016/07/10 14:41:44 UTC, 1 replies.
- [GitHub] flink pull request #1999: [FLINK-3805] BloomFilter initialized with no memor... - posted by rekhajoshm <gi...@git.apache.org> on 2016/07/10 21:07:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-3805) BloomFilter initialized with no memory available - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/10 21:08:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-4187) Support for outer joins on DataStream - posted by "miaoever (JIRA)" <ji...@apache.org> on 2016/07/11 01:47:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3163) Configure Flink for NUMA systems - posted by "Saliya Ekanayake (JIRA)" <ji...@apache.org> on 2016/07/11 04:10:11 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3875) Add a TableSink for Elasticsearch - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/07/11 06:37:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4189) Introduce symbols for internal use - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/11 07:38:11 UTC, 0 replies.
- [GitHub] flink issue #2223: [FLINK-4154] [core] Correction of murmur hash breaks back... - posted by uce <gi...@git.apache.org> on 2016/07/11 08:01:17 UTC, 0 replies.
- [GitHub] flink pull request #2224: [docs] {hotfix} fix errors and formatting in NiFi ... - posted by rmetzger <gi...@git.apache.org> on 2016/07/11 09:15:39 UTC, 1 replies.
- [jira] [Closed] (FLINK-4116) Document metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/11 09:27:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/11 09:34:11 UTC, 3 replies.
- [jira] [Closed] (FLINK-4096) Nested FileOutputStream is not closed in JarFileCreator - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/11 09:44:11 UTC, 0 replies.
- [GitHub] flink issue #2224: [docs] {hotfix} fix errors and formatting in NiFi documen... - posted by rmetzger <gi...@git.apache.org> on 2016/07/11 10:01:45 UTC, 0 replies.
- [GitHub] flink issue #2222: [FLINK-4185] Reflecting rename from Tachyon to Alluxio. - posted by rmetzger <gi...@git.apache.org> on 2016/07/11 10:04:48 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4185) Reflecting rename from Tachyon to Alluxio - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/11 10:07:11 UTC, 0 replies.
- [GitHub] flink issue #1989: FLINK-3901 - Added CsvRowInputFormat - posted by twalthr <gi...@git.apache.org> on 2016/07/11 10:09:42 UTC, 5 replies.
- [jira] [Commented] (FLINK-3901) Create a RowCsvInputFormat to use as default CSV IF in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/11 10:10:11 UTC, 10 replies.
- [GitHub] flink issue #2219: [FLINK-4143][metrics] Configurable delimiter - posted by zentol <gi...@git.apache.org> on 2016/07/11 10:25:12 UTC, 2 replies.
- [jira] [Created] (FLINK-4190) Generalise RollingSink to work with arbitrary buckets - posted by "Josh Forman-Gornall (JIRA)" <ji...@apache.org> on 2016/07/11 11:43:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4190) Generalise RollingSink to work with arbitrary buckets - posted by "Josh Forman-Gornall (JIRA)" <ji...@apache.org> on 2016/07/11 11:43:11 UTC, 20 replies.
- [jira] [Commented] (FLINK-4178) CoStreamCheckpointingITCase deadlocks - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/11 12:03:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3943) Add support for EXCEPT (set minus) - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/11 12:04:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4157) FlinkKafkaMetrics cause TaskManager shutdown during cancellation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/11 12:07:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4191) Expose shard information in KinesisDeserializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/11 12:54:11 UTC, 0 replies.
- [GitHub] flink pull request #2225: [FLINK-4191] Expose shard information in kinesis d... - posted by rmetzger <gi...@git.apache.org> on 2016/07/11 12:55:29 UTC, 9 replies.
- [jira] [Commented] (FLINK-4191) Expose shard information in KinesisDeserializationSchema - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/11 12:56:11 UTC, 15 replies.
- [jira] [Created] (FLINK-4192) Move Metrics API to separate module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/11 14:02:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4193) Task manager JVM crashes while deploying cancelling jobs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/07/11 14:12:10 UTC, 0 replies.
- [GitHub] flink pull request #2226: [FLINK-4192] - Move Metrics API to separate module - posted by zentol <gi...@git.apache.org> on 2016/07/11 14:32:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-4192) Move Metrics API to separate module - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/11 14:33:11 UTC, 35 replies.
- [GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module - posted by zentol <gi...@git.apache.org> on 2016/07/11 14:35:35 UTC, 33 replies.
- [jira] [Issue Comment Deleted] (FLINK-4190) Generalise RollingSink to work with arbitrary buckets - posted by "Josh Forman-Gornall (JIRA)" <ji...@apache.org> on 2016/07/11 14:52:11 UTC, 1 replies.
- [GitHub] flink issue #2225: [FLINK-4191] Expose shard information in kinesis deserial... - posted by tzulitai <gi...@git.apache.org> on 2016/07/11 14:55:26 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-4190) Generalise RollingSink to work with arbitrary buckets - posted by "Josh Forman-Gornall (JIRA)" <ji...@apache.org> on 2016/07/11 14:59:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-4154) Correction of murmur hash breaks backwards compatibility - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/11 15:22:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4193) Task manager JVM crashes while deploying cancelling jobs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/11 15:51:10 UTC, 6 replies.
- [GitHub] flink issue #2217: [FLINK-4159] Remove Quickstart exclusions for unused depe... - posted by greghogan <gi...@git.apache.org> on 2016/07/11 15:56:46 UTC, 1 replies.
- [jira] [Created] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/11 17:02:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/11 18:33:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/11 18:34:11 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/11 18:34:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3085) Move State Backend Initialization from "registerInputOutput()" to "invoke()" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/11 19:24:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3085) Move State Backend Initialization from "registerInputOutput()" to "invoke()" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/11 19:24:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4196) Remove "recoveryTimestamp" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/11 19:31:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4196) Remove "recoveryTimestamp" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/11 19:32:10 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-4196) Remove "recoveryTimestamp" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/11 19:32:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3515) Make the "file monitoring source" exactly-once - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/11 19:53:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/11 19:56:10 UTC, 2 replies.
- [GitHub] flink issue #421: [FLINK-1501] Add metrics library for monitoring TaskManage... - posted by sumitchawla <gi...@git.apache.org> on 2016/07/11 22:02:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/11 22:03:11 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3190) Retry rate limits for DataStream API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/11 22:03:12 UTC, 0 replies.
- [GitHub] flink issue #1947: [FLINK-1502] [WIP] Basic Metric System - posted by sumitchawla <gi...@git.apache.org> on 2016/07/11 22:56:51 UTC, 6 replies.
- [jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/11 22:57:11 UTC, 6 replies.
- [jira] [Created] (FLINK-4197) Allow Kinesis Endpoint to be Overridden via Config - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/07/12 02:32:10 UTC, 0 replies.
- [GitHub] flink pull request #2227: [FLINK-4197] Allow Kinesis endpoint to be overridd... - posted by skidder <gi...@git.apache.org> on 2016/07/12 02:39:46 UTC, 10 replies.
- [jira] [Commented] (FLINK-4197) Allow Kinesis Endpoint to be Overridden via Config - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/12 02:40:10 UTC, 17 replies.
- [jira] [Comment Edited] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/12 03:24:11 UTC, 10 replies.
- [GitHub] flink issue #2227: [FLINK-4197] Allow Kinesis endpoint to be overridden via ... - posted by tzulitai <gi...@git.apache.org> on 2016/07/12 03:31:21 UTC, 6 replies.
- [GitHub] flink pull request #2228: [FLINK-4170][kinesis-connector] Simplify Kinesis c... - posted by tzulitai <gi...@git.apache.org> on 2016/07/12 07:47:40 UTC, 4 replies.
- [GitHub] flink issue #2228: [FLINK-4170][kinesis-connector] Simplify Kinesis connecte... - posted by tzulitai <gi...@git.apache.org> on 2016/07/12 08:08:24 UTC, 6 replies.
- [jira] [Resolved] (FLINK-4191) Expose shard information in KinesisDeserializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/12 08:11:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/12 08:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4198) Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/12 09:06:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4199) Wrong client behavior when submitting job to non-existing cluster - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/12 09:17:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4199) Wrong client behavior when submitting job to non-existing cluster - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/12 09:18:20 UTC, 5 replies.
- [GitHub] flink pull request #2229: [hotfix][docs] Add note about Kinesis producer lim... - posted by rmetzger <gi...@git.apache.org> on 2016/07/12 09:19:58 UTC, 4 replies.
- [GitHub] flink issue #2229: [hotfix][docs] Add note about Kinesis producer limitation... - posted by uce <gi...@git.apache.org> on 2016/07/12 10:18:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4200) Kafka consumers should log the offset from which they restore - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/12 13:00:23 UTC, 0 replies.
- [GitHub] flink pull request #2230: [FLINK-4200] [Kafka Connector] Kafka consumers log... - posted by StefanRRichter <gi...@git.apache.org> on 2016/07/12 13:17:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-4200) Kafka consumers should log the offset from which they restore - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/12 13:18:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-4006) ExecutionGraph.restartStrategy field can't be serialized - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/12 13:31:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4006) ExecutionGraph.restartStrategy field can't be serialized - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/12 13:41:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4006) ExecutionGraph.restartStrategy field can't be serialized - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/12 13:41:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3916) Allow generic types passing the Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/12 13:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4201) Checkpoints for jobs in non-terminal state (e.g. suspended) get deleted - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/12 13:57:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4111) Flink Table & SQL doesn't work in very simple example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/12 14:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4202) Add JM metric which shows the restart duration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/12 14:14:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4199) Wrong client behavior when submitting job to non-existing cluster - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/12 14:25:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4203) Improve Table API documentation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/12 15:59:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4123) CassandraWriteAheadSink can hang on cassandra failure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/12 16:09:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4203) Improve Table API documentation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/12 16:28:20 UTC, 0 replies.
- [GitHub] flink issue #2230: [FLINK-4200] [Kafka Connector] Kafka consumers logs the o... - posted by rmetzger <gi...@git.apache.org> on 2016/07/12 16:42:31 UTC, 1 replies.
- [GitHub] flink issue #2002: Support for bz2 compression in flink-core - posted by mtanski <gi...@git.apache.org> on 2016/07/12 17:07:22 UTC, 2 replies.
- [GitHub] flink pull request #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to ... - posted by radekg <gi...@git.apache.org> on 2016/07/12 19:28:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/12 19:28:21 UTC, 17 replies.
- [jira] [Created] (FLINK-4204) Clean up gelly-examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/07/12 21:50:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4204) Clean up gelly-examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/07/12 21:50:20 UTC, 4 replies.
- [GitHub] flink pull request #2232: FLINK-4179: Update TPCHQuery3Table example - posted by smarthi <gi...@git.apache.org> on 2016/07/13 01:35:14 UTC, 1 replies.
- [jira] [Commented] (FLINK-4179) Update TPCHQuery3Table example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/13 01:35:20 UTC, 1 replies.
- [GitHub] flink pull request #2233: [FLINK-2125][streaming] Delimiter change from char... - posted by delding <gi...@git.apache.org> on 2016/07/13 03:33:53 UTC, 3 replies.
- [jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/13 03:34:22 UTC, 14 replies.
- [GitHub] flink issue #2233: [FLINK-2125][streaming] Delimiter change from char to str... - posted by delding <gi...@git.apache.org> on 2016/07/13 03:39:11 UTC, 9 replies.
- [jira] [Issue Comment Deleted] (FLINK-2125) String delimiter for SocketTextStream - posted by "Erli Ding (JIRA)" <ji...@apache.org> on 2016/07/13 03:43:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/13 06:34:20 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/13 06:35:20 UTC, 9 replies.
- [jira] [Created] (FLINK-4205) Implement stratified sampling for DataSet - posted by "Do Le Quoc (JIRA)" <ji...@apache.org> on 2016/07/13 07:21:20 UTC, 0 replies.
- [GitHub] flink pull request #2234: [hotfix][kinesis-connector] Remove duplicate info ... - posted by tzulitai <gi...@git.apache.org> on 2016/07/13 07:41:12 UTC, 1 replies.
- [GitHub] flink pull request #2235: [hotfix] removed duplicated code - posted by StefanRRichter <gi...@git.apache.org> on 2016/07/13 08:23:54 UTC, 1 replies.
- [GitHub] flink issue #2235: [hotfix] removed duplicated code - posted by zentol <gi...@git.apache.org> on 2016/07/13 08:33:57 UTC, 1 replies.
- [jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/13 08:41:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4127) Clean up configuration and check breaking API changes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/13 08:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4206) Metric names should alle special characters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/13 08:52:20 UTC, 0 replies.
- [GitHub] flink pull request #2236: [FLINK-4186] Use Flink metrics to report Kafka met... - posted by rmetzger <gi...@git.apache.org> on 2016/07/13 08:52:34 UTC, 17 replies.
- [jira] [Commented] (FLINK-4186) Expose Kafka metrics through Flink metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/13 08:53:20 UTC, 23 replies.
- [GitHub] flink issue #2236: [FLINK-4186] Use Flink metrics to report Kafka metrics - posted by rmetzger <gi...@git.apache.org> on 2016/07/13 08:55:07 UTC, 5 replies.
- [jira] [Updated] (FLINK-4206) Metric names should allow special characters - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/13 08:55:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4207) WindowOperator becomes very slow with allowed lateness - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/13 08:56:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4207) WindowOperator becomes very slow with allowed lateness - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/13 08:57:20 UTC, 0 replies.
- [GitHub] flink pull request #2237: [FLINK-4206][metrics] Remove alphanumeric name res... - posted by zentol <gi...@git.apache.org> on 2016/07/13 09:03:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-4206) Metric names should allow special characters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/13 09:04:20 UTC, 4 replies.
- [jira] [Closed] (FLINK-4200) Kafka consumers should log the offset from which they restore - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/13 09:37:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4159) Quickstart poms exclude unused dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/13 09:41:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4143) Configurable delimiter for metric identifier - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/13 09:45:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3729) Several SQL tests fail on Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/13 10:19:20 UTC, 0 replies.
- [GitHub] flink pull request #2238: [FLINK-3729] Fix Several SQL tests on Windows OS - posted by zentol <gi...@git.apache.org> on 2016/07/13 12:06:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-3729) Several SQL tests fail on Windows OS - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/13 12:07:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4207) WindowOperator becomes very slow with allowed lateness - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/13 12:20:20 UTC, 10 replies.
- [jira] [Comment Edited] (FLINK-4207) WindowOperator becomes very slow with allowed lateness - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/13 12:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4208) Support Running Flink processes in foreground mode - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/07/13 13:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4209) Docker image breaks with multiple NICs - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/07/13 13:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/13 13:44:20 UTC, 0 replies.
- [GitHub] flink pull request #2239: [FLINK-4208] Support Running Flink processes in fo... - posted by iemejia <gi...@git.apache.org> on 2016/07/13 14:05:02 UTC, 4 replies.
- [jira] [Commented] (FLINK-4208) Support Running Flink processes in foreground mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/13 14:05:20 UTC, 12 replies.
- [GitHub] flink pull request #2240: [FLINK-4209] Docker image breaks with multiple NIC... - posted by iemejia <gi...@git.apache.org> on 2016/07/13 14:06:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-4209) Docker image breaks with multiple NICs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/13 14:06:20 UTC, 2 replies.
- [GitHub] flink issue #2240: [FLINK-4209] Docker image breaks with multiple NICs - posted by iemejia <gi...@git.apache.org> on 2016/07/13 14:07:54 UTC, 0 replies.
- [GitHub] flink issue #2239: [FLINK-4208] Support Running Flink processes in foregroun... - posted by iemejia <gi...@git.apache.org> on 2016/07/13 14:09:21 UTC, 7 replies.
- [jira] [Assigned] (FLINK-3666) Remove Nephele references - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/13 14:16:20 UTC, 0 replies.
- [GitHub] flink pull request #2241: [FLINK-3666] Remove all remaining Nephele referenc... - posted by zentol <gi...@git.apache.org> on 2016/07/13 14:16:21 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4196) Remove "recoveryTimestamp" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/13 14:17:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3666) Remove Nephele references - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/13 14:17:20 UTC, 3 replies.
- [jira] [Created] (FLINK-4211) Dynamic Properties not working for jobs submitted to Yarn session - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/13 14:44:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4167) TaskMetricGroup does not close IOMetricGroup - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/13 15:03:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4152) TaskManager registration exponential backoff doesn't work - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/13 15:04:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4212) Lock on pid file when starting daemons - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/13 15:51:21 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4152) TaskManager registration exponential backoff doesn't work - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/13 16:25:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4197) Allow Kinesis Endpoint to be Overridden via Config - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/13 17:10:20 UTC, 0 replies.
- [GitHub] flink issue #2234: [hotfix][kinesis-connector] Remove duplicate info in Kine... - posted by rmetzger <gi...@git.apache.org> on 2016/07/13 17:11:59 UTC, 0 replies.
- [GitHub] flink issue #2237: [FLINK-4206][metrics] Remove alphanumeric name restrictio... - posted by rmetzger <gi...@git.apache.org> on 2016/07/13 17:17:03 UTC, 2 replies.
- [jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/13 17:30:20 UTC, 13 replies.
- [GitHub] flink pull request #2242: ExceptionHandler keep count of exceptions - posted by sumitchawla <gi...@git.apache.org> on 2016/07/13 19:19:15 UTC, 0 replies.
- [GitHub] flink pull request #2243: [FLINK-4196] [runtime] Remove recovery timestamp f... - posted by StephanEwen <gi...@git.apache.org> on 2016/07/13 19:54:08 UTC, 1 replies.
- [GitHub] flink pull request #2244: Kafka json - posted by mushketyk <gi...@git.apache.org> on 2016/07/13 21:45:29 UTC, 0 replies.
- [GitHub] flink issue #2244: [FLINK-3874] Add a Kafka TableSink with JSON serializatio... - posted by mushketyk <gi...@git.apache.org> on 2016/07/13 21:47:26 UTC, 4 replies.
- [jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/13 21:48:20 UTC, 8 replies.
- [jira] [Closed] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/14 01:16:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-2246) Add chained combine driver strategy for ReduceFunction - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/14 01:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4213) Provide CombineHint in Gelly algorithms - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/14 01:25:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4214) JobExceptionsHandler will return all exceptions - posted by "Sumit Chawla (JIRA)" <ji...@apache.org> on 2016/07/14 03:46:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4214) JobExceptionsHandler will return all exceptions - posted by "Sumit Chawla (JIRA)" <ji...@apache.org> on 2016/07/14 03:48:20 UTC, 3 replies.
- [jira] [Updated] (FLINK-4214) JobExceptionsHandler will return all exceptions - posted by "Sumit Chawla (JIRA)" <ji...@apache.org> on 2016/07/14 04:14:20 UTC, 1 replies.
- [GitHub] flink issue #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to Kafka 0... - posted by tzulitai <gi...@git.apache.org> on 2016/07/14 06:34:24 UTC, 12 replies.
- [jira] [Created] (FLINK-4215) timestamp of StreamRecord is lost in WindowOperator - posted by "Cody (JIRA)" <ji...@apache.org> on 2016/07/14 08:20:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4215) timestamp of StreamRecord is lost in WindowOperator - posted by "Cody (JIRA)" <ji...@apache.org> on 2016/07/14 08:39:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4178) CoStreamCheckpointingITCase deadlocks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/14 08:46:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4215) timestamp of StreamRecord is lost in WindowOperator - posted by "Cody (JIRA)" <ji...@apache.org> on 2016/07/14 08:52:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4206) Metric names should allow special characters - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/14 09:12:20 UTC, 0 replies.
- [GitHub] flink pull request #2245: [hotfix] Fix Redis Sink to fail at opening if Redi... - posted by kl0u <gi...@git.apache.org> on 2016/07/14 09:20:47 UTC, 14 replies.
- [GitHub] flink pull request #2246: [hotfix] [doc] fixed example - posted by mjsax <gi...@git.apache.org> on 2016/07/14 09:29:08 UTC, 1 replies.
- [GitHub] flink issue #2246: [hotfix] [doc] fixed example - posted by rmetzger <gi...@git.apache.org> on 2016/07/14 09:45:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4216) WordWithCount example with Java has wrong generics type - posted by "Serhiy Boychenko (JIRA)" <ji...@apache.org> on 2016/07/14 10:14:20 UTC, 0 replies.
- [GitHub] flink pull request #2247: FLINK-4216 - posted by serhiy <gi...@git.apache.org> on 2016/07/14 10:22:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-4216) WordWithCount example with Java has wrong generics type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/14 10:23:20 UTC, 4 replies.
- [GitHub] flink issue #2247: FLINK-4216 - posted by serhiy <gi...@git.apache.org> on 2016/07/14 10:24:36 UTC, 2 replies.
- [jira] [Updated] (FLINK-4216) WordWithCount example with Java has wrong generics type - posted by "Serhiy Boychenko (JIRA)" <ji...@apache.org> on 2016/07/14 10:28:20 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/14 12:36:20 UTC, 0 replies.
- [GitHub] flink issue #2242: [FLINK-4214] ExceptionHandler keep count of exceptions - posted by rmetzger <gi...@git.apache.org> on 2016/07/14 12:48:28 UTC, 1 replies.
- [GitHub] flink pull request #2244: [FLINK-3874] Add a Kafka TableSink with JSON seria... - posted by rmetzger <gi...@git.apache.org> on 2016/07/14 12:59:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-4211) Dynamic Properties not working for jobs submitted to Yarn session - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/14 13:14:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4217) Gelly drivers should read CSV values as strings - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/14 13:32:20 UTC, 0 replies.
- [GitHub] flink issue #2243: [FLINK-4196] [runtime] Remove recovery timestamp from che... - posted by uce <gi...@git.apache.org> on 2016/07/14 13:45:18 UTC, 2 replies.
- [jira] [Created] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting - posted by "Sergii Koshel (JIRA)" <ji...@apache.org> on 2016/07/14 15:26:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting - posted by "Sergii Koshel (JIRA)" <ji...@apache.org> on 2016/07/14 15:27:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4212) Lock PID file when starting daemons - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/14 15:55:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/14 16:16:20 UTC, 4 replies.
- [GitHub] flink pull request #2248: [FLINK-4213] [gelly] Provide CombineHint in Gelly ... - posted by greghogan <gi...@git.apache.org> on 2016/07/14 16:25:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-4213) Provide CombineHint in Gelly algorithms - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/14 16:25:20 UTC, 5 replies.
- [jira] [Commented] (FLINK-3985) A metric with the name * was already registered - posted by "Joshua Griffith (JIRA)" <ji...@apache.org> on 2016/07/14 16:34:20 UTC, 1 replies.
- [GitHub] flink pull request #2249: 4166 zookeeper namespaces - posted by StefanRRichter <gi...@git.apache.org> on 2016/07/14 17:05:45 UTC, 14 replies.
- [jira] [Created] (FLINK-4219) Quote PDSH opts in start-cluster.sh - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/14 17:40:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3630) Little mistake in documentation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/14 18:41:20 UTC, 0 replies.
- [GitHub] flink pull request #2250: [FLINK-4217] [gelly] Gelly drivers should read CSV... - posted by greghogan <gi...@git.apache.org> on 2016/07/14 19:04:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-4217) Gelly drivers should read CSV values as strings - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/14 19:05:20 UTC, 1 replies.
- [GitHub] flink issue #2248: [FLINK-4213] [gelly] Provide CombineHint in Gelly algorit... - posted by StephanEwen <gi...@git.apache.org> on 2016/07/14 19:17:03 UTC, 3 replies.
- [jira] [Commented] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/14 19:32:20 UTC, 8 replies.
- [GitHub] flink issue #2241: [FLINK-3666] Remove all remaining Nephele references - posted by StephanEwen <gi...@git.apache.org> on 2016/07/14 19:39:59 UTC, 1 replies.
- [GitHub] flink pull request #2251: [FLINK-4212] [scripts] Lock PID file when starting... - posted by greghogan <gi...@git.apache.org> on 2016/07/14 19:55:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-4212) Lock PID file when starting daemons - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/14 19:56:20 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3874) Add a Kafka TableSink with JSON serialization - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/07/14 20:02:20 UTC, 0 replies.
- [GitHub] flink pull request #2242: [FLINK-4214] ExceptionHandler keep count of except... - posted by asfgit <gi...@git.apache.org> on 2016/07/14 20:34:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4214) JobExceptionsHandler will return all exceptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/14 20:40:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4216) WordWithCount example with Java has wrong generics type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/14 20:40:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4216) WordWithCount example with Java has wrong generics type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/14 20:40:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4214) JobExceptionsHandler will return all exceptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/14 20:40:20 UTC, 0 replies.
- [GitHub] flink pull request #2252: [FLINK-3466] [runtime] Cancel state handled on sta... - posted by StephanEwen <gi...@git.apache.org> on 2016/07/14 20:50:35 UTC, 9 replies.
- [GitHub] flink issue #2249: 4166 zookeeper namespaces - posted by zentol <gi...@git.apache.org> on 2016/07/14 21:17:56 UTC, 1 replies.
- [GitHub] flink pull request #2253: [FLINK-4219] [scripts] Quote PDSH opts in start-cl... - posted by greghogan <gi...@git.apache.org> on 2016/07/15 00:21:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-4219) Quote PDSH opts in start-cluster.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/15 00:21:20 UTC, 0 replies.
- [GitHub] flink pull request #2254: [FLINK-3630] [docs] Little mistake in documentatio... - posted by greghogan <gi...@git.apache.org> on 2016/07/15 00:22:24 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/15 04:32:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4207) WindowOperator becomes very slow with allowed lateness - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/15 04:46:20 UTC, 0 replies.
- [GitHub] flink issue #2254: [FLINK-3630] [docs] Little mistake in documentation - posted by uce <gi...@git.apache.org> on 2016/07/15 09:03:36 UTC, 1 replies.
- [jira] [Created] (FLINK-4220) ClientTest fails after port conflict - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/15 09:09:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/15 09:13:21 UTC, 0 replies.
- [GitHub] flink pull request #2255: [FLINK-4142][docs] Add warning about YARN HA bug - posted by rmetzger <gi...@git.apache.org> on 2016/07/15 09:21:34 UTC, 1 replies.
- [GitHub] flink issue #2252: [FLINK-3466] [runtime] Cancel state handled on state rest... - posted by uce <gi...@git.apache.org> on 2016/07/15 09:42:37 UTC, 2 replies.
- [GitHub] flink issue #2255: [FLINK-4142][docs] Add warning about YARN HA bug - posted by uce <gi...@git.apache.org> on 2016/07/15 09:43:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-3666) Remove Nephele references - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/15 09:54:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-3630) Little mistake in documentation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/15 09:57:20 UTC, 0 replies.
- [GitHub] flink pull request #2135: [hotfix] [metrics] Prevent log flooding from colli... - posted by asfgit <gi...@git.apache.org> on 2016/07/15 09:59:33 UTC, 0 replies.
- [GitHub] flink pull request #2186: [licenses] Remove not included dependency from LIC... - posted by asfgit <gi...@git.apache.org> on 2016/07/15 10:06:57 UTC, 0 replies.
- [jira] [Closed] (FLINK-4053) Return value from Connection should be checked against null - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/15 10:19:20 UTC, 0 replies.
- [GitHub] flink pull request #2128: [FLINK-4053] Return value from Connection should b... - posted by asfgit <gi...@git.apache.org> on 2016/07/15 10:19:24 UTC, 0 replies.
- [jira] [Closed] (FLINK-4017) [py] Add Aggregation support to Python API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/15 10:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4221) Show metrics in WebFrontend - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/15 10:31:20 UTC, 0 replies.
- [GitHub] flink issue #2251: [FLINK-4212] [scripts] Lock PID file when starting daemon... - posted by StephanEwen <gi...@git.apache.org> on 2016/07/15 11:51:37 UTC, 1 replies.
- [jira] [Closed] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures. - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/15 12:59:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/15 13:01:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4150) Problem with Blobstore in Yarn HA setting on recovery after cluster shutdown - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/15 13:02:20 UTC, 0 replies.
- [GitHub] flink pull request #2256: [FLINK-4150] [runtime] Don't clean up BlobStore on... - posted by uce <gi...@git.apache.org> on 2016/07/15 13:28:26 UTC, 4 replies.
- [jira] [Commented] (FLINK-4150) Problem with Blobstore in Yarn HA setting on recovery after cluster shutdown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/15 13:29:20 UTC, 9 replies.
- [GitHub] flink pull request #2257: [FLINK-4152] Allow re-registration of TMs at resou... - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/15 13:54:56 UTC, 25 replies.
- [jira] [Closed] (FLINK-4184) Ganglia and GraphiteReporter report metric names with invalid characters - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/15 14:08:20 UTC, 0 replies.
- [GitHub] flink issue #2256: [FLINK-4150] [runtime] Don't clean up BlobStore on BlobSe... - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/15 14:14:53 UTC, 4 replies.
- [GitHub] flink pull request #2258: [FLINK-4104] [docs] Restructure Gelly docs - posted by greghogan <gi...@git.apache.org> on 2016/07/15 14:21:44 UTC, 0 replies.
- [jira] [Commented] (FLINK-4104) Restructure Gelly docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/15 14:22:20 UTC, 1 replies.
- [GitHub] flink issue #2258: [FLINK-4104] [docs] Restructure Gelly docs - posted by greghogan <gi...@git.apache.org> on 2016/07/15 14:24:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4186) Expose Kafka metrics through Flink metrics - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/15 14:32:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3204) TaskManagers are not shutting down properly on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/15 14:55:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-3204) TaskManagers are not shutting down properly on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/07/15 14:55:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/15 15:23:20 UTC, 1 replies.
- [jira] [Closed] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/15 15:25:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/15 15:25:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-1267) Add crossGroup operator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/15 15:31:20 UTC, 2 replies.
- [jira] [Closed] (FLINK-4196) Remove "recoveryTimestamp" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/15 15:33:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4196) Remove "recoveryTimestamp" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/15 15:33:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3279) Optionally disable DistinctOperator combiner - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/15 15:49:20 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-3279) Optionally disable DistinctOperator combiner - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/15 15:55:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4201) Checkpoints for jobs in non-terminal state (e.g. suspended) get deleted - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/15 16:21:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4201) Checkpoints for jobs in non-terminal state (e.g. suspended) get deleted - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/15 16:25:20 UTC, 5 replies.
- [GitHub] flink pull request #2259: [hotfix] Fixes broken TopSpeedWindowing scala exam... - posted by kl0u <gi...@git.apache.org> on 2016/07/15 16:53:13 UTC, 4 replies.
- [GitHub] flink issue #2240: [FLINK-4209] Fix issue on docker with multiple NICs and r... - posted by iemejia <gi...@git.apache.org> on 2016/07/15 20:33:47 UTC, 10 replies.
- [jira] [Closed] (FLINK-4208) Support Running Flink processes in foreground mode - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/07/15 20:37:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/07/15 20:38:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata - posted by "Nick Chadwick (JIRA)" <ji...@apache.org> on 2016/07/15 23:41:20 UTC, 0 replies.
- [GitHub] flink pull request #2260: [FLINK-4222] Allow Kinesis configuration to get cr... - posted by chadnickbok <gi...@git.apache.org> on 2016/07/15 23:41:57 UTC, 10 replies.
- [jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/15 23:42:20 UTC, 14 replies.
- [jira] [Created] (FLINK-4223) Rearrange scaladoc and javadoc for Scala API - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/07/16 03:20:20 UTC, 0 replies.
- [GitHub] flink issue #2260: [FLINK-4222] Allow Kinesis configuration to get credentia... - posted by tzulitai <gi...@git.apache.org> on 2016/07/16 07:25:54 UTC, 3 replies.
- [jira] [Closed] (FLINK-3910) New self-join operator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/16 11:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4224) Exception after successful execution when submitting job through the web interface. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/16 15:15:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4224) Exception after successful execution when submitting job through the web interface. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/16 15:16:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-4224) Exception after successful execution os job submitted through the web interface. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/16 15:19:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4225) ML On Streaming Operating in Continuous and Micro Backed Mode - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2016/07/16 15:55:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4226) Typo: Define Keys using Field Expressions example should use window and not reduce - posted by "Ahmad Ragab (JIRA)" <ji...@apache.org> on 2016/07/17 04:37:20 UTC, 0 replies.
- [GitHub] flink pull request #2261: [FLINK-4226] Typo: Define Keys using Field Express... - posted by ASRagab <gi...@git.apache.org> on 2016/07/17 04:50:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-4226) Typo: Define Keys using Field Expressions example should use window and not reduce - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/17 04:50:20 UTC, 5 replies.
- [jira] [Updated] (FLINK-4225) ML On Streaming Operating in Continuous and Micro Backed Mode - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/07/17 10:15:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4225) ML / Graphs On Streaming, Operating in Continuous and Micro Backed Mode - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2016/07/17 14:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4227) Add Heron (heronstreaming.io) comparison to features page - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2016/07/17 16:24:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4227) Add Heron (heronstreaming.io), Apex (http://apex.apache.org/) comparison to features page - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2016/07/17 16:29:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/18 09:04:20 UTC, 10 replies.
- [GitHub] flink pull request #2262: [ITCase] Session windowing - posted by StefanRRichter <gi...@git.apache.org> on 2016/07/18 09:05:28 UTC, 1 replies.
- [GitHub] flink issue #2149: [FLINK-4084] Add configDir parameter to CliFrontend and f... - posted by mxm <gi...@git.apache.org> on 2016/07/18 09:26:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/18 09:27:20 UTC, 9 replies.
- [GitHub] flink issue #2257: [FLINK-4152] Allow re-registration of TMs at resource man... - posted by mxm <gi...@git.apache.org> on 2016/07/18 10:11:44 UTC, 20 replies.
- [jira] [Commented] (FLINK-4166) Generate automatic different namespaces in Zookeeper for Flink applications - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/18 12:04:20 UTC, 11 replies.
- [jira] [Resolved] (FLINK-4149) Fix Serialization of NFA in AbstractKeyedCEPPatternOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/18 12:09:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4162) Event-Time CEP Job Fails after Restart - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/18 12:11:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4165) Event-Time CEP Job Sometimes Fails After Restart - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/18 12:11:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4169) CEP Does Not Work with RocksDB StateBackend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/18 12:13:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4199) Wrong client behavior when submitting job to non-existing cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/18 12:14:20 UTC, 0 replies.
- [GitHub] flink pull request #2060: [FLINK-3921] StringParser encoding - posted by greghogan <gi...@git.apache.org> on 2016/07/18 12:16:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/18 12:16:20 UTC, 1 replies.
- [GitHub] flink pull request #2240: [FLINK-4209] Fix issue on docker with multiple NIC... - posted by iemejia <gi...@git.apache.org> on 2016/07/18 13:12:02 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/18 13:12:20 UTC, 0 replies.
- [GitHub] flink issue #2060: [FLINK-3921] StringParser encoding - posted by greghogan <gi...@git.apache.org> on 2016/07/18 13:15:16 UTC, 0 replies.
- [GitHub] flink issue #2259: [hotfix] Fixes broken TopSpeedWindowing scala example - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/18 14:26:36 UTC, 2 replies.
- [jira] [Created] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/18 14:37:20 UTC, 0 replies.
- [GitHub] flink issue #2245: [hotfix] Fix Redis Sink to fail at opening if Redis is no... - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/18 14:39:25 UTC, 5 replies.
- [jira] [Updated] (FLINK-4199) Misleading messages by CLI upon job submission - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/18 15:04:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/18 15:06:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4199) Misleading messages by CLI upon job submission - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/18 15:06:20 UTC, 3 replies.
- [GitHub] flink pull request #2083: [FLINK-3713] [clients, runtime] Use user code clas... - posted by asfgit <gi...@git.apache.org> on 2016/07/18 15:06:28 UTC, 0 replies.
- [jira] [Created] (FLINK-4229) Do not start Metrics Reporter by default - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/18 15:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4230) Session Windowing IT Case - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/07/18 15:12:20 UTC, 0 replies.
- [GitHub] flink pull request #2263: [FLINK-4230] [DataStreamAPI] Add Session Windowing... - posted by StefanRRichter <gi...@git.apache.org> on 2016/07/18 15:21:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-4230) Session Windowing IT Case - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/18 15:22:20 UTC, 7 replies.
- [GitHub] flink pull request #2264: [FLINK-4199] Fix misleading CLI messages and retur... - posted by mxm <gi...@git.apache.org> on 2016/07/18 15:27:38 UTC, 1 replies.
- [GitHub] flink issue #2216: [FLINK-4173] Use shade-plugin in flink-metrics - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/18 15:31:07 UTC, 1 replies.
- [GitHub] flink pull request #2265: [FLINK-3097] [table] Add support for custom functi... - posted by twalthr <gi...@git.apache.org> on 2016/07/18 15:46:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-3097) Add support for custom functions in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/18 15:47:20 UTC, 7 replies.
- [jira] [Created] (FLINK-4231) Switch DistinctOperator from GroupReduceFunction to ReduceFunction - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/18 15:50:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4231) Switch DistinctOperator from GroupReduce to Reduce - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/18 15:51:20 UTC, 0 replies.
- [GitHub] flink pull request #2266: [FLINK-4229] Do not start any Metrics Reporter by ... - posted by aljoscha <gi...@git.apache.org> on 2016/07/18 15:51:43 UTC, 4 replies.
- [jira] [Commented] (FLINK-4229) Do not start Metrics Reporter by default - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/18 15:52:20 UTC, 18 replies.
- [jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/18 16:01:20 UTC, 4 replies.
- [GitHub] flink pull request #2249: [FLINK-4166] [CLI] Generate different namespaces f... - posted by mxm <gi...@git.apache.org> on 2016/07/18 16:08:43 UTC, 5 replies.
- [GitHub] flink issue #2266: [FLINK-4229] Do not start any Metrics Reporter by default - posted by zentol <gi...@git.apache.org> on 2016/07/18 16:11:41 UTC, 6 replies.
- [GitHub] flink issue #2249: [FLINK-4166] [CLI] Generate different namespaces for Zook... - posted by mxm <gi...@git.apache.org> on 2016/07/18 16:19:21 UTC, 4 replies.
- [GitHub] flink pull request #2267: [FLINK-4205] Create a simple stratified sampling f... - posted by doflink <gi...@git.apache.org> on 2016/07/18 17:08:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-4205) Implement stratified sampling for DataSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/18 17:09:21 UTC, 0 replies.
- [GitHub] flink issue #2265: [FLINK-3097] [table] Add support for custom functions in ... - posted by wuchong <gi...@git.apache.org> on 2016/07/19 01:36:41 UTC, 6 replies.
- [GitHub] flink issue #2221: [FLINK-4183] [table] Move checking for StreamTableEnviron... - posted by twalthr <gi...@git.apache.org> on 2016/07/19 07:47:15 UTC, 1 replies.
- [jira] [Created] (FLINK-4232) Flink executable does not return correct pid - posted by "David Moravek (JIRA)" <ji...@apache.org> on 2016/07/19 08:14:20 UTC, 0 replies.
- [GitHub] flink pull request #2268: [FLINK-4232] Make sure ./bin/flink returns correct... - posted by dmvk <gi...@git.apache.org> on 2016/07/19 08:15:53 UTC, 1 replies.
- [jira] [Commented] (FLINK-4232) Flink executable does not return correct pid - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/19 08:16:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4223) Rearrange scaladoc and javadoc for Scala API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/19 09:24:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4223) Rearrange scaladoc and javadoc for Scala API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/19 09:24:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4232) Flink executable does not return correct pid - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/19 10:25:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2985) Allow different field names for unionAll() in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/19 12:21:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases - posted by "Valentin Denisenkov (JIRA)" <ji...@apache.org> on 2016/07/19 12:32:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4233) Simplify leader election / leader session ID assignment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/19 12:57:20 UTC, 0 replies.
- [GitHub] flink issue #2182: [Flink-4130] CallGenerator could generate illegal code wh... - posted by twalthr <gi...@git.apache.org> on 2016/07/19 12:58:43 UTC, 0 replies.
- [GitHub] flink pull request #2182: [Flink-4130] CallGenerator could generate illegal ... - posted by asfgit <gi...@git.apache.org> on 2016/07/19 13:00:46 UTC, 0 replies.
- [GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten... - posted by mxm <gi...@git.apache.org> on 2016/07/19 13:00:55 UTC, 8 replies.
- [jira] [Resolved] (FLINK-4130) CallGenerator could generate illegal code when taking no operands - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/19 13:03:20 UTC, 0 replies.
- [GitHub] flink pull request #2269: [FLINK-4190] Generalise RollingSink to work with a... - posted by joshfg <gi...@git.apache.org> on 2016/07/19 14:15:44 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3792) RowTypeInfo equality should not depend on field names - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/19 14:38:20 UTC, 0 replies.
- [GitHub] flink issue #2263: [FLINK-4230] [DataStreamAPI] Add Session Windowing ITCase - posted by aljoscha <gi...@git.apache.org> on 2016/07/19 14:38:20 UTC, 5 replies.
- [jira] [Resolved] (FLINK-4183) Move checking for StreamTableEnvironment into validation layer - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/19 14:44:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3153) Support all comparisons for String type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/19 14:51:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3153) Support all comparisons for String type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/19 14:52:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4199) Misleading messages by CLI upon job submission - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/19 16:00:22 UTC, 0 replies.
- [jira] [Closed] (FLINK-4166) Generate automatic different namespaces in Zookeeper for Flink applications - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/19 16:02:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/07/19 16:24:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3674) Add an interface for EventTime aware User Function - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/07/19 17:09:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3695) ValueArray types - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/19 18:24:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/19 18:55:20 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-3042) Define a way to let types create their own TypeInformation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/20 11:52:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3695) ValueArray types - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/20 12:04:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-3753) KillerWatchDog should not use kill on toKill thread - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/20 12:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4234) CassandraConnectorTest causes travis build to time out - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/20 12:16:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3753) KillerWatchDog should not use kill on toKill thread - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/20 12:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4235) ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/20 12:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2016/07/20 12:44:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4070) Support literals on left side of binary expressions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/20 13:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4237) ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails due to Timeout Futures - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/20 13:23:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4237) ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails due to Timeout Futures - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/20 13:24:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4237) ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails due to Timeout Futures - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/20 13:30:20 UTC, 0 replies.
- [GitHub] flink issue #2238: [FLINK-3729] Fix Several SQL tests on Windows OS - posted by twalthr <gi...@git.apache.org> on 2016/07/20 14:13:07 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3729) Several SQL tests fail on Windows OS - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/20 14:33:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4050) FlinkKafkaProducer API Refactor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/20 14:35:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "Joan Goyeau (JIRA)" <ji...@apache.org> on 2016/07/20 14:47:20 UTC, 1 replies.
- [GitHub] flink pull request #2270: [FLINK-3956] Make FileInputFormats independent fro... - posted by kl0u <gi...@git.apache.org> on 2016/07/20 15:10:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-3956) Make FileInputFormats independent from Configuration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/20 15:10:22 UTC, 5 replies.
- [GitHub] flink pull request #2271: [FLINK-4202] Add restarting time JM metric - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/20 15:11:23 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4235) ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/20 15:12:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4237) ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails due to Timeout Futures - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/20 15:13:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4235) ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/20 15:15:20 UTC, 0 replies.
- [GitHub] flink pull request #2272: [FLINK-4231] [java] Switch DistinctOperator from G... - posted by greghogan <gi...@git.apache.org> on 2016/07/20 15:37:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-4231) Switch DistinctOperator from GroupReduce to Reduce - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/20 15:38:20 UTC, 0 replies.
- [GitHub] flink issue #2270: [FLINK-3956] Make FileInputFormats independent from Confi... - posted by aljoscha <gi...@git.apache.org> on 2016/07/20 15:42:57 UTC, 3 replies.
- [jira] [Resolved] (FLINK-3956) Make FileInputFormats independent from Configuration - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/20 16:04:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4229) Do not start Metrics Reporter by default - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/20 16:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4238) Only allow/require query for Tuple Stream in CassandraSink - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/20 16:10:21 UTC, 0 replies.
- [GitHub] flink pull request #2273: [FLINK-4238] Only allow/require query for Tuple St... - posted by aljoscha <gi...@git.apache.org> on 2016/07/20 16:11:19 UTC, 1 replies.
- [jira] [Commented] (FLINK-4238) Only allow/require query for Tuple Stream in CassandraSink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/20 16:11:21 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4224) Exception after successful execution os job submitted through the web interface. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/20 16:12:20 UTC, 0 replies.
- [GitHub] flink pull request #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL an... - posted by wuchong <gi...@git.apache.org> on 2016/07/20 16:37:38 UTC, 4 replies.
- [jira] [Commented] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/20 16:39:20 UTC, 0 replies.
- [GitHub] flink issue #2273: [FLINK-4238] Only allow/require query for Tuple Stream in... - posted by zentol <gi...@git.apache.org> on 2016/07/20 19:50:07 UTC, 1 replies.
- [GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit... - posted by vijikarthi <gi...@git.apache.org> on 2016/07/21 00:35:03 UTC, 56 replies.
- [jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/21 00:35:20 UTC, 63 replies.
- [jira] [Resolved] (FLINK-4230) Session Windowing IT Case - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/21 08:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4239) Set Default Allowed Lateness to Zero and Make Triggers Non-Purging - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/21 08:23:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4203) Improve Table API documentation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/21 08:29:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2016/07/21 08:43:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/21 08:49:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4235) ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/21 11:53:20 UTC, 0 replies.
- [GitHub] flink pull request #2276: [FLINK-4201] [runtime] Forward suspend to checkpoi... - posted by uce <gi...@git.apache.org> on 2016/07/21 12:02:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-4239) Set Default Allowed Lateness to Zero and Make Triggers Non-Purging - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 12:41:20 UTC, 19 replies.
- [GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta... - posted by StephanEwen <gi...@git.apache.org> on 2016/07/21 12:45:42 UTC, 6 replies.
- [GitHub] flink pull request #2277: [FLINK-4207] WindowOperator becomes very slow with... - posted by kl0u <gi...@git.apache.org> on 2016/07/21 13:08:16 UTC, 4 replies.
- [GitHub] flink pull request #2278: [FLINK-4239] Set Default Allowed Lateness to Zero ... - posted by aljoscha <gi...@git.apache.org> on 2016/07/21 13:11:56 UTC, 11 replies.
- [jira] [Created] (FLINK-4240) Cannot use expressions in Scala Table API's groupBy method - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 13:23:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4238) Only allow/require query for Tuple Stream in CassandraSink - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/21 13:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4241) Cryptic expression parser exceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 13:30:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4241) Cryptic expression parser exceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 13:32:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 13:33:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 13:33:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 13:34:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4202) Add JM metric which shows the restart duration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/21 13:39:21 UTC, 10 replies.
- [jira] [Created] (FLINK-4242) Improve validation exception messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 13:42:20 UTC, 0 replies.
- [GitHub] flink issue #2271: [FLINK-4202] Add restarting time JM metric - posted by uce <gi...@git.apache.org> on 2016/07/21 13:49:30 UTC, 4 replies.
- [GitHub] flink issue #2276: [FLINK-4201] [runtime] Forward suspend to checkpoint coor... - posted by StephanEwen <gi...@git.apache.org> on 2016/07/21 13:50:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 13:55:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 13:56:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 13:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4243) Change "Scope" to "Namespace" for Metrics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 13:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4244) Field names for union operator do not have to be equal - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 14:06:20 UTC, 0 replies.
- [GitHub] flink issue #2269: [FLINK-4190] Generalise RollingSink to work with arbitrar... - posted by aljoscha <gi...@git.apache.org> on 2016/07/21 14:22:11 UTC, 7 replies.
- [jira] [Closed] (FLINK-4202) Add JM metric which shows the restart duration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 14:22:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4245) Metric naming improvements - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 14:24:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4245) Metric naming improvements - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 14:26:20 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4245) Metric naming improvements - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 14:27:20 UTC, 1 replies.
- [GitHub] flink pull request #2279: [FLINK-4229] Only start JMX server when port is sp... - posted by aljoscha <gi...@git.apache.org> on 2016/07/21 14:46:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-4240) Cannot use expressions in Scala Table API's groupBy method - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/21 14:51:20 UTC, 1 replies.
- [GitHub] flink issue #2279: [FLINK-4229] Only start JMX server when port is specified - posted by StephanEwen <gi...@git.apache.org> on 2016/07/21 15:02:34 UTC, 2 replies.
- [jira] [Commented] (FLINK-4244) Field names for union operator do not have to be equal - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/21 15:03:21 UTC, 3 replies.
- [jira] [Created] (FLINK-4246) Allow Specifying Multiple Metrics Reporters - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/21 15:05:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4246) Allow Specifying Multiple Metrics Reporters - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/21 15:10:21 UTC, 49 replies.
- [jira] [Assigned] (FLINK-4244) Field names for union operator do not have to be equal - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/21 15:26:20 UTC, 0 replies.
- [GitHub] flink pull request #2280: [FLINK-4244] [docs] Field names for union operator... - posted by wuchong <gi...@git.apache.org> on 2016/07/21 15:30:33 UTC, 1 replies.
- [jira] [Created] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 15:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4249) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 15:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 15:44:20 UTC, 0 replies.
- [GitHub] flink issue #2051: [FLINK-3779] Add support for queryable state - posted by soniclavier <gi...@git.apache.org> on 2016/07/21 15:51:51 UTC, 10 replies.
- [jira] [Commented] (FLINK-3779) Add support for queryable state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/21 15:52:20 UTC, 10 replies.
- [jira] [Commented] (FLINK-4243) Change "Scope" to "Namespace" for Metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/21 16:23:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4250) Cannot select column from CsvTableSource - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 17:21:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4250) Cannot select column from CsvTableSource - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 17:26:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4250) Cannot select other than first column from Table - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/21 17:28:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4250) Cannot select other than first column from Table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/21 18:27:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue - posted by "Philipp Grulich (JIRA)" <ji...@apache.org> on 2016/07/21 20:35:20 UTC, 0 replies.
- [GitHub] flink pull request #2281: RMQ Sink: Possibility to customize queue config [F... - posted by PhilippGrulich <gi...@git.apache.org> on 2016/07/21 20:44:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/21 20:45:21 UTC, 4 replies.
- [jira] [Updated] (FLINK-4245) Metric naming improvements - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/21 21:51:20 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4202) Add JM metric which shows the restart duration - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/21 22:01:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4175) Broadcast data sent increases with # slots per TM - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2016/07/21 22:36:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3940) Add support for ORDER BY OFFSET FETCH - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2016/07/22 01:52:20 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4250) Cannot select other than first column from Table - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/22 02:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4252) Table program cannot be compiled - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/07/22 03:02:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4252) Table program cannot be compiled - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/07/22 03:02:20 UTC, 1 replies.
- [GitHub] flink pull request #2282: Support order by with offset and fetch. - posted by gallenvara <gi...@git.apache.org> on 2016/07/22 03:48:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-4252) Table program cannot be compiled - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/22 06:35:20 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-4252) Table program cannot be compiled - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/22 06:36:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open() - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/22 06:45:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open() - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/22 06:45:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open() - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/22 06:45:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/22 06:45:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/22 06:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4253) Rename "recovery.mode" config key to "high-availability" - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/22 09:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4254) Add file system based high-availability mode - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/22 09:37:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4229) Do not start Metrics Reporter by default - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/22 10:10:20 UTC, 0 replies.
- [GitHub] flink pull request #2283: [FLINK-3901] [table] Create a RowCsvInputFormat fo... - posted by twalthr <gi...@git.apache.org> on 2016/07/22 10:12:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-4240) Cannot use expressions in Scala Table API's groupBy method - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/22 10:18:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4246) Allow Specifying Multiple Metrics Reporters - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/22 10:21:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4249) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/22 10:21:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4249) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/22 10:23:20 UTC, 0 replies.
- [GitHub] flink pull request #1989: FLINK-3901 - Added CsvRowInputFormat - posted by fpompermaier <gi...@git.apache.org> on 2016/07/22 10:26:24 UTC, 0 replies.
- [GitHub] flink pull request #2284: [FLINK-4202] [metrics] Update restarting time metr... - posted by tillrohrmann <gi...@git.apache.org> on 2016/07/22 10:43:11 UTC, 1 replies.
- [GitHub] flink issue #2284: [FLINK-4202] [metrics] Update restarting time metric docu... - posted by zentol <gi...@git.apache.org> on 2016/07/22 10:58:16 UTC, 1 replies.
- [jira] [Closed] (FLINK-4201) Checkpoints for jobs in non-terminal state (e.g. suspended) get deleted - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/22 12:28:21 UTC, 0 replies.
- [GitHub] flink issue #2281: RMQ Sink: Possibility to customize queue config [FLINK-42... - posted by kkamkou <gi...@git.apache.org> on 2016/07/22 13:08:56 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3940) Add support for ORDER BY OFFSET FETCH - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2016/07/22 13:15:20 UTC, 0 replies.
- [GitHub] flink pull request #2285: [FLINK-4246] Allow Specifying Multiple Metrics Rep... - posted by aljoscha <gi...@git.apache.org> on 2016/07/22 13:28:09 UTC, 35 replies.
- [GitHub] flink pull request #2286: [FLINK-4210][metrics] Move close()/isClosed() out ... - posted by zentol <gi...@git.apache.org> on 2016/07/22 13:30:55 UTC, 2 replies.
- [jira] [Updated] (FLINK-4255) Unstable test WebRuntimeMonitorITCase.testNoEscape - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/22 14:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4255) Unstable test WebRuntimeMonitorITCase.testNoEscape - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/22 14:05:20 UTC, 0 replies.
- [GitHub] flink issue #2285: [FLINK-4246] Allow Specifying Multiple Metrics Reporters - posted by zentol <gi...@git.apache.org> on 2016/07/22 14:24:34 UTC, 12 replies.
- [jira] [Commented] (FLINK-4203) Improve Table API documentation - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/22 15:27:20 UTC, 1 replies.
- [GitHub] flink pull request #2282: [FLINK-3940] [table] Add support for ORDER BY OFFS... - posted by wuchong <gi...@git.apache.org> on 2016/07/22 15:36:13 UTC, 1 replies.
- [GitHub] flink pull request #2287: [hotfix] Prevent CheckpointCommitter from failing ... - posted by zentol <gi...@git.apache.org> on 2016/07/22 16:06:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-3725) Exception in thread "main" scala.MatchError: ... (of class scala.Tuple4) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/22 16:24:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-3725) Exception in thread "main" scala.MatchError: ... (of class scala.Tuple4) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/22 16:33:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3725) Exception in thread "main" scala.MatchError: ... (of class scala.Tuple4) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/22 16:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4256) Fine-grained recovery - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/22 16:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4257) Handle delegating algorithm change of class - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/22 17:28:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/07/22 17:43:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/07/22 17:43:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/07/22 17:49:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3298) Streaming connector for ActiveMQ - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/07/22 17:49:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4217) Gelly drivers should read CSV values as strings - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/22 18:41:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4213) Provide CombineHint in Gelly algorithms - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/22 18:41:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3006) TypeExtractor fails on custom type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/22 18:56:20 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (FLINK-4245) Metric naming improvements - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/22 18:58:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-2227) .yarn-properties file is not cleaned up - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/22 19:47:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-3411) Failed recovery can lead to removal of HA state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/22 19:49:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-2929) Recovery of jobs on cluster restarts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/22 19:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4258) Potential null pointer dereference in SavepointCoordinator#onFullyAcknowledgedCheckpoint - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/07/22 20:09:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/07/22 20:22:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3480) Add hash-based strategy for ReduceFunction - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/22 20:44:20 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-3480) Add hash-based strategy for ReduceFunction - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/23 02:09:20 UTC, 0 replies.
- [GitHub] flink pull request #2288: Feature/s3 a fix - posted by cresny <gi...@git.apache.org> on 2016/07/23 03:09:02 UTC, 0 replies.
- [GitHub] flink issue #2282: [FLINK-3940] [table] Add support for ORDER BY OFFSET FETC... - posted by gallenvara <gi...@git.apache.org> on 2016/07/23 07:46:17 UTC, 0 replies.
- [GitHub] flink pull request #2289: [FLINK-3866] StringArraySerializer type should be ... - posted by mushketyk <gi...@git.apache.org> on 2016/07/23 12:09:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-4242) Improve validation exception messages - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2016/07/23 16:06:20 UTC, 2 replies.
- [GitHub] flink pull request #2290: [FLINK-4242] [table] Improve validation exception ... - posted by gallenvara <gi...@git.apache.org> on 2016/07/23 16:07:42 UTC, 0 replies.
- [GitHub] flink issue #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL and Strea... - posted by wuchong <gi...@git.apache.org> on 2016/07/24 08:21:26 UTC, 1 replies.
- [GitHub] flink pull request #2291: FLINK-4226: Define Keys using Field Expressions ex... - posted by nssalian <gi...@git.apache.org> on 2016/07/24 23:05:47 UTC, 0 replies.
- [GitHub] flink issue #2291: [FLINK-4226] Typo: Define Keys using Field Expressions ex... - posted by gallenvara <gi...@git.apache.org> on 2016/07/25 02:45:13 UTC, 1 replies.
- [GitHub] flink pull request #2291: [FLINK-4226] Typo: Define Keys using Field Express... - posted by nssalian <gi...@git.apache.org> on 2016/07/25 03:10:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-2042) Increase font size for stack figure on website home - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/07/25 03:12:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-992) Create CollectionDataSets by reading (client) local files. - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/07/25 03:13:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4047) Fix documentation about determinism of KeySelectors - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/07/25 04:48:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect() - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/07/25 04:48:20 UTC, 1 replies.
- [GitHub] flink pull request #2292: [FLINK-3891] [table] Add a class containing all su... - posted by twalthr <gi...@git.apache.org> on 2016/07/25 08:51:27 UTC, 3 replies.
- [jira] [Commented] (FLINK-3891) Add a class containing all supported Table API types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/25 08:52:20 UTC, 4 replies.
- [GitHub] flink issue #2278: [FLINK-4239] Set Default Allowed Lateness to Zero and Mak... - posted by uce <gi...@git.apache.org> on 2016/07/25 09:40:51 UTC, 6 replies.
- [GitHub] flink issue #2277: [FLINK-4207] WindowOperator becomes very slow with allowe... - posted by uce <gi...@git.apache.org> on 2016/07/25 09:41:11 UTC, 4 replies.
- [GitHub] flink issue #2287: [hotfix] Prevent CheckpointCommitter from failing job - posted by aljoscha <gi...@git.apache.org> on 2016/07/25 11:34:41 UTC, 6 replies.
- [jira] [Created] (FLINK-4260) Allow SQL's LIKE ESCAPE - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 12:02:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4260) Allow SQL's LIKE ESCAPE - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 12:02:20 UTC, 3 replies.
- [jira] [Updated] (FLINK-4174) Enhance Window Evictor - posted by "vishnu viswanath (JIRA)" <ji...@apache.org> on 2016/07/25 12:03:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4260) Allow SQL's LIKE ESCAPE - posted by "miaoever (JIRA)" <ji...@apache.org> on 2016/07/25 12:50:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4256) Fine-grained recovery - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/07/25 13:08:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4260) Allow SQL's LIKE ESCAPE - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 13:09:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4257) Handle delegating algorithm change of class - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/25 13:11:20 UTC, 0 replies.
- [GitHub] flink issue #2283: [FLINK-3901] [table] Create a RowCsvInputFormat for Table... - posted by twalthr <gi...@git.apache.org> on 2016/07/25 13:14:16 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4256) Fine-grained recovery - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/07/25 13:14:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4150) Problem with Blobstore in Yarn HA setting on recovery after cluster shutdown - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/25 13:22:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3901) Create a RowCsvInputFormat to use as default CSV IF in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 13:28:20 UTC, 0 replies.
- [GitHub] flink issue #2292: [FLINK-3891] [table] Add a class containing all supported... - posted by twalthr <gi...@git.apache.org> on 2016/07/25 13:29:32 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3891) Add a class containing all supported Table API types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 13:35:20 UTC, 0 replies.
- [GitHub] flink issue #2280: [FLINK-4244] [docs] Field names for union operator do not... - posted by twalthr <gi...@git.apache.org> on 2016/07/25 13:44:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4244) Field names for union operator do not have to be equal - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 13:50:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4261) Setup atomic deployment of snapshots - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/25 14:11:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 14:11:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4261) Setup atomic deployment of snapshots - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/25 14:11:20 UTC, 0 replies.
- [GitHub] flink pull request #2123: [FLINK-3904] GlobalConfiguration doesn't ensure co... - posted by uce <gi...@git.apache.org> on 2016/07/25 14:21:07 UTC, 7 replies.
- [jira] [Created] (FLINK-4262) Consider null handling during sorting - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 14:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4263) SQL's VALUES does not work properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 14:47:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4263) SQL's VALUES does not work properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/25 14:47:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4264) New GraphMetrics driver - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/25 15:01:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-2125) String delimiter for SocketTextStream - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/25 15:40:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3932) Implement State Backend Security - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/07/25 16:25:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0 - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/07/25 16:28:20 UTC, 0 replies.
- [GitHub] flink pull request #2293: [FLINK-4203] [table] [docs] Improve Table API docu... - posted by twalthr <gi...@git.apache.org> on 2016/07/25 16:28:41 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3930) Implement Service-Level Authorization - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/07/25 16:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4265) Add a NoOpOperator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/25 17:53:20 UTC, 0 replies.
- [GitHub] flink pull request #2294: [FLINK-4265] [dataset api] Add a NoOpOperator - posted by greghogan <gi...@git.apache.org> on 2016/07/25 18:10:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-4265) Add a NoOpOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/25 18:11:20 UTC, 2 replies.
- [GitHub] flink issue #2294: [FLINK-4265] [dataset api] Add a NoOpOperator - posted by greghogan <gi...@git.apache.org> on 2016/07/25 18:11:22 UTC, 1 replies.
- [jira] [Commented] (FLINK-2237) Add hash-based Aggregation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/07/25 18:37:20 UTC, 3 replies.
- [GitHub] flink pull request #2295: [FLINK-4264] [gelly] New GraphMetrics driver - posted by greghogan <gi...@git.apache.org> on 2016/07/25 20:22:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-4264) New GraphMetrics driver - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/25 20:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4266) Cassandra Statebackend - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2016/07/25 20:23:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy() - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/07/25 20:26:20 UTC, 11 replies.
- [GitHub] flink issue #1220: [FLINK-1745] Add exact k-nearest-neighbours algorithm to ... - posted by thvasilo <gi...@git.apache.org> on 2016/07/26 06:20:30 UTC, 2 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/07/26 06:21:20 UTC, 2 replies.
- [GitHub] flink issue #2162: FLINK-4103: Modify CsvTableSource to implement StreamTabl... - posted by twalthr <gi...@git.apache.org> on 2016/07/26 06:40:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-4103) Modify CsvTableSource to implement StreamTableSource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/26 06:41:20 UTC, 1 replies.
- [GitHub] flink pull request #2162: FLINK-4103: Modify CsvTableSource to implement Str... - posted by asfgit <gi...@git.apache.org> on 2016/07/26 09:12:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4103) Modify CsvTableSource to implement StreamTableSource - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/26 09:14:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4081) FieldParsers should support empty strings - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/26 09:20:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4067) Add version header to savepoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/26 09:32:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4239) Set Default Allowed Lateness to Zero and Make Triggers Non-Purging - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/26 09:34:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/26 09:45:20 UTC, 1 replies.
- [GitHub] flink issue #2286: [FLINK-4210][metrics] Move close()/isClosed() out of Metr... - posted by uce <gi...@git.apache.org> on 2016/07/26 09:47:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/26 09:51:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4227) Add Heron (heronstreaming.io), Apex (http://apex.apache.org/) comparison to features page - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/26 10:13:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4192) Move Metrics API to separate module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/26 10:32:20 UTC, 0 replies.
- [GitHub] flink pull request #2296: [FLINK-4261][tools] retry in case of failed snapsh... - posted by mxm <gi...@git.apache.org> on 2016/07/26 14:05:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-4261) Setup atomic deployment of snapshots - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/26 14:05:20 UTC, 2 replies.
- [jira] [Closed] (FLINK-4152) TaskManager registration exponential backoff doesn't work - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/26 14:45:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4261) Setup atomic deployment of snapshots - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/26 14:51:20 UTC, 0 replies.
- [GitHub] flink pull request #2297: [FLINK-4081] [core] [table] FieldParsers should su... - posted by twalthr <gi...@git.apache.org> on 2016/07/26 14:51:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-4081) FieldParsers should support empty strings - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/26 14:52:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/26 15:02:20 UTC, 4 replies.
- [GitHub] flink pull request #2298: [FLINK-4247] [table] CsvTableSource.getDataSet() e... - posted by twalthr <gi...@git.apache.org> on 2016/07/26 15:30:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4263) SQL's VALUES does not work properly - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/26 15:32:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/26 15:32:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4125) Yarn CLI incorrectly calculates slotsPerTM when parallelism < task manager count - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/26 16:14:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4125) Yarn CLI incorrectly calculates slotsPerTM when parallelism < task manager count - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/26 16:16:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/26 16:19:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4258) Potential null pointer dereference in SavepointCoordinator#onFullyAcknowledgedCheckpoint - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/26 16:41:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/07/26 17:04:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue - posted by "Philipp Grulich (JIRA)" <ji...@apache.org> on 2016/07/26 17:59:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4207) WindowOperator becomes very slow with allowed lateness - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/07/26 21:59:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy() - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/07/26 22:33:22 UTC, 0 replies.
- [GitHub] flink pull request #2299: [FLINK-4259]: Unclosed FSDataOutputStream in FileC... - posted by nssalian <gi...@git.apache.org> on 2016/07/26 22:53:02 UTC, 1 replies.
- [GitHub] flink issue #2299: [FLINK-4259]: Unclosed FSDataOutputStream in FileCache#co... - posted by mbalassi <gi...@git.apache.org> on 2016/07/26 23:15:44 UTC, 8 replies.
- [jira] [Created] (FLINK-4267) Adding async I/O flat map - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/27 02:26:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4267) Adding async I/O flat map - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/07/27 02:26:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/27 07:23:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/27 07:23:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/27 07:24:20 UTC, 1 replies.
- [jira] [Closed] (FLINK-3006) TypeExtractor fails on custom type - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/07/27 08:02:20 UTC, 0 replies.
- [GitHub] flink pull request #2300: [FLINK-4245] Expose all possible variables - posted by zentol <gi...@git.apache.org> on 2016/07/27 09:41:08 UTC, 0 replies.
- [GitHub] flink issue #2298: [FLINK-4247] [table] CsvTableSource.getDataSet() expects ... - posted by zentol <gi...@git.apache.org> on 2016/07/27 09:47:44 UTC, 1 replies.
- [GitHub] flink pull request #2301: FLINK-3674 Add an interface for EventTime aware Us... - posted by ramkrish86 <gi...@git.apache.org> on 2016/07/27 10:28:50 UTC, 9 replies.
- [GitHub] flink issue #2301: FLINK-3674 Add an interface for EventTime aware User Func... - posted by ramkrish86 <gi...@git.apache.org> on 2016/07/27 10:33:24 UTC, 3 replies.
- [GitHub] flink issue #2290: [FLINK-4242] [table] Improve validation exception message... - posted by gallenvara <gi...@git.apache.org> on 2016/07/27 11:22:28 UTC, 0 replies.
- [GitHub] flink pull request #2302: [hotfix] [metrics] Refactor constructors and tests - posted by zentol <gi...@git.apache.org> on 2016/07/27 11:26:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/07/27 12:04:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/07/27 12:04:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/27 12:48:20 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/27 12:48:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/07/27 12:51:20 UTC, 0 replies.
- [GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no... - posted by twalthr <gi...@git.apache.org> on 2016/07/27 13:04:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-4268) Add a parsers for BigDecimal/BigInteger - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/27 13:13:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4268) Add a parsers for BigDecimals/BigInteger - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/27 13:13:20 UTC, 0 replies.
- [GitHub] flink pull request #2304: [FLINK-4268] [core] Add parsers for BigDecimal/Big... - posted by twalthr <gi...@git.apache.org> on 2016/07/27 13:52:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-4268) Add a parsers for BigDecimal/BigInteger - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/27 13:53:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4250) Cannot select other than first column from Table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/27 14:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4269) Decrease log level in RuntimeMonitorHandler - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/07/27 14:28:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-3904) GlobalConfiguration doesn't ensure config has been loaded - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/27 14:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4270) 'as' in front of join does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/27 15:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4271) There is no way to set parallelism of operators such as map and window produced by - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/07/28 02:13:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/07/28 02:14:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4269) Decrease log level in RuntimeMonitorHandler - posted by "Aditi Viswanathan (JIRA)" <ji...@apache.org> on 2016/07/28 04:00:23 UTC, 7 replies.
- [GitHub] flink issue #2303: [FLINK-4248] [core] [table] CsvTableSource does not suppo... - posted by gallenvara <gi...@git.apache.org> on 2016/07/28 05:52:55 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/28 06:09:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/28 06:15:20 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/28 06:18:20 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4179) Update TPCHQuery3Table example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/28 08:00:34 UTC, 0 replies.
- [GitHub] flink pull request #2305: [FLINK-4271] [DataStreamAPI] Enable CoGroupedStrea... - posted by wuchong <gi...@git.apache.org> on 2016/07/28 08:05:33 UTC, 0 replies.
- [GitHub] flink issue #1690: FLINK-3398: Allow for opting-out from Kafka offset auto-c... - posted by tzulitai <gi...@git.apache.org> on 2016/07/28 08:54:24 UTC, 5 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/07/28 08:55:20 UTC, 13 replies.
- [jira] [Assigned] (FLINK-4270) 'as' in front of join does not work - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/07/28 09:36:20 UTC, 0 replies.
- [GitHub] flink pull request #2306: [FLINK-4270] [table] fix 'as' in front of join doe... - posted by wuchong <gi...@git.apache.org> on 2016/07/28 09:48:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-4270) 'as' in front of join does not work - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/28 09:48:20 UTC, 0 replies.
- [GitHub] flink issue #2305: [FLINK-4271] [DataStreamAPI] Enable CoGroupedStreams and ... - posted by wuchong <gi...@git.apache.org> on 2016/07/28 09:59:26 UTC, 0 replies.
- [jira] [Created] (FLINK-4272) Create a JobClient for job control and monitoring - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/28 10:07:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4272) Create a JobClient for job control and monitoring - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/28 10:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/28 10:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4274) Expose new JobClient in the DataSet/DataStream API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/28 10:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/07/28 11:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/28 13:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4277) TaskManagerConfigurationTest fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/28 13:45:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4266) Cassandra StateBackend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/28 13:53:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/07/28 14:48:20 UTC, 2 replies.
- [jira] [Closed] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy() - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/07/28 17:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/07/28 19:24:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/07/28 19:25:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4094) Off heap memory deallocation might not properly work - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/07/29 02:06:20 UTC, 0 replies.
- [GitHub] flink pull request #1690: FLINK-3398: Allow for opting-out from Kafka offset... - posted by shikhar <gi...@git.apache.org> on 2016/07/29 04:19:14 UTC, 0 replies.
- [GitHub] flink pull request #2307: [FLINK-4269] Decrease log level in RuntimeMonitorH... - posted by aditivin <gi...@git.apache.org> on 2016/07/29 05:20:40 UTC, 1 replies.
- [GitHub] flink issue #2307: [FLINK-4269] Decrease log level in RuntimeMonitorHandler - posted by nssalian <gi...@git.apache.org> on 2016/07/29 05:40:01 UTC, 4 replies.
- [jira] [Closed] (FLINK-3714) Add Support for "Allowed Lateness" - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/29 08:36:20 UTC, 1 replies.
- [jira] [Reopened] (FLINK-3714) Add Support for "Allowed Lateness" - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/29 08:36:20 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-3714) Add Support for "Allowed Lateness" - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/29 08:37:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4094) Off heap memory deallocation might not properly work - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/07/29 09:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4279) [py] Set flink dependencies to provided - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 09:37:20 UTC, 0 replies.
- [GitHub] flink pull request #2308: [FLINK-4279] [py] Set flink dependencies to provid... - posted by zentol <gi...@git.apache.org> on 2016/07/29 09:40:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/29 09:41:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4279) [py] Set flink dependencies to provided - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/29 09:41:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/29 09:45:20 UTC, 2 replies.
- [GitHub] flink pull request #2309: [FLINK-4161] Add Quickstart exclusion for flink-di... - posted by zentol <gi...@git.apache.org> on 2016/07/29 09:54:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/29 10:03:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/29 10:05:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/07/29 10:06:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4277) TaskManagerConfigurationTest fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 10:11:20 UTC, 0 replies.
- [GitHub] flink pull request #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#test... - posted by zentol <gi...@git.apache.org> on 2016/07/29 10:20:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-4277) TaskManagerConfigurationTest fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/29 10:21:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4282) Add Offset Parameter to WindowAssigners - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/29 10:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4283) ExecutionGraphRestartTest fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 11:28:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4284) DataSet/CEP link to non-existant "Linking with Flink" section - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 11:52:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4284) DataSet/CEP link to non-existant "Linking with Flink" section - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 11:54:20 UTC, 0 replies.
- [GitHub] flink issue #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#testDefault... - posted by mxm <gi...@git.apache.org> on 2016/07/29 12:07:03 UTC, 2 replies.
- [GitHub] flink pull request #2311: [FLINK-4284] [docu] Fix broken links - posted by zentol <gi...@git.apache.org> on 2016/07/29 12:09:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-4284) DataSet/CEP link to non-existant "Linking with Flink" section - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/29 12:10:20 UTC, 3 replies.
- [jira] [Closed] (FLINK-4269) Decrease log level in RuntimeMonitorHandler - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 12:30:20 UTC, 0 replies.
- [GitHub] flink pull request #2312: [FLINK-4276] Fix TextInputFormatTest#testNestedFil... - posted by zentol <gi...@git.apache.org> on 2016/07/29 12:52:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/29 12:53:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 12:53:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4255) Unstable test WebRuntimeMonitorITCase.testNoEscape - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 13:05:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4283) ExecutionGraphRestartTest fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 13:10:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4277) TaskManagerConfigurationTest fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 13:11:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/29 13:11:20 UTC, 0 replies.
- [GitHub] flink issue #2311: [FLINK-4284] [docu] Fix broken links - posted by StephanEwen <gi...@git.apache.org> on 2016/07/29 14:43:59 UTC, 2 replies.
- [GitHub] flink issue #2309: [FLINK-4161] Add Quickstart exclusion for flink-dist depe... - posted by StephanEwen <gi...@git.apache.org> on 2016/07/29 14:46:12 UTC, 1 replies.
- [GitHub] flink issue #2308: [FLINK-4279] [py] Set flink dependencies to provided - posted by StephanEwen <gi...@git.apache.org> on 2016/07/29 14:48:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/29 15:18:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/29 15:18:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/29 15:46:20 UTC, 5 replies.
- [jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/07/29 15:49:20 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/29 16:46:20 UTC, 8 replies.
- [GitHub] flink pull request #2313: [FLINK-4273] Modify JobClient to attach to running... - posted by mxm <gi...@git.apache.org> on 2016/07/29 16:51:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/29 16:51:20 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/29 16:55:20 UTC, 4 replies.
- [jira] [Commented] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/30 08:10:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/30 08:15:20 UTC, 0 replies.
- [GitHub] flink pull request #2314: [FLINK-3298] Implement ActiveMQ streaming connecto... - posted by mushketyk <gi...@git.apache.org> on 2016/07/31 17:33:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/07/31 21:49:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/07/31 21:49:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/07/31 21:57:20 UTC, 0 replies.