[flink] branch release-1.15 updated: [FLINK-28140][python][docs] Improve the documentation by adding Python examples in DataStream API Integration page

This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.15 by this push: new 898dc492760 [FLINK-28140][python][doc

[flink] branch master updated (2f4f46219d0 -> ce11ce307e7)

This is an automated email from the ASF dual-hosted git repository. dianfu pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 2f4f46219d0 [FLINK-28288][table][python] Support decode and encode in Table API (#20098) add ce11ce307e7 [FLINK-2

[flink] branch master updated: [FLINK-28288][table][python] Support decode and encode in Table API (#20098)

This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 2f4f46219d0 [FLINK-28288][table][python] Support

[flink] branch master updated: [FLINK-28323][python][kafka] Support KafkaSource in PyFlink

This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new ea0368e7ee0 [FLINK-28323][python][kafka] Support

[flink] 03/03: [FLINK-28142][runtime] Enrich TaskExecutorRegistration with node information

This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit eab0a1faf5e7ecf8da641880b8913d49ac19da2b Author: Lijie Wang AuthorDate: Tue Jun 28 22:55:43 2022 +0800 [FLINK-28142][

[flink] branch master updated (ef07590403a -> eab0a1faf5e)

This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from ef07590403a [FLINK-28136][runtime] Implement ExecutionTimeBasedSlowTaskDetector new c1e39b6aca7 [hotfix][runtime][

[flink] 01/03: [hotfix][runtime][tests] Migrate TaskManagerLocationTest, TaskExecutorToResourceManagerConnectionTest and TaskManagerRunnerConfigurationTest to JUnit5

This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c1e39b6aca7fc0af5ae6370f6dcb644c91881dd1 Author: Lijie Wang AuthorDate: Wed Jun 22 20:05:19 2022 +0800 [hotfix][runti

[flink] 02/03: [FLINK-28142][runtime] Enrich TaskManagerLocation with node information

This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 51c139b601806cc4f4272fb678f4d1bed4cf06ab Author: Lijie Wang AuthorDate: Tue Jun 28 22:53:50 2022 +0800 [FLINK-28142][

[flink] 01/02: [FLINK-28135][runtime] Introduce SlowTaskDetector

This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit a0e8818d6967e5b0d14367d2095c91a05cadfe1f Author: hongli AuthorDate: Thu Jun 23 11:04:00 2022 +0800 [FLINK-28135][runt

[flink] 02/02: [FLINK-28136][runtime] Implement ExecutionTimeBasedSlowTaskDetector

This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ef07590403ad7448a523ef5da78da0306cccdae7 Author: hongli AuthorDate: Sat Jun 25 17:05:26 2022 +0800 [FLINK-28136][runt

[flink] branch master updated (bb8e1d14f05 -> ef07590403a)

This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from bb8e1d14f05 [FLINK-28309][rest] Introduce metrics of the duration that a task stays in each status new a0e8818d696

[flink] 02/03: [FLINK-28308] Introduce metrics of the accumulated time that a running task is busy / idle / back-pressured

This is an automated email from the ASF dual-hosted git repository. guoyangze pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit bc2a86e5bb5f048fb5e5007f916405773a88b5cc Author: Yangze Guo AuthorDate: Mon May 23 16:50:37 2022 +0800 [FLINK-283

[flink] 03/03: [FLINK-28309][rest] Introduce metrics of the duration that a task stays in each status

This is an automated email from the ASF dual-hosted git repository. guoyangze pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit bb8e1d14f05aca186ec874437eba3d44fbb3bd97 Author: Yangze Guo AuthorDate: Tue May 24 11:25:17 2022 +0800 [FLINK-283

[flink] branch master updated (202eacb2ee9 -> bb8e1d14f05)

This is an automated email from the ASF dual-hosted git repository. guoyangze pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 202eacb2ee9 [FLINK-26361][hive] Create LogicalFilter with CorrelationId to fix failed to rewrite subquery in hive d

[flink] 01/03: [hotfix][rest] Remove the stale items in rest_v1_dispatcher

This is an automated email from the ASF dual-hosted git repository. guoyangze pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6b8230cf83fd33c4fdd3d7cc99e6a90d9839a350 Author: Yangze Guo AuthorDate: Thu Jun 30 14:30:38 2022 +0800 [hotfix][r

[flink-ml] annotated tag release-2.1.0-rc2 updated (b23f499 -> eadb52d)

This is an automated email from the ASF dual-hosted git repository. zhangzp pushed a change to annotated tag release-2.1.0-rc2 in repository https://gitbox.apache.org/repos/asf/flink-ml.git *** WARNING: tag release-2.1.0-rc2 was modified! *** from b23f499 (commit) to eadb52d (tag)

svn commit: r55362 - in /dev/flink/flink-ml-2.1.0-rc2: ./ apache-flink-ml-2.1.0.tar.gz apache-flink-ml-2.1.0.tar.gz.asc apache-flink-ml-2.1.0.tar.gz.sha512 flink-ml-2.1.0-src.tgz flink-ml-2.1.0-src.tg

Author: zhangzp Date: Fri Jul 1 02:55:28 2022 New Revision: 55362 Log: Apache Flink ML, version 2.1.0, release candidate 2 Added: dev/flink/flink-ml-2.1.0-rc2/ dev/flink/flink-ml-2.1.0-rc2/apache-flink-ml-2.1.0.tar.gz (with props) dev/flink/flink-ml-2.1.0-rc2/apache-flink-ml-2.1.0.

[flink] branch master updated: [FLINK-26361][hive] Create LogicalFilter with CorrelationId to fix failed to rewrite subquery in hive dialect (#18920)

This is an automated email from the ASF dual-hosted git repository. shengkai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 202eacb2ee9 [FLINK-26361][hive] Create LogicalF

[flink-ml] branch master updated: [FLINK-27084] Fix classloader for per-round operators

This is an automated email from the ASF dual-hosted git repository. lindong pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-ml.git The following commit(s) were added to refs/heads/master by this push: new da4bf4b [FLINK-27084] Fix classloader for pe

[flink] branch master updated: [FLINK-28182][python][avro] Support Avro generic record decoder in PyFlink

This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new ae409d04e3b [FLINK-28182][python][avro] Support A

[flink-ml] branch release-2.1 updated: [FLINK-27084] Fix classloader for per-round operators

This is an automated email from the ASF dual-hosted git repository. lindong pushed a commit to branch release-2.1 in repository https://gitbox.apache.org/repos/asf/flink-ml.git The following commit(s) were added to refs/heads/release-2.1 by this push: new b23f499 [FLINK-27084] Fix classloa

[flink] branch master updated (d98a34be120 -> 798d83a0fb4)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from d98a34be120 [FLINK-27031][runtime] Assign even empty old state to the task if the upstream has output states since the

[flink] branch release-1.15 updated: [FLINK-27031][runtime] Assign even empty old state to the task if the upstream has output states since the task should be prepared to filter these old incoming sta

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.15 by this push: new 012a3602a91 [FLINK-27031][runtime] Ass

[flink] branch master updated: [FLINK-27031][runtime] Assign even empty old state to the task if the upstream has output states since the task should be prepared to filter these old incoming states fr

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new d98a34be120 [FLINK-27031][runtime] Assign even emp

[flink] branch master updated: [FLINK-28290][sql-gateway] Set lastAccessTime when create the Session Object (#20107)

This is an automated email from the ASF dual-hosted git repository. shengkai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new ac94fa1e9f3 [FLINK-28290][sql-gateway] Set last

[flink-web] branch asf-site updated (763f642cb -> 21c71e4af)

This is an automated email from the ASF dual-hosted git repository. mbalassi pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git from 763f642cb [hotfix] Refresh Slack invite link new 815238d18 [FLINK-22352] Removing mesos references from do

[flink-web] 01/02: [FLINK-22352] Removing mesos references from docs

This is an automated email from the ASF dual-hosted git repository. mbalassi pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git commit 815238d18a089673239be97fff9343ae63307979 Author: Dóra Marsal AuthorDate: Wed Jun 29 20:36:05 2022 +0200 [FLI

[flink-web] 02/02: Rebuild website

This is an automated email from the ASF dual-hosted git repository. mbalassi pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git commit 21c71e4af0bce58964d1e770d707f7bbbfbcea26 Author: Marton Balassi AuthorDate: Thu Jun 30 12:00:40 2022 +0200 R

[flink-kubernetes-operator] branch main updated: [FLINK-27868] Harden running job check

This is an automated email from the ASF dual-hosted git repository. gyfora pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git The following commit(s) were added to refs/heads/main by this push: new 015b929 [FLINK-27868] Harden run

[flink-table-store] branch master updated: [FLINK-28067] Introduce HiveCatalog

This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git The following commit(s) were added to refs/heads/master by this push: new cb688c5b [FLINK-28067] Introduc

[flink] 02/02: [FLINK-27906][runtime] Introduce HsDataIndex.

This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit cb9718c310e8eea93ae69300ae1e526fb78b3cad Author: Weijie Guo AuthorDate: Tue Jun 21 13:40:16 2022 +0800 [FLINK-27906]

[flink] branch master updated (1486fee1acd -> cb9718c310e)

This is an automated email from the ASF dual-hosted git repository. xtsong pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 1486fee1acd [hotfix][docs] Remove a unuseful space new e9e99876184 [hotfix] Add Extension META-INF for flink-runti

[flink] 01/02: [hotfix] Add Extension META-INF for flink-runtime module to support junit5.

This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e9e99876184f0163630d4cd6384f03994b32b31c Author: Weijie Guo AuthorDate: Tue Jun 21 13:38:27 2022 +0800 [hotfix] Add

[flink] branch master updated: [hotfix][docs] Remove a unuseful space

This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 1486fee1acd [hotfix][docs] Remove a unusef

[flink] branch master updated: [FLINK-28213][runtime] StreamExecutionEnvironment configure method support override pipeline.jars option

This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 065018dde64 [FLINK-28213][runtime] StreamExecution

[flink] branch dependabot/maven/flink-connectors/flink-connector-hive/org.apache.derby-derby-10.14.2.0 created (now 529e3abd608)

This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/flink-connectors/flink-connector-hive/org.apache.derby-derby-10.14.2.0 in repository https://gitbox.apache.org/repos/asf/flink.git at 529e3abd608 Bump derby in /flink-

[flink] branch master updated: [FLINK-28259][flink-parquet] Bump protoc version to 3.21.2 for proper ARM support

This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new f916bcf82a4 [FLINK-28259][flink-parquet] B

[flink] branch master updated: [FLINK-28047][api] Deprecate StreamExecutionEnvironment#readFile()/readTextFile() methods

This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 3e73fb543eb [FLINK-28047][api] Deprecate

[flink] branch master updated (dfdf7afb047 -> 0e95f5a3f63)

This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from dfdf7afb047 [FLINK-27586][python] Support non-keyed co-broadcast processing in PyFlink add 0e95f5a3f63 [FL