commits@flink.apache.org, 2023-01

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

- [flink-kubernetes-operator] branch main updated: [FLINK-30527] Validate flinkVersion change for suspended jobs - posted by gy...@apache.org on 2023/01/01 16:15:19 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30528] Reconcile other changes if upgrade is not available - posted by gy...@apache.org on 2023/01/01 16:15:35 UTC, 0 replies.
- [flink-kubernetes-operator] branch release-1.3 updated (5ed117cb -> 7f65de71) - posted by gy...@apache.org on 2023/01/01 16:15:53 UTC, 0 replies.
- [flink-kubernetes-operator] 01/03: [FLINK-30361] Do not redeploy task managers when scaling standalone session cluster - posted by gy...@apache.org on 2023/01/01 16:15:54 UTC, 0 replies.
- [flink-kubernetes-operator] 02/03: [FLINK-30528] Reconcile other changes if upgrade is not available - posted by gy...@apache.org on 2023/01/01 16:15:55 UTC, 0 replies.
- [flink-kubernetes-operator] 03/03: [FLINK-30527] Validate flinkVersion change for suspended jobs - posted by gy...@apache.org on 2023/01/01 16:15:56 UTC, 0 replies.
- svn commit: r59058 - in /dev/flink/flink-kubernetes-operator-1.3.1-rc1: ./ release/ - posted by gy...@apache.org on 2023/01/01 17:20:36 UTC, 0 replies.
- [flink-kubernetes-operator] annotated tag release-1.3.1-rc1 updated (8e60e9b4 -> 8e4324a9) - posted by gy...@apache.org on 2023/01/01 17:21:30 UTC, 0 replies.
- [flink] branch master updated: [FLINK-29363] allow fully redirection in web dashboard - posted by rm...@apache.org on 2023/01/02 10:03:00 UTC, 0 replies.
- [flink] branch master updated (ded2df542fd -> 1c2f4eb4ba1) - posted by gy...@apache.org on 2023/01/02 13:04:17 UTC, 0 replies.
- [flink] 01/05: [FLINK-30213] Change ForwardPartitioner to RebalancePartitioner on parallelism changes - posted by gy...@apache.org on 2023/01/02 13:04:18 UTC, 0 replies.
- [flink] 02/05: Replace Java 11 call - posted by gy...@apache.org on 2023/01/02 13:04:19 UTC, 0 replies.
- [flink] 03/05: Use RebalancePartitioner - posted by gy...@apache.org on 2023/01/02 13:04:20 UTC, 0 replies.
- [flink] 04/05: PR comment - posted by gy...@apache.org on 2023/01/02 13:04:21 UTC, 0 replies.
- [flink] 05/05: Update flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java - posted by gy...@apache.org on 2023/01/02 13:04:22 UTC, 0 replies.
- [flink] branch master updated (1c2f4eb4ba1 -> cc9540cacc2) - posted by sh...@apache.org on 2023/01/02 15:53:41 UTC, 0 replies.
- [flink] 01/02: [FLINK-22137][sql-parser] Support ALTER TABLE DROP syntax - posted by sh...@apache.org on 2023/01/02 15:53:42 UTC, 0 replies.
- [flink] 02/02: [FLINK-22137][table] Support DROP column/constraint/watermark for ALTER TABLE statement - posted by sh...@apache.org on 2023/01/02 15:53:43 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30392][web] Replace default thread dump depth to 50 - posted by ta...@apache.org on 2023/01/03 02:43:06 UTC, 0 replies.
- [flink-table-store] branch master updated (dea8ac80 -> dcae4c28) - posted by lz...@apache.org on 2023/01/03 03:44:47 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30423] Improve CastExecutor and CastExecutors - posted by lz...@apache.org on 2023/01/03 03:51:12 UTC, 0 replies.
- [flink] branch release-1.16 updated (31f1e235f87 -> c1435524399) - posted by go...@apache.org on 2023/01/03 04:06:40 UTC, 0 replies.
- [flink] branch release-1.15 updated: [hotfix][python] Fix the wrong clearing state logic on processing time window - posted by hx...@apache.org on 2023/01/03 07:39:57 UTC, 0 replies.
- [flink] branch release-1.16 updated (c1435524399 -> 3da62a21b8f) - posted by hx...@apache.org on 2023/01/03 07:41:25 UTC, 0 replies.
- [flink] branch master updated: [hotfix][python] Fix the wrong clearing state logic on processing time window - posted by hx...@apache.org on 2023/01/03 07:46:02 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30545] Add check of 'NOT NULL' for 'ADD COLUMN' schema change - posted by lz...@apache.org on 2023/01/03 08:19:12 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30545] Merge isNullable into logicalType in SchemaChange.addColumn - posted by lz...@apache.org on 2023/01/03 08:24:27 UTC, 0 replies.
- [flink-table-store] branch master updated: [hotfix] Speed up build - posted by lz...@apache.org on 2023/01/03 08:26:33 UTC, 0 replies.
- [flink-table-store] branch dependabot/maven/net.minidev-json-smart-2.3.1 created (now 565f97a4) - posted by gi...@apache.org on 2023/01/03 08:28:20 UTC, 0 replies.
- [flink-connector-pulsar] branch main updated: [FLINK-30413][Connector/Pulsar] Drop subscription support, remove unorder consuming, change related tests. (#10) - posted by ti...@apache.org on 2023/01/03 08:59:04 UTC, 0 replies.
- [flink] branch master updated: [FLINK-29217][Runtime/Checkpointing] Remove OC's guarantee for OperatorEvent on concurrent checkpoints - posted by li...@apache.org on 2023/01/03 09:14:52 UTC, 0 replies.
- [flink-table-store] branch master updated: [hotfix] Bump json-smart from 2.3 to 2.3.1 - posted by lz...@apache.org on 2023/01/03 09:32:34 UTC, 0 replies.
- [flink-table-store] branch master updated: [hotfix] Revert "Speed up build" to support maven 3.2.5 - posted by lz...@apache.org on 2023/01/03 10:08:32 UTC, 0 replies.
- [flink] branch master updated (9bec3b7dc4d -> 2ffe7e01919) - posted by ma...@apache.org on 2023/01/03 10:20:55 UTC, 0 replies.
- [flink] branch release-1.16 updated (3da62a21b8f -> e7f7e6b8c17) - posted by ma...@apache.org on 2023/01/03 10:21:47 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-30539][tests] Removes timeout from YARNSessionCapacitySchedulerITCase - posted by ma...@apache.org on 2023/01/03 10:23:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30496][table-api] Introduce TableChange to represent MODIFY change - posted by sh...@apache.org on 2023/01/03 12:14:31 UTC, 0 replies.
- [flink] branch master updated (d5b8ad7672c -> 9d9ee6eedb0) - posted by da...@apache.org on 2023/01/03 13:14:56 UTC, 0 replies.
- [flink-playgrounds] branch master updated: bump mysql version to 8.0.31 for table-walkthrough - posted by da...@apache.org on 2023/01/03 13:27:20 UTC, 0 replies.
- [flink-playgrounds] branch master updated: FLINK-30442: Upgrading table walk-through to Flink 1.16 - posted by da...@apache.org on 2023/01/03 13:30:46 UTC, 0 replies.
- [flink] branch master updated (9d9ee6eedb0 -> 13ef498172b) - posted by da...@apache.org on 2023/01/03 16:14:05 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30464] Exclude metrics during stabilization and ensure a full metric window (#493) - posted by mx...@apache.org on 2023/01/03 17:37:37 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [docs] Autoscaler doc and example improvement - posted by gy...@apache.org on 2023/01/03 17:43:22 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [hotfix] Add year 2023 to Notice files - posted by mb...@apache.org on 2023/01/03 19:48:25 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30522] Fix 'SHOW TBLPROPERTIES' can't read properties of table in Spark3 - posted by lz...@apache.org on 2023/01/04 01:43:04 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated (85ae4896 -> eeb09ca1) - posted by lz...@apache.org on 2023/01/04 01:44:56 UTC, 0 replies.
- [flink-table-store] 01/03: [FLINK-30545] Add check of 'NOT NULL' for 'ADD COLUMN' schema change - posted by lz...@apache.org on 2023/01/04 01:44:57 UTC, 0 replies.
- [flink-table-store] 02/03: [FLINK-30545] Merge isNullable into logicalType in SchemaChange.addColumn - posted by lz...@apache.org on 2023/01/04 01:44:58 UTC, 0 replies.
- [flink-table-store] 03/03: [FLINK-30522] Fix 'SHOW TBLPROPERTIES' can't read properties of table in Spark3 - posted by lz...@apache.org on 2023/01/04 01:44:59 UTC, 0 replies.
- [flink] branch release-1.16 updated (e7f7e6b8c17 -> dbb6654c9d2) - posted by go...@apache.org on 2023/01/04 02:06:59 UTC, 0 replies.
- [flink-table-store] branch master updated: [hotfix] fix typo in table-types - posted by lz...@apache.org on 2023/01/04 05:17:10 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30416][sql-gateway] Add configureSession REST API in the SQL Gateway (#21525) - posted by sh...@apache.org on 2023/01/04 08:21:38 UTC, 0 replies.
- [flink-table-store] branch master updated: [hotfix] Speedup build - posted by lz...@apache.org on 2023/01/04 08:28:19 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30389] Add retry to read hints - posted by lz...@apache.org on 2023/01/04 08:31:57 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated (eeb09ca1 -> 9cc9956c) - posted by lz...@apache.org on 2023/01/04 08:33:21 UTC, 0 replies.
- [flink-table-store] 01/02: [hotfix] fix typo in table-types - posted by lz...@apache.org on 2023/01/04 08:33:22 UTC, 0 replies.
- [flink-table-store] 02/02: [FLINK-30389] Add retry to read hints - posted by lz...@apache.org on 2023/01/04 08:33:23 UTC, 0 replies.
- svn commit: r59118 - in /dev/flink/flink-kubernetes-operator-1.3.1-rc1: ./ release/ - posted by gy...@apache.org on 2023/01/04 12:46:05 UTC, 0 replies.
- [flink] branch master updated (b48cddf12a3 -> e7631b51a51) - posted by mb...@apache.org on 2023/01/04 13:07:11 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30411] Validate empty JmSpec and TmSpec - posted by gy...@apache.org on 2023/01/04 13:07:27 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Fix documentation build - posted by mb...@apache.org on 2023/01/04 13:33:37 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30533][runtime] SourceOperator#emitNext() should push records to DataOutput in a while loop - posted by li...@apache.org on 2023/01/04 15:30:32 UTC, 0 replies.
- [flink-playgrounds] branch master updated: [FLINK-30441] Upgrading PyFlink walkthrough to Flink 1.16 - posted by da...@apache.org on 2023/01/04 16:33:32 UTC, 0 replies.
- [flink-playgrounds] branch release-1.16 created (now 4aa9a34) - posted by da...@apache.org on 2023/01/04 16:36:17 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30547] Flink-table-runtime free for flink-table-store-common - posted by lz...@apache.org on 2023/01/05 02:15:15 UTC, 0 replies.
- [flink-connector-pulsar] branch main updated: [FLINK-30552][Connector/Pulsar] Drop next message id calculation, use resetCursor api to exclude the given message. (#11) - posted by ti...@apache.org on 2023/01/05 02:52:15 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30497][table-api] Introduce TableChange to represent DROP change - posted by sh...@apache.org on 2023/01/05 04:26:56 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30560] Add more description of 'Overwriting a Partition' to doc 'Writing Tables' - posted by lz...@apache.org on 2023/01/05 04:34:40 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30560] Add more description of 'Overwriting a Partition' to doc 'Writing Tables' - posted by lz...@apache.org on 2023/01/05 04:35:29 UTC, 0 replies.
- [flink] branch master updated (cce059c556b -> b50f42673fc) - posted by zh...@apache.org on 2023/01/05 06:53:56 UTC, 0 replies.
- [flink] branch release-1.16 updated (dbb6654c9d2 -> fe5e0c1772f) - posted by zh...@apache.org on 2023/01/05 06:58:43 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30544][runtime] Speed up finding minimum watermark across all channels by introducing heap-based algorithm - posted by wa...@apache.org on 2023/01/05 09:22:02 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-27844] Support column type evolution in file meta - posted by lz...@apache.org on 2023/01/05 10:01:04 UTC, 0 replies.
- [flink] branch master updated (d9b8463da41 -> 898fe6ba6c8) - posted by xt...@apache.org on 2023/01/05 11:24:35 UTC, 0 replies.
- [flink] 01/03: [FLINK-30185][rest][refactor] Distinguish which ExecutionAttemptID each ThreadInfoSample belongs to - posted by xt...@apache.org on 2023/01/05 11:24:36 UTC, 0 replies.
- [flink] 02/03: [FLINK-30185][rest] Add the subtask index parameter for flame graph handler - posted by xt...@apache.org on 2023/01/05 11:24:37 UTC, 0 replies.
- [flink] 03/03: [FLINK-30185][ui] Allow choose the subtask index in the flame graph page - posted by xt...@apache.org on 2023/01/05 11:24:38 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30565] Flink-parquet free for flink-table-store-format - posted by lz...@apache.org on 2023/01/05 11:50:43 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30555] Hive cluster can not read oss/s3 tables - posted by lz...@apache.org on 2023/01/05 12:05:48 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30555] Hive cluster can not read oss/s3 tables - posted by lz...@apache.org on 2023/01/05 12:06:30 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30231][Kubernetes] Update to Fabric8 Kubernetes Client to 5.12.4. This closes #21599 - posted by ma...@apache.org on 2023/01/05 18:31:00 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-29607] Introduce FlinkResourceContext to simplify observer/reconciler logic - posted by gy...@apache.org on 2023/01/05 19:28:07 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30569] File Format can not change with data file exists - posted by lz...@apache.org on 2023/01/06 01:43:59 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30255] Throw exception when names are upper case in HiveCatalog - posted by lz...@apache.org on 2023/01/06 01:53:05 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30255] Throw exception when names are upper case in HiveCatalog - posted by lz...@apache.org on 2023/01/06 01:54:42 UTC, 0 replies.
- [flink-ml] branch master updated: [FLINK-30515] Add benchmark for CountVectorizer, Imputer, RobustScaler, UnivariateFeatureSelector and VarianceThresholdSelector - posted by li...@apache.org on 2023/01/06 06:02:59 UTC, 0 replies.
- [flink-ml] branch master updated: [FLINK-30249] Fix TableUtils.getRowTypeInfo by using ExternalTypeInfo.of() - posted by li...@apache.org on 2023/01/06 06:24:05 UTC, 0 replies.
- [flink-ml] branch master updated: [FLINK-30348] Add HasSeed param for RandomSplitter - posted by zh...@apache.org on 2023/01/06 06:48:35 UTC, 0 replies.
- [flink-ml] branch master updated (6f8aa57 -> 3bd19a2) - posted by li...@apache.org on 2023/01/06 06:59:21 UTC, 0 replies.
- [flink-ml] 01/02: [hotfix] Add document for DCT algorithm - posted by li...@apache.org on 2023/01/06 06:59:22 UTC, 0 replies.
- [flink-ml] 02/02: [FLINK-30532] Add benchmark for DCT, SQLTransformer and StopWordsRemover - posted by li...@apache.org on 2023/01/06 06:59:23 UTC, 0 replies.
- [flink] branch master updated (1028ee32852 -> d65f7c1c2f3) - posted by xt...@apache.org on 2023/01/06 08:05:51 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30573] Fix bug that Table Store dedicated compact job may skip some records when checkpoint interval is long - posted by lz...@apache.org on 2023/01/06 08:06:56 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30573] Fix bug that Table Store dedicated compact job may skip some records when checkpoint interval is long - posted by cz...@apache.org on 2023/01/06 08:17:10 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30557][connector/kinesis] Remove Kinesis Data Streams connectors from Flink master branch - posted by da...@apache.org on 2023/01/06 08:36:28 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30582] Flink-avro Flink-orc free for flink-table-store-format - posted by lz...@apache.org on 2023/01/06 09:28:37 UTC, 0 replies.
- [flink-connector-pulsar] branch main updated: [FLINK-25686][Connector/Pulsar] Support schema evolution for Pulsar source and sink. (#12) - posted by ti...@apache.org on 2023/01/08 08:45:44 UTC, 0 replies.
- [flink] branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/json5-1.0.2 created (now 0a5541357d5) - posted by gi...@apache.org on 2023/01/08 11:17:01 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30581] Deprecate FileStoreTableITCase and use CatalogITCaseBase - posted by lz...@apache.org on 2023/01/09 02:03:38 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30589] Snapshot expiration should be skipped in Table Store dedicated writer jobs - posted by lz...@apache.org on 2023/01/09 02:06:01 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30589] Snapshot expiration should be skipped in Table Store dedicated writer jobs - posted by lz...@apache.org on 2023/01/09 02:07:56 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30587] Validate primary key in append-only table in ddl - posted by lz...@apache.org on 2023/01/09 02:08:49 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30587] Validate primary key in append-only table in ddl - posted by lz...@apache.org on 2023/01/09 02:09:22 UTC, 0 replies.
- [flink-table-store] branch master updated: [hotfix] Fix typo in documentation - posted by lz...@apache.org on 2023/01/09 02:35:02 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30595] support create table like - posted by lz...@apache.org on 2023/01/09 02:37:29 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30595] support create table like - posted by lz...@apache.org on 2023/01/09 02:38:05 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30592][doc] Remove unsupported hive version in hive overview document (#21611) - posted by ja...@apache.org on 2023/01/09 02:44:32 UTC, 0 replies.
- svn commit: r59204 - /dev/flink/flink-table-store-0.3.0-rc1/ - posted by lz...@apache.org on 2023/01/09 04:00:56 UTC, 0 replies.
- [flink-table-store] annotated tag release-0.3.0-rc1 updated (9922a48b -> 66fd6604) - posted by lz...@apache.org on 2023/01/09 04:07:51 UTC, 0 replies.
- [flink] branch master updated: [FLINK-28796][sql-gateway] Add completeStatement REST API in the SQL Gateway - posted by sh...@apache.org on 2023/01/09 04:14:23 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns - posted by go...@apache.org on 2023/01/09 04:31:40 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30600] Merge flink-table-store-kafka to flink-table-store-connector - posted by lz...@apache.org on 2023/01/09 05:49:59 UTC, 0 replies.
- [flink-table-store] branch master updated: [hotfix][doc] Document partial-update.ignore-delete - posted by lz...@apache.org on 2023/01/09 06:27:05 UTC, 0 replies.
- [flink-table-store] branch master updated: [hotfix][doc] Add download to oss and s3 - posted by lz...@apache.org on 2023/01/09 06:39:50 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated (ed96a7ca -> 651bffbf) - posted by lz...@apache.org on 2023/01/09 06:40:24 UTC, 0 replies.
- [flink-table-store] 01/02: [hotfix][doc] Document partial-update.ignore-delete - posted by lz...@apache.org on 2023/01/09 06:40:25 UTC, 0 replies.
- [flink-table-store] 02/02: [hotfix][doc] Add download to oss and s3 - posted by lz...@apache.org on 2023/01/09 06:40:26 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30602] Remove FileStoreTableITCase in table store - posted by lz...@apache.org on 2023/01/09 06:41:20 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30584][docs] Document flame graph at the subtask level - posted by xt...@apache.org on 2023/01/09 08:13:19 UTC, 0 replies.
- [flink] branch master updated (b4810b5a0fd -> 1ac202dd8c2) - posted by ma...@apache.org on 2023/01/09 08:33:04 UTC, 0 replies.
- [flink] branch master updated (1ac202dd8c2 -> 8aa446a8aa7) - posted by di...@apache.org on 2023/01/09 09:46:35 UTC, 0 replies.
- [flink] branch release-1.16 updated (fe5e0c1772f -> bbd7b2c0d2c) - posted by di...@apache.org on 2023/01/09 09:49:15 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-30308][python] Fix ClassLeakCleaner to work with Java 11.0.16+ and 17.0.4+ - posted by di...@apache.org on 2023/01/09 09:49:39 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30536][runtime] Remove CountingOutput from per-record code path for most operators - posted by li...@apache.org on 2023/01/09 10:44:38 UTC, 0 replies.
- [flink] branch master updated (c45c4a05dd2 -> d37fca88cfa) - posted by sh...@apache.org on 2023/01/09 11:48:54 UTC, 0 replies.
- [flink] branch revert-21371-30166 created (now f77032efb9f) - posted by ma...@apache.org on 2023/01/09 12:26:45 UTC, 0 replies.
- [flink] 01/08: Revert "[FLINK-30166][ORC] Refactor deprecated StreamingFileSink usage with target FileSink" - posted by ma...@apache.org on 2023/01/09 12:26:46 UTC, 0 replies.
- [flink] 02/08: Revert "[FLINK-30166][Hadoop Compress] Refactor deprecated StreamingFileSink usage with target FileSink" - posted by ma...@apache.org on 2023/01/09 12:26:47 UTC, 0 replies.
- [flink] 03/08: Revert "[FLINK-30166][Hadoop Sequence Format] Refactor deprecated StreamingFileSink usage with target FileSink" - posted by ma...@apache.org on 2023/01/09 12:26:48 UTC, 0 replies.
- [flink] 04/08: Revert "[FLINK-30166][SQL E2E Test] Refactor deprecated StreamingFileSink usage with target FileSink" - posted by ma...@apache.org on 2023/01/09 12:26:49 UTC, 0 replies.
- [flink] 05/08: Revert "[FLINK-30166][Parquet] Refactor deprecated StreamingFileSink usage with target FileSink" - posted by ma...@apache.org on 2023/01/09 12:26:50 UTC, 0 replies.
- [flink] 06/08: Revert "[FLINK-30166][Tests] Remove StreamingFileSink as option for tests" - posted by ma...@apache.org on 2023/01/09 12:26:51 UTC, 0 replies.
- [flink] 07/08: Revert "[FLINK-30166][Tests] Remove no longer necessary test" - posted by ma...@apache.org on 2023/01/09 12:26:52 UTC, 0 replies.
- [flink] 08/08: Revert "[FLINK-30166][AVRO] Refactor deprecated StreamingFileSink usage with target FileSink" - posted by ma...@apache.org on 2023/01/09 12:26:53 UTC, 0 replies.
- [flink] branch master updated (d37fca88cfa -> 974f884021e) - posted by ma...@apache.org on 2023/01/09 12:34:16 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30578][build] Publish SBOM artifacts - posted by mb...@apache.org on 2023/01/09 21:12:41 UTC, 0 replies.
- [flink] branch master updated (9bb6500e2fa -> 627d293b693) - posted by ma...@apache.org on 2023/01/10 00:03:05 UTC, 0 replies.
- [flink] 01/03: [FLINK-29710][Filesystem] Bump minimum supported Hadoop version to 2.10.2 - posted by ma...@apache.org on 2023/01/10 00:03:06 UTC, 0 replies.
- [flink] 02/03: [FLINK-29710][Hadoop/Hive] Exclude Reload4J from all Hadoop and Hive dependencies - posted by ma...@apache.org on 2023/01/10 00:03:07 UTC, 0 replies.
- [flink] 03/03: [hotfix] Sync English version of gcs.md to Chinese version due to being out-of-sync - posted by ma...@apache.org on 2023/01/10 00:03:08 UTC, 0 replies.
- [flink] branch dependabot/maven/flink-connectors/flink-connector-hive/org.apache.hadoop-hadoop-common-3.2.4 created (now 444d7b825e0) - posted by gi...@apache.org on 2023/01/10 00:05:14 UTC, 0 replies.
- [flink] branch master updated (627d293b693 -> 13fd4f270a3) - posted by ma...@apache.org on 2023/01/10 00:05:27 UTC, 0 replies.
- [flink] branch master updated: [FLINK-28742][python] Fix ArrowUtils to support CHAR type - posted by di...@apache.org on 2023/01/10 01:40:22 UTC, 0 replies.
- [flink] branch release-1.16 updated (bbd7b2c0d2c -> 2b77c837636) - posted by di...@apache.org on 2023/01/10 01:40:42 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-28742][python] Fix ArrowUtils to support CHAR type - posted by di...@apache.org on 2023/01/10 01:41:23 UTC, 0 replies.
- [flink-web] branch add-committer-lincoln created (now 868351998) - posted by li...@apache.org on 2023/01/10 01:46:47 UTC, 0 replies.
- [flink-web] 01/02: Add Lincoln Lee to the committer list - posted by li...@apache.org on 2023/01/10 01:46:48 UTC, 2 replies.
- [flink-web] 02/02: Rebuild website - posted by li...@apache.org on 2023/01/10 01:46:49 UTC, 3 replies.
- [flink-web] branch add-committer-lincoln updated (868351998 -> 642f35fb0) - posted by li...@apache.org on 2023/01/10 01:53:23 UTC, 0 replies.
- [flink] branch master updated (0f14f13122e -> c8ecfadfb96) - posted by xt...@apache.org on 2023/01/10 02:13:30 UTC, 0 replies.
- [flink] branch master updated: [FLINK-29640] Enhance the function configured by execution.shutdown-on-attached-exit by heartbeat between client and dispatcher - posted by xt...@apache.org on 2023/01/10 02:19:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30491][hive] Hive table partition supports lazy deserialization during runtime - posted by go...@apache.org on 2023/01/10 02:34:58 UTC, 0 replies.
- [flink-web] branch asf-site updated (f87b576c1 -> 9f595f70f) - posted by li...@apache.org on 2023/01/10 03:50:26 UTC, 0 replies.
- [flink-connector-pulsar] branch main updated: [FLINK-28082][Connector/Pulsar] Add end-to-end encryption support for Pulsar connector. (#13) - posted by ti...@apache.org on 2023/01/10 03:59:33 UTC, 0 replies.
- [flink] branch master updated: [FLINK-27327][docs] Add description about changing max parallelism explicitly leads to state incompatibility - posted by ta...@apache.org on 2023/01/10 04:16:12 UTC, 0 replies.
- [flink] branch release-1.16 updated (2b77c837636 -> 85248af102f) - posted by ta...@apache.org on 2023/01/10 04:19:10 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-27327][docs] Add description about changing max parallelism explicitly leads to state incompatibility - posted by ta...@apache.org on 2023/01/10 04:22:41 UTC, 0 replies.
- svn commit: r59234 - /dev/flink/flink-kubernetes-operator-1.3.1-rc1/ /release/flink/flink-kubernetes-operator-1.3.1/ - posted by gy...@apache.org on 2023/01/10 05:43:32 UTC, 0 replies.
- svn commit: r59235 - /release/flink/flink-kubernetes-operator-1.3.0/ - posted by gy...@apache.org on 2023/01/10 05:45:25 UTC, 0 replies.
- [flink-kubernetes-operator] annotated tag release-1.3.1 updated (8e60e9b4 -> 7c4f2f01) - posted by gy...@apache.org on 2023/01/10 05:48:10 UTC, 0 replies.
- [flink-kubernetes-operator] branch release-1.3 updated: [release] Update doc version - posted by gy...@apache.org on 2023/01/10 05:53:34 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30586][table-runtime] Fix calcCodeGen failed if calc with 'like' condition contains double quotation mark - posted by go...@apache.org on 2023/01/10 06:22:59 UTC, 0 replies.
- [flink] branch release-1.16 updated (85248af102f -> 54518e9e27c) - posted by go...@apache.org on 2023/01/10 06:50:48 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30603] Fix unstable test CompactActionITCase#testStreamingCompact - posted by cz...@apache.org on 2023/01/10 07:34:22 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30603] Fix unstable test CompactActionITCase#testStreamingCompact - posted by cz...@apache.org on 2023/01/10 07:35:52 UTC, 0 replies.
- [flink-connector-pulsar] branch main updated: [FLINK-28870][Connector/Pulsar] Improve the Pulsar source performance when meeting small data rates. (#15) - posted by ti...@apache.org on 2023/01/10 08:40:05 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30611] Expiration can be performed with missing files - posted by cz...@apache.org on 2023/01/10 10:38:11 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30611] Expiration can be performed with missing files - posted by cz...@apache.org on 2023/01/10 10:39:12 UTC, 0 replies.
- [flink-web] branch asf-site updated (9f595f70f -> b8d3edecb) - posted by gy...@apache.org on 2023/01/10 14:10:22 UTC, 0 replies.
- [flink-web] 01/02: Flink Kubernetes Operator 1.3.1 - posted by gy...@apache.org on 2023/01/10 14:10:23 UTC, 0 replies.
- [flink-web] 02/02: regenerate website - posted by gy...@apache.org on 2023/01/10 14:10:24 UTC, 1 replies.
- [flink] branch master updated (68b37fb8673 -> ca18dd7c836) - posted by wa...@apache.org on 2023/01/10 14:48:32 UTC, 0 replies.
- [flink] 01/01: [FLINK-29666][runtime] Let job vertices whose parallelism has already been decided can be initialized earlier. - posted by wa...@apache.org on 2023/01/10 14:48:33 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30610] Flink-table-runtime free for disk io in flink-core - posted by lz...@apache.org on 2023/01/10 15:16:10 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30485][Connector/RabbitMQ] Remove RabbitMQ connector. This closes #21550 - posted by ma...@apache.org on 2023/01/10 21:19:11 UTC, 0 replies.
- [flink] branch release-1.16 updated (54518e9e27c -> 997365ebc70) - posted by ja...@apache.org on 2023/01/11 02:09:34 UTC, 0 replies.
- [flink] branch master updated (cfe794b792b -> afc8fb08ab0) - posted by di...@apache.org on 2023/01/11 02:46:23 UTC, 0 replies.
- [flink] 01/03: [FLINK-30607][python] Support MapType for Pandas UDF - posted by di...@apache.org on 2023/01/11 02:46:24 UTC, 0 replies.
- [flink] 02/03: [FLINK-30607][python] Support BinaryType for Pandas UDF - posted by di...@apache.org on 2023/01/11 02:46:25 UTC, 0 replies.
- [flink] 03/03: [FLINK-30607][python] Support NoneType for Pandas UDF - posted by di...@apache.org on 2023/01/11 02:46:26 UTC, 0 replies.
- [flink-ml] branch master updated: [FLINK-30401] Add Estimator and Transformer for MinHashLSH - posted by zh...@apache.org on 2023/01/11 03:07:35 UTC, 0 replies.
- [flink-connector-pulsar] branch v3.0 updated: [FLINK-30552][Connector/Pulsar] Drop next message id calculation, use resetCursor api to exclude the given message. (#16) - posted by ti...@apache.org on 2023/01/11 07:57:19 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30615] Refactor ReadWriteTableITCase to get rid of Managed Table and introduce new AbstractTestBase - posted by lz...@apache.org on 2023/01/11 08:09:01 UTC, 0 replies.
- [flink-ml] branch master updated: [FLINK-30566] Add benchmark for AgglomerativeClustering, HashingTF, IDF, KBinsDiscretizer, LinearRegression, LinearSVC, LogisticRegression, NGram, RegexTokenizer, Tokenizer and Vectorindexer - posted by li...@apache.org on 2023/01/11 08:12:11 UTC, 0 replies.
- [flink] branch master updated: [hotfix][client][test] Disable the unstable ClientHeartbeatTest#testJobRunningIfClientReportHeartbeat. - posted by xt...@apache.org on 2023/01/11 09:46:52 UTC, 0 replies.
- [flink] branch master updated (9b5394ad8f1 -> 78ab08bfc8e) - posted by ma...@apache.org on 2023/01/11 14:07:43 UTC, 0 replies.
- [flink] branch master updated (78ab08bfc8e -> 176f8d55601) - posted by ma...@apache.org on 2023/01/11 16:30:24 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30375][Table SQL / Client] sql-client leaks flink-table-planner jar in /tmp (#21512) - posted by da...@apache.org on 2023/01/11 20:57:59 UTC, 0 replies.
- [flink] branch master updated (086f13a9cd6 -> f611ea8cb5d) - posted by xt...@apache.org on 2023/01/12 03:27:12 UTC, 0 replies.
- [flink] branch master updated: [FLINK-28655][sql-gateway] Support SHOW JOBS syntax in SqlGateway - posted by sh...@apache.org on 2023/01/12 06:26:08 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Fix minor grammar typo in flink-architecture docs. This closes #21632 - posted by ma...@apache.org on 2023/01/12 07:24:50 UTC, 0 replies.
- [flink-connector-aws] branch v4.0 created (now 4e14ed6) - posted by da...@apache.org on 2023/01/12 07:57:40 UTC, 0 replies.
- [flink-connector-aws] branch v4.0 updated: [hotfix][docs] Correct connector shortcode on v4.0 branch - posted by da...@apache.org on 2023/01/12 08:13:01 UTC, 1 replies.
- [flink] branch master updated: [FLINK-14023][python] Support accessing job parameters in Python user-defined functions - posted by di...@apache.org on 2023/01/12 09:13:56 UTC, 0 replies.
- [flink] branch master updated (5cb434c36da -> 6a15b7e9b24) - posted by sh...@apache.org on 2023/01/12 11:41:57 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated (35604761 -> 8e41ed5e) - posted by gy...@apache.org on 2023/01/12 11:57:06 UTC, 0 replies.
- [flink-kubernetes-operator] 01/04: Decouple scaling execution from parallelism computation - posted by gy...@apache.org on 2023/01/12 11:57:07 UTC, 0 replies.
- [flink-kubernetes-operator] 02/04: [FLINK-30574] Detect ineffective scale up operations to avoid scaling further - posted by gy...@apache.org on 2023/01/12 11:57:08 UTC, 0 replies.
- [flink-kubernetes-operator] 03/04: [hotfix] Improve AutoScalerInfo - posted by gy...@apache.org on 2023/01/12 11:57:09 UTC, 0 replies.
- [flink-kubernetes-operator] 04/04: [hotfix][e2e] Pin busybox version - posted by gy...@apache.org on 2023/01/12 11:57:10 UTC, 0 replies.
- [flink] branch master updated: [FLINK-27640][Connector/Hive] Exclude pentaho-aggdesigner-algorithm from Hive connector dependencies. This closes #21653 - posted by ma...@apache.org on 2023/01/12 12:16:07 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30604][runtime] Remove the limitation that parallelism decided by adaptive batch scheduler is always a power of two - posted by wa...@apache.org on 2023/01/12 14:00:04 UTC, 0 replies.
- [flink-connector-aws] branch v3.0 updated (ba35b67 -> eed230f) - posted by da...@apache.org on 2023/01/12 14:12:53 UTC, 0 replies.
- [flink-connector-aws] 01/02: [FLINK-30633][Connectors/AWS] Normalize NOTICE file - posted by da...@apache.org on 2023/01/12 14:12:54 UTC, 0 replies.
- [flink-connector-aws] 02/02: [FLINK-30633][Connectors/AWS] Update AWS SDKv2 to v2.19.14 and Netty to 4.1.86.Final - posted by da...@apache.org on 2023/01/12 14:12:55 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30632] Introduce DataType for table store - posted by lz...@apache.org on 2023/01/12 14:58:00 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30213] Fix logic for determining downstream subtasks for partitioner replacement - posted by gy...@apache.org on 2023/01/12 15:23:59 UTC, 0 replies.
- [flink-connector-shared-utils] branch parent_pom created (now 1e05d70) - posted by ch...@apache.org on 2023/01/12 16:41:00 UTC, 0 replies.
- [flink-connector-shared-utils] 01/01: Add 1.0 connector parent pom - posted by ch...@apache.org on 2023/01/12 16:41:01 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30599][build] Publish SBOM artifacts (#503) - posted by mb...@apache.org on 2023/01/12 17:12:38 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Update the outdated documentation about broadcast state's support in PyFlink - posted by di...@apache.org on 2023/01/13 01:51:58 UTC, 0 replies.
- [flink] branch release-1.16 updated (997365ebc70 -> 5ac47d61134) - posted by di...@apache.org on 2023/01/13 01:52:26 UTC, 0 replies.
- [flink] branch master updated: [minor][python][tests] Add some test cases for binary and char types - posted by di...@apache.org on 2023/01/13 01:54:19 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30646] Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented - posted by cz...@apache.org on 2023/01/13 02:11:49 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30646] Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented - posted by cz...@apache.org on 2023/01/13 02:14:20 UTC, 0 replies.
- [flink] branch master updated (6b3a5dba6c1 -> 28c3e1a3923) - posted by ta...@apache.org on 2023/01/13 03:03:00 UTC, 0 replies.
- [flink-table-store] branch master updated: [hotfix] Document back quotes for system table triple access mode - posted by lz...@apache.org on 2023/01/13 03:27:28 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [hotfix] Document back quotes for system table triple access mode - posted by lz...@apache.org on 2023/01/13 03:27:56 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30620] Table Store Hive catalog supports specifying custom Hive metastore client - posted by cz...@apache.org on 2023/01/13 06:20:02 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30620] Table Store Hive catalog supports specifying custom Hive metastore client - posted by cz...@apache.org on 2023/01/13 06:21:54 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30425][runtime][security] Generalize token receive side - posted by mb...@apache.org on 2023/01/13 08:32:12 UTC, 0 replies.
- [flink-connector-aws] branch main updated (9ee0fe3 -> 2a24e7c) - posted by da...@apache.org on 2023/01/13 08:48:19 UTC, 0 replies.
- [flink] branch master updated (324b54cf413 -> a32bf0faf0e) - posted by da...@apache.org on 2023/01/13 08:53:51 UTC, 0 replies.
- [flink-table-store] branch master updated: [docs] Remove "embedded" SQL CLI parameter in the Flink quickstart documentation - posted by lz...@apache.org on 2023/01/13 09:55:25 UTC, 0 replies.
- [flink-connector-shared-utils] branch parent_pom updated: [hotfix] Fix parent section - posted by ch...@apache.org on 2023/01/13 14:34:54 UTC, 0 replies.
- [flink-connector-shared-utils] branch parent_pom updated: [hotfix] Add missing groupId - posted by ch...@apache.org on 2023/01/13 14:36:54 UTC, 0 replies.
- [flink-connector-shared-utils] branch parent_pom updated: [hotfix] Fix parent groupId - posted by ch...@apache.org on 2023/01/13 14:41:03 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-30633][Connectors/AWS] Update AWS SDKv2 to v2.19.14 - posted by da...@apache.org on 2023/01/13 14:47:03 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30525][web] Remove broken reference to env variables field - posted by ch...@apache.org on 2023/01/13 15:00:46 UTC, 0 replies.
- svn commit: r59318 - /dev/flink/flink-table-store-0.3.0-rc1/ /release/flink/flink-table-store-0.3.0/ - posted by lz...@apache.org on 2023/01/13 15:07:06 UTC, 0 replies.
- [flink] branch release-1.16 updated (5ac47d61134 -> 8283dfcf69f) - posted by ch...@apache.org on 2023/01/13 15:08:20 UTC, 0 replies.
- svn commit: r59319 - /release/flink/flink-table-store-0.1.0/ - posted by lz...@apache.org on 2023/01/13 15:08:41 UTC, 0 replies.
- [flink-table-store] annotated tag release-0.3.0 updated (9922a48b -> 66fd6604) - posted by lz...@apache.org on 2023/01/13 15:11:54 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: Release 0.3.0 - posted by lz...@apache.org on 2023/01/13 15:16:20 UTC, 0 replies.
- [flink-web] branch asf-site updated: Table Store Release 0.3.0 - posted by lz...@apache.org on 2023/01/13 15:33:15 UTC, 0 replies.
- [flink-web] branch asf-site updated: regenerate website - posted by lz...@apache.org on 2023/01/13 15:40:45 UTC, 0 replies.
- [flink-web] branch asf-site updated (2f3a3c4a5 -> a96ace934) - posted by lz...@apache.org on 2023/01/13 15:53:36 UTC, 0 replies.
- [flink-web] 01/02: update table store stable to 0.3 - posted by lz...@apache.org on 2023/01/13 15:53:37 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30652] Use max busytime to compute true processing rate - posted by gy...@apache.org on 2023/01/13 20:35:07 UTC, 0 replies.
- [flink] branch master updated: [FLINK-27731][Documentation][Build] Remove Hugo Modules code for setting up documentation since Flink now uses git to retrieve externally hosted documentation instead of Hugo Modules - posted by ma...@apache.org on 2023/01/14 13:20:12 UTC, 0 replies.
- [flink-connector-pulsar] branch main updated: [FLINK-30681][Connector/Pulsar] Add a warning hint on the delivery guarantee document. (#18) - posted by ti...@apache.org on 2023/01/15 02:55:17 UTC, 0 replies.
- [flink] branch master updated (439fdbd093d -> db5affc6159) - posted by sh...@apache.org on 2023/01/15 09:41:54 UTC, 0 replies.
- [flink] branch master updated: [FLINK-19883][table] Support "IF EXISTS" in DDL for ALTER TABLE - posted by sh...@apache.org on 2023/01/15 09:56:49 UTC, 0 replies.
- [flink] branch master updated (c26daffb904 -> 56b124bcfd6) - posted by li...@apache.org on 2023/01/15 14:08:14 UTC, 0 replies.
- [flink] 01/02: [FLINK-30668][table-api] Introduce ExplainFormat to Explainable and TableEnvironment - posted by li...@apache.org on 2023/01/15 14:08:15 UTC, 0 replies.
- [flink] 02/02: [FLINK-30668][table-planner] Introduce ExplainFormat to Planner - posted by li...@apache.org on 2023/01/15 14:08:16 UTC, 0 replies.
- [flink] branch master updated (56b124bcfd6 -> addca4e18aa) - posted by di...@apache.org on 2023/01/16 01:34:05 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-29231][python] Fix the issue that Python UDAF may produce multiple results for the same window - posted by di...@apache.org on 2023/01/16 01:34:51 UTC, 0 replies.
- [flink] branch release-1.16 updated (8283dfcf69f -> 6d3d66ca71a) - posted by di...@apache.org on 2023/01/16 01:35:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30168][python] Fix DataStream.execute_and_collect to support None data and ObjectArray - posted by di...@apache.org on 2023/01/16 01:40:36 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-30168][python] Fix DataStream.execute_and_collect to support None data and ObjectArray - posted by di...@apache.org on 2023/01/16 01:41:30 UTC, 0 replies.
- [flink] branch release-1.16 updated (6d3d66ca71a -> 46c91ed4bc2) - posted by di...@apache.org on 2023/01/16 01:41:52 UTC, 0 replies.
- [flink-ml] branch master updated: [FLINK-30578][build] Publish SBOM for externalized connectors - posted by li...@apache.org on 2023/01/16 01:56:07 UTC, 0 replies.
- [flink] branch master updated (46757739cf5 -> 8e50e24797f) - posted by xt...@apache.org on 2023/01/16 02:22:52 UTC, 0 replies.
- [flink] 01/04: [FLINK-30332][network] Introduce InternalRegionWriteReadUtils to read and write region. - posted by xt...@apache.org on 2023/01/16 02:22:53 UTC, 0 replies.
- [flink] 02/04: [FLINK-30332][network] Introduce HsFileDataIndexSpilledRegionManager to manage spilled regions. - posted by xt...@apache.org on 2023/01/16 02:22:54 UTC, 0 replies.
- [flink] 03/04: [FLINK-30332][network] Introduce HsFileDataIndexCache to cache and manage index data. - posted by xt...@apache.org on 2023/01/16 02:22:55 UTC, 0 replies.
- [flink] 04/04: [FLINK-30332][network] HsFileDataIndex supports caching index entry and introduce config option to configure cache size. - posted by xt...@apache.org on 2023/01/16 02:22:56 UTC, 0 replies.
- [flink] branch release-1.16 updated (46c91ed4bc2 -> 4acfbee2175) - posted by da...@apache.org on 2023/01/16 08:57:49 UTC, 0 replies.
- [flink] branch master updated (8e50e24797f -> c0c7dc47905) - posted by wa...@apache.org on 2023/01/16 09:13:59 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30676] Introduce Data Structures for table store - posted by lz...@apache.org on 2023/01/16 09:15:04 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30617][hive] Fix wrong data type for cast null literal with Hive dialect - posted by ji...@apache.org on 2023/01/16 09:27:54 UTC, 0 replies.
- [flink] branch master updated (1c524794362 -> 904c695776a) - posted by li...@apache.org on 2023/01/16 10:00:49 UTC, 0 replies.
- [flink] 01/04: [FLINK-30661][table] introduce SupportsRowLevelModificationScan interface - posted by li...@apache.org on 2023/01/16 10:00:50 UTC, 0 replies.
- [flink] 02/04: [FLINK-30661][table] introduce SupportsDeletePushDown interface - posted by li...@apache.org on 2023/01/16 10:00:51 UTC, 0 replies.
- [flink] 03/04: [FLINK-30661][table] introduce SupportsRowLevelDelete interface - posted by li...@apache.org on 2023/01/16 10:00:52 UTC, 0 replies.
- [flink] 04/04: [FLINK-30661][table] introduce SupportsRowLevelUpdate interface - posted by li...@apache.org on 2023/01/16 10:00:53 UTC, 0 replies.
- [flink] branch master updated (904c695776a -> 60101e120fb) - posted by ch...@apache.org on 2023/01/16 12:38:44 UTC, 0 replies.
- [flink] branch master updated (60101e120fb -> 0c4fdb6cb56) - posted by ch...@apache.org on 2023/01/16 13:05:42 UTC, 0 replies.
- [flink] branch master updated: [FLINK-28526][python] Fix Python UDF to support time indicator inputs - posted by di...@apache.org on 2023/01/17 02:06:57 UTC, 0 replies.
- [flink] branch master updated (d8417565d6f -> ae8de97ef2a) - posted by xt...@apache.org on 2023/01/17 02:18:24 UTC, 0 replies.
- [flink] 01/03: [FLINK-30471][network] Optimize the enriching network memory process in SsgNetworkMemoryCalculationUtils - posted by xt...@apache.org on 2023/01/17 02:18:25 UTC, 0 replies.
- [flink] 02/03: [FLINK-30472][network] Modify the default value of the max network memory config option - posted by xt...@apache.org on 2023/01/17 02:18:26 UTC, 0 replies.
- [flink] 03/03: [FLINK-30473][network] Optimize the InputGate network memory management for TaskManager - posted by xt...@apache.org on 2023/01/17 02:18:27 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30601][runtime] Omit "setKeyContextElement" call for non-keyed stream/operators to improve performance - posted by wa...@apache.org on 2023/01/17 06:29:38 UTC, 0 replies.
- [flink] branch master updated (4e3cd986cd4 -> d053867fb5c) - posted by hx...@apache.org on 2023/01/17 07:07:56 UTC, 0 replies.
- [flink] branch release-1.16 updated (4acfbee2175 -> eca940c5bf9) - posted by hx...@apache.org on 2023/01/17 07:08:58 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-30637][python] Replace 'is' with '==' to fix potential match issues with OverWindow Aggregation On Linux-arch64 - posted by hx...@apache.org on 2023/01/17 07:09:54 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30169][python][doc] Adds switcher.json file - posted by hx...@apache.org on 2023/01/17 07:25:21 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30710] Fix invalid field id for nested type in spark catalog - posted by lz...@apache.org on 2023/01/17 07:51:45 UTC, 0 replies.
- [flink-table-store] branch master updated: [hotfix][doc] Add 0.3 previous docs - posted by lz...@apache.org on 2023/01/17 08:18:02 UTC, 0 replies.
- [flink] branch release-1.16 updated (eca940c5bf9 -> 56a50453cfa) - posted by ma...@apache.org on 2023/01/17 08:31:38 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-27731][Documentation][Build] Remove Hugo Modules code for setting up documentation since Flink now uses git to retrieve externally hosted documentation instead of Hugo Modules - posted by ma...@apache.org on 2023/01/17 08:31:42 UTC, 0 replies.
- [flink] branch master updated (e6b5755d0ac -> 06435cec2e5) - posted by xt...@apache.org on 2023/01/17 09:35:48 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30706] Remove flink-table-common dependency for table store core - posted by lz...@apache.org on 2023/01/17 09:39:55 UTC, 0 replies.
- [flink] branch master updated: [FLINK-29879][filesystem] Introduce operators for merging files in batch mode (#21257) - posted by ja...@apache.org on 2023/01/17 09:56:09 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30579][hive] Introducing configurable option to use hive native function - posted by sh...@apache.org on 2023/01/17 10:13:45 UTC, 0 replies.
- [flink] branch master updated (95869e0bc99 -> 6cecf624552) - posted by sh...@apache.org on 2023/01/17 10:17:30 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30701] Remove SimpleTableTestHelper and use sql in SparkITCase - posted by lz...@apache.org on 2023/01/17 11:16:13 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30711] Support dropping partition via Flink action - posted by lz...@apache.org on 2023/01/17 11:17:15 UTC, 0 replies.
- [flink] branch master updated (6cecf624552 -> 128b0c4442a) - posted by sh...@apache.org on 2023/01/17 11:18:00 UTC, 0 replies.
- [flink-connector-aws] branch main updated: [FLINK-30418] [Connectors/Kinesis] Implement synchronous KinesisClient in EFO - posted by da...@apache.org on 2023/01/17 11:56:39 UTC, 0 replies.
- [flink-connector-elasticsearch] branch main updated: [FLINK-30359][es] flink-sql-connector-elasticsearch6's jar should including the dependency of com.carrotsearch:hppc. - posted by ma...@apache.org on 2023/01/17 12:02:15 UTC, 0 replies.
- [flink-table-store] branch release-0.3 updated: [FLINK-30711] Support dropping partition via Flink action - posted by lz...@apache.org on 2023/01/17 12:19:55 UTC, 0 replies.
- [flink] branch master updated (128b0c4442a -> 14ea1a58e9b) - posted by go...@apache.org on 2023/01/17 13:17:45 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30693][sql-gateway] Supports to specify RowFormat when fetching results - posted by sh...@apache.org on 2023/01/17 13:20:36 UTC, 0 replies.
- [flink-training] branch 30717 created (now 3f281f6) - posted by ch...@apache.org on 2023/01/17 14:47:33 UTC, 0 replies.
- [flink-training] 01/01: [FLINK-30717][ci] Migrate to GitHub Actions - posted by ch...@apache.org on 2023/01/17 14:47:34 UTC, 1 replies.
- [flink-training] branch 30717 updated (3f281f6 -> c286769) - posted by ch...@apache.org on 2023/01/17 14:49:35 UTC, 0 replies.
- [flink-benchmarks] branch 30717 created (now a83702b) - posted by ch...@apache.org on 2023/01/17 14:56:39 UTC, 0 replies.
- [flink-benchmarks] 01/01: [FLINK-30717][ci] Migrate to GitHub Actions - posted by ch...@apache.org on 2023/01/17 14:56:40 UTC, 1 replies.
- [flink-benchmarks] branch 30717 updated (a83702b -> bf57a85) - posted by ch...@apache.org on 2023/01/17 15:00:51 UTC, 0 replies.
- [flink] branch release-1.16 updated (56a50453cfa -> 4150d709906) - posted by di...@apache.org on 2023/01/17 15:03:12 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-28526][python] Fix Python UDF to support time indicator inputs - posted by di...@apache.org on 2023/01/17 15:08:09 UTC, 0 replies.
- [flink-benchmarks] branch 30717 updated (bf57a85 -> 9d7d868) - posted by ch...@apache.org on 2023/01/17 16:19:10 UTC, 0 replies.
- [flink-benchmarks] branch 30717 updated (9d7d868 -> 7db69ca) - posted by ch...@apache.org on 2023/01/17 16:21:26 UTC, 0 replies.
- [flink-benchmarks] branch 30717 updated (7db69ca -> 3b2849f) - posted by ch...@apache.org on 2023/01/17 16:54:20 UTC, 0 replies.
- [flink-benchmarks] branch 30717 updated (3b2849f -> 308dcce) - posted by ch...@apache.org on 2023/01/17 17:11:19 UTC, 0 replies.
- [flink] branch master updated: [FLINK-29721][hive] Supports native hive min function for hive dialect - posted by go...@apache.org on 2023/01/18 02:29:58 UTC, 0 replies.
- [flink] branch master updated: [hotfix][doc][azure-fs] Correct documentation regarding FileSink ABFS support. - posted by xt...@apache.org on 2023/01/18 08:54:39 UTC, 0 replies.
- [flink-training] branch 30717 updated (c286769 -> 60a6bba) - posted by ch...@apache.org on 2023/01/18 09:42:51 UTC, 0 replies.
- [flink-connector-shared-utils] branch parent_pom updated: [FLINK-30578] Setup cyclonedx-maven-plugin - posted by ch...@apache.org on 2023/01/18 12:30:59 UTC, 0 replies.
- [flink-connector-shared-utils] branch parent_pom updated (aa659f7 -> db590e5) - posted by ch...@apache.org on 2023/01/18 13:32:22 UTC, 0 replies.
- [flink] branch release-1.16 updated (4150d709906 -> f37048e78c9) - posted by ma...@apache.org on 2023/01/18 13:32:45 UTC, 0 replies.
- [flink-connector-shared-utils] branch parent_pom updated: [FLINK-30737] Add CI - posted by ch...@apache.org on 2023/01/18 13:37:03 UTC, 0 replies.
- [flink] branch master updated: [FLINK-29719][hive] Supports native count function for hive dialect - posted by go...@apache.org on 2023/01/18 14:14:40 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30704][build] Skip SBOM creation in fast profile - posted by mb...@apache.org on 2023/01/18 14:59:02 UTC, 0 replies.
- [flink-connector-elasticsearch] branch v3.0 updated: [BP-3.0][FLINK-30359][es] flink-sql-connector-elasticsearch6's jar should including the dependency of com.carrotsearch:hppc. (#51) - posted by ma...@apache.org on 2023/01/18 15:35:29 UTC, 0 replies.
- [flink] branch master updated: [FLINK-29884][test] Fix flaky test SortMergeResultPartitionTest.testRelease - posted by yi...@apache.org on 2023/01/19 01:13:35 UTC, 0 replies.
- [flink] branch master updated: [FLINK-29722][hive] Supports native hive max function for hive dialect - posted by go...@apache.org on 2023/01/19 03:33:49 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30191][python] Update net.sf.py4j:py4j dependency to 0.10.9.7 - posted by hx...@apache.org on 2023/01/19 03:49:35 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30677][sql-gateway] Fix unstable SqlGatewayServiceStatementITCase#testFlinkSqlStatements - posted by sh...@apache.org on 2023/01/19 07:06:07 UTC, 0 replies.
- [flink] branch release-1.16 updated (f37048e78c9 -> f91ca7d2cd4) - posted by hx...@apache.org on 2023/01/19 07:16:32 UTC, 0 replies.
- [flink] branch release-1.15 updated: [hotfix][python] Fix the KeyError in CachedMapState - posted by hx...@apache.org on 2023/01/19 07:17:53 UTC, 0 replies.
- [flink-shaded] branch master updated (0cf9196 -> ba56570) - posted by ma...@apache.org on 2023/01/19 09:12:09 UTC, 0 replies.
- [flink-shaded] 01/02: [FLINK-30232][Build/Shaded] Include all (including previously missing ARM64) platforms while shading Netty - posted by ma...@apache.org on 2023/01/19 09:12:10 UTC, 0 replies.
- [flink-shaded] 02/02: [FLINK-30232][Build/Shaded] Include all (including previously missing ARM64) platforms while shading Netty Tcnative Dynamic - posted by ma...@apache.org on 2023/01/19 09:12:11 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30678][tests] Use random port - posted by ch...@apache.org on 2023/01/19 09:48:35 UTC, 0 replies.
- [flink] branch release-1.16 updated (f91ca7d2cd4 -> fef1fdab86f) - posted by ch...@apache.org on 2023/01/19 09:49:16 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30724][docs] Update kafka-per-partition watermark to new source - posted by ta...@apache.org on 2023/01/19 10:02:16 UTC, 0 replies.
- [flink] branch release-1.16 updated (fef1fdab86f -> ce98d8f584a) - posted by ta...@apache.org on 2023/01/19 10:05:31 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-30724][docs] Update kafka-per-partition watermark to new source - posted by ta...@apache.org on 2023/01/19 10:07:51 UTC, 0 replies.
- [flink-benchmarks] branch master updated: [FLINK-30717][ci] Migrate to GitHub Actions - posted by ch...@apache.org on 2023/01/19 11:12:31 UTC, 0 replies.
- [flink-connector-gcp-pubsub] branch main updated (fabf8fa -> c546198) - posted by ma...@apache.org on 2023/01/19 12:20:05 UTC, 0 replies.
- [flink] branch master updated (2a9ceb7cb03 -> 838b79f5b9c) - posted by hx...@apache.org on 2023/01/19 12:36:59 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30093][protobuf] Fix compile errors for google.protobuf.Timestamp type - posted by li...@apache.org on 2023/01/19 12:53:07 UTC, 0 replies.
- svn commit: r59441 - in /dev/flink/flink-1.16.1-rc1: ./ flink-1.16.1-src.tgz flink-1.16.1-src.tgz.asc flink-1.16.1-src.tgz.sha512 - posted by ma...@apache.org on 2023/01/19 13:45:01 UTC, 0 replies.
- [flink] branch FLINK-30191 created (now e5764802ea4) - posted by ma...@apache.org on 2023/01/19 14:13:18 UTC, 0 replies.
- [flink] 01/01: Revert "[FLINK-30191][python] Update net.sf.py4j:py4j dependency to 0.10.9.7" - posted by ma...@apache.org on 2023/01/19 14:13:19 UTC, 0 replies.
- [flink] branch master updated (7ea4476c054 -> 7b69e93b301) - posted by sh...@apache.org on 2023/01/19 14:48:59 UTC, 0 replies.
- svn commit: r59444 - in /dev/flink/flink-1.16.1-rc1: ./ python/ - posted by ch...@apache.org on 2023/01/19 14:52:28 UTC, 0 replies.
- [flink] branch master updated (7b69e93b301 -> 6f88d7a9737) - posted by li...@apache.org on 2023/01/19 14:54:50 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30749][security][docs] Fix delegation token provider enabled flag key - posted by ch...@apache.org on 2023/01/19 15:26:08 UTC, 0 replies.
- svn commit: r59445 - in /dev/flink/flink-1.16.1-rc1: ./ python/ - posted by ma...@apache.org on 2023/01/19 15:55:06 UTC, 0 replies.
- [flink] annotated tag release-1.16.1-rc1 updated (278dc7b7933 -> 0ee99f965c8) - posted by ma...@apache.org on 2023/01/19 15:57:29 UTC, 0 replies.
- [flink] branch master updated (2698078ea47 -> 7f7b030d72f) - posted by ch...@apache.org on 2023/01/19 16:15:24 UTC, 0 replies.
- [flink] 01/02: [FLINK-30378][docs] Load data/ directory from externalized connector docs - posted by ch...@apache.org on 2023/01/19 16:15:25 UTC, 0 replies.
- [flink] 02/02: [FLINK-30378][docs] Load sql connector data from any data file - posted by ch...@apache.org on 2023/01/19 16:15:26 UTC, 0 replies.
- [flink-connector-aws] branch main updated: [FLINK-30378][docs] Use modified sql_connector_download_table shortcode - posted by ch...@apache.org on 2023/01/19 16:16:06 UTC, 0 replies.
- [flink] branch master updated (7f7b030d72f -> b7d32069c09) - posted by li...@apache.org on 2023/01/20 02:58:32 UTC, 0 replies.
- [flink] 01/02: [FLINK-30662][table] Planner supports delete push down. - posted by li...@apache.org on 2023/01/20 02:58:33 UTC, 0 replies.
- [flink] 02/02: [FLINK-30662][table] Planner supports row-level delete - posted by li...@apache.org on 2023/01/20 02:58:34 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30704][filesystems][s3] Add S3 delegation token support - posted by mb...@apache.org on 2023/01/20 10:45:06 UTC, 0 replies.
- [flink-web] branch asf-site updated (a96ace934 -> 9290f9c3b) - posted by mb...@apache.org on 2023/01/20 11:55:29 UTC, 0 replies.
- [flink-web] 01/02: Blog post on the Delegation Token Framework - posted by mb...@apache.org on 2023/01/20 11:55:30 UTC, 0 replies.
- [flink-connector-gcp-pubsub] branch v3.0 created (now c546198) - posted by ma...@apache.org on 2023/01/20 14:25:21 UTC, 0 replies.
- [flink-connector-gcp-pubsub] annotated tag v3.0.0-rc1 updated (51a2f32 -> 2d8fa60) - posted by ma...@apache.org on 2023/01/20 14:27:21 UTC, 0 replies.
- svn commit: r59461 - in /dev/flink/flink-connector-gcp-pubsub-3.0.0-rc1: ./ flink-connector-gcp-pubsub-3.0.0-src.tgz flink-connector-gcp-pubsub-3.0.0-src.tgz.asc flink-connector-gcp-pubsub-3.0.0-src.tgz.sha512 - posted by ma...@apache.org on 2023/01/20 14:27:29 UTC, 0 replies.
- [flink] branch master updated (0141f13ca80 -> 9e9081cbf88) - posted by ch...@apache.org on 2023/01/20 16:55:22 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30705] Fix CR ref gen to use JsonProperty annotation values - posted by gy...@apache.org on 2023/01/21 19:26:51 UTC, 0 replies.
- [flink] branch master updated (9e9081cbf88 -> 409e18b1f96) - posted by mb...@apache.org on 2023/01/23 15:16:34 UTC, 0 replies.
- [flink] branch master updated (409e18b1f96 -> 359217381a3) - posted by ch...@apache.org on 2023/01/23 15:19:10 UTC, 0 replies.
- [flink] branch master updated (359217381a3 -> 8be94e6663d) - posted by pn...@apache.org on 2023/01/23 15:47:24 UTC, 0 replies.
- [flink] 01/03: [hotfix] Remove useless exception in SubtaskCheckpointCoordinatorImpl - posted by pn...@apache.org on 2023/01/23 15:47:25 UTC, 0 replies.
- [flink] 02/03: [FLINK-26803][checkpoint] Fix the bug of ChannelStateWriterImpl close 2 times - posted by pn...@apache.org on 2023/01/23 15:47:26 UTC, 0 replies.
- [flink] 03/03: [FLINK-26803][checkpoint] Merge the channel state files - posted by pn...@apache.org on 2023/01/23 15:47:27 UTC, 0 replies.
- [flink] branch master updated (8be94e6663d -> 6d4bb1db78b) - posted by ma...@apache.org on 2023/01/24 10:38:30 UTC, 0 replies.
- [flink] branch master updated: [hotfix][legal] Remove excess char from license header - posted by ch...@apache.org on 2023/01/24 11:39:19 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30759][runtime] Merges DispatcherRunnerLeaderElectionLifecycleManager into DefaultDispatcherRunner - posted by ma...@apache.org on 2023/01/24 12:40:42 UTC, 0 replies.
- [flink] branch master updated (2d1d61c68d8 -> bf1fc7ad206) - posted by ma...@apache.org on 2023/01/24 12:42:36 UTC, 0 replies.
- [flink] branch master updated (bf1fc7ad206 -> b26c695b533) - posted by ma...@apache.org on 2023/01/24 12:52:18 UTC, 0 replies.
- [flink] branch master updated (b26c695b533 -> f38c2370e85) - posted by pn...@apache.org on 2023/01/24 16:10:51 UTC, 0 replies.
- [flink-connector-opensearch] branch dependabot/maven/flink-connector-opensearch/org.opensearch-opensearch-2.5.0 created (now f6b162f) - posted by gi...@apache.org on 2023/01/24 20:49:17 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated (410a0a32 -> e1682cc5) - posted by gy...@apache.org on 2023/01/24 21:21:31 UTC, 0 replies.
- [flink-kubernetes-operator] 01/02: [FLINK-30766][tests] Do not parameterize tests with all Flink versions - posted by gy...@apache.org on 2023/01/24 21:21:32 UTC, 0 replies.
- [flink-kubernetes-operator] 02/02: [tests] Improve flaky RollbackTest - posted by gy...@apache.org on 2023/01/24 21:21:33 UTC, 0 replies.
- [flink] branch master updated (f38c2370e85 -> f8105bb584f) - posted by ro...@apache.org on 2023/01/24 22:10:50 UTC, 0 replies.
- [flink] branch master updated (f8105bb584f -> b4fe4a42887) - posted by ro...@apache.org on 2023/01/25 01:58:53 UTC, 0 replies.
- [flink] branch master updated: [FLINK-29215][table-planner] Use config based constructors for converter rules instead of deprecated - posted by tw...@apache.org on 2023/01/25 08:40:21 UTC, 0 replies.
- [flink-connector-aws] branch main updated: [FLINK-30762][ci] Add nightly build workflow - posted by da...@apache.org on 2023/01/25 12:59:34 UTC, 0 replies.
- [flink] branch master updated (0ce8cb1f2bd -> f021b6dfefb) - posted by da...@apache.org on 2023/01/25 15:27:20 UTC, 0 replies.
- [flink] branch master updated: [hotfix][javadocs]Fix javadoc in Catalog Interface - posted by da...@apache.org on 2023/01/25 15:27:56 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [hotfix] Minor logging and scaling execution improvements for autoscaler - posted by gy...@apache.org on 2023/01/25 16:30:54 UTC, 0 replies.
- [flink] branch master updated (88cb0853b7b -> 560f3147038) - posted by li...@apache.org on 2023/01/26 07:30:26 UTC, 0 replies.
- [flink] 01/03: [FLINK-30623][runtime][refactor] Using the CanEmitBatchOfRecordsChecker instead of Supplier - posted by li...@apache.org on 2023/01/26 07:30:27 UTC, 0 replies.
- [flink] 02/03: [FLINK-30623][runtime][refactor] Using the canEmitBatchOfRecords instead of isEmitNextLoopDisabled in the SourceOperator - posted by li...@apache.org on 2023/01/26 07:30:28 UTC, 0 replies.
- [flink] 03/03: [FLINK-30623][runtime][bug] The canEmitBatchOfRecords should check recordWriter and changelogWriterAvailabilityProvider are available - posted by li...@apache.org on 2023/01/26 07:30:29 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30618][Python] Remove SNAPSHOT reference to Pulsar connector - posted by ma...@apache.org on 2023/01/26 08:27:38 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30754][tests] Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues - posted by mb...@apache.org on 2023/01/26 10:26:24 UTC, 0 replies.
- [flink-training] branch master updated: [FLINK-30717][ci] Migrate to GitHub Actions - posted by ch...@apache.org on 2023/01/26 10:58:57 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30619][tests] Add retry - posted by ch...@apache.org on 2023/01/26 15:43:08 UTC, 0 replies.
- [flink] branch release-1.16 updated: [FLINK-30619][tests] Add retry - posted by ch...@apache.org on 2023/01/26 15:44:20 UTC, 0 replies.
- [flink] branch master updated (38d390114e9 -> eb8a33fb0cb) - posted by ma...@apache.org on 2023/01/26 20:23:13 UTC, 0 replies.
- [flink] branch master updated (eb8a33fb0cb -> f6c7c30118e) - posted by li...@apache.org on 2023/01/27 01:35:17 UTC, 0 replies.
- [flink] 01/02: [hotfix] Migrate StreamTaskNetworkInputTest to Junit5 and AssertJ - posted by li...@apache.org on 2023/01/27 01:35:18 UTC, 0 replies.
- [flink] 02/02: [FLINK-30709][runtime] NetworkInput#emitNext() should push records to DataOutput within a while loop - posted by li...@apache.org on 2023/01/27 01:35:19 UTC, 0 replies.
- [flink] branch master updated (f6c7c30118e -> 952c7831e74) - posted by pn...@apache.org on 2023/01/27 09:15:01 UTC, 0 replies.
- [flink] 01/03: [FLINK-26082][runtime] Initializing test netty server and client in the loop to avoid the probability of `Address already in use` problem. - posted by pn...@apache.org on 2023/01/27 09:15:02 UTC, 0 replies.
- [flink] 02/03: [FLINK-26082][runtime] Refactor ServerTransportErrorHandlingTest and ClientTransportErrorHandlingTest according to `initServerAndClient` method changes. - posted by pn...@apache.org on 2023/01/27 09:15:03 UTC, 0 replies.
- [flink] 03/03: [hotfix][runtime] Check style ServerTransportErrorHandlingTest and ClientTransportErrorHandlingTest fix - posted by pn...@apache.org on 2023/01/27 09:15:04 UTC, 0 replies.
- [flink] branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/ua-parser-js-0.7.33 created (now a2f36e94f4b) - posted by gi...@apache.org on 2023/01/27 09:52:29 UTC, 0 replies.
- [flink] branch master updated (952c7831e74 -> 17064128599) - posted by pn...@apache.org on 2023/01/27 11:00:56 UTC, 0 replies.
- [flink] 01/03: [FLINK-15550][runtime] Revert "Debug logging for TaskTest" - posted by pn...@apache.org on 2023/01/27 11:00:57 UTC, 0 replies.
- [flink] 02/03: [FLINK-15550][runtime] The static latches in TaskTest were replaced by latches from invokable objects. - posted by pn...@apache.org on 2023/01/27 11:00:58 UTC, 0 replies.
- [flink] 03/03: [hotfix][runtime] Check style TaskTest fix. - posted by pn...@apache.org on 2023/01/27 11:00:59 UTC, 0 replies.
- [flink-connector-aws] branch main updated: [FLINK-30783][Connectors/AWS] Add a pull request template - posted by da...@apache.org on 2023/01/27 14:47:10 UTC, 0 replies.
- [flink] branch master updated (17064128599 -> 18a0ea99d6e) - posted by da...@apache.org on 2023/01/27 14:52:49 UTC, 0 replies.
- [flink] branch release-1.16 updated (0f52f62b189 -> d71cf8ee314) - posted by da...@apache.org on 2023/01/27 14:53:35 UTC, 0 replies.
- [flink] branch master updated (18a0ea99d6e -> e1c11ad20c8) - posted by ta...@apache.org on 2023/01/28 03:32:16 UTC, 0 replies.
- [flink] branch master updated (e1c11ad20c8 -> d336dad9345) - posted by zh...@apache.org on 2023/01/28 03:47:23 UTC, 0 replies.
- [flink] 01/06: [FLINK-30755][connector] Support getting attempt number from Sink context - posted by zh...@apache.org on 2023/01/28 03:47:24 UTC, 0 replies.
- [flink] 02/06: [FLINK-30755][api] Introduce SupportsConcurrentExecutionAttempts interface - posted by zh...@apache.org on 2023/01/28 03:47:25 UTC, 0 replies.
- [flink] 03/06: [FLINK-30755][runtime] Support SupportsConcurrentExecutionAttempts property of StreamGraph and JobGraph - posted by zh...@apache.org on 2023/01/28 03:47:26 UTC, 0 replies.
- [flink] 04/06: [FLINK-30755][runtime] Support SupportsConcurrentExecutionAttempts property of Transformation - posted by zh...@apache.org on 2023/01/28 03:47:27 UTC, 0 replies.
- [flink] 05/06: [FLINK-30755][runtime] Support SupportsConcurrentExecutionAttempts property of SinkV2 - posted by zh...@apache.org on 2023/01/28 03:47:28 UTC, 0 replies.
- [flink] 06/06: [FLINK-30755][runtime] Remove legacy codes of marking not support speculative executions - posted by zh...@apache.org on 2023/01/28 03:47:29 UTC, 0 replies.
- [flink] branch master updated (d336dad9345 -> 1534ea75161) - posted by sh...@apache.org on 2023/01/29 03:57:01 UTC, 0 replies.
- [flink] branch master updated: [FLINK-25874][python] Limit the version of 'python-dateutil' to '>=2.8.0,<3' - posted by di...@apache.org on 2023/01/29 05:59:47 UTC, 0 replies.
- [flink] branch release-1.16 updated (d71cf8ee314 -> f3f48657b3e) - posted by di...@apache.org on 2023/01/29 06:05:46 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30752][python] Support 'EXPLAIN PLAN_ADVICE' statement in PyFlink - posted by di...@apache.org on 2023/01/29 06:09:03 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30808][runtime] Properly handle ForwardForConsecutiveHashPartitioner when creating edges in StreamGraph - posted by zh...@apache.org on 2023/01/29 08:05:03 UTC, 0 replies.
- [flink] branch release-1.16 updated (f3f48657b3e -> f8e2b618c73) - posted by zh...@apache.org on 2023/01/29 08:08:31 UTC, 0 replies.
- [flink] branch master updated (a55ae1c6b42 -> 6e445064f6a) - posted by zh...@apache.org on 2023/01/29 13:20:01 UTC, 0 replies.
- [flink] 01/02: [hotfix][runtime] Remove useless imports and incorrect comment of StreamingJobGraphGeneratorTest - posted by zh...@apache.org on 2023/01/29 13:20:02 UTC, 0 replies.
- [flink] 02/02: [FLINK-30799][runtime] Make SinkFunction support speculative execution through implementing SupportsConcurrentExecutionAttempts interface - posted by zh...@apache.org on 2023/01/29 13:20:03 UTC, 0 replies.
- [flink] branch master updated (6e445064f6a -> 95df4e726f3) - posted by sh...@apache.org on 2023/01/29 13:37:34 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks. - posted by zh...@apache.org on 2023/01/29 14:11:56 UTC, 0 replies.
- [flink] branch master updated (02b09eac623 -> 916ff76b61a) - posted by go...@apache.org on 2023/01/30 01:54:58 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30816][sql-client] Fix SQL Client always uses the highest packaged version to connect to gateway - posted by sh...@apache.org on 2023/01/30 02:44:51 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30567][hive] Fix wrong behavior for insert overwrite with Hive dialect when the table contains uppercase character (#21602) - posted by ji...@apache.org on 2023/01/30 03:26:47 UTC, 0 replies.
- [flink] branch master updated: [FLINK-29878][hive] Include libfb303 to fix fail to use flink-sql-connector-hive-3.1.3 - posted by re...@apache.org on 2023/01/30 07:28:20 UTC, 0 replies.
- [flink] branch master updated (b1a9fe12f78 -> 7df2a12472f) - posted by ja...@apache.org on 2023/01/30 08:00:00 UTC, 0 replies.
- [flink] branch master updated (7df2a12472f -> 6d17ba88556) - posted by li...@apache.org on 2023/01/30 08:08:05 UTC, 0 replies.
- [flink] branch FLINK-30665 created (now 5afc301bc64) - posted by li...@apache.org on 2023/01/30 08:27:44 UTC, 0 replies.
- [flink] 01/01: [FLINK-30665][table] Planner supports row-level update - posted by li...@apache.org on 2023/01/30 08:27:45 UTC, 0 replies.
- [flink] branch master updated (6d17ba88556 -> 5afc301bc64) - posted by li...@apache.org on 2023/01/30 08:29:55 UTC, 0 replies.
- [flink] branch master updated (5afc301bc64 -> 143464d8281) - posted by zh...@apache.org on 2023/01/30 08:42:07 UTC, 0 replies.
- [flink] 01/03: [hotfix] Migrate ExecutionConfigTest to JUnit5. - posted by zh...@apache.org on 2023/01/30 08:42:08 UTC, 0 replies.
- [flink] 02/03: [hotfix][runtime] remove ExecutionConfig#setScheduler - posted by zh...@apache.org on 2023/01/30 08:42:09 UTC, 0 replies.
- [flink] 03/03: [FLINK-30683][runtime] Use AdaptiveBatchScheduler as default batch scheduler - posted by zh...@apache.org on 2023/01/30 08:42:10 UTC, 0 replies.
- [flink] branch master updated (143464d8281 -> 76ebeb93257) - posted by zh...@apache.org on 2023/01/30 08:46:10 UTC, 0 replies.
- [flink] 01/03: [hotfix] Migrate a few location preference tests to JUnit5 - posted by zh...@apache.org on 2023/01/30 08:46:11 UTC, 0 replies.
- [flink] 02/03: [FLINK-15325][coordination] Set the ConsumedPartitionGroup/ConsumerVertexGroup to its corresponding ConsumerVertexGroup/ConsumedPartitionGroup - posted by zh...@apache.org on 2023/01/30 08:46:12 UTC, 0 replies.
- [flink] 03/03: [FLINK-15325][coordination] Ignores the input locations of a ConsumePartitionGroup if the corresponding ConsumerVertexGroup is too large - posted by zh...@apache.org on 2023/01/30 08:46:13 UTC, 0 replies.
- [flink] branch master updated: [hotfix] Remove legacy code which was not removed due merge conflicts - posted by zh...@apache.org on 2023/01/30 09:05:48 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30577] Mount artifacts dir in helm template - posted by gy...@apache.org on 2023/01/30 09:06:38 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated (9441b114 -> cebc0b87) - posted by gy...@apache.org on 2023/01/30 09:07:45 UTC, 0 replies.
- [flink-kubernetes-operator] 01/02: [FLINK-30653] Trigger resource Events on autoscaler actions - posted by gy...@apache.org on 2023/01/30 09:07:46 UTC, 0 replies.
- [flink-kubernetes-operator] 02/02: [hotfix] Improve autoscaling example - posted by gy...@apache.org on 2023/01/30 09:07:47 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30804] helm/flink-kubernetes-operator - allow specifying resources for operator pod - posted by gy...@apache.org on 2023/01/30 09:12:32 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30800] Add doc entry how to re-generate java doc - posted by gy...@apache.org on 2023/01/30 09:14:24 UTC, 0 replies.
- [flink-ml] branch master updated: [FLINK-30568] Add benchmark for PolyNomialExpansion, Normalizer, Binarizer, Interaction, MaxAbsScaler, VectorSlicer, ElementWiseProduct and Featurehasher - posted by zh...@apache.org on 2023/01/30 09:19:52 UTC, 0 replies.
- [flink] branch master updated (2ca7e411f53 -> ec3243e36ee) - posted by go...@apache.org on 2023/01/30 09:26:14 UTC, 0 replies.
- [flink] branch release-1.15 updated: [FLINK-30679][connectors/hive] Fix IndexOutOfBoundsException for Hive lookup join when column pushdown to Hive lookup table source (#21783) - posted by ja...@apache.org on 2023/01/30 11:46:16 UTC, 0 replies.
- [flink] branch master updated (ec3243e36ee -> 5f5abb69187) - posted by ma...@apache.org on 2023/01/30 11:49:58 UTC, 0 replies.
- svn commit: r59699 - /dev/flink/flink-1.16.1-rc1/ /release/flink/flink-1.16.1/ - posted by ma...@apache.org on 2023/01/30 13:38:26 UTC, 0 replies.
- [flink] annotated tag release-1.16.1 updated (278dc7b7933 -> 82afb993594) - posted by ma...@apache.org on 2023/01/30 13:57:19 UTC, 0 replies.
- [flink] branch master updated (5f5abb69187 -> c9e87fe410c) - posted by sh...@apache.org on 2023/01/30 14:09:28 UTC, 0 replies.
- [flink-docker] branch dev-1.16 updated: Add GPG key for 1.16.1 release - posted by ma...@apache.org on 2023/01/30 14:28:51 UTC, 0 replies.
- [flink-docker] branch master updated: Update Dockerfiles for 1.16.1 release - posted by ma...@apache.org on 2023/01/30 14:30:23 UTC, 0 replies.
- [flink] branch release-1.16 updated (f8e2b618c73 -> 63bbd14d245) - posted by ji...@apache.org on 2023/01/30 14:49:50 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30781] Add completed checkpoint check to cluster health check - posted by gy...@apache.org on 2023/01/30 14:50:26 UTC, 0 replies.
- [flink] branch revert-21781-release-1.16-FLINK-30567 created (now 311a786d1e0) - posted by ji...@apache.org on 2023/01/30 14:53:28 UTC, 0 replies.
- [flink] 01/01: Revert "[FLINK-30567][hive] Fix wrong behavior for insert overwrite with Hive dialect when the table contains uppercase character (#21602) (#21781)" - posted by ji...@apache.org on 2023/01/30 14:53:29 UTC, 0 replies.
- [flink-web] branch asf-site updated: Flink 1.16.1. This closes #603 - posted by ma...@apache.org on 2023/01/30 15:01:48 UTC, 0 replies.
- [flink] branch master updated (c9e87fe410c -> abb060aa775) - posted by ro...@apache.org on 2023/01/30 15:50:18 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30624][runtime] Introduce a new HeapPriorityQueue for StatusWatermarkValve to avoid affecting the performance of memory state backend. - posted by zh...@apache.org on 2023/01/30 16:46:41 UTC, 0 replies.
- [flink] branch master updated (21e844b6c00 -> dcbb20688c0) - posted by go...@apache.org on 2023/01/31 02:03:03 UTC, 0 replies.
- [flink-connector-pulsar] branch v3.0 updated: [FLINK-30657][Connector/Pulsar] Remove Shared and Key_Shared related tests in Pulsar connector. (#17) - posted by ti...@apache.org on 2023/01/31 02:42:33 UTC, 0 replies.
- [flink] branch master updated (dcbb20688c0 -> 9a5c2dbb85f) - posted by zh...@apache.org on 2023/01/31 02:52:57 UTC, 0 replies.
- [flink] branch master updated (9a5c2dbb85f -> 0aab2cd369e) - posted by li...@apache.org on 2023/01/31 02:58:41 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-30679][connectors/hive] Fix IndexOutOfBoundsException for Hive lookup join when column pushdown to Hive lookup table source (#21782) - posted by ja...@apache.org on 2023/01/31 03:07:42 UTC, 0 replies.
- [flink] branch release-1.16 updated (63bbd14d245 -> b5f50c354c4) - posted by ja...@apache.org on 2023/01/31 03:08:31 UTC, 0 replies.
- [flink] branch master updated (0aab2cd369e -> cf358d7d55c) - posted by ja...@apache.org on 2023/01/31 03:09:40 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30820] Support varchar/char in spark - posted by lz...@apache.org on 2023/01/31 04:20:46 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30820] Remove Spark 3.0 support - posted by lz...@apache.org on 2023/01/31 04:23:33 UTC, 0 replies.
- [flink-table-store] branch master updated: [FLINK-30038] Fix hive e2e fail - posted by lz...@apache.org on 2023/01/31 04:24:48 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-30669] update most recent job status in flinkdeployment - posted by gy...@apache.org on 2023/01/31 08:23:53 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30542][table-planner] Introduce adaptive local hash aggregate to adaptively determine whether local hash aggregate is required at runtime - posted by go...@apache.org on 2023/01/31 10:27:59 UTC, 0 replies.
- [flink] branch master updated: [hotfix][table-planner] Correct StreamExecLookupJoin from SingleTransformationTranslator to MultipleTransformationTranslator - posted by li...@apache.org on 2023/01/31 11:15:02 UTC, 0 replies.
- [flink] branch master updated (ffa50a1043e -> 1420ee7ed69) - posted by zh...@apache.org on 2023/01/31 11:18:44 UTC, 0 replies.
- [flink] 01/05: [FLINK-30823][runtime] Enable speculative execution for DiscardingSink - posted by zh...@apache.org on 2023/01/31 11:18:45 UTC, 0 replies.
- [flink] 02/05: [FLINK-30823][runtime] Enable speculative execution for PrintSinkFunction - posted by zh...@apache.org on 2023/01/31 11:18:46 UTC, 0 replies.
- [flink] 03/05: [FLINK-30823][runtime] Enable speculative execution for PrintSink - posted by zh...@apache.org on 2023/01/31 11:18:47 UTC, 0 replies.
- [flink] 04/05: [FLINK-30823][runtime] Enable speculative execution for FileSink - posted by zh...@apache.org on 2023/01/31 11:18:48 UTC, 0 replies.
- [flink] 05/05: [FLINK-30823][runtime] Enable speculative execution for FileSystemOutputFormat - posted by zh...@apache.org on 2023/01/31 11:18:49 UTC, 0 replies.
- [flink] branch master updated: [FLINK-30796][metrics][slf4j] (Partially) skip metrics report - posted by ch...@apache.org on 2023/01/31 11:51:58 UTC, 0 replies.
- svn commit: r59725 - /dev/flink/flink-connector-gcp-pubsub-3.0.0-rc1/ /release/flink/flink-connector-gcp-pubsub-3.0.0/ - posted by ma...@apache.org on 2023/01/31 12:22:28 UTC, 0 replies.
- [flink-connector-gcp-pubsub] annotated tag v3.0.0 updated (51a2f32 -> c771b04) - posted by ma...@apache.org on 2023/01/31 12:22:51 UTC, 0 replies.
- [flink-connector-kafka] branch main updated: [hotfix][Connector/Kafka] Add release tools as submodule - posted by ma...@apache.org on 2023/01/31 12:49:58 UTC, 0 replies.
- [flink-web] branch asf-site updated: [hotfix] Update Slack invite link - posted by ma...@apache.org on 2023/01/31 13:00:14 UTC, 0 replies.
- [flink-connector-kafka] branch v3.0 created (now fae0538) - posted by ma...@apache.org on 2023/01/31 13:18:37 UTC, 0 replies.
- [flink] branch master updated (e856bd8b5f8 -> 6878fced84e) - posted by tw...@apache.org on 2023/01/31 13:21:12 UTC, 0 replies.
- [flink-connector-kafka] annotated tag v3.0.0-rc1 updated (88c192e -> 354e4cd) - posted by ma...@apache.org on 2023/01/31 14:16:01 UTC, 0 replies.
- svn commit: r59749 - in /dev/flink/flink-connector-kafka-3.0.0-rc1: ./ flink-connector-kafka-3.0.0-src.tgz flink-connector-kafka-3.0.0-src.tgz.asc flink-connector-kafka-3.0.0-src.tgz.sha512 - posted by ma...@apache.org on 2023/01/31 14:16:08 UTC, 0 replies.
- [flink-web] branch asf-site updated: Rebuild website - posted by ch...@apache.org on 2023/01/31 14:59:54 UTC, 0 replies.
- [flink] branch master updated (6878fced84e -> 0915c9850d8) - posted by zh...@apache.org on 2023/01/31 15:30:21 UTC, 0 replies.
- [flink-kubernetes-operator] branch main updated: [FLINK-29871] Upgraded flink dependencies to 1.16.1 - posted by mo...@apache.org on 2023/01/31 19:41:53 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bounded offset in the Kafka table connector - posted by dw...@apache.org on 2023/01/31 22:53:20 UTC, 0 replies.