You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-11242) The predicate `'o_c_id === Null(Types.STRING)` not work in TableAPI - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/01/01 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11243) GroupBy udf() can not be select in TableAPI - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/01/01 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11244) flink web.port can not be configured correctly in yarn mode - posted by "Kaicheng Sun (JIRA)" <ji...@apache.org> on 2019/01/02 01:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11245) Update documentation for catalogs in SQL-Client - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2019/01/02 01:34:00 UTC, 0 replies.
- Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem - posted by Eron Wright <er...@gmail.com> on 2019/01/02 02:39:04 UTC, 9 replies.
- [jira] [Created] (FLINK-11246) Fix distinct AGG visibility issues - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/01/02 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11247) Fix DESCRIBE command to support catalog tables - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2019/01/02 02:54:00 UTC, 0 replies.
- Apply for flink contributor permission - posted by Haibo Sun <su...@163.com> on 2019/01/02 04:37:30 UTC, 9 replies.
- subscribe to flink dev maillist - posted by Zhang Shaoquan <ba...@gmail.com> on 2019/01/02 05:14:21 UTC, 1 replies.
- Unbalanced processing of KeyedStream - posted by Jozef Vilcek <jo...@gmail.com> on 2019/01/02 08:16:57 UTC, 6 replies.
- [jira] [Created] (FLINK-11248) Support Row/CRow state schema evolution - posted by "boshu Zheng (JIRA)" <ji...@apache.org> on 2019/01/02 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11249) FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2019/01/02 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11250) fix thread lack when StreamTask switched from DEPLOYING to CANCELING - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2019/01/02 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11251) Incompatible metric name on prometheus reporter - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2019/01/02 10:07:00 UTC, 0 replies.
- Re: [DISCUSSION] Complete restart after successive failures - posted by Piotr Nowojski <pi...@da-platform.com> on 2019/01/02 12:15:14 UTC, 3 replies.
- [jira] [Created] (FLINK-11252) Download page contains irrelevant "Scala 2.11" column - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/02 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11253) Incorrect way to stop yarn session described in yarn_setup document - posted by "Tao Yang (JIRA)" <ji...@apache.org> on 2019/01/03 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11254) Unify serialization format of savepoint for switching state backends - posted by "Congxian Qiu (JIRA)" <ji...@apache.org> on 2019/01/03 04:46:00 UTC, 0 replies.
- [DISCUSS] Detection Flink Backpressure - posted by 裴立平 <pe...@gmail.com> on 2019/01/03 05:38:49 UTC, 9 replies.
- [jira] [Created] (FLINK-11255) RemoteStreamEnvironment - posted by "Benjamin Lee (JIRA)" <ji...@apache.org> on 2019/01/03 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11256) Referencing StreamNode objects directly in StreamEdge causes the sizes of JobGraph and TDD to become unnecessarily large - posted by "Haibo Suen (JIRA)" <ji...@apache.org> on 2019/01/03 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11257) FlinkKafkaConsumer should support assgin partition - posted by "shengjk1 (JIRA)" <ji...@apache.org> on 2019/01/03 07:40:00 UTC, 0 replies.
- Re: Question about Flink optimizer on Stream API - posted by Till Rohrmann <tr...@apache.org> on 2019/01/03 12:28:00 UTC, 0 replies.
- [NOTICE] Mandatory migration of git repositories to gitbox.apache.org - posted by Apache Infrastructure Team <in...@apache.org> on 2019/01/03 13:18:48 UTC, 7 replies.
- [jira] [Created] (FLINK-11258) Add badge to the README - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/03 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11259) Bump Zookeeper dependency to 3.4.13 - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/03 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11260) Bump Janino compiler dependency - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/03 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11261) BlobServer moves file with open OutputStream - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/03 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11262) Bump jython-standalone to 2.7.1 - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/03 16:13:00 UTC, 0 replies.
- Re: [DISCUSS] Long-term goal of making flink-table Scala-free - posted by Timo Walther <tw...@apache.org> on 2019/01/03 16:14:22 UTC, 0 replies.
- [jira] [Created] (FLINK-11263) yarn session script doesn't boot up task managers - posted by "Hongtao Zhang (JIRA)" <ji...@apache.org> on 2019/01/04 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11264) Fail to start scala shell - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/01/04 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11265) Invalid reference to AvroSinkWriter in example AvroKeyValueSinkWriter - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/04 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11266) Only release hadoop-free Flink - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/04 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11267) Update create_binary_release.sh to not create hadoop-specific releases - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/04 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11268) Update deploy_staging_jars.sh to deploy multiple flink-shaded-hadoop2 versions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/04 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11269) Extend Download page to list optional components - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/04 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11270) Do not include hadoop in flink-dist by default - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/04 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11271) Improve Kerberos Credential Distribution - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2019/01/04 17:42:00 UTC, 0 replies.
- Why UDF can not be non-static inner class ? - posted by Jeff Zhang <zj...@gmail.com> on 2019/01/07 01:22:11 UTC, 0 replies.
- Re: [DISCUSS] Support Interactive Programming in Flink Table API - posted by Becket Qin <be...@gmail.com> on 2019/01/07 09:41:07 UTC, 12 replies.
- [jira] [Created] (FLINK-11272) Support for parsing multiple --yarnship parameters - posted by "leesf (JIRA)" <ji...@apache.org> on 2019/01/07 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11273) Queryable state (rocksdb) end-to-end test fails - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/07 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11274) Scala 2.12 Kryo serialization bug - posted by "Zhenhao Li (JIRA)" <ji...@apache.org> on 2019/01/07 17:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11275) Unified Catalog APIs - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/01/07 23:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11276) Slicing Window Optimization - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2019/01/08 00:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11277) Queryable state IT test failed - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/01/08 01:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11278) Add documentation for TableAPI&SQL in scala-shell - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/01/08 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11279) The bug of Error parsing ExpressionParser - posted by "xuqianjin (JIRA)" <ji...@apache.org> on 2019/01/08 04:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11280) RocksDBSerializedCompositeKeyBuilder's key serializer is not being reconfigured properly - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/08 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11281) Two test in StateBackendMigrationTestBase failes - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/01/08 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11282) Merge StreamRecordWriter into RecordWriter - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/01/08 08:06:00 UTC, 0 replies.
- [attention] now there is a test broken in CI environment - posted by qianjin xu <fo...@gmail.com> on 2019/01/08 09:04:00 UTC, 1 replies.
- [jira] [Created] (FLINK-11283) Accessing the key when processing connected keyed stream - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2019/01/08 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11284) RocksDBStateBackendMigrationTest.testStateBackendRestoreSucceedsIfNewKeySerializerRequiresReconfiguration fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/08 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11285) Change the modifier of CsvTableSourceFactoryBase.createTableSource and CsvTableSinkFactoryBase.createTableSink to private[flink] - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2019/01/08 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/01/08 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11287) RocksDBListState creation should use actual registered state serializer instead of serializer provided by descriptor - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/08 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11288) Add separate flink-ml for building fat jar - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/08 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11289) Rework example module structure to account for licensing - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/08 16:15:00 UTC, 0 replies.
- [DISCUSS] Checkpoint Failure process improvement - posted by vino yang <ya...@gmail.com> on 2019/01/08 16:29:13 UTC, 1 replies.
- [jira] [Created] (FLINK-11290) BatchTableEnvironment and StreamTableEnvironment should transparent to users - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/01/09 01:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11291) Reorganize the package of flink-cep module - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2019/01/09 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11292) Document how to use the new CompositeTypeSerializerSnapshot - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/09 12:29:00 UTC, 0 replies.
- Request multiple subpartitions of one partition - posted by Chris Miller <cm...@34s.de> on 2019/01/09 12:46:23 UTC, 3 replies.
- [jira] [Created] (FLINK-11293) KafkaITCase.testConcurrentProducerConsumerTopology times out on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/09 13:06:00 UTC, 0 replies.
- Re: [DISCUSS] Dropping flink-storm? - posted by Till Rohrmann <tr...@apache.org> on 2019/01/09 15:08:47 UTC, 3 replies.
- [jira] [Created] (FLINK-11294) Remove legacy JobInfo usage in valid tests - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/01/10 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11295) Rename configuration options of queryable state from query.x to queryable-state.x - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/01/10 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11296) Support truncate in TableAPI - posted by "xuqianjin (JIRA)" <ji...@apache.org> on 2019/01/10 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11297) Add a doc link of jobmanager ha details - posted by "Yiqun Lin (JIRA)" <ji...@apache.org> on 2019/01/10 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11298) Scheduling job in the unit of concurrent groups - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2019/01/10 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11299) Decide the result partition type dynamically - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2019/01/10 07:20:00 UTC, 0 replies.
- SQL codegen bytecode beyond 64KB. - posted by "563280193@qq.com" <56...@qq.com> on 2019/01/10 07:34:11 UTC, 3 replies.
- ElasticSearch Connector - posted by Ramya Ramamurthy <ha...@gmail.com> on 2019/01/10 08:21:15 UTC, 5 replies.
- [DISCUSS] Bot for stale PRs on GitHub - posted by Aljoscha Krettek <al...@apache.org> on 2019/01/10 08:54:24 UTC, 2 replies.
- [jira] [Created] (FLINK-11300) Make MetricFetcher update interval configurable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/10 10:10:00 UTC, 0 replies.
- Re: [DISCUSS] Bot for stale PRs on GitHub - posted by Chesnay Schepler <ch...@apache.org> on 2019/01/10 10:21:36 UTC, 17 replies.
- [jira] [Created] (FLINK-11301) Travis failed: No output has been received in the last 10m0s - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/01/10 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11302) FlinkS3FileSystem uses an incorrect path for temporary files. - posted by "Artsem Semianenka (JIRA)" <ji...@apache.org> on 2019/01/10 14:42:00 UTC, 0 replies.
- Recovery problem in Flink 1.6.3 - posted by John Stone <jo...@accesso.com> on 2019/01/10 20:27:30 UTC, 0 replies.
- [jira] [Created] (FLINK-11303) Utilizing Kafka headers for serialization and deserialization - posted by "Allen Wang (JIRA)" <ji...@apache.org> on 2019/01/10 22:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11304) Typo in time attributes doc - posted by "Jaryzhen (JIRA)" <ji...@apache.org> on 2019/01/11 04:01:00 UTC, 0 replies.
- Apply for dev authority - posted by Jary Zhen <ja...@gmail.com> on 2019/01/11 06:01:52 UTC, 1 replies.
- [jira] [Created] (FLINK-11305) Allow developer to test flink without building the whole flink project - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/01/11 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11306) Bump derby from 10.10.1.1 to 10.14.2.0 - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/11 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11307) Set up nightly to run Tests with Java 9 - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/01/11 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11308) flink sql In the case when statement has a large in statement error： class DataStreamCalcRule$1933 grows beyond 64 KB - posted by "tivanli (JIRA)" <ji...@apache.org> on 2019/01/11 13:50:00 UTC, 0 replies.
- Identify the task within PartitionRequestQueue - posted by Chris Miller <cm...@34s.de> on 2019/01/12 08:03:03 UTC, 1 replies.
- [jira] [Created] (FLINK-11309) Batch Job Failover Using RestartPipelinedRegionStrategy Fails in Some Scenes - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/01/13 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11310) Convert predicates to IN or NOT_IN for Project - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/01/13 07:51:00 UTC, 0 replies.
- An exception about checkpoint - posted by Leor Li <br...@gmail.com> on 2019/01/13 10:51:09 UTC, 1 replies.
- Multiple select single result - posted by dhanuka ranasinghe <dh...@gmail.com> on 2019/01/13 13:42:19 UTC, 9 replies.
- [jira] [Created] (FLINK-11311) StreamSource implements StreamOperator interface multiple times. - posted by "Benchao Li (JIRA)" <ji...@apache.org> on 2019/01/13 14:23:00 UTC, 1 replies.
- Disable local data transportation - posted by Chris Miller <cm...@34s.de> on 2019/01/13 16:18:22 UTC, 2 replies.
- [jira] [Created] (FLINK-11312) The link to Zookeeper is broken in "jobmanager_high_availability" document - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2019/01/14 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11313) [checkpoint] Introduce LZ4 compression for keyed state in full checkpoints and savepoints - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2019/01/14 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11314) Reuse RocksDBWriteBatchWrapper in the flush method of RocksDBMapState - posted by "yuqi (JIRA)" <ji...@apache.org> on 2019/01/14 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11315) Make magic number in KvStateSerializer as a constant to make more readable - posted by "yuqi (JIRA)" <ji...@apache.org> on 2019/01/14 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11316) JarFileCreatorTest fails when run with Java 9 - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/01/14 14:16:00 UTC, 0 replies.
- 1.7.0 build failure, could not get required dependency from maven central. - posted by jiaxl <jt...@hotmail.com> on 2019/01/14 14:22:08 UTC, 2 replies.
- [jira] [Created] (FLINK-11317) test - posted by "begginghard (JIRA)" <ji...@apache.org> on 2019/01/14 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11318) [Regression] StreamingFileSink can overwrite existing files - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2019/01/14 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11319) Allow usage of custom implementation of Kafka Producer and Consumer in source and sink - posted by "Allen Wang (JIRA)" <ji...@apache.org> on 2019/01/14 21:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11320) Support user callback in Kafka sink - posted by "Allen Wang (JIRA)" <ji...@apache.org> on 2019/01/14 21:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11321) Clarify the NPE on fetching an nonexistent Kafka topic - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/14 23:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11322) Use try-with-resource for FlinkKafkaConsumer010 - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/14 23:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11323) Upgrade KryoSerializer snapshot to implement new TypeSerializerSnapshot interface - posted by "Igal Shilman (JIRA)" <ji...@apache.org> on 2019/01/15 04:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11324) Custom Log4j properties for each flink job - posted by "Ankit Sharma (JIRA)" <ji...@apache.org> on 2019/01/15 04:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11325) Flink Consumer Kafka Topic Not Found ConsumerID - posted by "dengjie (JIRA)" <ji...@apache.org> on 2019/01/15 07:22:00 UTC, 0 replies.
- [NOTICE] Mandatory migration of git repos to gitbox.apache.org - three weeks left! - posted by Apache Infrastructure Team <in...@apache.org> on 2019/01/15 07:50:08 UTC, 0 replies.
- [jira] [Created] (FLINK-11326) Using offsets to adjust windows to timezones UTC-8 throws IllegalArgumentException - posted by "TANG Wen-hui (JIRA)" <ji...@apache.org> on 2019/01/15 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11327) Migrate all remaining Flink serializers' snapshot classes to the new TypeSerializerSnapshot / TypeSerializerSchemaCompatibility abstractions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/15 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11328) Migrate all parameterless serializers / TypeSerializerSingleton's to use new serializer snapshot abstractions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/15 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11329) Migrate all remaining composite serializers to use new serializer snapshot abstraction - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/15 09:50:00 UTC, 0 replies.
- Re: [DISCUSS] Proposal of external shuffle service - posted by zhijiang <wa...@aliyun.com.INVALID> on 2019/01/15 09:53:28 UTC, 6 replies.
- [jira] [Created] (FLINK-11330) Migrate Scala-macro generated serializers to use new serialization compatibility abstractions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/15 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11331) Fix errors in tableApi.md and functions.md - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/01/15 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11332) Migrate Kryo-related serializers to use new serialization compatibility abstractions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/15 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11333) First-class support for Protobuf types with evolvable schema - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/15 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11334) Migrate enum serializers to use new serialization compatibility abstractions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/15 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11335) Kafka consumer can not commit offset at checkpoint - posted by "andy hoang (JIRA)" <ji...@apache.org> on 2019/01/15 11:33:00 UTC, 0 replies.
- [SURVEY] Custom RocksDB branch - posted by Andrey Zagrebin <an...@da-platform.com> on 2019/01/15 11:52:18 UTC, 0 replies.
- [jira] [Created] (FLINK-11336) Flink HA didn't remove ZK metadata - posted by "shengjk1 (JIRA)" <ji...@apache.org> on 2019/01/15 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11337) Incorrect watermark in StreaminFileSink BucketAssigner.Context when used in connected stream - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2019/01/15 12:48:00 UTC, 0 replies.
- Issues regarding Table-API - posted by Elias Saalmann <es...@studserv.uni-leipzig.de> on 2019/01/15 14:34:55 UTC, 2 replies.
- [ANNOUNCE] Apache Roadshow Chicago, Call for Presentations - posted by Trevor Grant <ra...@apache.org> on 2019/01/15 14:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-11338) Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2 - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/15 22:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11339) Bump exec-maven-plugin from 1.5.0 to 1.6.0 - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/15 22:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11340) Bump commons-configuration from 1.7 to 1.10 - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/15 23:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11341) Javadoc description does not match the parameter name - posted by "Gongwenzhou (JIRA)" <ji...@apache.org> on 2019/01/16 05:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11342) Add example for every built-In TableAPI&SQL Function - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/01/16 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11343) TaskExecutorTest is unstable on travis - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/01/16 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11344) Show All Execution Attempt Information on Flink Web Dashboard - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/01/16 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11345) BucketingSinkFaultToleranceITCase failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/16 10:05:00 UTC, 0 replies.
- Data not getting passed between operators - posted by Ramya Ramamurthy <ha...@gmail.com> on 2019/01/16 12:05:03 UTC, 1 replies.
- [jira] [Created] (FLINK-11346) Could not enable basic authentication with elastic search connector - posted by "kannan (JIRA)" <ji...@apache.org> on 2019/01/16 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11347) Optimize the ParquetAvroWriters factory - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/16 14:10:01 UTC, 0 replies.
- [jira] [Created] (FLINK-11348) Port YARNSessionCapacitySchedulerITCase to new code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11349) Port CoordinatorShutdownTest to new code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11350) Remove JobClientActorRecoveryITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11351) Port JobManagerCleanupITCase to new code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11353) Check & port JobManagerHAJobGraphRecoveryITCase if necessary to new code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11354) Check and port JobManagerHARecoveryTest if necessary to new code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11355) Check and port JobManagerProcessReapingTest if necessary to new code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11356) Check and port JobManagerStartupTest to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:43:02 UTC, 0 replies.
- [jira] [Created] (FLINK-11357) Check and port LeaderChangeJobRecoveryTest to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11358) Check and port LeaderChangeStateCleanupTest to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11359) Check and port LegacyAvroExternalJarProgramITCase to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11360) Check and remove LocalFlinkMiniClusterITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11361) Check and port RecoveryITCase to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11362) Check and port TaskManagerComponentsStartupShutdownTest to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11363) Check and remove TaskManagerConfigurationTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11365) Check and port TaskManagerFailureRecoveryITCase to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11364) Check and port TaskManagerFailsITCase to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11366) Check and port TaskManagerMetricsTest to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11367) Check and port TaskManagerProcessReapingTestBase to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11368) Check and port TaskManagerStartupTest to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11369) Check and port ZooKeeperHAJobManagerTest to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11370) Check and port ZooKeeperLeaderElectionITCase to new code base if necessary - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/16 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11371) Close the AvroParquetReader after use - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/16 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11372) Incorrect delegation of compatibility checks to new snapshots in CollectionSerializerConfigSnapshot - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/16 17:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11373) CliFrontend cuts off reason for error messages - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2019/01/16 17:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11374) Faiover add time range filter - posted by "lining (JIRA)" <ji...@apache.org> on 2019/01/17 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11375) Concurrent modification to slot pool due to SlotSharingManager releaseSlot directly - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2019/01/17 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11376) flink cli -yn -ys is not effect if (yn * ys) - posted by "shengjk1 (JIRA)" <ji...@apache.org> on 2019/01/17 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11377) AbstractYarnClusterDescriptor's validClusterSpecification is not final application resources from yarn if cli -yn -ys not effect - posted by "shengjk1 (JIRA)" <ji...@apache.org> on 2019/01/17 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11378) Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems. - posted by "Martijn (JIRA)" <ji...@apache.org> on 2019/01/17 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11379) "java.lang.OutOfMemoryError: Direct buffer memory" when TM loads a large size TDD - posted by "Haibo Suen (JIRA)" <ji...@apache.org> on 2019/01/17 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/01/17 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11381) JOIN LATERAL with a table was not support - posted by "Hongtao Zhang (JIRA)" <ji...@apache.org> on 2019/01/17 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11382) Disable MetricFetcher if interval is configured to 0 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/17 10:41:00 UTC, 0 replies.
- [QUESTION] about FsCheckpointStateOutputStream#createStream max 10 times create outStream - posted by 未来阳光 <22...@qq.com> on 2019/01/17 11:24:50 UTC, 1 replies.
- 回复： [QUESTION] about FsCheckpointStateOutputStream#createStream max10 times create outStream - posted by 未来阳光 <22...@qq.com> on 2019/01/17 12:33:49 UTC, 0 replies.
- [jira] [Created] (FLINK-11383) Dispatcher does not clean up blobs of failed submissions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/17 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11384) Remove legacy MesosTaskManager - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/01/18 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11385) Remove legacy MesosJobManager - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/01/18 05:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11386) Remove legacy ContaineredJobManager - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/01/18 05:03:00 UTC, 0 replies.
- [FLINK-6626] Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore - posted by tarush grover <ta...@gmail.com> on 2019/01/18 05:41:55 UTC, 1 replies.
- [jira] [Created] (FLINK-11387) Flink task can not restart from failed after running two days. - posted by "jiwei (JIRA)" <ji...@apache.org> on 2019/01/18 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11388) Add an OSS RecoverableWriter - posted by "wujinhu (JIRA)" <ji...@apache.org> on 2019/01/18 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11389) Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor - posted by "yuqi (JIRA)" <ji...@apache.org> on 2019/01/18 08:24:00 UTC, 0 replies.
- [DISCUSS] Towards a leaner flink-dist - posted by Chesnay Schepler <ch...@apache.org> on 2019/01/18 09:59:14 UTC, 15 replies.
- [jira] [Created] (FLINK-11390) Port YARNSessionCapacitySchedulerITCase to new code base - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/01/18 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11391) Introduce ShuffleMaster in Job Master - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/01/18 13:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-11392) Introduce ShuffleService in Task Executor - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/01/18 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11393) Activate default shuffle implementation and remove legacy code - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/01/18 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11394) Job UI is not rendered in case of slow back-end - posted by "Oleksandr Nitavskyi (JIRA)" <ji...@apache.org> on 2019/01/18 18:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11395) Support for Avro StreamingFileSink - posted by "Elango Ganesan (JIRA)" <ji...@apache.org> on 2019/01/18 19:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11396) MetricStore creates significant GC pressure - posted by "Oleksandr Nitavskyi (JIRA)" <ji...@apache.org> on 2019/01/19 09:52:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-27: Refactor Source Interface - posted by Biao Liu <mm...@gmail.com> on 2019/01/20 15:08:54 UTC, 3 replies.
- [jira] [Created] (FLINK-11397) Speed up initialization of AbstractStreamOperatorTestHarness - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/01/21 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11398) Add a dedicated phase to materialize time indicators for nodes produce updates - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/01/21 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11399) Parsing nested ROW()s in SQL - posted by "Benoît Paris (JIRA)" <ji...@apache.org> on 2019/01/21 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11400) JobManagerRunner does not wait for suspension of JobMaster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/21 15:54:00 UTC, 0 replies.
- issue in the MetricReporterRegistry - posted by Matthieu Bonneviot <ma...@datadome.co> on 2019/01/21 17:22:11 UTC, 3 replies.
- [ANNOUNCE] Contributing Alibaba's Blink - posted by Stephan Ewen <se...@apache.org> on 2019/01/21 19:46:11 UTC, 25 replies.
- [jira] [Created] (FLINK-11401) Allow compression on ParquetBulkWriter - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/21 20:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2019/01/21 22:04:00 UTC, 0 replies.
- Apply for Flink contributor permission - posted by 张洪涛 <zh...@gmail.com> on 2019/01/22 06:03:51 UTC, 1 replies.
- [jira] [Created] (FLINK-11403) Remove ResultPartitionConsumableNotifier from ResultPartition - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/01/22 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11404) web ui add see page and can filter by time - posted by "lining (JIRA)" <ji...@apache.org> on 2019/01/22 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11405) rest api can see exception by start end time filter - posted by "lining (JIRA)" <ji...@apache.org> on 2019/01/22 06:53:00 UTC, 0 replies.
- [DISCUSS] A strategy for merging the Blink enhancements - posted by Stephan Ewen <se...@apache.org> on 2019/01/22 14:15:58 UTC, 3 replies.
- [DISCUSS] Start new Review Process - posted by Fabian Hueske <fh...@gmail.com> on 2019/01/22 14:47:34 UTC, 12 replies.
- [jira] [Created] (FLINK-11406) Return TypeSerializerSchemaCompatibility.incompatible() when arity of nested serializers don't match in CompositeTypeSerializerSnapshot's compatibility check - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/22 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11407) Allow providing reason messages for TypeSerializerSchemaCompatibility.incompatible() - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/22 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11408) ContinuousProcessingTimeTrigger: NPE on clear() and state is lost on merge - posted by "Cristian (JIRA)" <ji...@apache.org> on 2019/01/22 16:27:00 UTC, 0 replies.
- Flink CEP : Doesn't generate output - posted by dhanuka ranasinghe <dh...@gmail.com> on 2019/01/22 17:58:11 UTC, 3 replies.
- [jira] [Created] (FLINK-11409) Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces - posted by "Kezhu Wang (JIRA)" <ji...@apache.org> on 2019/01/22 18:24:03 UTC, 0 replies.
- [jira] [Created] (FLINK-11410) Kubernetes Setup page gives incorrect url of Flink UI - posted by "Frank Huang (JIRA)" <ji...@apache.org> on 2019/01/22 20:55:02 UTC, 0 replies.
- [DISCUSS] Shall we make SpillableSubpartition repeatedly readable to support fine grained recovery - posted by Bo WANG <wb...@gmail.com> on 2019/01/23 03:45:58 UTC, 8 replies.
- [Feature]Returning RuntimeException to REST client while job submission - posted by Lavkesh Lahngir <la...@linux.com> on 2019/01/23 06:50:20 UTC, 7 replies.
- Request for permission - posted by Run <fa...@foxmail.com> on 2019/01/23 07:00:47 UTC, 1 replies.
- [jira] [Created] (FLINK-11411) Failover regions number of RestartPipelinedRegionStrategy not show in LOG due to incorrect parameter - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/01/23 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11412) Remove legacy MesosFlinkResourceManager - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/01/23 08:10:00 UTC, 0 replies.
- Applying for Flink contributor permission - posted by Lavkesh Lahngir <la...@gmail.com> on 2019/01/23 08:32:31 UTC, 4 replies.
- [jira] [Created] (FLINK-11413) MetricReporter: "metrics.reporters" configuration has to be provided for reporters to be taken into account - posted by "Matthieu Bonneviot (JIRA)" <ji...@apache.org> on 2019/01/23 08:35:00 UTC, 0 replies.
- 回复： Request for permission - posted by Run <fa...@foxmail.com> on 2019/01/23 09:10:48 UTC, 0 replies.
- [jira] [Created] (FLINK-11414) Introduce JobMasterService interface for the JobManagerRunner - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/23 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11415) Introduce JobMasterServiceFactor for JobManagerRunner - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/23 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11416) DISTINCT on a JOIN inside of an UNION is not working - posted by "Elias Saalmann (JIRA)" <ji...@apache.org> on 2019/01/23 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11417) Make access to ExecutionGraph single threaded from JobMaster main thread - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/01/23 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11418) Unable to build docs in Docker image - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2019/01/23 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2019/01/23 18:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11420) Serialization of case classes containing a Map[String, Any] sometimes throws ArrayIndexOutOfBounds - posted by "Jürgen Kreileder (JIRA)" <ji...@apache.org> on 2019/01/24 00:43:00 UTC, 0 replies.
- Parallel CEP - posted by dhanuka ranasinghe <dh...@gmail.com> on 2019/01/24 02:18:16 UTC, 7 replies.
- [jira] [Created] (FLINK-11421) Providing more compilation options for code-generated operators - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/01/24 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11422) Prefer testing class to mock StreamTask in AbstractStreamOperatorTestHarness - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/01/24 03:34:00 UTC, 0 replies.
- Side Outputs for late arriving records - posted by Ramya Ramamurthy <ha...@gmail.com> on 2019/01/24 05:42:10 UTC, 5 replies.
- [jira] [Created] (FLINK-11423) Propagate the error message from Main method to JarRunHandler - posted by "Lavkesh Lahngir (JIRA)" <ji...@apache.org> on 2019/01/24 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11424) org.apache.flink.metrics.datadog.DatadogHttpReporter#report remove will throw exception - posted by "lining (JIRA)" <ji...@apache.org> on 2019/01/24 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11425) Support of “Hash Teams” in Hybrid Hash Join - posted by "LiuJi (JIRA)" <ji...@apache.org> on 2019/01/24 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11426) FlinkKafkaProducerBase test case failed - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/01/24 11:02:00 UTC, 0 replies.
- [DISCUSS] Start a user-zh@flink.apache.org mailing list for the Chinese-speaking community? - posted by Robert Metzger <rm...@apache.org> on 2019/01/24 11:15:16 UTC, 25 replies.
- [jira] [Created] (FLINK-11427) Protobuf parquet writer implementation - posted by "Guang Hu (JIRA)" <ji...@apache.org> on 2019/01/24 12:14:00 UTC, 0 replies.
- [DISCUSS] FLIP-32: Restructure flink-table for future contributions - posted by Timo Walther <tw...@apache.org> on 2019/01/24 13:06:22 UTC, 6 replies.
- [jira] [Created] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis - posted by "Congxian Qiu (JIRA)" <ji...@apache.org> on 2019/01/24 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11429) Flink fails to authenticate s3a with core-site.xml - posted by " Mario Georgiev (JIRA)" <ji...@apache.org> on 2019/01/24 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11430) Incorrect Akka timeout syntax - posted by "Sina Madani (JIRA)" <ji...@apache.org> on 2019/01/24 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11431) Akka dependency not compatible with java 9 or above - posted by "Matthieu Bonneviot (JIRA)" <ji...@apache.org> on 2019/01/24 15:39:00 UTC, 0 replies.
- flink runtime incompatibility with java 9 or above due to akka version - posted by Matthieu Bonneviot <ma...@datadome.co> on 2019/01/24 16:04:13 UTC, 2 replies.
- [jira] [Created] (FLINK-11432) YarnFlinkResourceManagerTest test case timeout - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/01/25 07:50:00 UTC, 0 replies.
- Best way to create 1000 patterns programmatically - posted by dhanuka ranasinghe <dh...@gmail.com> on 2019/01/25 09:59:48 UTC, 2 replies.
- [jira] [Created] (FLINK-11433) JOIN on a table having a column of type MULTISET gives a NPE - posted by "Elias Saalmann (JIRA)" <ji...@apache.org> on 2019/01/25 11:49:00 UTC, 0 replies.
- Ratelimiting in the Flink Kafka connector - posted by Lakshmi Gururaja Rao <lr...@lyft.com.INVALID> on 2019/01/26 01:39:34 UTC, 7 replies.
- [jira] [Created] (FLINK-11434) Add the JSON_LENGTH function - posted by "xuqianjin (JIRA)" <ji...@apache.org> on 2019/01/26 10:58:01 UTC, 0 replies.
- [jira] [Created] (FLINK-11435) Different jobs same consumer group are treated as separate groups - posted by "Avi Levi (JIRA)" <ji...@apache.org> on 2019/01/26 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11436) Java deserialization failure of the AvroSerializer when used in an old CompositeSerializers - posted by "Igal Shilman (JIRA)" <ji...@apache.org> on 2019/01/27 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11437) EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism caused CancellationException - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/01/28 11:22:00 UTC, 0 replies.
- [DISCUSS] Contributing Chinese website and docs to Apache Flink - posted by Jark Wu <im...@gmail.com> on 2019/01/28 11:48:22 UTC, 12 replies.
- [jira] [Created] (FLINK-11438) Config for submitted job path - posted by "Alex (JIRA)" <ji...@apache.org> on 2019/01/28 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11439) INSERT INTO flink_sql SELECT * FROM blink_sql - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/28 15:04:00 UTC, 0 replies.
- [DISCUSS] Flip-31: Pluggable Shuffle Manager - posted by zhijiang <wa...@aliyun.com.INVALID> on 2019/01/28 15:19:12 UTC, 0 replies.
- [jira] [Created] (FLINK-11440) AbstractOperatorRestoreTestBase#testMigrationAndRestore caused IllegalStateException - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/01/29 01:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11441) Remove the schedule mode property from RPDD to TDD - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/01/29 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11442) Upgrade OSS SDK Version - posted by "wujinhu (JIRA)" <ji...@apache.org> on 2019/01/29 08:49:00 UTC, 0 replies.
- 回复： [DISCUSS] Contributing Chinese website and docs to Apache Flink - posted by 蜗牛 <sh...@foxmail.com> on 2019/01/29 08:58:45 UTC, 0 replies.
- [jira] [Created] (FLINK-11443) Recovering from save point error after adding "sum (constant)" - posted by "tivanli (JIRA)" <ji...@apache.org> on 2019/01/29 09:19:00 UTC, 0 replies.
- numLateRecordsDropped - posted by Ramya Ramamurthy <ha...@gmail.com> on 2019/01/29 09:59:38 UTC, 0 replies.
- [jira] [Created] (FLINK-11444) Deprecate methods for uncoupling table API and table core - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/29 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11445) Deprecate static methods in TableEnvironments - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/29 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11446) FlinkKafkaProducer011ITCase.testRecoverCommittedTransaction failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/29 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11447) Deprecate "new Table(TableEnvironment, String)" - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/29 10:24:01 UTC, 0 replies.
- [jira] [Created] (FLINK-11448) Clean-up and prepare Table API to be uncoupled from table core - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/29 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11449) Uncouple the Expression class from RexNodes - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/29 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11450) Port and move TableSource and TableSink to flink-table-common - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/29 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11451) Move *QueryConfig and TableDescriptor to flink-table-api-java - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/29 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11452) Make the table planner pluggable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/29 12:44:00 UTC, 0 replies.
- Flink Table Case Statements appending spaces - posted by Ramya Ramamurthy <ha...@gmail.com> on 2019/01/29 14:08:03 UTC, 2 replies.
- [jira] [Created] (FLINK-11453) Support SliceWindow with forwardable pane info - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2019/01/29 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11454) Support MergedStream operation - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2019/01/29 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11455) Support evictor operations on slicing and merging operators - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2019/01/29 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11456) Improve window operator with sliding window assigners - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2019/01/29 15:32:00 UTC, 0 replies.
- Re: [DISCUSS] Improvement to Flink Window Operator with Slicing - posted by Rong Rong <wa...@gmail.com> on 2019/01/29 15:37:13 UTC, 1 replies.
- [jira] [Created] (FLINK-11457) PrometheusPushGatewayReporter either overwrites its own metrics or creates too may labels - posted by "Oscar Westra van Holthe - Kind (JIRA)" <ji...@apache.org> on 2019/01/29 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11458) Ensure sink commit side-effects when cancelling with savepoint. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2019/01/29 16:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11459) Presto S3 does not show errors due to missing credentials with minio - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/01/29 18:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11460) Remove useless AcknowledgeStreamMockEnvironment - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/01/30 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11461) Remove useless MockRecordWriter - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/01/30 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11462) "Powered by Flink" page does not display correctly on Firefox - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2019/01/30 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11463) Rework end-to-end tests in Java - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/30 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11464) Implement DownloadCache - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/30 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11465) Implement LocalStandaloneFlinkResource - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/30 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11466) Implement LocalStandaloneKafkaResource - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/30 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11467) Port Kafka Streaming end-to-end test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/30 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11468) Setup jUnit categories - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/30 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11469) fix Tuning Checkpoints and Large State doc - posted by "shengjk1 (JIRA)" <ji...@apache.org> on 2019/01/30 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11470) LocalEnvironment doesn't call FileSystem.initialize() - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/01/30 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11471) Job is reported RUNNING prematurely for queued scheduling - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/01/30 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11472) KafkaITCase.testCancelingEmptyTopic failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/01/30 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11473) Clarify Documenation on Latency Markers - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/01/30 19:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11474) Add ReadableCatalog, ReadableWritableCatalog, and other related interfaces - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/01/31 00:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11475) Adapt existing InMemoryExternalCatalog to GenericInMemoryCatalog - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/01/31 00:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11476) Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/01/31 00:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11477) Define catalog entries in SQL client YAML file and handle the creation and registration of those entries - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/01/31 00:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11478) Handle existing table registration via YAML file in the context of catalog support - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/01/31 00:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11479) Implement HiveCatalog - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/01/31 00:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11480) Create HiveTableFactory that creates TableSource/Sink from a Hive table - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/01/31 00:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11481) Integrate HiveTableFactory with existing table factory discovery mechanism - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/01/31 00:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11482) Implement GenericHiveMetastoreCatalog - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/01/31 00:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11483) Improve StreamOperatorSnapshotRestoreTest with Parameterized - posted by "Congxian Qiu (JIRA)" <ji...@apache.org> on 2019/01/31 01:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11484) Blink java.util.concurrent.TimeoutException - posted by "pj (JIRA)" <ji...@apache.org> on 2019/01/31 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11485) Migrate PojoSerializer to use new serialization compatibility abstractions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/31 06:49:00 UTC, 0 replies.
- [DISCUSS] Standard / Convention for common connector metrics - posted by Becket Qin <be...@gmail.com> on 2019/01/31 07:44:41 UTC, 2 replies.
- Request contributor permission - posted by Becket Qin <be...@gmail.com> on 2019/01/31 09:37:01 UTC, 1 replies.
- [jira] [Created] (FLINK-11486) Remove RecoveryITCase for jobmanager - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2019/01/31 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11487) Support for writing data to Apache Flume - posted by "ambition (JIRA)" <ji...@apache.org> on 2019/01/31 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11488) Merge a basic Blink planner framework - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/31 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11489) Add an initial Blink streaming runtime - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/31 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11490) Add an initial batch runtime - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/31 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11491) Support all TPC-DS queries - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/31 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11492) Support the full Blink SQL runtime - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/31 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11493) Finalize the Blink SQL merging efforts - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/01/31 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11494) Remove legacy WebRuntimeMonitor - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/31 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11495) Remove legacy job archiving paths - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/31 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11496) FlinkS3 FileSysten is not handling multiple local temp directories - posted by "Elango Ganesan (JIRA)" <ji...@apache.org> on 2019/01/31 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11497) Remove invalid test JobManagerLeaderElectionTest - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/01/31 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11498) Getting java.lang.InstantiationError when trying to install flink 1.7.1 version through ansible - posted by "sambi reddy (JIRA)" <ji...@apache.org> on 2019/01/31 17:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policy's - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2019/01/31 17:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11500) 1.8 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/01/31 20:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2019/01/31 23:23:00 UTC, 0 replies.