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

---

- [jira] [Commented] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions - posted by "Mike Dias (JIRA)" <ji...@apache.org> on 2017/09/01 00:59:02 UTC, 8 replies.
- [GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ... - posted by lincoln-lil <gi...@git.apache.org> on 2017/09/01 03:17:42 UTC, 34 replies.
- [jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 03:18:00 UTC, 37 replies.
- [GitHub] flink pull request #4586: [FLINK-7502] [metrics] Improve PrometheusReporter - posted by mbode <gi...@git.apache.org> on 2017/09/01 05:54:15 UTC, 0 replies.
- [jira] [Commented] (FLINK-7502) PrometheusReporter improvements - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 05:55:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-7566) if there's only one checkpointing metadata file in , `flink run -s ` should successfully resume from that metadata file - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/01 06:18:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-7566) if there's only one checkpointing metadata file in , `flink run -s ` should successfully resume from that metadata file - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/01 06:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7223) Increase DEFAULT_SHARD_DISCOVERY_INTERVAL_MILLIS for Flink-kinesis-connector - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/01 07:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/09/01 07:18:00 UTC, 58 replies.
- [GitHub] flink pull request #4633: [FLINK-7564] [table] Fix Watermark semantics in Ro... - posted by xccui <gi...@git.apache.org> on 2017/09/01 08:20:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-7564) Fix Watermark semantics in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 08:21:00 UTC, 6 replies.
- [GitHub] flink issue #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / Use in ... - posted by aljoscha <gi...@git.apache.org> on 2017/09/01 08:38:13 UTC, 4 replies.
- [jira] [Commented] (FLINK-7552) Extend SinkFunction interface with SinkContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 08:39:00 UTC, 16 replies.
- [GitHub] flink issue #4422: [FLINK-7299][AVRO] Write GenericRecord using AvroOutputFo... - posted by aljoscha <gi...@git.apache.org> on 2017/09/01 08:51:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-7299) Write GenericRecord using AvroOutputFormat - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 08:52:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-7299) Write GenericRecord using AvroOutputFormat - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/01 08:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7422) Upgrade Kinesis Client Library (KCL) and AWS SDK in flink-connector-kinesis - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/01 09:01:00 UTC, 0 replies.
- [GitHub] flink issue #4627: [FLINK-7422][kinesis] Upgrade Kinesis Client Library (KCL... - posted by aljoscha <gi...@git.apache.org> on 2017/09/01 09:01:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-7422) Upgrade Kinesis Client Library (KCL) and AWS SDK in flink-connector-kinesis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 09:02:00 UTC, 1 replies.
- [GitHub] flink pull request #4422: [FLINK-7299][AVRO] Write GenericRecord using AvroO... - posted by soniclavier <gi...@git.apache.org> on 2017/09/01 09:02:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/09/01 09:33:00 UTC, 122 replies.
- [jira] [Created] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work - posted by "Peter Ertl (JIRA)" <ji...@apache.org> on 2017/09/01 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/01 10:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6163) Document per-window state in ProcessWindowFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/01 10:05:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-5944) Flink should support reading Snappy Files - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/01 11:01:00 UTC, 2 replies.
- [GitHub] flink issue #4630: [FLINK-6733] Remove commented out AvgAggregationFunction.... - posted by mlipkovich <gi...@git.apache.org> on 2017/09/01 11:45:31 UTC, 2 replies.
- [jira] [Commented] (FLINK-6733) Remove commented out AvgAggregationFunction.java - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 11:46:00 UTC, 3 replies.
- [GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio... - posted by asfgit <gi...@git.apache.org> on 2017/09/01 12:33:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 12:34:00 UTC, 0 replies.
- [GitHub] flink pull request #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / ... - posted by pnowojski <gi...@git.apache.org> on 2017/09/01 12:35:08 UTC, 11 replies.
- [GitHub] flink pull request #4634: [FLINK-7568] Improve Windowing Documentation - posted by aljoscha <gi...@git.apache.org> on 2017/09/01 13:37:43 UTC, 9 replies.
- [jira] [Commented] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 13:38:00 UTC, 11 replies.
- [jira] [Closed] (FLINK-6860) update Apache Beam in page Ecosystem - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/01 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7569) '1 record' delay for counted windowed streams - posted by "olivier sohn (JIRA)" <ji...@apache.org> on 2017/09/01 15:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7569) '1 record' delay for counted windowed streams - posted by "olivier sohn (JIRA)" <ji...@apache.org> on 2017/09/01 15:26:02 UTC, 0 replies.
- [GitHub] flink issue #4570: [FLINK-7438][DataStream API]Remove useless import, avoid ... - posted by yew1eb <gi...@git.apache.org> on 2017/09/01 15:53:18 UTC, 1 replies.
- [GitHub] flink issue #4614: [FLINK-7547] AsyncFunction.scala extends Function, serial... - posted by yew1eb <gi...@git.apache.org> on 2017/09/01 15:53:19 UTC, 1 replies.
- [GitHub] flink issue #4575: [FLINK-7494][travis] Add license headers to '.travis.yml'... - posted by yew1eb <gi...@git.apache.org> on 2017/09/01 15:53:22 UTC, 2 replies.
- [jira] [Commented] (FLINK-7494) No license headers in ".travis.yml" file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 15:54:01 UTC, 5 replies.
- [jira] [Commented] (FLINK-7438) Some classes are eclipsed by classes in package scala - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 15:54:01 UTC, 8 replies.
- [jira] [Commented] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 15:54:01 UTC, 6 replies.
- [jira] [Assigned] (FLINK-6733) Remove commented out AvgAggregationFunction.java - posted by "Mikhail Lipkovich (JIRA)" <ji...@apache.org> on 2017/09/01 16:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6016) Newlines should be valid in quoted strings in CSV - posted by "Mikhail Lipkovich (JIRA)" <ji...@apache.org> on 2017/09/01 16:57:00 UTC, 1 replies.
- [GitHub] flink pull request #4627: [FLINK-7422][kinesis] Upgrade Kinesis Client Libra... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/01 17:25:40 UTC, 0 replies.
- [jira] [Created] (FLINK-7570) Fix broken link on faq page - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/01 17:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7570) Fix broken link on faq page - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/01 17:45:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7571) Execution of TableSources with Time Indicators fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/01 20:06:00 UTC, 0 replies.
- [GitHub] flink pull request #4635: [FLINK-7571] [table] Fix translation of TableSourc... - posted by fhueske <gi...@git.apache.org> on 2017/09/01 20:12:52 UTC, 4 replies.
- [jira] [Commented] (FLINK-7571) Execution of TableSources with Time Indicators fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 20:13:00 UTC, 7 replies.
- [GitHub] flink issue #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInfo; add ... - posted by suez1224 <gi...@git.apache.org> on 2017/09/01 21:01:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6) - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/09/01 23:48:03 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-4319) Rework Cluster Management (FLIP-6) - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/09/01 23:48:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-7432) Unclosed HighAvailabilityServices instance in QueryableStateClient - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/02 03:28:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-7433) Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/02 03:28:00 UTC, 1 replies.
- [GitHub] flink issue #4562: [FLINK-7402] Fix ineffective null check in NettyMessage#w... - posted by tedyu <gi...@git.apache.org> on 2017/09/02 03:28:22 UTC, 1 replies.
- [jira] [Commented] (FLINK-7402) Ineffective null check in NettyMessage#write() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/02 03:29:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/02 14:42:02 UTC, 2 replies.
- [jira] [Resolved] (FLINK-6997) SavepointITCase fails in master branch sometimes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/03 01:56:03 UTC, 0 replies.
- [GitHub] flink issue #4634: [FLINK-7568] Improve Windowing Documentation - posted by aljoscha <gi...@git.apache.org> on 2017/09/03 16:29:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-7284) Verify compile time and runtime version of Hadoop - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/03 19:50:02 UTC, 0 replies.
- [GitHub] flink issue #4527: [FLINK-7409] [web] Make WebRuntimeMonitor reactive - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 20:52:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-7409) WebRuntimeMonitor blocks serving threads - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 20:53:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-4831) Implement a slf4j metric reporter - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/03 20:54:00 UTC, 6 replies.
- [GitHub] flink issue #4540: [FLINK-7444] [rpc] Make external calls non-blocking - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 20:54:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-7444) Make external calls non-blocking - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 20:55:00 UTC, 1 replies.
- [GitHub] flink issue #4548: [FLINK-7457] Make Dispatcher highly available - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 20:59:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-7457) Make dispatcher highly available - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 21:00:02 UTC, 1 replies.
- [GitHub] flink pull request #4548: [FLINK-7457] Make Dispatcher highly available - posted by asfgit <gi...@git.apache.org> on 2017/09/03 21:02:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-7457) Make dispatcher highly available - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/03 21:03:00 UTC, 0 replies.
- [GitHub] flink issue #4573: [FLINK-7489] Remove startJobExecution and suspendExecutio... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 21:04:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-7489) Remove job lifecycle methods from public JobMasterGateway interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 21:05:01 UTC, 1 replies.
- [GitHub] flink pull request #4573: [FLINK-7489] Remove startJobExecution and suspendE... - posted by asfgit <gi...@git.apache.org> on 2017/09/03 21:06:48 UTC, 0 replies.
- [GitHub] flink issue #4579: [FLINK-7500] Set JobMaster leader session id in main thre... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 21:06:55 UTC, 1 replies.
- [jira] [Closed] (FLINK-7489) Remove job lifecycle methods from public JobMasterGateway interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/03 21:07:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-7500) Set JobMaster leader session id in main thread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 21:07:02 UTC, 2 replies.
- [GitHub] flink issue #4580: [FLINK-7501] Generalize RegisteredRpcConnection to suppor... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 21:08:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-7501) Generalize leader id of RegisteredRpcConnection - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 21:09:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-7501) Generalize leader id of RegisteredRpcConnection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/03 21:11:02 UTC, 0 replies.
- [GitHub] flink pull request #4580: [FLINK-7501] Generalize RegisteredRpcConnection to... - posted by asfgit <gi...@git.apache.org> on 2017/09/03 21:11:44 UTC, 0 replies.
- [GitHub] flink issue #4589: [FLINK-7522] Add termination future to ClusterEntrypoint - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 21:11:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-7522) Add termination future to ClusterEntrypoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 21:12:00 UTC, 1 replies.
- [GitHub] flink pull request #4589: [FLINK-7522] Add termination future to ClusterEntr... - posted by asfgit <gi...@git.apache.org> on 2017/09/03 21:13:52 UTC, 0 replies.
- [jira] [Closed] (FLINK-7522) Add termination future to ClusterEntrypoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/03 21:14:00 UTC, 0 replies.
- [GitHub] flink issue #4588: [FLINK-7519] Add HttpResponseStatus to RestClientExceptio... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 21:16:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6344) Migrate from Java serialization for BucketingSink's state - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/03 21:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6347) Migrate from Java serialization for MessageAcknowledgingSourceBase's state - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/03 21:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7519) Enrich ClientRestException with HttpResponseStatus - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 21:17:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-7519) Enrich ClientRestException with HttpResponseStatus - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/03 21:18:00 UTC, 0 replies.
- [GitHub] flink pull request #4588: [FLINK-7519] Add HttpResponseStatus to RestClientE... - posted by asfgit <gi...@git.apache.org> on 2017/09/03 21:18:14 UTC, 0 replies.
- [GitHub] flink issue #4595: [FLINK-7526] [TaskExecutor] Filter out duplicate JobManag... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 21:19:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-7526) TaskExecutor should filter out duplicate JobManager gained leadership messages - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 21:20:00 UTC, 2 replies.
- [GitHub] flink issue #4596: [FLINK-7523] Add proper resource shutdown to ResourceMana... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 21:25:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-7523) test instability in LocalStreamEnvironmentITCase#testRunIsolatedJob - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 21:26:02 UTC, 2 replies.
- [GitHub] flink issue #4578: [FLINK-7078] [rpc] Introduce FencedRpcEndpoint - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/03 21:34:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-7078) Support fencing tokens to filter out outdated messages - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 21:35:00 UTC, 1 replies.
- [GitHub] flink pull request #4578: [FLINK-7078] [rpc] Introduce FencedRpcEndpoint - posted by asfgit <gi...@git.apache.org> on 2017/09/03 21:38:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-7078) Support fencing tokens to filter out outdated messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/03 21:39:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-7409) WebRuntimeMonitor blocks serving threads - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/03 22:01:03 UTC, 0 replies.
- [GitHub] flink pull request #4527: [FLINK-7409] [web] Make WebRuntimeMonitor reactive - posted by asfgit <gi...@git.apache.org> on 2017/09/03 22:01:24 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3182) TaskManagersHandler can block web frontend - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/03 22:04:00 UTC, 0 replies.
- [GitHub] flink pull request #4540: [FLINK-7444] [rpc] Make external calls non-blockin... - posted by asfgit <gi...@git.apache.org> on 2017/09/03 22:18:57 UTC, 0 replies.
- [jira] [Closed] (FLINK-7444) Make external calls non-blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/03 22:19:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7572) Improve TableSchema ValidationException message. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/09/04 00:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-3862) Restructure community website - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/04 03:28:00 UTC, 1 replies.
- [GitHub] flink issue #4500: [FLINK-6787] Fix Job-/StoppingException extend FlinkExcep... - posted by zjureel <gi...@git.apache.org> on 2017/09/04 05:17:28 UTC, 0 replies.
- [GitHub] flink pull request #4500: [FLINK-6787] Fix Job-/StoppingException extend Fli... - posted by zjureel <gi...@git.apache.org> on 2017/09/04 05:17:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-6787) Job-/StoppableException should extend FlinkException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 05:18:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-7500) Set JobMaster leader session id in main thread - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/04 06:38:02 UTC, 0 replies.
- [GitHub] flink pull request #4579: [FLINK-7500] Set JobMaster leader session id in ma... - posted by asfgit <gi...@git.apache.org> on 2017/09/04 06:38:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-7526) TaskExecutor should filter out duplicate JobManager gained leadership messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/04 06:42:00 UTC, 0 replies.
- [GitHub] flink pull request #4595: [FLINK-7526] [TaskExecutor] Filter out duplicate J... - posted by asfgit <gi...@git.apache.org> on 2017/09/04 06:42:10 UTC, 0 replies.
- [GitHub] flink issue #4584: [FLINK-7507] [dispatcher] Fence Dispatcher - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/04 06:47:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-7507) Fence Dispatcher - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 06:48:02 UTC, 1 replies.
- [jira] [Closed] (FLINK-7507) Fence Dispatcher - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/04 06:50:02 UTC, 0 replies.
- [GitHub] flink pull request #4584: [FLINK-7507] [dispatcher] Fence Dispatcher - posted by asfgit <gi...@git.apache.org> on 2017/09/04 06:50:08 UTC, 0 replies.
- [GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha... - posted by aljoscha <gi...@git.apache.org> on 2017/09/04 07:44:32 UTC, 25 replies.
- [jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 07:45:00 UTC, 29 replies.
- [jira] [Commented] (FLINK-3827) Flink modules include unused dependencies - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/04 08:57:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-5944) Flink should support reading Snappy Files - posted by "Mikhail Lipkovich (JIRA)" <ji...@apache.org> on 2017/09/04 09:00:16 UTC, 10 replies.
- [jira] [Assigned] (FLINK-3827) Flink modules include unused dependencies - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/04 09:45:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2269) Add Receiver operating characteristic (ROC) curve evaluation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/04 09:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2267) Support multi-class scoring for binary classification scores - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/04 09:58:00 UTC, 0 replies.
- [GitHub] flink issue #4582: [FLINK-7504] Fence the ResourceManager - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/04 11:43:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-7504) Fence ResourceManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 11:44:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-7504) Fence ResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/04 11:45:00 UTC, 0 replies.
- [GitHub] flink pull request #4582: [FLINK-7504] Fence the ResourceManager - posted by asfgit <gi...@git.apache.org> on 2017/09/04 11:45:35 UTC, 0 replies.
- [GitHub] flink issue #4597: [FLINK-7527] [rest] Let AbstractRestHandler extend Redire... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/04 12:08:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-7527) Add redirection logic to AbstractRestHandler - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 12:09:02 UTC, 12 replies.
- [jira] [Created] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2 - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/04 12:39:00 UTC, 0 replies.
- [GitHub] flink pull request #4590: [FLINK-7513][tests] remove TestBufferFactory#MOCK_... - posted by pnowojski <gi...@git.apache.org> on 2017/09/04 12:43:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-7513) remove TestBufferFactory#MOCK_BUFFER - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 12:44:00 UTC, 3 replies.
- [GitHub] flink pull request #4571: [FLINK-7487][tests] fix ClassLoaderITCase#testDisp... - posted by pnowojski <gi...@git.apache.org> on 2017/09/04 12:46:14 UTC, 2 replies.
- [jira] [Commented] (FLINK-7487) test instability in ClassLoaderITCase (no resources available) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 12:47:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2 - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/04 12:54:00 UTC, 2 replies.
- [jira] [Created] (FLINK-7574) flink-clients - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/04 13:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3828) flink-runtime - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/04 13:51:02 UTC, 0 replies.
- [GitHub] flink issue #4239: [FLINK-6988] flink-connector-kafka-0.11 with exactly-once... - posted by pnowojski <gi...@git.apache.org> on 2017/09/04 13:54:31 UTC, 2 replies.
- [jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 13:55:00 UTC, 2 replies.
- [GitHub] flink pull request #4517: [FLINK-7411][network] minor performance improvemen... - posted by pnowojski <gi...@git.apache.org> on 2017/09/04 14:16:58 UTC, 8 replies.
- [jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 14:17:00 UTC, 10 replies.
- [GitHub] flink pull request #4518: [FLINK-7412][network] optimise NettyMessage.TaskEv... - posted by pnowojski <gi...@git.apache.org> on 2017/09/04 14:35:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-7412) optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 14:36:00 UTC, 2 replies.
- [jira] [Created] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available - posted by "James Lafa (JIRA)" <ji...@apache.org> on 2017/09/04 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7576) Add FutureUtils.retryWithDelay - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/04 14:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6563) Expose time indicator attributes in the KafkaTableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/04 14:45:00 UTC, 18 replies.
- [GitHub] flink pull request #4637: [FLINK-7576] [futures] Add FutureUtils.retryWithDe... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/04 14:47:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-7576) Add FutureUtils.retryWithDelay - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 14:48:00 UTC, 2 replies.
- [GitHub] flink pull request #4638: [FLINK-6563] [table] Add time indicator support to... - posted by fhueske <gi...@git.apache.org> on 2017/09/04 15:06:26 UTC, 16 replies.
- [GitHub] flink pull request #4639: [FLINK-7524] Remove potentially blocking behaviour... - posted by StefanRRichter <gi...@git.apache.org> on 2017/09/04 15:06:35 UTC, 12 replies.
- [GitHub] flink issue #4639: [FLINK-7524] Remove potentially blocking behaviour from A... - posted by StefanRRichter <gi...@git.apache.org> on 2017/09/04 15:06:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-7524) Task "xxx" did not react to cancelling signal, but is stuck in method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 15:07:00 UTC, 13 replies.
- [jira] [Assigned] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/04 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7577) flink-core - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/04 15:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7525) Add config option to disable Cancel functionality on UI - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/04 15:21:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/04 15:21:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/04 15:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3831) flink-streaming-java - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/04 15:42:00 UTC, 0 replies.
- [GitHub] flink issue #3829: [FLINK-6442] [table] Extend TableAPI Support Sink Table R... - posted by fhueske <gi...@git.apache.org> on 2017/09/04 16:16:26 UTC, 2 replies.
- [GitHub] flink issue #4633: [FLINK-7564] [table] Fix Watermark semantics in RowTimeUn... - posted by fhueske <gi...@git.apache.org> on 2017/09/04 16:34:27 UTC, 4 replies.
- [GitHub] flink issue #3026: [FLINK-2980] [table] Support for GROUPING SETS clause in ... - posted by aljoscha <gi...@git.apache.org> on 2017/09/04 17:11:36 UTC, 2 replies.
- [jira] [Commented] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 17:12:00 UTC, 3 replies.
- [GitHub] flink issue #3124: [FLINK-5281] Extend KafkaJsonTableSources to support nest... - posted by aljoscha <gi...@git.apache.org> on 2017/09/04 17:12:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-5281) Extend KafkaJsonTableSources to support nested data - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 17:13:00 UTC, 1 replies.
- [GitHub] flink pull request #4640: [FLINK-7572][table]Improve TableSchema and FlinkTa... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/09/05 01:11:22 UTC, 1 replies.
- [jira] [Commented] (FLINK-7572) Improve TableSchema ValidationException message. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 01:12:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-7558) Improve SQL ValidationException message. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/09/05 02:21:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-7465) Add build-in BloomFilterCount on TableAPI&SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/09/05 02:39:01 UTC, 8 replies.
- [jira] [Commented] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2 - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/05 02:46:03 UTC, 3 replies.
- [jira] [Resolved] (FLINK-6995) Add a warning to outdated documentation - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/05 02:54:03 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/05 03:30:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7578) WindowStream should support rich AggregateFunction - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2017/09/05 04:29:00 UTC, 0 replies.
- [GitHub] flink issue #4485: [FLINK-7378][core]Create a fix size (non rebalancing) buf... - posted by zhijiangW <gi...@git.apache.org> on 2017/09/05 06:28:26 UTC, 4 replies.
- [jira] [Commented] (FLINK-7378) Create a fix size (non rebalancing) buffer pool type for the floating buffers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 06:29:01 UTC, 28 replies.
- [GitHub] flink pull request #4485: [FLINK-7378][core]Create a fix size (non rebalanci... - posted by zhijiangW <gi...@git.apache.org> on 2017/09/05 06:33:38 UTC, 23 replies.
- [GitHub] flink pull request #4641: [hotfix][docs] Fix a typo on log name for quick st... - posted by mcfongtw <gi...@git.apache.org> on 2017/09/05 07:38:50 UTC, 3 replies.
- [jira] [Created] (FLINK-7579) Documentation of yarn.application-attempts is not accurate - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2017/09/05 08:02:00 UTC, 0 replies.
- [GitHub] flink pull request #4642: [FLINK-7579] [Documentation] More accurate descrip... - posted by packet23 <gi...@git.apache.org> on 2017/09/05 08:07:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-7579) Documentation of yarn.application-attempts is not accurate - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 08:08:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-7227) OR expression with more than 2 predicates is not pushed into a TableSource - posted by "Usman Younas (JIRA)" <ji...@apache.org> on 2017/09/05 09:02:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-7227) OR expression with more than 2 predicates is not pushed into a TableSource - posted by "Usman Younas (JIRA)" <ji...@apache.org> on 2017/09/05 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7580) Let LeaderGatewayRetriever implementations automatically retry failed gateway retrieval operations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/05 09:41:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7560) Add Reset button for Plan Visualizer Page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/05 09:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7570) Fix broken link on faq page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/05 09:45:02 UTC, 0 replies.
- [GitHub] flink issue #4546: [FLINK-6751] [docs] Add missing documentation for User-De... - posted by fhueske <gi...@git.apache.org> on 2017/09/05 10:11:27 UTC, 0 replies.
- [GitHub] flink issue #4640: [FLINK-7572][table]Improve TableSchema and FlinkTable val... - posted by fhueske <gi...@git.apache.org> on 2017/09/05 10:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6751) Table API / SQL Docs: UDFs Page - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 10:12:01 UTC, 1 replies.
- [GitHub] flink issue #4507: [FLINK-7404] [table] Generate code for non-equi join cond... - posted by fhueske <gi...@git.apache.org> on 2017/09/05 10:12:12 UTC, 0 replies.
- [GitHub] flink issue #4608: [FLINK-7227][Table API & SQL]Fix the the TableSource pred... - posted by fhueske <gi...@git.apache.org> on 2017/09/05 10:12:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-7404) Table API batch join code-gen's equi-join conditions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 10:13:00 UTC, 1 replies.
- [GitHub] flink pull request #4643: [FLINK-7580] Automatically retry failed gateway re... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/05 10:20:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-7580) Let LeaderGatewayRetriever implementations automatically retry failed gateway retrieval operations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 10:21:00 UTC, 3 replies.
- [GitHub] flink issue #4583: [FLINK-7506] Fence JobMaster - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/05 10:37:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-7506) Fence JobMaster - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 10:38:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-7523) test instability in LocalStreamEnvironmentITCase#testRunIsolatedJob - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/05 10:39:00 UTC, 0 replies.
- [GitHub] flink pull request #4596: [FLINK-7523] Add proper resource shutdown to Resou... - posted by asfgit <gi...@git.apache.org> on 2017/09/05 10:39:48 UTC, 0 replies.
- [jira] [Closed] (FLINK-7506) Fence JobMaster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/05 10:46:02 UTC, 0 replies.
- [GitHub] flink pull request #4583: [FLINK-7506] Fence JobMaster - posted by asfgit <gi...@git.apache.org> on 2017/09/05 10:46:10 UTC, 0 replies.
- [jira] [Created] (FLINK-7581) Name netty threads of rest components - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/05 10:51:00 UTC, 0 replies.
- [GitHub] flink pull request #4644: [FLINK-7581] [REST] Name netty threads - posted by zentol <gi...@git.apache.org> on 2017/09/05 10:54:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-7581) Name netty threads of rest components - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 10:55:00 UTC, 3 replies.
- [jira] [Created] (FLINK-7582) Rest client may buffer responses indefinitely under heavy laod - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/05 10:58:00 UTC, 0 replies.
- [GitHub] flink pull request #4645: [FLINK-7582] [REST] Netty thread immediately parse... - posted by zentol <gi...@git.apache.org> on 2017/09/05 11:01:57 UTC, 6 replies.
- [jira] [Commented] (FLINK-7582) Rest client may buffer responses indefinitely under heavy laod - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 11:02:00 UTC, 6 replies.
- [jira] [Created] (FLINK-7583) Create singleton isntance for the content type header - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/05 11:06:00 UTC, 0 replies.
- [GitHub] flink pull request #4646: [FLINK-7583] [REST] Use static constant for CONTEN... - posted by zentol <gi...@git.apache.org> on 2017/09/05 11:09:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-7583) Create singleton isntance for the content type header - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 11:10:02 UTC, 3 replies.
- [GitHub] flink pull request #3026: [FLINK-2980] [table] Support for GROUPING SETS cla... - posted by chermenin <gi...@git.apache.org> on 2017/09/05 11:37:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5734) Implement code generation for NormalizedKeySorter - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/05 11:42:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-5734) Implement code generation for NormalizedKeySorter - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/05 11:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work - posted by "Mikhail Lipkovich (JIRA)" <ji...@apache.org> on 2017/09/05 11:49:00 UTC, 18 replies.
- [jira] [Comment Edited] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work - posted by "Mikhail Lipkovich (JIRA)" <ji...@apache.org> on 2017/09/05 11:50:00 UTC, 2 replies.
- [jira] [Resolved] (FLINK-4867) Investigate code generation for improving sort performance - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/05 11:53:00 UTC, 0 replies.
- [GitHub] flink pull request #4546: [FLINK-6751] [docs] Add missing documentation for ... - posted by asfgit <gi...@git.apache.org> on 2017/09/05 12:23:52 UTC, 0 replies.
- [GitHub] flink pull request #4608: [FLINK-7227][Table API & SQL]Fix the the TableSour... - posted by asfgit <gi...@git.apache.org> on 2017/09/05 12:23:52 UTC, 0 replies.
- [GitHub] flink pull request #4507: [FLINK-7404] [table] Generate code for non-equi jo... - posted by asfgit <gi...@git.apache.org> on 2017/09/05 12:23:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-7569) '1 record' delay for counted windowed streams - posted by "olivier sohn (JIRA)" <ji...@apache.org> on 2017/09/05 13:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7569) '1 record' delay for counted windowed streams - posted by "olivier sohn (JIRA)" <ji...@apache.org> on 2017/09/05 13:29:00 UTC, 0 replies.
- [GitHub] flink pull request #4647: [FLINK-7575] [WEB-DASHBOARD] Display "Fetching..."... - posted by jameslafa <gi...@git.apache.org> on 2017/09/05 13:49:00 UTC, 10 replies.
- [jira] [Commented] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 13:50:02 UTC, 15 replies.
- [jira] [Closed] (FLINK-6751) Table API / SQL Docs: UDFs Page - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/05 14:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7564) Fix Watermark semantics in Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/05 14:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7404) Table API batch join code-gen's equi-join conditions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/05 14:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7572) Improve TableSchema ValidationException message. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/05 14:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7227) OR expression with more than 2 predicates is not pushed into a TableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/05 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7584) [Documentation] Add checkstyle version due to breaking change in the plugin - posted by "James Lafa (JIRA)" <ji...@apache.org> on 2017/09/05 14:35:00 UTC, 0 replies.
- [GitHub] flink pull request #4510: [FLINK-7124] [flip-6] Add test to verify rescaling... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/05 14:41:21 UTC, 7 replies.
- [jira] [Commented] (FLINK-7124) Allow to rescale JobGraph on JobManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 14:42:00 UTC, 7 replies.
- [GitHub] flink pull request #4648: [FLINK-7584] [doc] Fix checkstyle version in Setup... - posted by jameslafa <gi...@git.apache.org> on 2017/09/05 14:55:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-7584) [Documentation] Add checkstyle version due to breaking change in the plugin - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 14:56:00 UTC, 5 replies.
- [jira] [Created] (FLINK-7585) SimpleCounter not thread safe - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/05 15:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7585) SimpleCounter not thread safe - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/05 15:14:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6163) Document per-window state in ProcessWindowFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/05 15:31:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4831) Implement a slf4j metric reporter - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/05 15:40:01 UTC, 0 replies.
- [GitHub] flink issue #4636: [FLINK-2268] Allow Flink binary release without Hadoop - posted by EronWright <gi...@git.apache.org> on 2017/09/05 15:41:11 UTC, 3 replies.
- [jira] [Closed] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/05 16:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7266) Don't attempt to delete parent directory on S3 - posted by "Steve Loughran (JIRA)" <ji...@apache.org> on 2017/09/05 16:21:00 UTC, 3 replies.
- [jira] [Created] (FLINK-7586) Report Watermark metrics in all operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/05 16:23:00 UTC, 0 replies.
- [GitHub] flink issue #4648: [FLINK-7584] [doc] Fix checkstyle version in Setup IDE - posted by zentol <gi...@git.apache.org> on 2017/09/05 17:44:16 UTC, 3 replies.
- [jira] [Closed] (FLINK-7585) SimpleCounter not thread safe - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/05 18:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7587) Flink doesn't delete checkpoint file's dir from s3 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/05 18:02:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-7586) Report Watermark metrics in all operators - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/05 18:12:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7588) Document RocksDB tuning for spinning disks - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/05 18:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7587) Flink doesn't delete checkpoint file's dir from s3 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/05 19:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7587) Flink doesn't delete empty checkpoint file's dir from s3 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/05 19:05:00 UTC, 0 replies.
- [GitHub] flink issue #4472: FLINK-7368: MetricStore makes cpu spin at 100% - posted by zentol <gi...@git.apache.org> on 2017/09/05 19:36:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100% - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 19:37:02 UTC, 0 replies.
- [GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i... - posted by fhueske <gi...@git.apache.org> on 2017/09/05 21:50:13 UTC, 117 replies.
- [jira] [Created] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/05 21:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/05 22:27:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/05 22:28:00 UTC, 2 replies.
- [GitHub] flink issue #4625: [FLINK-6233] [table] Support time-bounded stream inner jo... - posted by xccui <gi...@git.apache.org> on 2017/09/05 23:06:51 UTC, 4 replies.
- [GitHub] flink pull request #4556: [FLINK-6465][table]support FIRST_VALUE on Table AP... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/09/05 23:50:06 UTC, 3 replies.
- [jira] [Commented] (FLINK-6465) support FIRST_VALUE on Table API & SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 23:51:00 UTC, 4 replies.
- [GitHub] flink issue #4536: [FLINK-7439] [table] Support variable arguments for UDTF ... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/09/05 23:59:19 UTC, 2 replies.
- [jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 00:00:00 UTC, 7 replies.
- [GitHub] flink issue #4445: [FLINK-7310][core] always use the HybridMemorySegment - posted by KurtYoung <gi...@git.apache.org> on 2017/09/06 02:20:44 UTC, 0 replies.
- [jira] [Commented] (FLINK-7310) always use HybridMemorySegment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7591) Support partition by and order by of MATCH_RECOGNIZE - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/06 05:29:00 UTC, 0 replies.
- [GitHub] flink issue #4529: [FLINK-7428][network] avoid buffer copies when receiving ... - posted by KurtYoung <gi...@git.apache.org> on 2017/09/06 05:59:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-7428) avoid one additional buffer copy when receiving messages - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 06:00:03 UTC, 3 replies.
- [jira] [Created] (FLINK-7592) How to close the output log like "Connected to JobManager at Actor" and "Job execution switched to status RUNNING."? - posted by "brighteast (JIRA)" <ji...@apache.org> on 2017/09/06 07:22:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/06 07:32:00 UTC, 1 replies.
- [GitHub] flink issue #4647: [FLINK-7575] [WEB-DASHBOARD] Display "Fetching..." instea... - posted by uce <gi...@git.apache.org> on 2017/09/06 07:59:48 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/06 08:03:00 UTC, 0 replies.
- [GitHub] flink issue #4637: [FLINK-7576] [futures] Add FutureUtils.retryWithDelay - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/06 08:14:54 UTC, 0 replies.
- [jira] [Closed] (FLINK-7576) Add FutureUtils.retryWithDelay - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/06 08:20:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/06 08:34:00 UTC, 0 replies.
- [GitHub] flink pull request #4649: [FLINK-6116] Watermarks don't work when unioning w... - posted by gallenvara <gi...@git.apache.org> on 2017/09/06 08:39:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-6116) Watermarks don't work when unioning with same DataStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 08:40:00 UTC, 0 replies.
- [GitHub] flink issue #4513: [FLINK-6938] [cep] IterativeCondition should support Rich... - posted by dianfu <gi...@git.apache.org> on 2017/09/06 09:03:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-6938) IterativeCondition should support RichFunction interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7593) Generated plan does not create correct groups - posted by "Steffen Dienst (JIRA)" <ji...@apache.org> on 2017/09/06 09:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7593) Generated plan does not create correct groups - posted by "Steffen Dienst (JIRA)" <ji...@apache.org> on 2017/09/06 09:14:02 UTC, 1 replies.
- [GitHub] flink pull request #4650: [FLINK-7430] Set StreamTask.isRunning to false aft... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/06 09:26:34 UTC, 1 replies.
- [GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo... - posted by fhueske <gi...@git.apache.org> on 2017/09/06 10:03:26 UTC, 4 replies.
- [GitHub] flink issue #4650: [FLINK-7430] Set StreamTask.isRunning to false after clos... - posted by aljoscha <gi...@git.apache.org> on 2017/09/06 10:12:43 UTC, 1 replies.
- [jira] [Updated] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/06 10:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6369) Better support for overlay networks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/06 10:30:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-4812) Export currentLowWatermark metric also for sources - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/06 11:38:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-4812) Report Watermark metrics in all operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/06 11:39:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-4812) Report Watermark metrics in all operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/06 11:39:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7586) Report Watermark metrics in all operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/06 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7594) Add a SQL CLI client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/06 12:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7593) Generated plan does not create correct groups - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/06 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/06 12:44:03 UTC, 0 replies.
- [jira] [Updated] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/06 12:45:00 UTC, 0 replies.
- [GitHub] flink pull request #4631: [hotfix][kafka][docs] Add warning regarding data l... - posted by aljoscha <gi...@git.apache.org> on 2017/09/06 12:50:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/06 13:20:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work - posted by "Mikhail Lipkovich (JIRA)" <ji...@apache.org> on 2017/09/06 13:43:00 UTC, 0 replies.
- [GitHub] flink pull request #4651: [FLINK-7595] [Savepoints] Allow removing stateless... - posted by zentol <gi...@git.apache.org> on 2017/09/06 13:45:07 UTC, 0 replies.
- [GitHub] flink issue #4631: [hotfix][kafka][docs] Add warning regarding data losses w... - posted by pnowojski <gi...@git.apache.org> on 2017/09/06 14:04:11 UTC, 2 replies.
- [GitHub] flink issue #4646: [FLINK-7583] [REST] Use static constant for CONTENT_TYPE ... - posted by zentol <gi...@git.apache.org> on 2017/09/06 14:10:55 UTC, 1 replies.
- [jira] [Resolved] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/06 14:13:00 UTC, 0 replies.
- [GitHub] flink pull request #4575: [FLINK-7494][travis] Add license headers to '.trav... - posted by zentol <gi...@git.apache.org> on 2017/09/06 15:06:22 UTC, 2 replies.
- [GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/06 15:54:31 UTC, 33 replies.
- [jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 15:55:01 UTC, 34 replies.
- [GitHub] flink issue #4521: [FLINK-7357] [table] Created extended rules for WindowSta... - posted by walterddr <gi...@git.apache.org> on 2017/09/06 18:33:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 18:34:00 UTC, 2 replies.
- [GitHub] flink issue #4526: [FLINK-7407] [kafka] Adapt AbstractPartitionDiscoverer to... - posted by aljoscha <gi...@git.apache.org> on 2017/09/06 18:37:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 18:38:01 UTC, 3 replies.
- [jira] [Commented] (FLINK-7594) Add a SQL CLI client - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/09/06 23:59:00 UTC, 5 replies.
- [GitHub] flink pull request #4652: [FLINK-7465][table]Add cardinality count for table... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/09/07 00:44:27 UTC, 6 replies.
- [jira] [Created] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType) - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/09/07 01:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType) - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/09/07 02:33:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 02:38:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-7521) Remove the 10MB limit from the current REST implementation. - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/09/07 02:43:00 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-7594) Add a SQL CLI client - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/09/07 02:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7521) Remove the 10MB limit from the current REST implementation. - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/09/07 02:51:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 04:05:00 UTC, 5 replies.
- [jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 04:10:00 UTC, 5 replies.
- [GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/07 04:13:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 04:14:00 UTC, 5 replies.
- [GitHub] flink issue #4565: [FLINK-7429] [kinesis] Add migration test coverage for Fl... - posted by tzulitai <gi...@git.apache.org> on 2017/09/07 04:31:46 UTC, 0 replies.
- [GitHub] flink pull request #4565: [FLINK-7429] [kinesis] Add migration test coverage... - posted by tzulitai <gi...@git.apache.org> on 2017/09/07 04:31:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-7429) Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 04:32:00 UTC, 1 replies.
- [GitHub] flink pull request #4526: [FLINK-7407] [kafka] Adapt AbstractPartitionDiscov... - posted by tzulitai <gi...@git.apache.org> on 2017/09/07 04:51:58 UTC, 0 replies.
- [GitHub] flink pull request #4537: [FLINK-7440] [kinesis] Add various eager serializa... - posted by asfgit <gi...@git.apache.org> on 2017/09/07 06:20:56 UTC, 0 replies.
- [GitHub] flink pull request #4473: [FLINK-7367][kinesis connector] Parameterize more ... - posted by asfgit <gi...@git.apache.org> on 2017/09/07 06:20:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-7440) Add eager serializable checks on provided de-/serialization schemas for Kinesis consumer / producer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 06:21:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/07 06:23:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7440) Add eager serializable checks on provided de-/serialization schemas for Kinesis consumer / producer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/07 06:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc) - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/07 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7597) broken flink-connectors-kinesis setup in Intellij that potentially results from improper pom.xml - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 06:30:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7598) ineffective shaded artifacts checks in travis_mvn_watchdog.sh - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/07 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7598) ineffective shaded artifacts checks in travis_mvn_watchdog.sh - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/07 07:25:00 UTC, 0 replies.
- [GitHub] flink pull request #4653: [FLINK-7598][travis] fix ineffective shaded artifa... - posted by NicoK <gi...@git.apache.org> on 2017/09/07 07:25:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-7598) ineffective shaded artifacts checks in travis_mvn_watchdog.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 07:26:00 UTC, 3 replies.
- [GitHub] flink issue #4653: [FLINK-7598][travis] fix ineffective shaded artifacts che... - posted by zentol <gi...@git.apache.org> on 2017/09/07 07:42:15 UTC, 1 replies.
- [GitHub] flink pull request #4654: [FLINK-7521] Add config option to set the content ... - posted by zjureel <gi...@git.apache.org> on 2017/09/07 08:36:12 UTC, 1 replies.
- [GitHub] flink issue #4654: [FLINK-7521] Add config option to set the content length ... - posted by zjureel <gi...@git.apache.org> on 2017/09/07 08:38:00 UTC, 5 replies.
- [jira] [Created] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/07 08:58:00 UTC, 0 replies.
- [GitHub] flink issue #3703: [FLINK-5005] WIP: publish scala 2.12 artifacts - posted by joan38 <gi...@git.apache.org> on 2017/09/07 09:41:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-5005) Publish Scala 2.12 artifacts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 09:42:00 UTC, 0 replies.
- [GitHub] flink pull request #4655: [FLINK-7567]: Removed keepPartitioning parameter f... - posted by mlipkovich <gi...@git.apache.org> on 2017/09/07 14:08:21 UTC, 1 replies.
- [jira] [Updated] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/07 20:08:00 UTC, 2 replies.
- [GitHub] flink pull request #4656: [FLINK-7508][kinesis] switch FlinkKinesisProducer ... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/07 20:39:21 UTC, 5 replies.
- [jira] [Commented] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 20:40:00 UTC, 9 replies.
- [jira] [Closed] (FLINK-7597) broken flink-connectors-kinesis setup in Intellij that potentially results from improper pom.xml - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 21:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7597) broken flink-connectors-kinesis setup in Intellij that potentially results from improper pom.xml - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 21:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 21:35:03 UTC, 0 replies.
- [GitHub] flink pull request #4657: [FLINK-7600][kinesis] shorten delay of KinesisProd... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/07 22:31:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 22:32:01 UTC, 4 replies.
- [jira] [Commented] (FLINK-6125) Commons httpclient is not shaded anymore in Flink 1.2 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 23:33:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6703) Document how to take a savepoint on YARN - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 23:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6703) Document how to take a savepoint on YARN - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 23:49:00 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-6703) Document how to take a savepoint on YARN - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 23:50:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 23:55:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6549) Improve error message for type mismatches with side outputs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 23:56:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6957) WordCountTable example cannot be run - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 23:56:00 UTC, 0 replies.
- [GitHub] flink issue #4655: [FLINK-7567]: Removed keepPartitioning parameter from ite... - posted by mlipkovich <gi...@git.apache.org> on 2017/09/08 00:01:25 UTC, 8 replies.
- [jira] [Created] (FLINK-7601) Support classifier in MatchRecognize - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/08 07:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7601) Support classifier in MatchRecognize - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/08 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7602) Create sub tasks for porting the remaining rest handlers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/08 08:57:00 UTC, 0 replies.
- [GitHub] flink pull request #4658: Flink 7596 - posted by Xpray <gi...@git.apache.org> on 2017/09/08 09:17:52 UTC, 1 replies.
- [jira] [Created] (FLINK-7603) Support within clause in MatchRecognize - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/08 09:18:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7604) Add OpenTSDB metrics reporter - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/08 09:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7596) fix bug when Set Operation handles ANY type - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/09/08 09:33:01 UTC, 1 replies.
- [GitHub] flink pull request #4659: [FLINK-4047] Fix documentation about determinism o... - posted by zhangminglei <gi...@git.apache.org> on 2017/09/08 10:14:30 UTC, 3 replies.
- [jira] [Commented] (FLINK-4047) Fix documentation about determinism of KeySelectors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 10:15:00 UTC, 5 replies.
- [jira] [Created] (FLINK-7605) JDBCOutputFormat autoCommit - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2017/09/08 12:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7605) JDBCOutputFormat autoCommit - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2017/09/08 12:05:00 UTC, 2 replies.
- [GitHub] flink pull request #4660: [FLINK-7050][table] Add support of RFC compliant C... - posted by uybhatti <gi...@git.apache.org> on 2017/09/08 13:11:38 UTC, 47 replies.
- [jira] [Commented] (FLINK-7050) RFC Compliant CSV Parser for Table Source - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 13:12:00 UTC, 48 replies.
- [jira] [Created] (FLINK-7606) Memory leak on NestedMapsStateTable - posted by "Matteo Ferrario (JIRA)" <ji...@apache.org> on 2017/09/08 14:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7606) Memory leak on NestedMapsStateTable - posted by "Matteo Ferrario (JIRA)" <ji...@apache.org> on 2017/09/08 14:20:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/09/08 14:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/08 16:49:01 UTC, 18 replies.
- [jira] [Created] (FLINK-7607) Web Frontend Hangs with Large Numbers of Tasks - posted by "Joshua Griffith (JIRA)" <ji...@apache.org> on 2017/09/08 16:50:00 UTC, 0 replies.
- [GitHub] flink pull request #4661: [FLINK-4831] Implement a slf4j metric reporter - posted by yew1eb <gi...@git.apache.org> on 2017/09/08 18:43:54 UTC, 0 replies.
- [jira] [Updated] (FLINK-7402) Ineffective null check in NettyMessage#write() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/08 19:20:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-6838) RescalingITCase fails in master branch - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/08 19:20:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7608) LatencyGauge change to histogram metric - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/08 20:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7608) LatencyGauge change to histogram metric - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/08 20:36:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7609) WindowWordCount example doesn't print countWindow output with default configs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/08 20:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7609) WindowWordCount example doesn't print countWindow output with default configs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/08 20:43:00 UTC, 1 replies.
- [GitHub] flink pull request #4662: [FLINK-7609][examples] WindowWordCount example doe... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/08 20:47:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-7609) WindowWordCount example doesn't print countWindow output with default configs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 20:48:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/08 20:49:00 UTC, 8 replies.
- [GitHub] flink pull request #4663: [FLINK-6549] [DataStream API] Improve error messag... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/09 07:16:36 UTC, 1 replies.
- [jira] [Commented] (FLINK-6549) Improve error message for type mismatches with side outputs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/09 07:17:00 UTC, 6 replies.
- [GitHub] flink pull request #4664: [FLINK-7562] Show uploaded-jars descending by uplo... - posted by yew1eb <gi...@git.apache.org> on 2017/09/09 07:51:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-7562) uploaded jars sort by upload-time on dashboard page - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/09 07:52:02 UTC, 4 replies.
- [jira] [Assigned] (FLINK-7562) uploaded jars sort by upload-time on dashboard page - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/09 07:52:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-4500) Cassandra sink can lose messages - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/10 02:45:02 UTC, 23 replies.
- [GitHub] flink issue #3816: [FLINK-5720] Deprecate DataStream#fold() - posted by iduanyingjie <gi...@git.apache.org> on 2017/09/11 03:40:29 UTC, 1 replies.
- [jira] [Commented] (FLINK-5720) Deprecate "Folding" in all of DataStream API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/11 03:41:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/09/11 04:45:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/11 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7610) xerces lib conflict - posted by "Domenico Campagnolo (JIRA)" <ji...@apache.org> on 2017/09/11 05:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7610) xerces lib conflict - posted by "Domenico Campagnolo (JIRA)" <ji...@apache.org> on 2017/09/11 05:52:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-4796) Add new Sink interface with access to more meta data - posted by "Erik van Oosten (JIRA)" <ji...@apache.org> on 2017/09/11 06:56:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-6444) Add a check that '@VisibleForTesting' methods are only used in tests - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/11 08:40:00 UTC, 6 replies.
- [jira] [Commented] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization - posted by "Philipp Grulich (JIRA)" <ji...@apache.org> on 2017/09/11 11:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7606) Memory leak on NestedMapsStateTable - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/09/11 13:09:00 UTC, 3 replies.
- [jira] [Created] (FLINK-7611) add metrics to measure the data drop by watermark - posted by "aitozi (JIRA)" <ji...@apache.org> on 2017/09/11 14:53:00 UTC, 0 replies.
- [GitHub] flink issue #4664: [FLINK-7562] Show uploaded-jars descending by upload time - posted by zentol <gi...@git.apache.org> on 2017/09/11 16:58:39 UTC, 0 replies.
- [GitHub] flink issue #4663: [FLINK-6549] [DataStream API] Improve error message for t... - posted by zentol <gi...@git.apache.org> on 2017/09/11 17:00:11 UTC, 3 replies.
- [GitHub] flink issue #4661: [FLINK-4831] Implement a slf4j metric reporter - posted by zentol <gi...@git.apache.org> on 2017/09/11 17:03:45 UTC, 0 replies.
- [GitHub] flink issue #4662: [FLINK-7609][examples] WindowWordCount example doesn't pr... - posted by zentol <gi...@git.apache.org> on 2017/09/11 17:12:20 UTC, 5 replies.
- [GitHub] flink issue #4659: [FLINK-4047] Fix documentation about determinism of KeySe... - posted by zentol <gi...@git.apache.org> on 2017/09/11 17:18:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-6957) WordCountTable example cannot be run - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/11 19:34:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-6703) Document how to take a savepoint on YARN - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/11 20:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-3542) FlinkKafkaConsumer09 cannot handle changing number of partitions - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/11 21:37:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-2428) Clean up unused properties in StreamConfig - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/12 00:00:16 UTC, 0 replies.
- [jira] [Updated] (FLINK-7611) add metrics to measure the data drop by watermark - posted by "aitozi (JIRA)" <ji...@apache.org> on 2017/09/12 01:49:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-2395) Check Scala catch blocks for Throwable - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/12 02:34:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-7608) LatencyGauge change to histogram metric - posted by "Georgii Gobozov (JIRA)" <ji...@apache.org> on 2017/09/12 06:18:00 UTC, 1 replies.
- [GitHub] flink issue #4622: [FLINK-7294]:[flink-mesos] mesos.resourcemanager.framewor... - posted by bbayani <gi...@git.apache.org> on 2017/09/12 06:38:38 UTC, 4 replies.
- [jira] [Commented] (FLINK-7294) mesos.resourcemanager.framework.role not working - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/12 06:39:00 UTC, 5 replies.
- [GitHub] flink issue #4299: [FLINK-7155] [metrics] Add Influxdb reporter - posted by yew1eb <gi...@git.apache.org> on 2017/09/12 06:55:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/12 06:56:00 UTC, 0 replies.
- [GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data... - posted by Aitozi <gi...@git.apache.org> on 2017/09/12 07:06:53 UTC, 17 replies.
- [jira] [Created] (FLINK-7612) Implement Event-driven Network IO - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/12 09:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-1728) Add random forest ensemble method to machine learning library - posted by "Michael Gendelman (JIRA)" <ji...@apache.org> on 2017/09/12 13:44:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-1728) Add random forest ensemble method to machine learning library - posted by "Michael Gendelman (JIRA)" <ji...@apache.org> on 2017/09/12 13:45:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1728) Add random forest ensemble method to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/12 20:28:03 UTC, 0 replies.
- [jira] [Updated] (FLINK-7588) Document RocksDB tuning for spinning disks - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/12 21:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7611) add metrics to measure the data drop by watermark - posted by "aitozi (JIRA)" <ji...@apache.org> on 2017/09/13 01:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7613) Fix documentation error in QuickStart - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/09/13 03:21:00 UTC, 0 replies.
- [GitHub] flink pull request #4666: [FLINK-7613][Documentation] Fixed typographical er... - posted by raymondtay <gi...@git.apache.org> on 2017/09/13 03:22:28 UTC, 4 replies.
- [jira] [Commented] (FLINK-7613) Fix documentation error in QuickStart - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/13 03:23:00 UTC, 7 replies.
- [GitHub] flink issue #4666: [FLINK-7613][Documentation] Fixed typographical error - posted by yew1eb <gi...@git.apache.org> on 2017/09/13 04:03:49 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4500) Cassandra sink can lose messages - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/13 07:55:00 UTC, 0 replies.
- [GitHub] flink issue #4535: [FLINK-7474] [ Streaming Connectors] AzureEventhubs-conne... - posted by tzulitai <gi...@git.apache.org> on 2017/09/13 09:00:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-7474) Flink supports consuming data from and sink data to Azure eventhubs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/13 09:00:18 UTC, 1 replies.
- [jira] [Created] (FLINK-7614) Add a code snippet example of a valid POJO to "Data Types" documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/13 09:26:00 UTC, 0 replies.
- [GitHub] flink issue #4657: [FLINK-7600][kinesis] shorten delay of KinesisProducerCon... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/13 17:11:35 UTC, 2 replies.
- [GitHub] flink issue #4656: [FLINK-7508][kinesis] switch FlinkKinesisProducer to use ... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/13 17:11:44 UTC, 3 replies.
- [jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/13 18:58:02 UTC, 3 replies.
- [jira] [Created] (FLINK-7615) Under mesos when using a role, TaskManagers fail to schedule - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2017/09/13 21:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7615) Under mesos when using a role, TaskManagers fail to schedule - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2017/09/13 21:10:01 UTC, 2 replies.
- [jira] [Closed] (FLINK-2395) Check Scala catch blocks for Throwable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/13 21:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7615) Under mesos when using a role, TaskManagers fail to schedule - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/09/13 23:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4256) Fine-grained recovery - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/09/14 00:36:04 UTC, 0 replies.
- [jira] [Created] (FLINK-7616) Fix missing markups in Execution Configuration - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/09/14 03:10:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-7616) Fix missing markups in Execution Configuration - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/09/14 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2017/09/14 05:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2017/09/14 05:55:01 UTC, 11 replies.
- [GitHub] flink pull request #4667: [FLINK-5859] [table] Add PartitionableTableSource ... - posted by godfreyhe <gi...@git.apache.org> on 2017/09/14 06:34:59 UTC, 8 replies.
- [jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 06:35:00 UTC, 9 replies.
- [GitHub] flink pull request #4668: [FLINK-7617] Remove string format in BitSet to imp... - posted by JingsongLi <gi...@git.apache.org> on 2017/09/14 06:45:27 UTC, 3 replies.
- [GitHub] flink issue #4668: [FLINK-7617] Remove string format in BitSet to improve th... - posted by JingsongLi <gi...@git.apache.org> on 2017/09/14 06:52:28 UTC, 4 replies.
- [GitHub] flink issue #4502: [FLINK-7062] [table, cep] Support the basic functionality... - posted by dianfu <gi...@git.apache.org> on 2017/09/14 07:00:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-7062) Support the basic functionality of MATCH_RECOGNIZE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 07:01:00 UTC, 0 replies.
- [GitHub] flink issue #4626: [FLINK-7561][streaming] Implement PreAggregationOperator - posted by pnowojski <gi...@git.apache.org> on 2017/09/14 07:20:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-7561) Add support for pre-aggregation in DataStream API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 07:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7614) Add a code snippet example of a valid POJO to "Data Types" documentation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/14 08:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7614) Add a code snippet example of a valid POJO to "Data Types" documentation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/14 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7618) Add BINARY supported in FlinkTypeFactory - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/09/14 08:43:00 UTC, 0 replies.
- [GitHub] flink pull request #4669: [FLINK-7618][table] Add BINARY supported in FlinkT... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/09/14 09:29:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-7618) Add BINARY supported in FlinkTypeFactory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 09:30:01 UTC, 1 replies.
- [jira] [Created] (FLINK-7619) Improve abstraction in AbstractAsyncIOCallable to better fit - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/09/14 09:32:00 UTC, 0 replies.
- [GitHub] flink pull request #4670: [FLINK-2170] [connectors] Add ORC connector for Ta... - posted by uybhatti <gi...@git.apache.org> on 2017/09/14 09:36:04 UTC, 27 replies.
- [jira] [Commented] (FLINK-2170) Add OrcTableSource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 09:37:00 UTC, 27 replies.
- [GitHub] flink pull request #3860: [FLINK-6516] [table] using real row count instead ... - posted by godfreyhe <gi...@git.apache.org> on 2017/09/14 09:38:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-6516) using real row count instead of dummy row count when optimizing plan - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 09:39:00 UTC, 0 replies.
- [GitHub] flink pull request #4597: [FLINK-7527] [rest] Let AbstractRestHandler extend... - posted by zentol <gi...@git.apache.org> on 2017/09/14 09:44:24 UTC, 10 replies.
- [GitHub] flink pull request #4671: [FLINK-7619] Improve abstraction in AbstractAsyncI... - posted by StefanRRichter <gi...@git.apache.org> on 2017/09/14 09:45:48 UTC, 5 replies.
- [jira] [Commented] (FLINK-7619) Improve abstraction in AbstractAsyncIOCallable to better fit - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 09:46:02 UTC, 8 replies.
- [GitHub] flink issue #4671: [FLINK-7619] Improve abstraction in AbstractAsyncIOCallab... - posted by StefanRRichter <gi...@git.apache.org> on 2017/09/14 09:46:05 UTC, 2 replies.
- [GitHub] flink pull request #: - posted by taizilongxu <gi...@git.apache.org> on 2017/09/14 11:18:16 UTC, 3 replies.
- [GitHub] flink pull request #4622: [FLINK-7294]:[flink-mesos] mesos.resourcemanager.f... - posted by asfgit <gi...@git.apache.org> on 2017/09/14 11:32:28 UTC, 0 replies.
- [jira] [Created] (FLINK-7620) Supports custom optimization phase - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/09/14 11:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7620) Supports custom optimization phase - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/09/14 11:55:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-7620) Supports user defined optimization phase - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/09/14 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7621) Fix inconsistency of CaseSensitive Configuration - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/09/14 12:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7621) Fix Inconsistency of CaseSensitive Configuration - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/09/14 12:19:00 UTC, 0 replies.
- [GitHub] flink pull request #4672: Flink 7621 - posted by Xpray <gi...@git.apache.org> on 2017/09/14 12:20:39 UTC, 0 replies.
- [GitHub] flink issue #4672: Flink 7621 - posted by fhueske <gi...@git.apache.org> on 2017/09/14 12:27:39 UTC, 0 replies.
- [jira] [Created] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/14 12:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/14 12:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/14 12:41:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/14 12:44:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/14 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/14 12:52:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7294) mesos.resourcemanager.framework.role not working - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/14 12:55:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/14 12:56:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7294) mesos.resourcemanager.framework.role not working - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/14 12:56:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5098) Detect network problems to eagerly time out ask operations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/14 12:58:00 UTC, 0 replies.
- [GitHub] flink pull request #2830: [FLINK-5098] [akka] Detect unreachable remote acto... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/14 12:58:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-5098) Detect network problems to eagerly time out ask operations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 12:59:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7625) typo in docs metrics sections - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/14 13:04:00 UTC, 0 replies.
- [GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf... - posted by twalthr <gi...@git.apache.org> on 2017/09/14 13:18:07 UTC, 53 replies.
- [GitHub] flink issue #4669: [FLINK-7618][table] Add BINARY supported in FlinkTypeFact... - posted by twalthr <gi...@git.apache.org> on 2017/09/14 13:23:07 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2253) ALS fails if the data flow is split up and the input is non-deterministic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/14 13:25:00 UTC, 0 replies.
- [GitHub] flink issue #4672: [Flink-7621][TableAPI & SQL] Fix Inconsistency of CaseSen... - posted by twalthr <gi...@git.apache.org> on 2017/09/14 13:27:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/14 13:30:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/14 13:30:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5205) Asynchronous remove job messages can interfere with recovered or resubmitted jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/14 13:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-6331) StreamingOperatorsITCase.testAsyncWaitOperator spuriously failing on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/14 13:32:00 UTC, 0 replies.
- [GitHub] flink issue #4665: [Flink-7611]add metrics to measure the num of data droppe... - posted by aljoscha <gi...@git.apache.org> on 2017/09/14 13:32:50 UTC, 10 replies.
- [GitHub] flink pull request #4658: [Flink-7596][Table API & SQL] fix bug when Set Ope... - posted by twalthr <gi...@git.apache.org> on 2017/09/14 13:33:11 UTC, 1 replies.
- [jira] [Created] (FLINK-7626) Add some metric description about checkpoints - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/14 13:42:00 UTC, 0 replies.
- [GitHub] flink pull request #3511: [Flink-5734] code generation for normalizedkey sor... - posted by ggevay <gi...@git.apache.org> on 2017/09/14 13:52:19 UTC, 36 replies.
- [jira] [Updated] (FLINK-7606) CEP operator leaks state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/14 13:59:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-7606) CEP operator leaks state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/14 14:00:02 UTC, 11 replies.
- [jira] [Updated] (FLINK-7607) Web Frontend Hangs with Large Numbers of Tasks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/14 14:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/14 14:05:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/14 14:45:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4796) Add new Sink interface with access to more meta data - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/14 14:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-4796) Add new Sink interface with access to more meta data - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/14 14:52:00 UTC, 1 replies.
- [GitHub] flink issue #4658: [Flink-7596][Table API & SQL] fix bug when Set Operation ... - posted by Xpray <gi...@git.apache.org> on 2017/09/14 15:14:22 UTC, 3 replies.
- [GitHub] flink pull request #4673: [hotfix] [cep] Fix afterMatchStrategy parameter mi... - posted by yestinchen <gi...@git.apache.org> on 2017/09/14 16:08:12 UTC, 1 replies.
- [GitHub] flink issue #4673: [hotfix] [cep] Fix afterMatchStrategy parameter missing i... - posted by yestinchen <gi...@git.apache.org> on 2017/09/14 20:56:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants - posted by "Chetna Chaudhari (JIRA)" <ji...@apache.org> on 2017/09/14 22:37:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/09/15 01:08:02 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7606) CEP operator leaks state - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/15 02:19:01 UTC, 3 replies.
- [jira] [Assigned] (FLINK-5858) Support multiple sinks in same execution DAG - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/09/15 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7627) SingleElementIterable should implement with Serializable - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2017/09/15 03:08:00 UTC, 0 replies.
- [GitHub] flink pull request #4674: [FLINK-7627] [table] SingleElementIterable should ... - posted by hequn8128 <gi...@git.apache.org> on 2017/09/15 04:40:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-7627) SingleElementIterable should implement with Serializable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 04:41:02 UTC, 3 replies.
- [GitHub] flink pull request #4675: [FLINK-7386] FIx Elasticsearch 5 connector is not ... - posted by zjureel <gi...@git.apache.org> on 2017/09/15 05:34:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 05:35:02 UTC, 2 replies.
- [GitHub] flink issue #4675: [FLINK-7386] FIx Elasticsearch 5 connector is not compati... - posted by zjureel <gi...@git.apache.org> on 2017/09/15 05:41:48 UTC, 1 replies.
- [GitHub] flink pull request #4676: [FLINK-7625] Fix typo in metrics part of documents - posted by yew1eb <gi...@git.apache.org> on 2017/09/15 06:12:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-7625) typo in docs metrics sections - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 06:13:00 UTC, 2 replies.
- [GitHub] flink pull request #4677: [FLINK-7626] Add some checkpoints metric descripti... - posted by yew1eb <gi...@git.apache.org> on 2017/09/15 06:59:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-7626) Add some metric description about checkpoints - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 07:00:00 UTC, 3 replies.
- [jira] [Created] (FLINK-7628) Add cookbooks to the documentation - posted by "James Lafa (JIRA)" <ji...@apache.org> on 2017/09/15 07:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7584) [Documentation] Add checkstyle version due to breaking change in the plugin - posted by "James Lafa (JIRA)" <ji...@apache.org> on 2017/09/15 09:03:00 UTC, 0 replies.
- [GitHub] flink pull request #4499: [FLINK-7394][core] Implement basic InputChannel fo... - posted by NicoK <gi...@git.apache.org> on 2017/09/15 09:15:45 UTC, 13 replies.
- [jira] [Commented] (FLINK-7394) Implement basic InputChannel for credit-based logic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 09:16:00 UTC, 15 replies.
- [GitHub] flink issue #4632: [FLINK-7563] [cep] Fix watermark semantics in cep and rel... - posted by dawidwys <gi...@git.apache.org> on 2017/09/15 09:56:10 UTC, 2 replies.
- [jira] [Commented] (FLINK-7563) Fix watermark semantics in CEP operators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 09:57:00 UTC, 4 replies.
- [jira] [Reopened] (FLINK-4796) Add new Sink interface with access to more meta data - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/15 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7629) Scala stream aggregations should support nested field expressions - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/15 11:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4498) Better Cassandra sink documentation - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/15 12:10:00 UTC, 0 replies.
- [GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu... - posted by fhueske <gi...@git.apache.org> on 2017/09/15 13:38:52 UTC, 20 replies.
- [jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 13:39:01 UTC, 21 replies.
- [GitHub] flink pull request #4405: [FLINK-7273] [gelly] Gelly tests with empty graphs - posted by asfgit <gi...@git.apache.org> on 2017/09/15 14:00:12 UTC, 0 replies.
- [GitHub] flink pull request #4346: [FLINK-7199] [gelly] Graph simplification does not... - posted by asfgit <gi...@git.apache.org> on 2017/09/15 14:00:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-7199) Graph simplification does not set parallelism - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 14:00:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-7273) Gelly tests with empty graphs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 14:00:14 UTC, 0 replies.
- [jira] [Created] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile() - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/09/15 14:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile() - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/09/15 14:45:00 UTC, 6 replies.
- [jira] [Commented] (FLINK-7447) Hope add more committer information to "Community & Project Info" page. - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/09/15 15:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7199) Graph simplification does not set parallelism - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/09/15 15:10:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-7199) Graph simplification does not set parallelism - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/09/15 15:10:03 UTC, 0 replies.
- [jira] [Closed] (FLINK-7273) Gelly tests with empty graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/09/15 15:11:00 UTC, 0 replies.
- [GitHub] flink pull request #4574: [FLINK-6864] Fix confusing "invalid POJO type" mes... - posted by greghogan <gi...@git.apache.org> on 2017/09/15 15:51:15 UTC, 2 replies.
- [jira] [Commented] (FLINK-6864) Remove confusing "invalid POJO type" messages from TypeExtractor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 15:52:00 UTC, 2 replies.
- [GitHub] flink pull request #4624: [FLINK-7410] [table] Use toString method to displa... - posted by greghogan <gi...@git.apache.org> on 2017/09/15 15:58:37 UTC, 1 replies.
- [jira] [Commented] (FLINK-7410) Use toString method to display operator names for UserDefinedFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 15:59:00 UTC, 2 replies.
- [GitHub] flink issue #4641: [hotfix][docs] Fix a typo on log name for quick start gui... - posted by greghogan <gi...@git.apache.org> on 2017/09/15 18:42:29 UTC, 0 replies.
- [GitHub] flink issue #4676: [FLINK-7625] Fix typo in metrics part of documents - posted by greghogan <gi...@git.apache.org> on 2017/09/15 19:28:19 UTC, 0 replies.
- [GitHub] flink pull request #4562: [FLINK-7402] Fix ineffective null check in NettyMe... - posted by asfgit <gi...@git.apache.org> on 2017/09/15 20:44:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-4498) Better Cassandra sink documentation - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/16 05:56:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7494) No license headers in ".travis.yml" file - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/16 09:12:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-7510) Move some connectors to Apache Bahir - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/09/16 09:14:03 UTC, 3 replies.
- [jira] [Closed] (FLINK-7625) typo in docs metrics sections - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/16 09:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/16 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7631) Ineffective check in PageRank#open() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/16 13:22:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4498) Better Cassandra sink documentation - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/16 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7632) Better documentation on C* sink usage for Pojo and Tuples data types - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/16 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7633) Better documentation on C* sink on consistency guarantee - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/16 14:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7632) Better documentation and examples on C* sink usage for Pojo and Tuples data types - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/16 14:43:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-7633) Better documentation on C* sink on consistency guarantee - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/16 14:57:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7447) Hope add more committer information to "Community & Project Info" page. - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/16 17:05:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7536) Add MongoDB Source/Sink for Flink Streaming - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/16 17:16:02 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6573) Flink MongoDB Connector - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/16 17:22:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7466) Add a flink connector for Apache RocketMQ - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/16 17:27:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-7402) Ineffective null check in NettyMessage#write() - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/09/16 19:50:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7634) Add option to create a savepoint while canceling a job in the dashboard - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/17 01:01:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-7438) Some classes are eclipsed by classes in package scala - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/17 01:20:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-7478) Update documentation for sql insert and api change in TableAPI & SQL - posted by "lincoln.lee (JIRA)" <ji...@apache.org> on 2017/09/17 07:25:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7478) Update documentation for sql insert and api change in TableAPI & SQL - posted by "lincoln.lee (JIRA)" <ji...@apache.org> on 2017/09/17 07:26:00 UTC, 0 replies.
- [GitHub] flink pull request #4678: [FLINK-7630] Allow passing a File or an InputStrea... - posted by tony810430 <gi...@git.apache.org> on 2017/09/17 07:51:35 UTC, 0 replies.
- [jira] [Closed] (FLINK-7557) Fix typo for s3a config in AWS deployment documentation - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/09/17 07:54:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-7626) Add some metric description about checkpoints - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/17 07:58:00 UTC, 0 replies.
- [GitHub] flink pull request #4618: [hotfix] [docs] Fix typo for s3a config in AWS dep... - posted by tony810430 <gi...@git.apache.org> on 2017/09/17 12:34:04 UTC, 0 replies.
- [GitHub] flink pull request #4679: [hotfix] [doc] Fix typo for s3a config in AWS depl... - posted by tony810430 <gi...@git.apache.org> on 2017/09/17 12:38:27 UTC, 1 replies.
- [GitHub] flink pull request #4632: [FLINK-7563] [cep] Fix watermark semantics in cep ... - posted by asfgit <gi...@git.apache.org> on 2017/09/17 16:16:51 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7563) Fix watermark semantics in CEP operators - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/09/17 16:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7629) Scala stream aggregations should support nested field expressions - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/17 17:13:02 UTC, 0 replies.
- [GitHub] flink pull request #4680: [FLINK-7629] [scala] Fix KeyedStream.aggregate for... - posted by ggevay <gi...@git.apache.org> on 2017/09/17 20:51:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-7629) Scala stream aggregations should support nested field expressions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/17 20:52:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2017/09/18 00:47:00 UTC, 0 replies.
- [GitHub] flink issue #4499: [FLINK-7394][core] Implement basic InputChannel for credi... - posted by zhijiangW <gi...@git.apache.org> on 2017/09/18 02:22:52 UTC, 1 replies.
- [GitHub] flink issue #4667: [FLINK-5859] [table] Add PartitionableTableSource for par... - posted by KurtYoung <gi...@git.apache.org> on 2017/09/18 02:26:31 UTC, 0 replies.
- [jira] [Updated] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile() - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/09/18 03:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/18 04:34:01 UTC, 2 replies.
- [jira] [Created] (FLINK-7636) Introduce Flink RelOptTable, and remove tableSource from all TableSourceScan node constructor - posted by "jingzhang (JIRA)" <ji...@apache.org> on 2017/09/18 06:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7636) Introduce Flink RelOptTable, and remove tableSource from all TableSourceScan node constructor - posted by "jingzhang (JIRA)" <ji...@apache.org> on 2017/09/18 07:07:00 UTC, 1 replies.
- [GitHub] flink issue #4674: [FLINK-7627] [table] SingleElementIterable should impleme... - posted by fhueske <gi...@git.apache.org> on 2017/09/18 08:46:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-5964) Change TypeSerializers to allow construction of immutable types - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2017/09/18 09:15:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/18 09:17:00 UTC, 0 replies.
- [GitHub] flink pull request #4599: [FLINK-7529] Retrieve complete REST address from g... - posted by zentol <gi...@git.apache.org> on 2017/09/18 11:10:31 UTC, 2 replies.
- [jira] [Commented] (FLINK-7529) Retrieve complete REST address from RestfulGateway - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/18 11:11:00 UTC, 3 replies.
- [GitHub] flink pull request #4600: [FLINK-7531] Move Flink legacy rest handler to fli... - posted by zentol <gi...@git.apache.org> on 2017/09/18 11:16:40 UTC, 4 replies.
- [jira] [Commented] (FLINK-7531) Move existing REST handler to flink-runtime - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/18 11:17:00 UTC, 5 replies.
- [GitHub] flink issue #4677: [FLINK-7626] Add some checkpoints metric description in d... - posted by zentol <gi...@git.apache.org> on 2017/09/18 11:38:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-7631) Ineffective check in PageRank#open() - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/09/18 12:44:00 UTC, 1 replies.
- [GitHub] flink pull request #4603: [FLINK-7534] Create LegacyRestHandlerAdapter for o... - posted by zentol <gi...@git.apache.org> on 2017/09/18 13:05:52 UTC, 14 replies.
- [jira] [Commented] (FLINK-7534) Create LegacyRestHandlerAdapter for the old REST handlers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/18 13:06:00 UTC, 15 replies.
- [jira] [Commented] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/18 13:11:00 UTC, 1 replies.
- [GitHub] flink issue #4549: [FLINK-7458] Generalize GatewayRetriever for WebRuntimeMo... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/18 13:15:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-7458) Generalize GatewayRetriever for WebRuntimeMonitor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/18 13:16:00 UTC, 1 replies.
- [GitHub] flink issue #4551: [FLINK-7459] Generalize Flink's redirection logic - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/18 13:16:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-7459) Introduce RedirectHandler for the WebRuntimeMonitor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/18 13:17:00 UTC, 1 replies.
- [GitHub] flink issue #4602: [FLINK-7533] Let LeaderGatewayRetriever retry failed gate... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/18 13:17:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-7533) Retry failed gateway retrievals in the LeaderGatewayRetriever - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/18 13:18:00 UTC, 7 replies.
- [GitHub] flink issue #4643: [FLINK-7580] Automatically retry failed gateway retrieval... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/18 13:19:14 UTC, 1 replies.
- [GitHub] flink pull request #4602: [FLINK-7533] Let LeaderGatewayRetriever retry fail... - posted by zentol <gi...@git.apache.org> on 2017/09/18 13:49:18 UTC, 6 replies.
- [jira] [Assigned] (FLINK-7530) Port existing REST handlers to support Flip-6 components - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/18 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7638) Port CurrentJobsOverviewHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/18 14:05:00 UTC, 0 replies.
- [GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl... - posted by zentol <gi...@git.apache.org> on 2017/09/18 17:23:29 UTC, 21 replies.
- [GitHub] flink pull request #4549: [FLINK-7458] Generalize GatewayRetriever for WebRu... - posted by asfgit <gi...@git.apache.org> on 2017/09/18 21:00:54 UTC, 0 replies.
- [jira] [Closed] (FLINK-7458) Generalize GatewayRetriever for WebRuntimeMonitor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/18 21:01:00 UTC, 0 replies.
- [GitHub] flink pull request #4551: [FLINK-7459] Generalize Flink's redirection logic - posted by asfgit <gi...@git.apache.org> on 2017/09/18 21:01:54 UTC, 0 replies.
- [jira] [Closed] (FLINK-7459) Introduce RedirectHandler for the WebRuntimeMonitor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/18 21:02:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7533) Retry failed gateway retrievals in the LeaderGatewayRetriever - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/18 21:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7580) Let LeaderGatewayRetriever implementations automatically retry failed gateway retrieval operations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/18 21:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7639) TaskExecutorITCase is flakey - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/18 21:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7639) TaskExecutorITCase is flakey - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/18 21:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/18 23:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7640) Dashboard should display information about JobManager cluster in HA mode - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/19 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7641) Loss of JobManager in HA mode should not cause jobs to fail - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/19 01:04:58 UTC, 0 replies.
- [GitHub] flink pull request #4681: [FLINK-7636][Table API & SQL]Introduce Flink RelOp... - posted by beyond1920 <gi...@git.apache.org> on 2017/09/19 02:37:30 UTC, 8 replies.
- [jira] [Commented] (FLINK-7636) Introduce Flink RelOptTable, and remove tableSource from all TableSourceScan node constructor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 02:38:00 UTC, 9 replies.
- [GitHub] flink pull request #4682: [FLINK-7620] [table] Supports user defined optimiz... - posted by godfreyhe <gi...@git.apache.org> on 2017/09/19 02:44:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-7620) Supports user defined optimization phase - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7642) Upgrade maven surefire plugin to 2.19.1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/19 03:41:00 UTC, 0 replies.
- [GitHub] flink pull request #4598: [FLINK-7528] Create DispatcherRestEndpoint and int... - posted by zentol <gi...@git.apache.org> on 2017/09/19 08:16:18 UTC, 10 replies.
- [jira] [Commented] (FLINK-7528) Create Dispatcher REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 08:17:00 UTC, 10 replies.
- [jira] [Closed] (FLINK-6383) Add versioning for AbstractStreamOperator state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/19 08:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/19 08:52:00 UTC, 0 replies.
- [GitHub] flink pull request #4601: [FLINK-7532] Add web content handler to Dispatcher... - posted by zentol <gi...@git.apache.org> on 2017/09/19 08:57:28 UTC, 5 replies.
- [jira] [Commented] (FLINK-7532) Add StaticFileServerHandler to DispatcherRestEndpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 08:58:00 UTC, 6 replies.
- [jira] [Closed] (FLINK-4858) Remove Legacy Checkpointing Interfaces - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/19 09:01:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7598) ineffective shaded artifacts checks in travis_mvn_watchdog.sh - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/19 09:16:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7609) WindowWordCount example doesn't print countWindow output with default configs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/19 09:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7064) test instability in WordCountMapreduceITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/19 09:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7487) test instability in ClassLoaderITCase (no resources available) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/19 09:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7548) Support watermark generation for TableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/19 10:20:00 UTC, 7 replies.
- [GitHub] flink issue #4599: [FLINK-7529] Retrieve complete REST address from gateway - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/19 12:51:29 UTC, 0 replies.
- [GitHub] flink issue #4600: [FLINK-7531] Move Flink legacy rest handler to flink-runt... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/19 12:52:43 UTC, 0 replies.
- [GitHub] flink issue #4601: [FLINK-7532] Add web content handler to DispatcherRestEnd... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/19 13:03:10 UTC, 0 replies.
- [GitHub] flink pull request #4543: [FLINK-7449] [docs] Additional documentation for i... - posted by alpinegizmo <gi...@git.apache.org> on 2017/09/19 13:33:03 UTC, 16 replies.
- [GitHub] flink issue #4591: [FLINK-7514][tests] fix BackPressureStatsTrackerITCase re... - posted by zentol <gi...@git.apache.org> on 2017/09/19 13:34:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 13:34:03 UTC, 16 replies.
- [jira] [Commented] (FLINK-7514) fix BackPressureStatsTrackerITCase releasing buffers twice - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 13:34:06 UTC, 5 replies.
- [GitHub] flink pull request #4683: [FLINK-5944] Support reading of Snappy files - posted by mlipkovich <gi...@git.apache.org> on 2017/09/19 13:37:52 UTC, 6 replies.
- [jira] [Closed] (FLINK-7583) Create singleton isntance for the content type header - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/19 13:59:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7581) Name netty threads of rest components - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/19 14:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/19 14:00:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-7635) Support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/19 14:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7635) Support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/19 14:11:00 UTC, 0 replies.
- [GitHub] flink issue #4678: [FLINK-7630] [Java API] Allow passing a File or an InputS... - posted by aljoscha <gi...@git.apache.org> on 2017/09/19 14:20:09 UTC, 2 replies.
- [jira] [Closed] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/19 15:05:01 UTC, 0 replies.
- [GitHub] flink pull request #4678: [FLINK-7630] [Java API] Allow passing a File or an... - posted by tony810430 <gi...@git.apache.org> on 2017/09/19 15:34:29 UTC, 0 replies.
- [jira] [Closed] (FLINK-6549) Improve error message for type mismatches with side outputs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/19 17:17:04 UTC, 1 replies.
- [GitHub] flink pull request #4684: [FLINK-7603][savepoint/doc] Document how to take a... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/19 17:49:45 UTC, 2 replies.
- [jira] [Commented] (FLINK-7603) Support within clause in MatchRecognize - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 17:50:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/19 21:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/19 21:29:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7527) Add redirection logic to AbstractRestHandler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/19 22:30:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7528) Create Dispatcher REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/19 22:35:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-7529) Retrieve complete REST address from RestfulGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/19 22:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7531) Move existing REST handler to flink-runtime - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/19 22:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7634) Add option to create a savepoint while canceling a job in the dashboard - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 00:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7626) Add some metric description about checkpoints - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 00:52:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-6444) Add a check that '@VisibleForTesting' methods are only used in tests - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 01:01:50 UTC, 1 replies.
- [jira] [Created] (FLINK-7644) Line the extra semicolon in the source code - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 01:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7644) Line the extra semicolon in the source code - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 01:08:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-6733) Remove commented out AvgAggregationFunction.java - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/09/20 01:24:02 UTC, 2 replies.
- [GitHub] flink pull request #4630: [FLINK-6733] Remove commented out AvgAggregationFu... - posted by asfgit <gi...@git.apache.org> on 2017/09/20 01:24:17 UTC, 0 replies.
- [jira] [Created] (FLINK-7645) Modify system-metrics part show in the document - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 02:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414 - posted by "Kent Murra (JIRA)" <ji...@apache.org> on 2017/09/20 02:50:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-6733) Remove commented out AvgAggregationFunction.java - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/09/20 03:46:03 UTC, 0 replies.
- [jira] [Reopened] (FLINK-6733) Remove commented out AvgAggregationFunction.java - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/09/20 03:46:03 UTC, 1 replies.
- [GitHub] flink pull request #4685: [hotfix] Fix typo for English spells in Debugging ... - posted by YMorisawa <gi...@git.apache.org> on 2017/09/20 03:47:21 UTC, 1 replies.
- [jira] [Created] (FLINK-7646) Restart failed jobs with configurable parallelism range - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/20 04:00:00 UTC, 0 replies.
- [GitHub] flink issue #4685: [hotfix] Fix typo for English spells in Debugging Classlo... - posted by zentol <gi...@git.apache.org> on 2017/09/20 07:21:53 UTC, 1 replies.
- [jira] [Assigned] (FLINK-7602) Create sub tasks for porting the remaining rest handlers - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 07:38:00 UTC, 1 replies.
- [GitHub] flink pull request #4521: [FLINK-7357] [table] Created extended rules for Wi... - posted by asfgit <gi...@git.apache.org> on 2017/09/20 08:14:32 UTC, 0 replies.
- [jira] [Closed] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/20 08:19:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7532) Add StaticFileServerHandler to DispatcherRestEndpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/20 08:37:00 UTC, 0 replies.
- [GitHub] flink issue #4603: [FLINK-7534] Create LegacyRestHandlerAdapter for old REST... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/20 08:37:14 UTC, 0 replies.
- [GitHub] flink pull request #4604: [FLINK-7535] Port DashboardConfigHandler to new RE... - posted by tzulitai <gi...@git.apache.org> on 2017/09/20 08:40:46 UTC, 7 replies.
- [jira] [Commented] (FLINK-7535) Port DashboardConfigHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 08:41:02 UTC, 8 replies.
- [jira] [Created] (FLINK-7647) Port JobManagerConfigHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 08:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7647) Port JobManagerConfigHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7648) Port TaskManagersHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7649) Port JobStoppingHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7650) Port JobCancellationHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7651) RetryingRegistration does not wait between failed connection attempts - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/20 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7653) Properly implement DispatcherGateway methods on the Dispatcher - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 09:28:00 UTC, 0 replies.
- [GitHub] flink pull request #4686: [FLINK-7651] [flip-6] Delay RetryingRegistration i... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/20 10:16:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-7651) RetryingRegistration does not wait between failed connection attempts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 10:17:00 UTC, 2 replies.
- [GitHub] flink issue #4564: [FLINK-7442] Add option for using child-first classloader... - posted by StephanEwen <gi...@git.apache.org> on 2017/09/20 10:18:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-7442) Add option for using a child-first classloader for loading user code - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 10:19:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7654) Update RabbitMQ Java client to 4.x - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7655) Revisit default non-leader id for FencedRpcEndpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/20 12:46:00 UTC, 0 replies.
- [GitHub] flink issue #4572: [Flink-7243] [connectors] Add ParquetInputFormat - posted by mustafaakin <gi...@git.apache.org> on 2017/09/20 13:14:14 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7608) LatencyGauge change to histogram metric - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 13:32:00 UTC, 0 replies.
- [GitHub] flink pull request #4572: [Flink-7243] [connectors] Add ParquetInputFormat - posted by fpompermaier <gi...@git.apache.org> on 2017/09/20 13:41:14 UTC, 1 replies.
- [GitHub] flink issue #4628: [FLINK-7486]:[flink-mesos]:Support for adding unique attr... - posted by bbayani <gi...@git.apache.org> on 2017/09/20 13:46:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-7486) flink-mesos: Support for adding unique attribute / group_by attribute constraints - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 13:47:00 UTC, 6 replies.
- [GitHub] flink pull request #4687: [hotfix][docs][CEP] wrong method name for PatternF... - posted by alpinegizmo <gi...@git.apache.org> on 2017/09/20 14:03:15 UTC, 1 replies.
- [jira] [Created] (FLINK-7656) Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/20 14:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/20 14:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/20 14:40:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/20 14:40:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/20 14:46:00 UTC, 1 replies.
- [GitHub] flink pull request #4688: [FLINK-7638] [flip6] Port CurrentJobsOverviewHandl... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/20 14:50:54 UTC, 13 replies.
- [jira] [Commented] (FLINK-7638) Port CurrentJobsOverviewHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 14:51:00 UTC, 16 replies.
- [GitHub] flink pull request #4689: [FLINK-7655] [flip6] Set fencing token to null if ... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/20 15:44:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-7655) Revisit default non-leader id for FencedRpcEndpoints - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 15:45:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-7534) Create LegacyRestHandlerAdapter for the old REST handlers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/20 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException - posted by "Kent Murra (JIRA)" <ji...@apache.org> on 2017/09/20 16:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException - posted by "Kent Murra (JIRA)" <ji...@apache.org> on 2017/09/20 16:07:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException - posted by "Kent Murra (JIRA)" <ji...@apache.org> on 2017/09/20 16:09:00 UTC, 9 replies.
- [jira] [Comment Edited] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException - posted by "Kent Murra (JIRA)" <ji...@apache.org> on 2017/09/20 16:13:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/20 16:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7486) flink-mesos: Support for adding unique attribute / group_by attribute constraints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/20 17:00:12 UTC, 0 replies.
- [GitHub] flink pull request #4690: [FLINK-7656] [runtime] Switch to user classloader ... - posted by fhueske <gi...@git.apache.org> on 2017/09/20 17:02:03 UTC, 2 replies.
- [jira] [Commented] (FLINK-7656) Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 17:03:00 UTC, 4 replies.
- [GitHub] flink pull request #4691: [FLINK-7647] [flip6] Port JobManagerConfigHandler ... - posted by tzulitai <gi...@git.apache.org> on 2017/09/20 17:21:28 UTC, 10 replies.
- [jira] [Commented] (FLINK-7647) Port JobManagerConfigHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 17:22:00 UTC, 15 replies.
- [GitHub] flink issue #4684: [FLINK-7603][savepoint/doc] Document how to take a savepo... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/20 18:17:14 UTC, 0 replies.
- [GitHub] flink pull request #4628: [FLINK-7486]:[flink-mesos]:Support for adding uniq... - posted by EronWright <gi...@git.apache.org> on 2017/09/20 18:38:49 UTC, 5 replies.
- [GitHub] flink issue #4635: [FLINK-7571] [table] Fix translation of TableSource with ... - posted by fhueske <gi...@git.apache.org> on 2017/09/20 18:53:41 UTC, 2 replies.
- [jira] [Created] (FLINK-7658) Support COLLECT Aggregate function in Flink TABLE API - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/09/20 20:29:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/20 21:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7635) Support sideOutput in ProcessWindowFunciton - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/21 05:21:00 UTC, 2 replies.
- [jira] [Created] (FLINK-7660) Support sideOutput in ProcessAllWindowFunction - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/21 05:24:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-7635) Support sideOutput in ProcessWindowFunciton - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/21 05:30:00 UTC, 9 replies.
- [GitHub] flink pull request #4692: [FLINK-7644][build] Drop unnecessary semicolon - posted by yew1eb <gi...@git.apache.org> on 2017/09/21 06:09:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-7644) Line the extra semicolon in the source code - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 06:10:00 UTC, 3 replies.
- [GitHub] flink pull request #4693: [FLINK-7645][docs] Modify system-metrics part show... - posted by yew1eb <gi...@git.apache.org> on 2017/09/21 06:21:13 UTC, 1 replies.
- [GitHub] flink issue #4693: [FLINK-7645][docs] Modify system-metrics part show in the... - posted by yew1eb <gi...@git.apache.org> on 2017/09/21 06:21:50 UTC, 3 replies.
- [jira] [Commented] (FLINK-7645) Modify system-metrics part show in the document - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 06:22:00 UTC, 5 replies.
- [GitHub] flink issue #4692: [FLINK-7644][build] Drop unnecessary semicolon - posted by fhueske <gi...@git.apache.org> on 2017/09/21 07:29:25 UTC, 1 replies.
- [GitHub] flink issue #4604: [FLINK-7535] Port DashboardConfigHandler to new REST endp... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/21 07:30:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-7535) Port DashboardConfigHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 07:32:00 UTC, 0 replies.
- [GitHub] flink issue #4686: [FLINK-7651] [flip-6] Delay RetryingRegistration in case ... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/21 07:32:07 UTC, 0 replies.
- [jira] [Closed] (FLINK-7651) RetryingRegistration does not wait between failed connection attempts - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 07:34:00 UTC, 0 replies.
- [GitHub] flink issue #4691: [FLINK-7647] [flip6] Port JobManagerConfigHandler to new ... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/21 07:41:08 UTC, 4 replies.
- [jira] [Updated] (FLINK-7378) Create a fix size (non rebalancing) buffer pool type for the floating buffers - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/09/21 08:20:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7661) Add credit field in PartitionRequest message - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/09/21 08:26:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-7661) Add credit field in PartitionRequest message - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/09/21 08:27:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-7650) Port JobCancellationHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 08:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6243) Continuous Joins: True Sliding Window Joins - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/09/21 08:45:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-4558) Add support for synchronizing streams - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/09/21 08:48:00 UTC, 0 replies.
- [GitHub] flink pull request #4694: [FLINK-7654][RabbitMQ Connector] Update RabbitMQ J... - posted by yew1eb <gi...@git.apache.org> on 2017/09/21 08:49:37 UTC, 1 replies.
- [jira] [Commented] (FLINK-7654) Update RabbitMQ Java client to 4.x - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 08:50:00 UTC, 9 replies.
- [GitHub] flink pull request #4695: Flink 7661 - posted by zhijiangW <gi...@git.apache.org> on 2017/09/21 09:45:32 UTC, 0 replies.
- [GitHub] flink pull request #4696: [FLINK-7632] [document] Overhaul on Cassandra conn... - posted by mcfongtw <gi...@git.apache.org> on 2017/09/21 11:31:17 UTC, 25 replies.
- [jira] [Commented] (FLINK-7632) Better documentation and examples on C* sink usage for Pojo and Tuples data types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 11:32:00 UTC, 27 replies.
- [jira] [Closed] (FLINK-7552) Extend SinkFunction interface with SinkContext - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/21 11:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7553) Use new SinkFunction interface in FlinkKafkaProducer010 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/21 11:52:00 UTC, 0 replies.
- [GitHub] flink pull request #4697: [FLINK-7650] [flip6] Port JobCancellationHandler t... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/21 12:05:53 UTC, 27 replies.
- [jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 12:06:00 UTC, 32 replies.
- [jira] [Closed] (FLINK-7644) Line the extra semicolon in the source code - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/21 12:33:00 UTC, 0 replies.
- [GitHub] flink pull request #4564: [FLINK-7442] Add option for using child-first clas... - posted by aljoscha <gi...@git.apache.org> on 2017/09/21 13:02:30 UTC, 0 replies.
- [GitHub] flink issue #4590: [FLINK-7513][tests] remove TestBufferFactory#MOCK_BUFFER - posted by NicoK <gi...@git.apache.org> on 2017/09/21 13:03:53 UTC, 1 replies.
- [jira] [Closed] (FLINK-7442) Add option for using a child-first classloader for loading user code - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/21 13:04:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7571) Execution of TableSources with Time Indicators fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/21 13:11:00 UTC, 0 replies.
- [GitHub] flink issue #4688: [FLINK-7638] [flip6] Port CurrentJobsOverviewHandler to n... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/21 13:13:40 UTC, 2 replies.
- [jira] [Assigned] (FLINK-7649) Port JobStoppingHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 13:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7649) Port JobStoppingHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 13:18:00 UTC, 0 replies.
- [GitHub] flink issue #4586: [FLINK-7502] [metrics] Improve PrometheusReporter - posted by mbode <gi...@git.apache.org> on 2017/09/21 13:19:21 UTC, 0 replies.
- [GitHub] flink pull request #4695: [FLINK-7661][network] Add credit field in Partitio... - posted by zhijiangW <gi...@git.apache.org> on 2017/09/21 14:21:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-7661) Add credit field in PartitionRequest message - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 14:22:00 UTC, 5 replies.
- [GitHub] flink pull request #4698: [FLINK-7661][network] Add credit field in Partitio... - posted by zhijiangW <gi...@git.apache.org> on 2017/09/21 14:23:10 UTC, 0 replies.
- [jira] [Created] (FLINK-7662) Remove unnecessary packaged licenses - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/09/21 14:45:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7648) Port TaskManagersHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/21 14:50:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/21 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7663) Allow AbstractRestHandler to handle bad requests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 15:12:00 UTC, 0 replies.
- [GitHub] flink pull request #4699: [FLINK-7663] [flip6] Return BAD_REQUEST if Handler... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/21 16:26:53 UTC, 9 replies.
- [jira] [Commented] (FLINK-7663) Allow AbstractRestHandler to handle bad requests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 16:27:00 UTC, 12 replies.
- [GitHub] flink pull request #4700: [FLINK-7649] [flip6] Extend JobTerminationHandler ... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/21 16:46:22 UTC, 3 replies.
- [jira] [Commented] (FLINK-7649) Port JobStoppingHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 16:47:00 UTC, 7 replies.
- [jira] [Created] (FLINK-7664) Replace FlinkFutureException by CompletionException - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 16:59:00 UTC, 0 replies.
- [GitHub] flink pull request #4701: [FLINK-7664] Replace FlinkFutureException by java.... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/21 17:24:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-7664) Replace FlinkFutureException by CompletionException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 17:25:00 UTC, 5 replies.
- [jira] [Created] (FLINK-7665) Use wait/notify in ContinuousFileReaderOperator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/21 19:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/21 20:00:00 UTC, 0 replies.
- [GitHub] flink issue #4689: [FLINK-7655] [flip6] Set fencing token to null if not lea... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/21 22:58:34 UTC, 0 replies.
- [jira] [Closed] (FLINK-7655) Revisit default non-leader id for FencedRpcEndpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 23:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 23:35:01 UTC, 5 replies.
- [GitHub] flink pull request #4702: [FLINK-7635][DataStream API][Scala API] Support si... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/22 02:03:16 UTC, 4 replies.
- [GitHub] flink issue #4702: [FLINK-7635][DataStream API][Scala API] Support sideOutpu... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/22 03:57:42 UTC, 3 replies.
- [jira] [Assigned] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 05:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 05:37:01 UTC, 0 replies.
- [GitHub] flink pull request #4703: [FLINK-7659][REST] Unprotected access to inProgres... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/22 05:39:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/22 05:40:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-5726) Add the RocketMQ plugin for the Apache Flink - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 06:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7592) How to close the output log like "Connected to JobManager at Actor" and "Job execution switched to status RUNNING."? - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 06:20:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-7433) Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 06:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7433) Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 06:24:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 06:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 06:41:00 UTC, 0 replies.
- [GitHub] flink pull request #4704: [hotfix] [docs] Update function name in DataStream... - posted by phiradet <gi...@git.apache.org> on 2017/09/22 06:46:29 UTC, 1 replies.
- [jira] [Created] (FLINK-7667) Add serializable AccessExecutionGraph implementation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/22 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/22 08:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7667) Add serializable AccessExecutionGraph implementation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/22 08:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7667) Add serializable AccessExecutionGraph implementation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/22 08:29:00 UTC, 8 replies.
- [jira] [Updated] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/22 08:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5787) Unable to run jobs uploaded from IE - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/09/22 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/09/22 09:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/22 09:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/09/22 09:19:00 UTC, 0 replies.
- [GitHub] flink issue #4681: [FLINK-7636][Table API & SQL]Introduce Flink RelOptTable,... - posted by beyond1920 <gi...@git.apache.org> on 2017/09/22 10:41:37 UTC, 0 replies.
- [GitHub] flink issue #4690: [FLINK-7656] [runtime] Switch to user classloader before ... - posted by fhueske <gi...@git.apache.org> on 2017/09/22 11:57:57 UTC, 1 replies.
- [jira] [Closed] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/22 12:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/22 12:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/22 12:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/22 12:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7537) Add InfluxDB Sink for Flink Streaming - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/22 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7670) typo in docs runtime section - posted by "Kewei SHANG (JIRA)" <ji...@apache.org> on 2017/09/22 13:20:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/22 13:39:00 UTC, 5 replies.
- [GitHub] flink pull request #4705: [FLINK-6444] [build] Add a check that '@VisibleFor... - posted by zhangminglei <gi...@git.apache.org> on 2017/09/22 13:46:34 UTC, 0 replies.
- [GitHub] flink pull request #4706: [FLINK-7670][doc] fix typo in docs runtime section - posted by keweishang <gi...@git.apache.org> on 2017/09/22 13:51:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-7670) typo in docs runtime section - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/22 13:52:00 UTC, 5 replies.
- [GitHub] flink issue #4696: [FLINK-7632] [document] Overhaul on Cassandra connector d... - posted by zentol <gi...@git.apache.org> on 2017/09/22 15:05:15 UTC, 1 replies.
- [GitHub] flink issue #4706: [FLINK-7670][doc] fix typo in docs runtime section - posted by zentol <gi...@git.apache.org> on 2017/09/22 15:07:05 UTC, 3 replies.
- [GitHub] flink pull request #4707: [hotfix] Add doc for window operators, fix typos a... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/22 18:44:21 UTC, 1 replies.
- [jira] [Created] (FLINK-7671) JobManagerCleanupITCase failed in build - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 21:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7672) Publish Kinesis connector to Maven Central? - posted by "Radoslaw Gruchalski (JIRA)" <ji...@apache.org> on 2017/09/22 21:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7672) Publish Kinesis connector to Maven Central? - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/22 21:36:00 UTC, 6 replies.
- [jira] [Resolved] (FLINK-7672) Publish Kinesis connector to Maven Central? - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/22 21:43:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7656) Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/22 22:00:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-7393) Move FlinkKinesisConsumerTest - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 23:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7393) Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 23:07:00 UTC, 0 replies.
- [GitHub] flink pull request #4708: [FLINK-7393][kinesis connector] Move unit tests th... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/22 23:15:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-7393) Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/22 23:16:03 UTC, 4 replies.
- [jira] [Created] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code - posted by "Radoslaw Gruchalski (JIRA)" <ji...@apache.org> on 2017/09/22 23:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code - posted by "Radoslaw Gruchalski (JIRA)" <ji...@apache.org> on 2017/09/22 23:19:00 UTC, 2 replies.
- [GitHub] flink issue #4701: [FLINK-7664] Replace FlinkFutureException by java.util.co... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/22 23:21:47 UTC, 1 replies.
- [GitHub] flink issue #4534: [FLINK-7358][table]Add implicitly converts support for Us... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/09/23 00:24:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-7358) Add implicitly converts support for User-defined function - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/23 00:25:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field - posted by "Bin Wang (JIRA)" <ji...@apache.org> on 2017/09/23 08:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/09/23 08:15:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7674) NullPointerException in ContinuousFileMonitoringFunction close - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/23 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/09/23 10:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/09/23 10:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/09/23 10:49:00 UTC, 2 replies.
- [GitHub] flink pull request #4709: [FLINK-7675] [metrics] LatestCompletedCheckpointEx... - posted by tony810430 <gi...@git.apache.org> on 2017/09/23 11:26:17 UTC, 1 replies.
- [jira] [Commented] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/23 11:27:02 UTC, 5 replies.
- [jira] [Created] (FLINK-7676) ContinuousFileMonitoringFunction fails with GoogleHadoopFileSystem - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/23 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7677) Add side outputs to ProcessWindowFunction - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/23 15:26:01 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/23 20:22:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7678) SQL UserDefineTableFunction does not take CompositeType input correctly - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/09/23 20:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7679) Upgrade maven enforcer plugin to 3.0.0-M1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/23 21:38:00 UTC, 0 replies.
- [GitHub] flink pull request #4710: [FLINK-7446] [table] Change DefinedRowtimeAttribut... - posted by fhueske <gi...@git.apache.org> on 2017/09/23 23:03:10 UTC, 12 replies.
- [GitHub] flink pull request #4128: [FLINK-6893][table]Add BIN supported in SQL - posted by sunjincheng121 <gi...@git.apache.org> on 2017/09/24 00:11:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-6893) Add BIN supported in SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/24 00:12:01 UTC, 3 replies.
- [jira] [Resolved] (FLINK-7677) Add side outputs to ProcessWindowFunction - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/24 00:34:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7674) NullPointerException in ContinuousFileMonitoringFunction close - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/24 01:24:00 UTC, 0 replies.
- [GitHub] flink pull request #4711: [FLINK-7674][Streaming Connectors] NullPointerExce... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/24 01:28:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-7674) NullPointerException in ContinuousFileMonitoringFunction close - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/24 01:29:00 UTC, 2 replies.
- [GitHub] flink issue #4556: [FLINK-6465][table]support FIRST_VALUE on Table API & SQL - posted by sunjincheng121 <gi...@git.apache.org> on 2017/09/24 02:54:08 UTC, 0 replies.
- [GitHub] flink issue #4652: [FLINK-7465][table]Add cardinality count for tableAPI and... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/09/24 03:00:02 UTC, 0 replies.
- [GitHub] flink issue #4210: [FLINK-7024][table]Add supported for selecting window pro... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/09/24 03:28:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-7024) Add supported for selecting window proctime/rowtime on row-based Tumble/Slide window - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/24 03:29:01 UTC, 0 replies.
- [GitHub] flink issue #4710: [FLINK-7446] [table] Change DefinedRowtimeAttribute to wo... - posted by haohui <gi...@git.apache.org> on 2017/09/24 07:42:47 UTC, 3 replies.
- [jira] [Commented] (FLINK-3986) Rename readFileStream from the StreamExecutionEnvironment - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/24 08:37:02 UTC, 1 replies.
- [jira] [Updated] (FLINK-3986) Rename readFileStream from the StreamExecutionEnvironment - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/24 08:39:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-3829) flink-java - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/24 09:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-3829) flink-java - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/24 10:57:00 UTC, 8 replies.
- [jira] [Assigned] (FLINK-3832) flink-streaming-scala - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/24 11:13:02 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3830) flink-scala - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/24 11:13:02 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3834) flink-statebackend-rocksdb - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/24 11:13:02 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3833) flink-test-utils - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/24 11:13:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-7677) Add side outputs to ProcessWindowFunction - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/24 14:35:01 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-6444) Add a check that '@VisibleForTesting' methods are only used in tests - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/24 15:43:00 UTC, 1 replies.
- [GitHub] flink pull request #4712: fix flink-clients undeclared/unused dependencies - posted by yew1eb <gi...@git.apache.org> on 2017/09/24 16:23:35 UTC, 0 replies.
- [jira] [Closed] (FLINK-3834) flink-statebackend-rocksdb - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/24 16:51:02 UTC, 0 replies.
- [GitHub] flink pull request #4713: [FLINK-3828][build] POM Cleanup flink-runtime - posted by yew1eb <gi...@git.apache.org> on 2017/09/24 17:09:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-3828) flink-runtime - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/24 17:10:01 UTC, 0 replies.
- [GitHub] flink pull request #4714: [FLINK-7577][build] POM Cleanup flink-core - posted by yew1eb <gi...@git.apache.org> on 2017/09/24 17:21:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-7577) flink-core - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/24 17:22:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-3830) flink-scala - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/24 17:24:02 UTC, 0 replies.
- [GitHub] flink pull request #4715: [FLINK-3830][build] POM Cleanup flink-scala - posted by yew1eb <gi...@git.apache.org> on 2017/09/24 17:33:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-3830) flink-scala - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/24 17:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-3833) flink-test-utils - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/24 17:37:00 UTC, 0 replies.
- [GitHub] flink pull request #4716: [FLINK-3833][build] POM Cleanup flink-test-utils - posted by yew1eb <gi...@git.apache.org> on 2017/09/24 17:46:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3833) flink-test-utils - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/24 17:47:00 UTC, 0 replies.
- [GitHub] flink pull request #4717: [FLINK-3831][build] POM Cleanup flink-streaming-ja... - posted by yew1eb <gi...@git.apache.org> on 2017/09/24 17:50:57 UTC, 0 replies.
- [jira] [Commented] (FLINK-3831) flink-streaming-java - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/24 17:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-3832) flink-streaming-scala - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/24 18:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7680) Add "Performance Tuning" section to docs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/24 18:06:01 UTC, 0 replies.
- [GitHub] flink pull request #4718: [FLINK-3832][build] POM Cleanup flink-streaming-sc... - posted by yew1eb <gi...@git.apache.org> on 2017/09/24 18:08:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3832) flink-streaming-scala - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/24 18:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7680) Add "Performance Tuning" section to docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/24 18:17:00 UTC, 0 replies.
- [GitHub] flink pull request #4719: [FLINK-3829][build] POM Cleanup flink-java - posted by yew1eb <gi...@git.apache.org> on 2017/09/24 18:17:12 UTC, 0 replies.
- [GitHub] flink issue #3511: [Flink-5734] code generation for normalizedkey sorter - posted by ggevay <gi...@git.apache.org> on 2017/09/24 19:05:23 UTC, 4 replies.
- [jira] [Resolved] (FLINK-6333) Utilize Bloomfilters in RocksDb - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/24 21:38:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings - posted by "Luffy Tsai (JIRA)" <ji...@apache.org> on 2017/09/25 00:02:32 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings - posted by "Luffy Tsai (JIRA)" <ji...@apache.org> on 2017/09/25 00:06:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3829) flink-java - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/25 01:15:01 UTC, 1 replies.
- [GitHub] flink issue #4708: [FLINK-7393][kinesis connector] Move unit tests that shou... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/25 01:38:10 UTC, 2 replies.
- [GitHub] flink pull request #4720: Release 1.3.2 rc3 - posted by yaochunnian <gi...@git.apache.org> on 2017/09/25 02:43:17 UTC, 1 replies.
- [jira] [Updated] (FLINK-7394) Implement basic InputChannel for credit-based logic - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/09/25 03:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7394) Manage exclusive buffers in RemoteInputChannel - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/09/25 03:56:00 UTC, 0 replies.
- [GitHub] flink pull request #4721: [FLINK-6703][savepoint/doc] Document how to take a... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/25 05:02:06 UTC, 0 replies.
- [GitHub] flink issue #4684: [FLINK-6703][savepoint/doc] Document how to take a savepo... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/25 05:03:24 UTC, 0 replies.
- [GitHub] flink pull request #4684: [FLINK-6703][savepoint/doc] Document how to take a... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/25 05:03:25 UTC, 0 replies.
- [GitHub] flink issue #4694: [FLINK-7654][RabbitMQ Connector] Update RabbitMQ Java cli... - posted by yew1eb <gi...@git.apache.org> on 2017/09/25 06:15:35 UTC, 7 replies.
- [GitHub] flink issue #4664: [FLINK-7562][web] Show uploaded-jars descending by upload... - posted by yew1eb <gi...@git.apache.org> on 2017/09/25 06:19:12 UTC, 1 replies.
- [GitHub] flink issue #4661: [FLINK-4831][metrics] Implement a slf4j metric reporter - posted by yew1eb <gi...@git.apache.org> on 2017/09/25 06:21:11 UTC, 1 replies.
- [GitHub] flink issue #4614: [FLINK-7547][build] AsyncFunction.scala extends Function,... - posted by yew1eb <gi...@git.apache.org> on 2017/09/25 06:30:07 UTC, 3 replies.
- [GitHub] flink issue #4570: [FLINK-7438][build]Remove useless import, avoid warnings - posted by yew1eb <gi...@git.apache.org> on 2017/09/25 06:31:38 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-3827) Flink modules include unused dependencies - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/25 07:15:00 UTC, 1 replies.
- [GitHub] flink issue #4679: [hotfix] [doc] Fix typo for s3a config in AWS deployment ... - posted by tony810430 <gi...@git.apache.org> on 2017/09/25 07:17:47 UTC, 5 replies.
- [GitHub] flink pull request #4544: [FLINK-7451] [table] Support non-ascii character l... - posted by haohui <gi...@git.apache.org> on 2017/09/25 07:21:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-7451) Query fails when non-ascii characters are used in string literals - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 07:22:00 UTC, 1 replies.
- [GitHub] flink issue #4720: Release 1.3.2 rc3 - posted by tzulitai <gi...@git.apache.org> on 2017/09/25 08:36:58 UTC, 1 replies.
- [GitHub] flink issue #4707: [hotfix] Add doc for window operators, fix typos and form... - posted by aljoscha <gi...@git.apache.org> on 2017/09/25 08:57:52 UTC, 1 replies.
- [GitHub] flink issue #4687: [hotfix][docs][CEP] wrong method name for PatternFlatSele... - posted by tzulitai <gi...@git.apache.org> on 2017/09/25 09:47:37 UTC, 0 replies.
- [GitHub] flink issue #4704: [hotfix] [docs] Update function name in DataStream API - posted by tzulitai <gi...@git.apache.org> on 2017/09/25 09:59:58 UTC, 1 replies.
- [jira] [Created] (FLINK-7681) Support arbitrary TypeInformation in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/25 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7682) Invalid state size formatting - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/09/25 12:08:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/25 12:23:00 UTC, 0 replies.
- [GitHub] flink issue #4358: [FLINK-7068][blob] change BlobService sub-classes for per... - posted by NicoK <gi...@git.apache.org> on 2017/09/25 13:00:07 UTC, 0 replies.
- [GitHub] flink issue #4612: [FLINK-7452] [types] Add helper methods for all built-in ... - posted by twalthr <gi...@git.apache.org> on 2017/09/25 13:03:06 UTC, 0 replies.
- [jira] [Created] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/25 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7684) Avoid multiple data copies in MergingWindowSet - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/25 14:07:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7684) Avoid multiple data copies in MergingWindowSet - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/25 14:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7684) Avoid multiple data copies in MergingWindowSet - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/25 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7685) CompilerException: "Bug: Logic for branching plans (non-tree plans) has an error, and does not track the re-joining of branches correctly" - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/25 14:18:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/25 14:34:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 14:39:00 UTC, 19 replies.
- [GitHub] flink pull request #4722: [FLINK-7683] Iterate over keys in KeyedStateBacken... - posted by pnowojski <gi...@git.apache.org> on 2017/09/25 14:39:01 UTC, 14 replies.
- [GitHub] flink pull request #4723: [FLINK-7684] Avoid data copies in MergingWindowSet - posted by pnowojski <gi...@git.apache.org> on 2017/09/25 15:20:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-7684) Avoid multiple data copies in MergingWindowSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 15:21:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-7524) Task "xxx" did not react to cancelling signal, but is stuck in method - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/09/25 15:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7619) Improve abstraction in AbstractAsyncIOCallable to better fit - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/09/25 15:53:01 UTC, 0 replies.
- [GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem... - posted by NicoK <gi...@git.apache.org> on 2017/09/25 16:03:11 UTC, 8 replies.
- [jira] [Commented] (FLINK-7394) Manage exclusive buffers in RemoteInputChannel - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 16:04:01 UTC, 9 replies.
- [GitHub] flink issue #4609: [FLINK-7541] Refactor StateAssignmentOperation - posted by StefanRRichter <gi...@git.apache.org> on 2017/09/25 16:15:08 UTC, 5 replies.
- [jira] [Commented] (FLINK-7541) Redistribute operator state using OperatorID - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 16:16:02 UTC, 7 replies.
- [jira] [Created] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/25 18:53:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7638) Port CurrentJobsOverviewHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/25 21:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7687) Clarify the master and slaves files are not necessary unless using the cluster start/stop scripts - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/25 22:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7688) ContaineredTaskManagerParameters sets off heap memory size incorrectly unlimited - posted by "Bill Liu (JIRA)" <ji...@apache.org> on 2017/09/26 01:13:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5176) Properly wait for component shutdown in Runner components - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/09/26 02:00:03 UTC, 0 replies.
- [GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct... - posted by shaoxuan-wang <gi...@git.apache.org> on 2017/09/26 03:48:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/26 03:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/26 04:29:00 UTC, 8 replies.
- [jira] [Created] (FLINK-7689) Instrument the Flink JDBC connector - posted by "Martin Eden (JIRA)" <ji...@apache.org> on 2017/09/26 06:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7689) Instrument the Flink JDBC sink - posted by "Martin Eden (JIRA)" <ji...@apache.org> on 2017/09/26 06:03:00 UTC, 1 replies.
- [GitHub] flink issue #4499: [FLINK-7394][core] Manage exclusive buffers in RemoteInpu... - posted by zhijiangW <gi...@git.apache.org> on 2017/09/26 06:24:08 UTC, 0 replies.
- [jira] [Created] (FLINK-7690) Do not call actorSystem.awaitTermination from the main akka message handling thread - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/09/26 07:05:00 UTC, 0 replies.
- [GitHub] flink pull request #4724: [FLINK-7690] [Cluster Management] Do not call acto... - posted by suez1224 <gi...@git.apache.org> on 2017/09/26 07:17:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-7690) Do not call actorSystem.awaitTermination from the main akka message handling thread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/26 07:18:01 UTC, 1 replies.
- [jira] [Assigned] (FLINK-7076) Implement container release to support dynamic scaling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/26 07:47:00 UTC, 0 replies.
- [GitHub] flink pull request #4725: [FLINK-7689] [Streaming Connectors] Added metrics ... - posted by asicoe <gi...@git.apache.org> on 2017/09/26 08:30:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-7689) Instrument the Flink JDBC sink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/26 08:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7690) Do not call actorSystem.awaitTermination from the main akka message handling thread - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/09/26 08:33:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7439) Support variable arguments for UDTF in SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/26 08:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7678) SQL UserDefineTableFunction does not take CompositeType input correctly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/26 09:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop - posted by "Vishnu Viswanath (JIRA)" <ji...@apache.org> on 2017/09/26 09:09:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7664) Replace FlinkFutureException by CompletionException - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/26 09:27:01 UTC, 0 replies.
- [GitHub] flink pull request #4726: [FLINK-7678] [table] Support composite inputs for ... - posted by twalthr <gi...@git.apache.org> on 2017/09/26 11:36:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-7678) SQL UserDefineTableFunction does not take CompositeType input correctly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/26 11:37:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7691) Remove ClassTag in Scala DataSet API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/26 12:51:00 UTC, 0 replies.
- [GitHub] flink issue #4709: [FLINK-7675] [metrics] LatestCompletedCheckpointExternalP... - posted by zentol <gi...@git.apache.org> on 2017/09/26 13:34:29 UTC, 2 replies.
- [jira] [Created] (FLINK-7692) Support user-defined variables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/26 13:56:00 UTC, 0 replies.
- [GitHub] flink pull request #4727: [FLINK-7667] [flip6] Use ArchivedExecutionGraph as... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/26 14:55:56 UTC, 3 replies.
- [GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/26 14:59:19 UTC, 34 replies.
- [jira] [Resolved] (FLINK-7596) fix bug when Set Operation handles ANY type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/26 15:00:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7596) fix bug when Set Operation handles ANY type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/26 15:00:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/26 15:00:09 UTC, 40 replies.
- [jira] [Created] (FLINK-7693) Adapt web frontend to use proper DELETE REST call for job termination - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/26 15:04:00 UTC, 0 replies.
- [GitHub] flink pull request #4570: [FLINK-7438][build]Remove useless import, avoid wa... - posted by yew1eb <gi...@git.apache.org> on 2017/09/26 15:40:57 UTC, 2 replies.
- [jira] [Assigned] (FLINK-7692) Support user-defined variables - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/09/26 16:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4047) Fix documentation about determinism of KeySelectors - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/26 16:14:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7670) typo in docs runtime section - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/26 16:15:01 UTC, 0 replies.
- [jira] [Reopened] (FLINK-7654) Update RabbitMQ Java client to 4.x - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/26 16:16:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7654) Update RabbitMQ Java client to 4.x - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/26 16:16:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-7647) Port JobManagerConfigHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/26 16:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7647) Port JobManagerConfigHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/26 16:17:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7393) Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/26 16:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7393) Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/26 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7694) Port JobMetricsHandler to new REST handler - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/26 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7695) Port JobConfigHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/26 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7696) Add projection push-down support for TableSources with time attributes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/26 17:36:00 UTC, 0 replies.
- [GitHub] flink issue #4722: [FLINK-7683] Iterate over keys in KeyedStateBackend - posted by bowenli86 <gi...@git.apache.org> on 2017/09/26 18:09:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-7549) CEP - Pattern not discovered if source streaming is very fast - posted by "Paolo Rendano (JIRA)" <ji...@apache.org> on 2017/09/26 23:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7694) Port JobMetricsHandler to new REST handler - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/27 04:19:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-7642) Upgrade maven surefire plugin to 2.19.1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/27 04:21:00 UTC, 0 replies.
- [GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop... - posted by suez1224 <gi...@git.apache.org> on 2017/09/27 05:45:44 UTC, 4 replies.
- [jira] [Created] (FLINK-7697) Add metrics for Elasticsearch Sink - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/27 06:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7697) Add metrics for Elasticsearch Sink - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/27 06:12:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-7426) Table API does not support null values in keys - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/27 08:09:00 UTC, 0 replies.
- [GitHub] flink issue #4698: [FLINK-7661][network] Add credit field in PartitionReques... - posted by NicoK <gi...@git.apache.org> on 2017/09/27 08:44:09 UTC, 3 replies.
- [jira] [Created] (FLINK-7698) Join with null literals leads to NPE - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/27 09:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7698) Join with null literals leads to NPE - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/27 09:35:00 UTC, 0 replies.
- [GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc... - posted by NicoK <gi...@git.apache.org> on 2017/09/27 09:43:05 UTC, 40 replies.
- [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 09:44:00 UTC, 43 replies.
- [jira] [Closed] (FLINK-6167) Consider removing ArchivedExecutionGraph classes - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/27 09:55:00 UTC, 0 replies.
- [GitHub] flink issue #4509: [FLINK-7406][network] Implement Netty receiver incoming p... - posted by zhijiangW <gi...@git.apache.org> on 2017/09/27 10:00:07 UTC, 2 replies.
- [jira] [Created] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/09/27 10:18:00 UTC, 0 replies.
- [GitHub] flink issue #4697: [FLINK-7650] [flip6] Port JobCancellationHandler to new R... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/27 10:31:10 UTC, 4 replies.
- [GitHub] flink issue #4700: [FLINK-7649] [flip6] Extend JobTerminationHandler to supp... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/27 10:33:35 UTC, 3 replies.
- [GitHub] flink pull request #4730: [hotfix] [REST] Various rest-related hotfixes - posted by zentol <gi...@git.apache.org> on 2017/09/27 10:55:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-7072) Create RESTful cluster endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 10:56:00 UTC, 2 replies.
- [jira] [Created] (FLINK-7700) State merging in RocksDB backend leaves old state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/27 11:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2268) Provide Flink binary release without Hadoop - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/27 11:11:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/27 11:11:01 UTC, 0 replies.
- [GitHub] flink pull request #4731: [FLINK-7700] Fix RocksDB state merging - posted by aljoscha <gi...@git.apache.org> on 2017/09/27 11:16:56 UTC, 2 replies.
- [jira] [Commented] (FLINK-7700) State merging in RocksDB backend leaves old state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 11:17:01 UTC, 4 replies.
- [GitHub] flink pull request #4732: [FLINK-7426] [table] Support null values in keys - posted by twalthr <gi...@git.apache.org> on 2017/09/27 11:17:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-7426) Table API does not support null values in keys - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 11:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/27 11:20:00 UTC, 0 replies.
- [GitHub] flink issue #4727: [FLINK-7667] [flip6] Use ArchivedExecutionGraph as serial... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/27 11:35:08 UTC, 3 replies.
- [jira] [Created] (FLINK-7701) IllegalArgumentException in Netty bootstrap with small memory state segment size - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/27 11:43:03 UTC, 0 replies.
- [GitHub] flink issue #4699: [FLINK-7663] [flip6] Return BAD_REQUEST if HandlerRequest... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/27 11:44:42 UTC, 2 replies.
- [jira] [Created] (FLINK-7702) Javadocs link broken - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/27 11:58:00 UTC, 0 replies.
- [GitHub] flink pull request #4733: [FLINK-7701][network] really fix watermark configu... - posted by NicoK <gi...@git.apache.org> on 2017/09/27 11:59:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-7701) IllegalArgumentException in Netty bootstrap with small memory state segment size - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 12:00:02 UTC, 0 replies.
- [GitHub] flink pull request #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to ... - posted by tzulitai <gi...@git.apache.org> on 2017/09/27 12:20:19 UTC, 2 replies.
- [jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 12:21:00 UTC, 4 replies.
- [GitHub] flink issue #4728: [FLINK-7668] Add ExecutionGraphCache for ExecutionGraph b... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/27 12:25:36 UTC, 5 replies.
- [GitHub] flink issue #4660: [FLINK-7050][table] Add support of RFC compliant CSV pars... - posted by uybhatti <gi...@git.apache.org> on 2017/09/27 13:07:57 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7698) Join with null literals leads to NPE - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/09/27 13:10:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7702) Javadocs link broken - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/27 13:15:00 UTC, 0 replies.
- [GitHub] flink issue #4447: [FLINK-7312][checkstyle] activate checkstyle for flink/co... - posted by NicoK <gi...@git.apache.org> on 2017/09/27 13:15:43 UTC, 4 replies.
- [jira] [Commented] (FLINK-7312) activate checkstyle for flink/core/memory/* - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 13:16:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-7702) Javadocs link broken - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/27 13:18:00 UTC, 0 replies.
- [GitHub] flink issue #4506: [FLINK-7400][cluster] fix off-heap limits set to conserva... - posted by NicoK <gi...@git.apache.org> on 2017/09/27 13:18:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-7400) off-heap limits set to conservatively in cluster environments - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 13:19:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-6949) Add ability to ship custom resource files to YARN cluster - posted by "Mikhail Pryakhin (JIRA)" <ji...@apache.org> on 2017/09/27 13:35:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-7697) Add metrics for Elasticsearch Sink - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/27 13:40:00 UTC, 0 replies.
- [GitHub] flink issue #4605: [FLINK-4500] [C* Connector] CassandraSinkBase implements ... - posted by mcfongtw <gi...@git.apache.org> on 2017/09/27 13:43:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-7702) Javadocs link broken - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/27 14:06:00 UTC, 0 replies.
- [GitHub] flink issue #4624: [FLINK-7410] [table] Use toString method to display opera... - posted by hequn8128 <gi...@git.apache.org> on 2017/09/27 14:14:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-7698) Join with null literals leads to NPE - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/09/27 14:34:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:47:00 UTC, 2 replies.
- [jira] [Created] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:47:00 UTC, 0 replies.
- [GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter... - posted by zhijiangW <gi...@git.apache.org> on 2017/09/27 14:47:06 UTC, 11 replies.
- [jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 14:48:00 UTC, 5 replies.
- [jira] [Created] (FLINK-7704) Port JobPlanHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7705) Port JobDetailsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7706) Port JobAccumulatorsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7707) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7708) Port CheckpointConfigHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7710) Port CheckpointStatsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7711) Port JarListHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:00:10 UTC, 0 replies.
- [jira] [Created] (FLINK-7712) Port JarDeleteHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:01:00 UTC, 0 replies.
- [GitHub] flink issue #4517: [FLINK-7411][network] minor performance improvements in N... - posted by NicoK <gi...@git.apache.org> on 2017/09/27 15:01:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7713) Port JarUploadHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7714) Port JarPlanHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7715) Port JarRunHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7717) Port TaskManagerMetricsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:08:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException - posted by "Martin Luy (JIRA)" <ji...@apache.org> on 2017/09/27 15:13:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException - posted by "Martin Luy (JIRA)" <ji...@apache.org> on 2017/09/27 15:13:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7715) Port JarRunHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7714) Port JarPlanHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7713) Port JarUploadHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7712) Port JarDeleteHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7711) Port JarListHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:22:00 UTC, 0 replies.
- [GitHub] flink pull request #4736: [FLINK-7371] [table] Add support for constant para... - posted by twalthr <gi...@git.apache.org> on 2017/09/27 15:31:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7719) Send checkpoint id to task as part of deployment descriptor when resuming - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/09/27 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7720) Centralize creation of backends and state related resources - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/09/27 15:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6950) Add ability to specify single jar files to be shipped to YARN - posted by "Mikhail Pryakhin (JIRA)" <ji...@apache.org> on 2017/09/27 15:53:01 UTC, 1 replies.
- [jira] [Closed] (FLINK-7663) Allow AbstractRestHandler to handle bad requests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/27 16:15:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/27 16:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/27 16:19:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7717) Port TaskManagerMetricsHandler to new REST endpoint - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/27 16:20:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/27 16:20:00 UTC, 0 replies.
- [GitHub] flink pull request #4737: [FLINK-7695] [flip6] Add JobConfigHandler for new ... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/27 16:28:09 UTC, 5 replies.
- [jira] [Commented] (FLINK-7695) Port JobConfigHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 16:29:00 UTC, 9 replies.
- [jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 16:32:01 UTC, 7 replies.
- [GitHub] flink issue #4571: [FLINK-7487][tests] fix ClassLoaderITCase#testDisposeSave... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/27 16:33:09 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7704) Port JobPlanHandler to new REST endpoint - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/27 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 18:05:00 UTC, 0 replies.
- [GitHub] flink pull request #4738: [FLINK-7721] [DataStream] Only emit new min waterm... - posted by tzulitai <gi...@git.apache.org> on 2017/09/27 18:15:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 18:16:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6950) Add ability to specify single jar files to be shipped to YARN - posted by "Mikhail Pryakhin (JIRA)" <ji...@apache.org> on 2017/09/27 19:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7720) Centralize creation of backends and state related resources - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/27 19:54:01 UTC, 2 replies.
- [jira] [Created] (FLINK-7722) MiniCluster does not appear to honor Log4j settings - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/27 20:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7722) MiniCluster does not appear to honor Log4j settings - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/27 20:38:01 UTC, 1 replies.
- [jira] [Assigned] (FLINK-6949) Add ability to ship custom resource files to YARN cluster - posted by "Mikhail Pryakhin (JIRA)" <ji...@apache.org> on 2017/09/27 21:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7723) DispatcherTest instable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/27 21:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7722) MiniCluster does not appear to honor Log4j settings - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/27 22:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7724) add extra metrics to MetricStoreTest.setupStore - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/27 22:13:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7723) DispatcherTest instable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/27 23:05:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7650) Port JobCancellationHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/27 23:08:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7649) Port JobStoppingHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/27 23:09:00 UTC, 0 replies.
- [GitHub] flink pull request #4739: [FLINK-7724][REST][Tests][Metrics] add extra metri... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/27 23:09:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-7724) add extra metrics to MetricStoreTest.setupStore - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 23:10:00 UTC, 3 replies.
- [GitHub] flink issue #4721: [FLINK-6703][savepoint/doc] Document how to take a savepo... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/27 23:25:06 UTC, 0 replies.
- [GitHub] flink issue #4739: [FLINK-7724][REST][Tests][Metrics] add extra metrics to M... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/27 23:25:25 UTC, 1 replies.
- [jira] [Closed] (FLINK-7635) Support sideOutput in ProcessWindowFunciton - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/27 23:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/28 01:34:01 UTC, 3 replies.
- [GitHub] flink pull request #4740: [FLINK-7660][DataStream API/Scala API] Support sid... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/28 06:15:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-7660) Support sideOutput in ProcessAllWindowFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/28 06:16:00 UTC, 1 replies.
- [GitHub] flink issue #4735: [FLINK-7699][core] Define the BufferListener interface to... - posted by zhijiangW <gi...@git.apache.org> on 2017/09/28 07:38:09 UTC, 1 replies.
- [jira] [Created] (FLINK-7725) Add test base for marshalling requests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7726) Move marshalling testbases out of legacy namespace - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 08:30:00 UTC, 0 replies.
- [GitHub] flink pull request #4741: [hotfix] [REST] Add testbase for requests / allow ... - posted by zentol <gi...@git.apache.org> on 2017/09/28 08:31:44 UTC, 0 replies.
- [GitHub] flink issue #4741: [hotfix] [REST] Add testbase for requests / allow excepti... - posted by tzulitai <gi...@git.apache.org> on 2017/09/28 08:53:07 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7411) minor performance improvements in NettyMessage - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/28 09:01:00 UTC, 0 replies.
- [GitHub] flink pull request #4591: [FLINK-7514][tests] fix BackPressureStatsTrackerIT... - posted by asfgit <gi...@git.apache.org> on 2017/09/28 09:01:31 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7487) test instability in ClassLoaderITCase (no resources available) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/28 09:02:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7513) remove TestBufferFactory#MOCK_BUFFER - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/28 09:02:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7514) fix BackPressureStatsTrackerITCase releasing buffers twice - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/28 09:02:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7487) test instability in ClassLoaderITCase (no resources available) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/28 09:02:01 UTC, 0 replies.
- [GitHub] flink issue #4741: [FLINK-7725] [REST] Add testbase for requests / allow exc... - posted by zentol <gi...@git.apache.org> on 2017/09/28 09:27:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-7725) Add test base for marshalling requests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/28 09:28:00 UTC, 1 replies.
- [GitHub] flink issue #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to new RES... - posted by tzulitai <gi...@git.apache.org> on 2017/09/28 10:22:42 UTC, 1 replies.
- [jira] [Closed] (FLINK-7724) add extra metrics to MetricStoreTest.setupStore - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 11:02:00 UTC, 0 replies.
- [GitHub] flink pull request #4664: [FLINK-7562][web] Show uploaded-jars descending by... - posted by asfgit <gi...@git.apache.org> on 2017/09/28 11:02:40 UTC, 0 replies.
- [GitHub] flink pull request #4741: [FLINK-7725] [REST] Add testbase for requests / al... - posted by zentol <gi...@git.apache.org> on 2017/09/28 11:02:51 UTC, 0 replies.
- [jira] [Closed] (FLINK-7645) Modify system-metrics part show in the document - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 11:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7725) Add test base for marshalling requests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 11:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7562) uploaded jars sort by upload-time on dashboard page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 11:05:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-6549) Improve error message for type mismatches with side outputs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 11:10:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-7626) Add some metric description about checkpoints - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 11:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 11:13:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 11:13:00 UTC, 0 replies.
- [GitHub] flink pull request #4742: [FLINK-7072] [REST] Add Flip-6 client for submit/j... - posted by zentol <gi...@git.apache.org> on 2017/09/28 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7727) Extend logging in file server handlers - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 12:18:00 UTC, 0 replies.
- [GitHub] flink pull request #4743: [FLINK-7727] [REST] Improve error logging in Stati... - posted by zentol <gi...@git.apache.org> on 2017/09/28 12:28:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-7727) Extend logging in file server handlers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/28 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7728) StatusWatermarkValve has different min watermark advancement behavior depending on the ordering inputs become idle - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/28 12:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/28 12:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7438) Some classes are eclipsed by classes in package scala - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 12:45:02 UTC, 0 replies.
- [GitHub] flink issue #4711: [FLINK-7674][Streaming Connectors] NullPointerException i... - posted by zentol <gi...@git.apache.org> on 2017/09/28 12:54:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-7674) NullPointerException in ContinuousFileMonitoringFunction close - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7729) Remove Scala 2.10 support; add Scala 2.12 support - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/28 12:58:00 UTC, 0 replies.
- [GitHub] flink issue #4737: [FLINK-7695] [flip6] Add JobConfigHandler for new RestSer... - posted by zentol <gi...@git.apache.org> on 2017/09/28 13:22:47 UTC, 3 replies.
- [jira] [Commented] (FLINK-7715) Port JarRunHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/28 13:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7708) Port CheckpointConfigHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/28 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/28 13:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7704) Port JobPlanHandler to new REST endpoint - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/28 14:06:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7731) Trigger on GlobalWindow does not clean state completely - posted by "Gerard Garcia (JIRA)" <ji...@apache.org> on 2017/09/28 14:12:03 UTC, 0 replies.
- [GitHub] flink pull request #4609: [FLINK-7541] Refactor StateAssignmentOperation - posted by asfgit <gi...@git.apache.org> on 2017/09/28 14:31:42 UTC, 0 replies.
- [GitHub] flink issue #4731: [FLINK-7700] Fix RocksDB state merging - posted by aljoscha <gi...@git.apache.org> on 2017/09/28 14:47:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-7525) Add config option to disable Cancel functionality on UI - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/09/28 14:48:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-7413) Release Hadoop 2.8.x convenience binaries for 1.3.x - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/28 14:59:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7732) test instability in Kafa end-to-end test (invalid Kafka offset) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/28 15:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7732) test instability in Kafa end-to-end test (invalid Kafka offset) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/28 15:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7733) test instability in Kafa end-to-end test (RetriableCommitFailedException) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/28 15:25:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7733) test instability in Kafa end-to-end test (RetriableCommitFailedException) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/28 15:25:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/28 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7734) test instability in ResourceManagerTest - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/28 15:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7734) test instability in ResourceManagerTest - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/28 15:36:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-7692) Support user-defined variables in Metrics - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/28 15:37:01 UTC, 0 replies.
- [GitHub] flink pull request #4614: [FLINK-7547][build] AsyncFunction.scala extends Fu... - posted by yew1eb <gi...@git.apache.org> on 2017/09/28 15:38:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7734) test instability in ResourceManagerTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/28 15:39:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-7732) Test instability in Kafka end-to-end test (invalid Kafka offset) - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2017/09/28 15:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/09/28 15:53:00 UTC, 0 replies.
- [GitHub] flink pull request #4744: [FLINK-7708] [flip6] Add CheckpointConfigHandler f... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/28 16:42:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-7708) Port CheckpointConfigHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/28 16:43:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-7734) test instability in ResourceManagerTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/28 16:56:00 UTC, 0 replies.
- [GitHub] flink issue #4518: [FLINK-7412][network] optimise NettyMessage.TaskEventRequ... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/28 17:00:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-7731) Trigger on GlobalWindow does not clean state completely - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/28 18:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7735) Improve date/time handling in publically-facing Expressions - posted by "Kent Murra (JIRA)" <ji...@apache.org> on 2017/09/28 18:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7736) Fix some of the alerts raised by lgtm.com - posted by "Malcolm Taylor (JIRA)" <ji...@apache.org> on 2017/09/28 18:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss - posted by "Ryan Hobbs (JIRA)" <ji...@apache.org> on 2017/09/28 19:11:01 UTC, 0 replies.
- [GitHub] flink pull request #4745: [FLINK-7720] [state backends] Centralize creation ... - posted by StefanRRichter <gi...@git.apache.org> on 2017/09/28 19:26:09 UTC, 0 replies.
- [GitHub] flink issue #4745: [FLINK-7720] [state backends] Centralize creation of back... - posted by StefanRRichter <gi...@git.apache.org> on 2017/09/28 19:26:59 UTC, 0 replies.
- [GitHub] flink pull request #4746: [FLINK-7657] [Table] Adding logic to convert RexLi... - posted by kmurra <gi...@git.apache.org> on 2017/09/29 02:26:47 UTC, 0 replies.
- [jira] [Created] (FLINK-7738) Create WebSocket handler (server) - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/09/29 03:15:08 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/09/29 06:20:01 UTC, 0 replies.
- [GitHub] flink issue #4740: [FLINK-7660][DataStream API/Scala API] Support sideOutput... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/29 07:29:43 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7706) Port JobAccumulatorsHandler to new REST endpoint - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/29 07:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7705) Port JobDetailsHandler to new REST endpoint - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/29 07:46:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/29 08:26:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/29 08:26:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7541) Redistribute operator state using OperatorID - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/29 08:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7541) Redistribute operator state using OperatorID - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/29 08:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7667) Add serializable AccessExecutionGraph implementation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/29 08:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7710) Port CheckpointStatsHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/29 08:39:01 UTC, 0 replies.
- [GitHub] flink pull request #4747: [FLINK-7728] [DataStream] Flush StatusWatermarkVal... - posted by tzulitai <gi...@git.apache.org> on 2017/09/29 09:34:57 UTC, 0 replies.
- [jira] [Commented] (FLINK-7728) StatusWatermarkValve has different min watermark advancement behavior depending on the ordering inputs become idle - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/29 09:35:00 UTC, 0 replies.
- [GitHub] flink pull request #4748: [hotfix][tests] Use G1GC for tests - posted by pnowojski <gi...@git.apache.org> on 2017/09/29 10:28:31 UTC, 0 replies.
- [jira] [Created] (FLINK-7739) Improve Kafka*ITCase tests stability - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/29 12:47:00 UTC, 0 replies.
- [GitHub] flink pull request #4749: [FLINK-7739][tests] Properly shutdown resources in... - posted by pnowojski <gi...@git.apache.org> on 2017/09/29 13:09:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/29 13:10:09 UTC, 1 replies.
- [GitHub] flink issue #4730: [hotfix] [REST] Various rest-related hotfixes - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/29 13:18:38 UTC, 0 replies.
- [GitHub] flink pull request #4750: [FLINK-7710] [flip6] Add CheckpointStatisticsHandl... - posted by tillrohrmann <gi...@git.apache.org> on 2017/09/29 13:26:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-7710) Port CheckpointStatsHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/29 13:27:00 UTC, 1 replies.
- [GitHub] flink pull request #4751: [FLINK-7739][kafka-tests] Throttle down data produ... - posted by pnowojski <gi...@git.apache.org> on 2017/09/29 13:38:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-7736) Fix some of the alerts raised by lgtm.com - posted by "Malcolm Taylor (JIRA)" <ji...@apache.org> on 2017/09/29 14:37:02 UTC, 0 replies.
- [GitHub] flink pull request #4752: [FLINK-7700] Fix RocksDB state merging on release-... - posted by aljoscha <gi...@git.apache.org> on 2017/09/29 15:06:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-7735) Improve date/time handling in publically-facing Expressions - posted by "Alexey Diomin (JIRA)" <ji...@apache.org> on 2017/09/29 15:44:00 UTC, 0 replies.
- [GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out... - posted by NicoK <gi...@git.apache.org> on 2017/09/29 16:30:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/29 16:31:00 UTC, 0 replies.
- [GitHub] flink issue #3359: [FLINK-5544][streaming] Add InternalTimerService implemen... - posted by EXPjbucher <gi...@git.apache.org> on 2017/09/29 18:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/29 18:31:02 UTC, 3 replies.
- [GitHub] flink pull request #3359: [FLINK-5544][streaming] Add InternalTimerService i... - posted by bowenli86 <gi...@git.apache.org> on 2017/09/29 19:07:42 UTC, 2 replies.
- [jira] [Created] (FLINK-7740) Add parameter support in CassandraInputFormat - posted by "Bin Wang (JIRA)" <ji...@apache.org> on 2017/09/29 19:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7741) Fix NPE when throw new SlotNotFoundException - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/30 06:17:00 UTC, 0 replies.
- [GitHub] flink pull request #4753: [FLINK-7741][build] Fix NPE when throw new SlotNot... - posted by yew1eb <gi...@git.apache.org> on 2017/09/30 06:23:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-7741) Fix NPE when throw new SlotNotFoundException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/30 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7742) Fix array access might be out of bounds - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/30 06:44:00 UTC, 0 replies.
- [GitHub] flink pull request #4754: [FLINK-7742] Fix array access might be out of boun... - posted by yew1eb <gi...@git.apache.org> on 2017/09/30 07:31:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-7742) Fix array access might be out of bounds - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/30 07:32:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7743) Remove the restriction of minimum memory of JM - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/09/30 17:26:00 UTC, 0 replies.
- [GitHub] flink issue #4188: [FLINK-7009] dogstatsd mode in statds reporter - posted by DerekV <gi...@git.apache.org> on 2017/09/30 22:33:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-7009) dogstatsd mode in statsd reporter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/30 22:34:02 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/09/30 22:44:00 UTC, 0 replies.