You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-12073) Support appropriate precision and scale processing of Decimal in Blink SQL - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/01 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12074) Fix typo in `flinkDev/building.md` - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/04/01 03:03:02 UTC, 0 replies.
- [jira] [Created] (FLINK-12075) Not able to submit jobs on YARN when there's a firewall - posted by "Richard Deurwaarder (JIRA)" <ji...@apache.org> on 2019/04/01 07:29:02 UTC, 0 replies.
- Re: [VOTE] Release 1.8.0, release candidate #4 - posted by Richard Deurwaarder <ri...@xeli.eu> on 2019/04/01 07:29:42 UTC, 1 replies.
- [jira] [Created] (FLINK-12076) Add support for generating optimized logical plan for batch simple group aggregate - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/01 08:42:00 UTC, 0 replies.
- Re: Expose per partition Kafka lag metric in Flink Kafka connector - posted by Shuyi Chen <su...@gmail.com> on 2019/04/01 08:52:17 UTC, 0 replies.
- [jira] [Created] (FLINK-12077) Introduce HashJoinOperator and LongHashJoinGenerator to blink - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/01 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12078) Abstract TaskEventPublisher interface for simplify NetworkEnvironment - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/04/01 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12079) Add support for generating optimized logical plan for join on batch - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/01 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12080) Add timestamp property to savepoint - posted by "jeremy huang (JIRA)" <ji...@apache.org> on 2019/04/02 06:20:00 UTC, 0 replies.
- [DISCUSS] FLIP-38 Support python language in flink TableAPI - posted by jincheng sun <su...@gmail.com> on 2019/04/02 08:02:56 UTC, 27 replies.
- Re: [DISCUSS] Python (and Non-JVM) Language Support in Flink - posted by jincheng sun <su...@gmail.com> on 2019/04/02 08:12:28 UTC, 0 replies.
- [jira] [Created] (FLINK-12081) Introduce aggregation operator code generator to blink batch - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/02 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12082) Bump up the jython-standalone version - posted by "aloyszhang (JIRA)" <ji...@apache.org> on 2019/04/02 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12083) Sink into Hbase, one of the task(slot) failed to read hbase-site.xml which has already added into classpath. - posted by "kelun wang (JIRA)" <ji...@apache.org> on 2019/04/02 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12084) Flink API extensions do not seems to include split method - posted by "Jacopo Gobbi (JIRA)" <ji...@apache.org> on 2019/04/02 14:31:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12085) Improve Mesos job cluster entry point 'MesosJobClusterEntrypoint' - posted by "Jacky Yin (JIRA)" <ji...@apache.org> on 2019/04/02 15:38:03 UTC, 0 replies.
- [jira] [Created] (FLINK-12086) AsyncFunction - Add access to a user defined Object for cleanup on timeout - posted by "Felix Wollschläger (JIRA)" <ji...@apache.org> on 2019/04/02 21:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12087) Introduce over window operators to blink batch - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/03 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12088) Introduce unbounded streaming inner join operator - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/04/03 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12089) Broadcasting Dynamic Configuration - posted by "langjingxiang (JIRA)" <ji...@apache.org> on 2019/04/03 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12090) Can the log on the Apache Flink Dashboard be partitioned by day? - posted by "彭洋 (JIRA)" <ji...@apache.org> on 2019/04/03 03:23:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12091) Can Flink support the historyserver function like spark? - posted by "彭洋 (JIRA)" <ji...@apache.org> on 2019/04/03 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12092) Doc of when `onTimer(...)` is called is inacc - posted by "Ling Wang (JIRA)" <ji...@apache.org> on 2019/04/03 03:41:00 UTC, 0 replies.
- Apply for JIRA permission - posted by Hefei Li <lh...@gmail.com> on 2019/04/03 06:18:53 UTC, 1 replies.
- [jira] [Created] (FLINK-12093) Apache Flink:Active MQ consumer job is getting finished after first message consume. - posted by "shiv kumar (JIRA)" <ji...@apache.org> on 2019/04/03 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12094) Introduce sort merge join operator to blink batch - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/03 07:31:00 UTC, 0 replies.
- Re: [Proposal] Shuffle resources lifecycle management - posted by zhijiang <wa...@aliyun.com.INVALID> on 2019/04/03 07:51:05 UTC, 0 replies.
- [jira] [Created] (FLINK-12095) Canceling vs cancelling - posted by "Mike Pedersen (JIRA)" <ji...@apache.org> on 2019/04/03 08:04:54 UTC, 0 replies.
- [jira] [Created] (FLINK-12096) Flink counter state getting stuck on usin - posted by "Yogesh Nandigamq (JIRA)" <ji...@apache.org> on 2019/04/03 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12097) Flink SQL hangs in StreamTableEnvironment.sqlUpdate, keeps executing and seems never stop, finally lead to java.lang.OutOfMemoryError: GC overhead limit exceeded - posted by "xu (JIRA)" <ji...@apache.org> on 2019/04/03 12:02:00 UTC, 0 replies.
- [DISCUSS] Drop Elasticssearch 1 connector - posted by Chesnay Schepler <ch...@apache.org> on 2019/04/03 12:09:56 UTC, 5 replies.
- [jira] [Created] (FLINK-12098) Add support for generating optimized logical plan for simple group aggregate on batch - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/03 12:21:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12099) Elasticsearch(1)SinkITCase fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/03 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12100) Kafka 0.10 tests fail on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/03 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12101) Race condition when concurrenty running uploaded jars via REST - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2019/04/03 13:48:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12102) FlinkILoopTest fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/03 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12103) Extend builtin operator metrics with user defined scope and variables - posted by "Ben Marini (JIRA)" <ji...@apache.org> on 2019/04/03 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12104) Flink Kafka fails with Incompatible KafkaProducer version / NoSuchFieldException sequenceNumbers - posted by "Tim (JIRA)" <ji...@apache.org> on 2019/04/03 17:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12105) TUMBLE INTERVAL value errors out for 100 or more value - posted by "Vinod Mehra (JIRA)" <ji...@apache.org> on 2019/04/03 17:33:02 UTC, 0 replies.
- [CANCEL][VOTE] Release 1.8.0, release candidate #4 - posted by Aljoscha Krettek <al...@apache.org> on 2019/04/03 20:32:49 UTC, 0 replies.
- [jira] [Created] (FLINK-12106) Jobmanager is killing FINISHED taskmanger containers, causing exception in still running Taskmanagers an - posted by "John (JIRA)" <ji...@apache.org> on 2019/04/03 21:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12107) Use Proxy For DataDog Validation - posted by "Luka Jurukovski (JIRA)" <ji...@apache.org> on 2019/04/04 02:43:00 UTC, 0 replies.
- contributor permission - posted by 邵志鹏 <bo...@163.com> on 2019/04/04 05:10:34 UTC, 3 replies.
- [VOTE] Release 1.8.0, release candidate #5 - posted by Aljoscha Krettek <al...@apache.org> on 2019/04/04 06:22:22 UTC, 10 replies.
- [jira] [Created] (FLINK-12108) Simplify splitting expressions into projections, aggregations & windowProperties - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/04/04 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12109) Flink SQL hangs in StreamTableEnvironment.sqlUpdate, finally lead to java.lang.StackOverflowError - posted by "xu (JIRA)" <ji...@apache.org> on 2019/04/04 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12110) Introduce API point for ShuffleService to get estimation of locally required memory - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/04/04 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12111) TaskManagerProcessFailureBatchRecoveryITCase fails due to removed Slot - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/04 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12112) AbstractTaskManagerProcessFailureRecoveryTest process output logging does not work properly - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/04 14:04:00 UTC, 0 replies.
- [Discuss] Semantics of event time for state TTL - posted by Andrey Zagrebin <an...@ververica.com> on 2019/04/04 14:55:17 UTC, 7 replies.
- [jira] [Created] (FLINK-12113) User code passing to fromCollection(Iterator, Class) not cleaned - posted by "yankai zhang (JIRA)" <ji...@apache.org> on 2019/04/04 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12114) Try to perform UDF By Reflection - posted by "dong (JIRA)" <ji...@apache.org> on 2019/04/04 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12115) Add support in Flink to persist state in Azure's blob store - posted by "Piyush Narang (JIRA)" <ji...@apache.org> on 2019/04/04 20:16:00 UTC, 0 replies.
- New contributor to Apache Flink - posted by Aizhamal Nurmamat kyzy <ai...@google.com.INVALID> on 2019/04/05 02:30:24 UTC, 1 replies.
- [jira] [Created] (FLINK-12116) Args autocast will cause exception for plan transformation in TableAPI - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2019/04/05 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12117) CassandraConnectorITCase fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/05 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12118) Documentation in left navigation is not in step with its content - posted by "Yu Haidong (JIRA)" <ji...@apache.org> on 2019/04/05 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12119) Add OWASP Dependency Check to Flink Build - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/04/05 22:04:00 UTC, 0 replies.
- [DISCUSS] Apache Flink at Season of Docs - posted by Aizhamal Nurmamat kyzy <ai...@google.com.INVALID> on 2019/04/05 22:43:30 UTC, 31 replies.
- SQL CLI and JDBC - posted by Hanan Yehudai <ha...@radcom.com> on 2019/04/07 09:23:54 UTC, 0 replies.
- [jira] [Created] (FLINK-12120) Introduce "select sum(b), count(c) from T group by a" in Blink batch - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/08 06:10:00 UTC, 0 replies.
- Re: SQL CLI and JDBC - posted by Fabian Hueske <fh...@gmail.com> on 2019/04/08 08:17:46 UTC, 7 replies.
- [DISCUSS] Adaptive Parallelism of Job Vertex - posted by Bo WANG <wb...@gmail.com> on 2019/04/08 08:28:40 UTC, 3 replies.
- [jira] [Created] (FLINK-12121) Use composition instead of inheritance for the InternalKeyContext logic in backend - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/04/08 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/04/08 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12123) Upgrade Jepsen to 0.1.13 in flink-jepsen - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/04/08 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12124) Security is not support dynamicProperties - posted by "zhouqi (JIRA)" <ji...@apache.org> on 2019/04/08 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12125) Add OVH to poweredby.zh.md and index.zh.md - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2019/04/08 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12126) Make relaxed rescaling behaviour accessible in REST interface - posted by "Joshua Schneider (JIRA)" <ji...@apache.org> on 2019/04/08 13:29:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12127) Move network related options to NetworkEnvironmentOptions - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/04/08 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12128) There is a typo on the website - posted by "Kenneth Yang (JIRA)" <ji...@apache.org> on 2019/04/09 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12129) CompressedViews need release heap buffers to reduce memory usage in blink - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/09 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12130) Apply command line options to configuration before install security modules - posted by "Victor Wong (JIRA)" <ji...@apache.org> on 2019/04/09 04:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12131) Resetting ExecutionVertex in region failover may cause inconsistency of IntermediateResult status - posted by "Zhu Zhu (JIRA)" <ji...@apache.org> on 2019/04/09 04:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12132) The example in /docs/ops/deployment/yarn_setup.md should be updated due to the change FLINK-2021 - posted by "Wang Geng (JIRA)" <ji...@apache.org> on 2019/04/09 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12133) Support unbounded aggregate in streaming table runtime - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/04/09 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12134) Decrease parallelism of tasks with too small input data size - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/04/09 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12135) Decrease parallelism of tasks with too small input data size - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/04/09 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12136) Increase parallelism of tasks with large input data size - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/04/09 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12137) Add more proper explanation on flink streaming connectors - posted by "JoongkeunYang (JIRA)" <ji...@apache.org> on 2019/04/09 07:53:00 UTC, 0 replies.
- Re: [DISCUSS] A more restrictive JIRA workflow - posted by Timo Walther <tw...@apache.org> on 2019/04/09 07:58:53 UTC, 14 replies.
- [jira] [Created] (FLINK-12138) Limit input split count of each source task for better failover experience - posted by "Zhu Zhu (JIRA)" <ji...@apache.org> on 2019/04/09 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12139) Flink on mesos - Parameterize disk space needed. - posted by "Juan (JIRA)" <ji...@apache.org> on 2019/04/09 08:23:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.8.0, release candidate #5 - posted by Aljoscha Krettek <al...@apache.org> on 2019/04/09 08:24:48 UTC, 1 replies.
- [jira] [Created] (FLINK-12140) Support queries like "select a, b, c, e from T1, T2 where T1.a = T2.d" run in batch mode - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/09 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2019/04/09 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12142) Add beforeSnapshot method to StreamOperator interface - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2019/04/09 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12143) Mechanism to ship plugin jars in the cluster - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/04/09 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12144) Option to prefer checkpoints on recovery - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2019/04/09 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12145) Host config in flink-web is incorrect - posted by "Ji Liu (JIRA)" <ji...@apache.org> on 2019/04/09 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12146) Remove unregister task from NetworkEnvironment to simplify the interface of ShuffleService - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/04/09 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12147) Error for monitor kafka metrics when Use influxDB metric plugins - posted by "ouyangwulin (JIRA)" <ji...@apache.org> on 2019/04/09 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12148) Give precedence to specified local jar when same mainClass is included in both lib and specified jar - posted by "leesf (JIRA)" <ji...@apache.org> on 2019/04/09 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12149) Support Proto for Streaming File Sink - posted by "Kailash Hassan Dayanand (JIRA)" <ji...@apache.org> on 2019/04/09 17:36:00 UTC, 0 replies.
- Support for ProtoBuf data format in StreamingFileSink - posted by Kailash Dayanand <kd...@lyft.com.INVALID> on 2019/04/09 18:35:11 UTC, 4 replies.
- [jira] [Created] (FLINK-12150) Flink on mesos failed to created TaskManager while cache directory is gone - posted by "JackHe (JIRA)" <ji...@apache.org> on 2019/04/10 01:29:00 UTC, 0 replies.
- Flink contributor permission application - posted by 乐夏 <xi...@gmail.com> on 2019/04/10 02:29:15 UTC, 1 replies.
- [jira] [Created] (FLINK-12151) Drop Elasticsearch 1 connector - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/10 08:23:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.8.0 released - posted by Aljoscha Krettek <al...@apache.org> on 2019/04/10 08:31:14 UTC, 18 replies.
- [jira] [Created] (FLINK-12152) Make the vcore that Application Master used configurable for Flink on YARN - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/04/10 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12153) 提交flink job到flink环境下报错 - posted by "gaojunjie (JIRA)" <ji...@apache.org> on 2019/04/10 09:06:00 UTC, 1 replies.
- [jira] [Created] (FLINK-12154) Remove legacy fields for SingleInputGate - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/04/10 09:25:00 UTC, 0 replies.
- Introducing Flink's Plugin mechanism - posted by Piotr Nowojski <pi...@ververica.com> on 2019/04/10 09:48:05 UTC, 7 replies.
- [jira] [Created] (FLINK-12155) Remove legacy TaskManager - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/04/10 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12156) Remove legacy FlinkActor - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/04/10 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12157) Update maven download links to point to mvn central - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/10 11:55:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API - posted by Becket Qin <be...@gmail.com> on 2019/04/10 13:36:43 UTC, 0 replies.
- [jira] [Created] (FLINK-12158) Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7 - posted by "leesf (JIRA)" <ji...@apache.org> on 2019/04/10 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12159) Enable YarnMiniCluster integration test under non-secure mode - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/04/10 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12160) Support for transferring user config files on kubernetes - posted by "Yang Wang (JIRA)" <ji...@apache.org> on 2019/04/11 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12161) Supports partial-final optimization for stream group aggregate - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/11 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12162) Build error in flink-table-planner - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/04/11 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12163) Hadoop Compatibility, Could not load the TypeInformation due to incorrect classloader - posted by "morvenhuang (JIRA)" <ji...@apache.org> on 2019/04/11 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12164) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/04/11 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12165) Add resolution rule that checks all unresolved expressions are resolved - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/04/11 09:23:00 UTC, 0 replies.
- Request for contributor permission - posted by Run <fa...@foxmail.com> on 2019/04/11 11:50:27 UTC, 1 replies.
- [Discuss] Add support for Apache Arrow - posted by Run <fa...@foxmail.com> on 2019/04/11 12:21:12 UTC, 1 replies.
- Flink Forward Europe 2019 - Call for Presentations open until 17th May - posted by Fabian Hueske <fh...@gmail.com> on 2019/04/11 13:46:22 UTC, 0 replies.
- [jira] [Created] (FLINK-12166) env.java.opts not taken into account on Windows - posted by "Michał Jedynak (JIRA)" <ji...@apache.org> on 2019/04/11 19:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12167) ClusterClient doesn't unset the context class loader after program run - posted by "Abdul Qadeer (JIRA)" <ji...@apache.org> on 2019/04/12 01:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12168) Support e2e limit, sortLimit, rank, union in blink batch - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/12 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12169) Improve Javadoc of MessageAcknowledgingSourceBase - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/04/12 08:15:00 UTC, 0 replies.
- [Discuss][FLINK-8297]A solution for FLINK-8297 Timebased RocksDBListState - posted by Faxian Zhao <fa...@gmail.com> on 2019/04/12 08:33:55 UTC, 6 replies.
- [jira] [Created] (FLINK-12170) Add support for generating optimized logical plan for Over aggregate - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/12 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12171) The network buffer memory size should not be checked against the heap size on the TM side - posted by "Yun Gao (JIRA)" <ji...@apache.org> on 2019/04/12 11:56:00 UTC, 0 replies.
- Re: [DISCUSS] Create a Flink ecosystem website - posted by Daryl Roberts <da...@ververica.com> on 2019/04/12 12:51:58 UTC, 3 replies.
- [jira] [Created] (FLINK-12172) Flink fails to close pending BucketingSink - posted by " Mario Georgiev (JIRA)" <ji...@apache.org> on 2019/04/12 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/04/12 15:39:00 UTC, 0 replies.
- [PROGRESS-UPDATE] Redesign Flink Scheduling, introducing dedicated Scheduler Component - posted by Gary Yao <ga...@ververica.com> on 2019/04/12 15:52:56 UTC, 4 replies.
- [jira] [Created] (FLINK-12174) Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/04/12 16:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12175) TypeExtractor.getMapReturnTypes produces different TypeInformation than createTypeInformation for classes with parameterized ancestors - posted by "Dylan Adams (JIRA)" <ji...@apache.org> on 2019/04/12 19:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12176) Unify JobGraph creation in CliFrontend - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/04/13 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12177) Remove legacy FlinkUntypedActor - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/04/13 04:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12178) Remove legacy Scheduler - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/04/13 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12179) Remove legacy Instance - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/04/13 04:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12180) Port ExecutionVertexCancelTest to new codebase - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/04/13 04:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12181) Port ExecutionGraphRestartTest to new codebase - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/04/13 04:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12182) AggregateProjectMergeRule can not handle LogicalWindowAggregate - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/04/13 07:14:00 UTC, 0 replies.
- contributor permission request - posted by Fei5 Yang 杨飞 <ya...@xiaomi.com> on 2019/04/13 07:28:01 UTC, 1 replies.
- request contributor permission - posted by 杨飞 <ya...@gmail.com> on 2019/04/13 07:44:31 UTC, 1 replies.
- [jira] [Created] (FLINK-12183) Job Cluster doesn't release resources after cancel a running job in per-job Yarn mode - posted by "Yumeng Zhang (JIRA)" <ji...@apache.org> on 2019/04/13 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12184) HistoryServerArchiveFetcher isn't compatible with old version - posted by "Yumeng Zhang (JIRA)" <ji...@apache.org> on 2019/04/13 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12185) Add support for generating optimized logical plan for join on stream - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/13 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12186) Add implementation of FLIP-23 - Model Serving - posted by "Boris Lublinsky (JIRA)" <ji...@apache.org> on 2019/04/13 18:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12187) wrap FileWriter with BufferedWriter for better performance - posted by "bd2019us (JIRA)" <ji...@apache.org> on 2019/04/14 04:33:00 UTC, 0 replies.
- [DISCUSS] Backtracking for failover regions - posted by Chesnay Schepler <ch...@apache.org> on 2019/04/14 18:20:24 UTC, 2 replies.
- for subcribe - posted by Tyrion W <wa...@gmail.com> on 2019/04/15 02:29:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12188) Flink Deployment Docs to GCP is not updated for 2 years.. - posted by "Chethan U (JIRA)" <ji...@apache.org> on 2019/04/15 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12189) Fix bugs and typos in memory management related classes - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/04/15 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12190) Fix NPE throwed by FlinkKinesisConsumerMigrationTest#writeSnapshot - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/04/15 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12191) Flink SVGs on "Material" page broken, render incorrectly on Firefox - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2019/04/15 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12192) Add support for generating optimized logical plan for grouping sets and distinct aggregate - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/15 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12193) [Distributed Coordination] Send TM "can be released status" with RM heartbeat - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/04/15 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12194) Enable setting in DataStreamAllroundTestProgram - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/04/15 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12195) Incorrect resource time setting causes flink to fail to submit - posted by "tangshangwen (JIRA)" <ji...@apache.org> on 2019/04/15 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12196) FlinkKafkaProducerITCase#testRunOutOfProducersInThePool throws NPE - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/04/15 11:08:00 UTC, 1 replies.
- Re: [REMINDER] Please add entries for newly added dependencies to NOTICE file - posted by Robert Metzger <rm...@apache.org> on 2019/04/15 13:11:43 UTC, 0 replies.
- [jira] [Created] (FLINK-12197) Avro row deser for Confluent binary format - posted by "eugen yushin (JIRA)" <ji...@apache.org> on 2019/04/15 13:12:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12198) Flink JDBC Connector: Update existing JDBCInputFormat to support setting auto-commit mode of DB connection - posted by "Konstantinos Papadopoulos (JIRA)" <ji...@apache.org> on 2019/04/15 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12199) Refactor IOMetrics to not distinguish between local/remote - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/04/15 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12200) [Table API] Support UNNEST for MAP types - posted by "Artsem Semianenka (JIRA)" <ji...@apache.org> on 2019/04/15 15:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12201) Introduce InputGateWithMetrics in Task to increment in/out byte metrics - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/04/15 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12202) Consider introducing batch metric register in NetworkEnviroment - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/04/15 15:40:00 UTC, 0 replies.
- How can I use 1.9-SNAPSHOT Blink version for MapBundleFunction? - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/04/15 15:47:22 UTC, 1 replies.
- [jira] [Created] (FLINK-12203) Refactor ResultPartitionManager to break tie with Task - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/04/15 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12204) Improve JDBCOutputFormat ClassCastException - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2019/04/15 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12205) Internal server error., - posted by "Hobo Chen (JIRA)" <ji...@apache.org> on 2019/04/15 16:16:01 UTC, 0 replies.
-
[jira] [Created] (FLINK-12206) cannot query nested fields using Flink SQL - posted by "Yu Yang (JIRA)" <ji...@apache.org> on 2019/04/15 19:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12207) JsonRowDeserializationSchema and JsonRowSerializationSchema Types "==" bug - posted by "lynn (JIRA)" <ji...@apache.org> on 2019/04/16 01:48:00 UTC, 0 replies.
- Contributor permission Request - posted by Kevin Tang <ke...@gmail.com> on 2019/04/16 02:19:40 UTC, 7 replies.
- [jira] [Created] (FLINK-12208) Introduce Sort / TemporalSort / SortLimit/ Limit operators for blink streaming runtime - posted by "Jing Zhang (JIRA)" <ji...@apache.org> on 2019/04/16 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12209) Refactor failure handling with CheckpointFailureManager - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/04/16 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12210) Fix a bug in AbstractPagedInputView.readLine - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/04/16 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12211) Add more it cases to blink batch - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/16 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12212) Clarify documentation about async checkpointing - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/04/16 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12213) Pass TaskManagerMetricGroup into constructor of NetworkEnvironment - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/04/16 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12214) Add JobListener to capture job submission process - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/04/16 11:50:00 UTC, 0 replies.
- [DISCUSS] [FLINK SQL] External catalog for Confluent Kafka - posted by Artsem Semianenka <ar...@gmail.com> on 2019/04/16 15:35:03 UTC, 10 replies.
- Using guava ImmutableMap Serializer from magro/kyro-serializers - posted by vijikarthi <vi...@yahoo.com> on 2019/04/16 20:45:11 UTC, 2 replies.
- [jira] [Created] (FLINK-12215) Introduce SqlProcessFunction for blink streaming runtime - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/04/17 02:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12216) Respect the number of bytes from input parameters in HybridMemorySegment - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/04/17 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12217) OperationTreeBuilder.map() should perform ExpressionResolver.resolve() - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/04/17 04:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12218) Report more record information in IOMetrics for Speculative Schedule - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/04/17 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12219) Yarn application can't stop when flink job failed in per-job yarn cluste mode - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2019/04/17 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12220) Speculatively schedule execution for long tail task - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/04/17 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12221) Distinguish long tail task based on IOMetrics - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/04/17 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/04/17 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12223) HeapMemorySegment.getArray should return null after being freed - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/04/17 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12224) Kafka 0.10 e2e test fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/17 09:57:00 UTC, 0 replies.
- [DISCUSS] Update our Roadmap - posted by Fabian Hueske <fh...@gmail.com> on 2019/04/17 11:50:28 UTC, 7 replies.
- [jira] [Created] (FLINK-12225) Simplify the interface of the PartFileWriter - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/04/17 12:41:00 UTC, 0 replies.
- Contribute to Flink - posted by QingA Li <mo...@gmail.com> on 2019/04/17 12:58:11 UTC, 1 replies.
- Request for JIRA Contributor Permission - posted by "DONG, Weike" <ky...@connect.hku.hk> on 2019/04/17 13:17:34 UTC, 1 replies.
- [jira] [Created] (FLINK-12226) Add documentation about SUSPEND/TERMINATE - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2019/04/17 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12227) Introduce SchedulingStrategy interface - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/04/17 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12228) Implement Eager Scheduling Strategy - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/04/17 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12229) Implement Lazy Scheduling Strategy - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/04/17 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12230) Remove getExecutionGraph() and getRestartStrategy() from JobMaster - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/04/17 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12231) Introduce Scheduler interface and adapt ExecutionGraph to it - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/04/17 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12232) Support database related operations in HiveCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12233) Support table related operations in HiveCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12235) Support partition related operations in HiveCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12234) Support viewrelated operations in HiveCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12236) Support function related operations in HiveCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12237) Support table stats related operations in HiveCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12238) Support database related operations in GenericHiveMetastoreCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12239) Support table related operations in GenericHiveMetastoreCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12240) Support view related operations in GenericHiveMetastoreCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12241) Support function related operations in GenericHiveMetastoreCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12242) Support partition related operations in GenericHiveMetastoreCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12243) Support table stats related operations in GenericHiveMetastoreCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/17 17:56:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12244) SynchronousCheckpointITCase hang up - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/04/18 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12245) Transient slot allocation failure on job recovery - posted by "Hwanju Kim (JIRA)" <ji...@apache.org> on 2019/04/18 04:56:00 UTC, 0 replies.
- [Discuss] Add JobListener (hook) in flink job lifecycle - posted by Jeff Zhang <zj...@gmail.com> on 2019/04/18 05:29:52 UTC, 7 replies.
- [jira] [Created] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2019/04/18 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12247) fix NPE when writing an archive file to a FileSystem - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2019/04/18 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12248) Support e2e over window in blink batch - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/18 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12249) Type equivalence check fails for Window Aggregates - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/04/18 07:09:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-37: Rework of the Table API Type System (Part 1) - posted by Timo Walther <tw...@apache.org> on 2019/04/18 09:23:42 UTC, 0 replies.
- [jira] [Created] (FLINK-12250) Rewrite assembleNewPartPath to let it return a new PartPath - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/04/18 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12251) Rework the Table API & SQL type system - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/04/18 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12252) Support not escaped table name for External Catalogs in INSERT SQL statement - posted by "Artsem Semianenka (JIRA)" <ji...@apache.org> on 2019/04/18 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12253) Setup a class hierarchy for the new type system - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/04/18 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12254) Expose the new type system through the API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/04/18 10:27:00 UTC, 0 replies.
- I want to subscribe Flink mail group - posted by Armstrong <ar...@gmail.com> on 2019/04/18 11:32:41 UTC, 1 replies.
- HA lock nodes, Checkpoints, and JobGraphs after failure - posted by "dyana.rose" <dy...@salecycle.com> on 2019/04/18 13:12:07 UTC, 3 replies.
- [jira] [Created] (FLINK-12255) Rename a few exception class names that were migrated from scala - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/04/18 14:28:00 UTC, 0 replies.
- Apply for contributor permission - posted by peng2251 <pe...@163.com> on 2019/04/18 15:04:53 UTC, 7 replies.
- [jira] [Created] (FLINK-12256) Implement KafkaReadableCatalog - posted by "Artsem Semianenka (JIRA)" <ji...@apache.org> on 2019/04/18 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12257) Convert CatalogBaseTable to org.apache.calcite.schema.Table so that planner can use unified catalog APIs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/18 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12258) Decouple CatalogManager with Calcite - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/18 17:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12259) Improve debuggability of method invocation failures in OptimizerPlanEnvironment - posted by "Gaurav (JIRA)" <ji...@apache.org> on 2019/04/18 21:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12260) Slot allocation failure by taskmanager registration timeout and race - posted by "Hwanju Kim (JIRA)" <ji...@apache.org> on 2019/04/19 00:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12261) Support e2e group window in blink batch - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/04/19 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12262) Benefit of Watching TV Shows on the YesMovies Website - posted by "Sansa Stark (JIRA)" <ji...@apache.org> on 2019/04/19 04:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12263) Remove SINGLE_VALUE aggregate function from physical plan - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/04/19 06:43:00 UTC, 0 replies.
- RE: kafka partitions, data locality - posted by "Smirnov Sergey Vladimirovich (39833)" <s....@tinkoff.ru.INVALID> on 2019/04/19 09:48:35 UTC, 5 replies.
- [jira] [Created] (FLINK-12264) Port ExecutionGraphTestUtils to new code base - posted by "leesf (JIRA)" <ji...@apache.org> on 2019/04/19 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12265) link-table-planner-blink UT Failure: SortDistinctAggregateITCase.testSomeColumnsBothInDistinctAggAndGroupBy - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/19 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12266) add NOTICE file for dependencies that are newly introduced in flink-connector-hive - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/19 17:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12267) Port SimpleSlotTest to new code base - posted by "leesf (JIRA)" <ji...@apache.org> on 2019/04/20 01:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12268) Port SharedSlotsTest to new code base - posted by "leesf (JIRA)" <ji...@apache.org> on 2019/04/20 01:21:00 UTC, 0 replies.
- Hello, I want to subscribe Flink dev mail group - posted by Armstrong <ar...@gmail.com> on 2019/04/20 02:32:02 UTC, 1 replies.
- hello - posted by Armstrong <ar...@gmail.com> on 2019/04/20 02:37:51 UTC, 0 replies.
- [jira] [Created] (FLINK-12269) Support Temporal Table Join in blink planner - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/04/20 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12270) SortDistinctAggregateITCase fails on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/20 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12271) Display input field name list when throw Cannot resolve field exception - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/04/20 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12272) Enable session in ExecutionEnvironment - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/04/20 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure. - posted by "Mr.Nineteen (JIRA)" <ji...@apache.org> on 2019/04/20 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12274) Fix documentation to enable Queryable State - posted by "Pierre Zemb (JIRA)" <ji...@apache.org> on 2019/04/20 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12275) Add documentation for GenericHiveMetastoreCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/20 22:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12276) Add documentation for HiveCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/20 22:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12277) Add documentation for unified catalog APIs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/20 22:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12278) Support user implemented and customized catalogs thru dynamic class loading - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/20 22:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12279) Create source to allow streaming data from websocket. - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2019/04/20 22:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12280) Add documentation for catalog entries in SQL client YAML file - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/20 22:38:00 UTC, 0 replies.
- Flink connectors to Oracle Cloud Infrastructure services - posted by Михаил Тучков <tu...@gmail.com> on 2019/04/20 22:44:40 UTC, 1 replies.
- [jira] [Created] (FLINK-12281) SortDistinctAggregateITCase>DistinctAggregateITCaseBase.testSomeColumnsBothInDistinctAggAndGroupBy Failed - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/04/21 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12282) re-estimate row count for batch global Rank operator - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/21 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12283) Allow non static UDF - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/04/22 05:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12284) InputBufferPoolUsage is incorrect in credit-based network control flow - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2019/04/22 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12285) Memory leak in SavepointITCase and SavepointMigrationTestBase - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2019/04/22 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12286) The default log4j.properties will overwrite the customized log4j property file. - posted by "Tang Yan (JIRA)" <ji...@apache.org> on 2019/04/22 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12287) A document error in "StreamElement.java" - posted by "YangFei (JIRA)" <ji...@apache.org> on 2019/04/22 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12288) Bump Calcite dependency to 1.19.0 in blink planner - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/04/22 09:41:00 UTC, 0 replies.
- I want to apply Flink JIRA contributor - posted by Armstrong <ar...@gmail.com> on 2019/04/22 10:57:33 UTC, 1 replies.
- [jira] [Created] (FLINK-12289) Fix bugs and typos in Memory manager - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/04/22 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12290) Fix the misleading exception message in SharedSlot class - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/04/22 12:08:00 UTC, 0 replies.
- Flink Filesystems [FLINK-12115] - Review adding Azure FS support - posted by Piyush Narang <p....@criteo.com> on 2019/04/22 15:10:21 UTC, 1 replies.
- [jira] [Created] (FLINK-12291) Add benchmarks for the input processors - posted by "Haibo Sun (JIRA)" <ji...@apache.org> on 2019/04/23 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12292) Add benchmarks for the input processors - posted by "Haibo Sun (JIRA)" <ji...@apache.org> on 2019/04/23 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12293) Fix some comment typos in flink-streaming-java. - posted by "Ji Liu (JIRA)" <ji...@apache.org> on 2019/04/23 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12294) kafka consumer, data locality - posted by "Sergey (JIRA)" <ji...@apache.org> on 2019/04/23 06:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12295) use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/23 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator chained in a single task - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/04/23 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12297) We should clean the closure for OutputTags - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/04/23 06:55:00 UTC, 0 replies.
- [DISCUSS] Proposal of Flink Driver - Making Flink More Interactive - posted by Shuiqiang Chen <ac...@gmail.com> on 2019/04/23 08:01:49 UTC, 2 replies.
- [jira] [Created] (FLINK-12298) Make column functions accept custom - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/04/23 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12299) ExecutionConfig#setAutoWatermarkInterval should check param(interval should not less than zero) - posted by "shiwuliang (JIRA)" <ji...@apache.org> on 2019/04/23 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12300) Unused Import warning with DataStream[Seq[...]] - posted by "Michael (JIRA)" <ji...@apache.org> on 2019/04/23 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12301) Scala value classes cannot be serialized anymore in case classes in Flink 1.8.0 - posted by "Michael (JIRA)" <ji...@apache.org> on 2019/04/23 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12302) fix the finalStatus of application when job not finished - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2019/04/23 11:52:02 UTC, 0 replies.
- [jira] [Created] (FLINK-12303) Scala 2.12 lambdas does not work in event classes inside streams. - posted by "Matěj Novotný (JIRA)" <ji...@apache.org> on 2019/04/23 12:02:00 UTC, 0 replies.
- Apache Flink survey by Ververica - posted by Robert Metzger <ro...@ververica.com> on 2019/04/23 13:28:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12304) AvroInputFormat should support schema evolution - posted by "John (JIRA)" <ji...@apache.org> on 2019/04/23 15:12:00 UTC, 0 replies.
- [DISCUSS] Temporarily remove support for job rescaling via CLI action "modify" - posted by Gary Yao <ga...@ververica.com> on 2019/04/23 17:36:14 UTC, 6 replies.
- [jira] [Created] (FLINK-12305) Table API Clarification - posted by "Alex Barnes (JIRA)" <ji...@apache.org> on 2019/04/23 21:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12306) Change the name of variable "log" to Upper case "LOG" - posted by "Kejian Li (JIRA)" <ji...@apache.org> on 2019/04/24 01:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12307) Support translation from StreamExecWindowJoin to StreamTransformation. - posted by "Jing Zhang (JIRA)" <ji...@apache.org> on 2019/04/24 04:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12308) Support python language in Flink Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/04/24 05:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12309) JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align - posted by "FaxianZhao (JIRA)" <ji...@apache.org> on 2019/04/24 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12310) shade user facing common libraries in flink-connector-hive - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/04/24 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12311) Add base python framework and Add Scan, Projection, and Filter operator support - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/04/24 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12312) Remove CLI command for rescaling - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/04/24 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12313) SynchronousCheckpointITCase.taskCachedThreadPoolAllowsForSynchronousCheckpoints is unstable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2019/04/24 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12314) Translate "Types Serializationn" into Chinese - posted by "YangFei (JIRA)" <ji...@apache.org> on 2019/04/24 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12315) SynchronousCheckpointITCase deadlocks on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/24 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12316) JDBCFullTest fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/24 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12317) SynchronousCheckpointITCase fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/24 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12318) TimestampITCase deadlocks on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/24 10:11:00 UTC, 0 replies.
- contributor - posted by cc c <cx...@gmail.com> on 2019/04/24 10:41:45 UTC, 1 replies.
- Re: [DISCUSS] FLIP-33: Standardize connector metrics - posted by Stephan Ewen <se...@apache.org> on 2019/04/24 11:28:34 UTC, 0 replies.
- [jira] [Created] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer - posted by "Marco Pfatschbacher (JIRA)" <ji...@apache.org> on 2019/04/24 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12320) Flink bucketing sink restart with save point cause data loss when using SequenceFile.CompressionType.BLOCK - posted by "shin chen (JIRA)" <ji...@apache.org> on 2019/04/24 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12321) Supports sub-plan reuse - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/24 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12322) Remove legacy ActorTaskManagerGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/04/24 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12323) Remove legacy ActorGateway implementations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/04/24 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12324) Remove ActorGateway interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/04/24 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12325) Statsd reporter gives wrong metrics when using negative numbers - posted by "Richard Deurwaarder (JIRA)" <ji...@apache.org> on 2019/04/24 18:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12326) Add a basic test framework, just like the existing Java TableAPI, abstract some TestBase. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/04/25 01:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12327) Add simplicity support for submitting Python Table API job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple test). - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/04/25 01:53:00 UTC, 0 replies.
- JIRA Contributor Permission Application - posted by 张俸铭 <15...@163.com> on 2019/04/25 02:19:37 UTC, 0 replies.
- [jira] [Created] (FLINK-12328) Invalid Express - posted by "chauncy (JIRA)" <ji...@apache.org> on 2019/04/25 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12329) Netty thread deadlock bug of the SpilledSubpartitionView - posted by "Yingjie Cao (JIRA)" <ji...@apache.org> on 2019/04/25 04:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12330) Add integrated Tox for ensuring compatibility with the python2/3 version - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/04/25 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12331) Introduce partition/gate setup to decouple task registration with NetworkEnvironment - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/04/25 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12332) Cancel running tasks if exist before shutting down TM - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2019/04/25 10:51:00 UTC, 0 replies.
- [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component - posted by vino yang <ya...@gmail.com> on 2019/04/25 14:18:20 UTC, 12 replies.
- [jira] [Created] (FLINK-12333) Add documentation around save point with cancel lifecycle through REST - posted by "Vishal Santoshi (JIRA)" <ji...@apache.org> on 2019/04/25 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12334) change to MockStreamTask breaks OneInputStreamOperatorTestHarness - posted by "Cliff Resnick (JIRA)" <ji...@apache.org> on 2019/04/25 21:32:00 UTC, 0 replies.
- Containers are not released after job failed - posted by 刘建刚 <li...@gmail.com> on 2019/04/26 09:15:25 UTC, 0 replies.
- [jira] [Created] (FLINK-12335) Improvement the performance of class SegmentsUtil - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/04/26 09:43:01 UTC, 0 replies.
- How to let Flink 1.7.X run Flink session cluster on YARN in Java 7 default environment - posted by 胡逸才 <hu...@163.com> on 2019/04/26 09:48:00 UTC, 4 replies.
- [jira] [Created] (FLINK-12336) Handle HTTPS InfluxDB database - posted by "Etienne Carriere (JIRA)" <ji...@apache.org> on 2019/04/26 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12337) [TableSQL/Planner] InsertInto method should configure TableSink - posted by "Artsem Semianenka (JIRA)" <ji...@apache.org> on 2019/04/26 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12338) Update Apache Avro test to use try-with-resources - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/04/26 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12339) Modify the wrong variable name of topSeed in example - posted by "jianlong miao (JIRA)" <ji...@apache.org> on 2019/04/26 13:20:00 UTC, 0 replies.
- [DISCUSS] Bump required Maven version to 3.1.1 (from 3.0.3) - posted by Robert Metzger <rm...@apache.org> on 2019/04/26 13:43:14 UTC, 5 replies.
- Re: [DISCUSS] Improve Queryable State and introduce aQueryServerProxy component - posted by bupt_ljy <bu...@163.com> on 2019/04/26 13:45:36 UTC, 1 replies.
- [jira] [Created] (FLINK-12340) Cache frontend-maven-plugin npm artifacts - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2019/04/26 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12341) Add CLI command for rescaling - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/04/26 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12342) Yarn Resource Manager Acquire Too Many Containers - posted by "Zhenqiu Huang (JIRA)" <ji...@apache.org> on 2019/04/26 17:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12343) Allow set hdfs.replication in FlinkYarnSessionCli - posted by "Zhenqiu Huang (JIRA)" <ji...@apache.org> on 2019/04/26 17:50:00 UTC, 0 replies.
- 申请 JIRA Contributor 权限 - posted by 叶问 <ye...@gmail.com> on 2019/04/27 01:10:20 UTC, 1 replies.
- Re: Warning from dev@flink.apache.org - posted by aitozi <gj...@gmail.com> on 2019/04/27 08:21:35 UTC, 1 replies.
- [jira] [Created] (FLINK-12344) Remove legacy runtime messages - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/04/27 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12345) Add support for generating optimized logical plan for stream window aggregate - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/27 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12346) Scala-suffix check broken on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/27 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12347) flink-table-runtime-blink is missing scala suffix - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/27 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module. - posted by "Jing Zhang (JIRA)" <ji...@apache.org> on 2019/04/28 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12349) [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount - posted by "Ji Liu (JIRA)" <ji...@apache.org> on 2019/04/28 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12350) RocksDBStateBackendTest doesn't cover the incremental checkpoint code path - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/04/28 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/04/28 03:40:00 UTC, 0 replies.
- The contradiction between event time and natural time from EventTimeTrigger - posted by 邵志鹏 <bo...@163.com> on 2019/04/28 05:12:55 UTC, 0 replies.
- [jira] [Created] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2019/04/28 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12353) Add missing module to collect_japicmp_reports.sh - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2019/04/28 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12354) Add Reverse function supported in Table API and SQL - posted by "Zhanchun Zhang (JIRA)" <ji...@apache.org> on 2019/04/28 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12355) KafkaITCase.testTimestamps is unstable - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/04/28 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12356) Optimise version experssion of flink-shaded-hadoop2(-uber) - posted by "Paul Lin (JIRA)" <ji...@apache.org> on 2019/04/28 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12357) Remove useless code in TableConfig - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/04/28 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2019/04/28 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12359) SystemResourcesMetricsITCase unstable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/04/28 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12360) Translate "Jobs and Scheduling" Page to Chinese - posted by "Armstrong Nova (JIRA)" <ji...@apache.org> on 2019/04/29 01:35:00 UTC, 0 replies.
- [DISCUSS] FLIP-39: Flink ML pipeline and ML libs - posted by Shaoxuan Wang <ws...@gmail.com> on 2019/04/29 02:34:22 UTC, 3 replies.
- [jira] [Created] (FLINK-12361) Remove useless expression from runtime scheduler - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/04/29 03:20:00 UTC, 0 replies.
- Application for Contributor Permission - posted by Hunk <tr...@163.com> on 2019/04/29 06:54:38 UTC, 4 replies.
- [jira] [Created] (FLINK-12362) Add container number config option for Flink on yarn job cluster mode - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/04/29 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12363) Refactor legacy rest handlers - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/04/29 07:20:00 UTC, 0 replies.
- Contributor Permission Application - posted by 张俸铭 <15...@163.com> on 2019/04/29 07:26:54 UTC, 1 replies.
- Contributor Permission Request - posted by 张晨 <pe...@gmail.com> on 2019/04/29 07:54:29 UTC, 1 replies.
- Contribute to flink - posted by jake <ft...@qq.com> on 2019/04/29 08:05:56 UTC, 1 replies.
- [jira] [Created] (FLINK-12364) Introduce a CheckpointFailureManager to centralized manage checkpoint failure - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/04/29 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12365) Add stats related catalog APIs - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/04/29 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12366) Clean up Catalog APIs to make them more consistent and coherent - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/04/29 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12367) Create rich versions of functions for Scala - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2019/04/29 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12368) add subtask index to FlinkKafkaConsumerBase logging, which can be very useful when debugging problem - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2019/04/29 22:18:00 UTC, 0 replies.
- I want to contribute to Apache Flink - posted by aihua li <li...@gmail.com> on 2019/04/30 02:02:04 UTC, 1 replies.
- Apply for confluence Wiki edit permission - posted by Shuiqiang Chen <ac...@gmail.com> on 2019/04/30 02:28:44 UTC, 1 replies.
- [jira] [Created] (FLINK-12369) Introducing next version failover strategy interfaces and implement a region failover strategy with it - posted by "Zhu Zhu (JIRA)" <ji...@apache.org> on 2019/04/30 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12370) Integrated Travis for Python Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/04/30 04:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12371) Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logical plan - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/30 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12372) Implement ExecutionSlotAllocator - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/04/30 06:57:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink-shaded 7.0 - posted by jincheng sun <su...@gmail.com> on 2019/04/30 09:26:52 UTC, 2 replies.
- Re: [DISCUSS] FLIP-23 Model Serving - posted by Robert Metzger <rm...@apache.org> on 2019/04/30 09:33:31 UTC, 0 replies.
- [jira] [Created] (FLINK-12373) Improve checkpointing metrics - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2019/04/30 09:34:00 UTC, 0 replies.
- Why isn't state supported in AsyncFunction? - posted by Dominik Wosiński <wo...@gmail.com> on 2019/04/30 10:20:15 UTC, 1 replies.
- Your application for Season of Docs 2019 was unsuccessful - posted by Andrew Chen <ch...@google.com.INVALID> on 2019/04/30 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12374) Support translation from StreamExecTableSourceScan/BatchExecTableSourceScan to StreamTransformation. - posted by "Jing Zhang (JIRA)" <ji...@apache.org> on 2019/04/30 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12375) flink-container job jar does not have read permissions - posted by "Adam Lamar (JIRA)" <ji...@apache.org> on 2019/04/30 18:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12376) GCS runtime exn: Request payload size exceeds the limit - posted by "Henrik (JIRA)" <ji...@apache.org> on 2019/04/30 20:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12377) Outdated docs (Flink 0.10) for Google Compute Engine - posted by "Henrik (JIRA)" <ji...@apache.org> on 2019/04/30 21:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12378) Consolidate FileSystem Documentation - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2019/04/30 21:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12379) Parallelism in job/GCS/Hadoop: Could not finalize the pending checkpoint - posted by "Henrik (JIRA)" <ji...@apache.org> on 2019/04/30 22:28:00 UTC, 0 replies.