You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer) - posted by "Yun Gao (JIRA)" <ji...@apache.org> on 2018/10/01 05:23:00 UTC, 0 replies.
- Request for contributor permission - posted by "yungao.gy" <yu...@aliyun.com.INVALID> on 2018/10/01 05:42:18 UTC, 3 replies.
- [jira] [Created] (FLINK-10470) Add method to check if pattern can produce empty matches - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/01 08:20:00 UTC, 0 replies.
- Re: [DISCUSS] Feature freeze for Flink 1.7 - posted by Piotr Nowojski <pi...@data-artisans.com> on 2018/10/01 08:43:23 UTC, 2 replies.
- [DISCUSS] Improvements to the Unified SQL Connector API - posted by Timo Walther <tw...@apache.org> on 2018/10/01 08:52:58 UTC, 9 replies.
- Re: [DISCUSS] Dropping flink-storm? - posted by Fabian Hueske <fh...@gmail.com> on 2018/10/01 08:55:40 UTC, 7 replies.
- 回复：Request for contributor permission - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2018/10/01 09:15:38 UTC, 0 replies.
- [jira] [Created] (FLINK-10471) State TTL cleanup using RocksDb compaction filter - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/10/01 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10472) Add CBRT math function supported in Table API and SQL - posted by "Aleksei Izmalkin (JIRA)" <ji...@apache.org> on 2018/10/01 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/10/01 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10474) Don't translate IN to JOIN with VALUES for streaming queries - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/10/01 14:26:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-23 Model Serving - posted by Fabian Hueske <fh...@gmail.com> on 2018/10/01 14:54:38 UTC, 1 replies.
- [jira] [Created] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader - posted by "Thomas Wozniakowski (JIRA)" <ji...@apache.org> on 2018/10/01 15:37:00 UTC, 0 replies.
- Re: Handling burst I/O when using tumbling/sliding windows - posted by Rong Rong <wa...@gmail.com> on 2018/10/01 15:48:23 UTC, 3 replies.
- [jira] [Created] (FLINK-10476) Change related ProcessFunction to KeyedProcessFunction in Sql/Table-api - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/10/02 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10477) Add rescale button to web interface - posted by "Sander Ploegsma (JIRA)" <ji...@apache.org> on 2018/10/02 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10478) Kafka Producer wrongly formats "%" for transaction ID - posted by "Obi Tetsuya (JIRA)" <ji...@apache.org> on 2018/10/02 08:42:00 UTC, 0 replies.
- Running job in detached mode via ClusterClient. - posted by Piotr Szczepanek <pi...@gmail.com> on 2018/10/02 09:13:50 UTC, 0 replies.
- [jira] [Created] (FLINK-10479) Add Firebase Firestore Connector - posted by "Niklas Gögge (JIRA)" <ji...@apache.org> on 2018/10/02 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10480) Add Firebase Firestore Connector - posted by "Niklas Gögge (JIRA)" <ji...@apache.org> on 2018/10/02 11:17:00 UTC, 0 replies.
- [DISCUSS] Move hadoop 2.4 test profiles to cron jobs - posted by Chesnay Schepler <ch...@apache.org> on 2018/10/02 11:49:36 UTC, 4 replies.
- Flink Low level APIs How To’s - posted by Ramesh Byndoor <in...@gmail.com> on 2018/10/02 13:21:32 UTC, 2 replies.
- [jira] [Created] (FLINK-10481) Wordcount end-to-end test in docker env unstable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/02 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2018/10/02 17:50:00 UTC, 0 replies.
- Flink operators for Kubernetes - posted by Anand Swaminathan <as...@lyft.com.INVALID> on 2018/10/02 20:30:04 UTC, 3 replies.
- [jira] [Created] (FLINK-10483) Can't restore from a savepoint even with Allow Non Restored State enabled - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/10/02 23:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10484) New latency tracking metrics format causes metrics cardinality explosion - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2018/10/02 23:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10485) Gremlin Support from Flink for Graph Processing - posted by "Wei Ding (JIRA)" <ji...@apache.org> on 2018/10/03 00:08:00 UTC, 0 replies.
- MapState support for operator state - posted by Dániel Berecz <be...@gmail.com> on 2018/10/03 00:23:43 UTC, 5 replies.
- [jira] [Created] (FLINK-10486) Recover local mode on flink startup - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2018/10/03 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10487) fix deprecated Flink SQL example - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/10/03 21:18:00 UTC, 0 replies.
- TPCH/TPCDS benchmark - posted by Jin Sun <is...@gmail.com> on 2018/10/03 21:24:27 UTC, 1 replies.
- Future of JobManager.scala - posted by Jin Sun <is...@gmail.com> on 2018/10/04 00:06:40 UTC, 2 replies.
- [jira] [Created] (FLINK-10488) Add DISTINCT operator for streaming tables that leverages time attributes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/10/04 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10489) Inconsistent window information for streams with EventTime characteristic - posted by "Alexis Sarda-Espinosa (JIRA)" <ji...@apache.org> on 2018/10/04 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/04 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10491) Deadlock during spilling data in SpillableSubpartition - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/10/04 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10492) Document generic support for configuring AwsKinesisClient in the Kinesis Consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/10/04 13:42:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #40 - posted by Till Rohrmann <tr...@apache.org> on 2018/10/04 14:23:47 UTC, 0 replies.
- [DISCUSS] Breaking the Scala API for Scala 2.12 Support - posted by Aljoscha Krettek <al...@apache.org> on 2018/10/04 15:10:43 UTC, 11 replies.
- [jira] [Created] (FLINK-10493) Macro generated CaseClassSerializer considered harmful - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/10/04 20:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10494) Rename 'JobManager' to J'obMaster' for some classes in JobMaster folder - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/10/04 21:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10495) Add HYPOT math function supported in Table API and SQL - posted by "Aleksei Izmalkin (JIRA)" <ji...@apache.org> on 2018/10/05 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10496) CommandLineParser arguments interleaving - posted by "eugen yushin (JIRA)" <ji...@apache.org> on 2018/10/05 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10497) More fine grained control over access to REST endpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 10:39:00 UTC, 0 replies.
- [ANNOUNCE] Feature freeze for Flink 1.7: 22nd of October - posted by Till Rohrmann <tr...@apache.org> on 2018/10/07 13:10:57 UTC, 0 replies.
- [jira] [Created] (FLINK-10498) Decouple ExecutionGraph from JobMaster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10499) Introduce declarative resource management switch - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10500) Let ExecutionGraphDriver react to fail signal - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10501) Obtain resource overview of cluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10502) Wait for resource stabilization - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 16:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10503) Periodically check for new resources - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 16:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10504) Decide actual parallelism based on available resources - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10505) Treat fail signal as scheduling event - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10506) Introduce minimum, target and maximum parallelism to JobGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10507) Set target parallelism to maximum when using the standalone job cluster mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/07 16:11:00 UTC, 0 replies.
- Sharing state between subtasks - posted by Thomas Weise <th...@apache.org> on 2018/10/07 19:58:13 UTC, 17 replies.
- Re: Enrich testing doc with more unit test examples using AbstractStreamOperator - posted by Tony Wei <to...@gmail.com> on 2018/10/08 01:46:41 UTC, 1 replies.
- [jira] [Created] (FLINK-10508) Port JobManagerITCase to new code base - posted by "tison (JIRA)" <ji...@apache.org> on 2018/10/08 04:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10509) Drop flink-storm - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/08 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10510) Bump asm version to 6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/08 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10511) Code duplication of creating RPC service in ClusterEntrypoint and AkkaRpcServiceUtils - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/10/08 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10512) Remove legacy REST API docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/08 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10513) Replace TaskManagerActions#notifyFinalState with #updateTaskExecutionState - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/08 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10514) change Tychyon to Alluxio - posted by "yangxiaoshuo (JIRA)" <ji...@apache.org> on 2018/10/08 13:59:00 UTC, 0 replies.
- Re: [DISCUSS] [Contributing] (2) - Review Steps - posted by Fabian Hueske <fh...@gmail.com> on 2018/10/08 16:07:52 UTC, 11 replies.
- [jira] [Created] (FLINK-10515) Improve tokenisation of program args passed as string - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/10/08 17:14:00 UTC, 0 replies.
- Request for Contributor permissions - posted by Rafi Aroch <ra...@gmail.com> on 2018/10/08 19:18:05 UTC, 1 replies.
- 回复：[DISCUSS] [Contributing] (2) - Review Steps - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/10/09 07:08:36 UTC, 0 replies.
- [jira] [Created] (FLINK-10516) YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/10/09 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10517) Add stability test for the REST API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/09 10:46:00 UTC, 0 replies.
- [DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal - posted by Fabian Wollert <fa...@zalando.de> on 2018/10/09 10:46:30 UTC, 11 replies.
- [jira] [Created] (FLINK-10518) Inefficient design in ContinuousFileMonitoringFunction - posted by "Huyen Levan (JIRA)" <ji...@apache.org> on 2018/10/09 11:40:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #41 - posted by Till Rohrmann <tr...@apache.org> on 2018/10/09 13:31:33 UTC, 0 replies.
- [DISCUSS] Integrate Flink SQL well with Hive ecosystem - posted by "Zhang, Xuefu" <xu...@alibaba-inc.com> on 2018/10/09 17:22:23 UTC, 22 replies.
- [jira] [Created] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/10/09 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10520) Job save points REST API fails unless parameters are specified - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/10/09 22:15:00 UTC, 0 replies.
- No data issued by flink window after a few hours - posted by ? ?? <pa...@hotmail.com> on 2018/10/10 02:37:32 UTC, 0 replies.
- 回复：[DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/10/10 06:24:14 UTC, 0 replies.
- [jira] [Created] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/10/10 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10522) Check if RecoverableWriter supportsResume and accordingly. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/10/10 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10523) Add jackson-dataformat-csv to flink-shaded - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/10 12:49:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 5.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/10/10 13:11:59 UTC, 4 replies.
- [jira] [Created] (FLINK-10524) HeartbeatManagerTest failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/10 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10525) Deserialization schema, skip data, that couldn't be properly deserialized - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/10/10 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10526) Hadoop FileSystem not initialized properly on Yarn - posted by "Yan Yan (JIRA)" <ji...@apache.org> on 2018/10/10 23:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/11 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10528) Remove deprecated APIs from Table API for Flink 1.7.0 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/10/11 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10529) Add flink-s3-fs-base to the connectors in the travis stage file. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/10/11 13:16:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10530) ProcessFailureCancelingITCase.testCancelingOnProcessFailure failed on Travis. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/10/11 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10531) State TTL RocksDb backend end-to-end test end-to-end test failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/11 17:22:00 UTC, 0 replies.
- Spreading Tasks across TaskManagers - posted by Maximilian Michels <mx...@apache.org> on 2018/10/11 18:16:51 UTC, 5 replies.
- [jira] [Created] (FLINK-10532) Broken links in documentation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/11 19:55:00 UTC, 0 replies.
- Become a contributor - posted by "Zhang, Xuefu" <xu...@alibaba-inc.com> on 2018/10/11 23:18:40 UTC, 2 replies.
- [jira] [Created] (FLINK-10533) job parallelism equals task slot number but not use all tasl slot - posted by "sean.miao (JIRA)" <ji...@apache.org> on 2018/10/12 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10534) Add idle timeout for a flink session cluster - posted by "ouyangzhe (JIRA)" <ji...@apache.org> on 2018/10/12 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10535) User jar is present in the flink job manager's class path - posted by "yinhua.dai (JIRA)" <ji...@apache.org> on 2018/10/12 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10536) Flink Kinesis Consumer leading to job failure due to ProvisionedThroughputExceededException - posted by "Ravi Bhushan Ratnakar (JIRA)" <ji...@apache.org> on 2018/10/12 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10537) Network throughput performance regression after broadcast changes - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/10/12 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10538) standalone-job.sh causes Classpath issues - posted by "Razvan (JIRA)" <ji...@apache.org> on 2018/10/12 13:57:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10539) Support specific namespace in QueryableStateClient - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/10/12 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10540) Remove legacy LocalFlinkMiniCluster - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/12 19:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10541) Removed unused code of LocalFlinkMiniCluster - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/12 19:56:00 UTC, 0 replies.
- Creating a slide set for a Flink intro talk - posted by Fabian Hueske <fh...@gmail.com> on 2018/10/12 21:32:07 UTC, 4 replies.
- [jira] [Created] (FLINK-10542) Register Hive metastore as an external catalog in TableEnvironment - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/10/12 22:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10543) Leverage efficient timer deletion in relational operators - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/10/14 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10544) Remove custom settings.xml for snapshot deployments - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/14 15:35:00 UTC, 0 replies.
- Add checkpoint hooks to window triggers - posted by Paul Lam <pa...@gmail.com> on 2018/10/15 02:52:25 UTC, 5 replies.
- [jira] [Created] (FLINK-10545) Remove JobManagerLeaderSessionIDITCase - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/15 04:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10546) Remove StandaloneMiniCluster - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/15 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10547) Remove LegacyCLI - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/15 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10548) Remove LegacyStandaloneClusterDescriptor - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/15 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10549) Remove LegacyJobRetrievalITCase - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/15 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10550) Remove LegacyYarnClusterDescriptor - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/15 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10551) Remove legacy REST handlers - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/15 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10552) Provide RichAsyncFunction for scala API - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/10/15 08:06:00 UTC, 0 replies.
- Re: Please review : Re: PubSub connector (FLINK-9311) - posted by Richard Deurwaarder <ri...@xeli.eu> on 2018/10/15 08:09:39 UTC, 1 replies.
- [DISCUSS] Release 1.5.5 and 1.6.2 - posted by Chesnay Schepler <ch...@apache.org> on 2018/10/15 09:40:47 UTC, 9 replies.
- 回复：[DISCUSS] Improve broadcast serialization - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/10/15 10:02:22 UTC, 2 replies.
- [RESULT][VOTE] Release flink-shaded 5.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/10/15 13:52:37 UTC, 0 replies.
- [jira] [Created] (FLINK-10553) Unified table sink and source name in SQL statement - posted by "wangsan (JIRA)" <ji...@apache.org> on 2018/10/15 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10554) Bump flink-shaded dependency version - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/15 17:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10555) Port AkkaSslITCase to new code base - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/15 17:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10556) Integration with Apache Hive - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/10/15 19:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10557) Checkpoint size metric incorrectly reports the same value until restart - posted by "Ruby Andrews (JIRA)" <ji...@apache.org> on 2018/10/15 21:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10558) Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/16 01:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10559) Remove LegacyLocalStreamEnvironment - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/16 04:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10560) JVM_ARGS doesn't work in jobmanager and taskmangers' JVM on yarn - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/10/16 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10561) Flink doesn't start locally if remove log package - posted by "Aleksei Starikov (JIRA)" <ji...@apache.org> on 2018/10/16 07:34:00 UTC, 0 replies.
- Contribution to FlinkML - posted by Alejandro Alcalde <al...@gmail.com> on 2018/10/16 08:05:40 UTC, 0 replies.
- [jira] [Created] (FLINK-10562) Relax (or document) table name constraints - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2018/10/16 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10563) Expose shaded Presto S3 filesystem under "s3p" scheme - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/10/16 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10564) tm costs too much time to communicate jm - posted by "chenlf (JIRA)" <ji...@apache.org> on 2018/10/16 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10565) Refactor SchedulerTestBase - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/16 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10566) Flink Planning is exponential in the number of stages - posted by "Robert Bradshaw (JIRA)" <ji...@apache.org> on 2018/10/16 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10567) Lost serialize fields when ttl state store with the mutable serializer - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/10/16 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10568) Show correct time attributes when calling Table.getSchema() - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/10/16 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10569) Clean up uses of Scheduler and Instance in valid tests - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/16 16:26:00 UTC, 0 replies.
- Re: [DISCUSS] [Contributing] (3) - Review Tooling - posted by Fabian Hueske <fh...@gmail.com> on 2018/10/16 16:47:44 UTC, 7 replies.
- [jira] [Created] (FLINK-10570) State grows unbounded when "within" constraint not applied - posted by "Thomas Wozniakowski (JIRA)" <ji...@apache.org> on 2018/10/16 17:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10571) Remove support for topologies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/16 19:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10572) Enable Per-job level failover strategy. - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/10/16 21:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10573) Support task revocation - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/10/16 22:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10574) Update documents of new batch job failover strategy - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/10/16 22:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10575) Remove deprecated ExecutionGraphBuilder.buildGraph method - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/10/16 22:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10576) Introduce Machine/Node/TM health management - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/10/16 22:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10577) CEP's greedy() doesn't work - posted by "zhanghao (JIRA)" <ji...@apache.org> on 2018/10/17 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10578) Support writable state in QueryableStateClient - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/10/17 03:20:00 UTC, 0 replies.
- Request for contributor permissions； - posted by "winifred.wenhui.tang@gmail.com" <wi...@gmail.com> on 2018/10/17 08:45:49 UTC, 1 replies.
- [jira] [Created] (FLINK-10579) Remove unused deploysettings.xml - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/17 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10580) EventTimeWindowCheckpointingITCase fails on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/17 10:39:00 UTC, 0 replies.
- Re: [DISCUSS] Improve broadcast serialization - posted by Piotr Nowojski <pi...@data-artisans.com> on 2018/10/17 11:24:56 UTC, 2 replies.
- [jira] [Created] (FLINK-10581) YarnConfigurationITCase.testFlinkContainerMemory test instability - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/10/17 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10582) Make REST executor thread priority configurable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/17 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10584) Add support for state retention to the Event Time versioned joins. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/10/17 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10583) Add support for state retention to the Processing Time versioned joins. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/10/17 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10585) RestServerEndpoint responds with wrong Content-Type in Integration Test. - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/10/17 14:02:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #42 - posted by Till Rohrmann <tr...@apache.org> on 2018/10/17 15:29:39 UTC, 0 replies.
- [jira] [Created] (FLINK-10586) Running {{RestServerEndpointITCase}} may cause Kernel Panic - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/10/17 18:42:00 UTC, 0 replies.
- 回复：Sharing state between subtasks - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/10/18 06:42:16 UTC, 1 replies.
- [jira] [Created] (FLINK-10587) Improve support of greedy/reluctant quantifiers - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10588) Support reusing same variable in Pattern - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10589) Group patterns should support greedy quantifiers - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10590) Optional quantifier is discarded from first element of group pattern - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10591) Add functions to return TimeIndicators from MATCH_RECOGNIZE - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10592) Support exclusions in patterns - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10593) Add support for ALL ROWS PER MATCH - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10594) Support SUBSETS - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10595) Support patterns that can produce empty matches - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10596) Add access to timerService in IterativeCondition and Pattern(Flat)SelectFunction - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/18 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10598) Maintain modern Kafka connector - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/18 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10599) Provide documentation for the modern kafka connector - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/18 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/18 09:28:00 UTC, 0 replies.
- [VOTE] Release 1.5.5, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/10/18 11:17:02 UTC, 15 replies.
- [VOTE] Release 1.6.2, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/10/18 11:18:49 UTC, 15 replies.
- [jira] [Created] (FLINK-10601) Make user home dir consistent with Flink default filesystem - posted by "Paul Lin (JIRA)" <ji...@apache.org> on 2018/10/18 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10602) Run MetricFetcher in metrics ActorSystem - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/18 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10603) Reduce kafka test duration - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/18 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10604) Add Remainder math function supported in Table API and SQL - posted by "Max (JIRA)" <ji...@apache.org> on 2018/10/18 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10605) Upgrade AvroSerializer snapshot to implement new TypeSerializerSnapshot interface - posted by "Igal Shilman (JIRA)" <ji...@apache.org> on 2018/10/18 14:22:00 UTC, 0 replies.
- State access in RichAsyncFunction - posted by shimin yang <ys...@gmail.com> on 2018/10/19 06:36:50 UTC, 2 replies.
- [jira] [Created] (FLINK-10606) Construct NetworkEnvironment simple for tests - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/10/19 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10607) Unify to remove duplicated NoOpResultPartitionConsumableNotifier - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/10/19 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10608) maven-rat-plugin does not catch files without headers generatued during compilation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/19 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10609) Source distribution fails with logging ClassCastException - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/19 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10610) Port CoLocationConstraintITCase to new codebase - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/19 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10611) Documentation should describe how to choose between Rolling & Streaming file sink - posted by "Christophe Jolif (JIRA)" <ji...@apache.org> on 2018/10/19 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10612) Run rat-plugin separately for each module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/19 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10614) Update test_batch_allround.sh e2e to new testing infrastructure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/19 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10613) Remove logger casts in HBaseConnectorITCase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/19 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10615) Cancel with savepoint can fail the job - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/10/19 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10616) Jepsen test fails while tearing down Hadoop - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/10/19 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10617) Restoring job fails because of slot allocation timeout - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/10/19 22:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10618) Introduce catalog for Flink tables - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/10/19 23:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10619) config MemoryStateBackend default value - posted by "yangxiaoshuo (JIRA)" <ji...@apache.org> on 2018/10/20 00:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10620) Remove the dependency on the version string literal. - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/20 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10621) BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when running locally - posted by "Alexey Trenikhin (JIRA)" <ji...@apache.org> on 2018/10/20 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10622) Add end-to-end test for time versioned joins - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10623) Extend streaming SQL end-to-end test to test MATCH_RECOGNIZE - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10625) Add MATCH_RECOGNIZE documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10626) Add documentation for time versioned joins - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10627) Extend test_streaming_file_sink to test S3 writer - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10628) Add end-to-end test for REST communication encryption - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10629) FlinkKafkaProducerITCase.testFlinkKafkaProducer10FailTransactionCoordinatorBeforeNotify failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 19:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10630) Update migration tests for Flink 1.6 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 20:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10631) Update jepsen tests to run with multiple slots - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 20:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10632) Run general purpose test job with failures in per-job mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 20:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10633) End-to-end test: Prometheus reporter - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 20:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10634) End-to-end test: Metrics accessible via REST API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 20:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10635) End-to-end test: Take & resume from savepoint when using per-job mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/21 20:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10636) ERROR org.apache.flink.shaded.curator.org.apache.curator.ConnectionState - Authentication failed - posted by "dalongliu (JIRA)" <ji...@apache.org> on 2018/10/22 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10637) Start MiniCluster with random REST port - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/22 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10638) Invalid table scan resolution for temporal join queries - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/10/22 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10639) Fix java syntax error in document - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/10/22 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10640) Enable Slot Resource Profile for Resource Management - posted by "Xintong Song (JIRA)" <ji...@apache.org> on 2018/10/22 10:19:00 UTC, 0 replies.
- Enable Slot Resource Profile for Resource Management - posted by "宋辛童(五藏)" <xi...@alibaba-inc.com> on 2018/10/22 10:39:25 UTC, 2 replies.
- 回复：Re: Enable Slot Resource Profile for Resource Management - posted by "宋辛童(五藏)" <xi...@alibaba-inc.com> on 2018/10/22 12:20:46 UTC, 0 replies.
- [jira] [Created] (FLINK-10641) Slow when applying new containers - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/10/22 13:44:00 UTC, 0 replies.
- Fwd: reaching out from k8s Big Data SIG - posted by Erik Erlandson <ee...@redhat.com> on 2018/10/22 16:27:16 UTC, 3 replies.
- [jira] [Created] (FLINK-10642) CodeGen split fields errors when maxGeneratedCodeLength equals 1 - posted by "xueyu (JIRA)" <ji...@apache.org> on 2018/10/22 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10643) Bubble execution: Resource aware job execution - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/10/22 23:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10644) Batch Job: Speculative execution - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/10/22 23:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10645) Update StatefulJobSavepointMigrationITCase for 1.6 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/23 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10646) Update AbstractOperatorRestoreTestBase for 1.6 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/23 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10647) Update WindowOperatorMigrationTest for 1.6 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/23 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10648) Update ContinuousFileProcessingMigrationTest for 1.6 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/23 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10649) Update FlinkKafkaConsumerBaseMigrationTest for 1.6 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/23 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10650) Update BucketingSinkMigrationTest for 1.6 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/23 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10651) Update CEPMigrationTest for 1.6 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/23 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10652) Update StatefulJobWBroadcastStateMigrationITCase for 1.6 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/23 09:51:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10653) Propose of external shuffle service for batch jobs - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/10/23 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10654) AllowNonRestoredState should skip state that cannot be restored - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/10/23 12:04:00 UTC, 0 replies.
- Flink SQL Client Kafka keyed serialization - posted by Dominik Wosiński <wo...@gmail.com> on 2018/10/23 12:46:22 UTC, 2 replies.
- [ANNOUNCE] Weekly community update #43 - posted by Till Rohrmann <tr...@apache.org> on 2018/10/23 14:18:02 UTC, 0 replies.
- [jira] [Created] (FLINK-10655) RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/10/23 16:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10656) Refactor org.apache.flink.runtime.io.network.api.reader.ReaderBase - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/10/23 22:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10657) TPCHQuery3 fail with IllegalAccessException - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/10/24 00:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10658) org.apache.flink.util.FlinkException: Releasing shared slot parent. - posted by "chauncy (JIRA)" <ji...@apache.org> on 2018/10/24 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10659) get rid of splitting by comma for ProgramArgsQueryParameter - posted by "Kan (JIRA)" <ji...@apache.org> on 2018/10/24 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10660) Failed index data to Elastic search using Flink-connector-elasticsearch with JUNIT test - posted by "孙达 (JIRA)" <ji...@apache.org> on 2018/10/24 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10661) Initial credit should be configured in a separate parameter - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/10/24 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10662) Refactor the ChannelSelector interface for single selected channel - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/10/24 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10663) Closing StreamingFileSink can cause NPE - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/10/24 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10664) Flink: Checkpointing fails with S3 exception - Please reduce your request rate - posted by "Pawel Bartoszek (JIRA)" <ji...@apache.org> on 2018/10/24 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10665) Port YARNSessionFIFOITCase#testJavaAPI to new codebase - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/24 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10666) Port YarnClusterDescriptorTest to new codebase - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/24 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10667) Clean up Scala 2.10 remnants - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/10/24 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10668) Streaming File Sink E2E test fails because not all legitimate exceptions are excluded - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/10/24 12:10:00 UTC, 0 replies.
- Question over Incremental Snapshot vs Full Snapshot in rocksDb state backend - posted by chandan prakash <ch...@gmail.com> on 2018/10/24 12:47:07 UTC, 4 replies.
- [jira] [Created] (FLINK-10669) Exceptions & errors are not properly checked in logs - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/24 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10670) Fix Correlate codegen error - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/10/24 13:37:00 UTC, 0 replies.
- [ANNOUNCE] Flink Forward San Francisco 2019 - Call for Presentations is now open - posted by Till Rohrmann <tr...@apache.org> on 2018/10/24 16:14:38 UTC, 0 replies.
- [jira] [Created] (FLINK-10671) rest monitoring api Savepoint status call fails if akka.ask.timeout < checkpoint duration - posted by "Cliff Resnick (JIRA)" <ji...@apache.org> on 2018/10/24 20:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10672) Task stuck while writing output to flink - posted by "Ankur Goenka (JIRA)" <ji...@apache.org> on 2018/10/24 22:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10673) Table API / SQL UIDs not the only one - posted by "Fan weiwen (JIRA)" <ji...@apache.org> on 2018/10/25 01:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10674) DistinctAccumulator.remove lead to NPE - posted by "ambition (JIRA)" <ji...@apache.org> on 2018/10/25 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10675) Fix dependency issues in sql & table integration - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/25 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/10/25 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10677) Setup hadoop-free E2E test cron job - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/25 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10678) Add a switch to run_test to configure if logs should be checked for errors/excepions - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/25 11:58:00 UTC, 0 replies.
- Re: Reverse the order of fields in Flink SQL - posted by wangsan <wa...@163.com> on 2018/10/25 12:20:39 UTC, 0 replies.
- [jira] [Created] (FLINK-10679) Let TypeSerializerSchemaCompatibility.resolveSchemaCompatibility() be the entry point for compatibility checks in framework code - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/10/25 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10680) Unable to set negative offsets for TumblingEventTimeWindow - posted by "Paul Lin (JIRA)" <ji...@apache.org> on 2018/10/25 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10681) elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA installed - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/25 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10682) EOFException occurs during deserialization of Avro class - posted by "Ben La Monica (JIRA)" <ji...@apache.org> on 2018/10/25 21:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10683) Error while executing BLOB connection. java.io.IOException: Unknown operation - posted by "Yee (JIRA)" <ji...@apache.org> on 2018/10/26 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10684) Improve the CSV reading process - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/10/26 04:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10685) Support history server on YARN - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/26 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10686) Introduce a flink-table-common module - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/10/26 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10687) Make flink-formats Scala-free - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/10/26 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10688) Remove flink-table dependencies from flink-connectors - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/10/26 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10689) Port Table API extension points to flink-table-common - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/10/26 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10690) Tests leak resources via Files.list - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/26 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10691) StreamSQL E2E test relies on hadoop - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/26 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10692) Harden Confluent schema E2E test - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/26 10:46:00 UTC, 0 replies.
- Flink POJO type in forAvroRecordClass function of Kafka010AvroTableSource - posted by "Ansari, Kafeel (Nokia - IN/Bangalore)" <ka...@nokia.com> on 2018/10/26 13:21:30 UTC, 0 replies.
- [jira] [Created] (FLINK-10693) Fix Scala EitherSerializer duplication - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/10/26 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10694) ZooKeeperRunningJobsRegistry Cleanup - posted by "Mikhail Pryakhin (JIRA)" <ji...@apache.org> on 2018/10/26 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10695) "Cannot load user class" errors should set the underlying ClassNotFoundException as their cause - posted by "Max Feng (JIRA)" <ji...@apache.org> on 2018/10/26 20:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10696) Add APIs to ExternalCatalog for views and UDFs - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/10/26 22:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10697) Create an in-memory catalog that stores Flink's meta objects - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/10/26 23:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10698) Create CatalogManager class manages all external catalogs and temporary meta objects - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/10/26 23:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10699) Create a catalog implementation for persistent Flink meta objects using Hive metastore as a registry - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/10/26 23:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10700) Remove LegacyStandaloneClusterDescriptor - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/10/27 01:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10701) Move modern kafka connector module into connector profile - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/27 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10702) Yarn app is not killed when scala shell is terminated - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/10/27 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10703) Race condition in YarnResourceManager - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/10/29 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10704) Fix sql client end to end test failure - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/10/29 06:09:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.5.5, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/10/29 07:04:45 UTC, 0 replies.
- [RESULT][VOTE] Release 1.6.2, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/10/29 07:08:18 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.5.5 released - posted by Chesnay Schepler <ch...@apache.org> on 2018/10/29 07:36:12 UTC, 3 replies.
- [ANNOUNCE] Apache Flink 1.6.2 released - posted by Chesnay Schepler <ch...@apache.org> on 2018/10/29 07:37:33 UTC, 1 replies.
- [jira] [Created] (FLINK-10705) Rework Flink Web Dashboard - posted by "Fabian Wollert (JIRA)" <ji...@apache.org> on 2018/10/29 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10706) Rewrite Flink Dashboard with React - posted by "Fabian Wollert (JIRA)" <ji...@apache.org> on 2018/10/29 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10707) Improve Cluster Overview in Flink Dashboard - posted by "Fabian Wollert (JIRA)" <ji...@apache.org> on 2018/10/29 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10708) Implement a SerializerMigrationTestBase - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/10/29 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10709) Remove NS generic parameter from TypeSerializerSchemaCompatibility - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/10/29 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10710) Implement new CompositeSerializerSnapshot - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/10/29 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10711) flink-end-to-end-tests can fail silently - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/10/29 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/29 11:52:08 UTC, 0 replies.
- [jira] [Created] (FLINK-10713) RestartIndividualStrategy does not restore state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/10/29 11:55:07 UTC, 0 replies.
- [DISCUSS] Change underlying Frontend Architecture for Flink Web Dashboard - posted by Fabian Wollert <fa...@zalando.de> on 2018/10/29 12:06:42 UTC, 7 replies.
- [jira] [Created] (FLINK-10714) java.lang.IndexOutOfBoundsException when creating a heap backend snapshot - posted by "Michał Ciesielczyk (JIRA)" <ji...@apache.org> on 2018/10/29 12:25:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10715) E2e tests fail with ConcurrentModificationException in MetricRegistryImpl - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/29 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10716) Upgrade ListSerializer / ArrayListSerializer for state evolution - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/10/29 13:47:52 UTC, 0 replies.
- [jira] [Created] (FLINK-10717) Introduce SimpleSerializerSnapshot as replacement for ParameterlessTypeSerializerConfig - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/10/29 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10718) Use IO executor in RpcService for message serialization - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/29 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10719) Add user documentation for Flink-Hive integration - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/10/29 19:23:03 UTC, 0 replies.
- [jira] [Created] (FLINK-10720) Add stress deployment end-to-end test - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/29 21:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method - posted by "zhaoshijie (JIRA)" <ji...@apache.org> on 2018/10/30 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10722) Document MATCH_RECOGNIZE - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/10/30 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10723) Upgrade MapSerializer for state evolution - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/10/30 09:54:07 UTC, 0 replies.
- [jira] [Created] (FLINK-10724) Refactor failure handling in check point coordinator - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/10/30 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10725) Support for Java 11 (LTS) - posted by "Sina Madani (JIRA)" <ji...@apache.org> on 2018/10/30 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10726) Streaming SQL end-to-end test fails due to recent flink-table-common changes - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/10/30 13:06:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #44 - posted by Till Rohrmann <tr...@apache.org> on 2018/10/30 14:25:46 UTC, 0 replies.
- [jira] [Created] (FLINK-10727) Remove unnecessary synchronization in SingleInputGate#requestPartitions() - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/10/30 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10728) Unexpected items on ASF mirrors - posted by "Sebb (JIRA)" <ji...@apache.org> on 2018/10/30 18:36:00 UTC, 0 replies.
- FLINK-9752 (s3 recoverable writer) not actually fixed in 1.6.2? - posted by Addison Higham <ad...@gmail.com> on 2018/10/30 21:54:34 UTC, 4 replies.
- [jira] [Created] (FLINK-10729) Create a Hive a connector to access Hive data - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/10/31 00:18:00 UTC, 0 replies.
- Run Flink Natively On Kubernetes - posted by Jin Sun <is...@gmail.com> on 2018/10/31 00:55:01 UTC, 1 replies.
- 回复：[DISCUSS] Proposal of external shuffle service - posted by zhijiang <wa...@aliyun.com.INVALID> on 2018/10/31 06:48:42 UTC, 0 replies.
- [jira] [Created] (FLINK-10730) How to resume Flink SQL Job ? - posted by "xinzhang (JIRA)" <ji...@apache.org> on 2018/10/31 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10731) Support AVG on Date fields - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2018/10/31 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10732) force-shading 1.5.5 maven artifact was not released - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/10/31 08:48:00 UTC, 0 replies.
- Re: [DISCUSS] Proposal of external shuffle service - posted by Till Rohrmann <tr...@apache.org> on 2018/10/31 09:26:07 UTC, 1 replies.
- [jira] [Created] (FLINK-10733) Misleading clean_log_files() in common.sh - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/10/31 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10734) Temporal joins on heavily filtered tables might fail in planning - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/10/31 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10735) flink on yarn close container exception - posted by "Fei Feng (JIRA)" <ji...@apache.org> on 2018/10/31 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/31 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10738) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/31 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/31 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10739) Unstable ProcessFailureCancelingITCase.testCancelingOnProcessFailure - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/10/31 15:30:00 UTC, 0 replies.
- Flip23 - posted by Boris Lublinsky <bo...@lightbend.com> on 2018/10/31 15:32:41 UTC, 0 replies.
- [jira] [Created] (FLINK-10740) Refactor Source Interface - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/10/31 16:17:00 UTC, 0 replies.
- [DISCUSS] FLIP-27: Refactor Source Interface - posted by Aljoscha Krettek <al...@apache.org> on 2018/10/31 16:22:12 UTC, 0 replies.
- [jira] [Created] (FLINK-10741) GraphOperationsITCase.testFilterOnVerticesSugar deadlocks on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/10/31 16:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/10/31 17:31:00 UTC, 0 replies.
- [ANNOUNCE] Feature freeze for Flink 1.7 - posted by Till Rohrmann <tr...@apache.org> on 2018/10/31 17:47:36 UTC, 0 replies.
- [jira] [Created] (FLINK-10743) Use 0 processExitCode for ApplicationStatus.CANCELED - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/10/31 21:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10744) Integrate Flink with Hive metastore - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/10/31 22:11:00 UTC, 0 replies.