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

---

- [jira] [Created] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs/cache'" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/01 00:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19484) Kubernetes pyflink application test failed with "error executing jsonpath "{range .items[*]}{.metadata.name}{\"\\n\"}{end}": Error executing template: not in rang" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/01 00:28:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-144: Native Kubernetes HA for Flink - posted by Yang Wang <da...@gmail.com> on 2020/10/01 00:31:29 UTC, 2 replies.
- Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function - posted by Jark Wu <im...@gmail.com> on 2020/10/01 06:28:56 UTC, 25 replies.
- Re: Need help in creating Flink Streaming s3 Job for multiple path reader one by one - posted by Satyaa Dixit <sa...@gmail.com> on 2020/10/01 07:08:40 UTC, 17 replies.
- [jira] [Created] (FLINK-19485) Consider runtime-mode when creating the StreamGraph - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/01 07:31:00 UTC, 0 replies.
- Re: How to clean up resources in a UDF? - posted by Aljoscha Krettek <al...@apache.org> on 2020/10/01 09:55:13 UTC, 3 replies.
- Using Statefun with Confluent Kafka - posted by hezekiah maina <he...@gmail.com> on 2020/10/01 10:27:03 UTC, 1 replies.
- [jira] [Created] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/10/01 13:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19487) Checkpoint start delay is always zero for single channel tasks - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/10/01 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19488) Failed compilation of generated class - posted by "Satyam Shekhar (Jira)" <ji...@apache.org> on 2020/10/01 17:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19489) SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent gets stuck - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/02 00:52:00 UTC, 0 replies.
- [VOTE] FLIP-144: Native Kubernetes HA for Flink - posted by Yang Wang <da...@gmail.com> on 2020/10/02 01:11:39 UTC, 3 replies.
- [jira] [Created] (FLINK-19490) Document SOMAXCONN OS limit on blob server backlog - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/02 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19491) AvroSerializerSnapshot cannot handle large schema - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/10/02 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19492) Consolidate Source Events between Source API and Split Reader API - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/02 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19493) In CliFrontend, make flow of Configuration more obvious - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/10/02 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19494) Adjust "StreamExecutionEnvironment.generateSequence()" to new API Sources - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/02 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19495) Add documentation for avro-confluent format - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2020/10/02 16:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19496) DataGen source DECIMAL always returns null - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/10/02 18:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19497) Implement mutator methods for FlinkCounterWrapper - posted by "Richard Moorhead (Jira)" <ji...@apache.org> on 2020/10/02 20:27:00 UTC, 0 replies.
- Re: Dynamic Scaling: State Sharding - posted by Mazen Ezzeddine <ma...@etu.unice.fr> on 2020/10/03 09:33:28 UTC, 1 replies.
- Re: CheckpointedFunction initialization during checkpoint - posted by Yun Tang <my...@live.com> on 2020/10/03 10:34:01 UTC, 0 replies.
- Flink table error in 1.11 "Could not find a suitable table factory " - posted by Ravi Sankar Reddy Sangana <Ra...@radware.com> on 2020/10/03 10:58:19 UTC, 0 replies.
- [jira] [Created] (FLINK-19498) Port LocatableInputSplitAssigner to new File Source API - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/03 16:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19499) Expose Metric Groups to Split Assigners - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/03 17:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19500) Using canal-json,debezium-json,maxwell-json serialization, The DELETE semantics should be interpreted. - posted by "CaoZhen (Jira)" <ji...@apache.org> on 2020/10/04 09:04:00 UTC, 0 replies.
- [ANNOUNCE] New PMC member: Zhu Zhu - posted by Robert Metzger <rm...@apache.org> on 2020/10/05 05:32:25 UTC, 24 replies.
- [jira] [Created] (FLINK-19501) Missing state in enum type - posted by "goutham (Jira)" <ji...@apache.org> on 2020/10/05 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19502) Flink docker images: allow specifying arbitrary configuration values through environment - posted by "Julius Michaelis (Jira)" <ji...@apache.org> on 2020/10/05 07:58:00 UTC, 0 replies.
- Re: [VOTE] Release flink-shaded 12.0 - posted by Chesnay Schepler <ch...@apache.org> on 2020/10/05 08:33:13 UTC, 2 replies.
- [jira] [Created] (FLINK-19503) Add DSTL interface and its in-memory implementation for testing - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/10/05 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19504) Implement persistence for DSTL via DFS - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/10/05 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19505) Implement distributed DSTL (DFS-based) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/10/05 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19506) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnNonParallelLocalChannel: "Exceeded checkpoint tolerable failure threshold" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/05 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19507) Native support for Apache Pulsar - posted by "John Morrow (Jira)" <ji...@apache.org> on 2020/10/05 14:15:00 UTC, 0 replies.
- [RESULT][VOTE] Release flink-shaded 12.0 - posted by Robert Metzger <rm...@apache.org> on 2020/10/05 14:20:36 UTC, 0 replies.
- Re: [VOTE] FLIP-143: Unified Sink API - posted by Guowei Ma <gu...@gmail.com> on 2020/10/06 03:45:01 UTC, 0 replies.
- [jira] [Created] (FLINK-19508) Add collect() operation on DataStream - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/10/06 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19509) ClassCastException for MULTISET type of JsonRowDataDeserializationSchema and JsonRowDataSerializationSchema - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/06 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19510) Introduce new unified sink api - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/06 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19511) Rename the `SinkTransformation` to `LegacySinkTransformation` - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/06 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19512) Introduce the new sink api - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/06 08:44:00 UTC, 0 replies.
- [DISCUSS] Enforce common opinionated coding style using Spotless - posted by Aljoscha Krettek <al...@apache.org> on 2020/10/06 12:15:40 UTC, 10 replies.
- [jira] [Created] (FLINK-19513) Update docs/build_docs.sh to support the new parameters for regenerating the docs - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/06 12:56:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-shaded 12.0 released - posted by Robert Metzger <rm...@apache.org> on 2020/10/06 12:59:38 UTC, 1 replies.
- [jira] [Created] (FLINK-19514) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange times out - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/06 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19515) Async RequestReply handler concurrency bug - posted by "Frans King (Jira)" <ji...@apache.org> on 2020/10/06 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19516) PerJobMiniClusterFactoryTest. testJobClient() - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/06 17:21:00 UTC, 0 replies.
- IllegalStateException from incompatible state type - better exception type? - posted by "Kim, Hwanju" <hw...@amazon.com.INVALID> on 2020/10/06 22:27:16 UTC, 4 replies.
- [jira] [Created] (FLINK-19517) Support for Confluent Kafka on table creation - posted by "Kevin Kwon (Jira)" <ji...@apache.org> on 2020/10/07 02:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19518) Duration of running job is shown as 0 in web UI - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/07 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19519) Add support for port range in taskmanager.data.port - posted by "Truong Duc Kien (Jira)" <ji...@apache.org> on 2020/10/07 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19520) Add reliable test randomization for checkpointing - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/10/07 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19521) Support dynamic properties on DefaultCLI - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/10/07 11:07:00 UTC, 0 replies.
- Re: autoCommit for postgres jdbc streaming in Table/SQL API - posted by Dylan Forciea <dy...@oseberg.io> on 2020/10/07 13:52:33 UTC, 9 replies.
- [jira] [Created] (FLINK-19522) Add ability to set auto commit on jdbc driver from Table/SQL API - posted by "Dylan Forciea (Jira)" <ji...@apache.org> on 2020/10/07 16:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19523) Secrets should be filtered out from logs - posted by "Qinghui Xu (Jira)" <ji...@apache.org> on 2020/10/07 20:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19524) Google Season of Docs - FLIP 60 - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/10/07 20:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19525) Update Table API Overview page - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/10/07 20:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19527) Update SQL Pages - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/10/07 20:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19529) Table connectors docs - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/10/07 20:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19528) Setup and SQL execution - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/10/07 20:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19526) Update Table API specific section - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/10/07 20:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19530) Table Concepts Page - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/10/07 20:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19531) Implement the `WriterOperator` - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/08 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19532) FlinkZooKeeperQuorumPeer ignores purge settings - posted by "M L (Jira)" <ji...@apache.org> on 2020/10/08 05:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19533) Add state assignment to channel state during rescaling - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/10/08 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19534) build_wheels: linux failed with "ValueError: Incompatible component merge" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/08 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19535) SourceCoordinator should avoid fail job multiple times. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/10/08 07:57:00 UTC, 0 replies.
- flink 连hbase 报错 java.lang.NoSuchMethodError: org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest.newInstance - posted by 张立志 <zh...@163.com> on 2020/10/08 09:11:02 UTC, 1 replies.
- Wrapping a Flink Function - posted by Lorenzo Pirazzini <lo...@agilelab.it> on 2020/10/08 09:32:14 UTC, 2 replies.
- [jira] [Created] (FLINK-19536) Fix inconsistent priority notification - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/10/08 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19537) Processed in-flight bytes metric is not accurate - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/10/08 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19538) Support more complex routers in remote ingress definitions - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/10/08 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19539) JMXReporterFactoryTest fails on Azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/10/08 17:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19540) How to reduce or disable checkpoint logs in Flink - posted by "Xinhao Li (Jira)" <ji...@apache.org> on 2020/10/08 20:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19541) Improve hiveConfDir for HiveCatalog - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/09 02:49:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-144: Native Kubernetes HA for Flink - posted by Yang Wang <da...@gmail.com> on 2020/10/09 02:53:14 UTC, 0 replies.
- [jira] [Created] (FLINK-19542) Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/10/09 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19543) Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/10/09 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19544) Implement CheckpointRecoveryFactory based on Kubernetes API - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/10/09 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19545) Add e2e test for native Kubernetes HA - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/10/09 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19546) Add document for native Kubernetes HA - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/10/09 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19547) Partial record clean Up after receiver task fails and restart - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/10/09 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19548) Report correct progress to yarn resource manager - posted by "fa zheng (Jira)" <ji...@apache.org> on 2020/10/09 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19549) [CI] ##[error]The job running on agent Azure Pipelines 5 ran longer than the maximum time of 260 minutes. - posted by "Di Xu (Jira)" <ji...@apache.org> on 2020/10/09 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19550) StreamingFileSink can't be interrupted when writing to S3 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/10/09 06:07:00 UTC, 0 replies.
- [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2020/10/09 06:16:30 UTC, 7 replies.
- [jira] [Created] (FLINK-19551) Follow up improvements for shuffle service - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/10/09 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19552) JobManager dies with IllegalStateException SharedSlot (physical request SlotRequestId{%}) has been released - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/09 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19553) The format of checkpoint Completion Time and Failure Time is changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss - posted by "liufangliang (Jira)" <ji...@apache.org> on 2020/10/09 07:17:00 UTC, 0 replies.
- [DISCUSS] Add Translation Specification for Stateful Functions - posted by Congxian Qiu <qc...@gmail.com> on 2020/10/09 07:54:30 UTC, 4 replies.
- Re: [DISCUSS] FLIP-146: Improve new TableSource and TableSink interfaces - posted by Jingsong Li <ji...@gmail.com> on 2020/10/09 11:57:08 UTC, 3 replies.
- [jira] [Created] (FLINK-19554) Unified testing framework for connectors - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2020/10/09 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19555) Remove runAsyncWithoutFencing from MesosResourceManager - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/10/09 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19556) YarnResourceManagerDriver.getPendingRequestsAndCheckConsistency only returns container requests for first matching equivalent resource - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/10/09 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19557) Issue retrieving leader after zookeeper session reconnect - posted by "Max Mizikar (Jira)" <ji...@apache.org> on 2020/10/09 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19558) Umbrella Ticket for upgrading the REST API - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/09 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19559) Remove metrics from TaskManagerDetailsHandler - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/09 16:06:00 UTC, 0 replies.
- [Announce] Flink Forward Global Is Just Around the Corner - posted by Seth Wiesman <sj...@gmail.com> on 2020/10/09 16:30:22 UTC, 0 replies.
- [jira] [Created] (FLINK-19560) Translate "YARN Setup" of "Clusters & Depolyment" page into Chinese - posted by "onewayforlife (Jira)" <ji...@apache.org> on 2020/10/09 16:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19561) Corrected spelling errors in "Monitoring REST API" page of "Debugging & Monitoring" - posted by "weizheng (Jira)" <ji...@apache.org> on 2020/10/10 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19562) the /flink/docs/docker/run.sh cause an error with numeric username - posted by "Zhengchao Shi (Jira)" <ji...@apache.org> on 2020/10/10 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19563) database and table，two option can be combined into one - posted by "Zhengchao Shi (Jira)" <ji...@apache.org> on 2020/10/10 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19564) Parquet lack parquet-format-structures dependency - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/10 08:13:00 UTC, 0 replies.
- [VOTE] FLIP-145: Support SQL windowing table-valued function - posted by Jark Wu <im...@gmail.com> on 2020/10/10 10:06:07 UTC, 10 replies.
- [jira] [Created] (FLINK-19565) java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runtime.jobgraph.JobVertex - posted by "yardstrong (Jira)" <ji...@apache.org> on 2020/10/10 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19566) TableITCase.testCollectWithClose failed with "IllegalStateException: MiniCluster is not yet running or has already been shut down" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/11 04:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19567) JoinITCase.testInnerJoinOutputWithPk is unstable for POJO type inference - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/10/12 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19568) Offload creating TM launch contexts to the IO executor - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/10/12 06:40:00 UTC, 0 replies.
- [VOTE] Add Translation Specification for Stateful Functions - posted by Congxian Qiu <qc...@gmail.com> on 2020/10/12 06:41:14 UTC, 11 replies.
- [jira] [Created] (FLINK-19569) Upgrade ICU4J to 67.1+ - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/12 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/10/12 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19571) Port Transformation translation logic to StreamGraphTranslator framework - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/12 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19572) Create the TwoInputTransformation translator - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/12 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19573) Create the MultipleInputTransformation translator - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/12 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19574) Create the SourceTransformation translator - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/12 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19575) Create the LegacySourceTransformation translator - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/12 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19576) Create the SinkTransformation translator - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/12 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19578) Create the PartitionTransformation translator - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/12 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19577) Create the UnionTransformation translator - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/12 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19579) Create the SideOutputTransformation translator - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/12 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19580) Creating PackagedProgram overwrites an actual job name with default JobName - posted by "Murtaza H Zaveri (Jira)" <ji...@apache.org> on 2020/10/12 10:00:00 UTC, 0 replies.
- [DISCUSS]Why not emit messages to prevent too early state eviction in MiniBatchGroupAggFunction? - posted by Smile <LE...@163.com> on 2020/10/12 10:15:01 UTC, 2 replies.
- [jira] [Created] (FLINK-19581) Introduce OrcColumnarRowInputFormat - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/12 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19582) Introduce sort-merge based blocking shuffle to Flink - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/10/12 13:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19583) Expose the execution.runtime-mode to the users - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/12 14:01:00 UTC, 0 replies.
- [DISCUSS] Remove flink-connector-filesystem module. - posted by Kostas Kloudas <kk...@apache.org> on 2020/10/12 14:30:10 UTC, 24 replies.
- [jira] [Created] (FLINK-19584) HBaseSinkFunction no needs to create thread to flush when bufferFlushMaxMutations = 1 - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/12 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/12 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19586) Implement the stream committer operator - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/12 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19587) Error result when casting binary type as varchar - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/12 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19588) HBase zookeeper connection not released in hbase batch table source while flink job failover - posted by "zouyunhe (Jira)" <ji...@apache.org> on 2020/10/12 17:15:00 UTC, 0 replies.
- Re: [DISCUSS][Release 1.12] Stale blockers and build instabilities - posted by Robert Metzger <rm...@apache.org> on 2020/10/12 19:02:51 UTC, 1 replies.
- [jira] [Created] (FLINK-19589) Expose extra options in the S3 FileSystem - posted by "Padarn Wilson (Jira)" <ji...@apache.org> on 2020/10/13 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19590) flink-streaming-java module failed to compile - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/13 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19591) Missing @Internal annotation SimpleJdbcConnectionProvider - posted by "Kenzyme Le (Jira)" <ji...@apache.org> on 2020/10/13 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19592) MiniBatchGroupAggFunction should emit messages to prevent too early state eviction of downstream operators - posted by "Smile (Jira)" <ji...@apache.org> on 2020/10/13 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ? - posted by "Kenzyme Le (Jira)" <ji...@apache.org> on 2020/10/13 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19594) SubTasks start index don't unified and may confuse users - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2020/10/13 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19595) Flink SQL support S3 select - posted by "liuxiaolong (Jira)" <ji...@apache.org> on 2020/10/13 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19596) Do not recover CompletedCheckpointStore on each failover - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/10/13 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19597) Introduce SortBuffer and its implementation PartitionSortedBuffer for sort-merge based blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/10/13 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19598) E2E test Kerberized YARN application on Docker test (default input) fails on CI - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/10/13 06:00:19 UTC, 0 replies.
- [jira] [Created] (FLINK-19599) Introduce ParquetBulkFormatFactory to integrate new FileSource to table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/13 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19600) Introduce PartitionedFile and the corresponding writer/reader for sort-merge based blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/10/13 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19601) Introduce sort-merge based blocking result partition SortMergeResultPartition and the corresponding subpartition reader - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/10/13 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19602) Introduce new config options to enable sort-merge based blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/10/13 06:58:00 UTC, 0 replies.
- [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image - posted by Yun Tang <my...@LIVE.COM> on 2020/10/13 07:33:47 UTC, 14 replies.
- [jira] [Created] (FLINK-19603) Introduce shuffle data compression to sort-merge based blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/10/13 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19604) FLIP-145: Support SQL windowing table-valued function - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/13 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19605) Implement cumulative windowing for window aggregate operator - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/13 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19607) Implement streaming window TopN operator - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/13 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19606) Implement streaming window join operator - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/13 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19608) Support window TVF based window aggreagte in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/13 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19609) Support streaming window join in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/13 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19610) Support streaming window TopN in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/13 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19611) Introduce WindowProperties MetadataHandler to propagate window properties - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/13 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19612) Support CUMULATE window table function in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/13 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19613) Create flink-connector-files-test-utils for formats testing - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/13 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19614) Further optimization of sort-merge based blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/10/13 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19615) HBaseConnectorITCase.testTableSink is instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/13 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19616) Flink : Formats : Parquet compilation failure - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/10/13 10:27:00 UTC, 0 replies.
- [DISCUSS] Support Multiple Input for Blink Planner - posted by godfrey he <go...@gmail.com> on 2020/10/13 14:55:50 UTC, 0 replies.
- [jira] [Created] (FLINK-19617) Add Metaspace metric - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/13 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19618) Boken link in docs - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/13 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19619) Test failed in Azure For EmulatedPubSubSourceTest - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/14 00:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19620) Merge StateFun's ExactlyOnceE2E and RemoteModuleE2E - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/10/14 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19621) Introduce Multi-input operator in Blink planner - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/14 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19622) flinksql 1.11版本针对avro格式中Map类型value值的空指针异常 - posted by "宋洪亮 (Jira)" <ji...@apache.org> on 2020/10/14 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19623) Introduce ExecEdge to describe information on input edges for ExecNode - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/14 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19624) Update deadlock break-up algorithm to cover more cases - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/14 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19625) Introduce multi-input exec node - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/14 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19626) Introduce multi-input operator construction algorithm - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/14 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19627) Introduce multi-input operator for batch - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/14 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19628) Introduce multi-input operator for streaming - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/14 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19629) English words are spelled incorrectly and an example is not provided - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2020/10/14 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19630) Sink data in [ORC] format into Hive By using Legacy Table API caused unexpected Exception - posted by "Lsw_aka_laplace (Jira)" <ji...@apache.org> on 2020/10/14 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19631) Comments of DecodingFormatFactory is not clear - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/14 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19632) Introduce a new ResultPartitionType for Approximate Local Recovery - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/10/14 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19633) Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction - posted by "dalongliu (Jira)" <ji...@apache.org> on 2020/10/14 06:00:20 UTC, 0 replies.
- [jira] [Created] (FLINK-19634) Official Flink visualizer display bug - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/10/14 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/14 06:22:00 UTC, 0 replies.
- [DISCUSS] Support KeyedSortedMapState in DataStream API - posted by Sean Z <xi...@gmail.com> on 2020/10/14 07:30:43 UTC, 5 replies.
- [jira] [Created] (FLINK-19636) Add declarative SlotPool - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/14 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19637) Remove AllocationIdsExposingResourceManagerGateway - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/14 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19638) AvroUnionLogicalSerializerTest class compile error - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2020/10/14 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19639) Support SupportsNestedProjectionPushDown in planner - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/10/14 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19640) Expose to users the batch-style execution for bounded keyed streams - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/10/14 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19641) Optimize parallelism calculating of HiveTableSource by checking file number - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/14 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19642) RocksDBListStatePerformanceTest.testRocksDbListStateAPIs is instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/14 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19643) Add Pandas UDAF Doc - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/10/14 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19644) Support read specific partition of Hive table in temporal join - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/10/14 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/15 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19646) StreamExecutionEnvironment support new Source interface based on FLIP-27 - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2020/10/15 02:17:00 UTC, 0 replies.
- [DISCUSS] FLIP-148: Introduce Sort-Merge Based Blocking Shuffle to Flink - posted by Yingjie Cao <ke...@gmail.com> on 2020/10/15 03:02:56 UTC, 6 replies.
- [jira] [Created] (FLINK-19647) Support limit push down for hbase connector - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/10/15 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19648) Support nested projection push down for hbase connector - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/10/15 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19649) In Flink's module flink-sql-parser/sqlCreateTable/unparse, the tables without columns are not supported. - posted by "gsralex (Jira)" <ji...@apache.org> on 2020/10/15 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19650) Support the limit push down for the Jdbc connector - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/10/15 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19651) Support filter push down for the Jdbc connector - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/10/15 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19652) Support pure string format for Kafka table connector - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2020/10/15 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19653) HiveCatalogITCase fails on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/10/15 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19654) Improve the execution time of PyFlink end-to-end tests - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/15 05:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19655) NPE when using blink planner and TemporalTableFunction after setting IdleStateRetentionTime - posted by "seunjjs (Jira)" <ji...@apache.org> on 2020/10/15 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19656) Automatically replace delimiter in metric name components - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/15 11:52:00 UTC, 0 replies.
- [VOTE] FLIP-146: Improve new TableSource and TableSink interfaces - posted by Jingsong Li <ji...@gmail.com> on 2020/10/15 12:07:44 UTC, 8 replies.
- [jira] [Created] (FLINK-19657) YARNSessionCapacitySchedulerITCase.checkForProhibitedLogContents: netty failed with java.io.IOException: Broken pipe - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/15 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19658) Local recovery and sticky scheduling end-to-end test hangs with "Expected to find info here." - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/15 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/15 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19660) Translate page 'table_environment.zh.md' into Chinese - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/15 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19661) Implement changes required to resolve FLIP-104 - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/15 16:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19662) Create or extend REST endpoint to expose memory configuration - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/15 16:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19663) I would like to unsubscribe - posted by "Suryanarayana Murthy Maganti (Jira)" <ji...@apache.org> on 2020/10/15 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19664) Upload logs before end to end tests time out - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/15 18:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19665) AlternatingCheckpointBarrierHandlerTest.testMetricsAlternation - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/15 18:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19666) CLONE - [Kinesis][EFO] Add AWS SDK v2.x dependency and KinesisProxyV2 - posted by "Mohit Paliwal (Jira)" <ji...@apache.org> on 2020/10/15 20:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19667) Add integration with AWS Glue - posted by "Mohit Paliwal (Jira)" <ji...@apache.org> on 2020/10/15 20:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19668) Fix the plan regression by Calcite upgrade to 1.26 - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/10/16 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19669) PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2020/10/16 02:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19670) Create view error - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2020/10/16 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19671) Update EditorConfig file to be useful - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/10/16 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19672) Merge kafka-connector-base into flink-connector-kafka - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/10/16 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19673) Translate "Standalone Cluster" of "Clusters & Depolyment" page into Chinese - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2020/10/16 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19674) Translate "Docker" of "Clusters & Depolyment" page into Chinese - posted by "Shubin Ruan (Jira)" <ji...@apache.org> on 2020/10/16 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19675) The plan of is incorrect when Calc contains WHERE clause, composite fields access and Python UDF at the same time - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/16 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19676) java package name error in docs - posted by "leiqiang (Jira)" <ji...@apache.org> on 2020/10/16 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19677) TaskManager takes abnormally long time to register with JobManager on Kubernetes - posted by "Weike Dong (Jira)" <ji...@apache.org> on 2020/10/16 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19678) tableEnv.getConfig.setNullCheck(false) seems to break group by - posted by "Ion Alberdi (Jira)" <ji...@apache.org> on 2020/10/16 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19679) Deduplicate code between CheckpointBarrierUnaligner and CheckpointBarrierAligner - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/10/16 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19680) Add CheckpointBarrierAnnouncement priority message - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/10/16 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19681) Passively timeout alignment on the inputs - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/10/16 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19682) Actively timeout checkpoint barriers on the inputs - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/10/16 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19683) Actively timeout aligned checkpoints on the output - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/10/16 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19684) The Jdbc-connector's 'lookup.max-retries' option implementation is different from the meaning - posted by "CaoZhen (Jira)" <ji...@apache.org> on 2020/10/16 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19685) When use HBase-Connector lookupFunction, 8 hours less to query `DATE`,`TIME`,`TIMESTAMP` data - posted by "CaoZhen (Jira)" <ji...@apache.org> on 2020/10/16 15:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19686) Cast question for data | time - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/10/17 04:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19687) Support to get execution plan in `StatementSet` - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/10/17 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19688) Flink job gets into restart loop caused by InterruptedExceptions - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/17 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19689) TaskExecutorProcessSpecContainerResourcePriorityAdapterTest fails - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/17 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19690) ParquetStreamingFileSinkITCase.testWriteParquetAvroReflect failed with "expected:<1> but was:<2>" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/18 01:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/18 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19692) Can't restore feedback channel from savepoint - posted by "Antti Kaikkonen (Jira)" <ji...@apache.org> on 2020/10/18 05:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19693) Scheduler Change for Approximate Local Recovery - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/10/18 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19694) Support [UPDATE_AFTER, DELETE] ChangelogMode for ScanTableSource - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/18 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19695) Writing Table with RowTime Column of type TIMESTAMP(3) to Kafka fails with ClassCastException - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2020/10/18 16:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19696) Implement Batch committer for the new API - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/18 23:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19697) Make the streaming committer retry-able - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/18 23:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/10/19 01:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19699) PrometheusReporterEndToEndITCase crashes with exit code 143 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/19 01:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19700) Make Kubernetes Client in KubernetesResourceManagerDriver use io executor - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/10/19 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/10/19 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19702) Avoid using HiveConf::hiveSiteURL - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/10/19 03:50:00 UTC, 0 replies.
- 回复： [VOTE] FLIP-146: Improve new TableSource and TableSink interfaces - posted by 刘首维 <jo...@qq.com> on 2020/10/19 04:25:20 UTC, 0 replies.
- Re： [VOTE] FLIP-146: Improve new TableSource and TableSink interfaces - posted by 刘首维 <jo...@qq.com> on 2020/10/19 04:54:03 UTC, 0 replies.
- [jira] [Created] (FLINK-19703) A result partition is not untracked after its producer task failed in TaskManager - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/10/19 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19704) Flink checkpoint will fail when keytab dir meets a failure, and the flink should handle it. - posted by "zhuqi (Jira)" <ji...@apache.org> on 2020/10/19 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19705) Avro Confluent Schema Registry nightly end-to-end test: curl: (56) Recv failure: Connection reset by peer - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/19 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19706) Introduce `Repeated Partition Commit Check` in `org.apache.flink.table.filesystem.PartitionCommitPolicy` - posted by "Lsw_aka_laplace (Jira)" <ji...@apache.org> on 2020/10/19 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19707) Refactor table streaming file sink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/19 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19708) Support KeyedSortedMapState in DataStream API - posted by "Sean Z (Jira)" <ji...@apache.org> on 2020/10/19 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19709) Support KeyedSortedMapState in DataStream API - posted by "Sean Z (Jira)" <ji...@apache.org> on 2020/10/19 08:29:00 UTC, 0 replies.
- [DISCUSS] FLIP-149: Introduce the KTable Connector - posted by Shengkai Fang <fs...@gmail.com> on 2020/10/19 08:32:46 UTC, 28 replies.
- [DISCUSS] Release 1.12 Feature Freeze - posted by Robert Metzger <rm...@apache.org> on 2020/10/19 08:59:20 UTC, 13 replies.
- [REMINDER] Please only merge pull requests when CI is green and help keep our CI stable - posted by Robert Metzger <rm...@apache.org> on 2020/10/19 09:00:13 UTC, 3 replies.
- [jira] [Created] (FLINK-19710) Avoid performance regression introduced by thread-local keyword of FRocksDB - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/10/19 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19711) Parsing of invalid CSV fails even with ignoreParseErrors is enabled - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/10/19 10:52:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-135: Approximate Task-Local Recovery - posted by Piotr Nowojski <pn...@apache.org> on 2020/10/19 11:43:33 UTC, 0 replies.
- [jira] [Created] (FLINK-19712) Pipelined region failover should skip restarting tasks in CREATED - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/10/19 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19713) Update `JobGraphUtils` type to class - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/10/19 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19714) Assign different logical pipelined regions of a DataSet job to different slot sharing group - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/10/19 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19715) Optimize re-assignment of excess resources - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/19 12:51:00 UTC, 0 replies.
- [VOTE] FLIP-135: Approximate Task-Local Recovery - posted by Yuan Mei <yu...@gmail.com> on 2020/10/19 12:56:04 UTC, 7 replies.
- [jira] [Created] (FLINK-19716) [Kinesis][EFO] Unable to use Assume Role with EFO record publisher - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/10/19 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2020/10/19 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19718) HiveTableSourceITCase.testStreamPartitionRead is not stable on Azure - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/20 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19719) FLIP-146: Improve new TableSource and TableSink interfaces - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/20 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19720) Introduce DataStream and Source Providers - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/20 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19721) Speed up the frequency of checks in RpcGatewayRetriever - posted by "Dan Hill (Jira)" <ji...@apache.org> on 2020/10/20 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source) - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/20 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19723) The retry mechanism of jdbc connector has the risk of data duplication - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2020/10/20 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19724) tableEnv.toRetractStream(table, PoJo.class) when - posted by "HunterHunter (Jira)" <ji...@apache.org> on 2020/10/20 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19725) DataStreamTests.test_key_by_on_connect_stream is failed on Azure - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/20 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19726) Implement new providers for blink planner - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/20 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19727) Implement ParallelismProvider for sink in blink planner - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/20 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/20 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19729) Create the FeedbackTransformation translator - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/20 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19730) Create the CoFeedbackTransformation translator - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/20 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19731) 使用了批量执行SQL的api，job执行的时候，DataStream 不触发 - posted by "little-tomato (Jira)" <ji...@apache.org> on 2020/10/20 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19732) Disable Checkpointing when in BATCH mode - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/20 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19733) Make fast_operation and slow_operation produce functions consistent - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/10/20 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19734) Add scan-only TableSoure tests - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/10/20 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19735) TableFunction can not work in Flink View - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2020/10/20 11:14:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-130: Support for Python DataStream API (Stateless Part) - posted by blackjjcat <bl...@163.com> on 2020/10/20 11:34:40 UTC, 1 replies.
- [jira] [Created] (FLINK-19736) Implement the `SinkTransformation` - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/20 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19737) Introduce TableOperatorWrapperGenerator to translate transformation DAG in a multiple-input node to TableOperatorWrapper DAG - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/10/20 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19738) Remove the `getCommitter` from the `AbstractStreamingCommitterOperator` - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/20 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19739) CompileException when windowing in batch mode: A method named "replace" is not declared in any enclosing class nor any supertype - posted by "Alex Hall (Jira)" <ji...@apache.org> on 2020/10/20 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19740) Error in to_pandas for table containing event time: class java.time.LocalDateTime cannot be cast to class java.sql.Timestamp - posted by "Alex Hall (Jira)" <ji...@apache.org> on 2020/10/20 15:52:01 UTC, 0 replies.
- [jira] [Created] (FLINK-19741) InternalTimeServiceManager fails to restore if there are other users of raw keyed state streams - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/10/20 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19742) Invalid command in flink-end-to-end-tests README - posted by "Dan Hill (Jira)" <ji...@apache.org> on 2020/10/20 17:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19743) Add metrics definitions. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/10/21 01:12:00 UTC, 0 replies.
- [DISCUSS] Flink Nebula Connector - posted by Darion Yaphet <da...@gmail.com> on 2020/10/21 02:53:31 UTC, 1 replies.
- [jira] [Created] (FLINK-19744) Support Nebula Graph Connector - posted by "darion yaphet (Jira)" <ji...@apache.org> on 2020/10/21 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19745) Supplement micro-benchmark for bounded blocking partition in remote channel case - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/10/21 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19746) Why delete for - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/10/21 04:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19747) Move Predicate classes to OrcFilters - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/21 06:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19748) StateFun's UnboundedFeedbackLogger should call startNewKeyGroup for all assigned key groups - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/10/21 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19749) document error - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/10/21 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19750) Deserializer is not opened in Kafka consumer when restoring from state - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2020/10/21 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19751) document error for GroupBy Window Aggregation - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/10/21 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19752) Convert BigDicimal TypeInformation to DataTypes error - posted by "AT-Fieldless (Jira)" <ji...@apache.org> on 2020/10/21 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19753) Introduce 'STRCMP' function to compare between two string fields - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/21 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19754) Cannot have more than one execute() or executeAsync() call in a single environment. - posted by "little-tomato (Jira)" <ji...@apache.org> on 2020/10/22 00:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19755) flink cep - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/10/22 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19756) Use multi-input optimization by default - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/22 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19757) TimeStampData can cause time inconsistent problem - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2020/10/22 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19758) Implement a new unified File Sink based on the new Sink API - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/10/22 05:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19759) DeadlockBreakupTest.testSubplanReuse_AddSingletonExchange is instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/22 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19760) Make the `GlobalCommitter` a standalone interface that does not extend the `Committer` - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/22 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19761) Add lookup method for registered ShuffleDescriptor in ShuffleMaster - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2020/10/22 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19762) Selecting Job-ID in web UI covers more than the ID - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/22 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19763) Missing test MetricUtilsTest.testNonHeapMetricUsageNotStatic - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/22 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19764) Add More Metrics to TaskManager in Web UI - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2020/10/22 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19765) flink SqlUseCatalog.getCatalogName is not unified with SqlCreateCatalog and SqlDropCatalog - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/10/22 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19766) Introduce File streaming compaction operators - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/22 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19767) Add AbstractSlotPoolFactory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/22 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties - posted by "YUJIANBO (Jira)" <ji...@apache.org> on 2020/10/22 09:19:00 UTC, 0 replies.
- Re: [VOTE] FLIP-102: Add More Metrics to TaskManager - posted by Yadong Xie <vt...@gmail.com> on 2020/10/22 09:36:11 UTC, 0 replies.
- [VOTE] NEW FLIP-102: Add More Metrics to TaskManager - posted by Yadong Xie <vt...@gmail.com> on 2020/10/22 09:53:16 UTC, 6 replies.
- [jira] [Created] (FLINK-19769) Reuse StreamRecord in SourceOutputWithWatermarks#collect - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/22 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19770) mvn clean verify - testConfigurePythonExecution failing - posted by "Juha Mynttinen (Jira)" <ji...@apache.org> on 2020/10/22 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19771) NullPointerException when accessing null array from postgres in JDBC Connector - posted by "Dylan Forciea (Jira)" <ji...@apache.org> on 2020/10/22 13:53:00 UTC, 0 replies.
- Re: NullPointerException when trying to read null array in Postgres using JDBC Connector - posted by Dylan Forciea <dy...@oseberg.io> on 2020/10/22 13:58:38 UTC, 1 replies.
- [jira] [Created] (FLINK-19772) Add utility for retrying sync operations with exponential timeout - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/22 14:55:00 UTC, 0 replies.
- Re: Un-ignored Parsing Exceptions in the CsvFormat - posted by Austin Cawley-Edwards <au...@gmail.com> on 2020/10/22 15:08:34 UTC, 1 replies.
- [jira] [Created] (FLINK-19773) Exponential backoff restart strategy - posted by "Levi Ramsey (Jira)" <ji...@apache.org> on 2020/10/22 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19774) Introduce sub partition view version for approximate Failover - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/10/22 16:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19775) SystemProcessingTimeServiceTest.testImmediateShutdown is instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/23 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19776) cancel with savePoint throw Unrecognized field "status" - posted by "tonychan (Jira)" <ji...@apache.org> on 2020/10/23 02:58:00 UTC, 0 replies.
- Resuming Savepoint issue with upgraded Flink version 1.11.2 - posted by Partha Mishra <pa...@man-es.com> on 2020/10/23 05:19:59 UTC, 1 replies.
- [jira] [Created] (FLINK-19777) java.lang.NullPointerException - posted by "frank wang (Jira)" <ji...@apache.org> on 2020/10/23 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19778) Failed job reinitiated with wrong checkpoint after a ZK reconnection - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2020/10/23 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/10/23 07:05:00 UTC, 0 replies.
- [VOTE]FLIP-149: Introduce the upsert-kafka connector - posted by Shengkai Fang <fs...@gmail.com> on 2020/10/23 07:25:06 UTC, 6 replies.
- [jira] [Created] (FLINK-19780) FlinkRelMdDistinctRowCount#getDistinctRowCount(Calc) will always return 0 when number of rows are large - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/23 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19781) Upgrade commons_codec to 1.13 or newer - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/10/23 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19782) Upgrade antlr to 4.7.1 or newer - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/10/23 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19783) Upgrade mesos to 1.7 or newer - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/10/23 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19784) Upgrade okhttp to 3.13.0 or newer - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/10/23 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19785) Upgrade commons-io to 2.7 or newer - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/10/23 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19786) Flink doesn't set proper nullability for Logical types for Confluent Avro Serialization - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2020/10/23 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19787) Migrate Filesystem source to new table source sink interface - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/23 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19788) Flaky test ShuffleCompressionITCase.testDataCompressionForBlockingShuffle? - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/23 10:32:00 UTC, 0 replies.
- [SURVEY] Remove Mesos support - posted by Robert Metzger <rm...@apache.org> on 2020/10/23 11:42:19 UTC, 11 replies.
- [jira] [Created] (FLINK-19789) Migrate Hive connector to new table source sink interface - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/23 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19790) Writing MAP to Kafka with JSON format produces incorrect data. - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/10/23 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19791) PartitionRequestClientFactoryTest.testInterruptsNotCached fails with NullPointerException - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/23 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19792) Interval join with equal time attributes is not recognized - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/10/23 14:57:00 UTC, 0 replies.
- [DISCUSS] Releasing Apache Flink 1.11.3 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/10/23 15:01:28 UTC, 12 replies.
- [jira] [Created] (FLINK-19793) KafkaTableITCase.testKafkaSourceSinkWithMetadata fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/10/23 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19794) who wrote the the documents? - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/10/24 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19795) When TOPN handles duplicate data, it will throw an exception - posted by "jinxin (Jira)" <ji...@apache.org> on 2020/10/25 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19796) Error results when use constant decimal array - posted by "Zou (Jira)" <ji...@apache.org> on 2020/10/25 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19797) NPE when we use decimal array as input of UDAF - posted by "Zou (Jira)" <ji...@apache.org> on 2020/10/25 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19798) Support creating hive table input splits in parallel - posted by "Zou (Jira)" <ji...@apache.org> on 2020/10/25 10:00:05 UTC, 0 replies.
- [jira] [Created] (FLINK-19799) Make FileSource extensible - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/25 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19800) Make FileSourceSplit / FileSourceSplitState interaction extensible. - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/25 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19801) Add support for virtual channels - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/10/25 18:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19802) Let BulkFormat createReader and restoreReader methods accept Splits directly - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/25 22:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19803) Make File Source Checkpoint Serializer extensible - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/25 22:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19804) Make FileSource class generic with respect to split types - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/10/25 22:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19805) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster is instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/26 01:41:00 UTC, 0 replies.
- [VOTE] FLIP-148: Introduce Sort-Merge Based Blocking Shuffle to Flink - posted by Yingjie Cao <ke...@gmail.com> on 2020/10/26 03:19:25 UTC, 4 replies.
- [jira] [Created] (FLINK-19806) Job may try to leave SUSPENDED state in ExecutionGraph#failJob() - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/10/26 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19807) Add documentation for Flink's "pre-flight phase" and "cluster phase" - posted by "Manas Kale (Jira)" <ji...@apache.org> on 2020/10/26 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19808) Translate "Hive Read & Write" page of "Hive Integration" into Chinese - posted by "jiawen xiao (Jira)" <ji...@apache.org> on 2020/10/26 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19809) Add ServiceConnectionManager - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/26 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19810) Automatically run a basic NOTICE file check on CI - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/26 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19811) FlinkRexUtil#simplify should simplify search in conjunctions - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/26 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19812) Add More Metrics to Jobmanager UI - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2020/10/26 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19813) Translate "index SQL Connector" page into Chinese - posted by "jiawen xiao (Jira)" <ji...@apache.org> on 2020/10/26 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19814) Disable FeedbackTransformation for BATCH mode - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/26 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19815) Disable CoFeedbackTransformation for BATCH mode - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/10/26 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one) - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2020/10/27 01:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19817) Is FileSystem source unsupported? - posted by "CloseRiver (Jira)" <ji...@apache.org> on 2020/10/27 03:07:00 UTC, 0 replies.
- Re: [DISCUSS] Disable "Squash and merge" button for Flink repository on GitHub - posted by Yun Tang <my...@live.com> on 2020/10/27 03:18:29 UTC, 0 replies.
- [jira] [Created] (FLINK-19818) ArrayIndexOutOfBoundsException occus in 'Interval Joins' when the source table have nest json - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2020/10/27 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19819) SourceReaderBase supports limit push down - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/27 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19820) TableEnvironment init fails with JDK9 - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/10/27 05:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19821) Add ProcessFunction and timer access for Python DataStream API. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/10/27 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19822) remove redundant shuffle for stream - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/10/27 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19823) Integrate Filesystem and Hive connector with changelog format (e.g. debezium-json) - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/27 07:51:00 UTC, 0 replies.
- Re: [VOTE] FLIP-104: Add More Metrics to Jobmanager - posted by Yadong Xie <vt...@gmail.com> on 2020/10/27 07:59:10 UTC, 0 replies.
- [VOTE] NEW FLIP-104: Add More Metrics to JobManager - posted by Yadong Xie <vt...@gmail.com> on 2020/10/27 08:02:28 UTC, 6 replies.
- [jira] [Created] (FLINK-19824) Refactor and merge SupportsComputedColumnPushDown and SupportsWatermarkPushDown interfaces - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/27 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19825) scala package class case class on flink sql - posted by "Yanzhao Deng (Jira)" <ji...@apache.org> on 2020/10/27 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19826) StateFun Dockerfile copies plugins with a specific version instead of a wildcard - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/10/27 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19827) Allow the harness to start a MiniCluster with a user provided Flink configuration - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/10/27 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19828) Allow loading multiple configuration files - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/27 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19829) should enclose column name in double quotes for PostgreSQL - posted by "zl (Jira)" <ji...@apache.org> on 2020/10/27 11:22:00 UTC, 0 replies.
- Re: [BULK]Re: [SURVEY] Remove Mesos support - posted by Oleksandr Nitavskyi <o....@criteo.com> on 2020/10/27 11:28:49 UTC, 1 replies.
- [jira] [Created] (FLINK-19830) Properly implements processing-time temporal table join - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/10/27 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19831) Support grace period for not enough resources being available at cluster startup - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/27 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19832) Improve handling of immediately failed physical slot in SlotSharingExecutionSlotAllocator - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/10/27 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19833) Rename Sink API Writer interface to SinkWriter - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/10/27 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19834) Make the TestSink reusable in all the sink related tests. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/27 13:30:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/39-43 - posted by Konstantin Knauf <kn...@apache.org> on 2020/10/27 13:31:21 UTC, 0 replies.
- [jira] [Created] (FLINK-19835) Don't emit intermediate watermarks in BATCH execution mode - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/10/27 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19836) Serialize the committable by the serializer provided by the user during network shuffle - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/27 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19837) Don't emit intermediate watermarks watermark operators in BATCH execution mode - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/10/27 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19838) SQLClientKafkaITCase times out - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/27 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19839) e2e test failures are not causing the build to fail - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/27 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19840) Add a rocksdb and heap timers configuration validation - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/10/27 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19841) Rename GlobalStreamingCommitterOperator to StreamingGlobalCommitterOperator - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/10/27 16:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19842) PyFlinkStreamUserDefinedTableFunctionTests.test_table_function_with_sql_query is unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/27 18:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/28 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19844) Add documentation for Python UDAF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/28 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19845) Migrate all FileSystemFormatFactory implementations - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/28 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19846) Grammar mistakes in annotations and log - posted by "zhouchao (Jira)" <ji...@apache.org> on 2020/10/28 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19847) Can we create a fast support on the Nested table join? - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2020/10/28 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19848) flink docs of Building Flink from Source bug - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/10/28 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19849) Check NOTICE files for 1.12 release - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/28 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19850) Add E2E tests for the new streaming case of the new FileSink - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/10/28 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19851) flink sql client connector type jdbc exception - posted by "hulingchan (Jira)" <ji...@apache.org> on 2020/10/28 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19852) Managed memory released check can block IterativeTask - posted by "shaomeng.wang (Jira)" <ji...@apache.org> on 2020/10/28 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19853) BulkSlotProviderImplTest.testFailedBulkSlotAllocationReleasesAllocatedSlot failed in azure - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/28 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19854) TableScanTest.testTemporalJoinOnUpsertSource fails - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/10/28 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19855) Incompatible semantics of channelIndex in UnionInputGate.resumeConsumption and its clients - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/10/28 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19856) Add EndOfChannelRecovery rescaling epoch - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/10/28 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19857) FLIP-149: Introduce the upsert-kafka Connector - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/28 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19858) Add the new table factory for upsert-kafka connector - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/28 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19859) Add documentation for the upsert-kafka connector - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/28 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19860) Consider skipping restart and traverse regions which are already being restarted in RestartPipelinedRegionFailoverStrategy - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/10/28 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19861) Improve the document of now() function - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/28 17:05:00 UTC, 0 replies.
- Is there any way to change operator level parallelism dynamically? - posted by DEEP NARAYAN Singh <ab...@gmail.com> on 2020/10/28 18:04:50 UTC, 2 replies.
- [DISCUSS] 1.12 feature freeze date += one week ? - posted by Stephan Ewen <se...@apache.org> on 2020/10/28 18:12:48 UTC, 8 replies.
- [jira] [Created] (FLINK-19862) DeclarativeSlotManager#suspend can fail with NPE - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/28 18:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/29 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/29 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}"" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/10/29 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19866) FunctionsStateBootstrapOperator.createStateAccessor fails due to uninitialized runtimeContext - posted by "wang (Jira)" <ji...@apache.org> on 2020/10/29 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19867) Validation fails for UDF that accepts var-args - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/10/29 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19868) Csv Serialization schema contains line delimiter - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/29 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19869) Support java.util.UUID as RAW type in PostgresCatalog and handle it in PostgresRowConverter - posted by "Jingwei Zhang (Jira)" <ji...@apache.org> on 2020/10/29 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19870) Fix special case when the reuse of exchange causes the deadlock - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/29 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19871) add hash(primary key） to kafka partition sink mapping - posted by "底限 (Jira)" <ji...@apache.org> on 2020/10/29 06:22:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Congxian Qiu - posted by Yu Li <ca...@gmail.com> on 2020/10/29 06:28:19 UTC, 22 replies.
- [jira] [Created] (FLINK-19872) Support to parse millisecond for TIME type in CSV format - posted by "Fangliang Liu (Jira)" <ji...@apache.org> on 2020/10/29 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19873) Skip DDL change events for Canal data - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/29 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19874) Apply JoinDeriveNullFilterRule after join reorder - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/29 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19875) Integrate file compaction to connectors - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/29 07:50:00 UTC, 0 replies.
- [VOTE] Remove flink-connector-filesystem module. - posted by Kostas Kloudas <kk...@apache.org> on 2020/10/29 08:18:12 UTC, 7 replies.
- [jira] [Created] (FLINK-19876) Latency metrics can merge chain task latency metrics to reduce the number of latency metrics - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2020/10/29 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19877) AlterDatabaseOperation is missing ignoreIfNotExists - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2020/10/29 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19878) Improve watermark ChangelogNormalize for upsertSource - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/10/29 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19879) Support "IF NOT EXISTS" in DDL for CREATE TABLE - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2020/10/29 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19880) flink-json The validation and incoming parameters do not match - posted by "MingZhangOk (Jira)" <ji...@apache.org> on 2020/10/29 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka) - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/10/29 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19882) E2E: SQLClientHBaseITCase crash - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/29 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19883) Support "IF EXISTS" in DDL for ALTER TABLE - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2020/10/29 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19884) Add benchmarks for batch-style execution for bounded keyed streams - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/10/29 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19885) Extend the JobManager's web UI in accordance to FLIP-104 - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/29 13:07:00 UTC, 0 replies.
- 回复: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image - posted by 王刚 <wa...@autohome.com.cn> on 2020/10/29 16:37:55 UTC, 0 replies.
- Question about processing a 3-level List data type in parquet - posted by Naehee Kim <ty...@gmail.com> on 2020/10/29 23:38:42 UTC, 0 replies.
- [jira] [Created] (FLINK-19886) Integrate file compaction to Hive connector - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/30 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19887) flink-1.11.2 - 使用包对象下的样例类，会导致table api程序编译失败 - posted by "谢波 (Jira)" <ji...@apache.org> on 2020/10/30 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19888) Migrate Hive source to FLIP-27 source interface for streaming - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/10/30 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19889) Supports nested projection pushdown for filesystem connector of columnar format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/10/30 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19890) Introduce LimitableBulkFormat to wrap BulkFormat when limit pushed down - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/10/30 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19891) ScalarOperatorGens should generate a not-null type for IS NULL and IS NOT NULL - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/10/30 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19892) Replace __metaclass__ field with metaclass keyword - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/10/30 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19893) stop consuming in specific offset or timestamp - posted by "zoucao (Jira)" <ji...@apache.org> on 2020/10/30 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19894) Use iloc for positional slicing instead of direct slicing in from_pandas - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/10/30 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19895) Unify life cycle management of ResultPartitionType Pipelined Family - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/10/30 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19896) Support first-n-rows deduplication in the Deduplicate operator - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/10/30 09:00:22 UTC, 0 replies.
- [jira] [Created] (FLINK-19897) Improve UI related to FLIP-102 - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/30 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19898) [Kinesis][EFO] Ignore ReadTimeoutException from SubcribeToShard retry policy - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/10/30 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19899) [Kinesis][EFO] Optimise error handling to use a separate exception delivery mechanism - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/10/30 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19900) Wrong property name for surefire log4j configuration - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/10/30 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19901) Unable to exclude metrics variables for the last metrics reporter. - posted by "Truong Duc Kien (Jira)" <ji...@apache.org> on 2020/10/30 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19902) Adjust JobMasterTest to be compatible - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/10/30 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19903) Implement equivalent of Spark's f.input_file_name() - posted by "Ruben Laguna (Jira)" <ji...@apache.org> on 2020/10/30 13:01:00 UTC, 0 replies.
- grant me the permission as a contributor - posted by longlai li <lo...@gmail.com> on 2020/10/30 14:09:12 UTC, 1 replies.
- [jira] [Created] (FLINK-19904) Update documentation to address difference between -Xmx and the metric for maximum heap - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/10/30 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction - posted by "dalongliu (Jira)" <ji...@apache.org> on 2020/10/31 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19906) Incorrect result when compare two binary field - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/10/31 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19907) Channel state (upstream) can be restored after emission of new elements (watermarks) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/10/31 16:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19908) FlinkLogicalTableSourceScan and CommonPhysicalTableSourceScan should respect source reuse config option - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/10/31 21:28:00 UTC, 0 replies.