You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Machine Learning on Flink - Next steps - posted by Jinkui Shi <sh...@163.com> on 2017/04/01 03:39:29 UTC, 1 replies.
- [jira] [Created] (FLINK-6237) support RAND and RAND_INTEGER on SQL - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/04/01 05:14:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6238) support OVER on batch SQL - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/04/01 07:10:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6239) Sharing of State Across Operators - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/04/01 07:39:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6240) codeGen dataStream aggregates that use AggregateAggFunction - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/04/01 08:23:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6241) codeGen dataStream aggregates that use ProcessFunction - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/04/01 08:24:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6242) codeGen DataSet Goupingwindow Aggregates - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/04/01 08:25:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6243) Continuous Joins: True Sliding Window Joins - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/04/01 21:23:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6244) Emit timeouted Patterns as Side Output - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/04/03 08:05:41 UTC, 0 replies.
- Side Outputs - type bounds. - posted by Dawid Wysakowicz <wy...@gmail.com> on 2017/04/03 08:22:22 UTC, 1 replies.
- [jira] [Created] (FLINK-6245) Fix late side output documentation in Window documents. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/04/03 11:28:41 UTC, 0 replies.
- Re: Flink streaming job with iterations gets stuck waiting for network buffers - posted by Paris Carbone <pa...@kth.se> on 2017/04/03 11:33:13 UTC, 2 replies.
- [jira] [Created] (FLINK-6246) Fix generic type of OutputTag in operator Output - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/04/03 14:06:41 UTC, 0 replies.
- Re: [VOTE] Release Apache Flink 1.2.1 (RC1) - posted by Aljoscha Krettek <al...@apache.org> on 2017/04/03 14:39:35 UTC, 17 replies.
- [jira] [Created] (FLINK-6247) Build a jar-with-dependencies for flink-table and put it into ./opt - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/04/03 14:42:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6248) Make the optional() available to all offered patterns. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/04/03 14:49:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6249) Distinct Aggregates for OVER window - posted by "radu (JIRA)" <ji...@apache.org> on 2017/04/03 14:52:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6250) Distinct procTime with Rows boundaries - posted by "radu (JIRA)" <ji...@apache.org> on 2017/04/03 15:04:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6251) Distinct procTime with time range boundaries - posted by "radu (JIRA)" <ji...@apache.org> on 2017/04/03 15:06:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6252) Distinct rowTime with Rows boundaries - posted by "radu (JIRA)" <ji...@apache.org> on 2017/04/03 15:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6253) Distinct rowTime with time range boundaries - posted by "radu (JIRA)" <ji...@apache.org> on 2017/04/03 15:09:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6254) Consolidate late data methods on PatternStream and WindowedStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/04/03 15:26:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6255) Remove PatternStream.getSideOutput() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/04/03 15:28:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6256) Fix documentation of ProcessFunction. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/04/03 15:32:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6257) Post-pass OVER windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/04/03 16:17:41 UTC, 0 replies.
- Re: [DISCUSS] Code style / checkstyle - posted by Aljoscha Krettek <al...@apache.org> on 2017/04/03 16:33:14 UTC, 7 replies.
- [jira] [Created] (FLINK-6258) Deprecate ListCheckpointed interface for managed operator state - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/03 20:29:41 UTC, 0 replies.
- Flink limitations under Beam - posted by amir bahmanyari <am...@yahoo.com.INVALID> on 2017/04/04 00:11:44 UTC, 3 replies.
- Re: [DISCUSS] FLIP-18: Code Generation for improving sorting performance - posted by Pattarawat Chormai <pa...@gmail.com> on 2017/04/04 00:46:39 UTC, 1 replies.
- [jira] [Created] (FLINK-6259) Fix a small spelling error - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/04/04 00:52:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6260) Distinct Aggregates for Group By Windows - posted by "radu (JIRA)" <ji...@apache.org> on 2017/04/04 07:48:41 UTC, 0 replies.
- StreamSQL procTime granularity - posted by Stefano Bortoli <st...@huawei.com> on 2017/04/04 08:23:31 UTC, 2 replies.
- [jira] [Created] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/04/04 09:19:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6262) UnknownTopicOrPartitionException Kafka consumer error on broker restart/failure - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2017/04/04 13:31:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6263) Leader error in Kafka producer on leader change (broker restart/failrue) - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2017/04/04 13:35:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6264) Kafka consumer fails if can't find leader for partition - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2017/04/04 13:39:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6265) Fix consecutive() for times() pattern. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/04/04 16:04:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6266) Remove the useless import in FlinkRelBuilder - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/04/05 07:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6267) Remove the useless import in FlinkRelBuilder - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/04/05 07:09:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6268) Object reuse for Either type - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/04/05 13:46:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6269) var could be a val - posted by "CanBin Zheng (JIRA)" <ji...@apache.org> on 2017/04/06 01:39:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6270) Port several network config parameters to ConfigOption - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/04/06 07:54:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6271) NumericBetweenParametersProvider NullPinter - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2017/04/06 09:35:41 UTC, 0 replies.
- Re: [DISCUSS] FLIP-18: Code Generation for improving sorting performance - posted by Pattarawat Chormai <pa...@gmail.com> on 2017/04/06 11:09:19 UTC, 0 replies.
- [jira] [Created] (FLINK-6272) Rolling file sink saves incomplete lines on failure - posted by "Jakub Nowacki (JIRA)" <ji...@apache.org> on 2017/04/06 12:03:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/04/06 12:22:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6274) Replace usages of org.codehaus.jackson - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/04/06 12:32:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/06 14:57:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null. - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2017/04/07 06:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6277) RuntimeException in logs during normal shutdown - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/04/07 08:26:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6278) After "FATAL" message in logs taskmanager still working - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/04/07 09:44:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6279) the digest of VolcanoRuleMatch matched different table sources with same field names may be same - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/04/07 13:36:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6280) Allow logging with Java flags - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/04/07 17:28:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6281) Create TableSink for JDBC - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/04/07 21:42:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6282) Some words was spelled wrong - posted by "Jinjiang Ling (JIRA)" <ji...@apache.org> on 2017/04/08 06:17:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6283) Enable to clear a given file cache path - posted by "Zohar Mizrahi (JIRA)" <ji...@apache.org> on 2017/04/09 10:21:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6284) Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/04/10 04:03:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6285) resolve hadoop-compatibility confusion - posted by "Petr Novotnik (JIRA)" <ji...@apache.org> on 2017/04/10 06:15:41 UTC, 0 replies.
- Possible bug in Kafka producer partitioning logic - posted by Gyula Fóra <gy...@gmail.com> on 2017/04/10 08:16:04 UTC, 7 replies.
- [jira] [Created] (FLINK-6286) hbase command not found error - posted by "Jinjiang Ling (JIRA)" <ji...@apache.org> on 2017/04/10 10:26:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6287) Flakey JobManagerRegistrationTest - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/04/10 12:35:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/10 13:38:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6289) ExecutionEnvironment.readTextFile() can read gzip files & directories but not both - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2017/04/10 14:01:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6290) SharedBuffer is improperly released when multiple edges between entries - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/04/10 14:22:41 UTC, 0 replies.
- Question about the process order in stream aggregate - posted by Xingcan Cui <xi...@gmail.com> on 2017/04/11 03:30:35 UTC, 7 replies.
- [jira] [Created] (FLINK-6291) Internal Timer service cannot be "removed" - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2017/04/11 08:49:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6292) Travis: transfer.sh not accepting uploads via http:// anymore - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/04/11 09:26:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6293) Flakey JobManagerITCase - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/04/11 10:17:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6294) BucketingSink throws NPE while cancelling job - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/04/11 10:19:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6295) use LoadingCache instead of WeakHashMap to lower latency - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/04/11 11:38:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6296) Retrieving execution plan fails succeeding execution attempt - posted by "Petr Novotnik (JIRA)" <ji...@apache.org> on 2017/04/11 16:06:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6297) CEP timeout does not trigger under certain conditions - posted by "Vijayakumar Palaniappan (JIRA)" <ji...@apache.org> on 2017/04/11 17:45:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6298) Local execution is not setting RuntimeContext for RichOutputFormat - posted by "Mateusz Zakarczemny (JIRA)" <ji...@apache.org> on 2017/04/11 18:02:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6299) make all IT cases extend from TestLogger - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/04/12 09:19:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6300) PID1 of docker images does not behave correctly - posted by "kathleen sharp (JIRA)" <ji...@apache.org> on 2017/04/12 11:47:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug - posted by "Rahul Yadav (JIRA)" <ji...@apache.org> on 2017/04/12 19:33:41 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.2.1 (RC2) - posted by Robert Metzger <rm...@apache.org> on 2017/04/12 23:06:42 UTC, 17 replies.
- Jobmanager drops upon submitting a jar - posted by amir bahmanyari <am...@yahoo.com.INVALID> on 2017/04/13 00:54:10 UTC, 5 replies.
- Splitting input stream in to multiple windows and process individually - posted by madhairsilence <ha...@tcs.com> on 2017/04/13 05:39:16 UTC, 2 replies.
- Sliding Window - Weird behaviour - posted by madhairsilence <ha...@tcs.com> on 2017/04/13 08:43:13 UTC, 3 replies.
- [jira] [Created] (FLINK-6302) Documentation build error on ruby 2.4 - posted by "Tao Meng (JIRA)" <ji...@apache.org> on 2017/04/13 08:46:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6303) Documentation support build in docker on OSX - posted by "Tao Meng (JIRA)" <ji...@apache.org> on 2017/04/13 08:53:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6304) Clear a lot of useless import - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/04/13 09:51:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6305) flink-ml tests are executed in all flink-fast-test profiles - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/04/13 15:45:41 UTC, 0 replies.
- Why do I need this dependency? - posted by amir bahmanyari <am...@yahoo.com.INVALID> on 2017/04/14 17:03:36 UTC, 1 replies.
- [jira] [Created] (FLINK-6306) Sink for eventually consistent file systems - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2017/04/14 18:15:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6307) Refactor JDBC tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/04/15 15:55:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6308) Task managers are not attaching to job manager on macos - posted by "Mateusz Zakarczemny (JIRA)" <ji...@apache.org> on 2017/04/16 19:33:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6309) Memory consumer weights should be calculated in job vertex level - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/04/17 01:28:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6310) LocalExecutor#endSession() uses wrong lock for synchronization - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/17 02:00:45 UTC, 0 replies.
- [jira] [Created] (FLINK-6311) NPE in FlinkKinesisConsumer if source was closed before run - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/17 05:06:42 UTC, 0 replies.
- JIRA contributor permission - posted by Rahul Yadav <vi...@gmail.com> on 2017/04/17 06:40:45 UTC, 1 replies.
- [jira] [Created] (FLINK-6312) Update curator version to 2.12.0 - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/04/17 06:51:42 UTC, 0 replies.
- Issue while creating connector - posted by Sangeeta Gulia <sa...@knoldus.in> on 2017/04/17 07:09:51 UTC, 2 replies.
- [jira] [Created] (FLINK-6313) Some words was spelled wrong and incorrect LOG.error without print - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/04/17 07:48:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6314) Allow setting mapper options - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/04/17 16:24:42 UTC, 0 replies.
- Adding to Contributor list - posted by Neelesh Salian <ne...@gmail.com> on 2017/04/17 16:55:53 UTC, 1 replies.
- [jira] [Created] (FLINK-6315) Notify on checkpoint timeout - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2017/04/17 17:40:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6316) Kinesis connector docs should mention that FlinkKinesisConsumer does not provide strong ordering guarantees on resharding - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/18 00:53:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6317) History server - wrong default directory - posted by "Lorenz Bühmann (JIRA)" <ji...@apache.org> on 2017/04/18 07:27:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/04/18 12:36:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6319) Add timeout when shutting SystemProcessingTimeService down - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/04/18 13:47:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/04/18 13:51:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeydCEP. - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/04/18 14:00:46 UTC, 0 replies.
- [jira] [Created] (FLINK-6322) Mesos task labels - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/04/18 15:23:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6323) Add new Sink interface with access to more meta data - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/04/18 15:55:41 UTC, 0 replies.
- Rescaling state - posted by Vishnu Viswanath <vi...@gmail.com> on 2017/04/18 18:12:59 UTC, 1 replies.
- [jira] [Created] (FLINK-6324) Refine state access methods in OperatorStateStore - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/19 02:31:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6325) Refinement of slot reuse for task manager failure - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/04/19 08:27:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6326) add ProjectMergeRule at logical optimization stage - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/04/19 09:46:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6327) Bug in CommonCalc's estimateRowCount() method - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/04/19 11:36:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6328) Savepoints must not be counted as retained checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/04/19 13:08:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6329) refactor name-addressable accessors in BlobService classes from returning a URL to a File or InputStream - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/04/19 14:29:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6330) Improve Docker documentation - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2017/04/19 15:29:42 UTC, 0 replies.
- [jira] [Created] (FLINK-6331) StreamingOperatorsITCase.testAsyncWaitOperator spuriously failing on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/04/19 16:14:41 UTC, 0 replies.
- [jira] [Created] (FLINK-6332) Upgrade Scala version to 2.11.11 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/19 22:55:04 UTC, 0 replies.
- Read from and Write to Kafka through flink - posted by Pradeep Anumala <pr...@gmail.com> on 2017/04/19 23:38:07 UTC, 0 replies.
- [jira] [Created] (FLINK-6333) Utilize Bloomfilters in RocksDb - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/20 01:52:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6334) Refactoring UDTF interface - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/04/20 01:56:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6335) Support DISTINCT over grouped window in stream SQL - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/04/20 07:17:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6336) Placement Constraints for Mesos - posted by "Stephen Gran (JIRA)" <ji...@apache.org> on 2017/04/20 09:21:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6337) Remove the buffer provider from PartitionRequestServerHandler - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/04/20 10:22:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6339) Remove useless and unused class ConnectorSource - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/04/20 12:16:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6338) SimpleStringUtils should be called StringValueUtils - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/04/20 12:16:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6340) Introduce a TerminationFuture for Execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/04/20 12:21:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6341) JobManager can go to definite message sending loop when TaskManager registered - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/04/20 12:26:04 UTC, 0 replies.
- Why TimerService interface in ProcessFunction doesn't have deleteEventTimeTimer - posted by Jagadish Bihani <ja...@helpshift.com> on 2017/04/20 12:26:33 UTC, 0 replies.
- [jira] [Created] (FLINK-6342) Start ZooKeeperLeaderElectionService under lock to avoid race condition - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/04/20 14:45:04 UTC, 0 replies.
- Idempotent Job Submission - posted by James Bucher <jb...@expedia.com> on 2017/04/20 16:20:11 UTC, 1 replies.
- [jira] [Created] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/20 23:41:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6344) Migrate from Java serialization for `BucketingSink`'s state - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/20 23:49:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6345) Migrate from Java serialization for ContinuousFileReaderOperator's state - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/20 23:51:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6346) Migrate from Java serialization for GenericWriteAheadSink's state - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/20 23:52:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6347) Migrate from Java serialization for MessageAcknowledgingSourceBase's state - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/20 23:53:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6348) Migrate from Java serialization for RollingSink's state - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/20 23:54:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/21 00:08:04 UTC, 0 replies.
- Towards a spec for robust streaming SQL, Part 1 - posted by Tyler Akidau <ta...@google.com.INVALID> on 2017/04/21 00:57:42 UTC, 6 replies.
- [jira] [Created] (FLINK-6350) Flink: Windowing does not work with streams from collections and the local execution environment - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/04/21 02:43:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/04/21 02:53:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/04/21 06:31:04 UTC, 0 replies.
- Re: [DISCUSS] Planning Release 1.3 - posted by Robert Metzger <rm...@apache.org> on 2017/04/21 07:06:51 UTC, 1 replies.
- [jira] [Created] (FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/04/21 09:42:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6354) Add documentation for migration away from Checkpointed interface - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/04/21 09:57:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6355) TableEnvironment support register TableFunction - posted by "Kaibo Zhou (JIRA)" <ji...@apache.org> on 2017/04/21 10:48:04 UTC, 0 replies.
- Question on checkpointing - posted by Blake Essing <es...@swbell.net> on 2017/04/21 16:48:36 UTC, 2 replies.
- Mesos component status for 1.3 - posted by Eron Wright <ew...@live.com> on 2017/04/21 18:26:32 UTC, 1 replies.
- [jira] [Created] (FLINK-6356) Make times() eager and enable allowing combinations. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/04/21 19:28:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6357) Parametertool get unrequested parameters - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/04/22 13:16:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6358) Write job details for Gelly examples - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/04/22 13:21:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6359) Utilize Hierarchical Timing Wheels for performant timer - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/22 14:43:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6360) Failed to create assembly for Scala 2.11 due to tools/change-scala-version.sh not changing flink-gelly-examples_2.10 - posted by "Jacek Laskowski (JIRA)" <ji...@apache.org> on 2017/04/22 16:02:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6361) Finalize the AggregateFunction interface and refactoring built-in aggregates - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/04/22 17:34:04 UTC, 0 replies.
- Resource overallocation - posted by Luis Alves <lm...@gmail.com> on 2017/04/22 17:42:24 UTC, 2 replies.
- [jira] [Created] (FLINK-6362) Unprotected access to registeredStates in SharedStateRegistry#getReferenceCount - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/22 18:33:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6363) Document precedence rules of Kryo serializer registrations - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/04/23 09:59:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6364) Implement incremental checkpointing in RocksDBStateBackend - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/04/23 11:52:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6365) Adapt default values of the Kinesis connector - posted by "Steffen Hausmann (JIRA)" <ji...@apache.org> on 2017/04/23 19:24:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6366) KafkaConsumer is not closed in FlinkKafkaConsumer09 - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/04/24 07:10:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6367) support custom header settings of allow origin - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/04/24 09:34:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6368) Grouping keys in stream aggregations have wrong order - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/04/24 11:58:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6369) Better support for overlay networks - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2017/04/24 12:55:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6370) FileAlreadyExistsException on startup - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/04/24 14:19:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6371) Return matched patterns as Map> instead of Map - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/04/24 14:54:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6372) change-scala-version.sh does not change version for flink-gelly-examples - posted by "vishnu viswanath (JIRA)" <ji...@apache.org> on 2017/04/24 16:37:05 UTC, 0 replies.
- [jira] [Created] (FLINK-6373) Add runtime support for distinct aggregation over grouped windows - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/04/24 18:36:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6374) In yarn cluster model, the -ys parameter is not take effect. - posted by "zhangrucong1982 (JIRA)" <ji...@apache.org> on 2017/04/25 01:46:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6375) Fix LongValue hashCode - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/04/25 02:19:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token. - posted by "zhangrucong1982 (JIRA)" <ji...@apache.org> on 2017/04/25 02:26:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6377) Support map types in the Table / SQL API - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/04/25 04:43:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6378) Implement FLIP-6 Flink-on-Mesos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/04/25 06:12:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6379) Implement FLIP-6 Mesos Resource Manager - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/04/25 06:14:04 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.2.1 (RC2) - posted by Robert Metzger <rm...@apache.org> on 2017/04/25 08:29:08 UTC, 4 replies.
- [jira] [Created] (FLINK-6380) BlobService concurrency issues between delete and put/get methods - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/04/25 09:06:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6381) Unnecessary synchronizing object in BucketingSink - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/04/25 11:08:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6382) Support all numeric types for generated graphs in Gelly examples - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/04/25 15:13:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6383) Add versioning for AbstractStreamOperator state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/04/25 16:22:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6384) PythonStreamer does not close python processes - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/04/25 17:17:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6385) HistoryServerTest.testFullArchiveLifecycle instable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/04/25 17:23:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6386) Missing bracket in 'Compiler Limitation' section - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/04/26 02:46:04 UTC, 0 replies.
- Question on window ProcessFunction - posted by 魏偉哲 <to...@gmail.com> on 2017/04/26 04:39:09 UTC, 4 replies.
- [jira] [Created] (FLINK-6387) Flink UI support access log - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/04/26 07:11:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2017/04/26 15:41:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6389) Upgrade hbase dependency to 1.3.1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/26 15:46:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6390) Add Trigger Hooks to the Checkpoint Coordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/04/26 16:41:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6391) fix build for scala 2.11 (gelly-examples) - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/04/26 22:42:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6392) Change the alias of Window from optional to essential. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/04/26 23:13:04 UTC, 0 replies.
- question about rowtime processfunction - are watermarks needed? - posted by Radu Tudoran <ra...@huawei.com> on 2017/04/27 08:51:02 UTC, 6 replies.
- Official Flink Docker images - posted by Patrick Lucas <pa...@data-artisans.com> on 2017/04/27 10:21:31 UTC, 2 replies.
- [jira] [Created] (FLINK-6393) Add Evenly Graph Generator to Flink Gelly - posted by "FlorianFan (JIRA)" <ji...@apache.org> on 2017/04/27 11:08:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6394) GroupCombine reuses instances even though object reuse is disabled - posted by "Jaromir Vanek (JIRA)" <ji...@apache.org> on 2017/04/27 11:46:05 UTC, 0 replies.
- [jira] [Created] (FLINK-6395) TestBases not marked as abstract - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/04/27 13:48:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6396) FsSavepointStreamFactoryTest fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/04/27 13:56:04 UTC, 0 replies.
- [DISCUSS] Feature Freeze - posted by Ufuk Celebi <uc...@apache.org> on 2017/04/27 14:24:17 UTC, 17 replies.
- [jira] [Created] (FLINK-6397) MultipleProgramsTestBase does not reset ContextEnvironment - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/04/27 14:55:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6398) RowSerializer's duplicate should always return a new instance - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/04/27 15:31:04 UTC, 0 replies.
- 回复:[DISCUSS] Feature Freeze - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2017/04/27 15:38:47 UTC, 0 replies.
- [jira] [Created] (FLINK-6399) Update default Hadoop download version - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/04/27 15:42:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6400) Lack of protection accessing masterHooks in CheckpointCoordinator#triggerCheckpoint - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/27 15:55:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6401) RocksDBPerformanceTest.testRocksDbRangeGetPerformance fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/04/27 15:55:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6402) Consider locking REAPER_THREAD_LOCK in SafetyNetCloseableRegistry#doRegister() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/27 16:00:07 UTC, 0 replies.
- [jira] [Created] (FLINK-6403) constructFlinkClassPath produces nondeterministic classpath - posted by "Andrew Roberts (JIRA)" <ji...@apache.org> on 2017/04/27 17:22:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6404) Ensure PendingCheckpoint is registered when calling Checkpoint Hooks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/04/27 20:36:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6405) Flink should be able to load a jar from s3 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/04/27 21:32:04 UTC, 0 replies.
- ElasticsearchSink Serialization Error - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2017/04/28 02:57:44 UTC, 0 replies.
- [jira] [Created] (FLINK-6406) Cleanup useless import - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/04/28 06:50:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6407) Upgrade AVRO dependency version to 1.8.x - posted by "Miguel (JIRA)" <ji...@apache.org> on 2017/04/28 07:38:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6408) Repeated loading of configuration files in hadoop filesystem code paths - posted by "Stephen Gran (JIRA)" <ji...@apache.org> on 2017/04/28 08:38:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6409) TUMBLE/HOP/SESSION_START/END do not resolve time field correctly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/04/28 09:19:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6410) build fails after changing Scala to 2.11 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/04/28 09:45:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6411) YarnApplicationMasterRunner should not interfere with RunningJobsRegistry - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/04/28 10:17:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6412) Stream has already been closed durign job cancel - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/04/28 10:38:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6413) Add stream operator callback to notify about consumed network buffer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/04/28 12:49:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/04/28 13:52:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6415) Make sure Flink artifacts have no specific logger dependency - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/04/28 14:40:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6416) Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/28 15:46:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6417) Wildcard support for read text file - posted by "Artiom Darie (JIRA)" <ji...@apache.org> on 2017/04/28 16:06:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6418) Support for dynamic state changes in CEP patterns - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/04/28 23:26:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6419) Better support for CEP quantified conditions in PatternSelect.select - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/04/28 23:57:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6420) Cleaner CEP API to specify conditions between events - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/04/29 00:34:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6421) Unchecked reflection calls in PojoSerializer - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/29 19:32:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6422) Unreachable code in FileInputFormat#createInputSplits - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/04/29 19:42:04 UTC, 0 replies.
- [jira] [Created] (FLINK-6423) JoinFunction can not be replaced with lambda - posted by "Moshe Sayag (JIRA)" <ji...@apache.org> on 2017/04/30 08:56:04 UTC, 0 replies.
- Supported Hadoop versions - posted by Greg Hogan <co...@greghogan.com> on 2017/04/30 11:16:17 UTC, 1 replies.
- [jira] [Created] (FLINK-6424) Add basic helper functions for map type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/04/30 17:09:04 UTC, 0 replies.