You are viewing a plain text version of this content. The canonical link for it is here.

---

- [jira] [Created] (FLINK-16352) Use LinkedHashMap for deterministic iterations - posted by "testfixer0 (Jira)" <ji...@apache.org> on 2020/03/01 00:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16353) Issue when flink upload a job with stream sql query - posted by "Miguel Angel (Jira)" <ji...@apache.org> on 2020/03/01 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16354) Add PrintSink for Table API - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/03/01 02:04:00 UTC, 0 replies.
- Re: [VOTE] FLIP-93: JDBC catalog and Postgres catalog - posted by zoudan <zo...@163.com> on 2020/03/01 10:33:02 UTC, 6 replies.
- [jira] [Created] (FLINK-16355) Inconsistent library versions notice. - posted by "Kaifeng Huang (Jira)" <ji...@apache.org> on 2020/03/01 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16356) Some dependencies contain CVEs - posted by "XuCongying (Jira)" <ji...@apache.org> on 2020/03/01 13:45:00 UTC, 0 replies.
- [DISCUSS] FLIP-107: Reading table columns from different parts of source records - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/03/01 14:30:31 UTC, 9 replies.
- [ANNOUNCE] Weekly Community Update 2020/09 - posted by Konstantin Knauf <ko...@ververica.com> on 2020/03/01 16:30:53 UTC, 0 replies.
- [jira] [Created] (FLINK-16357) Extend Checkpoint Coordinator to differentiate between "regional restore" and "full restore". - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/01 23:04:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-84: Improve & Refactor execute/sqlQuery/sqlUpdate APIS of TableEnvironment - posted by godfrey he <go...@gmail.com> on 2020/03/02 01:50:28 UTC, 1 replies.
- [jira] [Created] (FLINK-16358) Failed to execute when using rowtime or proctime and table keywords - posted by "backbook (Jira)" <ji...@apache.org> on 2020/03/02 01:52:00 UTC, 0 replies.
- Re: [ANNOUNCE] Jingsong Lee becomes a Flink committer - posted by Terry Wang <zj...@gmail.com> on 2020/03/02 03:10:25 UTC, 1 replies.
- [DISCUSS] FLIP-108: Add GPU support in Flink - posted by Yangze Guo <ka...@gmail.com> on 2020/03/02 04:06:16 UTC, 32 replies.
- [jira] [Created] (FLINK-16359) Introduce WritableVectors for abstract writing - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/02 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16360) connector on hive 2.0.1 don't support type conversion from STRING to VARCHAR - posted by "wgcn (Jira)" <ji...@apache.org> on 2020/03/02 06:07:00 UTC, 0 replies.
- [DISCUSS] FLIP-109: Improve Hive dependencies out-of-box experience - posted by Jingsong Lee <lz...@apache.org> on 2020/03/02 06:31:01 UTC, 1 replies.
- Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment - posted by Jingsong Lee <lz...@apache.org> on 2020/03/02 06:45:59 UTC, 2 replies.
- [jira] [Created] (FLINK-16361) FLIP-84: Improve & Refactor API of TableEnvironment - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/02 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16362) remove deprecated method in StreamTableSink - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/02 07:04:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-106: Support Python UDF in SQL Function DDL - posted by Jark Wu <im...@gmail.com> on 2020/03/02 07:11:43 UTC, 10 replies.
- [jira] [Created] (FLINK-16363) Correct the execution behavior of TableEnvironment and StreamTableEnvironment - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/02 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16364) Deprecate the methods in TableEnvironment proposed by FLIP-84 - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/02 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16365) awaitTermination() result is not checked - posted by "Roman Leventov (Jira)" <ji...@apache.org> on 2020/03/02 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16366) Introduce executeStatement method in TableEnvironment - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/02 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16367) Introduce createDmlBatch method in TableEnvironment - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/02 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16368) ZooKeeperHighAvailabilityITCase test fail - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/02 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16369) Allow the StreamingFileSink to restore from a previous (old) savepoint. - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/03/02 08:58:00 UTC, 0 replies.
- Re: 开发相关问题咨询Development related problems consultation - posted by JingsongLee <lz...@aliyun.com.INVALID> on 2020/03/02 09:14:55 UTC, 0 replies.
- Re: [DISCUSS] FLIP-85: Delayed Job Graph Generation - posted by Kostas Kloudas <kk...@gmail.com> on 2020/03/02 09:57:48 UTC, 23 replies.
- [jira] [Created] (FLINK-16370) YARNHighAvailabilityITCase fails on JDK11 nightly test: NoSuchMethodError: org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.server.quorum.flexible.QuorumMaj - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/02 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16371) HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException' - posted by "Sivaprasanna Sethuraman (Jira)" <ji...@apache.org> on 2020/03/02 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16372) Generate unique operator name - posted by "Zou (Jira)" <ji...@apache.org> on 2020/03/02 10:19:00 UTC, 0 replies.
- Regarding access to Jira - posted by Sivaprasanna <si...@gmail.com> on 2020/03/02 10:23:15 UTC, 1 replies.
- [jira] [Created] (FLINK-16373) EmbeddedLeaderService: IllegalStateException: The RPC connection is already closed - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/02 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16374) StreamingKafkaITCase: IOException: error=13, Permission denied - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/02 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16375) Remove references to those methods from documentation - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/03/02 10:52:00 UTC, 0 replies.
- Flink dev blog - posted by Arvid Heise <ar...@ververica.com> on 2020/03/02 10:53:19 UTC, 36 replies.
- [jira] [Created] (FLINK-16376) Using consistent method to get Yarn application directory - posted by "Victor Wong (Jira)" <ji...@apache.org> on 2020/03/02 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16377) Support inline user defined functions in expression dsl - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/03/02 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16378) Kerberized YARN on Docker test fails on jdk11 on AZP - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/02 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16379) Introduce fromValues in TableEnvironment - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/03/02 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16380) AZP: Python test fails on jdk11 nightly test (misc profile) - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/02 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16381) Support CREATE FUNCTION statements in SQL CLI - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/03/02 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16382) SQL CLI should support command history file - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/03/02 12:32:00 UTC, 0 replies.
- Contributor permission application - posted by 1101300123 <hd...@163.com> on 2020/03/02 12:50:40 UTC, 2 replies.
- [jira] [Created] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/02 12:52:00 UTC, 0 replies.
- Re: [Discussion] Job generation / submission hooks & Atlas integration - posted by Márton Balassi <mb...@apache.org> on 2020/03/02 14:04:14 UTC, 17 replies.
- [jira] [Created] (FLINK-16384) Support SHOW CREATE TABLE command in SQL Client - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/02 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16385) Use LinkedHashMap in SqlFunctionUtils.java - posted by "cpugputpu (Jira)" <ji...@apache.org> on 2020/03/02 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16386) Use LinkedHashMap in SqlFunctionUtils.java - posted by "cpugputpu (Jira)" <ji...@apache.org> on 2020/03/02 14:46:00 UTC, 0 replies.
- Re: [VOTE] FLIP-100: Add Attempt Information - posted by Gary Yao <ga...@apache.org> on 2020/03/02 14:50:13 UTC, 8 replies.
- [jira] [Created] (FLINK-16387) Use LinkedHashMap for deterministic order in HeapMapState.java - posted by "cpugputpu (Jira)" <ji...@apache.org> on 2020/03/02 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16388) Bump orc-core to 1.4.5 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/02 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16389) Bump Kafka 0.10 to 0.10.2.2 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/02 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16390) Add `view` and `clear` methods to `PersistedTable` - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/03/02 19:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16391) Enhance the RequestReply protocol with Egresses and Delayed Messages - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/02 20:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16392) oneside sorted cache in intervaljoin - posted by "Chen Qin (Jira)" <ji...@apache.org> on 2020/03/02 22:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16393) Kinesis consumer unnecessarily creates record emitter thread w/o source sync - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2020/03/02 23:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16394) LocalFileSystemTest.testRenameFileWithNoAccess failed when Using root to execute MVN test on Linux system - posted by "Peidian Li (Jira)" <ji...@apache.org> on 2020/03/03 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16395) Mention OkHttp in NOTICE file of statefun-flink-distribution - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/03 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16396) Support binding Kafka egresses with YAML-ized modules - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/03 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16397) [metric] flink metric graphite will format double metrics to "%2.2f" - posted by "BlaBlabla (Jira)" <ji...@apache.org> on 2020/03/03 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16398) Rename Protobuf Kafka Ingress / Routable Kafka Ingress type identifier strings - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/03 04:33:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-56: Dynamic Slot Allocation - posted by shaoxun <83...@qq.com> on 2020/03/03 07:00:39 UTC, 1 replies.
- [jira] [Created] (FLINK-16399) An OOM error occurred in Flink Job Manager - posted by "jiangbo (Jira)" <ji...@apache.org> on 2020/03/03 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16400) HdfsKindTest.testS3Kind fails in Hadoop 2.4.1 nightly test - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/03 09:09:00 UTC, 0 replies.
- SerializableHadoopConfiguration - posted by Sivaprasanna <si...@gmail.com> on 2020/03/03 10:24:43 UTC, 11 replies.
- [Reminder] Service Unavailable in JIRA - posted by Xingbo Huang <hx...@gmail.com> on 2020/03/03 12:28:45 UTC, 0 replies.
- [DISCUSS] FLIP-110: Support LIKE clause in CREATE TABLE - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/03/03 13:12:11 UTC, 12 replies.
- Creating TemporalTable based on Catalog table in SQL Client - posted by Gyula Fóra <gy...@gmail.com> on 2020/03/03 13:16:33 UTC, 4 replies.
- Re: [DISCUSS] Remove Eclipse-specific plugin configurations - posted by Flavio Pompermaier <po...@okkam.it> on 2020/03/03 13:18:50 UTC, 3 replies.
- [jira] [Created] (FLINK-16401) Support map type for JsonRowSerializationSchema - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/03/03 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16402) Alter table fails on Hive catalog - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/03/03 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16403) Solve the potential deadlock problem when reducing exclusive buffers to zero - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/03 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16404) Solve the potential deadlock problem when reducing exclusive buffers to zero - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/03 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16405) Add hive-metastore dependency in connecting to hive docs - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/03/03 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16406) Increase default value for JVM Metaspace to minimise its OutOfMemoryError - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/03/03 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16407) Remove "FAQ" section from flink website - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/03 16:02:00 UTC, 0 replies.
- RE: Building with Hadoop 3 - posted by "LINZ, Arnaud" <AL...@bouyguestelecom.fr> on 2020/03/03 17:02:55 UTC, 1 replies.
- [jira] [Created] (FLINK-16408) Bind user code class loader to lifetime of a slot - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/03/03 18:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16409) Use LinkedHashMap for deterministic iterations - posted by "testfixer0 (Jira)" <ji...@apache.org> on 2020/03/03 19:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16410) PrometheusReporterEndToEndITCase fails with ClassNotFoundException - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/03 21:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16411) Use google maven mirrors in all maven invocations on AZP - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/03 21:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16412) Disallow embedded metastore in HiveCatalog production code - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/04 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16413) Reduce hive source parallelism when limit push down - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/04 05:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16414) create udaf/udtf function using sql casuing ValidationException: SQL validation failed. null - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2020/03/04 05:54:00 UTC, 0 replies.
- Flink Web UI display nothing in k8s when use ingress - posted by LakeShen <sh...@gmail.com> on 2020/03/04 06:07:48 UTC, 1 replies.
- [jira] [Created] (FLINK-16415) Add a version property to module.yaml - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/04 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16416) Shutdown the task manager gracefully in standalone mode - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/03/04 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16417) ConnectedComponents iterations with high parallelism end-to-end test fails with OutOfMemoryError: Direct buffer memory - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/04 08:23:00 UTC, 0 replies.
- Introduce flink-connector-hive-xx modules - posted by Jingsong Lee <lz...@apache.org> on 2020/03/04 08:57:04 UTC, 1 replies.
- [DISCUSS] Introduce flink-connector-hive-xx modules - posted by Jingsong Lee <lz...@apache.org> on 2020/03/04 09:00:34 UTC, 7 replies.
- [jira] [Created] (FLINK-16418) Hide hive version to avoid user confuse - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/04 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2020/03/04 09:31:00 UTC, 0 replies.
- [DISCUSS] FLIP-111: Docker image unification - posted by Andrey Zagrebin <az...@apache.org> on 2020/03/04 09:34:29 UTC, 12 replies.
- [Maven] Many artifactId contain ${scala.binary.version} - posted by Niels Basjes <Ni...@basjes.nl> on 2020/03/04 09:38:51 UTC, 1 replies.
- [jira] [Created] (FLINK-16420) Support CREATE TABLE with schema inference - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/04 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16421) Changing default catalog to hive without changing default database fails - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/03/04 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16422) Cannot use [catalog].[db].table with Hive catalog - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/03/04 11:52:00 UTC, 0 replies.
- [VOTE] FLIP-100[NEW]: Add Attempt Information - posted by Yadong Xie <vt...@gmail.com> on 2020/03/04 12:17:22 UTC, 4 replies.
- [jira] [Created] (FLINK-16423) test_ha_per_job_cluster_datastream.sh gets stuck - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/04 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16424) Can't verify PGP signatures of Flink 1.9.2 and 1.10.0 - posted by "Bob (Jira)" <ji...@apache.org> on 2020/03/04 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16425) Add rate limiting feature for kafka table source - posted by "Zou (Jira)" <ji...@apache.org> on 2020/03/04 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16426) Add rate limiting feature for kafka table source - posted by "Zou (Jira)" <ji...@apache.org> on 2020/03/04 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16427) Remove directly throw ProgramInvocationExceptions in RemoteStreamEnvironment - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2020/03/04 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16428) Fine-grained network buffer management for backpressure - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/04 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16429) failed to restore flink job from checkpoints due to unhandled exceptions - posted by "Yu Yang (Jira)" <ji...@apache.org> on 2020/03/05 00:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16430) Pipelined region scheduling - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/03/05 01:49:00 UTC, 0 replies.
- [PROPOSAL] Reverse the dependency from flink-streaming-java to flink-client - posted by tison <wa...@gmail.com> on 2020/03/05 01:53:36 UTC, 10 replies.
- [jira] [Created] (FLINK-16431) Pass build profile into end to end test script on Azure - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/05 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16432) Building Hive connector gives problems - posted by "Niels Basjes (Jira)" <ji...@apache.org> on 2020/03/05 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16433) TableEnvironment doesn't clear buffered operations when it fails to translate the operation - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/05 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16434) Add document to explain how to pack hive with their own hive dependencies - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/05 08:58:01 UTC, 0 replies.
- [jira] [Created] (FLINK-16435) Fix ide static check - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/03/05 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16436) Update Apache downloads link due to INFRA structural changes - posted by "Yu Li (Jira)" <ji...@apache.org> on 2020/03/05 09:42:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-76: Unaligned checkpoints - posted by Arvid Heise <ar...@ververica.com> on 2020/03/05 09:51:59 UTC, 0 replies.
- [jira] [Created] (FLINK-16437) Make SlotManager allocate resource from ResourceManager at the worker granularity. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/03/05 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16438) Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/03/05 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16439) Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/03/05 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16440) Extend SlotManager metrics and status for dynamic slot allocation. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/03/05 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/03/05 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16442) Make MesosResourceManager starts workers using WorkerResourceSpec requested by SlotManager - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/03/05 10:21:00 UTC, 0 replies.
- [DISCUSS] Disable "Squash and merge" button for Flink repository on GitHub - posted by Jark Wu <im...@gmail.com> on 2020/03/05 10:42:06 UTC, 23 replies.
- [jira] [Created] (FLINK-16443) Fix wrong fix for user-code CheckpointExceptions - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/05 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16444) Count the read/write/seek/next latency of RocksDB as metrics - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/03/05 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16445) Raise japicmp.referenceVersion to 1.10.0 - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/03/05 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16446) Add rate limiting feature for FlinkKafkaConsumer - posted by "Zou (Jira)" <ji...@apache.org> on 2020/03/05 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16447) Non serializable field on CompressWriterFactory - posted by "João Boto (Jira)" <ji...@apache.org> on 2020/03/05 17:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16448) add documentation for Hive table sink parallelism setting strategy - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/05 19:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16449) Deprecated methods in the Table API walkthrough. - posted by "Marta Paes Moreira (Jira)" <ji...@apache.org> on 2020/03/05 23:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16450) Integrate parquet columnar row reader to hive - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/06 02:11:00 UTC, 0 replies.
- [Discuss] IntervalJoin one side sorted cache - posted by Chen Qin <qi...@gmail.com> on 2020/03/06 02:47:02 UTC, 1 replies.
- [jira] [Created] (FLINK-16451) listagg with distinct for over window - posted by "jinfeng (Jira)" <ji...@apache.org> on 2020/03/06 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16452) Insert into static partition doesn't support order by or limit - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/06 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16453) A test failure in KafkaTest - posted by "cpugputpu (Jira)" <ji...@apache.org> on 2020/03/06 04:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16454) Update the copyright year in NOTICE files - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/06 05:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16455) Introduce flink-sql-connector-hive modules to provide hive uber jars - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/06 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16456) Heavy deployment end-to-end test fails with OutOfMemoryError on JDK11 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/06 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16457) Flink CLI end-to-end test unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/06 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16458) Bump japicmp.referenceVersion to 1.10.0 - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2020/03/06 09:13:00 UTC, 0 replies.
- [VOTE] [FLIP-85] Flink Application Mode - posted by Kostas Kloudas <kk...@apache.org> on 2020/03/06 09:17:57 UTC, 11 replies.
- [jira] [Created] (FLINK-16460) Add Serialization benchmark for Protobuf - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/03/06 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16459) Add Serialization benchmark for Apache Thrift - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/03/06 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16461) Multiple Bindings with SLF4J - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/03/06 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16462) PrometheusReporterEndToEndITCase failed with NoClassDefFoundError RequestBody - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/03/06 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16463) CodeGenUtils generates code that has two semicolons for GroupingWindowAggsHandler in blink - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/03/06 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16464) result-mode tableau may shift when content contains Chinese String in SQL CLI - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/03/06 13:00:09 UTC, 0 replies.
- [jira] [Created] (FLINK-16465) Add more detailed instructions for TableSink - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/03/06 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16466) Group by on event time should produce insert only result - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/03/06 14:09:00 UTC, 0 replies.
- 回复：[Discuss] IntervalJoin one side sorted cache - posted by "张静(槿瑜)" <ji...@alibaba-inc.com> on 2020/03/06 15:46:02 UTC, 0 replies.
- [jira] [Created] (FLINK-16467) MemorySizeTest#testToHumanReadableString() is not portable - posted by "Michael Osipov (Jira)" <ji...@apache.org> on 2020/03/06 17:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets - posted by "Jason Kania (Jira)" <ji...@apache.org> on 2020/03/06 17:47:00 UTC, 0 replies.
- Request for more Jira rights - posted by Niels Basjes <Ni...@basjes.nl> on 2020/03/06 19:07:21 UTC, 2 replies.
- [jira] [Created] (FLINK-16469) Improve logging configurations - posted by "Grzegorz Slowikowski (Jira)" <ji...@apache.org> on 2020/03/06 19:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16470) Network failure causes Checkpoint Coordinator to flood disk with exceptions - posted by "Jason Kania (Jira)" <ji...@apache.org> on 2020/03/06 20:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16471) develop PostgresJDBCCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/06 21:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16472) support precision of timestamp and time data types - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/06 21:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16473) add documentation for PostgresJDBCCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/06 22:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16474) develop OracleJDBCCatalog to connect Flink with Oracle databases and ecosystem - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/06 22:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16475) PulsarConsumerSource messageReceiveTimeoutMs parameter should be configurable - posted by "Jason Kania (Jira)" <ji...@apache.org> on 2020/03/07 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16476) SelectivityEstimatorTest logs LinkageErrors - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/07 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/07 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16478) add restApi to modify loglevel - posted by "xiaodao (Jira)" <ji...@apache.org> on 2020/03/07 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16479) TableUtilsStreamingITCase crashes - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/07 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16480) Improve e2e test failure error reporting - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/07 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16481) flink-kafka-connector 支持动态扩缩容 - posted by "likang (Jira)" <ji...@apache.org> on 2020/03/07 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16482) Flink任务的kafkaSource因为cancel导致任务失败而重启 - posted by "likang (Jira)" <ji...@apache.org> on 2020/03/07 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16483) Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/07 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16484) Support all the data types in vectorized Python UDF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/07 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16485) Support vectorized Python UDF in the batch mode of old planner - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/07 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16486) Add documentation for vectorized Python UDF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/07 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16487) Add flink-connector-kudu - posted by "Zhimin Li (Jira)" <ji...@apache.org> on 2020/03/07 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16488) Logging issues when running through K8s - posted by "John Mathews (Jira)" <ji...@apache.org> on 2020/03/07 23:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16489) flink on yarn模式下，rm重启am，没有从失败的am保存的chk来重启 - posted by "liangji (Jira)" <ji...@apache.org> on 2020/03/08 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16490) Add a minimal statefun Python SDK - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/08 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16491) Add compression support for ParquetAvroWriters - posted by "Yao Zhang (Jira)" <ji...@apache.org> on 2020/03/08 15:29:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/10 - posted by Konstantin Knauf <ko...@ververica.com> on 2020/03/08 20:22:04 UTC, 0 replies.
- [jira] [Created] (FLINK-16492) Flink SQL can not read decimal in hive parquet - posted by "xingoo (Jira)" <ji...@apache.org> on 2020/03/09 01:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16493) Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/09 01:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16494) Use enum type instead of string type for KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/09 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16495) Improve default flush strategy for Elasticsearch sink to make it work out-of-box - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/09 03:30:00 UTC, 0 replies.
- [DISCUSS] FLIP-112: Support User-Defined Metrics for Python UDF - posted by Hequn Cheng <he...@apache.org> on 2020/03/09 03:31:47 UTC, 6 replies.
- [jira] [Created] (FLINK-16496) Improve default flush strategy for HBase sink to make it work out-of-box - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/09 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/09 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16498) make Postgres table work end-2-end in Flink SQL with PostgresJDBCCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/09 04:02:00 UTC, 0 replies.
- [DISCUSS] Use SET statement to set table config in Flink SQL and implement a unified SQL call method - posted by "DONG, Weike" <ky...@connect.hku.hk> on 2020/03/09 04:46:17 UTC, 5 replies.
- Flink Kafka consumer auto-commit timeout - posted by Rong Rong <wa...@gmail.com> on 2020/03/09 05:10:20 UTC, 4 replies.
- [jira] [Created] (FLINK-16499) Flink shaded hadoop could not work when Yarn timeline service is enabled - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/03/09 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16500) Hive get primary key should not throw exception when Invalid method name - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/09 07:26:00 UTC, 0 replies.
- [DISCUSS]FLIP-113: Support SQL and planner hints - posted by Danny Chan <yu...@gmail.com> on 2020/03/09 08:36:21 UTC, 49 replies.
- [jira] [Created] (FLINK-16501) Support IS JSON predication for Table API in blink planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/09 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16502) Add documentation for all JSON function - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/09 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16503) Don't assign ScheduledExecutorService into variables of ExecutorService or Executor types - posted by "Roman Leventov (Jira)" <ji...@apache.org> on 2020/03/09 09:28:00 UTC, 0 replies.
- How to change the flink web-ui jobServer? - posted by LakeShen <sh...@gmail.com> on 2020/03/09 09:46:50 UTC, 4 replies.
- [DISCUSS] Update on Flink Stateful Functions & what are the next steps? - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/03/09 11:12:40 UTC, 5 replies.
- [jira] [Created] (FLINK-16504) Add a AWS DynamoDB (sink) connector - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/09 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16505) Document how to use the FlinkKinesisConsumer to read a CDC stream from DynamoDB - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/09 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16506) Sql - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2020/03/09 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16507) "update_branch_version" should also update the version in Stateful Function's Python SDK setup.py file - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/09 13:45:00 UTC, 0 replies.
- [DISCUSS] FLIP-114: Support Python UDF in SQL Client - posted by Wei Zhong <we...@gmail.com> on 2020/03/09 14:09:52 UTC, 7 replies.
- [jira] [Created] (FLINK-16508) Name the ports exposed by the main Container in Pod - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/09 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16509) FlinkKafkaConsumerBase tries to log a context that may not have been initialized and fails - posted by "Arnaud Linz (Jira)" <ji...@apache.org> on 2020/03/09 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16510) Task manager safeguard shutdown may not be reliable - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2020/03/09 20:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16511) Task cancellation timeout is not effective on OOM errors - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2020/03/09 20:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16512) Add persistence API - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/03/09 21:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16513) Implement persistence API - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/03/09 21:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16514) SQLClientKafkaITCase fails with output mismatch - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/09 21:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16515) Refactor statefun documentation for multi-language SDKs - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/03/09 23:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16516) Remove Python UDF Codegen Code - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/03/10 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16517) Add a long running WordCount example - posted by "Ethan Li (Jira)" <ji...@apache.org> on 2020/03/10 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16518) Stateful Function's KafkaSinkProvider should use `setProperty` instead of `put` for resolving client properties - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/10 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16519) CheckpointCoordinatorFailureTest logs LinkageErrors - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/10 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16520) Move Kafka client properties resolution in KafkaSinkProvider to KafkaEgressBuilder - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/10 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16521) Remove unused FileUtils#isClassFile - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/10 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16522) Take use of Python3 type hint to rebuild Python Function signature - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/03/10 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16523) The improvement for local state of rocksdb backend. - posted by "luojiangyu (Jira)" <ji...@apache.org> on 2020/03/10 09:11:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.10.1 - posted by Yu Li <ca...@gmail.com> on 2020/03/10 09:49:09 UTC, 28 replies.
- [DISCUSS] Link Stateful Functions from the Flink Website - posted by Stephan Ewen <se...@apache.org> on 2020/03/10 11:33:05 UTC, 6 replies.
- Re: [DISCUSS] Extend (or maintain) "shell" script support for Windows - posted by Aljoscha Krettek <al...@apache.org> on 2020/03/10 11:46:25 UTC, 6 replies.
- [VOTE] [FLIP-76] Unaligned checkpoints - posted by Arvid Heise <ar...@ververica.com> on 2020/03/10 13:33:08 UTC, 12 replies.
- [jira] [Created] (FLINK-16524) Optimize the result of FlattenRowCoder to generator to eliminate unnecessary function calls - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/03/10 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16525) TwoPhaseCommitSinkFunction subtask logs misleading name - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2020/03/10 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16526) Escape character doesn't work for computed column - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2020/03/10 17:20:00 UTC, 0 replies.
- time-windowed joins and tumbling windows - posted by Vinod Mehra <vm...@lyft.com.INVALID> on 2020/03/10 18:26:11 UTC, 1 replies.
- [jira] [Created] (FLINK-16527) hadoop.version of flink-shaded-hadoop-2-uber should be checked - posted by "Noah (Jira)" <ji...@apache.org> on 2020/03/11 00:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16528) Support Limit push down for streaming sources - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/11 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16529) Add ignore_parse_errors() method to Json format in python API - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/11 03:04:00 UTC, 0 replies.
- [DISCUSS] Features of Apache Flink 1.11 - posted by Zhijiang <wa...@aliyun.com.INVALID> on 2020/03/11 03:16:38 UTC, 5 replies.
- [jira] [Created] (FLINK-16530) Add documentation about "GROUPING SETS" and "CUBE" support in streaming mode - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/11 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16531) Add full integration tests for "GROUPING SETS" for streaming mode - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/11 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16532) Cannot insert white space characters as partition value for Hive table - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/11 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16533) ExecutionEnvironment supports executing plan - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/11 04:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16534) Support specify savepoint path when submitting sql job through sql client - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/03/11 04:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16535) BatchTableSink#emitDataSet returns DataSink - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/11 05:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16536) Implement InputChannel state recovery for unaligned checkpoint - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/11 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16537) Implement ResultPartition state recovery for unaligned checkpoint - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/11 05:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16538) Restructure Python Table API documentation - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/11 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16539) sql client set param error - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/03/11 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16540) Fully specify bugfix version of Docker containers in Flink Playground docker-compose.yaml files - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/03/11 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16541) Document of table.exec.shuffle-mode is incorrect - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/03/11 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16542) Nothing on the HistoryServer - posted by "JieFang.He (Jira)" <ji...@apache.org> on 2020/03/11 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16543) Support setting schedule mode by config for Blink planner in batch mode - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/03/11 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16544) Flink FileSystem for web.uploadDir - posted by "Angel Barragán (Jira)" <ji...@apache.org> on 2020/03/11 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16545) Remove Eclipse-specific plugins - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/11 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16546) Fix logging bug in YarnClusterDescriptor#startAppMaster - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/11 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16547) Corrent the order to write temporary files in YarnClusterDescriptor#startAppMaster - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/11 12:54:00 UTC, 0 replies.
- [DISCUSS] FLIP 116: Unified Memory Configuration for Job Managers - posted by Andrey Zagrebin <az...@apache.org> on 2020/03/11 12:55:58 UTC, 7 replies.
- [jira] [Created] (FLINK-16548) [Requirement] Consistent id to identify jm/tm in different cluster modes - posted by "hejianchao (Jira)" <ji...@apache.org> on 2020/03/11 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16549) ExecutionContextTest.testCatalogs gets stuck / Out of memory - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/11 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16550) HadoopS3* tests fail with NullPointerException exceptions - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/11 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16551) WebFrontendITCase.getFrontPage fails - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/11 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16552) Cannot include Option fields in any Table join - posted by "Jason Sinn (Jira)" <ji...@apache.org> on 2020/03/11 16:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-16553) KafkaFetcher topic/partition metrics - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2020/03/11 16:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16554) Extract static classes from StreamTask - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/03/11 17:39:00 UTC, 0 replies.
- AfterMatchSkipStrategy for timed out patterns - posted by Dominik Wosiński <wo...@gmail.com> on 2020/03/11 20:18:02 UTC, 0 replies.
- [jira] [Created] (FLINK-16555) Preflight check for known unstable hashCodes. - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/11 20:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16556) TopSpeedWindowing should implement checkpointing for its source - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/03/11 23:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16557) Document YAML-ized Kafka egresses / ingresses in Stateful Functions documentation - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/12 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16558) Reword Stateful Functions doc's tagline - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/12 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16559) Cannot create Hive avro table in test - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/12 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16560) StreamExecutionEnvironment configuration is empty when building program via PackagedProgramUtils#createJobGraph - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/03/12 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16561) Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure - posted by "Biao Liu (Jira)" <ji...@apache.org> on 2020/03/12 04:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16562) Handle JobManager termination future in place - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2020/03/12 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16563) CommandLineParser should fail with explicit error message when parsing recognized arguments. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/03/12 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16564) HadoopS3RecoverableWriterITCase fails with NullPointerException - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/12 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16565) Make Pipeline Json compitable between Java and Python if all Pipelinestage are Java ones - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/12 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16566) Change the log level of the launching command and dynamic properties from DEBUG to INFO in Mesos integration - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/03/12 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16567) Get the API error of the StreamQueryConfig on Page "Query Configuration" - posted by "jinhai (Jira)" <ji...@apache.org> on 2020/03/12 09:14:00 UTC, 0 replies.
- Flink 1.10 StopWithSavepoint only suit for the sources that implement the StoppableFunction interface? - posted by LakeShen <sh...@gmail.com> on 2020/03/12 09:44:00 UTC, 2 replies.
- [jira] [Created] (FLINK-16568) Cannot call Hive UDAF that requires constant arguments - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/12 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16569) Allow empty keys in Kafka egress messages for Statefun Python SDK - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/12 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16570) Difficulties to select correct metric with long name in dropdown of Flink UI task menu - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2020/03/12 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16571) Throw exception when current key are out of range - posted by "&res (Jira)" <ji...@apache.org> on 2020/03/12 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/03/12 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16573) Kinesis consumer does not properly shutdown RecordFetcher threads - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2020/03/12 12:25:00 UTC, 0 replies.
- [DISCUSS] Drop Bucketing Sink - posted by Robert Metzger <rm...@apache.org> on 2020/03/12 14:40:46 UTC, 15 replies.
- [jira] [Created] (FLINK-16574) StreamingFileSink should rename files or fail if destination file already exists - posted by "static-max (Jira)" <ji...@apache.org> on 2020/03/12 17:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16575) develop HBaseCatalog to integrate HBase metadata into Flink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/12 18:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16576) State inconsistency on restore with memory state backends - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/03/12 21:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2020/03/13 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16578) join lateral table function with condition fails with exception - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2020/03/13 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16579) Upgrade Calcite version to 1.23 for Flink SQL - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/13 03:15:00 UTC, 0 replies.
- Cancel the flink task and restore from checkpoint ,can I change the flink operator's parallelism - posted by LakeShen <sh...@gmail.com> on 2020/03/13 03:30:55 UTC, 5 replies.
- [jira] [Created] (FLINK-16580) flink-connector-kafka desrializer - posted by "李开青 (Jira)" <ji...@apache.org> on 2020/03/13 04:09:00 UTC, 0 replies.
- Flink YARN app terminated before the client receives the result - posted by "DONG, Weike" <ky...@connect.hku.hk> on 2020/03/13 04:30:46 UTC, 10 replies.
- [jira] [Created] (FLINK-16581) Minibatch deduplication lack state TTL - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/13 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/03/13 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16583) SQLClientKafkaITCase.testKafka failed in SqlClientException - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/13 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16584) Whether to support the long type field in table planner when the source is kafka and event time field's type is long - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/03/13 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com" - posted by "hiliuxg (Jira)" <ji...@apache.org> on 2020/03/13 06:52:00 UTC, 0 replies.
- [DISCUSS] FLIP-115: Filesystem connector in Table - posted by Jingsong Li <ji...@gmail.com> on 2020/03/13 07:32:39 UTC, 18 replies.
- [jira] [Created] (FLINK-16586) Build ResultSubpartitionInfo and InputChannelInfo in respective constructors - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/13 08:15:00 UTC, 0 replies.
- [Discuss] FLINK-16039 Add API method to get last element in session window - posted by Manas Kale <ma...@gmail.com> on 2020/03/13 08:46:43 UTC, 2 replies.
- [jira] [Created] (FLINK-16587) Add basic CheckpointBarrierHandler for unaligned checkpoint - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/03/13 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16588) Add Disk Space metrics to TaskManagers - posted by "Thomas Wozniakowski (Jira)" <ji...@apache.org> on 2020/03/13 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16589) Flink Table SQL fails/crashes with big queries with lots of fields - posted by "Viet Pham (Jira)" <ji...@apache.org> on 2020/03/13 11:22:00 UTC, 0 replies.
- [DISCUSS] JMX remote monitoring integration with Flink - posted by Rong Rong <wa...@gmail.com> on 2020/03/13 12:53:55 UTC, 3 replies.
- [VOTE] FLIP-106: Support Python UDF in SQL Function DDL - posted by Wei Zhong <we...@gmail.com> on 2020/03/13 13:05:14 UTC, 9 replies.
- [jira] [Created] (FLINK-16590) flink-oss-fs-hadoop: Not all dependencies in NOTICE file are bundled - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/03/13 15:59:00 UTC, 0 replies.
- FLIP-117: HBase catalog - posted by Flavio Pompermaier <po...@okkam.it> on 2020/03/13 23:43:27 UTC, 3 replies.
- [jira] [Created] (FLINK-16591) Flink-zh Doc‘s show a wrong Email address - posted by "forideal (Jira)" <ji...@apache.org> on 2020/03/14 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16592) The doc of Streaming File Sink has a mistake of grammar - posted by "Chen (Jira)" <ji...@apache.org> on 2020/03/14 04:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16593) Misspelled words in GlobalAggregateManager.java - posted by "forideal (Jira)" <ji...@apache.org> on 2020/03/14 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16594) Misspelled words in GlobalAggregateManager.java - posted by "forideal (Jira)" <ji...@apache.org> on 2020/03/14 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16595) Support extra hadoop filesystem URLs for which to request delegation tokens - posted by "fa zheng (Jira)" <ji...@apache.org> on 2020/03/14 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16596) Support Enum-Values as part of a Key - posted by "Felix Wollschläger (Jira)" <ji...@apache.org> on 2020/03/14 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16597) tryCleanupOnError should happen before close - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/03/14 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16598) Respect the rest port exposed by Service in Fabric8FlinkKubeClient#getRestEndpoint - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/15 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16599) Throw Unknown identifier when having nested computed column - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2020/03/15 05:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16600) Respect the rest.bind-port for the Kubernetes setup - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/15 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16601) Corret the way to get Endpoint address for NodePort rest Service - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/15 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16602) Rework the Service design for Kubernetes deployment - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/15 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16603) statefun-quickstart generates invalid pom.xml - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/15 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16604) Column key in JM configuration is too narrow - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2020/03/15 14:22:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/11 - posted by Konstantin Knauf <ko...@ververica.com> on 2020/03/15 21:52:21 UTC, 0 replies.
- [VOTE] FLIP-112: Support User-Defined Metrics for Python UDF - posted by Hequn Cheng <he...@apache.org> on 2020/03/16 02:01:12 UTC, 5 replies.
- [jira] [Created] (FLINK-16605) Add max limitation to the total number of slots - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/03/16 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16606) Throw exceptions for the data types which are not currently supported - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/16 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16607) Update flink-fn-execution.proto adding more schema information - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/16 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16608) Support primitive data types for vectorized Python UDF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/16 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16609) Promotes the column name representation of SQL-CLI - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/03/16 04:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16610) FlinkKafkaInternalProducerITCase fails with timeout exception - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/16 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16611) Datadog reporter should chunk large reports - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/16 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16612) Submit job through the rest api, job name will be lost - posted by "Junli Zhang (Jira)" <ji...@apache.org> on 2020/03/16 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16613) Builds on Azure pipeline are not triggered - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/16 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/03/16 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16615) Introduce data structures and utilities to calculate Job Manager memory components - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/03/16 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16616) Drop BucketingSink - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/16 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16617) Automatic Any unpacking is broken with type deduction. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/16 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16618) Cannot use Hive GenericUDFBaseNumeric with Flink - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/16 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16619) Misleading SlotManagerImpl logging for slot reports of unknown task manager - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/16 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16620) Add attempt information in logging - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/03/16 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16621) Add support for custom logging configuration in docker-flink - posted by "Michal Lyson (Jira)" <ji...@apache.org> on 2020/03/16 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16622) Type ARRAY of table field 'id' does not match with the physical type LEGACY('ARRAY', 'ANY<[Ljava.lang.String;, rO0ABXNyAD......>') of the 'id' field of the TableSource return type. - posted by "gkgkgk (Jira)" <ji...@apache.org> on 2020/03/16 16:56:00 UTC, 0 replies.
- [DISCUSS] FLIP-95: New TableSource and TableSink interfaces - posted by Timo Walther <tw...@apache.org> on 2020/03/16 17:36:31 UTC, 28 replies.
- [jira] [Created] (FLINK-16623) add the shorthand 'desc' for describe on sql client - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/03/17 00:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16624) Support to customize annotations for the rest Service on Kubernetes - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/17 01:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16625) Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtil - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/17 02:04:00 UTC, 0 replies.
- Flink YARN Job unexpectedly switched to SUCCEEDED final status after CSV deserialization failure - posted by "DONG, Weike" <ky...@connect.hku.hk> on 2020/03/17 03:44:26 UTC, 1 replies.
- [jira] [Created] (FLINK-16626) Exception Encountered when cancelling a job in yarn per-job mode - posted by "chaiyongqiang (Jira)" <ji...@apache.org> on 2020/03/17 05:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16627) when insert into kafka ,how can i remove the keys with null value of json - posted by "jackray wang (Jira)" <ji...@apache.org> on 2020/03/17 05:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16628) Complex JSON sink into kafka error - posted by "jackray wang (Jira)" <ji...@apache.org> on 2020/03/17 06:44:00 UTC, 0 replies.
- Question about RocksDBStateBackend Compaction Filter state cleanup - posted by LakeShen <sh...@gmail.com> on 2020/03/17 07:30:26 UTC, 2 replies.
- [jira] [Created] (FLINK-16629) Streaming bucketing end-to-end test output hash mismatch - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/03/17 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16630) '@version' STRING is not support - posted by "jackray wang (Jira)" <ji...@apache.org> on 2020/03/17 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16631) Flink cache on Travis does not exist - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/03/17 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16632) Cast string to timestamp fail - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/17 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16633) CI builds without S3 credentials fail - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/17 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16634) The PartitionDiscoverer in FlinkKafkaConsumer should not use the user provided client.id. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/03/17 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16635) Incompatible okio dependency in flink-metrics-influxdb module - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/03/17 11:06:00 UTC, 0 replies.
- Hope to be Flink contributor - posted by 342622945 <34...@qq.com> on 2020/03/17 11:47:50 UTC, 4 replies.
- [jira] [Created] (FLINK-16636) TableEnvironmentITCase failed on traivs - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/17 11:49:00 UTC, 0 replies.
- Watermark generation in Temporal Table Join - posted by Dominik Wosiński <wo...@gmail.com> on 2020/03/17 13:53:38 UTC, 4 replies.
- [jira] [Created] (FLINK-16637) Flink YARN app terminated before the client receives the result - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2020/03/17 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16638) Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs - posted by "Bashar Abdul Jawad (Jira)" <ji...@apache.org> on 2020/03/18 00:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16639) Flink SQL Kafka source connector, add the no json format filter params when format.type is json - posted by "LakeShen (Jira)" <ji...@apache.org> on 2020/03/18 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16640) Expose listStatus latency in flink filesystem - posted by "Lu Niu (Jira)" <ji...@apache.org> on 2020/03/18 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/18 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16642) CSV TableSource / TableSink shouldn't be in flink-table-api-java-bridge package - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/03/18 04:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16643) flink-connector-hive_2.11 build fails on retrieving javax.jms:jms:jar:1.1 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/18 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16644) HadoopS3FileSystemBehaviorITCase failed with null uri host - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/18 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16645) Limit the maximum backlogs in subpartitions for data skew case - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/18 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16646) flink read orc file throw a NullPointerException - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/03/18 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16647) Miss file extension when inserting to hive table with compression - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/18 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16648) Clean up the input parameter StreamQueryConfig of the API in StreamTableEnvironment - posted by "jinhai (Jira)" <ji...@apache.org> on 2020/03/18 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16649) Support Java 14 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/18 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16650) Support LocalZonedTimestampType for Python UDF of blink planner - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/18 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16651) flink stream SQL INNER JOIN乱序 - posted by "王太阳 (Jira)" <ji...@apache.org> on 2020/03/18 09:45:00 UTC, 0 replies.
- [DISCUSS] (FLINK-16648) Clean up the input parameter StreamQueryConfig of the API in StreamTableEnvironment - posted by jinhai wang <ji...@gmail.com> on 2020/03/18 09:58:07 UTC, 3 replies.
- [jira] [Created] (FLINK-16652) Hive 3.1.1 test is broken - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/18 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16653) Introduce ResultPartitionWriterTestBase for simplifying tests - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/18 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16654) Implement Application Mode according to FLIP-85 - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/03/18 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16655) Introduce the EmbeddedExecutor - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/03/18 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16656) Introduce the DispatcherBootstrap - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/03/18 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16657) Wire the EmbeddedExecutor to the Web Submission logic. - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/03/18 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16658) Wire the EmbeddedExecutor to the StandaloneClusterEntrypoint. - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/03/18 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16659) flink 1.9.1 流排序（普通模式、CEP模式）多并发情况下分组异常 - posted by "wuchangjun (Jira)" <ji...@apache.org> on 2020/03/18 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16660) Introduce the ApplicationDispatcherBootstrap - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/03/18 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16661) Introduce the YarnApplicationClusterEntrypoint - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/03/18 13:40:00 UTC, 0 replies.
- PackagedProgram and ProgramDescription - posted by Flavio Pompermaier <po...@okkam.it> on 2020/03/18 13:45:49 UTC, 2 replies.
- [VOTE] FLIP 116: Unified Memory Configuration for Job Managers - posted by Andrey Zagrebin <az...@apache.org> on 2020/03/18 14:16:18 UTC, 5 replies.
- [jira] [Created] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name) - posted by "chenxyz (Jira)" <ji...@apache.org> on 2020/03/18 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16663) Docs version 1.10 missing from version picker dropdown - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/18 16:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16664) Unable to set DataStreamSource parallelism to default (-1) - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/03/18 23:26:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-106: Support Python UDF in SQL Function DDL - posted by Wei Zhong <we...@gmail.com> on 2020/03/19 01:58:23 UTC, 0 replies.
- [jira] [Created] (FLINK-16665) Support Python UDF in SQL Function DDL (FLIP-106) - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/03/19 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16666) Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/03/19 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16667) Support new Python dependency configuration options in flink-client - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/03/19 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16668) Support new Python dependency configuration options in flink-python - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/03/19 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16669) Support Python UDF in SQL function DDL - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/03/19 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16670) Support User-Defined Metrics in Python UDF - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/19 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16671) Support define scopes and variables on Python metric group - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/19 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16672) Support Counter, Gauge, Meter, Distribution metric type for Python UDF - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/19 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16673) Support Counter, Gauge, Meter, Distribution metric type for Python UDTF - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/19 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16674) Add documentation about how to use user-defined metrics for Python UDF - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/19 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16675) TableEnvironmentITCase. testClearOperation fails on travis nightly build - posted by "Yu Li (Jira)" <ji...@apache.org> on 2020/03/19 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16676) test_pipeline_from_invalid_json failed on Azure - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/03/19 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16677) Make Stateful Functions more prominent in the Flink website. - posted by "Marta Paes Moreira (Jira)" <ji...@apache.org> on 2020/03/19 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16678) Hbase Connector Doc Error - posted by "sulei (Jira)" <ji...@apache.org> on 2020/03/19 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16679) Investigate more efficient outer join plans - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/03/19 10:12:00 UTC, 0 replies.
- Re: [VOTE] FLIP-102: Add More Metrics to TaskManager - posted by Yadong Xie <vt...@gmail.com> on 2020/03/19 10:37:39 UTC, 3 replies.
- [jira] [Created] (FLINK-16680) Add documentation for Stateful Function's State Bootstrapping API - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/19 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16681) Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if long time not records to write. - posted by "LakeShen (Jira)" <ji...@apache.org> on 2020/03/19 11:52:00 UTC, 0 replies.
- The question about the FLIP-45 - posted by LakeShen <sh...@gmail.com> on 2020/03/19 12:49:47 UTC, 1 replies.
- [jira] [Created] (FLINK-16682) Make batch size configurable for orc reader - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/19 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16683) Remove scripts for starting Flink on Windows - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/19 13:12:00 UTC, 0 replies.
- [DISCUSS] Introduce a new module 'flink-hadoop-utils' - posted by Sivaprasanna <si...@gmail.com> on 2020/03/19 13:14:41 UTC, 3 replies.
- [jira] [Created] (FLINK-16684) StreamingFileSink builder does not work with Scala - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/03/19 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16685) Add an example of how to deploy a multi-language function to Kubernetes. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/19 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/03/19 20:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16687) PyFlink Cannot determine simple type name "PythonScalarFunction$0" - posted by "mayne wong (Jira)" <ji...@apache.org> on 2020/03/20 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16688) Hive-connector should set SessionState for hive - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/20 04:36:00 UTC, 0 replies.
- [DISCUSS] Introduce TableFactory for StatefulSequenceSource - posted by Jingsong Li <ji...@gmail.com> on 2020/03/20 05:31:46 UTC, 9 replies.
- [jira] [Created] (FLINK-16689) kafka connector as source get byte deserialize add support charsets - posted by "xiaodao (Jira)" <ji...@apache.org> on 2020/03/20 05:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16690) Refactor StreamTaskTest to reuse TestTaskBuilder and MockStreamTaskBuilder - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/20 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16691) Adjust Python UDF document to remind users to install PyFlink on the cluster - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/03/20 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16692) flink joblistener can register from config - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/03/20 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16693) Legacy planner incompatible with Timestamp backed by LocalDateTime - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2020/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16694) Resuming Externalized Checkpoint end-to-end test failed on travis - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/03/20 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16696) Incomplete REST API docs - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16695) PrometheusReporterEndToEndITCase failed on travis - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16697) Disable JMX rebinding - posted by "Colm O hEigeartaigh (Jira)" <ji...@apache.org> on 2020/03/20 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16698) fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/03/20 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16699) Support accessing secured services via K8s secrets - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/20 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16700) Document Kinesis I/O Module - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/03/20 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16701) Elasticsearch sink support alias for indices. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/03/20 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16702) develop JDBCCatalogFactory for service discovery - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/20 23:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16703) AkkaRpcActor state machine does record transition to terminating state. - posted by "Dmitri Chmelev (Jira)" <ji...@apache.org> on 2020/03/21 01:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16704) Document has some error for connect.md - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/03/21 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16705) LocalExecutor tears down MiniCluster before client can retrieve JobResult - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2020/03/21 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16706) Update Stateful Functions master branch version to 2.0-SNAPSHOT - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/22 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16707) Fix potential memory leak of rest server when using session/standalone cluster for version 1.8 - posted by "jiangbo (Jira)" <ji...@apache.org> on 2020/03/22 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16708) When a JDBC connection has been closed, the retry policy of the JDBCUpsertOutputFormat cannot take effect and may result in data loss - posted by "tangshangwen (Jira)" <ji...@apache.org> on 2020/03/22 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16709) add a set command to set job name when submit job on sql client - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/03/22 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16710) Log Upload blocks Main Thread in TaskExecutor - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/03/22 12:23:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/12 - posted by Konstantin Knauf <ko...@ververica.com> on 2020/03/22 22:46:39 UTC, 0 replies.
- [jira] [Created] (FLINK-16711) ParquetColumnarRowSplitReader read footer from wrong end - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/23 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16712) Refactor StreamTask to construct final fields - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/23 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16713) Flink can not support the type of source table to query data from es - posted by "jackray wang (Jira)" <ji...@apache.org> on 2020/03/23 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16714) Kafka committedOffsets value <0 - posted by "pingle wang (Jira)" <ji...@apache.org> on 2020/03/23 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/23 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16716) Update Roadmap after Flink 1.10 release - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/03/23 08:41:00 UTC, 0 replies.
- [ANNOUNCE] Feature freeze for Apache Flink Stateful Functions 2.0.0 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/03/23 08:48:54 UTC, 0 replies.
- [jira] [Created] (FLINK-16717) Use headless service for rpc and blob port when flink on K8S - posted by "vanderliang (Jira)" <ji...@apache.org> on 2020/03/23 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16718) KvStateServerHandlerTest leaks Netty ByteBufs - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/03/23 09:17:01 UTC, 0 replies.
- [Dev Blog] Migrating Flink's CI Infrastructure from Travis CI to Azure Pipelines - posted by Robert Metzger <rm...@apache.org> on 2020/03/23 10:13:59 UTC, 3 replies.
- [jira] [Created] (FLINK-16719) flink-runtime-web install failure - posted by "jackray wang (Jira)" <ji...@apache.org> on 2020/03/23 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16720) Maven gets stuck downloading artifacts on Azure - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/23 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16721) getProcessCpuLoad seems to report a wrong cpu load - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2020/03/23 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16722) Add Python SDK walkthrough - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/23 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16723) Move Python SDK example out of statefun-python-sdk - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/23 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16724) ListSerializer cannot serialize list which containers null - posted by "Chongchen Chen (Jira)" <ji...@apache.org> on 2020/03/23 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16725) Support to parse various timestamp data format in JSON - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/23 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16726) ScalarFunction throws Given parameters of function 'func' do not match any signature. - posted by "Matrix42 (Jira)" <ji...@apache.org> on 2020/03/23 12:39:00 UTC, 0 replies.
- Re: TIME/TIMESTAMP parse in Flink TABLE/SQL API - posted by Jark Wu <im...@gmail.com> on 2020/03/23 12:44:17 UTC, 0 replies.
- [jira] [Created] (FLINK-16727) cannot cast 2020-11-12 as class java.time.LocalDate - posted by "Matrix42 (Jira)" <ji...@apache.org> on 2020/03/23 12:51:00 UTC, 0 replies.
- [DISCUSS] Switch to Azure Pipelines as the primary CI tool / switch off Travis - posted by Robert Metzger <rm...@apache.org> on 2020/03/23 13:48:10 UTC, 11 replies.
- [jira] [Created] (FLINK-16728) Taskmanager dies after job got stuck and canceling fails - posted by "Leonid Ilyevsky (Jira)" <ji...@apache.org> on 2020/03/23 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16729) Offer an out-of-the-box Set serializer - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/03/23 17:31:00 UTC, 0 replies.
- Dynamic Flink SQL - posted by Krzysztof Zarzycki <k....@gmail.com> on 2020/03/23 18:01:53 UTC, 4 replies.
- [jira] [Created] (FLINK-16730) Python SDK Getting Started - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/03/23 21:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16731) Support show partitions table command in sql client - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/03/24 01:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16732) Failed to call Hive UDF with constant return value - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/24 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16733) Refactor YarnClusterDescriptor - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/03/24 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16734) Remove ClusterSpecification - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/03/24 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16735) FlinkKafkaProducer should check that it is not null before sending a record - posted by "Shangwen Tang (Jira)" <ji...@apache.org> on 2020/03/24 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16736) Expose Elasticsearch sink metric - posted by "YangLee (Jira)" <ji...@apache.org> on 2020/03/24 04:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16737) Remove KubernetesUtils#getContentFromFile - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/24 04:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16738) Add convenience Kinesis generic egress record builder to the Python SDK - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/24 04:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16739) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails with no such key - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/24 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16740) OrcSplitReaderUtil::logicalTypeToOrcType fails to create decimal type with precision < 10 - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/24 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16741) add log list and read log by name for taskmanager in the web - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2020/03/24 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16742) Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/03/24 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16743) Introduce datagen, print, blackhole connectors - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/24 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16744) Implement API to persist channel state: checkpointing metadata - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/03/24 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16745) Use JobManagerProcessUtils to start JM container and pass JVM memory args - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/03/24 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16746) Deprecate/remove legacy memory options for JM and expose the new ones - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/03/24 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16747) Performance improvements for Python UDF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/24 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16748) Add Python UDTF doc - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/03/24 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16749) Support to set node selector for JM/TM pod - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/03/24 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16750) Kerberized YARN on Docker test fails with staring Hadoop cluster - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/24 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16751) Expose bind port for Flink metric query service - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/03/24 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16752) Ridesharing example doesn't start - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/24 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/03/24 16:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16754) Consider refactoring of ProcessMemoryUtilsTestBase to avoid inheritance - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/03/24 16:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16755) Savepoint docs should be updated - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/03/24 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16756) Move Bootstrap API example to statefun-examples/ - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/24 20:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16757) Refactor Helm charts - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/24 21:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16758) Port StateFun Documentation to Jekyll - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/03/24 23:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16759) HiveModuleTest failed to compile on release-1.10 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/25 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16760) Support the yaml file submission for native Kubernetes integration - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/03/25 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/25 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16762) Relocation Beam dependency of PyFlink - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/03/25 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16763) Should not use BatchTableEnvironment for Python UDF in the document of flink-1.10 - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/25 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16764) Kafka topic discovery - posted by "pine zhao (Jira)" <ji...@apache.org> on 2020/03/25 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16765) Replace all BatchTableEnvironment to StreamTableEnvironment in the document of PyFlink - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/25 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/25 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16767) Failed to read Hive table with RegexSerDe - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/25 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart runs without exit - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/25 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16769) Support new type inference for Table#flatMap - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/03/25 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/25 08:39:00 UTC, 0 replies.
- Re: Flink CEP greedy match of single pattern - posted by Dominik Wosiński <wo...@gmail.com> on 2020/03/25 09:03:44 UTC, 2 replies.
- [jira] [Created] (FLINK-16771) NPE when filtering by decimal column - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/25 09:56:00 UTC, 0 replies.
- [DISCUSS] FLIP-84 Feedback Summary - posted by godfrey he <go...@gmail.com> on 2020/03/25 10:17:33 UTC, 13 replies.
- [jira] [Created] (FLINK-16772) Bump derby to 10.12.1.1+ or exclude it - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/25 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16773) Flink 1.10 test execution is broken due to premature test cluster shutdown - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2020/03/25 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/03/25 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16775) expose FlinkKafkaConsumer/FlinkKafkaProducer Properties for other system - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/03/25 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16776) Support schema evolution for Hive parquet table - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/25 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16777) expose Pipeline in JobClient - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/03/25 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16778) the java e2e profile isn't setting the hadoop switch on Azure - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/25 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16779) Support RAW types through the stack - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/03/25 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16780) improve Flink lookup join - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/25 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16781) add built-in cache mechanism for LookupableTableSource in lookup join - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/25 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16782) Avoid unnecessary check on expired time state when we set visibility as ReturnExpiredIfNotCleanedUp - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/03/25 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16783) Add Polyglot Docker-compose example - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/25 21:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16784) Support KeyedBroadcastProcessFunction state bootstrapping. - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/03/25 21:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16785) Add a README to the Python SDK - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/25 22:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16786) Fix pyarrow version incompatible problem - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/26 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16787) Provide an assigner strategy of average splits allocation - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/26 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16788) ElasticSearch Connector SQL DDL add optional config (eg: enable-auth/username/password) - posted by "zhisheng (Jira)" <ji...@apache.org> on 2020/03/26 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16789) Support JMX RMI via JMXConnectorServer - posted by "Rong Rong (Jira)" <ji...@apache.org> on 2020/03/26 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16790) enables the interpretation of backslash escapes - posted by "yuwenbing (Jira)" <ji...@apache.org> on 2020/03/26 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16791) Could not deploy Yarn job cluster when using flink-s3-fs-hadoop-1.10.0.jar - posted by "yanxiaobin (Jira)" <ji...@apache.org> on 2020/03/26 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16792) flink-s3-fs-hadoop cannot access s3 - posted by "yanxiaobin (Jira)" <ji...@apache.org> on 2020/03/26 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16793) Add jobName to log4j ConversionPattern - posted by "jinhai (Jira)" <ji...@apache.org> on 2020/03/26 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16794) ClassNotFoundException caused by ClassLoader.getSystemClassLoader using impertinently - posted by "victor.jiang (Jira)" <ji...@apache.org> on 2020/03/26 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16795) End to end tests timeout on Azure - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/26 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16796) Fix The Bug of Python UDTF in SQL Query - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/03/26 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16798) Logs from BashJavaUtils are not properly preserved and passed into TM logs. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/03/26 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16797) Flink doesn't merge multiple sinks into one DAG - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2020/03/26 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16799) add hive partition limit when read from hive - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/03/26 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16800) TypeMappingUtils#checkPhysicalLogicalTypeCompatible didn't deal with nested types - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2020/03/26 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16801) PostgresCatalogITCase fails with IOException - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/26 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16802) Set schema info in JobConf for Hive readers - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/26 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16803) Need to make sure partition inherit table spec when writing to Hive tables - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/03/26 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16804) Deprecate String based Expression DSL in Table - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/03/26 09:14:00 UTC, 0 replies.
- [DISCUSS] FLIP-118: Improve Flink’s ID system - posted by Yangze Guo <ka...@gmail.com> on 2020/03/26 09:51:00 UTC, 8 replies.
- [jira] [Created] (FLINK-16805) StreamingKafkaITCase fails with "Could not instantiate instance using default factory." - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/26 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16806) Implement Input selection for MultipleInputStreamOperator - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/03/26 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16807) Improve reporting of errors during resource initialization - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/26 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16808) Consolidated logging in FactoryUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/26 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16809) Add Caller Context in Flink - posted by "zhuqi (Jira)" <ji...@apache.org> on 2020/03/26 12:39:00 UTC, 0 replies.
- [DISCUSS] Creating a new repo to host Stateful Functions Dockerfiles - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/03/26 15:15:24 UTC, 10 replies.
- [VOTE] Apache Flink Stateful Functions Release 2.0.0, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/03/26 16:48:17 UTC, 3 replies.
- [DISCUSS] FLIP-119: Pipelined Region Scheduling - posted by Gary Yao <ga...@apache.org> on 2020/03/26 17:38:23 UTC, 11 replies.
- [jira] [Created] (FLINK-16810) add back PostgresCatalogITCase - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/26 18:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16811) introduce JDBCRowConverter - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/26 20:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16812) introduce PostgresRowConverter - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/26 20:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16813) JDBCInputFormat doesn't correctly map Short - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/26 20:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16814) StringUtils.arrayToString() doesn't convert byte[] correctly - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/26 21:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16815) add e2e tests for reading from postgres with JDBCTableSource and PostgresCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/26 21:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16816) planner doesn't parse timestamp array correctly - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/26 22:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16817) StringUtils.arrayToString() doesn't convert byte[][] correctly - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/26 23:52:01 UTC, 0 replies.
- [jira] [Created] (FLINK-16818) Optimize data skew when flink write data to hive dynamic partition table - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/03/27 02:18:00 UTC, 0 replies.
- [VOTE] FLIP-115: Filesystem connector in Table - posted by Jingsong Li <ji...@gmail.com> on 2020/03/27 02:51:15 UTC, 6 replies.
- [jira] [Created] (FLINK-16819) Got KryoException while using UDAF in flink1.9 - posted by "Xingxing Di (Jira)" <ji...@apache.org> on 2020/03/27 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16820) support reading array of timestamp, data, and time in JDBCTableSource - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/03/27 04:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube" - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/27 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16822) The config set by SET command does not work - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/27 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16823) The functioin TIMESTAMPDIFF doesn't perform expected result - posted by "Adam N D DENG (Jira)" <ji...@apache.org> on 2020/03/27 05:57:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions Release 2.0.0, release candidate #2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/03/27 07:35:22 UTC, 5 replies.
- [jira] [Created] (FLINK-16824) Creating Temporal Table Function via DDL - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2020/03/27 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16825) PrometheusReporterEndToEndITCase should rely on path returned by DownloadCache - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/27 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16826) Support copying of jars - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/27 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16827) FLINK 1.9.1 KAFKA流数据按时间字段排序在多并发情况下抛出空指针异常 - posted by "wuchangjun (Jira)" <ji...@apache.org> on 2020/03/27 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16828) PrometheusReporters support factories - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/27 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16829) Pass PrometheusReporter arguments via constructor - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/27 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16830) Let users use Row/List/Map/Seq directly in Expression DSL - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/03/27 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16831) Support plugin directory as JarLocation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/27 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16832) Refactor ReporSetup - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/27 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16833) Make JDBCDialect pluggable for JDBC SQL connector - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/27 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16834) Examples cannot be run from IDE - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/03/27 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16835) Replace TableConfig with Configuration - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/03/27 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16836) Losing leadership does not clear rpc connection in JobManagerLeaderListener - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/03/27 16:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16837) Disable trimStackTrace in surefire plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/27 21:29:00 UTC, 0 replies.
- contribute to Apache Flink - posted by Leping Huang <hu...@gmail.com> on 2020/03/27 23:09:14 UTC, 1 replies.
- [jira] [Created] (FLINK-16838) Stateful Functions Quickstart archetype Dockerfile should reference a specific version tag - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/28 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16839) Connectors Kinesis metrics can be disabled - posted by "Muchl (Jira)" <ji...@apache.org> on 2020/03/28 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16840) PostgresCatalogTest fails waiting for server - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/28 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16841) Stateful Function artifacts jars should not bundle proto sources - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/28 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16842) Ridesharing example simulator built artifact is missing NOTICE / LICENSE for bundled dependencies - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/28 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16843) Python SDK distribution is missing LICENSE and NOTICE files - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/28 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16844) Support retract message for StreamExecGroupWindowAggregate in blink planner - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/03/28 10:32:00 UTC, 0 replies.
- Kafka - FLink - MongoDB using Scala - posted by Sivapragash Krishnan <si...@gmail.com> on 2020/03/28 12:45:09 UTC, 1 replies.
- [jira] [Created] (FLINK-16845) Implement SourceReaderOperator which runs the SourceReader. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/03/28 14:59:02 UTC, 0 replies.
- [jira] [Created] (FLINK-16846) Add docker images with python - posted by "Ismaël Mejía (Jira)" <ji...@apache.org> on 2020/03/28 20:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16847) Support timestamp types in vectorized Python UDF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/03/29 05:51:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions Release 2.0.0, release candidate #3 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/03/29 07:30:52 UTC, 8 replies.
- [jira] [Created] (FLINK-16848) Improve the performance of the RecordsWithSplitIds queue. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/03/29 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16849) comment is not reasonable - posted by "hufeihu (Jira)" <ji...@apache.org> on 2020/03/29 08:45:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/13 - posted by Konstantin Knauf <ko...@ververica.com> on 2020/03/29 13:02:43 UTC, 0 replies.
- [jira] [Created] (FLINK-16850) Make flink-benchmark align with different releases of Flink - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/03/29 16:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16851) Add common metrics to the SourceReader base implementation. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/03/30 00:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16852) Add metrics to the source coordinator. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/03/30 00:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16853) Update the version of protobuf-java from 3.8.0 to 3.7.1 in the NOTICE file of module statefun-flink-distribution - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/30 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16854) Correct dependency versions in the NOTICE file of module statefun-ridesharing-example-simulator - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/03/30 01:50:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions Release 2.0.0, release candidate #4 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/03/30 03:51:42 UTC, 17 replies.
- [jira] [Created] (FLINK-16855) Update K8s template for the standalone setup - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/03/30 04:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16856) taskmanager.sh is broken because of invalid arguments of head - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/03/30 05:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16857) Support partition prune for PartitionableTableSource with getPartitions - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/30 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16858) Expose partitioned by grammar - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/30 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16859) Introduce FileSystemTableFactory, FileSystemTableSource, FileSystemTableSink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/30 05:35:00 UTC, 0 replies.
- [DISCUSS] FLIP-122: New Connector Property Keys for New Factory - posted by Jark Wu <im...@gmail.com> on 2020/03/30 06:02:25 UTC, 22 replies.
- [VOTE] FLIP-95: New TableSource and TableSink interfaces - posted by Timo Walther <tw...@apache.org> on 2020/03/30 07:36:33 UTC, 5 replies.
- [jira] [Created] (FLINK-16860) TableException: Failed to push filter into table source! when upgrading flink to 1.9.2 - posted by "Nikola (Jira)" <ji...@apache.org> on 2020/03/30 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16861) Adding delegation token to the AM container Failed - posted by "Xianxun Ye (Jira)" <ji...@apache.org> on 2020/03/30 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16862) Use proper example url in quickstarts - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/30 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16863) add lastModified as a field of LogInfo - posted by "lining (Jira)" <ji...@apache.org> on 2020/03/30 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16864) Add idle metrics for Task - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/03/30 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16865) 【Flink Kafka Connector】Restore from Savepoint，if add new Kafka topic，Flink will consume the new topic from earlist，it may cause duplicate data sink - posted by "zhisheng (Jira)" <ji...@apache.org> on 2020/03/30 12:02:00 UTC, 0 replies.
- [ANNOUNCE] Flink on Zeppelin (Zeppelin 0.9 is released) - posted by Jeff Zhang <zj...@gmail.com> on 2020/03/30 12:47:03 UTC, 4 replies.
- [jira] [Created] (FLINK-16866) Make job submission non-blocking - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/03/30 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16867) Simplify default timeout configuration - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/03/30 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16868) Table/SQL doesn't support custom trigger - posted by "Jimmy Wong (Jira)" <ji...@apache.org> on 2020/03/30 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16869) Flink UI does not show version - posted by "Nikola (Jira)" <ji...@apache.org> on 2020/03/30 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16870) OrcTableSource throws NullPointerException - posted by "Nikola (Jira)" <ji...@apache.org> on 2020/03/30 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16871) Make more build information available during runtime. - posted by "Niels Basjes (Jira)" <ji...@apache.org> on 2020/03/30 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16872) Flink UI shows server error on selecting back pressure on a batch job - posted by "Nikola (Jira)" <ji...@apache.org> on 2020/03/30 16:02:00 UTC, 0 replies.
- codestyle issue - posted by flinker <fl...@126.com> on 2020/03/30 16:50:15 UTC, 2 replies.
- [VOTE] FLIP-114: Support Python UDF in SQL Client - posted by Wei Zhong <we...@gmail.com> on 2020/03/31 02:34:07 UTC, 0 replies.
- [jira] [Created] (FLINK-16873) Document the suggested memory size for statefun docker machine - posted by "Yu Li (Jira)" <ji...@apache.org> on 2020/03/31 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16874) Respect the dynamic options when calculating memory options in taskmanager.sh - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/03/31 03:39:00 UTC, 0 replies.
- [VOTE] FLIP-113: Supports Dynamic Table Options for Flink SQL - posted by Danny Chan <yu...@gmail.com> on 2020/03/31 03:48:53 UTC, 0 replies.
- [jira] [Created] (FLINK-16875) Tracking replace QueryConfig and TableConfig implementation with ConfigOption - posted by "jinhai (Jira)" <ji...@apache.org> on 2020/03/31 04:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16876) Make TtlTimeProvider configurable when creating keyed state backend - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/03/31 04:17:00 UTC, 0 replies.
- [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment & Table - posted by godfrey he <go...@gmail.com> on 2020/03/31 06:31:00 UTC, 2 replies.
- [jira] [Created] (FLINK-16877) SingleDirectoryWriter should not produce file when no input record - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/03/31 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16878) flink-table-planner contains unwanted dependency org.apiguardian.api - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/03/31 06:58:00 UTC, 0 replies.
- [VOTE] FLIP-110: Support LIKE clause in CREATE TABLE - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/03/31 07:33:17 UTC, 5 replies.
- [jira] [Created] (FLINK-16879) Disable the source-release-assembly execution goal when using the apache-release build profile - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/31 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16880) Adapt Dockerfiles from flink-statefun to be added to flink-statefun-docker - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/31 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16881) use Catalog's total size info in planner - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/03/31 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16882) NPE when reading hive table with RegexSerde - posted by "linweijiang (Jira)" <ji...@apache.org> on 2020/03/31 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16883) No support for log4j2 configuration formats besides properties - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2020/03/31 09:23:00 UTC, 0 replies.
- Question about the flink 1.6 memory config - posted by LakeShen <sh...@gmail.com> on 2020/03/31 09:34:01 UTC, 1 replies.
- [jira] [Created] (FLINK-16884) The "rest.port" configuration is always "0" with flink-yarn jobs - posted by "Victor Wong (Jira)" <ji...@apache.org> on 2020/03/31 10:16:00 UTC, 0 replies.
- [DISCUSS] FLIP-121: Support Cython Optimizing Python User Defined Function - posted by Xingbo Huang <hx...@gmail.com> on 2020/03/31 11:22:21 UTC, 0 replies.
- [jira] [Created] (FLINK-16885) SQL hive-connector wilcard excludes don't work on maven 3.1.X - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/03/31 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16886) Helm chart worker/master image name is using the wrong template value - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/31 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16887) Refactor retraction rules to support inferring ChangelogMode - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/31 15:24:00 UTC, 0 replies.
- [VOTE] FLIP-119: Pipelined Region Scheduling - posted by Gary Yao <ga...@apache.org> on 2020/03/31 15:52:24 UTC, 0 replies.
- [jira] [Created] (FLINK-16888) Re-add jquery license file under "/licenses" - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/31 16:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16889) Support converting BIGINT to TIMESTAMP for TO_TIMESTAMP function - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/03/31 17:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16890) Add AvroGeneric benchmark - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/03/31 18:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16891) Skip deployment of end-2-end test artifacts in StateFun - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/31 19:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16892) statefun-flink-distribution bundles many unwanted dependencies - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/31 19:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16893) Missing jquery license file in Stateful Functions - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/31 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16894) Add copyright holder to MIT license header for font-awesome - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/31 19:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16895) Remove outdated and defunct build_docs.bat - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/31 19:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16896) Remove unused components of docs system in StateFun - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/31 19:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16897) Consolidate docs image files in "fig" folder with license file - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/03/31 19:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16898) Helm chart worker deployment is using the wrong port for lives checks - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/31 19:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16899) Adjust module.yaml of python-k8s example to match python-worker-service - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/03/31 20:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16900) Exclude NOTCE and LICENSE files of Kafka dependencies for statefun-flink-distribution - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/31 22:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16901) Flink Kinesis connector NOTICE should have contents of AWS KPL's THIRD_PARTY_NOTICES file manually merged in - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/31 23:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16902) commons-codec dependency pulls in LICENSE.txt that should be excluded - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/03/31 23:59:00 UTC, 0 replies.