(flink) branch master updated (39779829b88 -> 7c4dec63eb4)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 39779829b88 [FLINK-34954][core] Kryo Input bug fix add 7c4dec63eb4 [FLINK-28048][connectors] Introduce Source API

(flink) branch master updated: [hotfix][docs] config key for parquet int64 option (#23909)

This is an automated email from the ASF dual-hosted git repository. thw 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 6334923af1e [hotfix][docs] config key for parquet

(flink) branch master updated: [FLINK-25565][Formats][Parquet] timestamp int64 option tidy up (#23900)

This is an automated email from the ASF dual-hosted git repository. thw 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 548e4b5188b [FLINK-25565][Formats][Parquet

(flink) branch release-1.18 updated: [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp (#18304) (#23887)

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.18 by this push: new 4379f2c39fb [FLINK-25565][Formats

(flink) branch master updated (43fec308b32 -> 978bff3bb90)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 43fec308b32 [FLINK-33599] Run restore tests with RocksDB state backend (#23883) add 978bff3bb90 [FLINK-25565

(flink) branch master updated (7eaa5db3024 -> acd3e7ab66c)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 7eaa5db3024 [FLINK-33581][python] Deprecate getter/setter methods related to state backend in python flink. add

[flink] branch master updated: [FLINK-32884] [flink-clients] Sending messageHeaders with decorated customHeaders for PyFlink client (#23452)

This is an automated email from the ASF dual-hosted git repository. thw 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 c5516533a57 [FLINK-32884] [flink-clients] Sending

[flink] branch master updated: PyFlink remote execution should support URLs with paths and https scheme

This is an automated email from the ASF dual-hosted git repository. thw 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 5682472e402 PyFlink remote execution should support

[flink] branch master updated: [FLINK-32885 ] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for PyFlink remote execution

This is an automated email from the ASF dual-hosted git repository. thw 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 e7eeea033a6 [FLINK-32885 ] Refactoring: Moving

[flink] branch master updated (079cd60510d -> 2b14c3ae834)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 079cd60510d [FLINK-32730][table-planner] Fix the bug of Scan reuse after projection pushdown without considering the dpp

[flink] branch master updated (d88ef0e355b -> 6e61b932a3e)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from d88ef0e355b [FLINK-32502][runtime] Remove the AbstractLeaderElectionService (#22959) add 6e61b932a3e [FLINK-32035

[flink] branch master updated: [FLINK-32373][sql-client] Support passing headers with SQL Client gateway requests (#22816)

This is an automated email from the ASF dual-hosted git repository. thw 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 1354d2fae3f [FLINK-32373][sql-client] Support

[flink] branch master updated: [FLINK-32030][sql-client] Add URLs support for SQL Client gateway mode (#22556)

This is an automated email from the ASF dual-hosted git repository. thw 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 4bd51ce122d [FLINK-32030][sql-client] Add URLs

[flink] branch master updated: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask (#20844)

This is an automated email from the ASF dual-hosted git repository. thw 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 61834da8298 [FLINK-29099][connectors/kinesis

[flink-kubernetes-operator] branch main updated: [FLINK-30004] Cleanup deployment after savepoint for Flink versions < 1.15

This is an automated email from the ASF dual-hosted git repository. thw 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 7db0eb1e [FLINK-30004] Cleanup

[flink] branch master updated: [FLINK-27479] add logic to manage the availability future with respect to the underlying reader future

This is an automated email from the ASF dual-hosted git repository. thw 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 9dad2029461 [FLINK-27479] add logic to manage the

[flink-kubernetes-operator] branch main updated: [FLINK-29109] Set jobId when upgrade mode is stateless (Flink < 1.16)

This is an automated email from the ASF dual-hosted git repository. thw 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 6f0914bb [FLINK-29109] Set jobId

[flink-kubernetes-operator] branch main updated: [FLINK-29251] Send CREATED status and Cancel event via FlinkResourceListener

This is an automated email from the ASF dual-hosted git repository. thw 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 84b08d00 [FLINK-29251] Send CREATED

[flink-kubernetes-operator] branch main updated: [FLINK-29100] Relax upgrade checks to allow stateless restart when no stable spec is present

This is an automated email from the ASF dual-hosted git repository. thw 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 6d7c8cee [FLINK-29100] Relax

[flink] branch master updated: [FLINK-28977] NullPointerException in HybridSourceSplitEnumerator.close (#20587)

This is an automated email from the ASF dual-hosted git repository. thw 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 ee4d27411b3 [FLINK-28977] NullPointerException in

[flink] branch release-1.15 updated: [FLINK-28817][connector/common] NullPointerException in HybridSource when restoring from checkpoint

This is an automated email from the ASF dual-hosted git repository. thw 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 e5570e3e33a [FLINK-28817][connector

[flink] branch master updated (1455e51c7cd -> 6e80d90b161)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 1455e51c7cd [FLINK-26771][hive] Fix incomparable exception between boolean type and numeric type in Hive dialect

[flink] branch release-1.15 updated: [FLINK-27255] [flink-avro] flink-avro does not support ser/de of large avro schema (#19645)

This is an automated email from the ASF dual-hosted git repository. thw 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 20768b2f53f [FLINK-27255] [flink-avro

[flink] branch release-1.15 updated: [FLINK-27465] Handle conversion of negative long to timestamp in AvroRowDeserializationSchema

This is an automated email from the ASF dual-hosted git repository. thw 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 50d280daaa8 [FLINK-27465] Handle

[flink] branch release-1.14 updated: [FLINK-27255] [flink-avro] flink-avro does not support ser/de of large avro schema (#19705)

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new d3be0d0154a [FLINK-27255] [flink-avro

[flink] branch master updated (1dcad2272e9 -> 610164d57dd)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 1dcad2272e9 [hotfix][docs-zh] Fix two inaccessible links. (#19678) add 610164d57dd [FLINK-27255] [flink-avro] flink

[flink] branch master updated (a112465efe0 -> 4c8f323d9ec)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from a112465efe0 [FLINK-27442][Formats][Avro Confluent] Add Confluent repo to module flink-sql-avro-confluent-registry

[flink] branch master updated (2e632af6a75 -> c65899f7790)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 2e632af6a75 [FLINK-27369][table-planner] Fix the type mismatch error in RemoveUnreachableCoalesceArgumentsRule add

[flink-web] branch asf-site updated: [FLINK-26781] Link Flink Kubernetes operator doc site to Flink Website

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new 9b9c20f [FLINK-26781] Link Flink

[flink-kubernetes-operator] branch main updated: [FLINK-26473] Check for deployment errors when listJobs fails

This is an automated email from the ASF dual-hosted git repository. thw 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 4b7ffaa [FLINK-26473] Check for

[flink-kubernetes-operator] branch main updated: [FLINK-26432] Cleanly separate validator, observer and reconciler modules

This is an automated email from the ASF dual-hosted git repository. thw 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 4bac805 [FLINK-26432] Cleanly

[flink-kubernetes-operator] 02/02: [FLINK-26261] Refactor to simplify reconciliation logic

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git commit 684b4597764daefe53fb1399298324bec5bc738e Author: Thomas Weise AuthorDate: Sat Feb 26 14:55:43 2022 -0800

[flink-kubernetes-operator] 01/02: [FLINK-26261] Wait for JobManager deployment ready before accessing REST API

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git commit becf19c82616e8f3a148c2ce27141b742f019ab3 Author: Thomas Weise AuthorDate: Thu Feb 24 14:26:30 2022 -0800

[flink-kubernetes-operator] branch main updated (e2ac688 -> 684b459)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git. from e2ac688 [hotfix] copy base config in config builder new becf19c [FLINK-26261] Wait for

[flink-kubernetes-operator] branch main updated: [hotfix] Fix observer sort logic for job status merge

This is an automated email from the ASF dual-hosted git repository. thw 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 3e6a00f [hotfix] Fix observer sort

[flink-kubernetes-operator] branch main updated: [FLINK-26260] Support watching specific namespaces only

This is an automated email from the ASF dual-hosted git repository. thw 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 d8f19bc [FLINK-26260] Support

[flink-kubernetes-operator] branch main updated (b5d71f1 -> 0737641)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git. discard b5d71f1 Seed commit to be removed new 0737641 Seed commit This update added new revisions

[flink-kubernetes-operator] 01/01: Seed commit

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git commit 07376419b83770c6f946d419263b376c7797c673 Author: Thomas Weise AuthorDate: Thu Feb 10 19:12:35 2022 -0800

[flink-kubernetes-operator] branch main created (now b5d71f1)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git. at b5d71f1 Seed commit to be removed This branch includes the following new commits: new b5d71f1

[flink-kubernetes-operator] 01/01: Seed commit to be removed

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git commit b5d71f10c88bebc82519656f2be63631535737d8 Author: Thomas Weise AuthorDate: Thu Feb 10 19:12:35 2022 -0800

svn commit: r52332 - /release/flink/flink-1.14.2/

Author: thw Date: Mon Jan 31 04:50:36 2022 New Revision: 52332 Log: remove flink-1.14.2 Removed: release/flink/flink-1.14.2/

[flink-web] branch asf-site updated: Rebuild website

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new e1657ab Rebuild website e1657ab is

[flink-web] branch asf-site updated: fixup: Add Flink release 1.14.3

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new 309ccfe fixup: Add Flink release 1.14.3

[flink] branch release-1.14 updated: Update japicmp configuration for 1.14.3

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new bd1cd34 Update japicmp configuration

[flink-web] branch asf-site updated: Add Flink release 1.14.3

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new c9d07f1 Add Flink release 1.14.3 c9d07f1

[flink-docker] branch master updated: Add 1.14.3 release

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-docker.git The following commit(s) were added to refs/heads/master by this push: new 312e9af Add 1.14.3 release 312e9af is

[flink-docker] branch dev-1.14 updated (dd51e81 -> a676953)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch dev-1.14 in repository https://gitbox.apache.org/repos/asf/flink-docker.git. from dd51e81 Run tests for 1.14.2 add 9362050 Add GPG key for 1.14.3 release add a676953 update

[flink] annotated tag release-1.14.3 updated (98997ea -> b36cd46)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to annotated tag release-1.14.3 in repository https://gitbox.apache.org/repos/asf/flink.git. *** WARNING: tag release-1.14.3 was modified! *** from 98997ea (commit) to b36cd46 (tag) tagging

svn commit: r52111 - /dev/flink/flink-1.14.3-rc1/ /release/flink/flink-1.14.3/

Author: thw Date: Mon Jan 17 18:05:00 2022 New Revision: 52111 Log: Release Flink 1.14.3 Added: release/flink/flink-1.14.3/ - copied from r52110, dev/flink/flink-1.14.3-rc1/ Removed: dev/flink/flink-1.14.3-rc1/

[flink] annotated tag release-1.14.3-rc1 updated (98997ea -> d32b95f)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to annotated tag release-1.14.3-rc1 in repository https://gitbox.apache.org/repos/asf/flink.git. *** WARNING: tag release-1.14.3-rc1 was modified! *** from 98997ea (commit) to d32b95f (tag

[flink] annotated tag release-1.14.3-rc1 updated (98997ea -> 217984e)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to annotated tag release-1.14.3-rc1 in repository https://gitbox.apache.org/repos/asf/flink.git. *** WARNING: tag release-1.14.3-rc1 was modified! *** from 98997ea (commit) to 217984e (tag

svn commit: r52020 - in /dev/flink/flink-1.14.3-rc1: ./ python/

Author: thw Date: Tue Jan 11 00:56:27 2022 New Revision: 52020 Log: Add flink-1.14.3-rc1 Added: dev/flink/flink-1.14.3-rc1/ dev/flink/flink-1.14.3-rc1/flink-1.14.3-bin-scala_2.11.tgz (with props) dev/flink/flink-1.14.3-rc1/flink-1.14.3-bin-scala_2.11.tgz.asc dev/flink/flink

[flink] 01/01: Commit for release 1.14.3

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.14.3-rc1 in repository https://gitbox.apache.org/repos/asf/flink.git commit 98997ea37ba08eae0f9aa6dd34823238097d8e0d Author: Thomas Weise AuthorDate: Sat Jan 8 14:23:54 2022 -0800

[flink] branch release-1.14.3-rc1 created (now 98997ea)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch release-1.14.3-rc1 in repository https://gitbox.apache.org/repos/asf/flink.git. at 98997ea Commit for release 1.14.3 This branch includes the following new commits: new 98997ea

[flink] branch release-1.14 updated: [FLINK-24064][connector/common] HybridSource restore from savepoint

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new cb71c37 [FLINK-24064][connector/common

[flink] branch release-1.13 updated: [FLINK-24064][connector/common] HybridSource restore from savepoint

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new c7ccd24 [FLINK-24064][connector/common

[flink] branch master updated: [FLINK-24064][connector/common] HybridSource restore from savepoint

This is an automated email from the ASF dual-hosted git repository. thw 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 2984d87 [FLINK-24064][connector/common

[flink] branch release-1.13 updated (dcfbf74 -> a8871ad)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from dcfbf74 [FLINK-24033][table-planner] Propagate unique keys for fromChangelogStream add a8871ad [FLINK

[flink] branch release-1.14 updated: [FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new 8c293c7 [FLINK-24010][connector/common

[flink] branch master updated: [FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

This is an automated email from the ASF dual-hosted git repository. thw 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 da944a8 [FLINK-24010][connector/common

[flink] 02/03: [FLINK-22791][docs] Documentation for HybridSource

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit f8a6d31c4e4e180421517f7e700c731e58be37d8 Author: Thomas Weise AuthorDate: Sun Aug 22 13:56:13 2021 -0700 [FLINK

[flink] 01/03: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit c72aa4b97848625f23bac331b8e916c6a3e2acd3 Author: Thomas Weise AuthorDate: Fri Feb 26 19:32:32 2021 -0800 [FLINK

[flink] 03/03: [FLINK-22791][docs] HybridSource release availability for 1.13.x

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit f74fc331ac8305df0539fb1cbfa1d4722d8c1c56 Author: Thomas Weise AuthorDate: Tue Aug 24 17:06:18 2021 -0700 [FLINK

[flink] branch release-1.13 updated (4b682e8 -> f74fc33)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from 4b682e8 [FLINK-23920][table-common] Keep primary key when inferring schema with SchemaTranslator new

[flink] branch master updated (543f6b7 -> fb7fbd8)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 543f6b7 [hotfix] Add missing import AkkaOptions to MiniClusterConfiguration add fb7fbd8 [FLINK-22791][docs

[flink] branch master updated (233e5d4 -> 23b048b)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 233e5d4 [hotfix][streaming] Removed useless calculateThroughput in the test add 23b048b [FLINK-22670][FLIP-150

[flink] branch master updated: [FLINK-22778] Upgrade to JUnit 4.13

This is an automated email from the ASF dual-hosted git repository. thw 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 15b5a06 [FLINK-22778] Upgrade to JUnit 4.13

[flink] branch release-1.12 updated (1de3d63 -> be33d47)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git. from 1de3d63 [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint. add fc886c7 [FLINK-20114

[flink] branch release-1.12 updated (719bf5e -> dbdacac)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git. from 719bf5e [FLINK-21944][python] Perform null check before closing arrowSerializer add dbdacac [FLINK-20533

[flink] branch release-1.12 updated: [FLINK-21169][kafka] flink-connector-base dependency should be scope compile

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

[flink] branch master updated: [FLINK-21169][kafka] flink-connector-base dependency should be scope compile

This is an automated email from the ASF dual-hosted git repository. thw 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 d859920 [FLINK-21169][kafka] flink-connector-base

[flink] branch release-1.12 updated: [FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.12 by this push: new 1822d13 [FLINK-21059][kafka

[flink] branch master updated (dac3e72 -> a4f1174)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from dac3e72 [FLINK-21006] Fix hbase 1.4 tests on Hadoop 3.x add a4f1174 [FLINK-21059][kafka] KafkaSourceEnumerator

[flink] branch master updated (09f1674 -> c7823ff)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 09f1674 [FLINK-18655][flink-runtime] Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin (#12941

[flink] branch release-1.10 updated (ff7b4f6 -> 99ea1aa)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git. from ff7b4f6 [FLINK-17313] Fix type validation error when sink table ddl contains columns with precision of decimal

[flink] branch master updated (2849e39 -> a737cdc)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 2849e39 [FLINK-17515][yarn] Move YARN staging functionality to a separate class add a737cdc [FLINK-17496

[flink] branch master updated (b098ce5 -> de5f8fa)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from b098ce5 [FLINK-15838] Dangling CountDownLatch.await(timeout) add de5f8fa [FLINK-16393][kinesis] Skip record

[flink] branch release-1.10 updated: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.10 by this push: new c4acec8 [FLINK-13027][fs-connector

[flink] branch master updated (ec8ea8b -> df5eb21)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from ec8ea8b [FLINK-13596][ml] Improve fallback conversion and test for Table transformation. add df5eb21 [FLINK

[flink] branch release-1.10 updated: [FLINK-15301] [kinesis] Exception propagation from record emitter to source thread

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.10 by this push: new c4e7baa [FLINK-15301] [kinesis

[flink] branch master updated (8525c37 -> c2c38b1)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 8525c37 [FLINK-15308][runtime] Remove data compression for pipelined partition add c2c38b1 [FLINK-15301

[flink] branch release-1.9 updated: Update KPL version to 0.13.1

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.9 by this push: new e7650ff Update KPL version to 0.13.1

[flink] branch release-1.8 updated: Upgrade KPL version to 0.13.1

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.8 by this push: new 148dedd Upgrade KPL version to 0.13.1

[flink-web] branch asf-site updated: Rebuild website

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new d2ee4f0 Rebuild website d2ee4f0 is

[flink] branch master updated (28c5264 -> 3f5c212)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 28c5264 [FLINK-13065][datastream][docs] Clarify key selector example add 3f5c212 [FLINK-14283][kinesis][docs

[flink] branch release-1.9 updated: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.9 by this push: new 8186ec3 [FLINK-14107][kinesis] Erroneous

[flink] branch release-1.8 updated: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.8 by this push: new 4a4dae0 [FLINK-14107][kinesis] Erroneous

[flink] branch master updated (f65ee55 -> 4a4a147)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from f65ee55 [FLINK-14017][python] Support to start up Python worker in process mode. add 4a4a147 [FLINK-14107

[flink] branch release-1.9 updated: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.9 by this push: new c905a4d [hotfix][kinesis] Update emit

[flink] branch master updated (0437ad2 -> b6bd8f6)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 0437ad2 [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 versions add b6bd8f6 [hotfix][kinesis

[flink] branch release-1.9 updated: [FLINK-12595][kinesis] Interrupt thread at right time to avoid deadlock

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.9 by this push: new 7ea55e9 [FLINK-12595][kinesis] Interrupt

[flink] branch master updated (5da6e4c -> 091266d)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 5da6e4c [FLINK-13206]replace 'use database' with 'use' in sql client parser add 091266d [

[flink] branch release-1.8 updated: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.8 by this push: new 184e8e0 [FLINK-10921] [kinesis] Shard

[flink] branch master updated: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer

This is an automated email from the ASF dual-hosted git repository. thw 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 793a784 [FLINK-10921] [kinesis] Shard watermark

[flink] branch release-1.8 updated: [FLINK-12539] [fs-connector] Make StreamingFileSink customizable (#8469)

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.8 by this push: new 7b862dc [FLINK-12539] [fs-connector

[flink] branch master updated (f652bb5 -> 7748729)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from f652bb5 [FLINK-12447][build] Set minimum maven version to 3.1.1 add 7748729 [FLINK-12539] [fs-connector] Make

[flink] branch release-1.8 updated (9795457 -> cf065a0)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git. from 9795457 [FLINK-12064] [core, State Backends] RocksDBKeyedStateBackend snapshots uses incorrect key serializer if

[flink] branch release-1.8 updated: [FLINK-9007] [kinesis] [e2e] Add Kinesis end-to-end test

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.8 by this push: new 11af452 [FLINK-9007] [kinesis] [e2e] Add

[flink] branch master updated: [FLINK-9007] [kinesis] [e2e] Build Kinesis test under include-kinesis profile

This is an automated email from the ASF dual-hosted git repository. thw 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 4250819 [FLINK-9007] [kinesis] [e2e] Build Kinesis

[flink] branch master updated: [hotfix] [FLINK-9007] [kinesis] [e2e] Disable record aggregation

This is an automated email from the ASF dual-hosted git repository. thw 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 92c7808 [hotfix] [FLINK-9007] [kinesis] [e2e

  1   2   >