[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] maosuhan commented on a change in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r767101531 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbFormatUtils.java ## @@ -0,0 +1,166 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] deadwind4 commented on pull request #18077: [FLINK-25240][core] update log4j2 version to 2.15.0

deadwind4 commented on pull request #18077: URL: https://github.com/apache/flink/pull/18077#issuecomment-991417465 > @EronWright committer and reviewer will backport to 1.13/1.14 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 4c19e62271afe1533bd9cf2fa2036f2ebe0075d5 Azure:

[GitHub] [flink] EronWright commented on pull request #18077: [FLINK-25240][core] update log4j2 version to 2.15.0

EronWright commented on pull request #18077: URL: https://github.com/apache/flink/pull/18077#issuecomment-991383576 @deadwind4 do you plan to backport to 1.13/1.14? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] JingGe commented on pull request #18082: [FLINK-24077][hbase2/HBaseConnectorITCase] fix flaky tests backport to 1.12

JingGe commented on pull request #18082: URL: https://github.com/apache/flink/pull/18082#issuecomment-991367079 @AHeise would you please help merging it? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 8caa0c3160fd57ea0476c0dc0d54a1422ee8bcef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 2d966d5e2317c9a4bcbd398e0ce4d7d2d4800973 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 2d966d5e2317c9a4bcbd398e0ce4d7d2d4800973 Azure:

[jira] [Updated] (FLINK-5263) Add docs about JVM sharing between tasks

