[jira] [Updated] (FLINK-26311) Test CsvFormat

[ https://issues.apache.org/jira/browse/FLINK-26311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-26311: -- Description: https://issues.apache.org/jira/browse/FLINK-24703 adds new

[GitHub] [flink] flinkbot commented on pull request #18914: [FLINK-26259][table-planner]Partial insert and partition insert canno…

flinkbot commented on pull request #18914: URL: https://github.com/apache/flink/pull/18914#issuecomment-1050374088 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 edited a comment on pull request #18914: [FLINK-26259][table-planner]Partial insert and partition insert canno…

flinkbot edited a comment on pull request #18914: URL: https://github.com/apache/flink/pull/18914#issuecomment-1050372877 ## CI report: * a591d1c40b987902427e7692e208e972b70bcb33 Azure:

[GitHub] [flink] flinkbot commented on pull request #18914: [FLINK-26259][table-planner]Partial insert and partition insert canno…

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

[jira] [Updated] (FLINK-26259) Partial insert and partition insert cannot work with sql hint

[ https://issues.apache.org/jira/browse/FLINK-26259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26259: --- Labels: pull-request-available (was: ) > Partial insert and partition insert cannot work

[GitHub] [flink] schumiyi opened a new pull request #18914: [FLINK-26259][table-planner]Partial insert and partition insert canno…

schumiyi opened a new pull request #18914: URL: https://github.com/apache/flink/pull/18914 ## What is the purpose of the change This PR fix the bug that partial insert and partition insert cannot work with sql hint. Before this PR, ```insert into /*+ OPTIONS('key'='value') */

[GitHub] [flink] flinkbot edited a comment on pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

flinkbot edited a comment on pull request #18903: URL: https://github.com/apache/flink/pull/18903#issuecomment-1049367947 ## CI report: * 5785ed60993a64454f18c28cc34053acf0118881 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

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

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * ebd80751a983dff7082f34365379e5c465c63d92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

flinkbot edited a comment on pull request #18903: URL: https://github.com/apache/flink/pull/18903#issuecomment-1049367947 ## CI report: * 53d933b146bfe3cc9bae334b15aa333cfa0cb812 Azure:

[GitHub] [flink] afedulov commented on pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

afedulov commented on pull request #18903: URL: https://github.com/apache/flink/pull/18903#issuecomment-1050304463 Thanks for the review, @fapaul. I fixed the build and removed the writer part as it is indeed only currently meaningful in the SQL context. -- This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

flinkbot edited a comment on pull request #18903: URL: https://github.com/apache/flink/pull/18903#issuecomment-1049367947 ## CI report: * 53d933b146bfe3cc9bae334b15aa333cfa0cb812 Azure:

[GitHub] [flink] afedulov commented on a change in pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

afedulov commented on a change in pull request #18903: URL: https://github.com/apache/flink/pull/18903#discussion_r814295734 ## File path: docs/content/docs/connectors/datastream/formats/csv.md ## @@ -0,0 +1,87 @@ +--- +title: "CSV" +weight: 4 +type: docs +aliases: +-

[GitHub] [flink] afedulov commented on a change in pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

afedulov commented on a change in pull request #18903: URL: https://github.com/apache/flink/pull/18903#discussion_r814220956 ## File path: docs/content/docs/connectors/datastream/formats/csv.md ## @@ -0,0 +1,87 @@ +--- +title: "CSV" +weight: 4 +type: docs +aliases: +-

[jira] [Commented] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

[ https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497745#comment-17497745 ] Galen Warren commented on FLINK-26340: -- Just a note for anyone who might arrive here – we changed

[jira] [Closed] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

[ https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-26340. Resolution: Fixed > Add ability in Golang SDK to create new statefun.Context from existing one,

[GitHub] [flink-statefun] galenwarren commented on pull request #303: [FLINK-26340][statefun-golang-sdk] Add ability in Golang SDK to create new statefun.Context from existing one, but with a new unde

galenwarren commented on pull request #303: URL: https://github.com/apache/flink-statefun/pull/303#issuecomment-1050288168 Squashed. Is there anything else I need to do on this one? Thanks again. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

[ https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497743#comment-17497743 ] Seth Wiesman commented on FLINK-26340: -- resolved in: 725202cd69b78442d1287deec000ae2d52da4bda >

[GitHub] [flink-statefun] sjwiesman closed pull request #303: [FLINK-26340][statefun-golang-sdk] Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying c

sjwiesman closed pull request #303: URL: https://github.com/apache/flink-statefun/pull/303 -- 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-statefun] galenwarren commented on pull request #303: [FLINK-26340][statefun-golang-sdk] Add ability in Golang SDK to create new statefun.Context from existing one, but with a new unde

galenwarren commented on pull request #303: URL: https://github.com/apache/flink-statefun/pull/303#issuecomment-1050282217 @sjwiesman Great! Thanks for taking the time to review this. I'll go ahead and squash the commits. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #18896: [FLINK-26186][test] update the API_ANNOTATIONS rule

flinkbot edited a comment on pull request #18896: URL: https://github.com/apache/flink/pull/18896#issuecomment-1048561075 ## CI report: * df12b3764056bf4908f1b14b46ce39559f380d3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18872: [FLINK-26283][table-planner] Harden AggregateCall serialization in JSON plan

flinkbot edited a comment on pull request #18872: URL: https://github.com/apache/flink/pull/18872#issuecomment-1047614320 ## CI report: * c16b85b48581125702586f4942982d32f2293003 Azure:

[GitHub] [flink] afedulov commented on a change in pull request #18911: [FLINK-26357][format] add FLINK API annotations

afedulov commented on a change in pull request #18911: URL: https://github.com/apache/flink/pull/18911#discussion_r814259791 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java ## @@ -42,7 +43,17 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18895: [FLINK-26287][table] Add convenience method TableConfig.set

flinkbot edited a comment on pull request #18895: URL: https://github.com/apache/flink/pull/18895#issuecomment-1048552059 ## CI report: * 670400c8f787e726925fa6a9a38b154c661f3c4d Azure:

[GitHub] [flink-web] sjwiesman closed pull request #508: [blog] Scala Free in One Fifteen

sjwiesman closed pull request #508: URL: https://github.com/apache/flink-web/pull/508 -- 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] sjwiesman commented on pull request #508: [blog] Scala Free in One Fifteen

sjwiesman commented on pull request #508: URL: https://github.com/apache/flink-web/pull/508#issuecomment-1050267081 merged manually. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

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

[GitHub] [flink] XComp edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

XComp edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050248709 The compiled docs look like that: https://user-images.githubusercontent.com/1101012/155604985-35f247c2-99bb-4731-86e2-f15221c0f3a9.png;> -- This is an automated

[GitHub] [flink] XComp commented on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

XComp commented on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050248709 The compiled docs look like that: ![Uploading Screenshot 2022-02-24 at 21.46.14.png…]() -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * a2dec769c7a8b1983e2f08b14421b5aa2937c943 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

flinkbot edited a comment on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1047490231 ## CI report: * 59399b4d133e898af4b00965cd0de07989fe6815 Azure:

[GitHub] [flink] rmetzger commented on pull request #18870: [FLINK-26191][connectors/elasticsearch] Revert Elasticsearch dependencies to 7.10.2 to keep Apache 2 license

rmetzger commented on pull request #18870: URL: https://github.com/apache/flink/pull/18870#issuecomment-1050222131 I don't fully get what the discussions about ES6 are about. The version we currently use seems to be `6.8.20`, which (according to the contents of the jar file is ASL 2.0,

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

CrynetLogistics commented on a change in pull request #18651: URL: https://github.com/apache/flink/pull/18651#discussion_r814230648 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -290,17

[GitHub] [flink] rmetzger edited a comment on pull request #18870: [FLINK-26191][connectors/elasticsearch] Revert Elasticsearch dependencies to 7.10.2 to keep Apache 2 license

rmetzger edited a comment on pull request #18870: URL: https://github.com/apache/flink/pull/18870#issuecomment-1050216538 Is the flink ci currently generally unstable? The last two PRs I looked at had failures. It would be nice if the ES tests were executed for this PR: ```

[GitHub] [flink] rmetzger commented on pull request #18870: [FLINK-26191][connectors/elasticsearch] Revert Elasticsearch dependencies to 7.10.2 to keep Apache 2 license

rmetzger commented on pull request #18870: URL: https://github.com/apache/flink/pull/18870#issuecomment-1050216538 Is the flink ci currently generally unstable? The last two PRs I looked at had failures. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #18908: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #18908: URL: https://github.com/apache/flink/pull/18908#issuecomment-1049835023 ## CI report: * e10596de77972fd01a672e84efeaea11e9259a65 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18912: [FLINK-26353] flink stop --help does not list --type option

flinkbot edited a comment on pull request #18912: URL: https://github.com/apache/flink/pull/18912#issuecomment-1050078111 ## CI report: * 0fc6498386e5ea2d87c488de1452164bbb18db2c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * a2dec769c7a8b1983e2f08b14421b5aa2937c943 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] afedulov commented on a change in pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

afedulov commented on a change in pull request #18903: URL: https://github.com/apache/flink/pull/18903#discussion_r814220956 ## File path: docs/content/docs/connectors/datastream/formats/csv.md ## @@ -0,0 +1,87 @@ +--- +title: "CSV" +weight: 4 +type: docs +aliases: +-

[GitHub] [flink] afedulov commented on a change in pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

afedulov commented on a change in pull request #18903: URL: https://github.com/apache/flink/pull/18903#discussion_r814220659 ## File path: docs/content/docs/connectors/datastream/formats/csv.md ## @@ -0,0 +1,87 @@ +--- +title: "CSV" +weight: 4 +type: docs +aliases: +-

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * a2dec769c7a8b1983e2f08b14421b5aa2937c943 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * a2dec769c7a8b1983e2f08b14421b5aa2937c943 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

CrynetLogistics commented on a change in pull request #18651: URL: https://github.com/apache/flink/pull/18651#discussion_r814210933 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -290,17

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * a2dec769c7a8b1983e2f08b14421b5aa2937c943 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18911: [FLINK-26357][format] add FLINK API annotations

flinkbot edited a comment on pull request #18911: URL: https://github.com/apache/flink/pull/18911#issuecomment-1050053238 ## CI report: * 3f271f3c15566615837995fff27bbe9658872df5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * a2dec769c7a8b1983e2f08b14421b5aa2937c943 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 85ab24d3a40d1714c60b784d396edfb9a8a4277e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * a2dec769c7a8b1983e2f08b14421b5aa2937c943 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 85ab24d3a40d1714c60b784d396edfb9a8a4277e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * a2dec769c7a8b1983e2f08b14421b5aa2937c943 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 85ab24d3a40d1714c60b784d396edfb9a8a4277e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * a2dec769c7a8b1983e2f08b14421b5aa2937c943 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 85ab24d3a40d1714c60b784d396edfb9a8a4277e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 85ab24d3a40d1714c60b784d396edfb9a8a4277e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 79c55a130a3cd24a043ab55696ddae6b840e1c05 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

flinkbot edited a comment on pull request #18845: URL: https://github.com/apache/flink/pull/18845#issuecomment-1044482798 ## CI report: * cfe1c27e4250473220cda130460a0b8dbcdebc82 Azure:

[jira] [Commented] (FLINK-26349) AvroParquetReaders does not work with ReflectData

[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497663#comment-17497663 ] Jing Ge commented on FLINK-26349: - I think there is a conflict between write model and read model. It

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * a2dec769c7a8b1983e2f08b14421b5aa2937c943 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18896: [FLINK-26186][test] update the API_ANNOTATIONS rule

flinkbot edited a comment on pull request #18896: URL: https://github.com/apache/flink/pull/18896#issuecomment-1048561075 ## CI report: * df12b3764056bf4908f1b14b46ce39559f380d3b Azure:

[jira] [Comment Edited] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497548#comment-17497548 ] Jing Ge edited comment on FLINK-26301 at 2/24/22, 6:58 PM: --- >> The reason of

[jira] [Resolved] (FLINK-25846) [FLIP-171] Async Sink does not gracefully shutdown on Cancel

[ https://issues.apache.org/jira/browse/FLINK-25846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-25846. --- Resolution: Fixed > [FLIP-171] Async Sink does not gracefully shutdown on Cancel >

[jira] [Commented] (FLINK-25846) [FLIP-171] Async Sink does not gracefully shutdown on Cancel

[ https://issues.apache.org/jira/browse/FLINK-25846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497646#comment-17497646 ] Danny Cranmer commented on FLINK-25846: --- Merged to master

[jira] [Commented] (FLINK-25848) [FLIP-171] KDS Sink does not fast fail when invalid configuration supplied

[ https://issues.apache.org/jira/browse/FLINK-25848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497645#comment-17497645 ] Danny Cranmer commented on FLINK-25848: --- Merged into master

[jira] [Resolved] (FLINK-25848) [FLIP-171] KDS Sink does not fast fail when invalid configuration supplied

[ https://issues.apache.org/jira/browse/FLINK-25848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-25848. --- Resolution: Fixed > [FLIP-171] KDS Sink does not fast fail when invalid configuration

[GitHub] [flink] dannycranmer merged pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration supplied

dannycranmer merged pull request #18553: URL: https://github.com/apache/flink/pull/18553 -- 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 commented on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18896: [FLINK-26186][test] update the API_ANNOTATIONS rule

flinkbot edited a comment on pull request #18896: URL: https://github.com/apache/flink/pull/18896#issuecomment-1048561075 ## CI report: * df12b3764056bf4908f1b14b46ce39559f380d3b Azure:

[GitHub] [flink] flinkbot commented on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

flinkbot commented on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050152403 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] JingGe commented on pull request #18896: [FLINK-26186][test] update the API_ANNOTATIONS rule

JingGe commented on pull request #18896: URL: https://github.com/apache/flink/pull/18896#issuecomment-1050150866 @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

[jira] [Updated] (FLINK-26331) Make max retries configurable

[ https://issues.apache.org/jira/browse/FLINK-26331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26331: --- Labels: pull-request-available (was: ) > Make max retries configurable >

[GitHub] [flink] XComp opened a new pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

XComp opened a new pull request #18913: URL: https://github.com/apache/flink/pull/18913 The goal is to align the user experience for retry functionality. I created a follow-up ticket FLINK-26359 to cover the actual alignment in the code. ## What is the purpose of the change

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 10469fa5592d420db362cb222ea97185fb050d52 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 79c55a130a3cd24a043ab55696ddae6b840e1c05 Azure:

[jira] [Created] (FLINK-26359) Aligning the retry mechanism for the repeatable cleanup and task restarts

Matthias Pohl created FLINK-26359: - Summary: Aligning the retry mechanism for the repeatable cleanup and task restarts Key: FLINK-26359 URL: https://issues.apache.org/jira/browse/FLINK-26359 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 79c55a130a3cd24a043ab55696ddae6b840e1c05 Azure:

[GitHub] [flink] akalash commented on a change in pull request #18845: [FLINK-25958][runtime] Report completed checkpoint to statistic only after the completed checkpoint is added to the store.

akalash commented on a change in pull request #18845: URL: https://github.com/apache/flink/pull/18845#discussion_r814148032 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java ## @@ -111,6 +111,8 @@ /** The promise to

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 79c55a130a3cd24a043ab55696ddae6b840e1c05 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18896: [FLINK-26186][test] update the API_ANNOTATIONS rule

flinkbot edited a comment on pull request #18896: URL: https://github.com/apache/flink/pull/18896#issuecomment-1048561075 ## CI report: * df12b3764056bf4908f1b14b46ce39559f380d3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18910: [FLINK-11813] Add missing documentation for JobResultStore and repeatable resource cleanup strategy

flinkbot edited a comment on pull request #18910: URL: https://github.com/apache/flink/pull/18910#issuecomment-1049985255 ## CI report: * a812e67a9e98b94f1b8ff83dc0f63d1c4c2263d0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18908: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #18908: URL: https://github.com/apache/flink/pull/18908#issuecomment-1049835023 ## CI report: * 085fe6741ce3c21d92001b6917c10c32268e870a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

flinkbot edited a comment on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1047490231 ## CI report: * 45b6030976ce90330477d2a04abbb3bd0d581a13 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * dc4e90caf1d8c05ed59bb993c6c3a0d72c9580b3 Azure:

<    1   2   3   4   5   6   >