You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric - posted by "Cristian (JIRA)" <ji...@apache.org> on 2017/12/01 00:01:00 UTC, 13 replies.
- [jira] [Commented] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue. - posted by "Tao Xia (JIRA)" <ji...@apache.org> on 2017/12/01 04:27:00 UTC, 5 replies.
- [jira] [Created] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/01 05:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/01 05:20:00 UTC, 0 replies.
- [GitHub] flink pull request #5108: [FLINK-8181] [kafka] Make FlinkFixedPartitioner in... - posted by tzulitai <gi...@git.apache.org> on 2017/12/01 05:43:13 UTC, 9 replies.
- [jira] [Commented] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 05:44:00 UTC, 14 replies.
- [GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out... - posted by zhijiangW <gi...@git.apache.org> on 2017/12/01 06:41:50 UTC, 32 replies.
- [jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 06:42:00 UTC, 37 replies.
- [GitHub] flink issue #4533: [FLINK-7416][network] Implement Netty receiver outgoing p... - posted by zhijiangW <gi...@git.apache.org> on 2017/12/01 06:47:31 UTC, 4 replies.
- [GitHub] flink issue #4559: [FLINK-7468][network] Implement sender backlog logic for ... - posted by zhijiangW <gi...@git.apache.org> on 2017/12/01 08:07:54 UTC, 8 replies.
- [jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 08:08:00 UTC, 36 replies.
- [GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc... - posted by zhijiangW <gi...@git.apache.org> on 2017/12/01 08:11:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 08:12:00 UTC, 1 replies.
- [GitHub] flink issue #4509: [FLINK-7406][network] Implement Netty receiver incoming p... - posted by zhijiangW <gi...@git.apache.org> on 2017/12/01 08:19:32 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 08:51:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-8167) Failing WikipediaEditsSourceTest on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/01 09:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8175) remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/01 09:11:00 UTC, 6 replies.
- [jira] [Created] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/12/01 09:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/01 09:37:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/01 09:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/01 09:39:00 UTC, 7 replies.
- [GitHub] flink pull request #5099: [FLINK-8080][metrics] Remove need for "metrics.rep... - posted by zentol <gi...@git.apache.org> on 2017/12/01 10:36:59 UTC, 9 replies.
- [jira] [Commented] (FLINK-8080) Remove need for "metrics.reporters" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 10:37:00 UTC, 10 replies.
- [GitHub] flink issue #4552: [FLINK-7456][network] Implement Netty sender incoming pip... - posted by zhijiangW <gi...@git.apache.org> on 2017/12/01 10:44:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 10:45:00 UTC, 0 replies.
- [GitHub] flink pull request #5107: [FLINK-8176][flip6] Start SubmittedJobGraphStore i... - posted by GJL <gi...@git.apache.org> on 2017/12/01 11:07:11 UTC, 19 replies.
- [jira] [Commented] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 11:08:00 UTC, 20 replies.
- [jira] [Comment Edited] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException - posted by "Christos Hadjinikolis (JIRA)" <ji...@apache.org> on 2017/12/01 11:26:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8183) Add native Avro type support to the Table API & SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 11:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException - posted by "Miguel E. Coimbra (JIRA)" <ji...@apache.org> on 2017/12/01 11:53:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8184) Return raw JsonPlan instead of escaped string value in JobDetailsInfo - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/01 12:19:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8185) Make first level flattening optional for input and output - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 12:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2017/12/01 12:47:00 UTC, 6 replies.
- [GitHub] flink pull request #5109: [FLINK-8141] [flip6] Fix JsonPlan serialization in... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/01 12:49:19 UTC, 1 replies.
- [jira] [Commented] (FLINK-8141) Add AppendStreamTableSink for bucketed ORC files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 12:50:00 UTC, 3 replies.
- [jira] [Created] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2017/12/01 13:21:00 UTC, 0 replies.
- [GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log... - posted by NicoK <gi...@git.apache.org> on 2017/12/01 13:38:12 UTC, 27 replies.
- [jira] [Assigned] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/01 13:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2017/12/01 13:57:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2017/12/01 14:05:00 UTC, 3 replies.
- [GitHub] flink pull request #5110: [hotfix][docs] Fix typo in Checkpointing doc - posted by chuanlei <gi...@git.apache.org> on 2017/12/01 14:09:23 UTC, 1 replies.
- [GitHub] flink pull request #5111: [FLINK-8173] [table] Fix input unboxing and suppor... - posted by twalthr <gi...@git.apache.org> on 2017/12/01 14:41:36 UTC, 1 replies.
- [jira] [Created] (FLINK-8187) Web client does not print errors - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 15:24:00 UTC, 0 replies.
- [GitHub] flink issue #5076: [FLINK-7574][build] POM Cleanup flink-clients - posted by yew1eb <gi...@git.apache.org> on 2017/12/01 15:32:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-7574) Remove unused dependencies from flink-clients - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 15:33:00 UTC, 6 replies.
- [jira] [Updated] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2017/12/01 15:40:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 16:06:00 UTC, 21 replies.
- [GitHub] flink issue #5070: [FLINK-8151][table]Map equality check to use entrySet equ... - posted by twalthr <gi...@git.apache.org> on 2017/12/01 16:20:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-8151) [Table] Map equality check to use entrySet equality - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 16:21:00 UTC, 1 replies.
- [GitHub] flink issue #5111: [FLINK-8173] [table] Fix input unboxing and support Avro ... - posted by fhueske <gi...@git.apache.org> on 2017/12/01 16:35:19 UTC, 0 replies.
- [GitHub] flink pull request #5070: [FLINK-8151][table]Map equality check to use entry... - posted by asfgit <gi...@git.apache.org> on 2017/12/01 16:37:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8151) [Table] Map equality check to use entrySet equality - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 16:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 17:04:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 17:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7294) mesos.resourcemanager.framework.role not working - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/01 18:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8188) Clean up flink-contrib - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/01 19:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8175) remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/01 19:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8175) remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/01 19:41:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8189) move flink-statebackend-rocksdb out of flink-contrib - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/01 19:53:00 UTC, 0 replies.
- [GitHub] flink issue #4988: [FLINK-8030] Instantiate JobMasterRestEndpoint in JobClus... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/01 22:38:52 UTC, 2 replies.
- [jira] [Commented] (FLINK-8030) Start JobMasterRestEndpoint in JobClusterEntrypoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 22:39:00 UTC, 5 replies.
- [GitHub] flink issue #5109: [FLINK-8141] [flip6] Fix JsonPlan serialization in JobDet... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/01 23:10:43 UTC, 0 replies.
- [jira] [Closed] (FLINK-8184) Return raw JsonPlan instead of escaped string value in JobDetailsInfo - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/01 23:14:00 UTC, 0 replies.
- [GitHub] flink issue #4471: [FLINK-6094] [table] Implement stream-stream proctime non... - posted by hequn8128 <gi...@git.apache.org> on 2017/12/02 02:02:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/02 02:03:00 UTC, 7 replies.
- [GitHub] flink pull request #5112: [FLINK-8175] remove flink-streaming-contrib and mi... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/02 08:28:42 UTC, 0 replies.
- [GitHub] flink pull request #4757: [FLINK-7694][REST][Webfrontend]Port JobMetricsHand... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/02 08:34:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-7694) Port JobMetricsHandler to new REST handler - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/02 08:35:00 UTC, 0 replies.
- [GitHub] flink pull request #5048: [Flink-7871] [flip6] SlotPool should release unuse... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/02 16:02:21 UTC, 5 replies.
- [GitHub] flink pull request #4839: [FLINK-7851] [scheduling] Improve scheduling balan... - posted by asfgit <gi...@git.apache.org> on 2017/12/02 16:06:31 UTC, 0 replies.
- [GitHub] flink pull request #4986: [FLINK-8028] Let JobMaster implement RestfulGatewa... - posted by asfgit <gi...@git.apache.org> on 2017/12/02 16:06:35 UTC, 0 replies.
- [jira] [Closed] (FLINK-8028) Let JobMaster impelment RestfulGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/02 16:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7851) Improve scheduling balance in case of fewer sub tasks than input operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/02 16:07:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7851) Improve scheduling balance in case of fewer sub tasks than input operator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/02 16:07:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-8028) Let JobMaster impelment RestfulGateway - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/02 16:07:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-8177) Flink cannot be built for Hadoop 2.9.0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/02 16:48:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-8178) Introduce not threadsafe write only BufferBuilder - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/12/03 10:31:01 UTC, 0 replies.
- [GitHub] flink pull request #5113: [FLINK-8156][build] Bump commons-beanutils version... - posted by yew1eb <gi...@git.apache.org> on 2017/12/03 11:07:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-8156) Bump commons-beanutils version to 1.9.3 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/03 11:08:00 UTC, 3 replies.
- [GitHub] flink pull request #5114: [FLINK-8174] [mesos] Mesos RM unable to accept off... - posted by EronWright <gi...@git.apache.org> on 2017/12/03 11:30:48 UTC, 22 replies.
- [jira] [Commented] (FLINK-8174) Mesos RM unable to accept offers for unreserved resources - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/03 11:31:01 UTC, 28 replies.
- [GitHub] flink issue #5114: [FLINK-8174] [mesos] Mesos RM unable to accept offers for... - posted by EronWright <gi...@git.apache.org> on 2017/12/03 11:49:36 UTC, 5 replies.
- [GitHub] flink pull request #5115: [FLINK-7692] [metrics] Support user-defined variab... - posted by tony810430 <gi...@git.apache.org> on 2017/12/03 12:08:27 UTC, 19 replies.
- [jira] [Commented] (FLINK-7692) Support user-defined variables in Metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/03 12:09:00 UTC, 24 replies.
- [GitHub] flink issue #5108: [FLINK-8181] [kafka] Make FlinkFixedPartitioner insensiti... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/03 19:15:21 UTC, 3 replies.
- [jira] [Created] (FLINK-8190) Add extra FlinkKafkaConsumer constructors to expose pattern-based topic subscription functionality - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 06:55:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-8190) Add extra FlinkKafkaConsumer constructors to expose pattern-based topic subscription functionality - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 06:59:00 UTC, 2 replies.
- [GitHub] flink issue #5040: [FLINK-8104][Table API] fixing ROW type value constructor... - posted by twalthr <gi...@git.apache.org> on 2017/12/04 08:35:44 UTC, 0 replies.
- [jira] [Commented] (FLINK-8104) Fix Row value constructor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 08:36:00 UTC, 1 replies.
- [GitHub] flink issue #5099: [FLINK-8080][metrics] Remove need for "metrics.reporters"... - posted by zentol <gi...@git.apache.org> on 2017/12/04 08:56:02 UTC, 3 replies.
- [GitHub] flink pull request #5066: [FLINK-8148][yarn/s3] fix test instability in Yarn... - posted by asfgit <gi...@git.apache.org> on 2017/12/04 09:03:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-8148) Test instability in YarnFileStageTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 09:04:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8148) Test instability in YarnFileStageTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 09:06:00 UTC, 1 replies.
- [GitHub] flink issue #5110: [hotfix][docs] Fix typo in Checkpointing doc - posted by zentol <gi...@git.apache.org> on 2017/12/04 09:06:09 UTC, 0 replies.
- [GitHub] flink pull request #5040: [FLINK-8104][Table API] fixing ROW type value cons... - posted by asfgit <gi...@git.apache.org> on 2017/12/04 09:07:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8104) Fix Row value constructor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/04 09:09:00 UTC, 0 replies.
- [GitHub] flink issue #5071: [FLINK-7907][docs] The metrics documentation missing scal... - posted by zentol <gi...@git.apache.org> on 2017/12/04 09:09:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-7907) Flink Metrics documentation missing Scala examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 09:10:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-7907) Flink Metrics documentation missing Scala examples - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 09:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/04 09:21:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-7883) Stop fetching source before a cancel with savepoint - posted by "Antoine Philippot (JIRA)" <ji...@apache.org> on 2017/12/04 09:47:00 UTC, 0 replies.
- [GitHub] flink issue #5048: [Flink-7871] [flip6] SlotPool should release unused slots... - posted by ifndef-SleePy <gi...@git.apache.org> on 2017/12/04 10:11:28 UTC, 1 replies.
- [jira] [Assigned] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector - posted by "Aegeaner (JIRA)" <ji...@apache.org> on 2017/12/04 10:20:01 UTC, 0 replies.
- [GitHub] flink pull request #5116: [FLINK-8191] [Kafka Connector] Add a RoundRobinPar... - posted by Aegeaner <gi...@git.apache.org> on 2017/12/04 10:54:36 UTC, 6 replies.
- [jira] [Commented] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 10:55:00 UTC, 6 replies.
- [GitHub] flink pull request #5117: [FLINK-8190] [kafka] Add constructors to expose to... - posted by tzulitai <gi...@git.apache.org> on 2017/12/04 11:29:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-8190) Add extra FlinkKafkaConsumer constructors to expose pattern-based topic subscription functionality - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 11:30:00 UTC, 5 replies.
- [jira] [Updated] (FLINK-8164) JobManager's archiving does not work on S3 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 11:31:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8164) JobManager's archiving does not work on S3 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 11:39:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 11:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 11:41:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 11:44:00 UTC, 0 replies.
- [GitHub] flink pull request #4651: [FLINK-7595] [Savepoints] Allow removing stateless... - posted by asfgit <gi...@git.apache.org> on 2017/12/04 11:44:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8192) Properly annotate APIs of all Flink connectors with @Public / @PublicEvolving / @Internal - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 11:47:00 UTC, 0 replies.
- [GitHub] flink pull request #5071: [FLINK-7907][docs] The metrics documentation missi... - posted by yew1eb <gi...@git.apache.org> on 2017/12/04 11:49:30 UTC, 0 replies.
- [jira] [Created] (FLINK-8193) Rework quickstart exclusions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 12:36:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-8164) JobManager's archiving does not work on S3 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/04 12:54:00 UTC, 0 replies.
- [GitHub] flink pull request #5118: [FLINK-8193][quickstart] Cleanup quickstart poms - posted by zentol <gi...@git.apache.org> on 2017/12/04 13:08:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-8193) Rework quickstart exclusions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 13:09:00 UTC, 20 replies.
- [GitHub] flink issue #5117: [FLINK-8190] [kafka] Add constructors to expose topic pat... - posted by aljoscha <gi...@git.apache.org> on 2017/12/04 13:21:08 UTC, 1 replies.
- [GitHub] flink issue #5102: [FLINK-7762, FLINK-8167] Clean up and harden WikipediaEdi... - posted by zentol <gi...@git.apache.org> on 2017/12/04 13:28:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-7797) Add support for windowed outer joins for streaming tables - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/04 13:29:00 UTC, 20 replies.
- [jira] [Commented] (FLINK-7762) Make WikipediaEditsSourceTest a proper test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 13:29:00 UTC, 1 replies.
- [GitHub] flink pull request #5102: [FLINK-7762, FLINK-8167] Clean up and harden Wikip... - posted by asfgit <gi...@git.apache.org> on 2017/12/04 13:30:42 UTC, 0 replies.
- [jira] [Updated] (FLINK-8167) Failing WikipediaEditsSourceTest on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 13:31:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-7762) Make WikipediaEditsSourceTest a proper test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 13:31:00 UTC, 0 replies.
- [GitHub] flink pull request #5092: [FLINK-4812][metrics] Expose currentLowWatermark f... - posted by zentol <gi...@git.apache.org> on 2017/12/04 13:31:42 UTC, 0 replies.
- [jira] [Closed] (FLINK-8167) Failing WikipediaEditsSourceTest on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 13:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4812) Report Watermark metrics in all operators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 13:32:00 UTC, 20 replies.
- [GitHub] flink issue #5068: [FLINK-8122] [table] Name all built-in table sinks and so... - posted by xccui <gi...@git.apache.org> on 2017/12/04 13:32:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-8122) Name all table sinks and sources - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 13:33:00 UTC, 12 replies.
- [GitHub] flink pull request #5076: [FLINK-7574][build] POM Cleanup flink-clients - posted by zentol <gi...@git.apache.org> on 2017/12/04 13:34:55 UTC, 2 replies.
- [jira] [Closed] (FLINK-7395) NumBytesOut metric in RecordWriter call synchronized method - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 13:41:00 UTC, 0 replies.
- [GitHub] flink pull request #: - posted by zentol <gi...@git.apache.org> on 2017/12/04 13:41:46 UTC, 5 replies.
- [GitHub] flink pull request #4504: [FLINK-7395] [metrics] Count bytesIn/Out without s... - posted by asfgit <gi...@git.apache.org> on 2017/12/04 13:42:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-7395) NumBytesOut metric in RecordWriter call synchronized method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 13:43:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8177) Flink cannot be built for Hadoop 2.9.0 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/04 13:45:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-7467) a slow client on the BlobServer may block writing operations - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/04 14:18:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-6106) Blob Server doesn't delete tmp fold when exit in HA mode. - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/04 14:23:01 UTC, 2 replies.
- [jira] [Resolved] (FLINK-6106) Blob Server doesn't delete tmp fold when exit in HA mode. - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/04 14:28:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-6627) Expose tmp directories via API - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/04 14:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6627) Expose tmp directories via API - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/04 14:39:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-6528) Refactor BlobLibraryCacheManager <=> BlobServer/Cache <=> BlobStore hierarchy - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/04 14:50:00 UTC, 0 replies.
- [GitHub] flink pull request #5119: [FLINK-6590] Integrate automatic docs generation - posted by zentol <gi...@git.apache.org> on 2017/12/04 14:50:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-6590) Integrate generated tables into documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 14:51:00 UTC, 3 replies.
- [jira] [Closed] (FLINK-8148) Test instability in YarnFileStageTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 14:57:00 UTC, 0 replies.
- [GitHub] flink issue #3916: [FLINK-6590] Integrate automatic docs generation - posted by zentol <gi...@git.apache.org> on 2017/12/04 14:59:31 UTC, 0 replies.
- [GitHub] flink issue #4504: [FLINK-7395] [metrics] Count bytesIn/Out without synchron... - posted by NicoK <gi...@git.apache.org> on 2017/12/04 15:14:47 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/04 15:17:00 UTC, 0 replies.
- [GitHub] flink pull request #5120: [FLINK-8186] Exclude flink-avro from flink-dist; f... - posted by aljoscha <gi...@git.apache.org> on 2017/12/04 15:18:19 UTC, 1 replies.
- [GitHub] flink issue #5120: [FLINK-8186] Exclude flink-avro from flink-dist; fix Avro... - posted by zentol <gi...@git.apache.org> on 2017/12/04 15:23:22 UTC, 4 replies.
- [jira] [Created] (FLINK-8194) Disable akka.actor.warn-about-java-serializer-usage to suppress akka warnings when using the Java serializer - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/04 15:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8194) Disable akka.actor.warn-about-java-serializer-usage to suppress akka warnings when using the Java serializer - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/04 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8195) Add Redis Sink - posted by "Wind (JIRA)" <ji...@apache.org> on 2017/12/04 16:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8195) Add Redis Sink - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/04 16:12:00 UTC, 0 replies.
- [GitHub] flink issue #5118: [FLINK-8193][quickstart] Cleanup quickstart poms - posted by aljoscha <gi...@git.apache.org> on 2017/12/04 16:18:13 UTC, 18 replies.
- [jira] [Updated] (FLINK-8173) Fix input unboxing and support Avro Utf8 in Table API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/04 16:24:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8190) Add extra FlinkKafkaConsumer constructors to expose pattern-based topic subscription functionality - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 16:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8190) Add extra FlinkKafkaConsumer constructors to expose pattern-based topic subscription functionality - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 16:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8146) Potential resource leak in PythonPlanBinder#unzipPythonLibrary - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/04 17:30:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8100) Consider introducing log4j-extras - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/04 17:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/04 17:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8196) Fix Hadoop Servled Dependency Exclusion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/04 17:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8196) Fix Hadoop Servlet Dependency Exclusion - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/04 17:53:00 UTC, 0 replies.
- [GitHub] flink pull request #5121: [FLINK-8116] Stale comments referring to Checkpoin... - posted by ankitiitb1069 <gi...@git.apache.org> on 2017/12/04 19:05:14 UTC, 5 replies.
- [jira] [Commented] (FLINK-8116) Stale comments referring to Checkpointed interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 19:06:00 UTC, 7 replies.
- [GitHub] flink pull request #3916: [FLINK-6590] Integrate automatic docs generation - posted by zentol <gi...@git.apache.org> on 2017/12/04 19:11:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8197) Support include conf directories in flink config - posted by "Hao Sun (JIRA)" <ji...@apache.org> on 2017/12/04 20:13:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8196) Fix Hadoop Servlet Dependency Exclusion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/04 20:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8196) Fix Hadoop Servlet Dependency Exclusion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/04 20:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8197) Support include conf directories in flink config - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/04 23:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7129) Dynamically changing patterns - posted by "Che Lui Shum (JIRA)" <ji...@apache.org> on 2017/12/05 00:27:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8198) Useless check against -1 in LimitedConnectionsFileSystem#fromConfig - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/05 01:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8195) Add Redis Sink - posted by "Wind (JIRA)" <ji...@apache.org> on 2017/12/05 02:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8192) Properly annotate APIs of all Flink connectors with @Public / @PublicEvolving / @Internal - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/12/05 05:24:00 UTC, 4 replies.
- [GitHub] flink issue #3359: [FLINK-5544][streaming] Add InternalTimerService implemen... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/05 05:31:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8199) Annotation for Elasticsearch connector - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/12/05 05:49:00 UTC, 0 replies.
- [GitHub] flink issue #4976: [FLINK-8017] Fix High availability cluster-id key in docu... - posted by tony810430 <gi...@git.apache.org> on 2017/12/05 06:42:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-8017) High availability cluster-id option incorrect in documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 06:43:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8200) RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/12/05 07:02:00 UTC, 0 replies.
- [GitHub] flink pull request #5122: [FLINK-8200] RocksDBAsyncSnapshotTest should use t... - posted by wenlong88 <gi...@git.apache.org> on 2017/12/05 07:24:07 UTC, 2 replies.
- [jira] [Commented] (FLINK-8200) RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 07:25:00 UTC, 4 replies.
- [jira] [Assigned] (FLINK-8200) RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/12/05 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8201) YarnResourceManagerTest causes license checking failure - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/12/05 07:54:00 UTC, 0 replies.
- [GitHub] flink pull request #5123: [FLINK-8201] YarnResourceManagerTest causes licens... - posted by wenlong88 <gi...@git.apache.org> on 2017/12/05 07:58:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-8201) YarnResourceManagerTest causes license checking failure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 07:59:00 UTC, 4 replies.
- [jira] [Assigned] (FLINK-8201) YarnResourceManagerTest causes license checking failure - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/12/05 08:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8199) Annotation for Elasticsearch connector - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/12/05 08:25:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8199) Annotation for Elasticsearch connector - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/12/05 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8202) Update queryable section on configuration page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/05 08:48:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8202) Update queryable section on configuration page - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/12/05 08:48:00 UTC, 0 replies.
- [GitHub] flink pull request #5098: [FLINK-8007][metrics] Move TestMeter/-Histogram in... - posted by aljoscha <gi...@git.apache.org> on 2017/12/05 08:51:33 UTC, 3 replies.
- [jira] [Commented] (FLINK-8007) Move TestMeter class to test scope - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 08:52:01 UTC, 4 replies.
- [GitHub] flink pull request #5062: [FLINK-7880][QS] Wait for proper resource cleanup ... - posted by kl0u <gi...@git.apache.org> on 2017/12/05 09:14:27 UTC, 19 replies.
- [jira] [Commented] (FLINK-7880) flink-queryable-state-java fails with core-dump - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 09:15:00 UTC, 21 replies.
- [GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I... - posted by senorcarbone <gi...@git.apache.org> on 2017/12/05 09:35:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 09:36:00 UTC, 0 replies.
- [GitHub] flink pull request #5124: [FLINK-8199] [elasticsearch connector] Properly an... - posted by zhangminglei <gi...@git.apache.org> on 2017/12/05 09:37:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-8199) Annotation for Elasticsearch connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 09:38:00 UTC, 4 replies.
- [GitHub] flink issue #5119: [FLINK-6590] Integrate automatic docs generation - posted by alpinegizmo <gi...@git.apache.org> on 2017/12/05 09:45:45 UTC, 0 replies.
- [GitHub] flink issue #5123: [FLINK-8201] YarnResourceManagerTest causes license check... - posted by aljoscha <gi...@git.apache.org> on 2017/12/05 10:05:09 UTC, 3 replies.
- [jira] [Updated] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/05 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8203) Make schema definition of DataStream/DataSet to Table conversion more flexible - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/05 10:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8203) Make schema definition of DataStream/DataSet to Table conversion more flexible - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/05 10:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8198) Useless check against -1 in LimitedConnectionsFileSystem#fromConfig - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/05 11:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8198) Useless check against -1 in LimitedConnectionsFileSystem#fromConfig - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/05 11:05:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-8198) Useless check against -1 in LimitedConnectionsFileSystem#fromConfig - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/05 12:22:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-8198) Useless check against -1 in LimitedConnectionsFileSystem#fromConfig - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/05 12:22:02 UTC, 0 replies.
- [GitHub] flink pull request #5125: [WIP][FLINK-4812][metrics] Expose currentLowWaterm... - posted by zentol <gi...@git.apache.org> on 2017/12/05 13:28:17 UTC, 14 replies.
- [GitHub] flink issue #5098: [FLINK-8007][metrics] Move TestMeter/-Histogram into metr... - posted by zentol <gi...@git.apache.org> on 2017/12/05 13:31:22 UTC, 0 replies.
- [jira] [Closed] (FLINK-8007) Move TestMeter class to test scope - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/05 13:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint() - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/05 13:59:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint() - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/05 14:00:01 UTC, 0 replies.
- [GitHub] flink pull request #5087: [FLINK-8085] Thin out LogicalSlot interface - posted by GJL <gi...@git.apache.org> on 2017/12/05 14:08:12 UTC, 16 replies.
- [jira] [Commented] (FLINK-8085) Thin out the LogicalSlot interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 14:09:00 UTC, 16 replies.
- [jira] [Created] (FLINK-8204) Failing JobManagerLeaderSessionIDITCase on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/05 14:21:00 UTC, 0 replies.
- [GitHub] flink pull request #5068: [FLINK-8122] [table] Name all built-in table sinks... - posted by twalthr <gi...@git.apache.org> on 2017/12/05 14:28:20 UTC, 9 replies.
- [jira] [Closed] (FLINK-8164) JobManager's archiving does not work on S3 - posted by "Cristian (JIRA)" <ji...@apache.org> on 2017/12/05 14:29:00 UTC, 0 replies.
- [GitHub] flink issue #5115: [FLINK-7692] [metrics] Support user-defined variables in ... - posted by tony810430 <gi...@git.apache.org> on 2017/12/05 14:31:31 UTC, 4 replies.
- [jira] [Closed] (FLINK-8204) Failing JobManagerLeaderSessionIDITCase on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/05 14:33:00 UTC, 0 replies.
- [GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/05 14:49:49 UTC, 10 replies.
- [jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 14:50:01 UTC, 12 replies.
- [GitHub] flink pull request #5065: [FLINK-8139][table] Check for proper equals() and ... - posted by twalthr <gi...@git.apache.org> on 2017/12/05 15:05:42 UTC, 9 replies.
- [jira] [Commented] (FLINK-8139) Check for proper equals() and hashCode() when registering a table - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 15:06:00 UTC, 10 replies.
- [GitHub] flink issue #5122: [FLINK-8200] RocksDBAsyncSnapshotTest should use temp fol... - posted by wenlong88 <gi...@git.apache.org> on 2017/12/05 15:20:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/05 15:54:00 UTC, 0 replies.
- [GitHub] flink issue #5125: [WIP][FLINK-4812][metrics] Expose currentLowWatermark for... - posted by aljoscha <gi...@git.apache.org> on 2017/12/05 16:45:51 UTC, 1 replies.
- [GitHub] flink pull request #5126: [FLINK-5506] [gelly] Fix CommunityDetection NullPo... - posted by greghogan <gi...@git.apache.org> on 2017/12/05 22:04:49 UTC, 1 replies.
- [jira] [Closed] (FLINK-6528) Refactor BlobLibraryCacheManager <=> BlobServer/Cache <=> BlobStore hierarchy - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/06 08:34:00 UTC, 0 replies.
- [GitHub] flink pull request #5100: [FLINK-4812][metrics] Expose currentLowWatermark f... - posted by zentol <gi...@git.apache.org> on 2017/12/06 08:35:32 UTC, 0 replies.
- [GitHub] flink issue #5100: [FLINK-4812][metrics] Expose currentLowWatermark for all ... - posted by zentol <gi...@git.apache.org> on 2017/12/06 08:35:32 UTC, 0 replies.
- [jira] [Closed] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/06 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8205) Multi key get - posted by "Martin Eden (JIRA)" <ji...@apache.org> on 2017/12/06 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8206) Clean up and refactor RecordWriter Tests - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8207) Unify TestPooledBufferProvider and TestInfinityBufferProvider - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 09:50:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-6750) Table API / SQL Docs: Table Sources & Sinks Page - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/06 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8208) Reduce mockito usage in RecordWriterTest - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8209) Do not relay on specific method names in LocalBufferPoolTest - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8210) Do not use mockito for collecting results in MockEnvironment - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8211) Rename ResultPartitionWriter to OutputGate - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8212) Pull EnvironmentInformation out of TaskManagerServices - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/06 10:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8212) Pull EnvironmentInformation out of TaskManagerServices - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/06 10:16:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-7749) Refactor the ResultPartitionWriter to interface - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 10:31:01 UTC, 1 replies.
- [jira] [Closed] (FLINK-8193) Rework quickstart exclusions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/06 10:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8174) Mesos RM unable to accept offers for unreserved resources - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/06 10:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7749) Refactor the ResultPartitionWriter into an interface - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/06 10:59:00 UTC, 1 replies.
- [GitHub] flink pull request #4991: [FLINK-7928] [runtime] extend the resources in Res... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/06 11:31:56 UTC, 7 replies.
- [jira] [Commented] (FLINK-7928) Extend the filed in ResourceProfile for precisely calculating the resource of a task manager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 11:32:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-8205) Multi key get - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/12/06 11:35:00 UTC, 6 replies.
- [jira] [Closed] (FLINK-8211) Rename ResultPartitionWriter to OutputGate - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 12:12:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint() - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/06 12:27:00 UTC, 0 replies.
- [GitHub] flink issue #5062: [FLINK-7880][QS] Wait for proper resource cleanup after e... - posted by zentol <gi...@git.apache.org> on 2017/12/06 12:58:54 UTC, 1 replies.
- [jira] [Created] (FLINK-8213) Prevent potential metric-related ClassCastExceptions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/06 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8214) Do not use mockito for collecting results in StreamMockEnvironment - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 14:49:00 UTC, 0 replies.
- [GitHub] flink pull request #5088: [FLINK-8087] Decouple Slot from AllocatedSlot - posted by GJL <gi...@git.apache.org> on 2017/12/06 14:53:49 UTC, 8 replies.
- [jira] [Updated] (FLINK-8205) Multi key get - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/12/06 14:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8087) Decouple Slot from SlotPool - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 14:54:00 UTC, 9 replies.
- [jira] [Closed] (FLINK-7880) flink-queryable-state-java fails with core-dump - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/12/06 15:45:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7975) Queryable state client does not wait for shutdown completion - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/12/06 15:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/12/06 15:46:00 UTC, 0 replies.
- [GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ... - posted by kl0u <gi...@git.apache.org> on 2017/12/06 15:46:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 15:47:00 UTC, 1 replies.
- [GitHub] flink issue #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in QS clie... - posted by kl0u <gi...@git.apache.org> on 2017/12/06 15:47:12 UTC, 0 replies.
- [GitHub] flink pull request #5127: [FLINK-7749][network] refactor the ResultPartition... - posted by NicoK <gi...@git.apache.org> on 2017/12/06 16:33:43 UTC, 2 replies.
- [jira] [Commented] (FLINK-7749) Refactor the ResultPartitionWriter into an interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 16:34:00 UTC, 5 replies.
- [GitHub] flink issue #4762: [FLINK-7749][network] remove the ResultPartitionWriter wr... - posted by NicoK <gi...@git.apache.org> on 2017/12/06 16:34:26 UTC, 0 replies.
- [GitHub] flink pull request #4762: [FLINK-7749][network] remove the ResultPartitionWr... - posted by NicoK <gi...@git.apache.org> on 2017/12/06 16:34:26 UTC, 0 replies.
- [GitHub] flink issue #4759: [FLINK-7746][network] move ResultPartitionWriter#writeBuf... - posted by NicoK <gi...@git.apache.org> on 2017/12/06 16:37:10 UTC, 0 replies.
- [GitHub] flink pull request #4759: [FLINK-7746][network] move ResultPartitionWriter#w... - posted by NicoK <gi...@git.apache.org> on 2017/12/06 16:37:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-7746) move ResultPartitionWriter#writeBufferToAllChannels up into ResultPartition - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 16:38:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-8120) Cannot access Web UI from YARN application overview in FLIP-6 mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/06 16:56:00 UTC, 0 replies.
- [GitHub] flink pull request #5128: [FLINK-8120] [flip6] Register Yarn application wit... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/06 17:04:17 UTC, 1 replies.
- [jira] [Commented] (FLINK-8120) Cannot access Web UI from YARN application overview in FLIP-6 mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 17:05:00 UTC, 2 replies.
- [GitHub] flink pull request #5129: [Hotfix for State doc in 1.4 and 1.5] update State... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/06 19:39:29 UTC, 1 replies.
- [jira] [Created] (FLINK-8215) Collections codegen exception when constructing Array or Map via SQL API - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/12/07 00:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/07 02:55:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8216) Unify test utils in flink-connector-kinesis - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/07 07:21:01 UTC, 0 replies.
- [GitHub] flink pull request #5130: [FLINK-8216] Unify test utils in flink-connector-k... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/07 07:25:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-8216) Unify test utils in flink-connector-kinesis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 07:26:00 UTC, 4 replies.
- [jira] [Created] (FLINK-8217) Properly annotate APIs of flink-connector-kinesis - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/07 07:30:00 UTC, 0 replies.
- [GitHub] flink issue #5069: [FLINK-8149][kinesis] Replace usages of deprecated Serial... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/07 07:37:42 UTC, 2 replies.
- [jira] [Commented] (FLINK-8149) Replace usages of deprecated SerializationSchema - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 07:38:00 UTC, 2 replies.
- [jira] [Created] (FLINK-8218) move flink-connector-kinesis examples from /src to /test - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/07 07:56:00 UTC, 0 replies.
- [GitHub] flink issue #5129: [Hotfix for State doc in 1.4 and 1.5] update State's doc ... - posted by tzulitai <gi...@git.apache.org> on 2017/12/07 08:01:44 UTC, 2 replies.
- [GitHub] flink pull request #5131: [FLINK-8218] move flink-connector-kinesis examples... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/07 08:06:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-8218) move flink-connector-kinesis examples from /src to /test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 08:07:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-8215) Collections codegen exception when constructing Array or Map via SQL API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/07 09:19:00 UTC, 3 replies.
- [GitHub] flink issue #5052: [FLINK-8133][REST][docs] Generate REST API documentation - posted by kl0u <gi...@git.apache.org> on 2017/12/07 09:54:02 UTC, 2 replies.
- [jira] [Commented] (FLINK-8133) Generate documentation for new REST API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 09:55:00 UTC, 13 replies.
- [jira] [Comment Edited] (FLINK-8205) Multi key get - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/12/07 10:14:00 UTC, 2 replies.
- [GitHub] flink issue #5065: [FLINK-8139][table] Check for proper equals() and hashCod... - posted by fhueske <gi...@git.apache.org> on 2017/12/07 10:16:40 UTC, 0 replies.
- [GitHub] flink pull request #5052: [FLINK-8133][REST][docs] Generate REST API documen... - posted by kl0u <gi...@git.apache.org> on 2017/12/07 10:35:09 UTC, 10 replies.
- [jira] [Assigned] (FLINK-7681) Support arbitrary TypeInformation in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/07 11:16:00 UTC, 0 replies.
- [GitHub] flink pull request #5047: Code refine of WordWithCount - posted by harborl <gi...@git.apache.org> on 2017/12/07 11:24:05 UTC, 0 replies.
- [GitHub] flink pull request #5090: [FLINK-8089] Also check for other pending slot req... - posted by GJL <gi...@git.apache.org> on 2017/12/07 11:25:41 UTC, 4 replies.
- [jira] [Commented] (FLINK-8089) Fulfil slot requests with unused offered slots - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 11:26:00 UTC, 5 replies.
- [GitHub] flink pull request #5132: [FLINK-8203] [FLINK-7681] [table] Make schema defi... - posted by twalthr <gi...@git.apache.org> on 2017/12/07 11:30:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-8203) Make schema definition of DataStream/DataSet to Table conversion more flexible - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 11:31:00 UTC, 0 replies.
- [GitHub] flink issue #4626: [FLINK-7561][streaming] Implement PreAggregationOperator - posted by StephanEwen <gi...@git.apache.org> on 2017/12/07 11:48:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-7561) Add support for pre-aggregation in DataStream API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 11:49:00 UTC, 1 replies.
- [GitHub] flink pull request #5091: [FLINK-7956] [flip6] Add support for queued schedu... - posted by GJL <gi...@git.apache.org> on 2017/12/07 12:04:47 UTC, 39 replies.
- [jira] [Commented] (FLINK-7956) Add support for scheduling with slot sharing - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 12:05:00 UTC, 40 replies.
- [GitHub] flink pull request #4801: [FLINK-7812] Log system resources metrics - posted by StephanEwen <gi...@git.apache.org> on 2017/12/07 12:12:15 UTC, 4 replies.
- [jira] [Commented] (FLINK-7812) Log system resources as metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 12:13:00 UTC, 4 replies.
- [GitHub] flink issue #4723: [FLINK-7684] Avoid data copies in MergingWindowSet - posted by StephanEwen <gi...@git.apache.org> on 2017/12/07 12:21:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-7684) Avoid multiple data copies in MergingWindowSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 12:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8133) Generate documentation for new REST API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/07 12:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" - posted by "dongtingting (JIRA)" <ji...@apache.org> on 2017/12/07 13:23:00 UTC, 0 replies.
- [GitHub] flink pull request #5133: [hotfix] Fix typo in AkkaUtils method - posted by casidiablo <gi...@git.apache.org> on 2017/12/07 13:59:47 UTC, 0 replies.
- [GitHub] flink issue #5073: [FLINK-8124] Make Trigger implementations more generic - posted by casidiablo <gi...@git.apache.org> on 2017/12/07 14:01:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-8124) EventTimeTrigger (and other triggers) could have less specific generic types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 14:02:00 UTC, 0 replies.
- [GitHub] flink issue #5133: [hotfix] Fix typo in AkkaUtils method - posted by yew1eb <gi...@git.apache.org> on 2017/12/07 14:09:06 UTC, 4 replies.
- [jira] [Created] (FLINK-8219) Kinesis Connector metrics - posted by "Gary Oslon (JIRA)" <ji...@apache.org> on 2017/12/07 14:11:00 UTC, 0 replies.
- [GitHub] flink issue #5086: [FLINK-8078] Introduce LogicalSlot interface - posted by GJL <gi...@git.apache.org> on 2017/12/07 14:29:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-8078) Decouple Execution from actual slot implementation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 14:30:00 UTC, 2 replies.
- [jira] [Created] (FLINK-8220) Define set of network throughput benchmarks in Flink - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/07 15:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8220) Define set of network throughput benchmarks in Flink - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/07 15:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8220) Implement set of network throughput benchmarks in Flink - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/07 15:12:00 UTC, 2 replies.
- [jira] [Created] (FLINK-8221) Implement set of network latency benchmarks in Flink - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/07 15:12:00 UTC, 0 replies.
- [GitHub] flink pull request #5134: [FLINK-8220] Implement set of network benchmarks - posted by pnowojski <gi...@git.apache.org> on 2017/12/07 15:24:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-8220) Implement set of network throughput benchmarks in Flink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 15:25:00 UTC, 13 replies.
- [GitHub] flink issue #5134: [FLINK-8220] Implement set of network benchmarks - posted by zentol <gi...@git.apache.org> on 2017/12/07 16:13:30 UTC, 11 replies.
- [GitHub] flink issue #5047: Code refine of WordWithCount - posted by harborl <gi...@git.apache.org> on 2017/12/07 17:14:47 UTC, 0 replies.
- [jira] [Created] (FLINK-8222) Update Scala version - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/07 18:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8223) Update Hadoop versions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/07 18:29:00 UTC, 0 replies.
- [GitHub] flink pull request #5135: [hotfix] [doc] Fix typo in TaskManager and Environ... - posted by casidiablo <gi...@git.apache.org> on 2017/12/07 19:00:57 UTC, 2 replies.
- [GitHub] flink issue #5072: [FLINK-7984][build] Bump snappy-java to 1.1.4 - posted by greghogan <gi...@git.apache.org> on 2017/12/07 20:16:49 UTC, 4 replies.
- [jira] [Commented] (FLINK-7984) Bump snappy-java to 1.1.4 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 20:17:00 UTC, 4 replies.
- [GitHub] flink pull request #5136: [FLINK-8222] [build] Update Scala version - posted by greghogan <gi...@git.apache.org> on 2017/12/07 20:30:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-8222) Update Scala version - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 20:31:00 UTC, 3 replies.
- [GitHub] flink pull request #5137: [FLINK-8223] [build] Update Hadoop versions - posted by greghogan <gi...@git.apache.org> on 2017/12/07 21:37:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-8223) Update Hadoop versions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 21:38:00 UTC, 2 replies.
- [GitHub] flink issue #4911: [FLINK-7878] [api] make resource type extendible in Resou... - posted by shuai-xu <gi...@git.apache.org> on 2017/12/08 02:21:53 UTC, 1 replies.
- [jira] [Closed] (FLINK-8076) Upgrade KinesisProducer to 0.10.6 to set properties approperiately - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/08 06:10:00 UTC, 0 replies.
- [GitHub] flink pull request #5138: [FLINK-8192] Properly annotate APIs of flink-conne... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/08 06:17:40 UTC, 0 replies.
- [GitHub] flink issue #5112: [FLINK-8175] remove flink-streaming-contrib and migrate i... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/08 06:21:57 UTC, 0 replies.
- [jira] [Created] (FLINK-8225) Use JsonRowDeserializationSchema without Kafka connector dependency - posted by "Sendoh (JIRA)" <ji...@apache.org> on 2017/12/08 09:38:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8224) Should shudownApplication when job terminated in job mode - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/08 09:38:03 UTC, 0 replies.
- [GitHub] flink pull request #5139: [FLINK-8224] [runtime] shutdown application when j... - posted by shuai-xu <gi...@git.apache.org> on 2017/12/08 10:11:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-8224) Should shudownApplication when job terminated in job mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/08 10:12:00 UTC, 0 replies.
- [GitHub] flink issue #5138: [FLINK-8192] [Kinesis connector] Properly annotate APIs o... - posted by greghogan <gi...@git.apache.org> on 2017/12/08 13:41:30 UTC, 0 replies.
- [GitHub] flink pull request #4988: [FLINK-8030] Instantiate JobMasterRestEndpoint in ... - posted by GJL <gi...@git.apache.org> on 2017/12/08 15:07:51 UTC, 2 replies.
- [GitHub] flink pull request #4987: [FLINK-8029] Create WebMonitorEndpoint - posted by GJL <gi...@git.apache.org> on 2017/12/08 15:24:43 UTC, 3 replies.
- [jira] [Commented] (FLINK-8029) Create common WebMonitorEndpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/08 15:25:00 UTC, 4 replies.
- [GitHub] flink pull request #5140: [FLINK-7797] [table] Add support for windowed oute... - posted by xccui <gi...@git.apache.org> on 2017/12/09 02:29:33 UTC, 17 replies.
- [jira] [Created] (FLINK-8226) Dangling reference generated after NFA clean up timed out SharedBufferEntry - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/12/09 02:55:01 UTC, 0 replies.
- [GitHub] flink pull request #5141: [FLINK-8226] [cep] Dangling reference generated af... - posted by dianfu <gi...@git.apache.org> on 2017/12/09 03:01:17 UTC, 6 replies.
- [jira] [Commented] (FLINK-8226) Dangling reference generated after NFA clean up timed out SharedBufferEntry - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/09 03:02:00 UTC, 8 replies.
- [jira] [Created] (FLINK-8227) Optimize the performance of SharedBufferSerializer - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/12/09 03:49:01 UTC, 0 replies.
- [GitHub] flink pull request #5142: [FLINK-8227] Optimize the performance of SharedBuf... - posted by dianfu <gi...@git.apache.org> on 2017/12/09 03:53:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-8227) Optimize the performance of SharedBufferSerializer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/09 03:54:00 UTC, 8 replies.
- [GitHub] flink issue #5138: [FLINK-8217] [Kinesis connector] Properly annotate APIs o... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/09 06:02:28 UTC, 6 replies.
- [jira] [Commented] (FLINK-8217) Properly annotate APIs of flink-connector-kinesis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/09 06:03:00 UTC, 8 replies.
- [jira] [Created] (FLINK-8228) Code cleanup - pointless bitwise expressions - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/12/09 08:16:02 UTC, 0 replies.
- [GitHub] flink pull request #5143: [FLINK-8228][cleanup] Code cleanup - pointless bit... - posted by yew1eb <gi...@git.apache.org> on 2017/12/09 08:24:51 UTC, 1 replies.
- [jira] [Commented] (FLINK-8228) Code cleanup - pointless bitwise expressions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/09 08:25:00 UTC, 3 replies.
- [GitHub] flink pull request #5144: [Minor][cleanup] Remove unnecessary semicolons - posted by yew1eb <gi...@git.apache.org> on 2017/12/09 08:39:32 UTC, 0 replies.
- [jira] [Created] (FLINK-8229) Cannot use broadcast in StreamingEnvironment - posted by "Wind (JIRA)" <ji...@apache.org> on 2017/12/09 09:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8229) Cannot use broadcast in StreamingEnvironment - posted by "Wind (JIRA)" <ji...@apache.org> on 2017/12/09 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8230) NPE in OrcRowInputFormat on nested structs - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2017/12/10 13:25:08 UTC, 0 replies.
- [GitHub] flink pull request #5145: [FLINK-8230] [ORC] Improved mapping of Orc records... - posted by packet23 <gi...@git.apache.org> on 2017/12/10 13:42:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-8230) NPE in OrcRowInputFormat on nested structs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/10 13:43:06 UTC, 1 replies.
- [GitHub] flink issue #4828: [FLINK-4816] [checkpoints] Executions failed from "DEPLOY... - posted by tony810430 <gi...@git.apache.org> on 2017/12/11 04:07:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-4816) Executions failed from "DEPLOYING" should retain restored checkpoint information - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/11 04:08:00 UTC, 0 replies.
- [GitHub] flink issue #5107: [FLINK-8176][flip6] Start SubmittedJobGraphStore in Dispa... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/11 08:12:47 UTC, 0 replies.
- [jira] [Created] (FLINK-8231) Extend AbstractRestHandler to return response headers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/11 08:29:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8232) Create RestHandler for long running operations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/11 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8233) Retrieve ExecutionResult by REST polling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/11 08:43:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/11 08:46:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-8229) Cannot use broadcast in StreamingEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/11 08:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7934) Upgrade Calcite dependency to 1.15 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/11 09:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7586) Report Watermark metrics in all operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/11 09:58:00 UTC, 1 replies.
- [jira] [Reopened] (FLINK-7586) Report Watermark metrics in all operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/11 09:58:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8235) Cannot run spotbugs for single module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/11 10:45:00 UTC, 0 replies.
- [GitHub] flink pull request #5146: [FLINK-8235][build] Spotbugs exclusion file path n... - posted by zentol <gi...@git.apache.org> on 2017/12/11 10:48:04 UTC, 1 replies.
- [jira] [Closed] (FLINK-5573) Kafka08ITCase.testStartFromZookeeperCommitOffsets fails on Travis - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/11 10:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8235) Cannot run spotbugs for single module - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/11 10:49:00 UTC, 3 replies.
- [GitHub] flink issue #5140: [FLINK-7797] [table] Add support for windowed outer joins... - posted by fhueske <gi...@git.apache.org> on 2017/12/11 10:53:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner - posted by "Konstantin Lalafaryan (JIRA)" <ji...@apache.org> on 2017/12/11 11:54:01 UTC, 6 replies.
- [jira] [Created] (FLINK-8236) Allow to set the parallelism of table queries - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/11 12:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8236) Allow to set the parallelism of table queries - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/11 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8237) BucketingSink throws NPE when Writer.duplicate returns null - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2017/12/11 13:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8238) StreamTaskTestHarness should only allow one setup call - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/11 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8238) StreamTaskTestHarness should only allow one setup call - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/11 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8239) Extend StreamTaskTestHarness to support TwoInput head operators - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/11 14:17:00 UTC, 0 replies.
- [GitHub] flink pull request #5097: [FLINK-6909] [FLINK-7450] [types] Improve the hand... - posted by aljoscha <gi...@git.apache.org> on 2017/12/11 14:46:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-6909) Flink should support Lombok POJO - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/11 14:47:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-8236) Allow to set the parallelism of table queries - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/11 15:12:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3659) Add ConnectWithBroadcast Operation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/11 16:44:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8229) Cannot use broadcast in StreamingEnvironment - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/11 16:44:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3659) Add ConnectWithBroadcast Operation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/11 16:44:00 UTC, 0 replies.
- [GitHub] flink issue #5143: [FLINK-8228][cleanup] Code cleanup - pointless bitwise ex... - posted by aljoscha <gi...@git.apache.org> on 2017/12/11 16:45:26 UTC, 1 replies.
- [jira] [Reopened] (FLINK-8211) Rename ResultPartitionWriter to OutputGate - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/11 16:51:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/11 17:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/11 17:23:00 UTC, 2 replies.
- [jira] [Created] (FLINK-8241) Remove ResultPartitionWriter related PrepareForTest annotations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/11 17:23:00 UTC, 0 replies.
- [GitHub] flink pull request #5147: [FLINK-8241][tests] Remove ResultPartitionWriter-r... - posted by zentol <gi...@git.apache.org> on 2017/12/11 17:26:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-8241) Remove ResultPartitionWriter related PrepareForTest annotations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/11 17:27:07 UTC, 2 replies.
- [jira] [Updated] (FLINK-7913) Add support for Kafka default partitioner - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/11 23:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/11 23:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/11 23:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/11 23:09:05 UTC, 0 replies.
- [GitHub] flink pull request #5138: [FLINK-8217] [Kinesis connector] Properly annotate... - posted by tzulitai <gi...@git.apache.org> on 2017/12/11 23:24:56 UTC, 1 replies.
- [GitHub] flink pull request #5148: [FLINK-8215][Table] fix codegen issue on array/map... - posted by walterddr <gi...@git.apache.org> on 2017/12/11 23:40:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/12 01:31:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/12 01:31:00 UTC, 1 replies.
- [GitHub] flink pull request #5149: [FLINK-7858][flp6] Port JobVertexTaskManagersHandl... - posted by zjureel <gi...@git.apache.org> on 2017/12/12 05:50:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-7858) Port JobVertexTaskManagersHandler to REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 05:51:00 UTC, 0 replies.
- [GitHub] flink pull request #5150: upgrade Calcite dependency to 1.15 - posted by suez1224 <gi...@git.apache.org> on 2017/12/12 07:55:23 UTC, 1 replies.
- [GitHub] flink issue #5147: [FLINK-8241][tests] Remove ResultPartitionWriter-related ... - posted by NicoK <gi...@git.apache.org> on 2017/12/12 09:51:52 UTC, 0 replies.
- [GitHub] flink pull request #5151: [hotfix][javadoc]fix spelling mistake in StreamEle... - posted by Matrix42 <gi...@git.apache.org> on 2017/12/12 10:14:13 UTC, 1 replies.
- [jira] [Updated] (FLINK-8202) Update queryable section on configuration page - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/12 10:19:00 UTC, 0 replies.
- [GitHub] flink pull request #5152: [hotfix][javadoc]fix spelling mistake in StreamEle... - posted by Matrix42 <gi...@git.apache.org> on 2017/12/12 10:20:18 UTC, 1 replies.
- [GitHub] flink pull request #5064: [FLINK-8145][tests] fix various IOManagerAsync ins... - posted by zentol <gi...@git.apache.org> on 2017/12/12 10:26:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-8145) IOManagerAsync not properly shut down in various tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 10:27:00 UTC, 4 replies.
- [GitHub] flink issue #5064: [FLINK-8145][tests] fix various IOManagerAsync instances ... - posted by NicoK <gi...@git.apache.org> on 2017/12/12 10:36:28 UTC, 1 replies.
- [GitHub] flink issue #5152: [hotfix][javadoc]fix spelling mistake in StreamElement ja... - posted by zentol <gi...@git.apache.org> on 2017/12/12 10:47:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-8145) IOManagerAsync not properly shut down in various tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 10:49:00 UTC, 1 replies.
- [GitHub] flink issue #5146: [FLINK-8235][build] Spotbugs exclusion file path now abso... - posted by zentol <gi...@git.apache.org> on 2017/12/12 10:53:28 UTC, 0 replies.
- [jira] [Closed] (FLINK-8228) Code cleanup - pointless bitwise expressions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 10:56:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8242) ClassCastException in OrcTableSource.toOrcPredicate - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/12 11:01:05 UTC, 0 replies.
- [jira] [Created] (FLINK-8243) OrcTableSource should recursively read all files in nested directories of the input path. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/12 11:04:00 UTC, 0 replies.
- [GitHub] flink pull request #5153: [FLINK-8238][FLINK-8239] Extend StreamTaskTestHarn... - posted by zentol <gi...@git.apache.org> on 2017/12/12 11:13:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-8238) StreamTaskTestHarness should only allow one setup call - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 11:14:00 UTC, 4 replies.
- [GitHub] flink issue #5153: [FLINK-8238][FLINK-8239] Extend StreamTaskTestHarness - posted by aljoscha <gi...@git.apache.org> on 2017/12/12 11:32:37 UTC, 2 replies.
- [GitHub] flink pull request #5154: [FLINK-8123][metrics] Guard against metric-related... - posted by zentol <gi...@git.apache.org> on 2017/12/12 11:49:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-8123) Bundle python library in jar - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 11:50:00 UTC, 0 replies.
- [GitHub] flink pull request #5155: [FLINK-4812][metrics] Expose currentLowWatermark f... - posted by zentol <gi...@git.apache.org> on 2017/12/12 12:05:51 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8079) Skip remaining E2E tests if one failed - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 13:00:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-8079) Skip remaining E2E tests if one failed - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 13:06:00 UTC, 0 replies.
- [GitHub] flink pull request #5156: [FLINK-8079][tests] Stop end-to-end test execution... - posted by zentol <gi...@git.apache.org> on 2017/12/12 13:07:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-8079) Skip remaining E2E tests if one failed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 13:08:06 UTC, 2 replies.
- [jira] [Updated] (FLINK-8080) Rework "metrics.reporters" config option to an optional include list - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 13:11:00 UTC, 1 replies.
- [GitHub] flink issue #5127: [FLINK-7749][network] refactor the ResultPartitionWriter ... - posted by zentol <gi...@git.apache.org> on 2017/12/12 13:16:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-8145) IOManagerAsync not properly shut down in various tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 13:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7692) Support user-defined variables in Metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 13:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8235) Cannot run spotbugs for single module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 13:23:01 UTC, 0 replies.
- [GitHub] flink issue #4932: [FLINK-7958][metrics] Allow reporters to define default d... - posted by zentol <gi...@git.apache.org> on 2017/12/12 13:33:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-7958) Allow reporters to override the default delimiter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 13:34:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8244) There are two zookeeper client created when read data from hbase in the flink yarn session model - posted by "zhanglibing000 (JIRA)" <ji...@apache.org> on 2017/12/12 13:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8244) There are two zookeeper client created when read data from hbase in the flink yarn session model - posted by "zhanglibing000 (JIRA)" <ji...@apache.org> on 2017/12/12 13:46:00 UTC, 1 replies.
- [GitHub] flink issue #4761: [FLINK-7748][network] properly use the TaskEventDispatche... - posted by zentol <gi...@git.apache.org> on 2017/12/12 13:51:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-7748) remove event listener behaviour from ResultPartitionWriter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 13:52:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8245) Add some interval between logs when requested resources are not available - posted by "Wind (JIRA)" <ji...@apache.org> on 2017/12/12 13:53:00 UTC, 0 replies.
- [GitHub] flink pull request #5154: [FLINK-8213][metrics] Guard against metric-related... - posted by aljoscha <gi...@git.apache.org> on 2017/12/12 14:09:46 UTC, 2 replies.
- [jira] [Commented] (FLINK-8213) Prevent potential metric-related ClassCastExceptions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 14:10:01 UTC, 3 replies.
- [GitHub] flink issue #5144: [Minor][cleanup] Remove unnecessary semicolons - posted by greghogan <gi...@git.apache.org> on 2017/12/12 14:31:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-8080) Rework "metrics.reporters" config option to an optional include list - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 14:50:00 UTC, 2 replies.
- [GitHub] flink issue #5154: [FLINK-8213][metrics] Guard against metric-related ClassC... - posted by zentol <gi...@git.apache.org> on 2017/12/12 15:56:38 UTC, 0 replies.
- [jira] [Created] (FLINK-8246) Download page must not link to dist.apache.org - posted by "Sebb (JIRA)" <ji...@apache.org> on 2017/12/12 15:57:02 UTC, 0 replies.
- [GitHub] flink pull request #5105: [FLINK-8178][network] Introduce not threadsafe wri... - posted by NicoK <gi...@git.apache.org> on 2017/12/12 17:05:45 UTC, 39 replies.
- [jira] [Commented] (FLINK-8178) Introduce not threadsafe write only BufferBuilder - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 17:06:01 UTC, 40 replies.
- [GitHub] flink issue #5105: [FLINK-8178][network] Introduce not threadsafe write only... - posted by NicoK <gi...@git.apache.org> on 2017/12/12 17:07:53 UTC, 0 replies.
- [jira] [Closed] (FLINK-8213) Prevent potential metric-related ClassCastExceptions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 19:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8238) StreamTaskTestHarness should only allow one setup call - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 19:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8239) Extend StreamTaskTestHarness to support TwoInput head operators - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 19:29:00 UTC, 0 replies.
- [GitHub] flink pull request #4761: [FLINK-7748][network] properly use the TaskEventDi... - posted by asfgit <gi...@git.apache.org> on 2017/12/12 19:29:35 UTC, 0 replies.
- [jira] [Closed] (FLINK-8241) Remove ResultPartitionWriter related PrepareForTest annotations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 19:30:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7748) remove event listener behaviour from ResultPartitionWriter - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 19:30:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7749) Refactor the ResultPartitionWriter into an interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 19:30:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-8080) Rework "metrics.reporters" config option to an optional include list - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 19:30:01 UTC, 0 replies.
- [GitHub] flink pull request #5157: [hotfix] [docs] Consistent capitalization in Mesos... - posted by joerg84 <gi...@git.apache.org> on 2017/12/12 22:10:26 UTC, 1 replies.
- [jira] [Closed] (FLINK-8219) Kinesis Connector metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/12 23:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8247) Support Hadoop-free variant of Flink on Mesos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/13 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4 - posted by "jia liu (JIRA)" <ji...@apache.org> on 2017/12/13 08:15:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4 - posted by "jia liu (JIRA)" <ji...@apache.org> on 2017/12/13 08:18:00 UTC, 5 replies.
- [jira] [Updated] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/13 09:12:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/13 09:13:00 UTC, 0 replies.
- [GitHub] flink pull request #5158: [hotfix][docs] Update debugging class loading doc ... - posted by pnowojski <gi...@git.apache.org> on 2017/12/13 09:13:40 UTC, 1 replies.
- [GitHub] flink issue #5158: [hotfix][docs] Update debugging class loading doc to Java... - posted by twalthr <gi...@git.apache.org> on 2017/12/13 09:17:27 UTC, 1 replies.
- [GitHub] flink issue #5157: [hotfix] [docs] Consistent capitalization in Mesos docume... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/13 10:05:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/13 10:13:00 UTC, 2 replies.
- [jira] [Created] (FLINK-8249) Kinesis Producer dont cpnfigure region - posted by "Joao Boto (JIRA)" <ji...@apache.org> on 2017/12/13 10:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8249) Kinesis Producer didnt configure region - posted by "Joao Boto (JIRA)" <ji...@apache.org> on 2017/12/13 10:25:00 UTC, 6 replies.
- [GitHub] flink pull request #5159: [FLINK-8249] [KinesisConnector] [hotfix] aws regio... - posted by eskabetxe <gi...@git.apache.org> on 2017/12/13 11:19:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-8249) Kinesis Producer didnt configure region - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/13 11:20:04 UTC, 16 replies.
- [GitHub] flink issue #5159: [FLINK-8249] [KinesisConnector] [hotfix] aws region is ne... - posted by tzulitai <gi...@git.apache.org> on 2017/12/13 11:29:30 UTC, 3 replies.
- [GitHub] flink pull request #5160: [FLINK-8249] [KinesisConnector] [hotfix] aws regio... - posted by eskabetxe <gi...@git.apache.org> on 2017/12/13 11:46:41 UTC, 6 replies.
- [GitHub] flink pull request #5161: 7608 - posted by zentol <gi...@git.apache.org> on 2017/12/13 12:01:31 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4 - posted by "jia liu (JIRA)" <ji...@apache.org> on 2017/12/13 12:18:00 UTC, 2 replies.
- [jira] [Created] (FLINK-8250) Remove RecordSerializer#instantiateMetrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/13 12:23:00 UTC, 0 replies.
- [GitHub] flink pull request #5162: [FLINK-8250][runtime] Remove unused RecordSerializ... - posted by zentol <gi...@git.apache.org> on 2017/12/13 12:25:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-8250) Remove RecordSerializer#instantiateMetrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/13 12:26:00 UTC, 1 replies.
- [GitHub] flink issue #4581: [FLINK-7499][io] fix double buffer release in SpillableSu... - posted by NicoK <gi...@git.apache.org> on 2017/12/13 12:50:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/13 12:51:02 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/13 13:28:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/13 13:31:01 UTC, 1 replies.
- [jira] [Closed] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/13 13:33:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8251) Add some network micro-benchmarks in Flink - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/13 13:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8221) Implement set of network latency benchmarks in Flink - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/13 13:35:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8251) Add network (micro) benchmarks in Flink - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/13 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8252) Convert network benchmarks to streaming benchmarks - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/13 13:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8247) Support Hadoop-free variant of Flink on Mesos - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/13 14:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/13 14:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7815) Remove grouping from MultipleJobsDetails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/13 14:04:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-7815) Remove grouping from MultipleJobsDetails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/13 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8253) flink-docs-stable still points to 1.3 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/12/13 14:06:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8253) flink-docs-stable still points to 1.3 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/12/13 14:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/13 15:13:00 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-8236) Allow to set the parallelism of table queries - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/13 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8254) REST API documentation wonky due to shading - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/13 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8255) Key expressions on named rows types do not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/13 15:53:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-8255) Key expressions on named row types do not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/13 15:54:00 UTC, 1 replies.
- [GitHub] flink pull request #5163: [FLINK-8254][REST][docs] Bandaid generated documen... - posted by zentol <gi...@git.apache.org> on 2017/12/13 15:54:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-8254) REST API documentation wonky due to shading - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/13 15:55:00 UTC, 0 replies.
- [GitHub] flink pull request #5164: [hotfix][javadoc] fix typo in StreamExecutionEnvir... - posted by Matrix42 <gi...@git.apache.org> on 2017/12/13 16:00:13 UTC, 1 replies.
- [GitHub] flink issue #5112: [FLINK-8175] [DataStream API java/scala] remove flink-str... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/13 17:05:11 UTC, 3 replies.
- [GitHub] flink issue #4987: [FLINK-8029] Create WebMonitorEndpoint - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/13 17:12:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-8103) Flink 1.4 not writing to standard out log file - posted by "Ryan Brideau (JIRA)" <ji...@apache.org> on 2017/12/13 17:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8103) Flink 1.4 not writing to standard out log file - posted by "Ryan Brideau (JIRA)" <ji...@apache.org> on 2017/12/13 17:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException - posted by "Ryan Brideau (JIRA)" <ji...@apache.org> on 2017/12/13 20:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8100) Consider introducing log4j-extras - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/13 21:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8257) Unify the value checks for setParallelism() - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/14 02:38:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-8257) Unify the value checks for setParallelism() - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/14 02:42:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4 - posted by "jia liu (JIRA)" <ji...@apache.org> on 2017/12/14 03:55:00 UTC, 1 replies.
- [GitHub] flink issue #5160: [FLINK-8249] [KinesisConnector] [hotfix] aws region is ne... - posted by tzulitai <gi...@git.apache.org> on 2017/12/14 06:56:29 UTC, 2 replies.
- [jira] [Created] (FLINK-8258) Enable query configuration for batch queries - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/14 07:19:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8029) Create common WebMonitorEndpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 08:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8030) Start JobMasterRestEndpoint in JobClusterEntrypoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 08:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8085) Thin out the LogicalSlot interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 08:09:00 UTC, 0 replies.
- [GitHub] flink pull request #5086: [FLINK-8078] Introduce LogicalSlot interface - posted by asfgit <gi...@git.apache.org> on 2017/12/14 08:09:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-8078) Decouple Execution from actual slot implementation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 08:10:01 UTC, 1 replies.
- [jira] [Reopened] (FLINK-8078) Decouple Execution from actual slot implementation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 08:10:01 UTC, 0 replies.
- [GitHub] flink issue #5128: [FLINK-8120] [flip6] Register Yarn application with corre... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/14 08:12:16 UTC, 0 replies.
- [jira] [Created] (FLINK-8259) Release flink 1.4 docker image on dockerhub - posted by "Gytis Zilinskas (JIRA)" <ji...@apache.org> on 2017/12/14 08:50:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-8259) Release flink 1.4 docker image on dockerhub - posted by "Gytis Zilinskas (JIRA)" <ji...@apache.org> on 2017/12/14 09:13:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8259) Release flink 1.4 docker image on dockerhub - posted by "Gytis Zilinskas (JIRA)" <ji...@apache.org> on 2017/12/14 09:13:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-8246) Download page must not link to dist.apache.org - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/14 09:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8246) Download page must not link to dist.apache.org - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/14 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8260) Document API of Kafka 0.11 Producer - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/14 10:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8260) Document API of Kafka 0.11 Producer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/14 11:01:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-8260) Document API of Kafka 0.11 Producer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/14 11:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 11:13:00 UTC, 5 replies.
- [jira] [Created] (FLINK-8261) Typos in the shading exclusion for jsr305 in the quickstarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/14 11:48:00 UTC, 0 replies.
- [GitHub] flink pull request #5165: [FLINK-8285] [table] Enable query configuration fo... - posted by xccui <gi...@git.apache.org> on 2017/12/14 11:52:47 UTC, 1 replies.
- [jira] [Created] (FLINK-8262) IndividualRestartsConcurrencyTest.testLocalFailureFailsPendingCheckpoints fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 11:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8261) Typos in the shading exclusion for jsr305 in the quickstarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/14 12:07:03 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8261) Typos in the shading exclusion for jsr305 in the quickstarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/14 12:07:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8263) Wrong packaging of flink-core in scala quickstarty - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/14 12:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8263) Wrong packaging of flink-core in scala quickstarty - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/14 12:44:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8263) Wrong packaging of flink-core in scala quickstarty - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/14 12:44:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8264) Add Scala to the parent-first loading patterns - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/14 12:48:00 UTC, 0 replies.
- [GitHub] flink pull request #5166: [FLINK-8264] [core] Add 'scala.' to the 'parent-fi... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/14 13:03:53 UTC, 1 replies.
- [jira] [Commented] (FLINK-8264) Add Scala to the parent-first loading patterns - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/14 13:04:00 UTC, 5 replies.
- [GitHub] flink pull request #5167: [FLINK-8264] [core] Add 'scala.' to the 'parent-fi... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/14 13:05:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-8262) IndividualRestartsConcurrencyTest.testLocalFailureFailsPendingCheckpoints fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 13:15:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException - posted by "Ryan Brideau (JIRA)" <ji...@apache.org> on 2017/12/14 13:46:00 UTC, 0 replies.
- [GitHub] flink issue #5166: [FLINK-8264] [core] Add 'scala.' to the 'parent-first' cl... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/14 15:10:24 UTC, 1 replies.
- [GitHub] flink issue #5088: [FLINK-8087] Decouple Slot from AllocatedSlot - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/14 15:32:09 UTC, 0 replies.
- [GitHub] flink issue #5089: [FLINK-8088] Associate logical slots with the slot reques... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/14 15:32:27 UTC, 0 replies.
- [GitHub] flink issue #5090: [FLINK-8089] Also check for other pending slot requests i... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/14 15:32:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-8088) Bind logical slots to their request id instead of the slot allocation id - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/14 15:33:00 UTC, 1 replies.
- [GitHub] flink pull request #5089: [FLINK-8088] Associate logical slots with the slot... - posted by asfgit <gi...@git.apache.org> on 2017/12/14 15:35:13 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/12/14 16:02:44 UTC, 19 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/12/14 16:03:01 UTC, 20 replies.
- [jira] [Assigned] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/14 16:23:00 UTC, 0 replies.
- [GitHub] flink issue #5091: [FLINK-7956] [flip6] Add support for queued scheduling wi... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/14 16:41:07 UTC, 0 replies.
- [jira] [Closed] (FLINK-7956) Add support for scheduling with slot sharing - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 16:44:00 UTC, 0 replies.
- [GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP - posted by GJL <gi...@git.apache.org> on 2017/12/14 17:45:45 UTC, 25 replies.
- [jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/14 17:46:00 UTC, 35 replies.
- [jira] [Resolved] (FLINK-7878) Extend the resource type user can define in ResourceSpec - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 17:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8257) Unify the value checks for setParallelism() - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/14 20:16:00 UTC, 2 replies.
- [jira] [Created] (FLINK-8265) Missing jackson dependency for flink-mesos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/14 20:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8265) Missing jackson dependency for flink-mesos - posted by "Jared Stehler (JIRA)" <ji...@apache.org> on 2017/12/14 21:13:01 UTC, 1 replies.
- [GitHub] flink pull request #5169: [FLINK-8258] [table] Enable query configuration fo... - posted by xccui <gi...@git.apache.org> on 2017/12/15 01:28:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-8258) Enable query configuration for batch queries - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/15 01:29:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-7928) Extend the filed in ResourceProfile for precisely calculating the resource of a task manager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/15 07:57:00 UTC, 0 replies.
- [GitHub] flink issue #5050: [FLINK-4822] Ensure that the Kafka 0.8 connector is compa... - posted by taizilongxu <gi...@git.apache.org> on 2017/12/15 09:28:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-4822) Ensure that the Kafka 0.8 connector is compatible with kafka-consumer-groups.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/15 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8266) Add network memory to ResourceProfile - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/15 09:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8266) Add network memory to ResourceProfile - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/15 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8267) Kinesis Producer example setting Region key - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2017/12/15 10:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8267) Kinesis Producer example setting Region key - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2017/12/15 10:24:00 UTC, 1 replies.
- [GitHub] flink pull request #5170: [FLINK-8266] [runtime] add network memory to Resou... - posted by shuai-xu <gi...@git.apache.org> on 2017/12/15 10:51:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-8266) Add network memory to ResourceProfile - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/15 10:52:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/12/15 12:56:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8264) Add Scala to the parent-first loading patterns - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/15 14:26:02 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8264) Add Scala to the parent-first loading patterns - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/15 14:26:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/15 14:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8233) Retrieve ExecutionResult by REST polling - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/15 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8269) Set netRuntime in JobExecutionResult - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/15 15:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8267) Kinesis Producer example setting Region key - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/15 18:47:00 UTC, 1 replies.
- [GitHub] flink issue #5113: [FLINK-8156][build] Bump commons-beanutils version to 1.9... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/15 18:58:54 UTC, 1 replies.
- [GitHub] flink issue #5124: [FLINK-8199] [elasticsearch connector] Properly annotate ... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/15 19:04:10 UTC, 3 replies.
- [GitHub] flink issue #5126: [FLINK-5506] [gelly] Fix CommunityDetection NullPointerEx... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/15 19:10:29 UTC, 1 replies.
- [GitHub] flink issue #5135: [hotfix] [doc] Fix typo in TaskManager and EnvironmentInf... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/15 19:14:46 UTC, 1 replies.
- [GitHub] flink issue #5136: [FLINK-8222] [build] Update Scala version - posted by StephanEwen <gi...@git.apache.org> on 2017/12/15 19:17:20 UTC, 1 replies.
- [GitHub] flink issue #5137: [FLINK-8223] [build] Update Hadoop versions - posted by StephanEwen <gi...@git.apache.org> on 2017/12/15 19:18:10 UTC, 0 replies.
- [GitHub] flink issue #5142: [FLINK-8227] Optimize the performance of SharedBufferSeri... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/15 19:25:26 UTC, 6 replies.
- [GitHub] flink issue #5156: [FLINK-8079][tests] Stop end-to-end test execution after ... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/15 19:28:10 UTC, 0 replies.
- [GitHub] flink issue #5162: [FLINK-8250][runtime] Remove unused RecordSerializer#inst... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/15 19:30:58 UTC, 0 replies.
- [GitHub] flink issue #5164: [hotfix][javadoc] fix typo in StreamExecutionEnvironment ... - posted by StephanEwen <gi...@git.apache.org> on 2017/12/15 19:31:16 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-8267) Kinesis Producer example setting Region key - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/15 19:40:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8267) Kinesis Producer example setting Region key - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/15 19:40:01 UTC, 0 replies.
- [GitHub] flink issue #4784: FLINK-7736: fix some lgtm.com alerts - posted by 1m2c3t4 <gi...@git.apache.org> on 2017/12/15 19:55:51 UTC, 1 replies.
- [jira] [Commented] (FLINK-7736) Fix some of the alerts raised by lgtm.com - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/15 19:56:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8270) TaskManagers do not use correct local path for shipped Keytab files in Yarn deployment modes - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/16 00:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8271) upgrade AmazonKinesisClient - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/17 06:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8271) upgrade from deprecated classes to AmazonKinesis - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/17 07:15:00 UTC, 0 replies.
- [GitHub] flink pull request #5171: [FLINK-8271][Kinesis connector] upgrade from depre... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/17 07:19:42 UTC, 2 replies.
- [jira] [Commented] (FLINK-8271) upgrade from deprecated classes to AmazonKinesis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/17 07:20:00 UTC, 12 replies.
- [jira] [Created] (FLINK-8272) 1.4 & Scala: Exception when querying the state - posted by "Juan Miguel Cejuela (JIRA)" <ji...@apache.org> on 2017/12/17 10:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8272) 1.4 & Scala: Exception when querying the state - posted by "Juan Miguel Cejuela (JIRA)" <ji...@apache.org> on 2017/12/17 11:49:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-8272) 1.4 & Scala: Exception when querying the state - posted by "Juan Miguel Cejuela (JIRA)" <ji...@apache.org> on 2017/12/17 13:50:08 UTC, 1 replies.
- [jira] [Closed] (FLINK-8272) 1.4 & Scala: Exception when querying the state - posted by "Juan Miguel Cejuela (JIRA)" <ji...@apache.org> on 2017/12/17 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8273) Configs shown on JobManager WebUI maybe not the real runtime value - posted by "Lynch Lee (JIRA)" <ji...@apache.org> on 2017/12/17 14:57:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-8270) TaskManagers do not use correct local path for shipped Keytab files in Yarn deployment modes - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/17 20:08:00 UTC, 4 replies.
- [jira] [Created] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/12/18 02:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/18 03:21:02 UTC, 1 replies.
- [jira] [Updated] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/18 03:23:00 UTC, 1 replies.
- [GitHub] flink issue #5171: [FLINK-8271][Kinesis connector] upgrade from deprecated c... - posted by tzulitai <gi...@git.apache.org> on 2017/12/18 04:02:19 UTC, 5 replies.
- [GitHub] flink issue #5131: [FLINK-8218] [Kinesis connector] move flink-connector-kin... - posted by tzulitai <gi...@git.apache.org> on 2017/12/18 04:38:05 UTC, 0 replies.
- [GitHub] flink issue #5130: [FLINK-8216] [Kinesis connector] Unify test utils in flin... - posted by tzulitai <gi...@git.apache.org> on 2017/12/18 04:41:27 UTC, 0 replies.
- [GitHub] flink pull request #5131: [FLINK-8218] [Kinesis connector] move flink-connec... - posted by asfgit <gi...@git.apache.org> on 2017/12/18 07:27:12 UTC, 0 replies.
- [GitHub] flink pull request #5130: [FLINK-8216] [Kinesis connector] Unify test utils ... - posted by asfgit <gi...@git.apache.org> on 2017/12/18 07:27:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8249) Kinesis Producer didnt configure region - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/18 07:28:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8218) move flink-connector-kinesis examples from /src to /test - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/18 07:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8216) Unify test utils in flink-connector-kinesis - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/18 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/12/18 07:53:00 UTC, 0 replies.
- [GitHub] flink pull request #5172: [FLINK-8275] [Security] fix keytab local path in Y... - posted by suez1224 <gi...@git.apache.org> on 2017/12/18 07:58:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 07:59:00 UTC, 5 replies.
- [jira] [Updated] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/12/18 08:00:02 UTC, 0 replies.
- [GitHub] flink issue #5172: [FLINK-8275] [Security] fix keytab local path in YarnTask... - posted by tzulitai <gi...@git.apache.org> on 2017/12/18 08:09:24 UTC, 3 replies.
- [jira] [Created] (FLINK-8276) Annotation for Kafka connector - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/12/18 08:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/18 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8277) Optimize code generation by using local references - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/18 09:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/18 09:19:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-7860) Support YARN proxy user in Flink (impersonation) - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/12/18 09:31:00 UTC, 3 replies.
- [jira] [Created] (FLINK-8278) Scala examples in Metric documentation do not compile - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/18 09:52:00 UTC, 0 replies.
- [GitHub] flink pull request #5173: [FLINK-8276] [kafka connector] Properly annotate A... - posted by zhangminglei <gi...@git.apache.org> on 2017/12/18 10:27:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-8276) Annotation for Kafka connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 10:28:00 UTC, 0 replies.
- [GitHub] flink pull request #5174: [FLINK-8274][TableAPI & SQL] Fix Java 64K method c... - posted by Xpray <gi...@git.apache.org> on 2017/12/18 10:47:12 UTC, 0 replies.
- [jira] [Created] (FLINK-8279) Use Mesos/YARN temp directories as fallback for BlobServer/Cache temp directories - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/18 10:56:00 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/12/18 11:41:36 UTC, 0 replies.
- [GitHub] flink pull request #4889: [FLINK-7903] [tests] Add flip6 build profile - posted by GJL <gi...@git.apache.org> on 2017/12/18 12:12:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-7903) Add Flip6 build profile - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 12:13:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8280) Enable checkstyle for org.apache.flink.runtime.blob - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/18 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable - posted by "brucewoo (JIRA)" <ji...@apache.org> on 2017/12/18 12:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable - posted by "brucewoo (JIRA)" <ji...@apache.org> on 2017/12/18 12:33:00 UTC, 2 replies.
- [GitHub] flink pull request #5175: [FLINK-8280][checkstyle] fix checkstyle in BlobSer... - posted by NicoK <gi...@git.apache.org> on 2017/12/18 13:31:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-8280) Enable checkstyle for org.apache.flink.runtime.blob - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 13:32:05 UTC, 1 replies.
- [jira] [Assigned] (FLINK-8278) Scala examples in Metric documentation do not compile - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/18 13:41:00 UTC, 0 replies.
- [GitHub] flink pull request #5176: [FLINK-8279][blob] fall back to TaskManager temp d... - posted by NicoK <gi...@git.apache.org> on 2017/12/18 13:43:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-8279) Use Mesos/YARN temp directories as fallback for BlobServer/Cache temp directories - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 13:44:00 UTC, 2 replies.
- [GitHub] flink pull request #5177: [FLINK-8278] [doc] Fix the private member init pro... - posted by xccui <gi...@git.apache.org> on 2017/12/18 14:05:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-8278) Scala examples in Metric documentation do not compile - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 14:06:00 UTC, 5 replies.
- [GitHub] flink issue #4621: [FLINK-7495] Call to AbstractUdfStreamOperator#initialize... - posted by PedroMrChaves <gi...@git.apache.org> on 2017/12/18 15:32:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8282) Transformation with TwoInputStreamOperator fails - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/18 15:35:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-8282) Transformation with TwoInputStreamOperator fails - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/18 15:35:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-8282) Transformation with TwoInputStreamOperator fails - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/18 16:19:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/18 16:31:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/18 16:32:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8284) Custom metrics not being exposed for Prometheus - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2017/12/18 16:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/18 17:00:00 UTC, 0 replies.
- [GitHub] flink pull request #3934: [FLINK-6065] Add initClient method to Elasticsearc... - posted by sschaef <gi...@git.apache.org> on 2017/12/18 17:42:06 UTC, 0 replies.
- [GitHub] flink issue #5176: [FLINK-8279][blob] fall back to TaskManager temp director... - posted by EronWright <gi...@git.apache.org> on 2017/12/18 17:42:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-6065) Make TransportClient for ES5 pluggable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 17:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/18 17:59:00 UTC, 3 replies.
- [jira] [Created] (FLINK-8285) Iterator Data Sink doesn't mention required module - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2017/12/18 18:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8285) Iterator Data Sink doesn't mention required module - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2017/12/18 18:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8285) Iterator Data Sink doesn't mention required module - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/18 18:57:00 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-8285) Iterator Data Sink doesn't mention required module - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/18 19:25:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-7860) Support YARN proxy user in Flink (impersonation) - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/12/18 21:02:00 UTC, 2 replies.
- [jira] [Created] (FLINK-8286) Investigate Flink-Yarn-Kerberos integration for flip-6 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/12/18 21:11:00 UTC, 0 replies.
- [GitHub] flink issue #5121: [FLINK-8116] Stale comments referring to Checkpointed int... - posted by tzulitai <gi...@git.apache.org> on 2017/12/18 21:33:21 UTC, 0 replies.
- [GitHub] flink pull request #1875: [FLINK-3742][ml][wip] Add Multilayer Perceptron - posted by rawkintrevo <gi...@git.apache.org> on 2017/12/18 21:55:53 UTC, 0 replies.
- [GitHub] flink issue #1875: [FLINK-3742][ml][wip] Add Multilayer Perceptron - posted by rawkintrevo <gi...@git.apache.org> on 2017/12/18 21:55:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-3742) Add Multi Layer Perceptron Predictor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 21:56:00 UTC, 1 replies.
- [GitHub] flink pull request #1865: [FLINK-3720][ml][wip] Add Warm Starts for Iterativ... - posted by rawkintrevo <gi...@git.apache.org> on 2017/12/18 21:56:07 UTC, 0 replies.
- [GitHub] flink issue #1865: [FLINK-3720][ml][wip] Add Warm Starts for Iterative Solve... - posted by rawkintrevo <gi...@git.apache.org> on 2017/12/18 21:56:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-3720) Add warm starts for models - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 21:57:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/12/18 22:58:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/12/18 22:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8287) Flink Kafka Producer docs should clearly state what partitioner is used by default - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/18 23:43:00 UTC, 0 replies.
- [GitHub] flink pull request #5178: [hotfix] Fix typo in TestableKinesisDataFetcher - posted by casidiablo <gi...@git.apache.org> on 2017/12/18 23:56:29 UTC, 0 replies.
- [jira] [Created] (FLINK-8288) Register the web interface url to yarn for yarn job mode - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 02:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable - posted by "brucewoo (JIRA)" <ji...@apache.org> on 2017/12/19 02:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 02:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8288) Register the web interface url to yarn for yarn job mode - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8 - posted by "xymaqingxiang (JIRA)" <ji...@apache.org> on 2017/12/19 02:36:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-8270) TaskManagers do not use correct local path for shipped Keytab files in Yarn deployment modes - posted by "dongxiao.yang (JIRA)" <ji...@apache.org> on 2017/12/19 02:57:00 UTC, 0 replies.
- [GitHub] flink pull request #5179: [FLINK-8260/8287] [kafka] Bunch of improvements to... - posted by tzulitai <gi...@git.apache.org> on 2017/12/19 04:46:15 UTC, 0 replies.
- [GitHub] flink issue #5178: [hotfix] Fix typo in TestableKinesisDataFetcher - posted by tzulitai <gi...@git.apache.org> on 2017/12/19 04:47:19 UTC, 1 replies.
- [GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c... - posted by djh4230 <gi...@git.apache.org> on 2017/12/19 06:20:45 UTC, 4 replies.
- [jira] [Commented] (FLINK-7951) YarnApplicationMaster does not load HDFSConfiguration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/19 06:21:00 UTC, 4 replies.
- [jira] [Created] (FLINK-8291) For security, Job Manager web UI should be accessed with username/password - posted by "Lynch Lee (JIRA)" <ji...@apache.org> on 2017/12/19 08:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 08:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5793) Running slot may not be add to AllocatedMap in SlotPool - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 08:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5171) Wrong use of Preconditions.checkState in TaskManagerRunner - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 08:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5190) ZooKeeperLeaderRetrievalService should not close the zk client when stop - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 08:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-6434) There may be allocatedSlots leak in SlotPool - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 08:09:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7928) Extend the filed in ResourceProfile for precisely calculating the resource of a task manager - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 08:09:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7878) Extend the resource type user can define in ResourceSpec - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 08:09:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-8292) Remove unnecessary force cast in DataStreamSource - posted by "Matrix42 (JIRA)" <ji...@apache.org> on 2017/12/19 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8292) Remove unnecessary force cast in DataStreamSource - posted by "Matrix42 (JIRA)" <ji...@apache.org> on 2017/12/19 08:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8291) For security, Job Manager web UI should be accessed with username/password - posted by "Lynch Lee (JIRA)" <ji...@apache.org> on 2017/12/19 08:24:00 UTC, 1 replies.
- [GitHub] flink pull request #5180: [FLINK-8292] Remove unnecessary force cast in Data... - posted by Matrix42 <gi...@git.apache.org> on 2017/12/19 08:32:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-8292) Remove unnecessary force cast in DataStreamSource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/19 08:33:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-7452) Add helper methods for all built-in Flink types to Types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/19 08:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7736) Fix some of the alerts raised by lgtm.com - posted by "Malcolm Taylor (JIRA)" <ji...@apache.org> on 2017/12/19 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8293) Rework Flink's type and serialization docs - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/19 08:51:02 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4352) Refactor CLI to use RESTful client for cluster communication - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/19 08:53:00 UTC, 0 replies.
- [GitHub] flink issue #5148: [FLINK-8215][Table] fix codegen issue on array/map value ... - posted by twalthr <gi...@git.apache.org> on 2017/12/19 10:00:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-8215) upport implicit type widening for array/map constructors in SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/19 10:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8215) Support implicit type widening for array/map constructors in SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/19 10:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8215) Support implicit type widening for array/map constructors in SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/19 10:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8215) Support implicit type widening for array/map constructors in SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/19 10:28:00 UTC, 0 replies.
- [GitHub] flink pull request #5181: [FLINK-8283] [kafka] Fix mock verification on fina... - posted by tzulitai <gi...@git.apache.org> on 2017/12/19 10:31:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/19 10:32:00 UTC, 11 replies.
- [GitHub] flink issue #5181: [FLINK-8283] [kafka] Fix mock verification on final metho... - posted by tzulitai <gi...@git.apache.org> on 2017/12/19 10:34:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-7594) Add a SQL client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/19 11:15:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8294) Missing examples/links in Data Sink docs - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2017/12/19 12:00:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-8284) Custom metrics not being exposed for Prometheus - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2017/12/19 13:15:00 UTC, 0 replies.
- [GitHub] flink pull request #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' mil... - posted by casidiablo <gi...@git.apache.org> on 2017/12/19 15:35:11 UTC, 9 replies.
- [jira] [Commented] (FLINK-7465) Add build-in BloomFilterCount on TableAPI&SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/19 15:40:00 UTC, 1 replies.
- [jira] [Created] (FLINK-8295) Netty shading does not work properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/19 15:41:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7465) Add build-in BloomFilterCount on TableAPI&SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/19 15:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8295) Netty shading does not work properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/19 15:41:00 UTC, 0 replies.
- [GitHub] flink pull request #4652: [FLINK-7465][table]Add cardinality count for table... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/12/19 15:42:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-7594) Add a SQL client - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/19 16:31:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-8295) Netty shading does not work properly - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/19 17:10:00 UTC, 0 replies.
- [GitHub] flink pull request #5183: [FLINK-8295][cassandra][build] properly shade nett... - posted by NicoK <gi...@git.apache.org> on 2017/12/19 17:23:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-8295) Netty shading does not work properly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/19 17:24:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/19 18:20:00 UTC, 7 replies.
- [jira] [Comment Edited] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/19 18:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8296) Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/19 20:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8297) RocksDBListState stores whole list in single byte[] - posted by "Jan Lukavský (JIRA)" <ji...@apache.org> on 2017/12/19 20:59:01 UTC, 0 replies.
- [GitHub] flink pull request #5184: [FLINK-8234][flip6] Cache JobExecutionResult in Di... - posted by GJL <gi...@git.apache.org> on 2017/12/19 21:14:06 UTC, 7 replies.
- [jira] [Updated] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/19 21:33:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8233) Retrieve ExecutionResult by REST polling - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/19 21:33:00 UTC, 0 replies.
- [GitHub] flink pull request #5185: [FLINK-8297] [flink-rocksdb] optionally use RocksD... - posted by je-ik <gi...@git.apache.org> on 2017/12/19 21:38:44 UTC, 0 replies.
- [jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[] - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/19 21:39:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-5880) Add documentation for object reuse for DataStream API - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/12/20 02:20:00 UTC, 0 replies.
- [GitHub] flink pull request #5186: [FLINK-8288] [runtime] register job master rest en... - posted by shuai-xu <gi...@git.apache.org> on 2017/12/20 02:26:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-8288) Register the web interface url to yarn for yarn job mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/20 02:27:00 UTC, 0 replies.
- [GitHub] flink pull request #5187: Merge pull request #1 from apache/master - posted by laolang113 <gi...@git.apache.org> on 2017/12/20 02:36:26 UTC, 1 replies.
- [GitHub] flink issue #5183: [FLINK-8295][cassandra][build] properly shade netty for t... - posted by mcfongtw <gi...@git.apache.org> on 2017/12/20 02:46:06 UTC, 3 replies.
- [jira] [Assigned] (FLINK-8257) Unify the value checks for setParallelism() - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/20 07:11:00 UTC, 0 replies.
- [GitHub] flink issue #5168: [FLINK-8234][flip6] WIP - posted by GJL <gi...@git.apache.org> on 2017/12/20 08:29:23 UTC, 0 replies.
- [GitHub] flink pull request #5188: [FLINK-8296] [kafka] Rework FlinkKafkaConsumerBase... - posted by tzulitai <gi...@git.apache.org> on 2017/12/20 09:01:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-8296) Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/20 09:02:00 UTC, 0 replies.
- [GitHub] flink pull request #5189: [FLINK-8283] [kafka] Introduce KafkaOffsetCommitte... - posted by tzulitai <gi...@git.apache.org> on 2017/12/20 09:16:11 UTC, 1 replies.
- [GitHub] flink pull request #5190: [FLINK-8289] [runtime] set the rest.address to the... - posted by shuai-xu <gi...@git.apache.org> on 2017/12/20 09:42:02 UTC, 2 replies.
- [GitHub] flink pull request #5191: Release 1.4 - posted by czhxmz <gi...@git.apache.org> on 2017/12/20 11:15:11 UTC, 0 replies.
- [GitHub] flink pull request #5192: [FLINK-8257] [conf] Unify the value checks for set... - posted by xccui <gi...@git.apache.org> on 2017/12/20 11:15:15 UTC, 0 replies.
- [GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability - posted by pnowojski <gi...@git.apache.org> on 2017/12/20 12:19:08 UTC, 13 replies.
- [jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/20 12:20:00 UTC, 14 replies.
- [jira] [Assigned] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/20 12:46:01 UTC, 0 replies.
- [GitHub] flink pull request #5194: [FLINK-8233][flip6] Add JobExecutionResultHandler - posted by GJL <gi...@git.apache.org> on 2017/12/20 13:51:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-8233) Retrieve ExecutionResult by REST polling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/20 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8298) Shutdown MockEnvironment - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/20 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8299) Retrieve ExecutionResult by REST polling - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/20 15:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8233) Expose JobExecutionResult via HTTP - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/20 15:44:00 UTC, 1 replies.
- [GitHub] flink issue #5180: [FLINK-8292] Remove unnecessary force cast in DataStreamS... - posted by greghogan <gi...@git.apache.org> on 2017/12/20 15:48:39 UTC, 0 replies.
- [jira] [Created] (FLINK-8300) Make JobExecutionResult accessible from JobMaster - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/20 16:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8300) Make JobExecutionResult accessible from JobMaster - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/20 16:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8233) Expose JobExecutionResult via HTTP - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/20 16:55:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-8295) Netty shading does not work properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/20 17:30:01 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7588) Document RocksDB tuning for spinning disks - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/20 18:03:00 UTC, 0 replies.
- [GitHub] flink issue #5171: [FLINK-8271][Kinesis connector] upgrade deprecated method... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/20 18:08:19 UTC, 0 replies.
- [GitHub] flink pull request #5195: [hotfix] [build] Always include Kafka 0.11 connect... - posted by greghogan <gi...@git.apache.org> on 2017/12/20 19:17:32 UTC, 1 replies.
- [GitHub] flink issue #5185: [FLINK-8297] [flink-rocksdb] optionally use RocksDBMapSta... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/20 19:25:41 UTC, 1 replies.
- [GitHub] flink issue #5195: [hotfix] [build] Always include Kafka 0.11 connector - posted by tzulitai <gi...@git.apache.org> on 2017/12/20 20:45:13 UTC, 0 replies.
- [GitHub] flink issue #5187: Merge pull request #1 from apache/master - posted by tzulitai <gi...@git.apache.org> on 2017/12/20 20:50:25 UTC, 0 replies.
- [GitHub] flink issue #5191: Release 1.4 - posted by tzulitai <gi...@git.apache.org> on 2017/12/20 20:51:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-7525) Add config option to disable Cancel functionality on UI - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/20 22:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7795) Utilize error-prone to discover common coding mistakes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/20 22:51:00 UTC, 0 replies.
- [GitHub] flink pull request #5171: [FLINK-8271][Kinesis connector] upgrade deprecated... - posted by tzulitai <gi...@git.apache.org> on 2017/12/20 23:34:44 UTC, 2 replies.
- [jira] [Updated] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/21 00:26:00 UTC, 0 replies.
- [GitHub] flink issue #5141: [FLINK-8226] [cep] Dangling reference generated after NFA... - posted by dianfu <gi...@git.apache.org> on 2017/12/21 06:58:23 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8300) Make JobExecutionResult accessible in per-job cluster mode - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/21 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8301) Support Unicode in codegen for TableAPI && SQL - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/12/21 08:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8301) Support Unicode in codegen for TableAPI && SQL - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/12/21 08:06:00 UTC, 0 replies.
- [GitHub] flink issue #5192: [FLINK-8257] [conf] Unify the value checks for setParalle... - posted by xccui <gi...@git.apache.org> on 2017/12/21 08:56:04 UTC, 0 replies.
- [GitHub] flink issue #5169: [FLINK-8258] [table] Enable query configuration for batch... - posted by xccui <gi...@git.apache.org> on 2017/12/21 08:57:24 UTC, 0 replies.
- [jira] [Created] (FLINK-8302) Support shift_left and shift_right in TableAPI - posted by "DuBin (JIRA)" <ji...@apache.org> on 2017/12/21 09:19:00 UTC, 0 replies.
- [GitHub] flink pull request #5196: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ... - posted by dubin555 <gi...@git.apache.org> on 2017/12/21 09:31:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/21 09:32:00 UTC, 6 replies.
- [jira] [Created] (FLINK-8303) Update Savepoint Compatibility Table for 1.4 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/21 09:51:00 UTC, 0 replies.
- [GitHub] flink issue #3915: [FLINK-6352] Support to use timestamp to set the initial ... - posted by zjureel <gi...@git.apache.org> on 2017/12/21 09:52:32 UTC, 0 replies.
- [GitHub] flink pull request #5197: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ... - posted by dubin555 <gi...@git.apache.org> on 2017/12/21 10:00:20 UTC, 1 replies.
- [GitHub] flink pull request #5198: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ... - posted by dubin555 <gi...@git.apache.org> on 2017/12/21 10:10:48 UTC, 1 replies.
- [jira] [Created] (FLINK-8304) Document Kubernetes and Flink HA setup - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/12/21 10:57:01 UTC, 0 replies.
- [GitHub] flink pull request #4896: [FLINK-7909] Unify Flink test bases - posted by GJL <gi...@git.apache.org> on 2017/12/21 11:28:13 UTC, 7 replies.
- [jira] [Commented] (FLINK-7909) Unify cluster creation for test bases - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/21 11:29:00 UTC, 7 replies.
- [GitHub] flink issue #5177: [FLINK-8278] [doc] Fix the private member init problem fo... - posted by xccui <gi...@git.apache.org> on 2017/12/21 12:04:42 UTC, 3 replies.
- [GitHub] flink pull request #5199: [hotfix] [javadoc] Fix typos in MemorSegment class - posted by casidiablo <gi...@git.apache.org> on 2017/12/21 13:33:57 UTC, 0 replies.
- [jira] [Reopened] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/12/21 15:05:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/12/21 15:05:02 UTC, 1 replies.
- [jira] [Updated] (FLINK-8031) Provide configuration to enable/disable ability to cancel jobs in Web Frontend - posted by "Stephen Hesketh (JIRA)" <ji...@apache.org> on 2017/12/21 16:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8031) Provide configuration to enable/disable ability to cancel jobs in Web Frontend - posted by "Stephen Hesketh (JIRA)" <ji...@apache.org> on 2017/12/21 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8305) Docker port mapping doesn't work for JobManager RPC port on Official Flink image - posted by "Thomas Wozniakowski (JIRA)" <ji...@apache.org> on 2017/12/21 16:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8305) Docker port mapping doesn't work for JobManager RPC port on Official Flink image - posted by "Thomas Wozniakowski (JIRA)" <ji...@apache.org> on 2017/12/21 16:37:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/21 17:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/21 18:53:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/21 18:53:02 UTC, 0 replies.
- [GitHub] flink issue #5189: [FLINK-8283] [kafka] Introduce KafkaOffsetCommitter inter... - posted by tzulitai <gi...@git.apache.org> on 2017/12/21 21:46:27 UTC, 0 replies.
- [GitHub] flink pull request #5200: [FLINK-8306] [kafka] Introduce KafkaOffsetCommitte... - posted by tzulitai <gi...@git.apache.org> on 2017/12/21 21:51:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/21 21:52:00 UTC, 0 replies.
- [GitHub] flink pull request #5201: [FLINK-8283] [kafka] Stabalize FlinkKafkaConsumerB... - posted by tzulitai <gi...@git.apache.org> on 2017/12/21 22:04:08 UTC, 0 replies.
- [GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ... - posted by dubin555 <gi...@git.apache.org> on 2017/12/22 00:15:57 UTC, 0 replies.
- [jira] [Created] (FLINK-8307) org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler logging improvments - posted by "Colin Williams (JIRA)" <ji...@apache.org> on 2017/12/22 00:41:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-8307) org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler logging improvments - posted by "Colin Williams (JIRA)" <ji...@apache.org> on 2017/12/22 00:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8301) Support Unicode in codegen for SQL - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/12/22 02:11:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/12/22 02:14:00 UTC, 1 replies.
- [GitHub] flink pull request #5203: [FLINK-8301] Support Unicode in codegen for SQL &&... - posted by Xpray <gi...@git.apache.org> on 2017/12/22 02:23:43 UTC, 10 replies.
- [jira] [Commented] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 02:24:01 UTC, 13 replies.
- [jira] [Assigned] (FLINK-7715) Port JarRunHandler to new REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/12/22 02:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7714) Port JarPlanHandler to new REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/12/22 02:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7713) Port JarUploadHandler to new REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/12/22 02:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7712) Port JarDeleteHandler to new REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/12/22 02:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7711) Port JarListHandler to new REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/12/22 02:43:00 UTC, 0 replies.
- [GitHub] flink pull request #5204: Release 1.4 - posted by zhentaowang <gi...@git.apache.org> on 2017/12/22 03:34:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/22 10:03:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8277) Optimize code generation by using local references - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/12/22 12:34:00 UTC, 0 replies.
- [GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct... - posted by hequn8128 <gi...@git.apache.org> on 2017/12/22 13:08:56 UTC, 5 replies.
- [GitHub] flink issue #5201: [FLINK-8283] [kafka] Stabalize FlinkKafkaConsumerBaseTest... - posted by tzulitai <gi...@git.apache.org> on 2017/12/22 15:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8309) JVM sigsegv crash when enabling async checkpoints - posted by "Kevin Pullin (JIRA)" <ji...@apache.org> on 2017/12/22 17:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8309) JVM sigsegv crash when enabling async checkpoints - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/12/22 18:21:00 UTC, 1 replies.
- [GitHub] flink pull request #5205: [FLINK-8037] Fix integer multiplication or shift i... - posted by greghogan <gi...@git.apache.org> on 2017/12/22 18:33:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 18:34:00 UTC, 0 replies.
- [GitHub] flink pull request #5199: [hotfix] [javadoc] Fix typos in MemorySegment clas... - posted by asfgit <gi...@git.apache.org> on 2017/12/22 19:14:13 UTC, 0 replies.
- [GitHub] flink issue #5190: [FLINK-8289] [runtime] set the rest.address to the host o... - posted by EronWright <gi...@git.apache.org> on 2017/12/22 19:14:53 UTC, 0 replies.
- [jira] [Closed] (FLINK-8223) Update Hadoop versions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/22 19:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8223) Update Hadoop versions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/22 19:16:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8222) Update Scala version - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/22 19:16:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8222) Update Scala version - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/22 19:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8309) JVM sigsegv crash when enabling async checkpoints - posted by "Kevin Pullin (JIRA)" <ji...@apache.org> on 2017/12/22 19:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8310) Flink 1.4 Column 'rowtime' not found in any table - posted by "Xuan Nguyen (JIRA)" <ji...@apache.org> on 2017/12/22 20:49:02 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8310) Flink 1.4 Column 'rowtime' not found in any table - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/22 21:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8311) Flink needs documentation for network access control - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/12/22 22:05:03 UTC, 0 replies.
- [jira] [Updated] (FLINK-8311) Flink needs documentation for network access control - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/22 23:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/12/23 10:30:00 UTC, 0 replies.
- [GitHub] flink pull request #5206: [FLINK-8312][TableAPI && SQL] Fix ScalarFunction v... - posted by Xpray <gi...@git.apache.org> on 2017/12/23 10:57:23 UTC, 4 replies.
- [jira] [Commented] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/23 10:58:00 UTC, 6 replies.
- [jira] [Created] (FLINK-8313) Please add REAMD file for flink-web repository - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/12/23 11:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8313) Please add REAMD file for flink-web repository - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/12/23 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8314) Add support for Kinesis Firehose - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2017/12/23 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2017/12/23 12:38:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8316) The CsvTableSink and the CsvInputFormat are not in sync - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/23 16:10:04 UTC, 0 replies.
- [jira] [Reopened] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP. - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/12/23 18:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP. - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/12/23 18:14:01 UTC, 0 replies.
- [jira] [Reopened] (FLINK-7760) Restore failing from external checkpointing metadata. - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/12/23 18:16:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-7760) Restore failing from external checkpointing metadata. - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/12/23 18:16:02 UTC, 0 replies.
- [GitHub] flink issue #5203: [FLINK-8301] Support Unicode in codegen for SQL && TableA... - posted by Xpray <gi...@git.apache.org> on 2017/12/24 04:08:25 UTC, 2 replies.
- [GitHub] flink pull request #5207: [FLINK-8299][flip6] Poll JobExecutionResult after ... - posted by GJL <gi...@git.apache.org> on 2017/12/24 10:35:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-8299) Retrieve ExecutionResult by REST polling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/24 10:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8231) Extend AbstractRestHandler to return response headers - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/24 10:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4834) Implement unified High Availability Services Abstraction - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/24 10:43:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-7780) Integrate savepoint command into REST client - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/24 10:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7780) Integrate savepoint command into REST client - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/24 10:45:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7780) Integrate savepoint command into REST client - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/24 10:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8317) Enable triggering of Savepoints via RestfulGateway - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/24 10:57:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8317) Expose met triggering of Savepoints via HTTP - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/24 10:57:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/24 10:59:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/24 10:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8043) change fullRestarts (for fine grained recovery) from guage to counter - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2017/12/24 20:11:00 UTC, 0 replies.
- [GitHub] flink issue #5206: [FLINK-8312][TableAPI && SQL] Fix ScalarFunction varargs ... - posted by Xpray <gi...@git.apache.org> on 2017/12/25 02:22:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-7612) Implement Event-driven Network IO - posted by "Keren Zhu (JIRA)" <ji...@apache.org> on 2017/12/25 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8318) Conflict jackson library with ElasticSearch connector - posted by "Jihyun Cho (JIRA)" <ji...@apache.org> on 2017/12/26 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8319) Savepoint restore failing in CEP - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/12/26 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8320) Flink cluster does not work on Java 9 - posted by "Steve Layland (JIRA)" <ji...@apache.org> on 2017/12/26 09:56:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/26 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8321) Generate _SUCCESS (map-reduce style) when folder has been written! - posted by "yanxiaobin (JIRA)" <ji...@apache.org> on 2017/12/26 16:23:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8278) Scala examples in Metric documentation do not compile - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/26 20:04:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/27 03:01:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-8321) Generate _SUCCESS (map-reduce style) when folder has been written! - posted by "yanxiaobin (JIRA)" <ji...@apache.org> on 2017/12/27 03:49:00 UTC, 0 replies.
- [GitHub] flink issue #4963: [FLINK-7475] [core][DataStream API] support update() in L... - posted by bowenli86 <gi...@git.apache.org> on 2017/12/27 04:39:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-7475) support update() in ListState - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/27 04:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8322) support getting existing timers from TimerService - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/27 04:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8322) support getting existing timers and number of existing timers in TimerService - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/27 07:02:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8322) support getting number of existing timers in TimerService - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/27 07:04:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-8322) support getting number of existing timers in TimerService - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/27 07:17:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-8322) support getting number of existing timers in TimerService - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/27 07:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8226) Dangling reference generated after NFA clean up timed out SharedBufferEntry - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/12/27 13:22:05 UTC, 0 replies.
- [jira] [Created] (FLINK-8323) Fix Mod scala function bug - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/27 15:40:01 UTC, 0 replies.
- [GitHub] flink pull request #5208: [FLINK-8265] [Mesos] Missing jackson dependency fo... - posted by EronWright <gi...@git.apache.org> on 2017/12/27 22:35:56 UTC, 0 replies.
- [jira] [Updated] (FLINK-8265) Missing jackson dependency for flink-mesos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/27 22:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/12/28 02:07:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/12/28 02:10:00 UTC, 1 replies.
- [GitHub] flink pull request #5209: [FLINK-7711] Port JarListHandler to WebMonitorEndp... - posted by zjureel <gi...@git.apache.org> on 2017/12/28 02:14:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/28 02:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/12/28 02:23:00 UTC, 2 replies.
- [jira] [Created] (FLINK-8325) Add support for constant parameters in GROUP WINDOW aggregate - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/28 08:34:00 UTC, 0 replies.
- [GitHub] flink pull request #5210: [FLINK-8316][table]The CsvTableSink and the CsvInp... - posted by xccui <gi...@git.apache.org> on 2017/12/28 08:42:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-8316) The CsvTableSink and the CsvInputFormat are not in sync - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/28 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8326) CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/12/28 10:19:02 UTC, 0 replies.
- [GitHub] flink pull request #5211: [FLINK-8326] [chks] CheckpointCoordinatorTest#test... - posted by tony810430 <gi...@git.apache.org> on 2017/12/28 10:35:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-8326) CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/28 10:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/28 13:48:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/12/28 14:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7760) Restore failing from external checkpointing metadata. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/12/28 15:02:05 UTC, 1 replies.
- [jira] [Closed] (FLINK-8319) Savepoint restore failing in CEP - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/12/28 15:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8169) Document timestamp and timezone behavior for Table API & SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/28 15:19:00 UTC, 0 replies.
- [GitHub] flink pull request #5212: [FLINK-8323][table] fix MOD scalar function bug. - posted by sunjincheng121 <gi...@git.apache.org> on 2017/12/28 15:59:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-8323) Fix Mod scala function bug - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/28 16:00:00 UTC, 0 replies.
- [GitHub] flink issue #4924: [FLINK-7949] AsyncWaitOperator is not restarting when que... - posted by bartektartanus <gi...@git.apache.org> on 2017/12/28 16:14:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-7949) AsyncWaitOperator is not restarting when queue is full - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/28 16:15:04 UTC, 0 replies.
- [GitHub] flink pull request #5213: [docs][metrics] Fix typo of metrics docs - posted by yew1eb <gi...@git.apache.org> on 2017/12/28 17:54:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2017/12/28 21:25:00 UTC, 1 replies.
- [GitHub] flink pull request #5214: [FLINK-8324] [kafka] Expose another offsets metric... - posted by tony810430 <gi...@git.apache.org> on 2017/12/29 01:22:23 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4817) Checkpoint Coordinator should be called to restore state with a specific checkpoint ID - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/12/29 07:24:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8327) ClassLoader resolution of child-first does not appear to work - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/12/29 07:51:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-8327) ClassLoader resolution of child-first does not appear to work - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/12/29 07:52:00 UTC, 4 replies.
- [jira] [Closed] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/29 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/29 17:12:00 UTC, 0 replies.
- [GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/29 17:17:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/29 17:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8329) Move YarnClient out of YarnClusterClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/29 17:22:05 UTC, 0 replies.
- [GitHub] flink pull request #5216: [FLINK-8329] [flip6] Move YarnClient to AbstractYa... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/29 17:25:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-8329) Move YarnClient out of YarnClusterClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/29 17:26:00 UTC, 2 replies.
- [jira] [Created] (FLINK-8330) Remove FlinkYarnCLI - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/29 17:28:00 UTC, 0 replies.
- [GitHub] flink pull request #5217: [FLINK-8330] [flip6] Remove FlinkYarnCLI - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/29 17:28:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-8330) Remove FlinkYarnCLI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/29 17:29:00 UTC, 2 replies.
- [GitHub] flink issue #5101: [FLINK-8171] [flip6] Remove work arounds from Flip6LocalS... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/29 17:30:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-8171) Remove work arounds in Flip6LocalStreamEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/29 17:31:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/29 20:43:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/29 20:43:01 UTC, 1 replies.
- [jira] [Created] (FLINK-8331) FieldParsers do not correctly set EMPT_COLUMN error state - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/29 21:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8331) FieldParsers do not correctly set EMPT_COLUMN error state - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/30 02:24:00 UTC, 0 replies.
- [GitHub] flink issue #5216: [FLINK-8329] [flip6] Move YarnClient to AbstractYarnClust... - posted by GJL <gi...@git.apache.org> on 2017/12/30 12:05:32 UTC, 1 replies.
- [GitHub] flink pull request #5218: [FLINK-8331][core] FieldParser do not correctly se... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/12/30 13:39:48 UTC, 13 replies.
- [jira] [Commented] (FLINK-8331) FieldParsers do not correctly set EMPT_COLUMN error state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/30 13:40:00 UTC, 15 replies.
- [GitHub] flink issue #5218: [FLINK-8331][core] FieldParser do not correctly set EMPT_... - posted by sunjincheng121 <gi...@git.apache.org> on 2017/12/31 07:02:27 UTC, 1 replies.
- [GitHub] flink pull request #4299: [FLINK-7155] [metrics] Add Influxdb reporter - posted by gobozov <gi...@git.apache.org> on 2017/12/31 08:54:15 UTC, 0 replies.
- [jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/31 08:55:00 UTC, 0 replies.
- [GitHub] flink pull request #5101: [FLINK-8171] [flip6] Remove work arounds from Flip... - posted by asfgit <gi...@git.apache.org> on 2017/12/31 16:15:43 UTC, 0 replies.
- [jira] [Closed] (FLINK-8171) Remove work arounds in Flip6LocalStreamEnvironment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/31 16:16:03 UTC, 0 replies.
- [GitHub] flink issue #5217: [FLINK-8330] [flip6] Remove FlinkYarnCLI - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/31 16:21:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-8330) Remove FlinkYarnCLI - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/31 16:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8332) Move dispose savepoint into ClusterClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/31 17:43:02 UTC, 0 replies.
- [GitHub] flink pull request #5219: [FLINK-8332] [flip6] Move savepoint dispose into C... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/31 17:45:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-8332) Move dispose savepoint into ClusterClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/31 17:46:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8333) Split command options from deployment options in CliFrontend - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/31 17:55:00 UTC, 0 replies.
- [GitHub] flink pull request #5220: [FLINK-8333] [flip6] Separate deployment options f... - posted by tillrohrmann <gi...@git.apache.org> on 2017/12/31 17:58:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-8333) Split command options from deployment options in CliFrontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/31 17:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/31 19:06:00 UTC, 0 replies.