You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-30255) Throw exception for upper case fields is used in hive metastore - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/01 02:25:00 UTC, 0 replies.
- FW: Why streaming over agg not supporting ranged upper boundary? - posted by Renjie Liu <li...@gmail.com> on 2022/12/01 03:16:17 UTC, 0 replies.
- [DISCUSS] FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store - posted by Shammon FY <zj...@gmail.com> on 2022/12/01 03:48:52 UTC, 14 replies.
- [VOTE] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax - posted by Shengkai Fang <fs...@gmail.com> on 2022/12/01 04:20:15 UTC, 9 replies.
- [jira] [Created] (FLINK-30256) LogalWindowAgg can set the chaining Strategy to always - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2022/12/01 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30257) SqlClientITCase#testMatchRecognize failed - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/01 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30258) PyFlink supports closing loop back server - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/12/01 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30259) Using flink Preconditions Util instead of uncertain Assert keyword to do checking - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2022/12/01 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30260) FLIP-271: Autoscaling - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2022/12/01 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30261) PartiallyFinishedSourcesITCase.test timed out while waiting for tasks to finish - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/01 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30262) UpsertKafkaTableITCase failed when starting the container because waiting for a port timed out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/01 11:31:00 UTC, 0 replies.
- [RESULT][VOTE] Release flink-connector-cassandra, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2022/12/01 12:18:09 UTC, 0 replies.
- [jira] [Created] (FLINK-30263) Introduce schemas table to table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/01 12:19:00 UTC, 0 replies.
- Re: [jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint - posted by Fabian Paul <fp...@apache.org> on 2022/12/01 12:21:59 UTC, 0 replies.
- [jira] [Created] (FLINK-30264) Set session job status to FAILED if already have retried max attempts - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/12/01 13:03:00 UTC, 0 replies.
- Re: [DISCUSS]Introduce a time-segment based restart strategy - posted by Dong Lin <li...@gmail.com> on 2022/12/01 13:46:08 UTC, 0 replies.
- [jira] [Created] (FLINK-30265) Turn on debug logs for k8s operator e2e tests in CI when tests failing - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/01 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30266) Recovery reconciliation loop fails if no checkpoint has been created yet - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2022/12/01 14:43:00 UTC, 0 replies.
- [DISCUSS] Retroactively externalize some connectors for 1.16 - posted by Chesnay Schepler <ch...@apache.org> on 2022/12/01 15:01:43 UTC, 8 replies.
- [jira] [Created] (FLINK-30267) PyFlink YARN per-job on Docker test failed because it could not build hadoop image - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/01 15:40:00 UTC, 0 replies.
- RE: [VOTE] Release flink-connector-dynamodb v3.0.0, release candidate #0 - posted by Yura Gusev <yu...@gmail.com> on 2022/12/01 21:49:27 UTC, 5 replies.
- [jira] [Created] (FLINK-30268) HA metadata and other cluster submission related errors should not throw DeploymentFailedException - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/01 22:12:00 UTC, 0 replies.
- Re: [DISCUSS] assign SQL Table properties from environment variables - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2022/12/02 00:36:33 UTC, 1 replies.
- [jira] [Created] (FLINK-30269) Validate table name for metadata table - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/02 05:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30270) FlinkJoinToMultiJoinRule incorrectly combines Left/Right outer join to MultiJoin - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/12/02 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30271) Introduce Table.copy from dynamic options - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/02 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30272) Introduce a Predicate Visitor - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/02 07:59:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-275: Support Remote SQL Client Based on SQL Gateway - posted by yu zelin <yu...@gmail.com> on 2022/12/02 08:09:16 UTC, 11 replies.
- Re: [DISCUSS] Issue tracking workflow - posted by Piotr Nowojski <pn...@apache.org> on 2022/12/02 08:19:16 UTC, 0 replies.
- [jira] [Created] (FLINK-30273) Introduce RecordReaderUtils.transform to transform RecordReader - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/02 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30274) Add commons-collections4 to replace commons-collections 3.x - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2022/12/02 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30275) TaskExecutorTest.testSharedResourcesLifecycle fails - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/02 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30276) [umbrella] Flink free for table store core - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/02 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30277) Allow PYTHONPATH of Python Worker to be configurable - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/12/02 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30278) Unexpected config mutation in SinkTransformationTranslator - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/12/02 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30279) Move existing RabbitMQ connector code from Flink repo to dedicated RabbitMQ repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/02 12:43:00 UTC, 0 replies.
- [VOTE] Release flink-connector-hbase v3.0.0, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2022/12/02 13:04:39 UTC, 5 replies.
- Re: [DISCUSS] FLIP-269: Properly Handling the Processing Timers on Job Termination - posted by Dawid Wysakowicz <dw...@apache.org> on 2022/12/02 13:20:35 UTC, 3 replies.
- [jira] [Created] (FLINK-30280) Default operator logging configuration is broken - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2022/12/02 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30281) Turn off operator metrics for e2e tests - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/02 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30282) Logical type ROW lost inner field's nullability after convert to RelDataType - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/12/02 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30283) Evaluate operator error log entry: Error while patching status - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/02 16:23:00 UTC, 0 replies.
- [RESULT] [VOTE] flink-connector-dynamodb 3.0.0, release candidate #0 - posted by Danny Cranmer <da...@apache.org> on 2022/12/02 16:37:37 UTC, 0 replies.
- [jira] [Created] (FLINK-30284) Make datadog reporter url configurable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/02 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30285) Inline checkstyle config into pom - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/02 17:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30286) Run rat plugin in validate phase - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/02 17:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30287) Configmaps get cleaned up when upgrading standalone Flink cluster - posted by "Steven Zhang (Jira)" <ji...@apache.org> on 2022/12/02 19:23:00 UTC, 0 replies.
- [DISCUSS] FLIP-277: Native GlueCatalog Support in Flink - posted by Samrat Deb <de...@gmail.com> on 2022/12/03 04:29:16 UTC, 13 replies.
- Re: [VOTE] Release flink-connector-jdbc v3.0.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2022/12/03 19:06:37 UTC, 4 replies.
- [jira] [Created] (FLINK-30288) Use visitor to convert predicate for orc - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/04 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30289) RateLimitedSourceReader uses wrong signal for checkpoint rate-limiting - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/04 20:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30290) IteratorSourceReaderBase should report END_OF_INPUT sooner - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/04 20:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30291) Integrate flink-connector-aws into Flink docs - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/12/05 00:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30292) Better support for conversion between DataType and TypeInformation - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/12/05 01:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30293) Create an enumerator for static (batch) - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/05 02:19:00 UTC, 0 replies.
- Need right - posted by Stan1005 <53...@qq.com.INVALID> on 2022/12/05 02:40:12 UTC, 0 replies.
- Patch to support Parquet schema evolution - posted by sunshun18 <su...@126.com> on 2022/12/05 03:54:38 UTC, 1 replies.
- Re: Need right - posted by Martijn Visser <ma...@apache.org> on 2022/12/05 06:21:31 UTC, 1 replies.
- [jira] [Created] (FLINK-30294) Change table property key 'log.scan' to 'startup.mode' and add a default startup mode in Table Store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/12/05 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30295) Develop MariaDbCatalog to connect Flink with MariaDb tables and ecosystem - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/12/05 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30296) In the situation of flink on yarn, how to control the number of TM in each nodemanager? - posted by "StarBoy1005 (Jira)" <ji...@apache.org> on 2022/12/05 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30297) Alibaba001 not responding - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/05 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30298) KafkaTableITCase.testStartFromGroupOffsetsNone failed due to timeout - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/05 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30299) TaskManagerRunnerTest fails with 239 exit code (i.e. FatalExitExceptionHandler was called) - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/05 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30300) Building wheels on macos took longer than expected - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/05 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30301) TaskExecutorTest.testSharedResourcesLifecycle failed with TaskException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/05 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30302) WatermarkAssignerChangelogNormalizeTransposeRuleTest failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/05 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30303) Support max column width in sql client - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/05 15:10:00 UTC, 0 replies.
- [VOTE] Release flink-connector-aws v4.0.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2022/12/05 15:25:58 UTC, 7 replies.
- [jira] [Created] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/12/05 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback - posted by "Alexis Sarda-Espinosa (Jira)" <ji...@apache.org> on 2022/12/05 16:25:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-dynamodb 3.0.0 released - posted by Danny Cranmer <da...@apache.org> on 2022/12/05 16:26:43 UTC, 0 replies.
- [jira] [Created] (FLINK-30306) Audit utils can expose potentially sensitive information - posted by "Alexis Sarda-Espinosa (Jira)" <ji...@apache.org> on 2022/12/05 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30307) Turn off e2e test error check temporarily - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/05 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30308) ClassCastException: class java.io.ObjectStreamClass$Caches$1 cannot be cast to class java.util.Map is showing in the logging when the job shutdown - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/12/06 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30309) Add the ability to supply custom SslContexts for netty client/servers. - posted by "Steve Niemitz (Jira)" <ji...@apache.org> on 2022/12/06 03:41:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-273: Improve the Catalog API to Support ALTER TABLE syntax - posted by Shengkai Fang <fs...@gmail.com> on 2022/12/06 06:44:51 UTC, 0 replies.
- [jira] [Created] (FLINK-30310) Re-enable e2e test error check - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/06 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30311) CI error: Back-off pulling image "flink:1.14" - posted by "Peter Vary (Jira)" <ji...@apache.org> on 2022/12/06 09:44:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-cassandra 3.0.0 released - posted by Chesnay Schepler <ch...@apache.org> on 2022/12/06 10:25:37 UTC, 0 replies.
- [jira] [Created] (FLINK-30312) Remove cassandra connector from master branch - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/06 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/06 13:41:00 UTC, 0 replies.
- Re: [DISCUSS] TLS issues - posted by Jean-Damien Hatzenbuhler <je...@contentsquare.com.INVALID> on 2022/12/06 13:41:58 UTC, 1 replies.
- [DISCUSS] the bug with column lost comment - posted by 黑猪 <bl...@dingtalk.com.INVALID> on 2022/12/06 13:58:02 UTC, 0 replies.
- [jira] [Created] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API - posted by "Dmitry Yaraev (Jira)" <ji...@apache.org> on 2022/12/06 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30315) Add more information about image pull failures to the operator log - posted by "Peter Vary (Jira)" <ji...@apache.org> on 2022/12/06 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30316) [JUnit5 Migration] Migrate flink-statebackend-common - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/12/06 15:36:00 UTC, 0 replies.
- Re: [Cassandra] source connector - posted by Etienne Chauchot <ec...@apache.org> on 2022/12/06 16:37:47 UTC, 0 replies.
- [jira] [Created] (FLINK-30317) Create table in FTS catalog with s3 warehouse throws DatabaseNotExistException - posted by "Alex Sorokoumov (Jira)" <ji...@apache.org> on 2022/12/06 17:04:00 UTC, 0 replies.
- ABFS/WASB IT test cases not running - posted by ramkrishna vasudevan <ra...@gmail.com> on 2022/12/06 17:22:45 UTC, 4 replies.
- Redis source - posted by Pramod Immaneni <pr...@gmail.com> on 2022/12/06 19:23:27 UTC, 2 replies.
- [DISCUSS] Support SSO for Apache Flink Web Dashboard with Casdoor Component:Web Dashboard , SSO - posted by Accepted <25...@qq.com.INVALID> on 2022/12/07 01:08:33 UTC, 0 replies.
- [jira] [Created] (FLINK-30318) sql-client failed to load jar passed with -j args in flink 1.16.0 - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/12/07 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30319) Validate illegal column name in table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/07 03:56:00 UTC, 0 replies.
- Re: Table API thrift support - posted by Chen Qin <qi...@gmail.com> on 2022/12/07 04:01:13 UTC, 1 replies.
- [DISCUSS] Externalizing Kafka connector - posted by Mason Chen <ma...@gmail.com> on 2022/12/07 06:22:28 UTC, 1 replies.
- [jira] [Created] (FLINK-30320) hbase connector insert timestamp type error - posted by "zhengshubin (Jira)" <ji...@apache.org> on 2022/12/07 08:18:00 UTC, 0 replies.
- [DISCUSS] Cleaning up HighAvailabilityServices interface to reflect the per-JM-process LeaderElection - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2022/12/07 08:28:03 UTC, 10 replies.
- [jira] [Created] (FLINK-30321) Upgrade ZLIB of FRocksDB to 1.2.13 - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/12/07 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30322) Support table/column/partition statistics in table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/07 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30323) Add statistics and support table statistics in table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/07 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30324) Support column/partition statistics in table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/07 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30325) the column lost comments, also find some issue ,but that commit is not mr. i have some diff solution - posted by "blackpighe (Jira)" <ji...@apache.org> on 2022/12/07 10:14:00 UTC, 0 replies.
- Re: [DISCUSS] the bug with column lost comment - posted by Jingsong Li <ji...@gmail.com> on 2022/12/07 10:38:06 UTC, 2 replies.
- 回复:[DISCUSS] the bug with column lost comment - posted by 黑猪 <bl...@dingtalk.com.INVALID> on 2022/12/07 11:38:34 UTC, 0 replies.
- [jira] [Created] (FLINK-30326) SQL Client should not create table directory structure - posted by "Alex Sorokoumov (Jira)" <ji...@apache.org> on 2022/12/07 12:34:00 UTC, 0 replies.
- Re: [VOTE] Release flink-connector-pulsar v3.0.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2022/12/07 12:54:40 UTC, 2 replies.
- [jira] [Created] (FLINK-30327) Adding a values.schema.json to the Helm chart source to support schema validation on Helm chart configuration - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/07 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30328) TaskManagerWideRocksDbMemorySharingITCase.testBlockCache failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/07 16:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30329) flink-kubernetes-operator helm chart does not work with dynamic config because of use of ConfigMap subPath - posted by "Andrew Otto (Jira)" <ji...@apache.org> on 2022/12/07 19:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30330) Exclude .github from source release(s) - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/12/07 23:28:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.3.0, release candidate #1 - posted by Őrhidi Mátyás <ma...@gmail.com> on 2022/12/08 01:39:24 UTC, 6 replies.
- [jira] [Created] (FLINK-30331) Further improvement of production availability of hybrid shuffle - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/12/08 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30332) HsFileDataIndex should supports spill to file - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/12/08 03:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30333) Supports lookup a partial-update table with full compaction - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/08 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30334) SourceCoordinator error split check cause HybridSource hang - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2022/12/08 07:27:00 UTC, 0 replies.
- [DISCUSS] FLIP-274 : Introduce metric group for OperatorCoordinator - posted by Hang Ruan <ru...@gmail.com> on 2022/12/08 07:28:00 UTC, 12 replies.
- [DISCUSSION] Scan mode in Table Store for Flink Stream and Batch job - posted by Shammon FY <zj...@gmail.com> on 2022/12/08 08:11:07 UTC, 4 replies.
- [jira] [Created] (FLINK-30335) [Umbrella] Improvement for Hive Query Syntax Compatibility-Part2 - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/12/08 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30336) Sync missing Pulsar e2e tests to external repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/08 09:11:00 UTC, 0 replies.
- [DISCUSS] Hybrid Source Connector - posted by Ran Tao <ch...@gmail.com> on 2022/12/08 09:26:17 UTC, 1 replies.
- [jira] [Created] (FLINK-30337) Stateful Functions application throws an exception when stopping a job gracefully creating a final savepoint - posted by "Ali Bahadir Zeybek (Jira)" <ji...@apache.org> on 2022/12/08 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30338) Clean leader election legacy code - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/08 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30339) Add a unified deleagation token manager - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/08 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30340) PulsarUnorderedSourceITCase fails with IllegalStateException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/08 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30341) Introduce audit_log system table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/08 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30342) Migrate ZooKeeperLeaderElectionTest - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/08 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30343) Migrate KubernetesLeaderElectionAndRetrievalITCase - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/08 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30344) Migrate KubernetesHighAvailabilityTestBase and implementing test classes - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/08 15:53:00 UTC, 0 replies.
- Edit Wiki for Release Verification Steps - posted by Jim Busche <jb...@us.ibm.com> on 2022/12/09 00:28:58 UTC, 1 replies.
- [jira] [Created] (FLINK-30345) Improve the serializer performace of state change of changelog - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/12/09 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30346) wrong code comment in class Trigger - posted by "ruanliang (Jira)" <ji...@apache.org> on 2022/12/09 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30347) Connecting SqlGateway via beeline gets java.lang.UnsupportedOperationException:: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS - posted by "Yao Zhang (Jira)" <ji...@apache.org> on 2022/12/09 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30348) Refine Transformer for RandomSplitter - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/12/09 03:38:00 UTC, 0 replies.
- Edit permission - posted by Hao t Chang <ht...@us.ibm.com> on 2022/12/09 03:44:50 UTC, 2 replies.
- [jira] [Created] (FLINK-30349) Sync missing HBase e2e tests to external repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/09 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30350) Write dependency-reduced pom to default directory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/09 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30351) Enable test cases again - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/09 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30352) [Connectors][Elasticsearch] Document missing configuration properties - posted by "Andriy Redko (Jira)" <ji...@apache.org> on 2022/12/09 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30353) Enable concurrency for external connector repositories - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/09 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30354) Reducing the number of ThreadPools in LookupFullCache and related cache-loading classes - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/09 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30355) crictl causes long wait in e2e tests - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/09 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30356) Update NOTICE files to say "Apache Flink AWS connectors" - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/12/09 16:22:00 UTC, 0 replies.
- [RESULT] [VOTE] flink-connector-aws v4.0.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2022/12/09 18:44:55 UTC, 0 replies.
- [jira] [Created] (FLINK-30357) Wrong link in connector/jdbc doc. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2022/12/10 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30358) Show the task manager id on the exception history page - posted by "JUNRUILi (Jira)" <ji...@apache.org> on 2022/12/10 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30359) Encountered NoClassDefFoundError when using flink-sql-connector-elasticsearch6 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/12/10 17:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30360) A null pointer exception is thrown when data is written to the HBase table using the specified column name - posted by "Jichao Wang (Jira)" <ji...@apache.org> on 2022/12/11 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30361) Flink cluster deleted while updating the replicas - posted by "SwathiChandrashekar (Jira)" <ji...@apache.org> on 2022/12/11 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30362) Flink-connector-hive can't build with maven 3.8 - posted by "Chen Qin (Jira)" <ji...@apache.org> on 2022/12/11 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2022/12/11 19:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30364) Job failed without exception stack - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/12/12 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30365) New dynamic partition pruning strategy to support more dpp patterns - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/12/12 01:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30366) Python Group Agg failed in cleaning the idle state - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2022/12/12 03:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30367) Enrich the thread dump info with deeper stack - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/12/12 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30368) Fix calcite method RelMdUtil$numDistinctVals() wrongly return zero if the method input domainSize much larger than numSelected - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/12/12 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30369) Fix FlinkFilterJoinRule push wrong filters to another side while join type is left/right outer join - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/12/12 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30370) Move existing delegation token framework authentication to providers - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/12 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2022/12/12 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30372) dependencyManagement bom for flink-dist - posted by "James Z.M. Gao (Jira)" <ji...@apache.org> on 2022/12/12 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30373) Flink-table-runtime free for flink-table-store-codegen - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/12 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30374) DefaultExecutionGraphCacheTest fails with 239 exit code - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/12/12 10:22:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-aws v4.0.0 released - posted by Danny Cranmer <da...@apache.org> on 2022/12/12 11:11:34 UTC, 0 replies.
- [jira] [Created] (FLINK-30375) SqlClient leaks flink-table-planner jar under /tmp - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/12/12 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30376) Introduce a new flink busy join reorder rule which based on greedy algorithm - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/12/12 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30377) CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/12/12 11:36:00 UTC, 0 replies.
- Slack link expired - posted by Ruben van Vreeland <ru...@gmail.com> on 2022/12/12 12:01:07 UTC, 1 replies.
- [jira] [Created] (FLINK-30378) Rework sql_download_table shortcode - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/12 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30379) Decouple connector docs integration from connector releases - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/12 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30380) Look into enable parallel compilation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/12 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30381) Bump minikube kubernetes version for operator - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/12 12:48:00 UTC, 0 replies.
- [DISCUSS] Release new FRocksDB - posted by Yanfei Lei <fr...@gmail.com> on 2022/12/12 14:02:03 UTC, 5 replies.
- [jira] [Created] (FLINK-30382) Flink 1.16 to integrate KDS/KDF docs from flink-connector-aws - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/12/12 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30383) UseLogicalIdentifier makes datadog consider metric as custom - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/12 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30384) Sync master KDS/KDF connector changes to flink-connector-aws - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/12/12 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30385) Remove KDS/KDF/AWS Base connectors from master branch - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/12/12 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30386) Column primary key constraint lacks enforced check - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/12/12 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30387) support job singleton within TM - posted by "James Z.M. Gao (Jira)" <ji...@apache.org> on 2022/12/12 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30388) Add support for ElementConverted open() method for KDS/KDF/DDB - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/12/12 16:34:00 UTC, 0 replies.
- Slack Invite - posted by Grant Wade <wa...@galatea-associates.com> on 2022/12/12 17:35:52 UTC, 1 replies.
- [VOTE] Release flink-connector-pulsar v3.0.0, release candidate #2 - posted by Martijn Visser <ma...@apache.org> on 2022/12/12 19:06:45 UTC, 2 replies.
- [jira] [Created] (FLINK-30389) Add retry to read hints - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/13 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30390) Ensure that no compaction is in progress before closing the writer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/13 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30391) show jars command doesn't list client wrapper classloader loaded jars - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/12/13 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30392) Increase the default value of cluster.thread-dump.stacktrace-max-depth - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/12/13 05:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30393) PulsarSourceUnorderedE2ECase.testScaleDown failed with TimeoutException - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/12/13 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30394) [umbrella] Refactor filesystem support in table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/13 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30395) Refactor module name and documentation for filesystems - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/13 07:55:00 UTC, 0 replies.
- Flink 中的类加载KafkaSerializerWrapper - posted by wangshuai <tu...@163.com> on 2022/12/13 08:02:11 UTC, 1 replies.
- [jira] [Created] (FLINK-30396) sql hint 'LOOKUP' which is defined in outer query block may take effect in inner query block - posted by "Jianhui Dong (Jira)" <ji...@apache.org> on 2022/12/13 08:41:00 UTC, 0 replies.
- [SUMMARY] Flink 1.17 Release Sync 12/13/2022 - posted by Leonard Xu <xb...@gmail.com> on 2022/12/13 09:32:18 UTC, 0 replies.
- Invitation link to Community Slack - posted by Lauri Suurväli <la...@checkout.com.INVALID> on 2022/12/13 09:38:09 UTC, 1 replies.
- [jira] [Created] (FLINK-30397) Remove Pulsar connector from master branch - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/13 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30398) Introduce S3 support for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/12/13 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30399) Enable connectors to use config docs generator - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/13 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30400) Stop bundling connector-base in externalized connectors - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/12/13 11:59:00 UTC, 0 replies.
- [VOTE] Release flink-connector-rabbitmq, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2022/12/13 12:22:55 UTC, 4 replies.
- [VOTE] Release flink-connector-pulsar, release candidate #3 - posted by Martijn Visser <ma...@apache.org> on 2022/12/13 12:29:23 UTC, 1 replies.
- [jira] [Created] (FLINK-30401) Add Estimator and Transformer for MinHashLSH - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2022/12/13 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30402) Separate token framework generic and hadoop specific parts - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/13 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30403) The reported latest completed checkpoint is discarded - posted by "Zdenek Tison (Jira)" <ji...@apache.org> on 2022/12/13 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30404) Do not redeploy taskmanagers on standalone application scaling - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/13 17:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30405) Add ResourceLifecycleStatus to CommonStatus and printer column - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/13 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30406) Jobmanager Deployment error without HA metadata should not lead to unrecoverable error - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/13 20:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30407) Better encapsulate error handling logic in controllers - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/13 20:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30408) Add unit test for HA metadata check logic - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/13 20:50:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.3.0, release candidate #1 - posted by Őrhidi Mátyás <ma...@gmail.com> on 2022/12/13 21:23:29 UTC, 0 replies.
- [jira] [Created] (FLINK-30409) Support reopening closed metric groups - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2022/12/14 03:43:00 UTC, 0 replies.
- I want to join - posted by Ruslan Maznytsia <ru...@gmail.com> on 2022/12/14 07:46:07 UTC, 1 replies.
- [jira] [Created] (FLINK-30410) Rename 'full' to 'latest-full' and 'compacted' to 'compacted-full' for scan.mode in Table Store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/12/14 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2022/12/14 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30412) create many checkpoint empty dir when job not enable checkpoint - posted by "xiaodao (Jira)" <ji...@apache.org> on 2022/12/14 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30413) Drop Share and Key_Shared subscription support in Pulsar connector - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/12/14 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30414) Add unit test time out when run ci. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2022/12/14 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30415) Sync JDBC connector to match with previously released 1.16 version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/14 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30416) Add configureSession REST API in the SQL Gateway - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/12/14 12:00:00 UTC, 0 replies.
- [VOTE] FLIP-275: Support Remote SQL Client Based on SQL Gateway - posted by yu zelin <yu...@gmail.com> on 2022/12/14 12:41:18 UTC, 5 replies.
- [jira] [Created] (FLINK-30417) Rabbit error is not clear - posted by "Yaron Shani (Jira)" <ji...@apache.org> on 2022/12/14 13:02:00 UTC, 0 replies.
- [VOTE] Release flink-connector-jdbc, release candidate #2 - posted by Martijn Visser <ma...@apache.org> on 2022/12/14 13:14:24 UTC, 5 replies.
- [jira] [Created] (FLINK-30418) Implement synchronous KinesisClient in EFO - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2022/12/14 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30419) Allow tuning of transaction timeout - posted by "Vicky Papavasileiou (Jira)" <ji...@apache.org> on 2022/12/14 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30420) NPE thrown when using window time in Table API - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2022/12/14 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30421) Move TGT renewal to hadoop module - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/14 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30422) Generalize token framework provider API - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/14 16:17:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.3.0 released - posted by Őrhidi Mátyás <ma...@gmail.com> on 2022/12/14 17:30:06 UTC, 1 replies.
- Re: [DISCUSS] FLIP-271: Autoscaling - posted by Maximilian Michels <mx...@apache.org> on 2022/12/14 18:36:57 UTC, 1 replies.
- [jira] [Created] (FLINK-30423) Introduce cast executor codegen for column type evolution - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/15 01:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30424) Add source operator restore readerState log to distinguish split is from newPartitions or split state - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2022/12/15 04:18:00 UTC, 0 replies.
- [DISCUSS] FLIP-278: Hybrid Source Connector - posted by Ran Tao <ch...@gmail.com> on 2022/12/15 08:02:52 UTC, 6 replies.
- [jira] [Created] (FLINK-30425) Generalize token receive side - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/15 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30426) Archunit can't find any tests in Pulsar repository - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/15 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30427) Pulsar SQL connector lists not bundled dependencies - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/12/15 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30428) SparkReadITCase.testSnapshotsTable is unstable - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/15 12:15:00 UTC, 0 replies.
- [VOTE] Release flink-connector-pulsar, release candidate #4 - posted by Martijn Visser <ma...@apache.org> on 2022/12/15 14:46:23 UTC, 1 replies.
- [jira] [Created] (FLINK-30429) Flink command stops with IllegalArgumentException - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/12/15 14:52:00 UTC, 0 replies.
- [DICSUSS] Releasing Flink Opensearch Connector v1.0.0 - posted by Andriy Redko <dr...@gmail.com> on 2022/12/15 15:16:07 UTC, 5 replies.
- [jira] [Created] (FLINK-30430) Remove the useless dependencies in flink-connector-pulsar's dependencyManagement - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/12/15 15:37:00 UTC, 0 replies.
- [VOTE] Release flink-connector-pulsar, release candidate #5 - posted by Martijn Visser <ma...@apache.org> on 2022/12/15 15:41:00 UTC, 6 replies.
- [DISCUSS] Release Flink 1.16.1 - posted by Martijn Visser <ma...@apache.org> on 2022/12/15 18:52:41 UTC, 11 replies.
- Re: [SURVEY] Drop Share and Key_Shared subscription support in Pulsar connector - posted by Martijn Visser <ma...@apache.org> on 2022/12/15 20:01:56 UTC, 0 replies.
- [jira] [Created] (FLINK-30431) JDBC Connector fails to reestablish the lost DB connection. - posted by "Sai Nadendla (Jira)" <ji...@apache.org> on 2022/12/15 22:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30432) HiveSoure doesn't need to maintain all splits when it's for parallelism inference - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/12/16 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30433) HiveDialectITCase#testCreateDatabase fails with "Could not execute CREATE DATABASE" - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/16 08:23:00 UTC, 0 replies.
- [DISCUSS] FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode - posted by Jing Ge <ji...@ververica.com.INVALID> on 2022/12/16 10:09:36 UTC, 0 replies.
- [VOTE] FLIP-277: Improve Catalog API to Support ALTER TABLE syntax - posted by Samrat Deb <de...@gmail.com> on 2022/12/16 10:15:25 UTC, 1 replies.
- [VOTE] FLIP-277: Glue catalog support in Flink - posted by Samrat Deb <de...@gmail.com> on 2022/12/16 10:17:29 UTC, 6 replies.
- [jira] [Created] (FLINK-30434) The non-null check for transactionalIdPrefix is unnecessary in the KafkaWriter constructor - posted by "Zhengqi Zhang (Jira)" <ji...@apache.org> on 2022/12/16 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30435) `SHOW CREATE TABLE` shows column comment - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/12/16 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30436) Integrate Opensearch connector docs into Flink docs v1.16 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/12/16 11:12:00 UTC, 0 replies.
- [VOTE] Release flink-connector-opensearch, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2022/12/16 12:40:42 UTC, 10 replies.
- [jira] [Created] (FLINK-30437) Last-state upgrade combined with state incompatibility causes state loss - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/16 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30438) The generated schema is not correct when using value.format debezium-avro-confluent - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2022/12/16 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30439) Update playgrounds for 1.16 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/12/16 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30441) Update pyflink walkthrough playground for 1.16 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/12/16 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30440) Update operations playground for 1.16 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/12/16 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30442) Update table walkthrough playground for 1.12 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/12/16 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30443) Expand list of sensitive keys - posted by "Gunnar Morling (Jira)" <ji...@apache.org> on 2022/12/16 16:12:00 UTC, 0 replies.
- Re: [VOTE] Update Flink's Scala 2.12 support from 2.12.7 to 2.12.16 - posted by Martijn Visser <ma...@apache.org> on 2022/12/16 17:22:07 UTC, 3 replies.
- [jira] [Created] (FLINK-30444) State recovery error not handled correctly and always causes JM failure - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/16 17:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30445) Add Flink Web3 Connector - posted by "Junyao Huang (Jira)" <ji...@apache.org> on 2022/12/16 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30446) [flink-playgrounds] Use more recent MySQL image built for linux/arm64/v8 & linux/amd64 - posted by "Connor Ameres (Jira)" <ji...@apache.org> on 2022/12/16 18:18:00 UTC, 0 replies.
- Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang - posted by Jun Qin <qi...@gmail.com> on 2022/12/16 19:52:02 UTC, 2 replies.
- Streaming queries in FTS using Kafka log - posted by Alexander Sorokoumov <as...@confluent.io.INVALID> on 2022/12/17 01:28:02 UTC, 1 replies.
- Confluent Kafka connector for protobuf format - posted by Krish Narukulla <kr...@gmail.com> on 2022/12/17 20:52:07 UTC, 1 replies.
- [jira] [Created] (FLINK-30447) Scylladb SQL sink connector - posted by "Krish Narukulla (Jira)" <ji...@apache.org> on 2022/12/17 20:55:00 UTC, 0 replies.
- Scylladb sink connector - posted by Krish Narukulla <kr...@gmail.com> on 2022/12/17 21:01:18 UTC, 1 replies.
- [Discuss] Discuss about the interface of Catalog - posted by Aitozi <gj...@gmail.com> on 2022/12/18 03:02:51 UTC, 0 replies.
- [jira] [Created] (FLINK-30448) "filter(Objects::nonNull)" will bring down task with failure cause: ClassCastException - posted by "Wang Yong (Jira)" <ji...@apache.org> on 2022/12/18 04:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30449) Improve Serialization and Deserialization of FetchResultsResponseBody - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/12/18 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30450) FileSystem supports exporting client-side metrics - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/12/19 04:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30451) Add Estimator and Transformer for Swing - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/12/19 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30452) Wrong argument type is used when call Hive's function - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/12/19 07:22:00 UTC, 0 replies.
- [DISCUSS] FLIP-266: Simplify network memory configurations for TaskManager - posted by Yuxin Tan <ta...@gmail.com> on 2022/12/19 07:35:43 UTC, 18 replies.
- [jira] [Created] (FLINK-30453) Fix 'can't find CatalogFactory' error when using FLINK sql-client to add table store bundle jar - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/12/19 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30454) Inconsistent class hierarchy in TaskIOMetricGroup - posted by "Gunnar Morling (Jira)" <ji...@apache.org> on 2022/12/19 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30455) Avoid "cleaning" of java.lang.String in ClosureCleaner - posted by "Gunnar Morling (Jira)" <ji...@apache.org> on 2022/12/19 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30456) OLM Bundle Description Version Problems - posted by "James Busche (Jira)" <ji...@apache.org> on 2022/12/20 01:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30457) Introduce period compaction to FRocksDB - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/12/20 04:05:00 UTC, 0 replies.
- [DISCUSS] Add Flink Web3 Connector - posted by Junyao Huang <Ju...@microsoft.com.INVALID> on 2022/12/20 05:11:08 UTC, 1 replies.
- [jira] [Created] (FLINK-30458) Refactor Table Store Documentation - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/12/20 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30459) SQL Client supports "SET 'property'" - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/12/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30460) Support writing HBase's CEIL TTL metadata - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2022/12/20 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30461) Some rocksdb sst files will remain forever - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/12/20 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30462) DefaultMultipleComponentLeaderElectionService saves wrong leader session ID - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/20 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30463) Stabilization period starts before job goes into RUNNING - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2022/12/20 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30464) Exclude metrics during stabilization period from the scaling decision - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2022/12/20 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30465) Remove flink-connector-jdbc - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/20 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30466) Detect ineffective scaling operations - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/20 16:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/12/21 01:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30468) The SortOrder of BusyRatio should be descend by default - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/12/21 05:16:00 UTC, 0 replies.
- [VOTE] FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records - posted by Dong Lin <li...@gmail.com> on 2022/12/21 07:13:02 UTC, 4 replies.
- [RESULT][VOTE] FLIP-277: Glue native catalog support in Flink - posted by Samrat Deb <de...@gmail.com> on 2022/12/21 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30469) FLIP-266: Simplify network memory configurations for TaskManager - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2022/12/21 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30470) Change groupId for flink-connector-parent - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/21 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30471) Optimize the enriching network memory process in SsgNetworkMemoryCalculationUtils - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2022/12/21 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30472) Modify the default value of the max network memory config option - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2022/12/21 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30473) Optimize the InputGate network memory management for TaskManager - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2022/12/21 08:44:00 UTC, 0 replies.
- [Discuss] SQL Client syntax to show a configuration - posted by Mingliang Liu <li...@apache.org> on 2022/12/21 08:47:37 UTC, 3 replies.
- [jira] [Created] (FLINK-30474) DefaultMultipleComponentLeaderElectionService triggers HA backend change even if it's not the leader - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/21 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30475) Improved speed of RocksDBMapState clear() using rocksDB.deleteRange - posted by "David Hrbacek (Jira)" <ji...@apache.org> on 2022/12/21 10:23:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-275: Support Remote SQL Client Based on SQL Gateway - posted by yu zelin <yu...@gmail.com> on 2022/12/21 12:16:34 UTC, 0 replies.
- [jira] [Created] (FLINK-30476) TrackingFsDataInputStream batch tracking issue - posted by "Denis (Jira)" <ji...@apache.org> on 2022/12/21 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30477) Not properly blocking retries when timeout occurs in AsyncWaitOperator - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/12/21 13:25:00 UTC, 0 replies.
- [RESULT] [VOTE] flink-connector-opensearch 1.0.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2022/12/21 16:12:10 UTC, 0 replies.
- [jira] [Created] (FLINK-30478) Don't depend on IPAddressUtil - posted by "Gunnar Morling (Jira)" <ji...@apache.org> on 2022/12/21 16:52:00 UTC, 0 replies.
- Question about match_recognize clause in Flink - posted by Marjan Jordanovski <mj...@gmail.com> on 2022/12/21 17:09:09 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-pulsar 3.0.0 released - posted by Martijn Visser <ma...@apache.org> on 2022/12/21 20:42:10 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-jdbc 3.0.0 released - posted by Martijn Visser <ma...@apache.org> on 2022/12/21 20:42:26 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-rabbitmq 3.0.0 released - posted by Martijn Visser <ma...@apache.org> on 2022/12/21 20:42:37 UTC, 0 replies.
- [jira] [Created] (FLINK-30479) Document flink-connector-files for local execution - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/12/22 00:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30480) Add benchmarks for adaptive batch scheduler - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/12/22 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30481) create base aws-glue catalog implementation in flink-connector-aws - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/12/22 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30482) Update catalog documentation - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/12/22 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30483) Make Avro format support for TIMESTAMP_LTZ - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/12/22 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30484) ZooKeeperLeaderElectionTest.testZooKeeperReelection timed out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/22 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30485) Remove flink-connector-rabbitmq from master branch - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/22 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30486) Make the config documentation generator available to connector repos - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/22 12:16:00 UTC, 0 replies.
- [DISCUSS] FLIP-281 Sink Supports Speculative Execution For Batch Job - posted by Biao Liu <mm...@gmail.com> on 2022/12/22 12:16:21 UTC, 5 replies.
- [jira] [Created] (FLINK-30487) Add RabbitMQ Table/SQL connector documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/22 12:32:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-opensearch 1.0.0 released - posted by Danny Cranmer <da...@apache.org> on 2022/12/22 13:23:38 UTC, 0 replies.
- Re: [Consulting] Should a Flink class loader be a singleton? - posted by Ken Krugler <kk...@transpac.com> on 2022/12/22 15:54:42 UTC, 0 replies.
- [jira] [Created] (FLINK-30488) OpenSearch implementation of Async Sink - posted by "Andriy Redko (Jira)" <ji...@apache.org> on 2022/12/22 18:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30489) flink-sql-connector-pulsar doesn't shade all dependencies - posted by "Henri Yandell (Jira)" <ji...@apache.org> on 2022/12/22 21:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30490) Deleted topic from KafkaSource is still included in subsequent restart from savepoint - posted by "Hilmi Al Fatih (Jira)" <ji...@apache.org> on 2022/12/23 05:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30491) Hive table partition supports to deserialize later during runtime - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/12/23 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30492) hive overview document given an Incorrect dependency artifactId example - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/12/23 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30493) FLIP 273: Improve the Catalog API to Support ALTER TABLE syntax - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/12/23 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30494) Introduce TableChange to represents table option modification - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/12/23 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30495) Introduce TableChange to represents ADD change - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/12/23 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30496) Introduce TableChange to represent MODIFY change - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/12/23 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30497) Introduce TableChange to represent DROP change - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/12/23 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30498) frocksdb throw an UnsatisfiedLinkError - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2022/12/23 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30499) over window codegen error when member code incorrectly used in method body - posted by "Runkang He (Jira)" <ji...@apache.org> on 2022/12/24 01:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30500) Got an null pointer exception when using table environment in sub-thread - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/12/24 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30501) Update pom.xml to use Java 11 by default - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/12/25 08:35:00 UTC, 0 replies.
- [DISCUSS] Release Kubernetes Operator 1.3.1 - posted by Gyula Fóra <gy...@gmail.com> on 2022/12/25 21:13:51 UTC, 1 replies.
- [jira] [Created] (FLINK-30502) Checkpoint state Continued to increase - posted by "heyu dou (Jira)" <ji...@apache.org> on 2022/12/26 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30503) KafkaSourceITCase$IntegrationTests.testSavepoint failed with timeout - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/12/26 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30504) Fix UnsupportedFileSystemSchemeException when writing Table Store on OSS with other engines - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/12/26 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30505) Close the connection between TM and JM when task executor failed - posted by "Yongming Zhang (Jira)" <ji...@apache.org> on 2022/12/26 10:24:00 UTC, 0 replies.
- [DISCUSS] FLIP-282: Introduce Delete & Update API - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2022/12/26 12:03:14 UTC, 2 replies.
- [DISCUSS] FLIP-280: Introduce a new explain mode to provide SQL advice - posted by Jane Chan <qi...@gmail.com> on 2022/12/26 13:39:18 UTC, 2 replies.
- [jira] [Created] (FLINK-30506) Add documentation for writing Table Store with Spark3 - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/12/27 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30507) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMinMaxParallelism could not be initialized - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/12/27 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30508) CliClientITCase.testSqlStatements failed with output not matched with expected - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/12/27 07:28:00 UTC, 0 replies.
- [DISCUSS] Extending the feature freezing date of Flink 1.17 - posted by Qingsheng Ren <re...@apache.org> on 2022/12/27 08:40:40 UTC, 2 replies.
- [RESULT][VOTE] FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records - posted by Dong Lin <li...@gmail.com> on 2022/12/27 08:47:51 UTC, 0 replies.
- [jira] [Created] (FLINK-30509) Modify sql-client.sh - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/12/27 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30510) Allow configuring minimum and maximum metrics window size - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2022/12/27 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30511) Ignore the Exception in user-timer Triggerble when recover form state. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/12/27 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30512) Flink SQL state TTL has no effect when using Interval Join - posted by "wangkang (Jira)" <ji...@apache.org> on 2022/12/27 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30513) HA storage dir leaks on cluster termination - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2022/12/27 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30514) HybridSource savepoint recovery sequence - posted by "Denis Golovachev (Jira)" <ji...@apache.org> on 2022/12/27 17:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30515) Add benchmark for CountVectorizer, Imputer, RobustScaler, UnivariateFeatureSelector and VarianceThresholdSelector - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2022/12/28 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30516) Add file count and row count in snapshots table - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/12/28 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30517) Decrease log output interval while waiting for YARN JobManager be allocated - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2022/12/28 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address - posted by "Binh-Nguyen Tran (Jira)" <ji...@apache.org> on 2022/12/28 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30519) Add e2e tests for operator dynamic config - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/28 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2022/12/28 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30521) Improve `Altering Tables` of Doc - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/12/28 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30522) `SHOW TBLPROPERTIES` can't read properties of table in Spark3 - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/12/28 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30523) Refine benchmark of vectorAssembler - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/12/28 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30524) Unify the style of the logs page - posted by "Yongming Zhang (Jira)" <ji...@apache.org> on 2022/12/28 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30525) Cannot open jobmanager configuration web page - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2022/12/28 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30526) Handle failures in OpenSearch with ActionRequestFailureHandler being deprecated - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/28 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30527) Last-state suspend followed by flinkVersion change may lead to state loss - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/28 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30528) Job may be stuck in upgrade loop when last-state fallback is disabled and deployment is missing - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/28 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30529) Use simple cancel for savepoint upgrades on failing jobs - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/12/28 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30530) Flink configuration from user-provided ConfigMap - posted by "Arseniy Tashoyan (Jira)" <ji...@apache.org> on 2022/12/28 20:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30531) Reduce operator chain call stack depth - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/12/29 01:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30532) Add benchmark for DCT, SQLTransformer and StopWordsRemover algorithm - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/12/29 01:47:00 UTC, 0 replies.
- [DISCUSS] Adding a option for planner to decide which join reorder rule to choose - posted by yh z <zh...@gmail.com> on 2022/12/29 06:43:33 UTC, 0 replies.
- [jira] [Created] (FLINK-30533) IteratorSourceReaderBase#pollNext() should push records to ReaderOutput in a while loop - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/12/29 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30534) Discuss / migrate People section to Hugo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/12/29 08:38:00 UTC, 0 replies.
- [DISCUSS] FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs - posted by JunRui Lee <jr...@gmail.com> on 2022/12/29 11:45:36 UTC, 2 replies.
- [jira] [Created] (FLINK-30535) Introduce TTL state based benchmarks - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/12/30 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30536) Invoke CountingOutput and ChainingOutput as listeners - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/12/30 13:26:00 UTC, 0 replies.