dev@flink.apache.org, 2020-07

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

- Re: [VOTE] Release 1.11.0, release candidate #4 - posted by Thomas Weise <th...@apache.org> on 2020/07/01 05:01:14 UTC, 39 replies.
- Re: [DISCUSS] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/07/01 08:35:50 UTC, 2 replies.
- Re: Flink JDK compatibility problem. - posted by Niels Basjes <Ni...@basjes.nl> on 2020/07/01 08:50:01 UTC, 3 replies.
- Extend the Table API & SQL Documentation - posted by Ayeshmantha Perera <ak...@gmail.com> on 2020/07/01 09:54:08 UTC, 1 replies.
- [jira] [Created] (FLINK-18457) Fix invalid links in "Detecting Patterns" page of "Streaming Concepts" - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/07/01 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18458) Setting the property java.version makes the build brittle and harder to debug. - posted by "Niels Basjes (Jira)" <ji...@apache.org> on 2020/07/01 12:03:00 UTC, 0 replies.
- [VOTE] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers - posted by "Cranmer, Danny" <cr...@amazon.com.INVALID> on 2020/07/01 12:56:38 UTC, 5 replies.
- [jira] [Created] (FLINK-18459) ClassNotFoundException in ProcessFunction property object's callback and promise - posted by "Xinhao Li (Jira)" <ji...@apache.org> on 2020/07/01 23:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18460) If the Python UDFs are called before calling the Python Dependency Management API, the Python Dependency Management would not will not take effect. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/07/02 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18461) Changelog source can't be insert into upsert sink - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/02 03:37:00 UTC, 0 replies.
- Re: [DISCUSS] Sql-client lack support for new features - posted by Kurt Young <yk...@gmail.com> on 2020/07/02 04:30:25 UTC, 2 replies.
- [jira] [Created] (FLINK-18462) Improve the exception message when INSERT INTO mismatch types for empty char - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/02 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18463) Make the "input_types" parameter of the Python udf decorator optional - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/07/02 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/07/02 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18465) Support to integrate FLIP-24 source interface with Table API - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/02 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18466) JDBC should fail-fast if the target table doesn't exist - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/02 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18467) Document what can be reconfigured for state with TTL between job restarts - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/07/02 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18468) TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermination fails with - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/07/02 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18469) Add Application Mode to release notes. - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/07/02 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18470) Tests RocksKeyGroupsRocksSingleStateIteratorTest#testMergeIteratorByte & RocksKeyGroupsRocksSingleStateIteratorTest#testMergeIteratorShort fail locally - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/07/02 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18471) flink-runtime lists "org.uncommons.maths:uncommons-maths:1.2.2a" as a bundled dependency, but it isn't - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/07/02 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18472) Local Installation Getting Started Guide - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/07/02 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18473) Optimize RocksDB disk load balancing strategy - posted by "fanrui (Jira)" <ji...@apache.org> on 2020/07/02 16:00:00 UTC, 0 replies.
- Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL - posted by Konstantin Knauf <kn...@apache.org> on 2020/07/02 16:49:35 UTC, 11 replies.
- [jira] [Created] (FLINK-18474) Flink on YARN produces WARN log statements about the configuration - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/07/02 17:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18475) Scrolling does not work in logs view - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/07/02 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails locally - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/07/02 18:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18477) ChangelogSocketExample does not work - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/07/02 18:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/07/02 18:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18479) can not commit partition when set partition time - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/07/03 01:22:00 UTC, 0 replies.
- Hi~ - posted by haishuai guo <ha...@gmail.com> on 2020/07/03 06:33:37 UTC, 1 replies.
- Re: [DISCUSS] Drop connectors for 5.x and restart the flink es source connector - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 06:57:28 UTC, 0 replies.
- Re: Does FlinkKinesisConsumer not retry on NoHttpResponseException? - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 07:31:19 UTC, 0 replies.
- Re: [DISCUSS] Semantics of our JIRA fields - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 07:40:19 UTC, 0 replies.
- Re: NullPointer Exception while trying to access or read ReadOnly ctx in processElement method in KeyedBroadCastProcessFunction in Apache Flink - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/07/03 07:56:46 UTC, 3 replies.
- Re: Moving in and Modify Dependency Source - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 07:56:51 UTC, 0 replies.
- Re: [DISCUSS] Leverage Maven Wrapper - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 08:12:37 UTC, 3 replies.
- [jira] [Created] (FLINK-18480) JomManager suspend because of loss ZK connection - posted by "Zhang Jianguo (Jira)" <ji...@apache.org> on 2020/07/03 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18481) Kafka connector can't select data - posted by "initsun (Jira)" <ji...@apache.org> on 2020/07/03 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18482) Replace flink-training datasets with data generators - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/07/03 12:39:00 UTC, 0 replies.
- Problem of compiling Flink source code - posted by Gu Wenyu <we...@scania.com> on 2020/07/03 14:14:25 UTC, 0 replies.
- [jira] [Created] (FLINK-18483) [EFO] Test coverage improvements for existing connector - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/07/03 14:48:00 UTC, 0 replies.
- Re: [FLINK-17073] checkpoint backpressure design doc - posted by Etienne Chauchot <ec...@apache.org> on 2020/07/03 14:59:46 UTC, 0 replies.
- [jira] [Created] (FLINK-18484) RowSerializer arity error does not provide specific information about the mismatch - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2020/07/03 18:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/04 05:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18486) Add documentation for the '%' modulus function - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/05 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18487) New table source factory omits unrecognized properties silently - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/07/05 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18488) Python API CsvTableSource missing optional constructor params - posted by "Chris Nix (Jira)" <ji...@apache.org> on 2020/07/05 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18489) java.lang.ArrayIndexOutOfBoundsException - posted by "Ori Popowski (Jira)" <ji...@apache.org> on 2020/07/05 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18490) Extract the implementation logic of Beam in AbstractPythonFunctionOperator - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/07/06 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18491) Extract the implementation logic of Beam in coders - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/07/06 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18492) Extract the implementation logic of Beam in Operations - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/07/06 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18493) Make target home directory used to store yarn files configurable - posted by "Kevin Zhang (Jira)" <ji...@apache.org> on 2020/07/06 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18494) The job was migrated from flink1.9.0 to 1.10.1, and there were incompatibilities: No enum constant org.apache.flink.table.types.logical.LogicalTypeRoot.ANY - posted by "wuleiflink (Jira)" <ji...@apache.org> on 2020/07/06 07:18:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.11.0, release candidate #4 - posted by Zhijiang <wa...@aliyun.com.INVALID> on 2020/07/06 07:24:47 UTC, 0 replies.
- [jira] [Created] (FLINK-18495) flink filterpushdown can not take effect in blink planner - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/07/06 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18496) Anchors are not generated based on ZH characters - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/07/06 09:30:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/26-27 - posted by Konstantin Knauf <kn...@apache.org> on 2020/07/06 11:12:21 UTC, 0 replies.
- [jira] [Created] (FLINK-18497) Publish Docerfiles for release 1.11.0 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/07/06 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18498) Update Flink Playgrounds to 1.11 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/07/06 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18499) Update Flink Exercises to 1.11 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/07/06 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18500) Make the legacy planner exception more clear when resolving computed columns types for schema - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/07/06 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18501) Mapping of Pluggable Filesystems to scheme is not properly logged - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2020/07/06 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18502) Add 'legacySourceSinks.zh.md' into the 'flink/docs/dev/table' directory - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/07/06 15:42:00 UTC, 0 replies.
- Flink Parallelism for various type of transformation - posted by Prasanna kumar <pr...@gmail.com> on 2020/07/06 17:01:36 UTC, 1 replies.
- [ANNOUNCE] New PMC member: Piotr Nowojski - posted by Stephan Ewen <se...@apache.org> on 2020/07/06 17:07:18 UTC, 41 replies.
- [jira] [Created] (FLINK-18503) bug occurs when `HeapReducingState#add` method handles null - posted by "fanrui (Jira)" <ji...@apache.org> on 2020/07/06 18:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18504) Mismatch between CsvTableSource constructor and builder params - posted by "Chris Nix (Jira)" <ji...@apache.org> on 2020/07/06 22:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18505) correct the content of 'sourceSinks.zh.md' - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/07/07 00:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18506) The generated flink-docker file misses flink version in Tags - posted by "Yu Li (Jira)" <ji...@apache.org> on 2020/07/07 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18507) Move get_config implementation to TableEnvironment to eliminate the duplication - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/07 02:29:00 UTC, 0 replies.
- [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API - posted by Jark Wu <im...@gmail.com> on 2020/07/07 02:32:49 UTC, 16 replies.
- [jira] [Created] (FLINK-18508) Dynamic source supports statistics and parallelism report - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/07/07 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18509) add ignite idbc dialect - posted by "底限 (Jira)" <ji...@apache.org> on 2020/07/07 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18511) Unsupported call: TUMBLE_END(TIME(0), INTERVAL SECOND(3) NOT NULL) - posted by "mzz (Jira)" <ji...@apache.org> on 2020/07/07 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18510) Job Listener接口不生效 - posted by "Edsion_Lin (Jira)" <ji...@apache.org> on 2020/07/07 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18512) [KINESIS][EFO] Introduce RecordPublisher Interface - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/07/07 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18513) [Kinesis][EFO] Add AWS SDK v2.x dependency and FanOutKinesisProxy - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/07/07 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18514) Building fails with JDK 14 installed - posted by "Niels Basjes (Jira)" <ji...@apache.org> on 2020/07/07 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18515) [Kinesis][EFO] FanOutRecordPublisher and full EFO support - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/07/07 08:00:10 UTC, 0 replies.
- [jira] [Created] (FLINK-18516) Improve error message for rank function in streaming mode - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/07/07 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18517) kubernetes session test failed with "java.net.SocketException: Broken pipe" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/07 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18518) Add Async RequestReply handler for the Python SDK - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/07/07 12:38:00 UTC, 0 replies.
- Check pointing for simple pipeline - posted by Prasanna kumar <pr...@gmail.com> on 2020/07/07 12:43:42 UTC, 2 replies.
- [ANNOUNCE] Apache Flink 1.11.0 released - posted by Zhijiang <wa...@aliyun.com.INVALID> on 2020/07/07 14:06:05 UTC, 12 replies.
- [jira] [Created] (FLINK-18519) Propagate exception to client when execution fails for REST submission - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/07/07 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18520) New Table Function type inference fails - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/07/07 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18521) Add release script for creating snapshot branches - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/07/07 16:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18522) ZKCheckpointIDCounterMultiServersTest.testRecoveredAfterConnectionLoss failed with "Address already in use" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/08 01:58:00 UTC, 0 replies.
- [DISCUSS] FLIP-130: Support for Python DataStream API (Stateless Part) - posted by Shuiqiang Chen <ac...@gmail.com> on 2020/07/08 03:13:30 UTC, 15 replies.
- [jira] [Created] (FLINK-18523) The watermark could be updated without data for some time - posted by "chen yong (Jira)" <ji...@apache.org> on 2020/07/08 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18524) Scala varargs cause exception for new inference - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/07/08 08:43:00 UTC, 0 replies.
- Why ApplicationMode for k8s doesn't support using remote jar? - posted by DashShen <38...@qq.com> on 2020/07/08 09:12:12 UTC, 1 replies.
- [jira] [Created] (FLINK-18525) Running yarn-session.sh occurs error - posted by "zhangyunyun (Jira)" <ji...@apache.org> on 2020/07/08 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18526) Add the configuration of Python UDF using Managed Memory in the doc of Pyflink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/07/08 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18527) Task Managers fail to start on HDP 2.6.5 due to commons-cli conflict - posted by "Truong Duc Kien (Jira)" <ji...@apache.org> on 2020/07/08 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18528) Update UNNEST to new type system - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/07/08 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18529) Query Hive table and filter by timestamp partition doesn't work - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/07/08 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18530) ParquetAvroWriters can not write data to hdfs - posted by "humengyu (Jira)" <ji...@apache.org> on 2020/07/08 13:14:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18531) Minicluster option to reuse same port if 0 is applied - posted by "David Chen (Jira)" <ji...@apache.org> on 2020/07/08 16:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18532) Remove Beta tag from MATCH_RECOGNIZE docs - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/07/08 17:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18533) AccumulatorLiveITCase.testStreaming hangs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/09 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18534) KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic 'changelog_topic' already exists" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/09 02:17:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.11.1 soon? - posted by Jark Wu <im...@gmail.com> on 2020/07/09 03:10:09 UTC, 28 replies.
- 来自靳亚洽的邮件 - posted by 靳亚洽 <ji...@163.com> on 2020/07/09 06:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-18535) Elasticsearch connector hangs for threads deadlocked - posted by "DeFOX (Jira)" <ji...@apache.org> on 2020/07/09 06:24:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API - posted by Xuannan Su <su...@gmail.com> on 2020/07/09 08:00:00 UTC, 5 replies.
- [jira] [Created] (FLINK-18536) [Kinesis][EFO] Configuration deserialisation and validation - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/07/09 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18537) Remove RowDataTypeInfo - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/07/09 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18538) SqlClientException - posted by "neo (Jira)" <ji...@apache.org> on 2020/07/09 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18539) StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type information - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/09 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18540) Unnecessary retract messages when setIdleStateRetentionTime before converting dynamic table to retract stream - posted by "WeiqiangSun (Jira)" <ji...@apache.org> on 2020/07/09 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18541) Verify the Elasticsearch authentication option in end to end test - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/09 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18542) GPUDiscoveryScriptTest fails for permission denied - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2020/07/09 10:23:00 UTC, 0 replies.
- Improvement idea: Naming the maven modules. - posted by Niels Basjes <Ni...@basjes.nl> on 2020/07/09 12:21:27 UTC, 7 replies.
- [jira] [Created] (FLINK-18543) FunctionITCase.testInvalidUseOfSystemScalarFunction - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/09 13:00:14 UTC, 0 replies.
- [jira] [Created] (FLINK-18544) FunctionITCase.testInvalidUseOfSystemScalarFunction fails - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/07/09 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18545) Sql api cannot special flink job name - posted by "venn wu (Jira)" <ji...@apache.org> on 2020/07/09 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18546) Upgrade to Kafka Schema Registry Client 5.5.0 - posted by "Lucas Heimberg (Jira)" <ji...@apache.org> on 2020/07/09 14:30:00 UTC, 0 replies.
- Season of Docs 2020 Proposal for Apache Flink (AdityaHurkat) - posted by Season of Docs <se...@google.com.INVALID> on 2020/07/10 01:33:28 UTC, 0 replies.
- Season of Docs 2020 Proposal for Apache Flink (Ayeshmantha) - posted by Season of Docs <se...@google.com.INVALID> on 2020/07/10 01:33:29 UTC, 0 replies.
- Season of Docs 2020 Proposal for Apache Flink (haseeb1431) - posted by Season of Docs <se...@google.com.INVALID> on 2020/07/10 01:33:30 UTC, 1 replies.
- Season of Docs 2020 Proposal for Apache Flink (dvohra) - posted by Season of Docs <se...@google.com.INVALID> on 2020/07/10 01:33:30 UTC, 0 replies.
- Season of Docs 2020 Proposal for Apache Flink (Hezeh) - posted by Season of Docs <se...@google.com.INVALID> on 2020/07/10 01:33:32 UTC, 0 replies.
- Season of Docs 2020 Proposal for Apache Flink (Kartik Khare) - posted by Season of Docs <se...@google.com.INVALID> on 2020/07/10 01:33:35 UTC, 0 replies.
- Season of Docs 2020 Proposal for Apache Flink (Rene1) - posted by Season of Docs <se...@google.com.INVALID> on 2020/07/10 01:33:38 UTC, 0 replies.
- Season of Docs 2020 Proposal for Apache Flink (Sanjay T) - posted by Season of Docs <se...@google.com.INVALID> on 2020/07/10 01:33:38 UTC, 0 replies.
- Season of Docs 2020 Proposal for Apache Flink (Tom Smith) - posted by Season of Docs <se...@google.com.INVALID> on 2020/07/10 01:33:41 UTC, 0 replies.
- Season of Docs 2020 Proposal for Apache Flink (Vivin) - posted by Season of Docs <se...@google.com.INVALID> on 2020/07/10 01:33:44 UTC, 0 replies.
- [jira] [Created] (FLINK-18547) the filesystem sql connector can't work well - posted by "tinny cat (Jira)" <ji...@apache.org> on 2020/07/10 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18548) Improve FlinkCalcMergeRule to merge calc nodes better - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/07/10 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18549) flink 1.11 can not commit partition automatically - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/07/10 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18550) use TableResult#collect to get select result for sql client - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/07/10 03:39:00 UTC, 0 replies.
- Flink memory consumption - posted by Ramya Ramamurthy <ha...@gmail.com> on 2020/07/10 06:32:12 UTC, 1 replies.
- [jira] [Created] (FLINK-18551) Don't need to download flink-conf.yaml when launching taskmanager on Yarn mode - posted by "Yumeng Zhang (Jira)" <ji...@apache.org> on 2020/07/10 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18552) Update migration tests in master to cover migration from release-1.11 - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/07/10 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18553) Update Table API set operations to the new type system - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/07/10 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18554) Memory exceeds taskmanager.memory.process.size when enabling mmap_read for RocksDB - posted by "Truong Duc Kien (Jira)" <ji...@apache.org> on 2020/07/10 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18555) Make TableConfig options can be configured by string-based Configuration - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/10 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18556) Drop the unused options in TableConfig - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/10 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18557) Blink planner should only use ReadableConfig instead of TableConfig - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/10 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18558) Introduce collect iterator with at least once semantics and exactly once semantics without fault tolerance - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/07/10 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18560) Introduce collect iterator with at least once semantics and exactly once semantics without fault tolerance - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/07/10 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18559) Refactor tests for datastream / table collect - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/07/10 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18561) Build manylinux1 with better compatibility instead of manylinux2014 Python Wheel Packages - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/07/10 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2020/07/10 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2020/07/10 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18564) Add Support for Azure Event Hub DataStream Connector - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2020/07/10 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2020/07/10 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2020/07/10 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18567) Add Support for Azure Cognitive Search DataStream Connector - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2020/07/10 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18568) Add Support for Azure Data Lake Store Gen 2 in Streaming File Sink - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2020/07/10 11:39:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18569) Add Table.limit() which is the equivalent of SQL LIMIT - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/07/10 14:32:00 UTC, 0 replies.
- Functions in Flick - posted by david david <te...@gmail.com> on 2020/07/10 16:57:23 UTC, 1 replies.
- [jira] [Created] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/07/10 17:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18571) when i use sql-client write to hive but throw a exception "This is a bug. Please consider filing an issue" - posted by "JasonLee (Jira)" <ji...@apache.org> on 2020/07/11 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18572) Flink web UI doesn't display unaligned checkpoint config - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2020/07/12 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18573) plugins/metrics-influx/flink-metrics-influxdb-1.11.0.jar META-INF has no dir named "services" , but "service" - posted by "zhangyunyun (Jira)" <ji...@apache.org> on 2020/07/13 01:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18574) DownloadPipelineArtifact failed occasionally - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/13 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18575) Failed to send data to Kafka - posted by "mzz (Jira)" <ji...@apache.org> on 2020/07/13 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18577) Mail.run Blocked By the Legacy Source Thread - posted by "zhangyunyun (Jira)" <ji...@apache.org> on 2020/07/13 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18576) BigInteger to Long - posted by "sunteng (Jira)" <ji...@apache.org> on 2020/07/13 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18578) Add rejecting checkpoint logic in source - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2020/07/13 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18579) Remove deprecated classes in flink-connector-jdbc - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/13 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18580) Incomplete conversion for MySQL types - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/07/13 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18581) Cannot find GC cleaner with java version previous 8u202 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/07/13 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18583) The _id field is incorrectly set to index in Elasticsearch6 DynamicTableSink - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/07/13 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18582) add title anchor link for file event_driven.zh.md - posted by "Herman, Li (Jira)" <ji...@apache.org> on 2020/07/13 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18584) JDBCLookupFunction not support AsyncLookupFunction - posted by "ranqiqiang (Jira)" <ji...@apache.org> on 2020/07/13 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18585) Dynamic index can not work in new DynamicTableSink - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/07/13 09:58:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/28 - posted by Konstantin Knauf <kn...@apache.org> on 2020/07/13 11:03:20 UTC, 0 replies.
- [jira] [Created] (FLINK-18586) Simplify the creation of explicit structured types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/07/13 12:12:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18587) java.lang.IllegalArgumentException: Position out of bounds - posted by "Ori Popowski (Jira)" <ji...@apache.org> on 2020/07/13 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18588) hive ddl create table should support 'if not exists' - posted by "wangtong (Jira)" <ji...@apache.org> on 2020/07/13 14:12:00 UTC, 0 replies.
- Use of SinkFunction.Context without generic parameter. - posted by Niels Basjes <Ni...@basjes.nl> on 2020/07/13 15:03:00 UTC, 2 replies.
- [jira] [Created] (FLINK-18589) java.io.EOFException when reading integer state - posted by "Ori Popowski (Jira)" <ji...@apache.org> on 2020/07/13 16:56:00 UTC, 0 replies.
- Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4) - posted by Thomas Weise <th...@apache.org> on 2020/07/13 18:14:18 UTC, 5 replies.
- [jira] [Created] (FLINK-18590) Support json array explode to multi messages - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/07/14 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18591) Fix the format issue for metrics web page - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/07/14 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure - posted by "JIAN WANG (Jira)" <ji...@apache.org> on 2020/07/14 04:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18593) Hive bundle jar URLs are broken - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/07/14 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18594) The link is broken in kafka doc - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/14 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18595) Deadlock during job shutdown - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/14 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18596) Derive format schema from table schema may get error result - posted by "wangsan (Jira)" <ji...@apache.org> on 2020/07/14 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18597) elasticsearch sql insert function cannot set documentid - posted by "xy (Jira)" <ji...@apache.org> on 2020/07/15 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18598) Add instructions for asynchronous execute in PyFlink doc - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/07/15 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18599) Compile error when use windowAll and TumblingProcessingTimeWindows - posted by "henvealf (Jira)" <ji...@apache.org> on 2020/07/15 02:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18600) Kerberized YARN per-job on Docker test failed to download JDK 8u251 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/15 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18601) Taskmanager shut down often in standalone cluster - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2020/07/15 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18602) Support specific offset for topic list for kafka connector in table api - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/07/15 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18603) SQL fails with java.lang.IllegalStateException: No operators defined in streaming topology - posted by "Alexander Filipchik (Jira)" <ji...@apache.org> on 2020/07/15 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18604) HBase Descriptor can not work in Table API - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/07/15 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18605) Refactor Descriptor API (TableEnvironment#connect) - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/15 07:41:00 UTC, 0 replies.
- Re: PackagedProgram and ProgramDescription - posted by Aljoscha Krettek <al...@apache.org> on 2020/07/15 10:00:50 UTC, 5 replies.
- [VOTE] Release 1.11.1, release candidate #1 - posted by Dian Fu <di...@gmail.com> on 2020/07/15 10:02:42 UTC, 16 replies.
- [jira] [Created] (FLINK-18606) Remove generic parameter from SinkFunction.Context - posted by "Niels Basjes (Jira)" <ji...@apache.org> on 2020/07/15 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18607) Give the maven modules human readable names. - posted by "Niels Basjes (Jira)" <ji...@apache.org> on 2020/07/15 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18608) CustomizedConvertRule#convertCast drops nullability - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2020/07/15 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18609) The user-defined jdbc-source process before add window ,job finished early. - posted by "ZHangTianLong (Jira)" <ji...@apache.org> on 2020/07/15 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18610) Clean up Table connector docs grammar - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/07/15 17:02:00 UTC, 0 replies.
- Performance test Flink vs Storm - posted by Prasanna kumar <pr...@gmail.com> on 2020/07/15 17:57:27 UTC, 1 replies.
- Using md5 hash while sinking files to s3 - posted by nikita Balakrishnan <ni...@gmail.com> on 2020/07/16 01:11:03 UTC, 3 replies.
- [jira] [Created] (FLINK-18611) Include `m` as time unit expression for MINUTE in SQL - posted by "Q Kang (Jira)" <ji...@apache.org> on 2020/07/16 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18612) WordCount example failure when using relative output path - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/07/16 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18613) How to support retract & upsert sink for a TableSink ? - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/07/16 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18614) Performance regression 2020.07.13 (most benchmarks) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/07/16 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18615) run flink with openjdk11 get java.lang.UnsupportedOperationException: sun.misc.Unsafe or java.nio.DirectByteBuffer.(long, int) not available - posted by "dongjie.shi (Jira)" <ji...@apache.org> on 2020/07/16 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18616) Add SHOW CURRENT DDLs - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/07/16 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18617) run flink with openjdk 11 get java.lang.UnsupportedOperationException: sun.misc.Unsafe or java.nio.DirectByteBuffer.(long, int) not available error - posted by "dongjie.shi (Jira)" <ji...@apache.org> on 2020/07/16 09:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18618) Docker e2e tests are failing on CI - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/07/16 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18619) Update training to use WatermarkStrategy - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/07/16 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18620) Unify behaviors of active resource managers - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/07/17 05:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18621) Simplify the methods of Executor interface in sql client - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/07/17 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18622) Add limit method in the Python Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/17 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18623) CREATE TEMPORARY TABLE not documented - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/07/17 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18624) Document CREATE TEMPORARY TABLE - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/07/17 09:13:00 UTC, 0 replies.
- Re: How to write junit testcases for KeyedBroadCastProcess Function - posted by David Anderson <da...@alpinegizmo.com> on 2020/07/17 09:52:41 UTC, 0 replies.
- [jira] [Created] (FLINK-18625) Maintain redundant taskmanagers to speed up failover - posted by "Liu (Jira)" <ji...@apache.org> on 2020/07/17 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18626) the result of aggregate SQL on streaming cannot write to upsert table sink - posted by "gaoling ma (Jira)" <ji...@apache.org> on 2020/07/17 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18627) Get unmatch filter method records to side output - posted by "Roey Shem Tov (Jira)" <ji...@apache.org> on 2020/07/17 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18628) Invalid error message for overloaded methods with same parameter name - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/07/17 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18629) ConnectedStreams#keyBy can not derive key TypeInformation for lambda KeySelectors - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/07/17 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18630) Improve solution to Long Rides training exercise - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/07/17 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18631) Serializer for scala sealed trait hierarchies - posted by "Roman Grebennikov (Jira)" <ji...@apache.org> on 2020/07/17 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18632) RowData's row kind do not assigned from input row data when sink code generate and physical type info is pojo type - posted by "luoziyu (Jira)" <ji...@apache.org> on 2020/07/17 14:53:00 UTC, 0 replies.
- Flink Sinks - posted by Prasanna kumar <pr...@gmail.com> on 2020/07/17 19:55:05 UTC, 1 replies.
- [jira] [Created] (FLINK-18633) Download miniconda is instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/18 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/18 03:08:00 UTC, 0 replies.
- thrift support - posted by Chen Qin <qi...@gmail.com> on 2020/07/18 07:42:37 UTC, 11 replies.
- [jira] [Created] (FLINK-18635) Typo in 'concepts/timely stream processing' part of the website - posted by "Xuhui Mao (Jira)" <ji...@apache.org> on 2020/07/18 17:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18636) Asynchronous close via configurable timeout in seconds for CompletedOperationCache - posted by "tartarus (Jira)" <ji...@apache.org> on 2020/07/19 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18637) Key group is not in KeyGroupRange - posted by "Ori Popowski (Jira)" <ji...@apache.org> on 2020/07/19 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18638) FutureUtils support timeout message - posted by "tartarus (Jira)" <ji...@apache.org> on 2020/07/19 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18639) Error messages from BashJavaUtils is eaten - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/07/20 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18640) Flink jdbc not support postgresql with schema - posted by "毛宗良 (Jira)" <ji...@apache.org> on 2020/07/20 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook - posted by "Brian Zhou (Jira)" <ji...@apache.org> on 2020/07/20 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18642) flink sql cep - posted by "franklin DREW (Jira)" <ji...@apache.org> on 2020/07/20 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18643) Migrate Jenkins jobs to ci-builds.apache.org - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/07/20 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18644) Remove scala-shell doc for hive connector - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/07/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18645) Add community driven SDKs to StateFun documentations. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/07/20 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18646) Managed memory released check can block RPC thread - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/07/20 13:21:00 UTC, 0 replies.
- [REMINDER] Use 'starter' labels for Jira issues where it makes sense - posted by Andrey Zagrebin <az...@apache.org> on 2020/07/20 14:02:42 UTC, 3 replies.
- Re: Flink Jobs are failing for running testcases when trying to build in Jenkins server - posted by Piotr Nowojski <pn...@apache.org> on 2020/07/20 14:38:12 UTC, 0 replies.
- [jira] [Created] (FLINK-18647) How to handle processing time timers with bounded input - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/07/20 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18648) KafkaITCase.testStartFromGroupOffsets times out on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/07/20 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18649) MongoDB Exactly-Once Semantics - recommended approach - posted by "Eric Holsinger (Jira)" <ji...@apache.org> on 2020/07/20 17:49:00 UTC, 0 replies.
- How does TaskManager announce JobManager about available ResultPartitions? - posted by Fork Joseph <fo...@gmail.com> on 2020/07/20 19:23:29 UTC, 0 replies.
- [jira] [Created] (FLINK-18650) The description of dispatcher in Flink Architecture document is not accurate - posted by "Peng (Jira)" <ji...@apache.org> on 2020/07/21 00:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18651) implicitly cast the time attribute to regular TIMESTAMP type in regular join - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/07/21 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18652) JDBCAppendTableSink to ClickHouse (data always repeating) - posted by "mzz (Jira)" <ji...@apache.org> on 2020/07/21 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18653) flink-storm中可以根据TopologyBuilder转换成DataStream，但是，在现实使用的时候，我们只能从Storm jar中获得StormTopolgoy。 - posted by "陈磊 (Jira)" <ji...@apache.org> on 2020/07/21 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18654) Correct missleading documentation in "Partitioned Scan" section of JDBC connector - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/21 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18655) Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/07/21 04:10:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.11.1, release candidate #1 - posted by Dian Fu <di...@gmail.com> on 2020/07/21 05:28:20 UTC, 1 replies.
- subscribe dev mail list - posted by Jake <ft...@qq.com> on 2020/07/21 06:49:03 UTC, 2 replies.
- [jira] [Created] (FLINK-18656) Start Delay metric is always zero for unaligned checkpoints - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/07/21 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18657) Change semantics of DESCRIBE SELECT statement - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/07/21 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18658) MiniClusterResource does not forward RpcServiceSharing setting - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/07/21 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18659) FileNotFoundException when writing Hive orc tables - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/07/21 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18660) Bump netty to 4.1.51 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/07/21 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18661) [Kinesis][EFO] Stream consumer Registration/Deregistration - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/07/21 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/07/21 10:32:00 UTC, 0 replies.
- Flink Redis connectivity - posted by Ramya Ramamurthy <ha...@gmail.com> on 2020/07/21 10:42:20 UTC, 4 replies.
- [jira] [Created] (FLINK-18663) Fix Flink On YARN AM not exit - posted by "tartarus (Jira)" <ji...@apache.org> on 2020/07/21 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18664) Publish Dockerfiles for release 1.11.1 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/21 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18665) Filesystem connector should use TableSchema exclude computed columns - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/21 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18666) Update japicmp configuration for 1.11.1 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/22 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18667) Data Types documentation misunderstand users - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/07/22 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18668) BytesHashMap#growAndRehash should release newly allocated segments before throwing the exception - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/07/22 06:43:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.11.1 released - posted by Dian Fu <di...@apache.org> on 2020/07/22 06:52:44 UTC, 0 replies.
- Re: [ANNOUNCE] Apache Flink 1.11.1 released - posted by Leonard Xu <xb...@gmail.com> on 2020/07/22 07:09:25 UTC, 10 replies.
- [jira] [Created] (FLINK-18669) Remove testing-related code from production code in PubSub connector - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/07/22 07:42:00 UTC, 0 replies.
- [DISCUSS] Adding Azure Platform Support in DataStream, Table and SQL Connectors - posted by Israel Ekpo <is...@gmail.com> on 2020/07/22 08:40:38 UTC, 3 replies.
- [jira] [Created] (FLINK-18670) Add (statefun-)docker repos to community page - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/07/22 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18671) Update upgrade compatibility table (docs/ops/upgrading.md) for 1.11.0 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/07/22 11:31:00 UTC, 0 replies.
- [DISCUSS] Planning Flink 1.12 - posted by Robert Metzger <rm...@apache.org> on 2020/07/22 12:10:40 UTC, 7 replies.
- [jira] [Created] (FLINK-18672) Fix Scala code examples for UDF type inference annotations - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/07/22 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18673) Calling ROW() in a UDF results in UnsupportedOperationException - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/07/22 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18674) Support to bridge Transformation (DataStream) with FLIP-95 interface? - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/22 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints - posted by "Ravi Bhushan Ratnakar (Jira)" <ji...@apache.org> on 2020/07/22 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18676) Update version of aws to support use of default constructor of "WebIdentityTokenCredentialsProvider" - posted by "Ravi Bhushan Ratnakar (Jira)" <ji...@apache.org> on 2020/07/22 17:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18677) ZooKeeperLeaderRetrievalService does not invalidate leader in case of SUSPENDED connection - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/07/22 21:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18678) Hive connector fails to create vector orc reader if user specifies incorrect hive version - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/07/23 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18679) It doesn't support to join two tables containing the same field names in Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/23 05:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18680) Improve RecordsWithSplitIds API - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/07/23 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18681) The jar package version conflict causes the task to continue to increase and grab resources - posted by "wangtaiyang (Jira)" <ji...@apache.org> on 2020/07/23 07:35:00 UTC, 0 replies.
- 答复: Flink Redis connectivity - posted by 范超 <fa...@mgtv.com> on 2020/07/23 08:24:33 UTC, 0 replies.
- [jira] [Created] (FLINK-18682) Vector orc reader cannot read Hive 2.0.0 table - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/07/23 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18683) Support @DataTypeHint for TableFunction output types - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/07/23 10:21:00 UTC, 0 replies.
- [DISCUSS] Align the semantic of returning null from InputFormat#nextRecord - posted by Benchao Li <li...@apache.org> on 2020/07/23 10:31:17 UTC, 4 replies.
- [jira] [Created] (FLINK-18684) Performance regression around 2020.07.22 in serialization - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/07/23 11:00:17 UTC, 0 replies.
- [jira] [Created] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/07/23 11:44:00 UTC, 0 replies.
- Re: Is it possible to do state migration with checkpoints? - posted by Sivaprasanna <si...@gmail.com> on 2020/07/23 12:03:27 UTC, 0 replies.
- [jira] [Created] (FLINK-18686) Getting the emit time when `table.exec.emit.early-fire.enabled` is true - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/07/23 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18687) ProjectionCodeGenerator#generateProjectionExpression should remove for loop optimization - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/07/23 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18688) ProjectionCodeGenerator#generateProjectionExpression should remove for loop optimization - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/07/23 12:43:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18689) Deterministic Slot Sharing - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/07/23 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/07/23 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18691) add HiveCatalog Construction method with HiveConf - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/07/23 14:02:00 UTC, 0 replies.
- Hi - posted by Suryanarayana Murthy Maganti <su...@gmail.com> on 2020/07/23 14:07:40 UTC, 8 replies.
- [jira] [Created] (FLINK-18693) AvroSerializationSchema does not work with types generated by avrohugger - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/07/23 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18692) AvroSerializationSchema does not work with types generated by avrohugger - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/07/23 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18694) Add unaligned checkpoint config to web ui - posted by "Kboh (Jira)" <ji...@apache.org> on 2020/07/23 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/07/23 17:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18696) Java 14 Records are not recognized as POJOs - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/07/23 18:33:00 UTC, 0 replies.
- Inconsistent behavior between different states with ListState.get().iterator().remove() - posted by Ken Krugler <kk...@transpac.com> on 2020/07/23 18:40:36 UTC, 2 replies.
- [jira] [Created] (FLINK-18697) Adding flink-table-api-java-bridge_2.11 to a Flink job kills the IDE logging - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/07/23 19:06:00 UTC, 0 replies.
- [Discuss] Questions about SortedMapState in Stream API - posted by Sean Z <xi...@gmail.com> on 2020/07/23 19:35:55 UTC, 2 replies.
- [jira] [Created] (FLINK-18698) org.apache.flink.sql.parser.utils.ParserResource compile error - posted by "毛宗良 (Jira)" <ji...@apache.org> on 2020/07/24 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18699) Allow variables for column names in Scala Table API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/07/24 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18700) Debezium-json format throws Exception when PG table's IDENTITY config is not FULL - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/07/24 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18701) NOT NULL constraint is not guaranteed when aggregation split is enabled - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/24 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18702) Flink elasticsearch connector leaks threads and classloaders thereof - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2020/07/24 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18703) Use new data structure converters when legacy types are not present - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/07/24 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18704) Support DECIMAL types in datagen Table source connector - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/07/24 10:38:00 UTC, 0 replies.
- [VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API - posted by Jark Wu <im...@gmail.com> on 2020/07/24 10:42:02 UTC, 7 replies.
- [jira] [Created] (FLINK-18705) Debezium-JSON throws NPE when tombstone message is received - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/24 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source - posted by "Yumeng Zhang (Jira)" <ji...@apache.org> on 2020/07/24 11:45:00 UTC, 0 replies.
- [VOTE] FLIP-130: Support for Python DataStream API (Stateless Part) - posted by Shuiqiang Chen <ac...@gmail.com> on 2020/07/24 12:31:44 UTC, 5 replies.
- [jira] [Created] (FLINK-18707) Calling remove() for RockDB ListState iterator does nothing - posted by "Kenneth William Krugler (Jira)" <ji...@apache.org> on 2020/07/24 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18708) The links of the connector sql jar of Kafka 0.10 and 0.11 are extinct - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/07/24 14:26:00 UTC, 0 replies.
- [Discuss] Handling of Timestamp in DataGen table created via LIKE - posted by Seth Wiesman <sj...@gmail.com> on 2020/07/24 15:27:17 UTC, 4 replies.
- [jira] [Created] (FLINK-18709) Implement PhysicalSlotProvider - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/07/24 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18710) ResourceProfileInfo is not serializable - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/07/24 18:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18711) Trim the blank space for TableOptions - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/07/25 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18712) Flink RocksDB statebackend memory leak issue - posted by "Farnight (Jira)" <ji...@apache.org> on 2020/07/25 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18713) Allow default ms unit for table.exec.mini-batch.allow-latency etc. - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/07/25 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18714) Support consuming multiple topics for KafkaTableSource - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/07/25 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18715) add cpu usage metric of jobmanager/taskmanager - posted by "wgcn (Jira)" <ji...@apache.org> on 2020/07/25 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18716) Remove the deprecated "execute" and "insert_into" calls in PyFlink Table API docs - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/07/26 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18717) reuse MiniCluster in table integration test class ? - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/07/26 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18718) Support for using yarn-cluster CLI parameters on application mode - posted by "Felipe Lolas (Jira)" <ji...@apache.org> on 2020/07/26 23:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18719) Define the interfaces and introduce ActiveResourceManager - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/07/27 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18720) Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/07/27 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18721) Migrate YarnResourceManager to the new YarnResourceManagerDriver - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/07/27 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18722) Migrate MesosResourceManager to the new MesosResourceManagerDriver - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/07/27 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18723) performance test - posted by "junbiao chen (Jira)" <ji...@apache.org> on 2020/07/27 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18724) Integration with DataStream and DataSet API report error - posted by "liang ding (Jira)" <ji...@apache.org> on 2020/07/27 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18725) "Run Kubernetes test" failed with "30025: provided port is already allocated" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/27 05:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18726) Support INSERT INTO specific columns - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/07/27 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18727) Remove the previous finished empty Buffer in PipelinedSubpartition when adding a new Buffer - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/07/27 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18728) Make initialCredit of RemoteInputChannel final - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/07/27 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18729) kafka - posted by "shengjk1 (Jira)" <ji...@apache.org> on 2020/07/27 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18730) Remove Beta tag from SQL Client docs - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/27 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18731) The monotonicity of UNIX_TIMESTAMP function is not correct - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/07/27 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18732) Update the hyperlink to the latest version - posted by "weizheng (Jira)" <ji...@apache.org> on 2020/07/27 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper - posted by "Leonid Ilyevsky (Jira)" <ji...@apache.org> on 2020/07/27 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC - posted by "Vinay (Jira)" <ji...@apache.org> on 2020/07/27 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18735) Enhance DataGen source to support more types - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/07/27 15:15:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/29-30 - posted by Konstantin Knauf <kn...@apache.org> on 2020/07/27 16:29:27 UTC, 0 replies.
- [DISCUSS][Release 1.12] Stale blockers and build instabilities - posted by Robert Metzger <rm...@apache.org> on 2020/07/27 18:42:02 UTC, 0 replies.
- [jira] [Created] (FLINK-18736) Source chaining with N-Ary Stream Operator in Flink - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/07/28 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18737) translate jdbc connector - posted by "weizheng (Jira)" <ji...@apache.org> on 2020/07/28 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18738) Revisit resource management model for python processes. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/07/28 07:56:00 UTC, 0 replies.
- [DISCUSS] FLIP-132: Temporal Table DDL - posted by Leonard Xu <xb...@gmail.com> on 2020/07/28 07:56:22 UTC, 4 replies.
- [jira] [Created] (FLINK-18739) Implement MergingSharedSlotProfileRetriever - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/07/28 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18740) Support rate limiter in the universal kafka connector - posted by "Truong Duc Kien (Jira)" <ji...@apache.org> on 2020/07/28 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18741) ProcessWindowFunction's process function exception - posted by "mzz (Jira)" <ji...@apache.org> on 2020/07/28 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18743) Modify English link to Chinese link - posted by "weizheng (Jira)" <ji...@apache.org> on 2020/07/28 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18742) Configuration args do not take effect at client - posted by "Matt Wang (Jira)" <ji...@apache.org> on 2020/07/28 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18744) resume from modified savepoint dirctionary: No such file or directory - posted by "tao wang (Jira)" <ji...@apache.org> on 2020/07/28 13:55:00 UTC, 0 replies.
- [DISCUSS] add a '--filename' parameter for sql-client - posted by Jun Zhang <zh...@gmail.com> on 2020/07/29 01:20:57 UTC, 3 replies.
- [jira] [Created] (FLINK-18745) 'SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)' failed to download Elasticsearch - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/29 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18746) WindowStaggerTest.testWindowStagger failed - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/29 01:49:00 UTC, 0 replies.
- flink1.11 可以使用processtime开窗，但是无法使用eventtime开窗 - posted by 111 <ta...@163.com> on 2020/07/29 01:57:14 UTC, 3 replies.
- [jira] [Created] (FLINK-18747) Make Debezium Json format support timestamp with timezone - posted by "Leon Hao (Jira)" <ji...@apache.org> on 2020/07/29 03:28:00 UTC, 0 replies.
- 回复：flink1.11 可以使用processtime开窗，但是无法使用eventtime开窗 - posted by 何会远 <kn...@163.com> on 2020/07/29 04:25:11 UTC, 1 replies.
- [jira] [Created] (FLINK-18748) Savepoint would be queued unexpected - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2020/07/29 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18749) Correct dependencies in Kubernetes pom and notice file - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/07/29 05:51:00 UTC, 0 replies.
- flink 1.11 CREATE VIEW + LATERAL TABLE 语法校验问题 - posted by XiaChang <13...@163.com> on 2020/07/29 07:00:20 UTC, 1 replies.
- [jira] [Created] (FLINK-18750) SqlValidatorException thrown when select from a view which contains a UDTF call - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/07/29 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18751) Implement SlotSharingExecutionSlotAllocator - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/07/29 07:49:00 UTC, 0 replies.
- Re: flink 1.11 CREATE VIEW + LATERAL TABLE 语法校验问题 - posted by Jark Wu <im...@gmail.com> on 2020/07/29 08:11:46 UTC, 0 replies.
- [jira] [Created] (FLINK-18752) Yarn ship logic should support files - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/07/29 08:32:00 UTC, 0 replies.
- [DISCUSS] FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API) - posted by Aljoscha Krettek <al...@apache.org> on 2020/07/29 10:45:51 UTC, 10 replies.
- [jira] [Created] (FLINK-18753) Support local recovery for Unaligned checkpoints - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/07/29 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18754) Display Python streaming metrics in Grafana dashboard - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2020/07/29 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18755) RabbitMQ QoS Chinese Documentation - posted by "Austin Cawley-Edwards (Jira)" <ji...@apache.org> on 2020/07/29 19:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18756) Support IF NOT EXISTS for CREATE TABLE statement - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/30 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18757) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed with "Topic XX not present in metadata after 60000 ms" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/30 03:13:00 UTC, 0 replies.
- [DISCUSS] Introduce SupportsParallelismReport and SupportsStatisticsReport for Hive and Filesystem - posted by Jingsong Li <ji...@gmail.com> on 2020/07/30 03:16:11 UTC, 5 replies.
- [jira] [Created] (FLINK-18758) Support debezium data type in debezium format - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/07/30 04:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18759) Add readme.md for TPC-DS tools - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/07/30 04:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18760) Redundant task managers should be released when there's no job running in session cluster - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/07/30 05:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18761) Support Python DataStream API (Stateless part) - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/07/30 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18762) Make network buffers per incoming/outgoing channel can be configured separately - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/07/30 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18763) Support basic TypeInformation for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/07/30 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18764) Support from_collection for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/07/30 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18765) Support map() and flat_map() for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/07/30 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18766) Support add_sink() for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/07/30 07:23:00 UTC, 0 replies.
- Re: Checkpointing under backpressure - posted by Arvid Heise <ar...@ververica.com> on 2020/07/30 09:04:47 UTC, 1 replies.
- [jira] [Created] (FLINK-18767) Streaming job stuck when disabling operator chaining - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/07/30 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18768) Imporve SQL kafka connector docs about passing kafka properties - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/07/30 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18769) Streaming Table job stuck when enabling minibatching - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/07/30 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18770) Emitting element fails in KryoSerializer - posted by "Leonid Ilyevsky (Jira)" <ji...@apache.org> on 2020/07/30 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18771) "Kerberized YARN per-job on Docker test" failed with "Client cannot authenticate via:[TOKEN, KERBEROS]" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/30 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18772) Hide submit job web ui elements when running in per-job/application mode - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/07/30 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18773) Enable parallel classloading - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/07/30 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18774) Support debezium-avro format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/30 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18775) Rework PyFlink Documentation - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/07/31 01:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18776) "compile_cron_scala212" failed to compile - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/31 02:07:00 UTC, 0 replies.
- [DISCUSS] FLIP-133: Rework PyFlink Documentation - posted by jincheng sun <su...@gmail.com> on 2020/07/31 02:14:58 UTC, 3 replies.
- [jira] [Created] (FLINK-18777) Supports schema registry catalog - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/07/31 04:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18779) Support the SupportsFilterPushDown interface for ScanTableSource. - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/31 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18778) Support the SupportsProjectionPushDown interface for LookupTableSource - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/31 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18780) FlinkKafkaProducer should add another constructor accepting SerializationSchema - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2020/07/31 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18781) Example in table/sql/queries.md Exists section is not correct - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/07/31 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18782) How to retain the column'name when convert a Table to DataStream - posted by "Ying Z (Jira)" <ji...@apache.org> on 2020/07/31 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18783) Load AkkaRpcService through separate class loader - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/07/31 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18784) Push Projection through WatermarkAssigner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/07/31 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path - posted by "Kai Chen (Jira)" <ji...@apache.org> on 2020/07/31 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18786) Performance regresssion on 2020.07.29 in some state backend benchmarks - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/07/31 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18787) Add a "cluster-info" command to the Flink command line client - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/07/31 12:26:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18788) Refactor sql-client based the proposed interfaces of FLIP-84 - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/07/31 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18789) Use TableEnvironment#executeSql to execute insert statement in sql client - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/07/31 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18790) Set a connection timeout that is lower than the request timeout for remote functions - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/07/31 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18791) Simplify the logic of SqlCommandParser and CliClient - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/07/31 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18792) TaskManager Start Failure - posted by "Chris R (Jira)" <ji...@apache.org> on 2020/07/31 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18793) Fix Typo for api.common.eventtime.WatermarkStrategy Description - posted by "Chris Lan (Jira)" <ji...@apache.org> on 2020/07/31 17:26:00 UTC, 0 replies.
- [DISCUSS] StreamingFileSink: parallelizing active buckets checkpointing? - posted by Paul Bernier <pb...@splunk.com.INVALID> on 2020/07/31 17:58:24 UTC, 0 replies.