dev@flink.apache.org, 2022-07

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

- [jira] [Created] (FLINK-28335) Delete topic after tests - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/01 00:49:00 UTC, 0 replies.
- Re: Re: [DISCUSS] FLIP-239: Port JDBC Connector Source to FLIP-27 - posted by Lijie Wang <wa...@gmail.com> on 2022/07/01 02:24:56 UTC, 4 replies.
- [jira] [Created] (FLINK-28336) Support parquet-avro format in PyFlink DataStream - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/07/01 03:02:00 UTC, 0 replies.
- [VOTE] Apache Flink ML Release 2.1.0, release candidate #2 - posted by Zhipeng Zhang <zh...@gmail.com> on 2022/07/01 03:10:48 UTC, 5 replies.
- [jira] [Created] (FLINK-28337) java.lang.IllegalArgumentException: Table identifier not set - posted by "wei (Jira)" <ji...@apache.org> on 2022/07/01 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28338) org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParseException: Invalid numeric value: Leading zeroes not allowed - posted by "wangkang (Jira)" <ji...@apache.org> on 2022/07/01 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28339) Introduce SparkCatalog in table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/01 04:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28340) Support using system conda env for PyFlink tests - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/07/01 06:36:00 UTC, 0 replies.
- Re: Enquiry about contributing to Flink - posted by Martijn Visser <ma...@apache.org> on 2022/07/01 06:41:15 UTC, 0 replies.
- [jira] [Created] (FLINK-28341) Fix comment in BytesKeyNormalizationUtil.java - posted by "shen (Jira)" <ji...@apache.org> on 2022/07/01 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28342) Flink batch support for Hive StorageHandlers - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/07/01 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28343) Hive dialect fails using union map type - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/07/01 07:17:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-244: Support IterativeCondition with Accumulator in CEP Pattern - posted by Martijn Visser <ma...@apache.org> on 2022/07/01 07:29:41 UTC, 0 replies.
- [jira] [Created] (FLINK-28344) How to connect flink and elasticsearch in pyflink 1.15.0? - posted by "ela demir (Jira)" <ji...@apache.org> on 2022/07/01 08:18:00 UTC, 0 replies.
- Re: [DISCUSS] Support partition pruning for streaming reading - posted by Martijn Visser <ma...@apache.org> on 2022/07/01 08:20:27 UTC, 5 replies.
- [jira] [Created] (FLINK-28345) Flink Jdbc connector should check batch count before flush - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2022/07/01 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28346) Wrong plan when selects metadata in a different order against ddl - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/01 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28347) Update testcontainers dependency to v1.17.3 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/01 09:22:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-238: Introduce FLIP-27-based Data Generator Source - posted by Becket Qin <be...@gmail.com> on 2022/07/01 09:28:40 UTC, 10 replies.
- [jira] [Created] (FLINK-28348) Add configurable flag to disable last-state fallback for savepoint upgrade - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/01 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28349) Consider using resource uid as fixed jobid for operator deployed jobs - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/01 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28350) Test last-state upgrades across Flink minor versions - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/01 09:54:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-245: Source Supports Speculative Execution For Batch Job - posted by Jing Zhang <be...@gmail.com> on 2022/07/01 10:02:46 UTC, 8 replies.
- [jira] [Created] (FLINK-28351) Pulsar Sink should support dynamic generated topic from record - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/07/01 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28352) [Umbrella] Make Pulsar connector stable - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/01 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28353) Exclude unschedulable nodes using IP addresses of kubernetes nodes - posted by "Suxing Lee (Jira)" <ji...@apache.org> on 2022/07/01 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28354) Support instr and locate bulit-in function in Table API - posted by "LuNing Wang (Jira)" <ji...@apache.org> on 2022/07/01 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28355) Python Bash e2e tests don't clean-up after they've ran, causing disk space issues - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/01 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28356) Move operator metric recording logic into statusrecorder - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/01 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28357) Watermark issue when recovering Finished sources - posted by "James (Jira)" <ji...@apache.org> on 2022/07/01 15:22:00 UTC, 0 replies.
- Re: [VOTE] Release 1.15.1, release candidate #1 - posted by Konstantin Knauf <kn...@apache.org> on 2022/07/01 18:08:46 UTC, 4 replies.
- [jira] [Created] (FLINK-28358) when debug in local ,throw out "The system time period specification expects Timestamp type but is 'TIMESTAMP_WITH_LOCAL_TIME_ZONE' " exception - posted by "PengfeiChang (Jira)" <ji...@apache.org> on 2022/07/02 00:43:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-242: Introduce configurable RateLimitingStrategy for Async Sink - posted by "Teoh, Hong" <li...@amazon.co.uk.INVALID> on 2022/07/02 07:02:28 UTC, 1 replies.
- [jira] [Created] (FLINK-28359) Support Microsoft SQL Server JDBC Dialect - posted by "Lim Qing Wei (Jira)" <ji...@apache.org> on 2022/07/02 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28360) Support stop job operation in SQL client - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/02 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28361) Support show jobs operation in SQL client - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/02 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28362) Support savepoint statements in SQL client - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/02 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28363) Support drop savepoint statement in SQL client - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/02 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28364) Job types support Python - posted by "wu3396 (Jira)" <ji...@apache.org> on 2022/07/03 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28365) TO_TIMESTAMP lose precision beyond seconds - posted by "Lim Qing Wei (Jira)" <ji...@apache.org> on 2022/07/03 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28366) Support for custom query for JDBC Table API source connector - posted by "Jeya Prakash Thanigaivel (Jira)" <ji...@apache.org> on 2022/07/03 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28367) OffsetDateTime does not work with keyBy - posted by "Henrik Laxhuber (Jira)" <ji...@apache.org> on 2022/07/03 15:50:00 UTC, 0 replies.
- Python Job Support for the Kubernetes Operator - posted by Gyula Fóra <gy...@apache.org> on 2022/07/03 16:12:22 UTC, 11 replies.
- Re: [DISCUSS] FLIP-217 Support watermark alignment of source splits - posted by Thomas Weise <th...@apache.org> on 2022/07/04 01:58:57 UTC, 10 replies.
- [jira] [Created] (FLINK-28368) Get field type return result problem - posted by "hunter (Jira)" <ji...@apache.org> on 2022/07/04 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28369) Support PARSE_URL bulit-in function in Table API - posted by "LuNing Wang (Jira)" <ji...@apache.org> on 2022/07/04 05:10:00 UTC, 0 replies.
- [VOTE] FLIP-218: Support SELECT clause in CREATE TABLE(CTAS) - posted by Mang Zhang <zh...@163.com> on 2022/07/04 07:00:20 UTC, 15 replies.
- [jira] [Created] (FLINK-28370) Add close method for KafkaRecordSerializationSchema - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/07/04 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28371) Upgrade netty version in flink-akka-rpc - posted by "Michael Groys (Jira)" <ji...@apache.org> on 2022/07/04 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28372) Investigate Akka Artery - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/04 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28373) Read larger size of data sequentially for sort-shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/04 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28374) Some further improvements of sort-shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/04 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28375) Whether to consider adding other data type to support for last_value function - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2022/07/04 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28376) Reduce the number of IO threads for sort-shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/04 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28377) Enable to request less number of data reading buffers for sort-shuffle if there is no enough data - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/04 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28378) Use larger data reading buffer size for sort-shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/04 09:25:00 UTC, 0 replies.
- Re: Re: Re:Re: [DISCUSS] FLIP-218: Support SELECT clause in CREATE TABLE(CTAS) - posted by Jark Wu <im...@gmail.com> on 2022/07/04 09:32:20 UTC, 5 replies.
- Re: [NOTICE] Dev@ ML is not receiving jira issue created notifications - posted by Jark Wu <im...@gmail.com> on 2022/07/04 09:40:54 UTC, 0 replies.
- [jira] [Created] (FLINK-28379) Process produced no output for 900 seconds after/while running org.apache.flink.runtime.blob.BlobClientSslTest - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/04 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28380) Produce one intermediate dataset for multiple consumers consuming the same data - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/04 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28381) Add Spark Reader documentation - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/04 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28382) Introduce new compression algorithms of higher compression ratio - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/04 12:51:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-243: Dedicated Opensearch connectors - posted by Martijn Visser <ma...@apache.org> on 2022/07/04 14:22:46 UTC, 3 replies.
- [jira] [Created] (FLINK-28383) HDFS source: Trying to access closed classloader - posted by "Arseniy Tashoyan (Jira)" <ji...@apache.org> on 2022/07/04 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28384) Add CatalogLock support for HiveCatalog in table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/05 02:04:00 UTC, 0 replies.
- RE: [DISCUSS] FLIP-236: Asynchronous Job Submission - posted by zlzhang0122 <zl...@163.com> on 2022/07/05 03:00:39 UTC, 2 replies.
- [VOTE] FLIP-245: Source Supports Speculative Execution For Batch Job - posted by Jing Zhang <be...@gmail.com> on 2022/07/05 03:42:31 UTC, 5 replies.
- [External] Access issue with ParquetColumnarRowInputFormat - posted by Kamesh Chandran <ka...@grab.com.INVALID> on 2022/07/05 05:47:55 UTC, 0 replies.
- [jira] [Created] (FLINK-28385) Change the validator to return an error if the Jar URI is an empty string - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/07/05 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28386) Trigger an immediate checkpoint after all sources finished - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/07/05 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28387) Organizing Options in table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/05 06:26:00 UTC, 0 replies.
- [DISCUSS] FLIP-249: Flink Web UI Enhancement for Speculative Execution - posted by Gen Luo <lu...@gmail.com> on 2022/07/05 07:10:25 UTC, 10 replies.
- [jira] [Created] (FLINK-28388) Python doc build breaking nightly docs - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/07/05 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28389) Correct spec and status updates in FlinkDeploymentControllerTest - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/07/05 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28390) Allows RocksDB to configure FIFO Compaction to reduce CPU overhead. - posted by "ming li (Jira)" <ji...@apache.org> on 2022/07/05 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28391) DefaultBlocklistHandlerTest unstable - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/05 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28392) org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategyTest fails with exit code 239 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/05 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28393) Support AvroInputFormat in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/07/05 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28394) Python py36-cython: InvocationError for command install_command.sh fails with exit code 1 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/05 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28395) Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi fails with Elasticsearch exception [type=index_not_found_exception, reason=no such index] - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/05 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28396) Add doc versions to k8s operator docs - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/07/05 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28397) Source Supports Speculative Execution For Batch Job - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/07/05 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28398) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest( gets stuck - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/05 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28399) Refactor CheckedThread to accept runnable via constructor - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/05 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28400) Customize table source. After inheriting Richparallelsourcefunction class, data disorder under Multiple Parallelism - posted by "thecai (Jira)" <ji...@apache.org> on 2022/07/05 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28401) Remove snapshot repo from quickstarts for released versions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/05 09:07:00 UTC, 0 replies.
- [ACTION REQUESTED] Flink 1.16 Release Sync update - posted by Martijn Visser <ma...@apache.org> on 2022/07/05 09:32:24 UTC, 2 replies.
- [jira] [Created] (FLINK-28402) Create FailureHandlingResultSnapshot with the truly failed execution - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/07/05 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28403) SqlParserPos value for SqlCall is ambiguous - posted by "suheng.cloud (Jira)" <ji...@apache.org> on 2022/07/05 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28404) Annotation @InjectClusterClient do not work correctly - posted by "zl (Jira)" <ji...@apache.org> on 2022/07/05 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28405) Update used Confluent Platform images to v7.12 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/05 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28406) Build fails on retrieving org.pentaho:pentaho-aggdesigner-algorithm - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/07/05 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28407) Make Jenkins benchmark script more autonomous - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/07/05 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28408) FAQ / best practices page for Kubernetes Operator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/07/05 13:32:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.15.1, release candidate #1 - posted by David Anderson <da...@apache.org> on 2022/07/05 13:45:30 UTC, 0 replies.
- [DISCUSS] Creating benchmark channel in Apache Flink slack - posted by Anton Kalashnikov <ka...@yandex.com> on 2022/07/05 14:09:17 UTC, 7 replies.
- [jira] [Created] (FLINK-28409) Move FlinkContainerTestEnvironment and its dependencied into flink-connector-test-utils - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/07/05 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28410) Add Elasticsearch E2E test cases to the external repository - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/07/05 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28411) OperatorCoordinator exception may fail Session Cluster - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2022/07/05 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28412) kubernetes-client doesn't infer kubeconfig encryption algorithm and failed on k3s - posted by "wangqi (Jira)" <ji...@apache.org> on 2022/07/06 00:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28413) Support ParquetColumnarRowInputFormat in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/07/06 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28414) Using flink to query the hive table, an exception occurred, SQL validation failed. Failed to get table schema from deserializer - posted by "xcrossed (Jira)" <ji...@apache.org> on 2022/07/06 05:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28415) FLIP-221: Support Partial and Full Caching in Lookup Table Source - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/07/06 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28416) Add the new LookupFunction interface for Lookup table source - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/07/06 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28417) Add interface and default implementation for cache in lookup table - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/07/06 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28418) Add runtime provider interface for partial caching lookup - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/07/06 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28419) Add runtime provider interface for full caching lookup - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/07/06 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28420) Support partial lookup caching in lookup join runners - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/07/06 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28421) Support full caching in lookup table source - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/07/06 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28422) Fall back to lastest supported HiveShim when user use a higher hive version - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/07/06 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28423) ExecutionVertexCancelTest crashed with exit code 239 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/06 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28424) JdbcExactlyOnceSinkE2eTest hangs on Azure - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/06 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28425) E2E tests run out of disk space on Azure - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/06 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28426) PyFlink provides M1 wheel package - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/06 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28427) MiniClusterResource should not override rest port settings - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/06 09:10:00 UTC, 0 replies.
- Re: [DISCUSS] Publish flink-end-to-end-tests-common to Maven - posted by Alexander Fedulov <al...@ververica.com> on 2022/07/06 11:35:05 UTC, 1 replies.
- [jira] [Created] (FLINK-28428) Example in the Elasticsearch doc of fault tolerance section is missing - posted by "LuNing Wang (Jira)" <ji...@apache.org> on 2022/07/06 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28429) Reduce pyflink tests time - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/06 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28430) HiveFunctionWrapper should use UserClassLoader to load class - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/07/06 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28431) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception" - posted by "aresyhzhang (Jira)" <ji...@apache.org> on 2022/07/06 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28432) HiveCatalogTable only support using the latest columns as partition keys - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/07/06 19:47:00 UTC, 0 replies.
- [DISCUSS] FLIP-250: Support Customized Kubernetes Schedulers Proposal - posted by bo zhaobo <bz...@gmail.com> on 2022/07/07 01:15:13 UTC, 15 replies.
- [jira] [Created] (FLINK-28433) Allow connection to mysql through mariadb driver - posted by "PengLei (Jira)" <ji...@apache.org> on 2022/07/07 01:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28434) Extend "NestedProjectionUtil" to unify support for projection pushdown for physical fields or metadata only - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/07 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28435) Flink version 1.15.0 consumption Kafka has backpressure. - posted by "HunterHunter (Jira)" <ji...@apache.org> on 2022/07/07 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28436) test_multi_sessionjob.sh is failing intermittently - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/07/07 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28437) Document Engine Matrix and Build page - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/07 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28438) We should clear the error message after the session job is running/finished - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/07/07 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28439) Support SUBSTR and REGEXP built-in function in Table API - posted by "LuNing Wang (Jira)" <ji...@apache.org> on 2022/07/07 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28440) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed with restore - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/07 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28441) The parsing result of configuration `pipeline.cached-files` is incorrect - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2022/07/07 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28442) SplitGenerator should use Ordered Packing - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/07 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28443) Provide official Flink image for PyFlink - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/07/07 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28444) Support SUBSTR without parameter in SQL and Table API - posted by "LuNing Wang (Jira)" <ji...@apache.org> on 2022/07/07 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28445) Support dynamic configurations - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/07/07 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28446) Expose more information in PartitionDescriptor to support more optimized Shuffle Service - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2022/07/07 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28447) Create Kubernetes Operator PR template - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/07 10:26:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink ML Release 2.1.0, release candidate #2 - posted by Zhipeng Zhang <zh...@gmail.com> on 2022/07/07 10:35:13 UTC, 0 replies.
- [DISCUSS] FLIP-251: Support collecting arbitrary number of streams - posted by Chesnay Schepler <ch...@apache.org> on 2022/07/07 11:35:01 UTC, 3 replies.
- [jira] [Created] (FLINK-28448) BoundedDataTestBase has potential problem when compression is enable - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/07/07 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28449) [JUnit5 Migration] Module: flink-parquet - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/07/07 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28450) Run helm linter in k8s operator ci - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/07/07 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28451) HiveFunctionDefinitionFactory load udf using user classloader instead of thread context classloader - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/07/07 17:46:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.15.1 released - posted by David Anderson <da...@apache.org> on 2022/07/07 22:18:01 UTC, 1 replies.
- [jira] [Created] (FLINK-28452) "Reduce" and "aggregate" operations of "window_all" are supported in Python datastream API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/07/08 01:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28453) KafkaSourceLegacyITCase.testBrokerFailure hang on azure - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/08 02:51:00 UTC, 0 replies.
- 来自杨柳的邮件 - posted by 杨柳 <18...@163.com> on 2022/07/08 02:52:34 UTC, 0 replies.
- [jira] [Created] (FLINK-28454) Fix the wrong timestamp example of KafkaSource - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/07/08 05:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28455) pyflink tableResult collect to local timeout - posted by "zhou (Jira)" <ji...@apache.org> on 2022/07/08 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28456) Document streaming query page - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/08 07:27:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-218: Support SELECT clause in CREATE TABLE(CTAS) - posted by Mang Zhang <zh...@163.com> on 2022/07/08 08:00:14 UTC, 0 replies.
- [RESULT][VOTE] FLIP-245: Source Supports Speculative Execution For Batch Job - posted by Jing Zhang <be...@gmail.com> on 2022/07/08 08:18:50 UTC, 0 replies.
- [jira] [Created] (FLINK-28457) Flink add JobStatusHook support - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/07/08 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28458) Document append-only mode - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/08 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28459) Flink SQL supports non-atomic CREATE TABLE AS SELECT(CTAS) - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/07/08 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28460) Flink SQL supports atomic CREATE TABLE AS SELECT(CTAS) - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/07/08 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28461) PyFlink Table should add get_resolved_schema method - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/07/08 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28462) Table API support CREATE TABLE AS SELECT(CTAS) - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/07/08 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28463) Flink SQL syntax support CREATE TABLE AS SELECT(CTAS) - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/07/08 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28464) Support CsvReaderFormat in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/07/08 08:45:00 UTC, 0 replies.
- [DISCUSS] FLIP-247 Bulk fetch of table and column statistics for given partitions - posted by Jing Ge <ji...@ververica.com> on 2022/07/08 09:35:50 UTC, 13 replies.
- [jira] [Created] (FLINK-28465) commit.force-compact should always be true under batch mode - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/08 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28466) Update assertj to 3.23.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/07/08 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28467) AVRO Table API fails during schema evolution - posted by "Jaya Ananthram (Jira)" <ji...@apache.org> on 2022/07/08 12:20:00 UTC, 0 replies.
- [DISCUSS] FLIP-248: Introduce dynamic partition pruning - posted by godfrey he <go...@gmail.com> on 2022/07/08 14:12:05 UTC, 11 replies.
- [jira] [Created] (FLINK-28468) Creating benchmark channel in Apache Flink slack - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/07/08 14:48:00 UTC, 0 replies.
- [VOTE] Creating benchmark channel in Apache Flink slack - posted by Anton Kalashnikov <ka...@yandex.com> on 2022/07/08 14:58:43 UTC, 7 replies.
- [jira] [Created] (FLINK-28469) Setting a timer within broadcast applyToKeyedState() - posted by "James (Jira)" <ji...@apache.org> on 2022/07/08 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28470) Show source watermarks on dashboard - posted by "James (Jira)" <ji...@apache.org> on 2022/07/08 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28471) Translate hive_read_write.md into Chinese - posted by "eyys (Jira)" <ji...@apache.org> on 2022/07/08 17:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28472) Add JmStatus as a group for JobManagerDeploymentStatus count metrics - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/09 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28473) JobManager restart/failover doesn't trigger local recovery on TaskManagers - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2022/07/09 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28474) ChannelStateWriteResult may not fail after checkpoint abort - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/07/09 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28475) kafka connector won't stop when the stopping offset is zero - posted by "Leo zhang (Jira)" <ji...@apache.org> on 2022/07/09 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28476) Add metrics for Kubernetes API server access - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/07/09 16:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28477) Support to scan the history server dir with max depth - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/07/10 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28478) Session Cluster will lost if it failed between status recorded and deploy - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/07/10 04:02:00 UTC, 0 replies.
- Usage of PublicEvolving annotation - posted by Blake Wilson <bl...@yellowpapersun.com> on 2022/07/10 05:06:56 UTC, 2 replies.
- [jira] [Created] (FLINK-28479) Add latency histogram for resource state transitions - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/10 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28480) Forward timeControllerExecution time as histogram for JOSDK Metrics interface - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/10 17:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28481) Bump the fabric8 kubernetes-client to 5.12.3 - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/07/11 02:42:00 UTC, 0 replies.
- Re: Re: Re: [DISCUSS ] Make state.backend.incremental as true by default - posted by Yuan Mei <yu...@gmail.com> on 2022/07/11 03:53:12 UTC, 1 replies.
- [jira] [Created] (FLINK-28482) num-sorted-run.stop-trigger introduced a unstable merging - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/11 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28483) Basic schema evolution for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/11 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28484) UniqueKey inference should respect the semantics of null as well as consider the possibility of precision loss from implicit conversions - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/11 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28485) Structure examples better and add README/doc - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/11 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28486) [Flink][doc] Flink FileSystem SQL Connector Doc is not right - posted by "DingGeGe (Jira)" <ji...@apache.org> on 2022/07/11 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28487) Introduce configurable RateLimitingStrategy for Async Sink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2022/07/11 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28488) KafkaMetricWrapper does incorrect cast - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/11 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28489) FLIP-240: Introduce "ANALYZE TABLE" Syntax - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/11 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28490) Introduce "ANALYZE TABLE" Syntax in sql parser - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/11 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28491) Introduce APPROX_COUNT_DISTINCT aggregate function for batch sql - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/11 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28492) Support "ANALYZE TABLE" execution - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/11 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28493) Add document to describe "ANALYZE TABLE" syntax - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/11 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28494) Add new job status states to CRD - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2022/07/11 12:48:00 UTC, 0 replies.
- [DISCUSS] Add new JobStatus fields to Flink Kubernetes Operator CRD - posted by "WONG, DAREN" <da...@amazon.co.uk.INVALID> on 2022/07/11 13:17:04 UTC, 12 replies.
- [jira] [Created] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/07/11 15:39:00 UTC, 0 replies.
- Not able to run a simple table API file streaming sink - posted by Jaya Ananthram <ja...@ft.com.INVALID> on 2022/07/11 19:00:58 UTC, 1 replies.
- [jira] [Created] (FLINK-28496) Expose label selector support in k8s operator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/07/11 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28498) resource leak when job failed with unknown status In Application Mode - posted by "lihe ma (Jira)" <ji...@apache.org> on 2022/07/12 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28497) resource leak when job failed with unknown status In Application Mode - posted by "lihe ma (Jira)" <ji...@apache.org> on 2022/07/12 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28499) resource leak when job failed with unknown status In Application Mode - posted by "lihe ma (Jira)" <ji...@apache.org> on 2022/07/12 03:24:00 UTC, 0 replies.
- A common question on how to release resource in Flink job - posted by Bruce Zu <zu...@gmail.com> on 2022/07/12 03:42:08 UTC, 0 replies.
- [jira] [Created] (FLINK-28500) Add Transformer for Tokenizer - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/07/12 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28501) Add Transformer and Estimator for VectorIndexer - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/07/12 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28502) Add Transformer for RegexTokenizer - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/07/12 03:59:00 UTC, 0 replies.
- [VOTE] FLIP-249: Flink Web UI Enhancement for Speculative Execution - posted by Gen Luo <lu...@gmail.com> on 2022/07/12 05:46:19 UTC, 6 replies.
- [jira] [Created] (FLINK-28503) Fix invalid link in Python FAQ Document - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/07/12 06:53:00 UTC, 0 replies.
- [ANNOUNCE] Flink 1.16 feature freeze extended until August 9th, 2022 - posted by Martijn Visser <ma...@apache.org> on 2022/07/12 07:22:49 UTC, 0 replies.
- [jira] [Created] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid - posted by "nyingping (Jira)" <ji...@apache.org> on 2022/07/12 07:23:00 UTC, 0 replies.
- [ACTION REQUESTED] Help needed with test stabilities - posted by Martijn Visser <ma...@apache.org> on 2022/07/12 07:25:03 UTC, 0 replies.
- [jira] [Created] (FLINK-28505) Pulsar sink doesn't support topic auto creation - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/07/12 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28506) Pulsar sink don't support zero timestamp which may be provided by flink - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/07/12 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28507) supports set hadoop mount path in pod - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/07/12 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28508) Support SPLIT_INDEX and STR_TO_MAP built-in function in Table API - posted by "LuNing Wang (Jira)" <ji...@apache.org> on 2022/07/12 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28509) Support REVERSE built-in function in Table API - posted by "LuNing Wang (Jira)" <ji...@apache.org> on 2022/07/12 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28510) Support using new KafkaSink in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/07/12 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28511) Improve Spark dependencies and document - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/12 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28512) Select HashBasedDataBuffer and SortBasedDataBuffer dynamically based on the number of network buffers can be allocated for - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/12 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception - posted by "Jaya Ananthram (Jira)" <ji...@apache.org> on 2022/07/12 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28514) Remove data flush in SortMergeResultPartition - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/12 11:02:00 UTC, 0 replies.
- [DISCUSS] Kubernetes Operator 1.1.0 release - posted by Gyula Fóra <gy...@apache.org> on 2022/07/12 11:25:25 UTC, 1 replies.
- [jira] [Created] (FLINK-28515) The files in local recovery directory hasn't be clean up properly after checkpoint abort - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2022/07/12 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28516) UI is misleading when source doesn't emit watermark due to misconfigured idleness - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/12 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28517) Bump Flink version to 1.15.1 - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/07/12 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28518) Exception: AssertionError: Cannot add expression of different type to set in sub-query with ROW type - posted by "Koylubaev Nikita (Jira)" <ji...@apache.org> on 2022/07/12 11:55:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink ML 2.1.0 released - posted by Zhipeng Zhang <zh...@gmail.com> on 2022/07/12 12:04:28 UTC, 0 replies.
- [jira] [Created] (FLINK-28519) Fix the bug that SortMergeResultPartitionReadScheduler may not read data sequentially - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/12 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28520) RestClient doesn't use SNI TLS extension - posted by "Jean-Damien HATZENBUHLER (Jira)" <ji...@apache.org> on 2022/07/12 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28521) Hostname verification in ssl context is not working - posted by "Jean-Damien HATZENBUHLER (Jira)" <ji...@apache.org> on 2022/07/12 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28522) [JUnit5 Migration] Module: flink-sequence-file - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/07/12 23:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28523) LocalRecoveryITCase failed with AssertionError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/13 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28524) Translate "User-defined Sources & Sinks" - posted by "hunter (Jira)" <ji...@apache.org> on 2022/07/13 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28525) HiveDialectITCase.testTableWithSubDirsInPartitionDir failed with AssertJMultipleFailuresError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/13 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28526) Fail to lateral join with UDTF from Table with timstamp column - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/07/13 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28527) Fail to lateral join with UDTF from Table with timstamp column - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/07/13 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28528) Table.getSchema fails on table with watermark - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/07/13 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28529) ChangelogPeriodicMaterializationSwitchStateBackendITCase.testSwitchFromDisablingToEnablingInClaimMode failed with CheckpointException: Checkpoint expired before completing - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/13 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28530) Improvement of conditions extraction that can be pushed into join inputs - posted by "Alexander Trushev (Jira)" <ji...@apache.org> on 2022/07/13 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28531) Shutdown cluster after history server archive finished - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/07/13 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28532) Support InputFormat as full caching provider in lookup table source - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/07/13 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28533) SchemaChange supports updateColumnNullability and updateColumnComment - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/13 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28534) Spec change event is triggered twice per upgrade - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/13 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28535) Support create database/table for SparkCatalog - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/13 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28536) Adds an internal abstraction `PhysicalDagProcessor` for physical plan processing - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/13 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28537) OffsetsInitializer.timestamp() fails if no element exceeds timestamps - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/13 11:03:00 UTC, 0 replies.
- [REQUEST] Edit Permissions for FLIP - posted by Steve Yurong Su <ro...@apache.org> on 2022/07/13 11:55:00 UTC, 5 replies.
- [jira] [Created] (FLINK-28538) Eagerly emit a watermark the first time we exceed Long.MIN_VALUE - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/13 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28539) Enable CompactionDynamicLevelBytes in FLASH_SSD_OPTIMIZED - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/07/13 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28540) Unaligned checkpoint waiting in 'start delay' with AsyncDataStream - posted by "Nathan P Sharp (Jira)" <ji...@apache.org> on 2022/07/13 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28541) Add OwnerReferences to FlinkDeployment CR in jobmanager Deployment - posted by "ChangZhuo Chen (陳昌倬) (Jira)" <ji...@apache.org> on 2022/07/13 16:16:00 UTC, 0 replies.
- [VOTE] FLIP-243: Dedicated Opensearch connectors - posted by Andriy Redko <dr...@gmail.com> on 2022/07/13 20:22:11 UTC, 4 replies.
- [jira] [Created] (FLINK-28542) [JUnit5 Migration] FileSystemBehaviorTestSuite - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/07/13 22:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28543) After compiling Flink, you should provide the artifact file in tar format instead of a folder - posted by "MengYao (Jira)" <ji...@apache.org> on 2022/07/14 01:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28544) Elasticsearch6SinkE2ECase failed with no space left on device - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/14 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28545) FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool failed with TimeoutException: Topic flink-kafka-producer-fail-before-notify not present in metadata after 60000 ms - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/14 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28546) Add the release logic for py39 and m1 wheel package - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/14 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28547) Add IT cases for SpeculativeScheduler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/07/14 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28548) The commit partition base path is not created when no data is sent which may cause FileNotFoundException - posted by "Liu (Jira)" <ji...@apache.org> on 2022/07/14 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28549) Support DataStream PythonProcessOperator in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/14 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28550) Remove the unused field in SortMergeSubpartitionReader - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/14 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28551) Store the number of bytes instead of the number of buffers in index entry for sort-shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/14 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28552) GenerateUtils#generateCompare supports MULTISET and MAP - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/14 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28553) The serializer in StateMap has not been updated when metaInfo of StateTable updated - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/07/14 13:16:00 UTC, 0 replies.
- Re: Flink running same task on different Task Manager - posted by Great Info <gu...@gmail.com> on 2022/07/14 16:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28554) Kubernetes-Operator allow readOnlyRootFilesystem securityContext - posted by "Tim (Jira)" <ji...@apache.org> on 2022/07/14 16:50:00 UTC, 0 replies.
- Re: [DISCUSS] Contribution of Multi Cluster Kafka Source - posted by Mason Chen <ma...@gmail.com> on 2022/07/14 21:31:21 UTC, 0 replies.
- [jira] [Created] (FLINK-28555) Update history server documentation - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/07/15 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28556) Extract header fields of Buffer into a BufferHeader class for blocking shuffle file IO - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/15 02:40:00 UTC, 0 replies.
- [DISCUSS][FLINK-26014]Document how to use the working directory for faster local recoveries - posted by Haihang Jing <ge...@gmail.com> on 2022/07/15 03:08:21 UTC, 0 replies.
- [jira] [Created] (FLINK-28557) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest Process produced no output for 900 seconds - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/15 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28558) HistoryServer log retrieval configuration improvement - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/07/15 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28559) Support DataStream PythonKeyedProcessOperator in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/15 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28560) Support Spark 3.3 profile for SparkSource - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2022/07/15 03:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28561) Merge subpartition shuffle data read request for better sequential IO - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/15 06:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28562) Rocksdb state backend is too slow when using AggregateFunction - posted by "Yue Shang (Jira)" <ji...@apache.org> on 2022/07/15 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28563) Add Transformer for VectorSlicer - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/07/15 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28564) Update NOTICE/LICENCE files for 1.1.0 release - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/07/15 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28565) Create NOTICE file for flink-table-store-hive-catalog - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/15 07:33:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-249: Flink Web UI Enhancement for Speculative Execution - posted by Gen Luo <lu...@gmail.com> on 2022/07/15 07:49:59 UTC, 0 replies.
- [jira] [Created] (FLINK-28566) Adds materialization support to eliminate the non determinism generated by lookup join node - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/15 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28567) Introduce predicate inference from one side of join to the other - posted by "Alexander Trushev (Jira)" <ji...@apache.org> on 2022/07/15 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28568) Implements a new lookup join operator (sync mode only) with state to eliminate the non determinism - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/15 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28569) SinkUpsertMaterializer should be aware of the input upsertKey if it is not empty - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/15 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28570) Introduces a StreamPhysicalPlanChecker to validate if there's any non-deterministic updates which may cause wrong result - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/15 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28571) Add Chi-squared test as Transformer to ml.feature - posted by "Simon Tao (Jira)" <ji...@apache.org> on 2022/07/15 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28572) FlinkSQL executes Table.execute multiple times on the same Table, and changing the Table.execute code position will produce different phenomena - posted by "Andrew Chan (Jira)" <ji...@apache.org> on 2022/07/15 13:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-28573) Nested type will lose nullability when converting from TableSchema - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/15 15:00:03 UTC, 0 replies.
- [DISCUSS] FLIP-252: Amazon DynamoDB Sink Connector - posted by Danny Cranmer <da...@apache.org> on 2022/07/15 17:50:31 UTC, 2 replies.
- [RESULT][VOTE] Creating benchmark channel in Apache Flink slack - posted by Anton Kalashnikov <ka...@yandex.com> on 2022/07/15 19:50:15 UTC, 0 replies.
- [jira] [Created] (FLINK-28574) Bump the fabric8 kubernetes-client to 6.0.0 - posted by "ConradJam (Jira)" <ji...@apache.org> on 2022/07/16 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28575) support hbase connector 2.2 to write to hbase 2.4.9 - posted by "Zhen Wang (Jira)" <ji...@apache.org> on 2022/07/16 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28576) Kafka's two source api performance differences - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2022/07/17 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28577) 1.15.1 web ui console report error about checkpoint size - posted by "nobleyd (Jira)" <ji...@apache.org> on 2022/07/17 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28578) Upgrade Spark version of flink-table-store-spark to 3.1.3, 3.2.2 or 3.3.0 or later - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2022/07/18 01:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28579) Supports predicate testing for new columns - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/18 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28580) Predicate supports unknown stats - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/18 03:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28581) Test Changelog StateBackend V2 Manually - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/07/18 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28582) LSM tree structure may be incorrect when multiple jobs are committing into the same bucket - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/07/18 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28583) make flink dist log4j dependency simple and clear - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/07/18 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28584) Add an option to ConfigMap that can be set to immutable - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2022/07/18 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28585) Speculative execution for InputFormat sources - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/07/18 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28586) Speculative execution for new sources - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/07/18 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28587) FLIP-249: Flink Web UI Enhancement for Speculative Execution - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/07/18 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28588) Enhance REST API for Speculative Execution - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/07/18 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28589) Enhance Web UI for Speculative Execution - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/07/18 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28590) flink on yarn checkpoint exception - posted by "wangMu (Jira)" <ji...@apache.org> on 2022/07/18 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28591) Array> is not serialized correctly - posted by "Andrzej Swatowski (Jira)" <ji...@apache.org> on 2022/07/18 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28592) Implement custom resource counters as counters not gauges - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/07/18 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28593) Introduce default ingress templates at operator level - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/07/18 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28594) Add metrics for FlinkService - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/07/18 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28595) KafkaSource should not read metadata of unmatched regex topics - posted by "Afzal Mazhar (Jira)" <ji...@apache.org> on 2022/07/18 17:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28596) Support writing arrays to postgres array columns in Flink SQL JDBC connector - posted by "Bobby Richard (Jira)" <ji...@apache.org> on 2022/07/18 21:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28597) Empty checkpoint folders not deleted on job cancellation if their shared state is still in use - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/07/18 23:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28598) ClusterEntryPoint can't get the real exit reason when shutting down - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2022/07/19 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28599) Adding FlinkJoinToMultiJoinRule to support left/right outer join can be translated to multi join - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/07/19 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28600) Support FilterPushDown in flink-connector-jdbc - posted by "Hailin Wang (Jira)" <ji...@apache.org> on 2022/07/19 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28601) Support FeatureHasher in FlinkML - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/07/19 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28602) Changelog cannot close stream normally while enabling compression - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/07/19 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28603) Flink runtime.rpc.RpcServiceUtils code style - posted by "wuqingzhi (Jira)" <ji...@apache.org> on 2022/07/19 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28604) job failover and not restore from checkpoint in zookeeper HA mode - posted by "KevinyhZou (Jira)" <ji...@apache.org> on 2022/07/19 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28605) Throw exception intentionally when new snapshots are committed during restore - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/07/19 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28606) Preserve distributed consistency of OperatorEvents from OperatorCoordinator to subtasks - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/07/19 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28607) Table-API print connector encoding issue - posted by "Sarah Cho (Jira)" <ji...@apache.org> on 2022/07/19 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28608) Make Hadoop FS token renewer configurable - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/07/19 07:46:00 UTC, 0 replies.
- [VOTE] FLIP-251: Support collecting arbitrary number of streams - posted by Chesnay Schepler <ch...@apache.org> on 2022/07/19 08:26:15 UTC, 5 replies.
- [SUMMARY] Flink 1.16 release sync of 2022-07-19 - posted by Xingbo Huang <hx...@gmail.com> on 2022/07/19 08:56:45 UTC, 0 replies.
- [jira] [Created] (FLINK-28609) Flink-Pulsar connector fails on larger schemas - posted by "Jacek Wislicki (Jira)" <ji...@apache.org> on 2022/07/19 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28610) Enable speculative execution of sources - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/07/19 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28611) Support ElementwiseProduct in FlinkML - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/07/19 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28612) Cancel pending slot allocation after canceling executions - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/07/19 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28613) PyFlink 1.15 unable to start in Application Mode in k8s - posted by "Clive Wong (Jira)" <ji...@apache.org> on 2022/07/19 13:31:00 UTC, 0 replies.
- [DISCUSS] TLS issues - posted by Jean-Damien Hatzenbuhler <je...@contentsquare.com.INVALID> on 2022/07/19 13:55:01 UTC, 2 replies.
- [VOTE] FLIP-238: Introduce FLIP-27-based Data Generator Source - posted by Alexander Fedulov <al...@ververica.com> on 2022/07/19 19:31:08 UTC, 5 replies.
- [DISCUSS] Handling of removed splits for FLIP-27 - posted by Xinbin Huang <bi...@apache.org> on 2022/07/19 21:04:03 UTC, 0 replies.
- 邮件退订 - posted by cason0126 <ca...@163.com> on 2022/07/20 03:49:33 UTC, 1 replies.
- [jira] [Created] (FLINK-28614) Empty local state folders not cleanup on retrieving local state - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/07/20 05:05:00 UTC, 0 replies.
- [ANNOUNCE] Table Store release-0.2 branch cut - posted by Jingsong Li <ji...@gmail.com> on 2022/07/20 06:50:04 UTC, 2 replies.
- [DISCUSS] Replace Attempt column with Attempt Number on the subtask list page of the Web UI - posted by Gen Luo <lu...@gmail.com> on 2022/07/20 07:24:20 UTC, 2 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.1.0, release candidate #1 - posted by Gyula Fóra <gy...@apache.org> on 2022/07/20 09:47:24 UTC, 8 replies.
- [VOTE] FLIP-252: Amazon DynamoDB Sink Connector - posted by Danny Cranmer <da...@apache.org> on 2022/07/20 13:13:12 UTC, 8 replies.
- [jira] [Created] (FLINK-28615) Add K8s recommend labels to the deployments, services created by operator - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/07/20 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28616) Quickstart and examples docs should use configured stable version - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/20 17:01:00 UTC, 0 replies.
- [DISCUSS] FLIP-246: Multi Cluster Kafka Source - posted by Mason Chen <ma...@gmail.com> on 2022/07/20 17:35:29 UTC, 1 replies.
- [GitHub] [flink-connector-redis] knaufk commented on pull request #2: [FLINK-15571][connector][WIP] Redis Stream connector for Flink - posted by GitBox <gi...@apache.org> on 2022/07/20 21:16:42 UTC, 0 replies.
- [jira] [Created] (FLINK-28617) Support stop job statement in SqlGatewayService - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/21 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28618) Cannot use hive.dialect on master - posted by "liubo (Jira)" <ji...@apache.org> on 2022/07/21 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28619) flink sql window aggregation using early fire will produce empty data - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2022/07/21 03:28:00 UTC, 0 replies.
- 来自Howie Yang的邮件 - posted by Howie Yang <ha...@126.com> on 2022/07/21 07:13:42 UTC, 0 replies.
- [jira] [Created] (FLINK-28620) SQL Client doesn't properly print values of INTERVAL type - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/07/21 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28621) Register JavaTimeModule in all internal object mappers - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/21 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28622) Can't restore a flink job that uses Table API and Kafka connector with savepoint - posted by "Nathan (Jira)" <ji...@apache.org> on 2022/07/21 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28623) Optimize the use of off heap memory by blocking and hybrid shuffle reader - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/07/21 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28624) CsvReaderFormat should accept CsvMapper factory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/21 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28625) Guard against changing target session deployment for sessionjob - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/21 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28626) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with FileNotFoundException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/21 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28627) KafkaITCase.testBrokerFailure failed with TestTimedOutException: test timed out after 60000 milliseconds - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/21 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28628) Introduce operation execution plugin - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/07/21 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28629) Allow to getCatalogs in the HiveServer2 Endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/07/21 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28631) Allow to GetFunctions in the HiveServer2 Endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/07/21 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28630) Allow to GetSchemas in the HiveServer2 Endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/07/21 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28632) Allow to GetColumns/GetTableTypes/GetPrimaryKeys in the HiveServer2 Endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/07/21 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28633) Allow to GetTables in the HiveServer2 Endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/07/21 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28634) Add a simple Json (De) SerializationSchema - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/21 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28635) HybridSourceReader availabilityFuture always completed - posted by "hongfei zhang (Jira)" <ji...@apache.org> on 2022/07/21 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28636) Add utility to test POJO compliance - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/21 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28637) High vulnerability in flink-kubernetes-operator-1.1.0-shaded.jar - posted by "James Busche (Jira)" <ji...@apache.org> on 2022/07/21 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28638) Restrict ALTER TABLE from setting write-mode - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/22 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28639) Preserve distributed consistency of OperatorEvents from subtasks to OperatorCoordinator - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/07/22 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28640) Allow BlocklistDeclarativeSlotPool to accept duplicated slot offers - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/07/22 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28641) Remove StreamingFileSink - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/22 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28642) Cannot create sink for Temporary table in table store catalog - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/22 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28643) Job archive file contains too much Job json file on Flink HistoryServer - posted by "LI Mingkun (Jira)" <ji...@apache.org> on 2022/07/22 09:06:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-251: Support collecting arbitrary number of streams - posted by Chesnay Schepler <ch...@apache.org> on 2022/07/22 09:06:35 UTC, 0 replies.
- [jira] [Created] (FLINK-28645) Clean up logging in FlinkService / Reconciler - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/22 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28644) Support collecting arbitrary number of streams - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/22 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28646) Handle scaling operation separately in reconciler/service - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/22 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28647) Remove separate error handling and adjust documentation for CLAIM mode + RocksDB native savepoint - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/07/22 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28648) Allow session deletion to block on any running job - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/22 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28649) Allow adopting unmanaged jobs as FlinkSessionJob resource - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/22 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28650) Flink SQL Parsing bug for METADATA - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2022/07/22 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28651) JarRunHandler ignores restore mode set in the configuration - posted by "Nuno Afonso (Jira)" <ji...@apache.org> on 2022/07/22 16:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28652) Amazon Linux 2 based Docker container for Flink - posted by "Alexey Petrenko (Jira)" <ji...@apache.org> on 2022/07/22 17:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords - posted by "Peleg Tsadok (Jira)" <ji...@apache.org> on 2022/07/23 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28654) Operator includes JMX metric reporter - posted by "Dylan Meissner (Jira)" <ji...@apache.org> on 2022/07/23 17:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28655) Support show jobs statement in SqlGatewatService - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/24 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28656) Support savepoint statements in SqlGatewayService - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/24 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28657) Support drop savepoint statement in SqlGatewayService - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/24 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28658) Add document for job lifecycle statements - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/24 02:40:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.1.0, release candidate #1 - posted by Gyula Fóra <gy...@apache.org> on 2022/07/24 08:27:27 UTC, 0 replies.
- [jira] [Created] (FLINK-28659) [JUnit5 Migration] Module: flink-java - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/07/24 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28660) Simplify logs of blocklist - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/07/24 14:29:00 UTC, 0 replies.
- [VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal - posted by bo zhaobo <bz...@gmail.com> on 2022/07/25 01:37:56 UTC, 9 replies.
- [jira] [Created] (FLINK-28661) Introduce generic mode for table store catalog - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/25 02:09:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.1.0 released - posted by Gyula Fóra <gy...@apache.org> on 2022/07/25 02:44:04 UTC, 1 replies.
- [jira] [Created] (FLINK-28662) Compaction may block job cancelling - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/07/25 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28663) Allow multiple downstream consumer job vertices sharing the same intermediate dataset at scheduler side - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/25 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28664) Support AvroWriters in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/07/25 06:59:00 UTC, 0 replies.
- [VOTE] FLIP-247 Bulk fetch of table and column statistics for given partitions - posted by Jing Ge <ji...@ververica.com> on 2022/07/25 07:09:20 UTC, 4 replies.
- [jira] [Created] (FLINK-28665) flink-table-store-benchmark-jar-with-dependencies.jar NOTICE file is wrong - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/25 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28666) Alter spark table's primary key should throw exception - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/25 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28667) "evictor" operations of "window_all" are supported in Python datastream API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/07/25 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28668) Fail to create partitioned table without primary key for Spark - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/25 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28669) FileStoreExpireTest.testExpireWithTime failed - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/25 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28670) Documentation of spark2 is wrong - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/25 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28671) Update Spark3 to create/drop table in Compatibility Matrix - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/25 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28672) properties.allow.auto.create.topics无效 - posted by "songwenbin (Jira)" <ji...@apache.org> on 2022/07/25 10:56:00 UTC, 0 replies.
- [GitHub] [flink-connector-redis] sazzad16 commented on pull request #2: [FLINK-15571][connector][WIP] Redis Stream connector for Flink - posted by GitBox <gi...@apache.org> on 2022/07/25 10:57:26 UTC, 0 replies.
- [jira] [Created] (FLINK-28673) Migrate Flink ML to Flink 1.15.1 - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/07/25 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28674) EqualiserCodeGenerator generates wrong equaliser for Timestamp fields in BinaryRowData - posted by "Weike Dong (Jira)" <ji...@apache.org> on 2022/07/25 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28675) AvroDeserializationSchema should eagerly validate that class is SpecificRecord - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/25 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28676) Update copyright year to 2014-2022 in NOTICE files - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2022/07/25 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28677) Primary key should not be null when creating Spark table - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/25 14:55:00 UTC, 0 replies.
- BOUNDED VS UNBOUNDED - posted by 하지양 <ha...@koreaspacedata.com> on 2022/07/25 23:00:37 UTC, 1 replies.
- [jira] [Created] (FLINK-28678) Support SQL hint for Filter, SetOp, Sort, Window, Values - posted by "xuyang (Jira)" <ji...@apache.org> on 2022/07/26 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28679) HiveServer2Endpoint compile failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/26 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28680) No space left on device on Azure e2e_2_ci tests - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/26 02:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28681) The number of windows allocated by sliding windows is inaccurate, when the window length is irregular - posted by "nyingping (Jira)" <ji...@apache.org> on 2022/07/26 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28682) support join hint in flink batch - posted by "xuyang (Jira)" <ji...@apache.org> on 2022/07/26 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28683) Modify changelog-file to changelog-producer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/26 04:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28684) NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/07/26 04:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28685) Optimize CatalogManager getTable implementation - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/07/26 04:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28686) Spark table with column comment cannot be read/write by Flink - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/26 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28687) BucketSelector is wrong when hashcode is negative - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/26 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28688) Support DataStream PythonWindowOperator in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/26 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28689) Optimize Spark documentation to Catalog and Dataset - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/26 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28690) UpdateSchema#fromCatalogTable lost column comment - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/26 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28691) Improve cache hit rate of generated class - posted by "Zou (Jira)" <ji...@apache.org> on 2022/07/26 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28692) Check warehouse path in CatalogFactory - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/26 10:49:00 UTC, 0 replies.
- [SUMMARY] Flink 1.16 release sync of 2022-07-26 - posted by Xingbo Huang <hx...@gmail.com> on 2022/07/26 11:49:44 UTC, 0 replies.
- [jira] [Created] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression - posted by "Hongbo (Jira)" <ji...@apache.org> on 2022/07/26 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28694) Set pipeline.name to resource name by default for Applications - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/26 13:54:00 UTC, 0 replies.
- [VOTE] FLIP-248: Introduce dynamic partition pruning - posted by godfrey he <go...@gmail.com> on 2022/07/26 14:00:17 UTC, 5 replies.
- [jira] [Created] (FLINK-28695) Fail to send partition request to restarted taskmanager - posted by "Simonas (Jira)" <ji...@apache.org> on 2022/07/26 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28696) Notify all newlyAdded/Merged blocked nodes to BlocklistListener - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/07/26 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID - posted by "Josh Mahonin (Jira)" <ji...@apache.org> on 2022/07/26 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/07/27 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28699) Native rocksdb full snapshot in non-incremental checkpointing - posted by "Lihe Ma (Jira)" <ji...@apache.org> on 2022/07/27 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28700) Table store sink fails to commit for Flink 1.14 batch job - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/07/27 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28701) Minimize the explosion range during failover for hybrid shuffle - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/07/27 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28702) Why can't "scan.incremental.snapshot.enabled" be set when using datastream source in MySQL CDC connector - posted by "liujian (Jira)" <ji...@apache.org> on 2022/07/27 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28703) Describe partitioned spark table lost partition info - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/27 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28704) Document should add a description that change-log mode cannot support map and multiset data type - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/27 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28705) Update copyright year to 2014-2022 in NOTICE files - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2022/07/27 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28706) FLIP-248: Introduce dynamic partition pruning - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/27 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28707) Introduce interface SupportsDynamicPartitionPruning - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/27 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28708) Introduce planner rules to optimize dpp pattern - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/27 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28709) Implement dynamic filtering operators - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/27 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28710) Transform dpp ExecNode to StreamGraph - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/27 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28711) Hive connector implements SupportsDynamicFiltering interface - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/27 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28712) Default Changelog all when changelog producer is input - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/27 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28713) Remove unused curator-test dependency from flink-test-utils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/27 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28714) Resolve CVEs from beam-vendor-grpc-1_26_0-0.3 - posted by "Bilna (Jira)" <ji...@apache.org> on 2022/07/27 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28715) Throw better exception when file not found in reading - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/27 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28716) uploading multiple files/form datas fail randomly when use rest api - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2022/07/27 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28717) Table Store Hive connector will throw exception if primary key fields are not selected - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/07/27 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28718) SinkSavepointITCase.testRecoverFromSavepoint is unstable - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/27 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly. - posted by "Mykyta Mykhailenko (Jira)" <ji...@apache.org> on 2022/07/27 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28720) Add Hive partition when flink has no data to write - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/07/27 12:02:00 UTC, 0 replies.
- I want to contribute to Apache Flink. - posted by 黄如飞 <13...@qq.com.INVALID> on 2022/07/27 12:08:21 UTC, 3 replies.
- [jira] [Created] (FLINK-28721) Support Protobuf in DataStream API - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/27 18:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28722) Hybrid Source should use .equals() for Integer comparison - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2022/07/27 22:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28723) Support json format to serialize the MapData when its key is not STRING - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/07/28 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28724) Test - posted by "HuangRufei (Jira)" <ji...@apache.org> on 2022/07/28 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28725) flink-kubernetes-operator taskManager: replicas: 2 error - posted by "lizu18xz (Jira)" <ji...@apache.org> on 2022/07/28 05:07:00 UTC, 0 replies.
- 来自梁勃的邮件 - posted by 梁勃 <18...@163.com> on 2022/07/28 06:16:07 UTC, 0 replies.
- [jira] [Created] (FLINK-28726) CompileException: BoundedOverAggregateHelper must implement method AggsHandeFunction.setWindowSize(int) - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/28 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28727) Flink Source supports SupportsLimitPushDown - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/07/28 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28728) Support to set the end offset for streaming connector - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2022/07/28 07:56:00 UTC, 0 replies.
- Ask for permission to create a FLIP in Confluence - posted by Hannan Kan <ha...@foxmail.com> on 2022/07/28 08:08:02 UTC, 0 replies.
- [jira] [Created] (FLINK-28729) flink hive catalog don't support jdk11 - posted by "jeff-zou (Jira)" <ji...@apache.org> on 2022/07/28 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28730) Add Tez execution engine test for Table Store Hive connector - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/07/28 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28731) Logging of global config should take dynamic properties into account - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/28 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28732) Deprecate ambiguous StateTTLConfig#cleanFullSnapshot API - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/07/28 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28733) jobmanager.sh should support dynamic properties - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/28 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28734) Configurable role(binding) names in the helm chart - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/07/28 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28735) Deprecate host/webuiport parameter of jobmanager.sh - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/28 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28736) Add APPROX_PERCENTILE function - posted by "Josh Mahonin (Jira)" <ji...@apache.org> on 2022/07/28 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28737) FlinkRelMdUpsertKeys should consider the case when the condition of a calc node is non-deterministic - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/29 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28738) [doc] Add a user doc about the correctness for non-deterministic updates - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/29 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28739) Illegal State for checkpoint in LogisticRegressionTest.test_get_model_data - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/07/29 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28740) Support CsvBulkWriter in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/07/29 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28741) Unexpected result if insert 'false' to boolean column - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/07/29 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28742) Table.to_pandas fails with lit("xxx") - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/07/29 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28743) Support validating the determinism for StreamPhysicalMatchRecognize - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/07/29 08:22:00 UTC, 0 replies.
- [GitHub] [flink-connector-redis] eskabetxe opened a new pull request, #3: [FLINK-15571] Add Redis sink - posted by GitBox <gi...@apache.org> on 2022/07/29 09:10:59 UTC, 0 replies.
- [jira] [Created] (FLINK-28744) Upgrade Calcite version to 1.31 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/29 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28745) Support DataStream PythonCoProcessOperator and PythonKeyedCoProcessOperator in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/29 10:59:00 UTC, 0 replies.
- [GitHub] [flink-connector-redis] MartijnVisser merged pull request #4: [hotfix] Add CI and label configurator - posted by GitBox <gi...@apache.org> on 2022/07/29 11:29:09 UTC, 0 replies.
- [jira] [Created] (FLINK-28746) Add test for sequential read - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/07/29 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28747) "target_id can not be missing" in HTTP statefun request - posted by "Stephan Weinwurm (Jira)" <ji...@apache.org> on 2022/07/29 23:25:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-248: Introduce dynamic partition pruning - posted by godfrey he <go...@gmail.com> on 2022/07/30 01:54:29 UTC, 0 replies.
- [jira] [Created] (FLINK-28748) Translate "SELECT DISTINCT" page into Chinese - posted by "liujingmao (Jira)" <ji...@apache.org> on 2022/07/30 05:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28749) Add resource type to KubernetesResourceNamespaceMetricGroup scope - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/30 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28750) Whether to add comment for hive table - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2022/07/30 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28751) Poor performance of the built in json_value function - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/07/30 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28752) Add the json plan support in Python UDFs - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/30 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28753) Improve FilterIntoJoinRule which could push some predicate to another side - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/07/30 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28754) document that Java 8 is required to build table store - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/07/30 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28755) Error when switching from stateless to savepoint upgrade mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/07/31 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28756) Can't write nested object to parquet flink 1.15.1 - posted by "Jonathan diamant (Jira)" <ji...@apache.org> on 2022/07/31 12:26:00 UTC, 0 replies.