[ https://issues.apache.org/jira/browse/FLINK-5263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5263: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-5409) Separate Job API from the Runtime

[ https://issues.apache.org/jira/browse/FLINK-5409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5409: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8417: -- Labels: auto-deprioritized-major auto-deprioritized-minor usability (was:

[jira] [Updated] (FLINK-5301) Can't upload job via Web UI when using a proxy

[ https://issues.apache.org/jira/browse/FLINK-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5301: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-5351) Make the TypeExtractor support functions with more than 2 inputs

[ https://issues.apache.org/jira/browse/FLINK-5351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5351: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-5139) consum kafka can set offset

[ https://issues.apache.org/jira/browse/FLINK-5139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5139: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-5264) Improve error message when assigning uid to intermediate operator

[ https://issues.apache.org/jira/browse/FLINK-5264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5264: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-5279) Improve error message when trying to access keyed state in non-keyed operator

[ https://issues.apache.org/jira/browse/FLINK-5279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5279: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-5334) outdated scala SBT quickstart example

[ https://issues.apache.org/jira/browse/FLINK-5334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5334: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-8302) Support shift_left and shift_right in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8302: -- Labels: auto-deprioritized-major auto-deprioritized-minor features pull-request-available

[jira] [Updated] (FLINK-8377) Document DataViews for user-defined aggregate functions

[ https://issues.apache.org/jira/browse/FLINK-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8377: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-15642) Support to set JobManager readiness and liveness check

[ https://issues.apache.org/jira/browse/FLINK-15642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15642: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-15596) Support key-value messages for KafkaTableSink for flink SQL \Table

[ https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15596: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-8358) Hostname used by DataDog metric reporter is not configurable

[ https://issues.apache.org/jira/browse/FLINK-8358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8358: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-5156) Consolidate streaming FieldAccessor functionality

[ https://issues.apache.org/jira/browse/FLINK-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5156: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-8444) Rework dependency setup docs

[ https://issues.apache.org/jira/browse/FLINK-8444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8444: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-8380) Dynamic BucketingSink paths based on ingested Kafka topics

[ https://issues.apache.org/jira/browse/FLINK-8380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8380: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-15678) Optimize producing primary key without row number in special Top 1

[ https://issues.apache.org/jira/browse/FLINK-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15678: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-5422) Check for name collisions in the Rolling/BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5422: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-5260) Add docs about how to react to cancellation

[ https://issues.apache.org/jira/browse/FLINK-5260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5260: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider

[ https://issues.apache.org/jira/browse/FLINK-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8416: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 2d966d5e2317c9a4bcbd398e0ce4d7d2d4800973 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 737062727b800d068521ec30b89d5fd3a03fa2a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 737062727b800d068521ec30b89d5fd3a03fa2a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 6445d1c6fb469ef7ca57bdee129a52f0e5bb369b Azure:

[GitHub] [flink-web] sjwiesman commented on a change in pull request #488: add concrete flink configuration to CVE blog post

sjwiesman commented on a change in pull request #488: URL: https://github.com/apache/flink-web/pull/488#discussion_r766932872 ## File path: _posts/2021-12-10-log4j-cve.md ## @@ -13,8 +13,15 @@ It is by now tracked under [CVE-2021-44228](https://nvd.nist.gov/vuln/detail/CVE

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 737062727b800d068521ec30b89d5fd3a03fa2a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 737062727b800d068521ec30b89d5fd3a03fa2a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

flinkbot edited a comment on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-986500405 ## CI report: * ac179499cd39e4d3c8abea70dbb6209a45f6dee3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 737062727b800d068521ec30b89d5fd3a03fa2a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18082: [FLINK-24077][hbase2/HBaseConnectorITCase] fix flaky tests backport to 1.12

flinkbot edited a comment on pull request #18082: URL: https://github.com/apache/flink/pull/18082#issuecomment-990938904 ## CI report: * c9c237e13e5e43f0f2e5a70967ce3bf331c3bac8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18082: [FLINK-24077][hbase2/HBaseConnectorITCase] fix flaky tests backport to 1.12

flinkbot edited a comment on pull request #18082: URL: https://github.com/apache/flink/pull/18082#issuecomment-990938904 ## CI report: * c9c237e13e5e43f0f2e5a70967ce3bf331c3bac8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18082: [FLINK-24077][hbase2/HBaseConnectorITCase] fix flaky tests backport to 1.12

flinkbot edited a comment on pull request #18082: URL: https://github.com/apache/flink/pull/18082#issuecomment-990938904 ## CI report: * c9c237e13e5e43f0f2e5a70967ce3bf331c3bac8 Azure:

[GitHub] [flink] JingGe commented on pull request #18082: [FLINK-24077][hbase2/HBaseConnectorITCase] fix flaky tests backport to 1.12

JingGe commented on pull request #18082: URL: https://github.com/apache/flink/pull/18082#issuecomment-991193943 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] pnowojski commented on a change in pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

pnowojski commented on a change in pull request #17774: URL: https://github.com/apache/flink/pull/17774#discussion_r766826678 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1084,6 +1083,15 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #18082: [FLINK-24077][hbase2/HBaseConnectorITCase] fix flaky tests backport to 1.12

flinkbot edited a comment on pull request #18082: URL: https://github.com/apache/flink/pull/18082#issuecomment-990938904 ## CI report: * c9c237e13e5e43f0f2e5a70967ce3bf331c3bac8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18071: [FLINK-24077][hbase2/HBaseConnectorITCase] fix flaky tests backport to 1.13

flinkbot edited a comment on pull request #18071: URL: https://github.com/apache/flink/pull/18071#issuecomment-990316009 ## CI report: * d72c4a290de9373b3868237940976276499b100b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17785: [FLINK-24580][Connectors/Kinesis] Make ConnectTimeoutException recoverable

flinkbot edited a comment on pull request #17785: URL: https://github.com/apache/flink/pull/17785#issuecomment-967470963 ## CI report: * fc88ab25f463422610629a737ad087e427c01828 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 70f0705383e67a4ffa9f577a48165a0657a8dcb7 Azure:

[jira] [Commented] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail

[ https://issues.apache.org/jira/browse/FLINK-22775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457284#comment-17457284 ] Till Rohrmann commented on FLINK-22775: --- Can we backport the fix to {{1.14}} and {{1.13}}

[GitHub] [flink] deadwind4 commented on pull request #16635: [hotfix][connector-jdbc] fix postgres unit test typo

deadwind4 commented on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-991145925 @MartijnVisser please review it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] deadwind4 removed a comment on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

deadwind4 removed a comment on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-991140514 LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] jelly-1203 commented on a change in pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

jelly-1203 commented on a change in pull request #18017: URL: https://github.com/apache/flink/pull/18017#discussion_r766554432 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/MergeTableLikeUtil.java ## @@ -426,6 +433,14 @@

[GitHub] [flink] jelly-1203 commented on a change in pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

jelly-1203 commented on a change in pull request #18017: URL: https://github.com/apache/flink/pull/18017#discussion_r766554531 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/MergeTableLikeUtil.java ## @@ -426,6 +433,14 @@

[GitHub] [flink] deadwind4 commented on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

deadwind4 commented on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-991140514 LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [flink] flinkbot edited a comment on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

flinkbot edited a comment on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-986500405 ## CI report: * a3995c2e238f415d94360e70df3fc08b3c15e382 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

flinkbot edited a comment on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-986500405 ## CI report: * a3995c2e238f415d94360e70df3fc08b3c15e382 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18077: [FLINK-25240][core] update log4j2 version to 2.15.0

flinkbot edited a comment on pull request #18077: URL: https://github.com/apache/flink/pull/18077#issuecomment-990863888 ## CI report: * aec502fbe28c7dc9cf457b10972f2570582bd551 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 737062727b800d068521ec30b89d5fd3a03fa2a3 Azure:

[GitHub] [flink] flinkbot commented on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot commented on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991129881 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

flinkbot commented on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 737062727b800d068521ec30b89d5fd3a03fa2a3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] tillrohrmann opened a new pull request #18083: [Draft][FLIP-198] Introduce working directory for Flink processes

tillrohrmann opened a new pull request #18083: URL: https://github.com/apache/flink/pull/18083 This PR is a draft PR for [FLIP-198](https://cwiki.apache.org/confluence/x/ZZiqCw). It consists of several commits that implement the proposed changes:

[jira] [Closed] (FLINK-25257) Make the TaskExecutor not depend on concrete BlobServiceCache implementation

[ https://issues.apache.org/jira/browse/FLINK-25257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25257. - Resolution: Fixed Fixed via cf1e8c39111378735e4c05a5edb3bd713229bb08 > Make the TaskExecutor

[jira] [Updated] (FLINK-25257) Make the TaskExecutor not depend on concrete BlobServiceCache implementation

[ https://issues.apache.org/jira/browse/FLINK-25257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25257: -- Issue Type: Technical Debt (was: Improvement) > Make the TaskExecutor not depend on concrete

[GitHub] [flink] tillrohrmann closed pull request #18081: [FLINK-25257][TE] Let TaskExecutor use TaskExecutorBlobService interface instead of concrete BlobCacheService implementation

tillrohrmann closed pull request #18081: URL: https://github.com/apache/flink/pull/18081 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #18078: [FLINK-20195][coordination] Deduplicate jobs for overview

flinkbot edited a comment on pull request #18078: URL: https://github.com/apache/flink/pull/18078#issuecomment-990888233 ## CI report: * 787da020d7ccc3ed2190090a5bb64e7f86efe8a1 Azure:

[GitHub] [flink-web] zentol commented on a change in pull request #487: Add blog post about Log4j Zero Day

zentol commented on a change in pull request #487: URL: https://github.com/apache/flink-web/pull/487#discussion_r766811104 ## File path: _posts/2021-12-10-log4j-cve.md ## @@ -0,0 +1,21 @@ +--- +layout: post +title: "Advise on Apache Log4j Zero Day (CVE-2021-44228)" +date:

[GitHub] [flink] flinkbot edited a comment on pull request #18051: [FLINK-25159][tests] Streamline E2E surefire setup

flinkbot edited a comment on pull request #18051: URL: https://github.com/apache/flink/pull/18051#issuecomment-988626420 ## CI report: * 4aa8e0b8440840e20dcc57f82acf73dd26f499c3 Azure:

[GitHub] [flink-web] knaufk merged pull request #487: Add blog post about Log4j Zero Day

knaufk merged pull request #487: URL: https://github.com/apache/flink-web/pull/487 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-web] knaufk commented on a change in pull request #487: Add blog post about Log4j Zero Day

knaufk commented on a change in pull request #487: URL: https://github.com/apache/flink-web/pull/487#discussion_r766806463 ## File path: _posts/2021-12-10-log4j-cve.md ## @@ -0,0 +1,21 @@ +--- +layout: post +title: "Advise on Apache Log4j Zero Day (CVE-2021-44228)" +date:

[jira] [Closed] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-25238. Resolution: Won't Fix > flink iceberg source reading array types fail with Cast Exception >

[jira] [Commented] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457235#comment-17457235 ] Seth Wiesman commented on FLINK-25238: -- The Iceberg Sink is maintained by the Apache Iceberg

[GitHub] [flink] flinkbot edited a comment on pull request #18055: [docs] Tutorial: Write Your First Flink SQL program

flinkbot edited a comment on pull request #18055: URL: https://github.com/apache/flink/pull/18055#issuecomment-988788303 ## CI report: * 9763d55b86ff8ef5f68fb8520360197f7a66c044 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 6731722ca4886ba8c584d541219a7d6b980b3028 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

flinkbot edited a comment on pull request #18063: URL: https://github.com/apache/flink/pull/18063#issuecomment-989830995 ## CI report: * 1d2ab2ff32663de8d43339b76686e4775d52f22f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 6731722ca4886ba8c584d541219a7d6b980b3028 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 6731722ca4886ba8c584d541219a7d6b980b3028 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 6731722ca4886ba8c584d541219a7d6b980b3028 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17785: [FLINK-24580][Connectors/Kinesis] Make ConnectTimeoutException recoverable

flinkbot edited a comment on pull request #17785: URL: https://github.com/apache/flink/pull/17785#issuecomment-967470963 ## CI report: * 134c805f9271cfac8059656d4d49b5362538409b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 6731722ca4886ba8c584d541219a7d6b980b3028 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17785: [FLINK-24580][Connectors/Kinesis] Make ConnectTimeoutException recoverable

flinkbot edited a comment on pull request #17785: URL: https://github.com/apache/flink/pull/17785#issuecomment-967470963 ## CI report: * 134c805f9271cfac8059656d4d49b5362538409b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 6731722ca4886ba8c584d541219a7d6b980b3028 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 6731722ca4886ba8c584d541219a7d6b980b3028 Azure:

[GitHub] [flink-web] zentol commented on a change in pull request #487: Add blog post about Log4j Zero Day

zentol commented on a change in pull request #487: URL: https://github.com/apache/flink-web/pull/487#discussion_r766778688 ## File path: _posts/2021-12-10-log4j-cve.md ## @@ -0,0 +1,21 @@ +--- +layout: post +title: "Advise on Apache Log4j Zero Day (CVE-2021-44228)" +date:

[GitHub] [flink-web] zentol commented on a change in pull request #487: Add blog post about Log4j Zero Day

zentol commented on a change in pull request #487: URL: https://github.com/apache/flink-web/pull/487#discussion_r766776759 ## File path: _posts/2021-12-10-log4j-cve.md ## @@ -0,0 +1,21 @@ +--- +layout: post +title: "Advise on Apache Log4j Zero Day (CVE-2021-44228)" +date:

[GitHub] [flink] flinkbot edited a comment on pull request #18055: [docs] Tutorial: Write Your First Flink SQL program

flinkbot edited a comment on pull request #18055: URL: https://github.com/apache/flink/pull/18055#issuecomment-988788303 ## CI report: * aa96631ae9ae4e1d26a350026bbac73e7785b7ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 6731722ca4886ba8c584d541219a7d6b980b3028 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 6731722ca4886ba8c584d541219a7d6b980b3028 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18077: [FLINK-25240][core] update log4j2 version to 2.15.0

flinkbot edited a comment on pull request #18077: URL: https://github.com/apache/flink/pull/18077#issuecomment-990863888 ## CI report: * 917836dd8f25d3cc29c5e71f2cc19bab3593256b Azure:

  1   2   3   4   5   6   >