You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [DISCUSS] Support Interactive Programming in Flink Table API - posted by Shaoxuan Wang <ws...@gmail.com> on 2018/12/01 02:56:08 UTC, 20 replies.
- Re: [ANNOUNCE] Apache Flink 1.7.0 released - posted by Hequn Cheng <ch...@gmail.com> on 2018/12/01 07:17:58 UTC, 3 replies.
- [ANNOUNCE] Call for Presentations Extended for Flink Forward San Francisco 2019 - posted by Fabian Hueske <fh...@gmail.com> on 2018/12/01 11:26:55 UTC, 0 replies.
- [jira] [Created] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/02 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry - posted by "luoguohao (JIRA)" <ji...@apache.org> on 2018/12/02 07:19:00 UTC, 0 replies.
- withPartitioner() vs calling partitionCustom() beforehand - posted by Giannis Evagorou <ge...@msn.com> on 2018/12/02 12:35:41 UTC, 2 replies.
- [jira] [Created] (FLINK-11047) CoGroupGroupSortTranslationTest does not compile with scala 2.12 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/12/02 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/12/02 23:49:00 UTC, 0 replies.
- [DISCUSS] Unified Core API for Streaming and Batch - posted by 孙海波 <su...@163.com> on 2018/12/03 02:51:58 UTC, 10 replies.
- [jira] [Created] (FLINK-11049) Unable to execute partial DAG - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/12/03 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound - posted by "Liu (JIRA)" <ji...@apache.org> on 2018/12/03 05:18:00 UTC, 0 replies.
- [DISCUSS] Support Higher-order functions in Flink sql - posted by "winifred.wenhui.tang@gmail.com" <wi...@gmail.com> on 2018/12/03 08:13:16 UTC, 4 replies.
- 回复:[DISCUSS] Unified Core API for Streaming and Batch - posted by zhijiang <wa...@aliyun.com.INVALID> on 2018/12/03 08:38:13 UTC, 0 replies.
- [jira] [Created] (FLINK-11051) Add Bounded(Group Window) FlatAggregate operator to streaming Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/03 09:00:11 UTC, 0 replies.
- [jira] [Created] (FLINK-11052) Add Bounded(Group Window) FlatAggregate operator to batch Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/03 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11053) Examples in documentation not compiling - posted by "Avi Levi (JIRA)" <ji...@apache.org> on 2018/12/03 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11054) Ingest Long value as TIMESTAMP attribute - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/12/03 12:45:00 UTC, 0 replies.
- Re: support/docs for compression in StreamingFileSink - posted by Kostas Kloudas <k....@data-artisans.com> on 2018/12/03 14:06:45 UTC, 0 replies.
- [jira] [Created] (FLINK-11055) Allow Queryable State to be transformed on the TaskManager before being returned to the client - posted by "Galen Warren (JIRA)" <ji...@apache.org> on 2018/12/03 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11056) Remove MesosApplicationMasterRunner - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/12/04 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11057) where in grammar will cause stream inner join loigcal - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/12/04 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11058) FlinkKafkaProducer011 fails when kafka broker crash - posted by "cz (JIRA)" <ji...@apache.org> on 2018/12/04 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11059) JobMaster may continue using an invalid slot if releasing idle slot meet a timeout - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2018/12/04 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11060) Unable to set number of task manager and slot per task number in scala shell local mode - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/12/04 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11061) Add travis profile that would run on each commit with scala 2.12 - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/12/04 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11062) web ui log error - posted by "lining (JIRA)" <ji...@apache.org> on 2018/12/04 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11063) Make flink-table Scala-free - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/12/04 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11064) Setup a new flink-table module structure - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/12/04 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11065) Migrate flink-table runtime classes - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/12/04 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11066) Migrate main Table API classes to flink-table-api-base - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/12/04 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11067) Port TableEnvironments to Java - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/12/04 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11068) Port Table class to Java - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/12/04 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11069) Remove FutureUtil - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/12/04 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11070) Add stream-stream non-window cross join - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/04 12:11:00 UTC, 0 replies.
- Proposal regarding Queryable State - posted by Galen Warren <ga...@cvillewarrens.com> on 2018/12/04 16:45:03 UTC, 0 replies.
- [jira] [Created] (FLINK-11071) Dynamic proxy classes cannot be resolved when deserializing job graph - posted by "Oleg Zhukov (JIRA)" <ji...@apache.org> on 2018/12/04 19:35:00 UTC, 0 replies.
- Re: [DISCUSS] Embracing Table API in Flink ML - posted by Weihua Jiang <we...@gmail.com> on 2018/12/05 03:59:18 UTC, 0 replies.
- Re: [DISCUSS] Flink SQL DDL Design - posted by Jark Wu <im...@gmail.com> on 2018/12/05 04:19:48 UTC, 24 replies.
- [jira] [Created] (FLINK-11072) KafkaITCase.testKeyValueSupport failure - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/12/05 04:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11073) Make serializers immutable / provide option TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/12/05 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11074) Improve the harness test to make it possible test with state backend - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2018/12/05 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11075) Remove redundant code path in CompatibilityUtil - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/12/05 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11076) Processing for Avro generated classes is very slow - posted by "Maciej Bryński (JIRA)" <ji...@apache.org> on 2018/12/05 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11077) Make subtask aware of the timeout of checkpoint and abort the current ongoing asynccheckpoint - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/12/05 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11078) Capability to define the numerical range for running TaskExecutors - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/12/05 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11079) Update LICENSE and NOTICE files for flnk-storm-examples - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/12/05 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11080) Define flink-connector-elasticsearch6 uber-jar dependencies via artifactSet - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/12/05 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11081) Support binding port range for REST server - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/12/05 15:21:00 UTC, 0 replies.
- [ANNOUNCE] Flink licensing guide - posted by Till Rohrmann <tr...@apache.org> on 2018/12/05 15:47:27 UTC, 0 replies.
- [DISCUSS] Improvement to Flink Window Operator with Slicing - posted by Rong Rong <wa...@gmail.com> on 2018/12/06 02:17:11 UTC, 0 replies.
- [jira] [Created] (FLINK-11082) Increase backlog only if it is available for consumption - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/12/06 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable - posted by "boshu Zheng (JIRA)" <ji...@apache.org> on 2018/12/06 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11084) Incorrect ouput after two successive split and select - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/12/06 06:33:00 UTC, 0 replies.
- delay one of the datastream when performing join operation on event-time and watermark - posted by Rakesh Kumar <ra...@gmail.com> on 2018/12/06 11:09:58 UTC, 1 replies.
- Apply for permission to solve flink's jira issues - posted by shen lei <sh...@gmail.com> on 2018/12/06 11:12:04 UTC, 1 replies.
- [jira] [Created] (FLINK-11085) flink-s3-fs-presto - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/12/06 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11086) flink-hadoop-compatibility tests fail for 3.x hadoop versions - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2018/12/06 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0 - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2018/12/06 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/12/06 23:49:00 UTC, 0 replies.
- dev apply - posted by sf lee <le...@gmail.com> on 2018/12/07 02:45:02 UTC, 0 replies.
- [jira] [Created] (FLINK-11089) Log filecache directory removed messages - posted by "liuzhaokun (JIRA)" <ji...@apache.org> on 2018/12/07 02:54:00 UTC, 0 replies.
- Apply for flink contributor permission - posted by sf lee <le...@gmail.com> on 2018/12/07 03:17:16 UTC, 10 replies.
- [jira] [Created] (FLINK-11090) Unused parameter in WindowedStream.aggregate() - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/07 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11091) Clear the use of deprecated methods of KeyedStream in table operators - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/07 04:13:00 UTC, 0 replies.
- Discuss [FLINK-9740] Support group windows over intervals of months - posted by x1q1j1 <23...@qq.com> on 2018/12/07 04:20:17 UTC, 0 replies.
- [jira] [Created] (FLINK-11092) Migrate flink-table runtime Selector and Collector classes - posted by "xueyu (JIRA)" <ji...@apache.org> on 2018/12/07 05:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11093) Migrate flink-table runtime Function classes - posted by "xueyu (JIRA)" <ji...@apache.org> on 2018/12/07 05:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in new execution causes NPE on snapshot - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/12/07 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11095) Table based ML Pipeline - posted by "Weihua Jiang (JIRA)" <ji...@apache.org> on 2018/12/07 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11096) Create a new table based flink ML package - posted by "Weihua Jiang (JIRA)" <ji...@apache.org> on 2018/12/07 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11097) Migrate flink-table runtime io classes - posted by "xuqianjin (JIRA)" <ji...@apache.org> on 2018/12/07 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11098) Migrate flink-table runtime Row Types classes - posted by "xuqianjin (JIRA)" <ji...@apache.org> on 2018/12/07 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11099) Migrate flink-table runtime Row Types classes - posted by "xuqianjin (JIRA)" <ji...@apache.org> on 2018/12/07 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11100) Presto S3 FileSystem E2E test broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/12/07 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11101) Ineffective openjdk exclusion Presto S3 FileSystem module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/12/07 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/12/07 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11103) Set a default uncaught exception handler - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/12/07 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11104) LEFT JOIN with Table Function not working - posted by "Denys Fakhritdinov (JIRA)" <ji...@apache.org> on 2018/12/07 14:49:00 UTC, 0 replies.
- Re: [DISCUSS] Long-term goal of making flink-table Scala-free - posted by Aljoscha Krettek <al...@apache.org> on 2018/12/07 15:20:01 UTC, 1 replies.
- [ANNOUNCE] Weekly community update #49 - posted by Till Rohrmann <tr...@apache.org> on 2018/12/07 15:21:31 UTC, 0 replies.
- [SURVEY] Usage of flink-python and flink-streaming-python - posted by Till Rohrmann <tr...@apache.org> on 2018/12/07 15:29:31 UTC, 9 replies.
- [DISCUSS] Creating last bug fix release for 1.5 branch - posted by Till Rohrmann <tr...@apache.org> on 2018/12/07 15:38:26 UTC, 10 replies.
- [jira] [Created] (FLINK-11105) Add an new implementation of the HighAvailabilityServices using etcd - posted by "Yang Wang (JIRA)" <ji...@apache.org> on 2018/12/07 16:19:00 UTC, 0 replies.
- [NOTICE] Mandatory relocation of Apache git repositories on git-wip-us.apache.org - posted by Daniel Gruno <hu...@apache.org> on 2018/12/07 16:52:36 UTC, 0 replies.
- [jira] [Created] (FLINK-11106) Remove legacy flink-yarn component - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/12/08 04:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11107) [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2018/12/09 17:01:00 UTC, 0 replies.
- Re: [DISCUSS] Flink backward compatibility - posted by Stephan Ewen <se...@apache.org> on 2018/12/09 20:49:20 UTC, 0 replies.
- Re: [DISCUSS] Proposal of external shuffle service - posted by Andrey Zagrebin <an...@data-artisans.com> on 2018/12/09 21:18:41 UTC, 4 replies.
- [jira] [Created] (FLINK-11108) Create a new set of table based ML Pipeline classes - posted by "Weihua Jiang (JIRA)" <ji...@apache.org> on 2018/12/10 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11109) Create Table based optimizers - posted by "Weihua Jiang (JIRA)" <ji...@apache.org> on 2018/12/10 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11110) Support pipeline stage type inference - posted by "Weihua Jiang (JIRA)" <ji...@apache.org> on 2018/12/10 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11111) Create a new set of parameters - posted by "Weihua Jiang (JIRA)" <ji...@apache.org> on 2018/12/10 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11112) Support pipeline import/export - posted by "Weihua Jiang (JIRA)" <ji...@apache.org> on 2018/12/10 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11113) Support periodically update models when inferencing - posted by "Weihua Jiang (JIRA)" <ji...@apache.org> on 2018/12/10 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11114) Support wrapping inference pipeline as a UDF function in SQL - posted by "Weihua Jiang (JIRA)" <ji...@apache.org> on 2018/12/10 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11115) Port some flink.ml algorithms to table based - posted by "Weihua Jiang (JIRA)" <ji...@apache.org> on 2018/12/10 03:00:00 UTC, 0 replies.
- 回复:[DISCUSS] Proposal of external shuffle service - posted by zhijiang <wa...@aliyun.com.INVALID> on 2018/12/10 07:41:29 UTC, 0 replies.
- [jira] [Created] (FLINK-11116) Clean-up temporary files that upon recovery, they belong to no checkpoint. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/12/10 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11117) Migrate connector classes to flink-table-spi - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/12/10 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11118) Refactor and unify rowtime timestamp extractor interface - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/12/10 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11119) Incorrect Scala example for Table Function - posted by "Denys Fakhritdinov (JIRA)" <ji...@apache.org> on 2018/12/10 09:37:00 UTC, 0 replies.
- [DISCUSS] Enhance convenience of TableEnvironment in TableAPI/SQL - posted by jincheng sun <su...@gmail.com> on 2018/12/10 10:05:41 UTC, 8 replies.
- [jira] [Created] (FLINK-11120) The bug of timestampadd handles time - posted by "xuqianjin (JIRA)" <ji...@apache.org> on 2018/12/10 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11121) Check and update licensing notes for Aliyun FS [FLINK-10865] - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/12/10 12:20:01 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #50 - posted by Till Rohrmann <tr...@apache.org> on 2018/12/10 14:12:51 UTC, 0 replies.
- [jira] [Created] (FLINK-11122) SafetyNetCloseableRegistryTest fails with ClassCastException - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/12/10 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11123) Improve ml quick start doc - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/11 00:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11124) Add private[flink] to TemporalTableFunction.create() - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/11 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11125) Remove useless import - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/11 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11126) Filter out AMRMToken in the TaskManager credentials - posted by "Paul Lin (JIRA)" <ji...@apache.org> on 2018/12/11 05:18:00 UTC, 0 replies.
- [DISCUSS] Flink client api enhancement for downstream project - posted by Jeff Zhang <zj...@gmail.com> on 2018/12/11 09:04:36 UTC, 5 replies.
- [jira] [Created] (FLINK-11127) Make metrics query service establish connection to JobManager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/12/11 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11128) Methods of org.apache.flink.table.expressions.Expression are private[flink] - posted by "Denys Fakhritdinov (JIRA)" <ji...@apache.org> on 2018/12/11 09:50:01 UTC, 0 replies.
- [jira] [Created] (FLINK-11129) dashbord for job which contain important information - posted by "lining (JIRA)" <ji...@apache.org> on 2018/12/11 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11130) Migrate flink-table runtime KeyedCoProcessOperatorWithWatermarkDelay class - posted by "shenlei (JIRA)" <ji...@apache.org> on 2018/12/11 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11131) Enable unused import checkstyle on flink-core and flink-runtime tests - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/11 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11132) Restore From Savepoint on HA Setup - posted by "Edmond (JIRA)" <ji...@apache.org> on 2018/12/11 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11133) FsCheckpointStorage is unaware about S3 entropy when creating directories - posted by "Mark Cho (JIRA)" <ji...@apache.org> on 2018/12/12 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11134) Invalid REST API request should not log the full exception in Flink logs - posted by "Mark Cho (JIRA)" <ji...@apache.org> on 2018/12/12 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11135) Reduce priority of the deprecated Hadoop specific Flink conf options - posted by "Paul Lin (JIRA)" <ji...@apache.org> on 2018/12/12 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11136) Fix the logical of merge for DISTINCT aggregates - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2018/12/12 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11137) Unexpected RegistrationTimeoutException of TaskExecutor - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2018/12/12 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11138) RocksDB's wal seems to be useless in rocksdb-state-backend that reduce the disk's overhead - posted by "cailiuyang (JIRA)" <ji...@apache.org> on 2018/12/12 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11139) stream non window join support state ttl - posted by "zhaoshijie (JIRA)" <ji...@apache.org> on 2018/12/12 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11140) Can not create a Path from an empty string while use BasePathBucketAssigner - posted by "Matrix42 (JIRA)" <ji...@apache.org> on 2018/12/12 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11141) Key generation for RocksDBMapState can theoretically be ambiguous - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/12/12 11:14:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.6.3 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/12/12 11:34:49 UTC, 5 replies.
- [DISCUSS] Releasing Flink 1.7.1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/12/12 12:04:46 UTC, 4 replies.
- Connection leak with flink elastic Sink - posted by Vijay Bhaskar <bh...@gmail.com> on 2018/12/12 12:31:38 UTC, 3 replies.
- [jira] [Created] (FLINK-11142) Undefined behavior in the conversion from DataStream/DataSet to Table - posted by "Yangze Guo (JIRA)" <ji...@apache.org> on 2018/12/12 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11143) AskTimeoutException is thrown during job submission and completion - posted by "Alex Vinnik (JIRA)" <ji...@apache.org> on 2018/12/12 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11144) Run Tests on Java 9 - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/12/12 13:54:01 UTC, 0 replies.
- [jira] [Created] (FLINK-11145) Fix Hadoop version handling in binary release script - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/12/12 17:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11146) Get rid of legacy codes from ClusterClient - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/12/13 03:54:00 UTC, 0 replies.
- [DISCUSS] Python (and Non-JVM) Language Support in Flink - posted by Xianda Ke <ke...@gmail.com> on 2018/12/13 08:57:48 UTC, 4 replies.
- [jira] [Created] (FLINK-11147) Add document for TableAggregate Function - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/13 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11148) Rescaling operator regression in Flink 1.7 - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/12/13 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11149) Flink will request too more containers than it actually needs - posted by "Fan Xinpu (JIRA)" <ji...@apache.org> on 2018/12/13 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11150) Check exception messages in ValidationTest of flink-table - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/13 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11151) FileUploadHandler stops working if the upload directory is removed - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/12/13 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11152) ClosureCleanerTest fails with IllegalStateException - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/12/13 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11153) UdfAnalyzerTest fails with CodeAnalyzerException - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/12/13 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11154) Upgrade Netty to 4.1.32 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/12/13 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11155) HadoopFreeFsFactoryTest fails with ClassCastException - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/12/13 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11156) ZooKeeperCompletedCheckpointStoreMockitoTest fails with IncompatibleClassChangeError - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/12/13 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11157) Web UI should show timestamps relative to server time zone - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/12/13 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11158) Do not show empty page for unknown jobs - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/12/13 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11159) Allow configuration whether to fall back to savepoints for restore - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/12/13 16:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11160) Confluent Avro Serialization Schema - posted by "Zhenhao Li (JIRA)" <ji...@apache.org> on 2018/12/13 17:44:00 UTC, 0 replies.
- Create version 1.7.1 in JIRA - posted by Thomas Weise <th...@apache.org> on 2018/12/13 20:17:11 UTC, 2 replies.
- Thanks for hiding ASF GitHub Bot logs on JIRA - posted by Tzu-Li Chen <wa...@gmail.com> on 2018/12/13 21:00:26 UTC, 3 replies.
- [jira] [Created] (FLINK-11161) Unable to import java packages in scala-shell - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/12/14 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11162) Provide a rest API to list all logical operators - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/12/14 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11163) RestClusterClientTest#testSendIsNotRetriableIfHttpNotFound with BindException - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/12/14 04:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11164) Refreshing expired shard iterator fails if no records were retrieved from shard since ShardConsumer was started in FlinkKinesisConsumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/12/14 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11165) Refine the deploying log for easier finding of task locations - posted by "Zhu Zhu (JIRA)" <ji...@apache.org> on 2018/12/14 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11166) Slot Placement Constraint - posted by "Tony Xintong Song (JIRA)" <ji...@apache.org> on 2018/12/14 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11167) Optimize RocksDBList#put for no empty input - posted by "Congxian Qiu (JIRA)" <ji...@apache.org> on 2018/12/14 10:05:00 UTC, 0 replies.
- Apply for contributor permission - posted by Shengyang Sha <sh...@gmail.com> on 2018/12/14 10:47:19 UTC, 2 replies.
- Re: MODERATE for dev@flink.apache.org - posted by Stephan Ewen <se...@apache.org> on 2018/12/14 10:51:20 UTC, 0 replies.
- [VOTE] Release 1.7.1, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/12/14 12:45:12 UTC, 1 replies.
- [CANCELED] [VOTE] Release 1.7.1, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/12/14 15:37:25 UTC, 0 replies.
- [jira] [Created] (FLINK-11168) LargePlanTest times out on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/12/14 16:06:00 UTC, 0 replies.
- 回复:Apply for flink contributor permission - posted by Tony Xintong Song <xi...@alibaba-inc.com> on 2018/12/15 03:22:06 UTC, 0 replies.
- [jira] [Created] (FLINK-11169) [hotfix][runtime] fix the problem of not being reloaded for jobmanager's log after clicking the refresh button in web ui - posted by "Jiayong Mo (JIRA)" <ji...@apache.org> on 2018/12/15 05:42:00 UTC, 0 replies.
- CEP - Support for multiple pattern - posted by bupt_ljy <bu...@163.com> on 2018/12/15 09:07:29 UTC, 0 replies.
- [jira] [Created] (FLINK-11170) Support DISTINCT aggregates in MATCH_RECOGNIZE - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/12/16 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend - posted by "Sayat Satybaldiyev (JIRA)" <ji...@apache.org> on 2018/12/16 11:38:00 UTC, 0 replies.
- [VOTE] Release 1.7.1, release candidate #2 - posted by Chesnay Schepler <ch...@apache.org> on 2018/12/16 19:39:41 UTC, 8 replies.
- Re: CEP - Support for multiple pattern - posted by "fudian.fd" <fu...@alibaba-inc.com> on 2018/12/17 02:17:39 UTC, 1 replies.
- [jira] [Created] (FLINK-11172) Remove the max retention time in StreamQueryConfig - posted by "Yangze Guo (JIRA)" <ji...@apache.org> on 2018/12/17 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11173) Proctime Attribute validation throws an incorrect exception message - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/12/17 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11174) flink Metrics Prometheus labels support chinese - posted by "Fan weiwen (JIRA)" <ji...@apache.org> on 2018/12/17 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11175) The sample code describing the Processing time used in TableSource is incorrect - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/12/17 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11176) Improve the harness tests to use the code-generated operator - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2018/12/17 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11177) Node health tracker - posted by "ryantaocer (JIRA)" <ji...@apache.org> on 2018/12/17 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11178) Check flink-test module for 1.7.1-rc2 - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/17 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11179) JoinCancelingITCase#testCancelSortMatchWhileDoingHeavySorting test error - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/17 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11180) ProcessFailureCancelingITCase#testCancelingOnProcessFailure - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/17 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11181) SimpleRecoveryITCaseBase test error - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/17 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11182) JobManagerHACheckpointRecoveryITCase need be improved - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/17 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11183) Flink 1.7 wrong memory graphite metrics - posted by " Mario Georgiev (JIRA)" <ji...@apache.org> on 2018/12/17 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11184) Rework TableSource and TableSink interfaces - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/12/17 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11185) StreamSourceOperatorWatermarksTest failed with InterruptedException - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2018/12/17 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11186) Support for event-time balancing for multiple Kafka comsumer partitions - posted by "Tom Schamberger (JIRA)" <ji...@apache.org> on 2018/12/17 15:45:00 UTC, 0 replies.
- Re: StreamingFileSink causing AmazonS3Exception - posted by Addison Higham <ad...@gmail.com> on 2018/12/17 21:37:32 UTC, 1 replies.
- [jira] [Created] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2018/12/17 21:50:00 UTC, 0 replies.
- [DISCUSS] Flink Kerberos Improvement - posted by Rong Rong <wa...@gmail.com> on 2018/12/18 01:48:46 UTC, 2 replies.
- [jira] [Created] (FLINK-11188) Bounded over should not enable state retention time - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/18 02:05:00 UTC, 0 replies.
- [VOTE] Release 1.5.6, release candidate #1 - posted by Thomas Weise <th...@apache.org> on 2018/12/18 05:27:15 UTC, 12 replies.
- [jira] [Created] (FLINK-11189) Deprecated documentation for readSequenceFile function - posted by "shin chen (JIRA)" <ji...@apache.org> on 2018/12/18 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11190) Log stack trace on declined checkpoint - posted by "Daniel Harper (JIRA)" <ji...@apache.org> on 2018/12/18 09:42:00 UTC, 0 replies.
- [VOTE] Release 1.6.3, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/12/18 10:15:43 UTC, 5 replies.
- [jira] [Created] (FLINK-11191) Exception in code generation when ambiguous columns in MATCH_RECOGNIZE - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/12/18 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11192) rockdb customize configuration Covered jobmaster - posted by "Fan weiwen (JIRA)" <ji...@apache.org> on 2018/12/18 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11193) rockdb customize configuration Covered jobmaster - posted by "Fan weiwen (JIRA)" <ji...@apache.org> on 2018/12/18 16:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11194) missing Scala 2.12 build of HBase connector - posted by "Zhenhao Li (JIRA)" <ji...@apache.org> on 2018/12/18 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11195) Extend AbstractS3FileSystemFactory.createHadoopFileSystem to accept URI and Hadoop Configuration - posted by "Mark Cho (JIRA)" <ji...@apache.org> on 2018/12/18 19:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11196) Extend S3 EntropyInjector to use key replacement (instead of key removal) when creating checkpoint metadata files - posted by "Mark Cho (JIRA)" <ji...@apache.org> on 2018/12/18 22:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11197) Improve migration test comments about how to generate snapshots - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/19 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich) - posted by "Chirag Dewan (JIRA)" <ji...@apache.org> on 2018/12/19 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11199) Support interactive programming in Flink - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2018/12/19 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11200) Port DataView classes to flink-table-common - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/12/19 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11201) flink-test-utils dependency issue - posted by "eugen yushin (JIRA)" <ji...@apache.org> on 2018/12/19 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11202) log split file, every job has one log file - posted by "chauncy (JIRA)" <ji...@apache.org> on 2018/12/19 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11203) FunctionContext of AggregateFunction will not be initialized for window GroupBy - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/19 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11204) flink start-scala-shell.sh do not work in security mode with kerberos authentication. - posted by "kelun wang (JIRA)" <ji...@apache.org> on 2018/12/19 13:10:00 UTC, 0 replies.
- Question about Flink optimizer on Stream API - posted by Felipe Gutierrez <fe...@gmail.com> on 2018/12/19 14:14:08 UTC, 0 replies.
- [jira] [Created] (FLINK-11205) Task Manager Metaspace Memory Leak - posted by "Nawaid Shamim (JIRA)" <ji...@apache.org> on 2018/12/19 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11206) sql statement parser enhancement - posted by "ambition (JIRA)" <ji...@apache.org> on 2018/12/20 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11207) Update Apache commons-compress from 1.4.1 to 1.18 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/12/20 14:45:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #51 - posted by Till Rohrmann <tr...@apache.org> on 2018/12/20 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11208) Decrease build/testing time of modules - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/12/20 17:20:00 UTC, 0 replies.
- Re: Flink 1.7 doesn't work with Kafka Table Source Descriptors - posted by dhanuka ranasinghe <dh...@gmail.com> on 2018/12/21 10:23:58 UTC, 5 replies.
- [RESULT] [VOTE] Release 1.7.1, release candidate #2 - posted by Chesnay Schepler <ch...@apache.org> on 2018/12/21 17:29:53 UTC, 3 replies.
- [RESULT] [VOTE] Release 1.5.6, release candidate #1 - posted by Thomas Weise <th...@apache.org> on 2018/12/22 01:08:38 UTC, 3 replies.
- [jira] [Created] (FLINK-11209) Provide more complete guidance for the log usage documentation - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/12/22 12:14:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.6.3, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/12/22 12:57:26 UTC, 0 replies.
- [jira] [Created] (FLINK-11210) Enable auto state cleanup strategy for RANGE OVER - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/22 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11211) ReinterpretDataStreamAsKeyedStreamITCase failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/12/22 14:01:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.7.1 released - posted by Chesnay Schepler <ch...@apache.org> on 2018/12/22 19:34:56 UTC, 4 replies.
- [ANNOUNCE] Apache Flink 1.6.3 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/12/23 13:35:42 UTC, 4 replies.
- [jira] [Created] (FLINK-11212) operator metric key can repalce operator name by operator id - posted by "lining (JIRA)" <ji...@apache.org> on 2018/12/24 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11213) Is there any condition that large amount of redis connection created on each TM? - posted by "lzh9 (JIRA)" <ji...@apache.org> on 2018/12/24 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11214) Support non mergable aggregates for group windows on batch table - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2018/12/25 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11215) TaskExecutor RegistrationTimeoutException within the specified maximum registration duration 300000ms - posted by "Liu (JIRA)" <ji...@apache.org> on 2018/12/25 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11216) Back to top button is missing in the Joining document and is not properly placed in the Process Function document - posted by "leesf (JIRA)" <ji...@apache.org> on 2018/12/25 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11217) Back to top button is missing in the Joining document and is not properly placed in the Process Function document - posted by "leesf (JIRA)" <ji...@apache.org> on 2018/12/25 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11218) fix the default restart delay value - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2018/12/26 02:39:00 UTC, 0 replies.
- Discuss on Upgrade Calcite dependency to 1.18 - posted by qianjin xu <fo...@gmail.com> on 2018/12/26 03:42:09 UTC, 0 replies.
- 回复:Discuss on Upgrade Calcite dependency to 1.18 - posted by 未来阳光 <22...@qq.com> on 2018/12/26 03:53:30 UTC, 0 replies.
- [jira] [Created] (FLINK-11219) Upgrade Jackson dependency to 2.9.6 - posted by "xuqianjin (JIRA)" <ji...@apache.org> on 2018/12/26 04:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11220) Can not Select row time field in JOIN query - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/26 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11221) Support delimited identifiers in TableAPI - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/26 13:52:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.5.6 released - posted by Thomas Weise <th...@apache.org> on 2018/12/26 20:03:33 UTC, 5 replies.
- [jira] [Created] (FLINK-11222) Change api.scala.DataStream to api.datastream.DataStream in HarnessTestBase - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/27 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11223) Time zone problem of row time field - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/27 03:47:00 UTC, 0 replies.
- Hbase state backend in Flink - posted by Naveen Kumar <na...@flipkart.com.INVALID> on 2018/12/27 08:49:09 UTC, 5 replies.
- [jira] [Created] (FLINK-11224) Log is missing in scala-shell - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/12/27 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11225) Error state of addedJobGraphs when Dispatcher with concurrent revoking and granting leadership - posted by "dongtingting (JIRA)" <ji...@apache.org> on 2018/12/27 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11226) Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream - posted by "Albert Bikeev (JIRA)" <ji...@apache.org> on 2018/12/27 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11227) The DescriptorProperties contains some bounds checking errors - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/12/27 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11228) Flink web UI can not read stdout logs - posted by "wxmimperio (JIRA)" <ji...@apache.org> on 2018/12/28 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11229) Support ScalarFunction for the where/filter clause. - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/12/29 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11230) Sum of FlinkSql after two table union all.The value is too large. - posted by "jiwei (JIRA)" <ji...@apache.org> on 2018/12/29 04:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11231) Unified the definition of Java DataStream and Scala DataStream interface for set parallelism - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/12/29 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11232) Empty Start Time of sub-task on web dashboard - posted by "BoWang (JIRA)" <ji...@apache.org> on 2018/12/29 09:12:00 UTC, 0 replies.
- [DISCUSSION] Complete restart after successive failures - posted by Gyula Fóra <gy...@gmail.com> on 2018/12/29 12:36:01 UTC, 0 replies.
- [jira] [Created] (FLINK-11233) Small typo in documentation - Jobs in Flink correspond "do" dataflow graphs. - posted by "Shuangjiang Li (JIRA)" <ji...@apache.org> on 2018/12/30 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11234) ExternalTableCatalogBuilder unable to build a batch-only table - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/12/31 03:22:00 UTC, 0 replies.
- Re: [DISCUSS]Enhancing flink scheduler by implementing blacklist mechanism - posted by Stephan Ewen <se...@apache.org> on 2018/12/31 10:44:23 UTC, 0 replies.
- [jira] [Created] (FLINK-11235) fix thread lack when elasticsearch transport client init failed - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2018/12/31 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11236) possible Confluent dependency leak - posted by "Zhenhao Li (JIRA)" <ji...@apache.org> on 2018/12/31 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11237) Enhance LocalExecutor to wrap TableEnvironment w/ user classloader - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/12/31 17:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11238) Enhance SQL-Client to recursively list tables - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/12/31 20:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11239) Enhance SQL-Client to recursively list UDFs - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/12/31 21:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11240) Implement external catalog factory and descriptor - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/12/31 22:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11241) Enhance TableEnvironment to connect to a catalog via a descriptor - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/12/31 22:56:00 UTC, 0 replies.