[jira] [Commented] (FLINK-16795) End to end tests timeout on Azure

[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136330#comment-17136330 ] Robert Metzger commented on FLINK-16795:

[jira] [Updated] (FLINK-18088) Umbrella for testing features in release-1.11.0

[ https://issues.apache.org/jira/browse/FLINK-18088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18088: - Priority: Critical (was: Blocker) > Umbrella for testing features in release-1.11.0 >

[GitHub] [flink] zhijiangW commented on pull request #12510: [FLINK-18039]

zhijiangW commented on pull request #12510: URL: https://github.com/apache/flink/pull/12510#issuecomment-644543716 @becketqin FYI: this PR has conflicts now to be resolved. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #12655: [FLINK-18300][sql-client] SQL Client doesn't support ALTER VIEW

flinkbot edited a comment on pull request #12655: URL: https://github.com/apache/flink/pull/12655#issuecomment-644085772 ## CI report: * e9f9d2e5bd744d8443b78e9e3712bd718efa6b0d Azure:

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440597301 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -218,6 +230,67

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136307#comment-17136307 ] Yadong Xie edited comment on FLINK-18288 at 6/16/20, 5:28 AM: --

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136307#comment-17136307 ] Yadong Xie edited comment on FLINK-18288 at 6/16/20, 5:28 AM: --

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136307#comment-17136307 ] Yadong Xie edited comment on FLINK-18288 at 6/16/20, 5:27 AM: --

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136307#comment-17136307 ] Yadong Xie edited comment on FLINK-18288 at 6/16/20, 5:25 AM: --

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136307#comment-17136307 ] Yadong Xie edited comment on FLINK-18288 at 6/16/20, 5:24 AM: --

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136307#comment-17136307 ] Yadong Xie edited comment on FLINK-18288 at 6/16/20, 5:21 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #12661: [FLINK-18299][Formats(Json)]Add option in json format to parse timestamp in different standard

flinkbot edited a comment on pull request #12661: URL: https://github.com/apache/flink/pull/12661#issuecomment-644211738 ## CI report: * c1314ccf8e399484f78f3cea57d0229cb6a5d79b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12665: [FLINK-17886][docs-zh] Update Chinese documentation for new Watermark…

flinkbot edited a comment on pull request #12665: URL: https://github.com/apache/flink/pull/12665#issuecomment-644514775 ## CI report: * 539b338979344b960cbed6ab152eb32c117e121c Azure:

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136307#comment-17136307 ] Yadong Xie edited comment on FLINK-18288 at 6/16/20, 5:19 AM: --

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136307#comment-17136307 ] Yadong Xie edited comment on FLINK-18288 at 6/16/20, 5:19 AM: --

[GitHub] [flink] JingsongLi commented on pull request #12655: [FLINK-18300][sql-client] SQL Client doesn't support ALTER VIEW

JingsongLi commented on pull request #12655: URL: https://github.com/apache/flink/pull/12655#issuecomment-644536811 Can you re-trigger azure testing? This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136307#comment-17136307 ] Yadong Xie commented on FLINK-18288: [~appleyuchi] plz note that : #

[GitHub] [flink] JingsongLi commented on a change in pull request #12651: [FLINK-18272][table-runtime-blink] Add retry logic to FileSystemLooku…

JingsongLi commented on a change in pull request #12651: URL: https://github.com/apache/flink/pull/12651#discussion_r440590714 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemLookupFunction.java ## @@ -143,26

[GitHub] [flink] JingsongLi commented on a change in pull request #12651: [FLINK-18272][table-runtime-blink] Add retry logic to FileSystemLooku…

JingsongLi commented on a change in pull request #12651: URL: https://github.com/apache/flink/pull/12651#discussion_r440590313 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemLookupFunction.java ## @@ -59,6 +59,11

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * f5939316d96975bea8e80acb52bc17683087 UNKNOWN * 1253ab0db340f4d3aac238a3c2bc8f8f4abb6941 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

flinkbot edited a comment on pull request #12313: URL: https://github.com/apache/flink/pull/12313#issuecomment-633389597 ## CI report: * 05c952fdab2c5cf05b70fa26bd7049a827d06149 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

flinkbot edited a comment on pull request #12657: URL: https://github.com/apache/flink/pull/12657#issuecomment-644140243 ## CI report: * 14cdb5d641588f9dfa7f8536fe92e3e57abd8e14 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * f5939316d96975bea8e80acb52bc17683087 UNKNOWN * 1253ab0db340f4d3aac238a3c2bc8f8f4abb6941 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12656: [FLINK-17666][table-planner-blink] Insert into partitioned table can …

flinkbot edited a comment on pull request #12656: URL: https://github.com/apache/flink/pull/12656#issuecomment-644099955 ## CI report: * e35de4a21f5cf007341a71a1461b796b286c9948 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12642: [FLINK-18282][docs-zh] retranslate the documentation home page

flinkbot edited a comment on pull request #12642: URL: https://github.com/apache/flink/pull/12642#issuecomment-643624564 ## CI report: * d13e1778d93d1aa4f365057bda967ed708555962 Azure:

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440582367 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -218,6 +230,67

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440581662 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -218,6 +230,67

[jira] [Commented] (FLINK-18242) Custom OptionsFactory settings seem to have no effect on RocksDB

[ https://issues.apache.org/jira/browse/FLINK-18242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136294#comment-17136294 ] Yu Li commented on FLINK-18242: --- bq. For 1.11 / 1.12 what do you think about dropping the OptionsFactory

[jira] [Created] (FLINK-18316) Add a dynamic state registration primitive for Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-18316: --- Summary: Add a dynamic state registration primitive for Stateful Functions Key: FLINK-18316 URL: https://issues.apache.org/jira/browse/FLINK-18316

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440578921 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -218,6 +230,67

[GitHub] [flink] sdlcwangsong commented on a change in pull request #12642: [FLINK-18282][docs-zh] retranslate the documentation home page

sdlcwangsong commented on a change in pull request #12642: URL: https://github.com/apache/flink/pull/12642#discussion_r440578667 ## File path: docs/index.zh.md ## @@ -23,53 +23,71 @@ specific language governing permissions and limitations under the License. --> + +Apache

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440578551 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -218,6 +230,67

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135831#comment-17135831 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 4:24 AM: -- runtime-web

[GitHub] [flink] flinkbot edited a comment on pull request #12656: [FLINK-17666][table-planner-blink] Insert into partitioned table can …

flinkbot edited a comment on pull request #12656: URL: https://github.com/apache/flink/pull/12656#issuecomment-644099955 ## CI report: * e35de4a21f5cf007341a71a1461b796b286c9948 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12661: [FLINK-18299][Formats(Json)]Add option in json format to parse timestamp in different standard

flinkbot edited a comment on pull request #12661: URL: https://github.com/apache/flink/pull/12661#issuecomment-644211738 ## CI report: * 204bbb584e74633c7cd82fb0358e5570d5d74563 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

flinkbot edited a comment on pull request #12657: URL: https://github.com/apache/flink/pull/12657#issuecomment-644140243 ## CI report: * 14cdb5d641588f9dfa7f8536fe92e3e57abd8e14 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12665: [FLINK-17886][docs-zh] Update Chinese documentation for new Watermark…

flinkbot edited a comment on pull request #12665: URL: https://github.com/apache/flink/pull/12665#issuecomment-644514775 ## CI report: * 539b338979344b960cbed6ab152eb32c117e121c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12642: [FLINK-18282][docs-zh] retranslate the documentation home page

flinkbot edited a comment on pull request #12642: URL: https://github.com/apache/flink/pull/12642#issuecomment-643624564 ## CI report: * d13e1778d93d1aa4f365057bda967ed708555962 Azure:

[GitHub] [flink] JingsongLi commented on pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

JingsongLi commented on pull request #12657: URL: https://github.com/apache/flink/pull/12657#issuecomment-644522570 50108ca39ff114f9c85ae5f2b5cc72eb3dd4357a Looks good to me. This is an automated message from the Apache Git

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136281#comment-17136281 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 4:22 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

flinkbot edited a comment on pull request #12313: URL: https://github.com/apache/flink/pull/12313#issuecomment-633389597 ## CI report: * 05c952fdab2c5cf05b70fa26bd7049a827d06149 Azure:

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136281#comment-17136281 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 4:21 AM: --

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136281#comment-17136281 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 4:21 AM: --

[jira] [Commented] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136281#comment-17136281 ] appleyuchi commented on FLINK-18288: *---some

[jira] [Closed] (FLINK-18268) Correct Table API in Temporal table docs

[ https://issues.apache.org/jira/browse/FLINK-18268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18268. Resolution: Fixed master: fea20adef1ab5f722e418c1a89600e0786208469 release-1.11: 

[GitHub] [flink] JingsongLi merged pull request #12630: [FLINK-18268][docs] Correct Table API in Temporal table docs

JingsongLi merged pull request #12630: URL: https://github.com/apache/flink/pull/12630 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

[jira] [Assigned] (FLINK-18315) Insert into partitioned table can fail with values

[ https://issues.apache.org/jira/browse/FLINK-18315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-18315: Assignee: Danny Chen > Insert into partitioned table can fail with values >

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135831#comment-17135831 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 4:11 AM: -- runtime-web

[GitHub] [flink] klion26 commented on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

klion26 commented on pull request #12313: URL: https://github.com/apache/flink/pull/12313#issuecomment-644519136 @yangyichao-mango thanks for the work, could you please use `git rebase` instead of `git merge` to resolve the conflict.

[jira] [Commented] (FLINK-18288) WEB UI failure in Flink1.12

[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136274#comment-17136274 ] Yang Wang commented on FLINK-18288: --- I am not familiar with npm. cc [~vthinkxie], could you please

[jira] [Created] (FLINK-18315) Insert into partitioned table can fail with values

Danny Chen created FLINK-18315: -- Summary: Insert into partitioned table can fail with values Key: FLINK-18315 URL: https://issues.apache.org/jira/browse/FLINK-18315 Project: Flink Issue Type:

[GitHub] [flink] JingsongLi commented on a change in pull request #12630: [FLINK-18268][docs] Correct Table API in Temporal table docs

JingsongLi commented on a change in pull request #12630: URL: https://github.com/apache/flink/pull/12630#discussion_r440572767 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -260,32 +260,45 @@ See also the page about [joins for continuous queries](joins.html)

[GitHub] [flink] JingsongLi commented on a change in pull request #12630: [FLINK-18268][docs] Correct Table API in Temporal table docs

JingsongLi commented on a change in pull request #12630: URL: https://github.com/apache/flink/pull/12630#discussion_r440572767 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -260,32 +260,45 @@ See also the page about [joins for continuous queries](joins.html)

[GitHub] [flink] DashShen edited a comment on pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

DashShen edited a comment on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-644514878 @wuchong Sorry, due to my personal physical reasons, I don't have enough time to finish this work recently.You can assign others to finish this. I'll be involved in

[GitHub] [flink] DashShen edited a comment on pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

DashShen edited a comment on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-644514878 @wuchong Sorry, due to my personal physical reasons, I don't have enough time to finish this work recently.You can assignee others to finish this. I'll be involved in

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440570913 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -218,6 +230,67

[GitHub] [flink] godfreyhe commented on a change in pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

godfreyhe commented on a change in pull request #12657: URL: https://github.com/apache/flink/pull/12657#discussion_r440569344 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java ## @@ -462,7 +462,7 @@ public

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440570454 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -218,6 +230,67

[GitHub] [flink] DashShen commented on pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

DashShen commented on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-644514878 @wuchong Sorry, due to my personal physical reasons, I don't have enough time to finish this work recently.You can assignee others to finish this.

[GitHub] [flink] flinkbot edited a comment on pull request #12661: [FLINK-18299][Formats(Json)]Add option in json format to parse timestamp in different standard

flinkbot edited a comment on pull request #12661: URL: https://github.com/apache/flink/pull/12661#issuecomment-644211738 ## CI report: * 204bbb584e74633c7cd82fb0358e5570d5d74563 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12663: [hotfix][docs] Using a savepoint prevents data loss

flinkbot edited a comment on pull request #12663: URL: https://github.com/apache/flink/pull/12663#issuecomment-644317639 ## CI report: * babfbece617757adcd5f1c424610d6a83937d549 Azure:

[GitHub] [flink] flinkbot commented on pull request #12665: [FLINK-17886][docs-zh] Update Chinese documentation for new Watermark…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12630: [FLINK-18268][docs] Correct Table API in Temporal table docs

flinkbot edited a comment on pull request #12630: URL: https://github.com/apache/flink/pull/12630#issuecomment-643173834 ## CI report: * 535ba0fc8ca6ea67ded71fd9a80a24762b381a88 Azure:

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440569809 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -218,6 +230,67

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440569953 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -218,6 +230,67

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * f5939316d96975bea8e80acb52bc17683087 UNKNOWN * 1253ab0db340f4d3aac238a3c2bc8f8f4abb6941 Azure:

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440569676 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -218,6 +230,67

[GitHub] [flink] yangyichao-mango commented on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

yangyichao-mango commented on pull request #12313: URL: https://github.com/apache/flink/pull/12313#issuecomment-644513011 > @yangyichao-mango Seems there are some conflicts need to be resolved, could you please rebase the new master to resolve them? Thx a lot. I've resolved those

[GitHub] [flink] zhijiangW commented on a change in pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

zhijiangW commented on a change in pull request #12664: URL: https://github.com/apache/flink/pull/12664#discussion_r440568203 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -275,7 +277,7 @@

[GitHub] [flink] flinkbot commented on pull request #12665: [FLINK-17886][docs-zh] Update Chinese documentation for new Watermark…

flinkbot commented on pull request #12665: URL: https://github.com/apache/flink/pull/12665#issuecomment-644512331 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] libenchao commented on a change in pull request #12642: [FLINK-18282][docs-zh] retranslate the documentation home page

libenchao commented on a change in pull request #12642: URL: https://github.com/apache/flink/pull/12642#discussion_r440568132 ## File path: docs/index.zh.md ## @@ -23,53 +23,71 @@ specific language governing permissions and limitations under the License. --> + +Apache

[jira] [Updated] (FLINK-17886) Update Chinese documentation for new WatermarkGenerator/WatermarkStrategies

[ https://issues.apache.org/jira/browse/FLINK-17886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17886: --- Labels: pull-request-available (was: ) > Update Chinese documentation for new

[GitHub] [flink] yangyichao-mango opened a new pull request #12665: [FLINK-17886][docs-zh] Update Chinese documentation for new Watermark…

yangyichao-mango opened a new pull request #12665: URL: https://github.com/apache/flink/pull/12665 ## What is the purpose of the change *Update Chinese documentation for new WatermarkGenerator/WatermarkStrategies* ## Brief change log - *Update Chinese

[GitHub] [flink] danny0405 commented on a change in pull request #12632: [FLINK-18134][FLINK-18135][docs] Add documentation for Debezium and Canal formats

danny0405 commented on a change in pull request #12632: URL: https://github.com/apache/flink/pull/12632#discussion_r440564919 ## File path: docs/dev/table/connectors/formats/canal.md ## @@ -0,0 +1,175 @@ +--- +title: "Canal Format" +nav-title: Canal +nav-parent_id: sql-formats

[GitHub] [flink] jiasheng55 closed pull request #12359: [FLINK-15448][yarn] Add host and port info to yarn ResourceID

jiasheng55 closed pull request #12359: URL: https://github.com/apache/flink/pull/12359 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] leonardBang commented on a change in pull request #12630: [FLINK-18268][docs] Correct Table API in Temporal table docs

leonardBang commented on a change in pull request #12630: URL: https://github.com/apache/flink/pull/12630#discussion_r440563526 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -260,32 +260,43 @@ See also the page about [joins for continuous

[jira] [Reopened] (FLINK-18314) There are some problems in docs

[ https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinxin reopened FLINK-18314: sorry ,i change the wrong state . i mean it's not fixed now    > There are some problems in docs >

[jira] [Resolved] (FLINK-18314) There are some problems in docs

[ https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinxin resolved FLINK-18314. Resolution: Fixed > There are some problems in docs > --- > >

[jira] [Updated] (FLINK-18314) There are some problems in docs

[ https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinxin updated FLINK-18314: --- Affects Version/s: 1.12.0 > There are some problems in docs > --- > >

[jira] [Updated] (FLINK-18314) There are some problems in docs

[ https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinxin updated FLINK-18314: --- Description: In this page 

[jira] [Created] (FLINK-18314) There are some problems in docs

jinxin created FLINK-18314: -- Summary: There are some problems in docs Key: FLINK-18314 URL: https://issues.apache.org/jira/browse/FLINK-18314 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-18312) SavepointStatusHandler and StaticFileServerHandler not redirect

[ https://issues.apache.org/jira/browse/FLINK-18312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136258#comment-17136258 ] Yu Wang commented on FLINK-18312: - I think there seems a issue in

[jira] [Created] (FLINK-18312) SavepointStatusHandler and StaticFileServerHandler not redirect

Yu Wang created FLINK-18312: --- Summary: SavepointStatusHandler and StaticFileServerHandler not redirect Key: FLINK-18312 URL: https://issues.apache.org/jira/browse/FLINK-18312 Project: Flink

[jira] [Created] (FLINK-18313) Hive dialect doc should mention that views created in Flink cannot be used in Hive

Rui Li created FLINK-18313: -- Summary: Hive dialect doc should mention that views created in Flink cannot be used in Hive Key: FLINK-18313 URL: https://issues.apache.org/jira/browse/FLINK-18313 Project:

[GitHub] [flink] prosscode commented on pull request #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance"

prosscode commented on pull request #7820: URL: https://github.com/apache/flink/pull/7820#issuecomment-644503913 Encountered this problem, has been resolved according to your modified codes. Follow @Draczech description, we can improve this parameter **randomJobNameSuffix**, if is

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * f5939316d96975bea8e80acb52bc17683087 UNKNOWN * 1253ab0db340f4d3aac238a3c2bc8f8f4abb6941 Azure:

[GitHub] [flink] libenchao commented on a change in pull request #12642: [FLINK-18282][docs-zh] retranslate the documentation home page

libenchao commented on a change in pull request #12642: URL: https://github.com/apache/flink/pull/12642#discussion_r440557123 ## File path: docs/index.zh.md ## @@ -23,53 +23,71 @@ specific language governing permissions and limitations under the License. --> + +Apache

[GitHub] [flink] zhuzhurk removed a comment on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

zhuzhurk removed a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-644476328 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #12656: [FLINK-17666][table-planner-blink] Insert into partitioned table can …

flinkbot edited a comment on pull request #12656: URL: https://github.com/apache/flink/pull/12656#issuecomment-644099955 ## CI report: * e35de4a21f5cf007341a71a1461b796b286c9948 Azure:

[jira] [Commented] (FLINK-18236) flink elasticsearch IT test ElasticsearchSinkTestBase.runElasticsearchSink* verify it not right

[ https://issues.apache.org/jira/browse/FLINK-18236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136245#comment-17136245 ] jackylau commented on FLINK-18236: -- hi [~dwysakowicz] , could you please also review this issue and PR?

[jira] [Updated] (FLINK-18311) StreamingKafkaITCase stalls indefinitely

[ https://issues.apache.org/jira/browse/FLINK-18311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18311: Labels: test-stability (was: ) > StreamingKafkaITCase stalls indefinitely >

[jira] [Comment Edited] (FLINK-18311) StreamingKafkaITCase stalls indefinitely

[ https://issues.apache.org/jira/browse/FLINK-18311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136236#comment-17136236 ] Dian Fu edited comment on FLINK-18311 at 6/16/20, 2:27 AM: --- It seems caused by

[GitHub] [flink] flinkbot edited a comment on pull request #12656: [FLINK-17666][table-planner-blink] Insert into partitioned table can …

flinkbot edited a comment on pull request #12656: URL: https://github.com/apache/flink/pull/12656#issuecomment-644099955 ## CI report: * e35de4a21f5cf007341a71a1461b796b286c9948 Azure:

[GitHub] [flink] sdlcwangsong commented on pull request #12642: [FLINK-18282][docs-zh] retranslate the documentation home page

sdlcwangsong commented on pull request #12642: URL: https://github.com/apache/flink/pull/12642#issuecomment-644491027 hi, @libenchao, I have finish it This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] leonardBang commented on a change in pull request #12632: [FLINK-18134][FLINK-18135][docs] Add documentation for Debezium and Canal formats

leonardBang commented on a change in pull request #12632: URL: https://github.com/apache/flink/pull/12632#discussion_r440548891 ## File path: docs/dev/table/connectors/formats/canal.zh.md ## @@ -0,0 +1,175 @@ +--- +title: "Canal Format" +nav-title: Canal +nav-parent_id:

[jira] [Commented] (FLINK-18303) Filesystem connector doesn't flush part files after rolling interval

[ https://issues.apache.org/jira/browse/FLINK-18303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136241#comment-17136241 ] Jingsong Lee commented on FLINK-18303: -- First, I don't think this is a technical bug, but it can be

[GitHub] [flink] prosscode removed a comment on pull request #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance"

prosscode removed a comment on pull request #7820: URL: https://github.com/apache/flink/pull/7820#issuecomment-644485100 Encountered this problem, has been resolved according to your modified codes, thanks. This is an

[jira] [Closed] (FLINK-18261) flink-orc and flink-parquet have invalid NOTICE file

[ https://issues.apache.org/jira/browse/FLINK-18261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18261. Resolution: Fixed master: 6388336b0c56589c3a77e38f8fd16f582e2d947c release-1.11: 

[jira] [Updated] (FLINK-18311) StreamingKafkaITCase stalls indefinitely

[ https://issues.apache.org/jira/browse/FLINK-18311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18311: Fix Version/s: 1.11.0 > StreamingKafkaITCase stalls indefinitely >

[jira] [Commented] (FLINK-18311) StreamingKafkaITCase stalls indefinitely

[ https://issues.apache.org/jira/browse/FLINK-18311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136236#comment-17136236 ] Dian Fu commented on FLINK-18311: - It seems caused by the change: 

  1   2   3   4   5   6   7   >