[GitHub] [flink] flinkbot edited a comment on pull request #13488: [FLINK-19381][docs] Fix docs for savepoint relocation

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #13488: URL: https://github.com/apache/flink/pull/13488#issuecomment-699590439 ## CI report: * 3b8d5db8e7a5799df55ba6ce17a197e0fa01fe67 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14199: [FLINK-20118][file connector] Extend FileSourceTextLinesITCase with JM/TM failover tests

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #14199: URL: https://github.com/apache/flink/pull/14199#issuecomment-732845197 ## CI report: * 6ffe3e161a8ec42b7ce5da3c46b57587d98a1f90 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rmetzger commented on pull request #14237: [FLINK-20381][yarn] Replace -id by -yid

2020-11-30 Thread GitBox
rmetzger commented on pull request #14237: URL: https://github.com/apache/flink/pull/14237#issuecomment-735625226 Thanks a lot for your review. I will open a new PR restoring the behavior. This is an automated message from th

[GitHub] [flink] rmetzger closed pull request #14237: [FLINK-20381][yarn] Replace -id by -yid

2020-11-30 Thread GitBox
rmetzger closed pull request #14237: URL: https://github.com/apache/flink/pull/14237 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

[jira] [Commented] (FLINK-20392) Migrating bash e2e tests to Java/Docker

2020-11-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240549#comment-17240549 ] Yang Wang commented on FLINK-20392: --- [~mapohl] Thanks for creating this umbrella ticke

[jira] [Commented] (FLINK-20410) SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401"

2020-11-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240551#comment-17240551 ] Dawid Wysakowicz commented on FLINK-20410: -- I will look into it > SQLClientSch

[jira] [Assigned] (FLINK-20410) SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401"

2020-11-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-20410: Assignee: Dawid Wysakowicz > SQLClientSchemaRegistryITCase.testWriting failed wit

[GitHub] [flink] flinkbot edited a comment on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 693e48ac1e9cd413f54e7cbc4c46b9ae190ce848 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dawidwys closed pull request #14249: [FLINK-20391] Set FORWARD_EDGES_PIPELINED for BATCH ExecutionMode

2020-11-30 Thread GitBox
dawidwys closed pull request #14249: URL: https://github.com/apache/flink/pull/14249 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

[jira] [Closed] (FLINK-20391) Set FORWARD_EDGES_PIPELINED for BATCH ExecutionMode

2020-11-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-20391. Resolution: Implemented Implemented in ffb538b171cae299cb9a7b4e078ad9482f9493b8 > Set FOR

[GitHub] [flink] flinkbot edited a comment on pull request #14199: [FLINK-20118][file connector] Extend FileSourceTextLinesITCase with JM/TM failover tests

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #14199: URL: https://github.com/apache/flink/pull/14199#issuecomment-732845197 ## CI report: * 6ffe3e161a8ec42b7ce5da3c46b57587d98a1f90 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #14238: URL: https://github.com/apache/flink/pull/14238#issuecomment-734336545 ## CI report: * 5b9ca356af610ffa7faf50a88372a5e22f7c7185 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] sebastianliu opened a new pull request #14260: [FLINK-20416][flink-table-api-java] Add Generic Cached Catalog

2020-11-30 Thread GitBox
sebastianliu opened a new pull request #14260: URL: https://github.com/apache/flink/pull/14260 ## What is the purpose of the change *This pull request add a generic cached catalog which can delegate other catalog implementations of `AbstractCatalog`. With this generic cached

[jira] [Created] (FLINK-20416) Need a cached catalog for batch SQL job

2020-11-30 Thread Sebastian Liu (Jira)
Sebastian Liu created FLINK-20416: - Summary: Need a cached catalog for batch SQL job Key: FLINK-20416 URL: https://issues.apache.org/jira/browse/FLINK-20416 Project: Flink Issue Type: Improve

[jira] [Updated] (FLINK-20416) Need a cached catalog for batch SQL job

2020-11-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20416: --- Labels: pull-request-available (was: ) > Need a cached catalog for batch SQL job >

[GitHub] [flink] flinkbot commented on pull request #14260: [FLINK-20416][flink-table-api-java] Add Generic Cached Catalog

2020-11-30 Thread GitBox
flinkbot commented on pull request #14260: URL: https://github.com/apache/flink/pull/14260#issuecomment-735642290 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 pro

[jira] [Updated] (FLINK-20416) Need a cached catalog for batch SQL job

2020-11-30 Thread Sebastian Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Liu updated FLINK-20416: -- Description: For OLAP scenarios, There are usually some analytical queries which running time

[jira] [Updated] (FLINK-20416) Need a cached catalog for batch SQL job

2020-11-30 Thread Sebastian Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Liu updated FLINK-20416: -- Description: For OLAP scenarios, There are usually some analytical queries which running time

[GitHub] [flink] flinkbot edited a comment on pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #14238: URL: https://github.com/apache/flink/pull/14238#issuecomment-734336545 ## CI report: * 5b9ca356af610ffa7faf50a88372a5e22f7c7185 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20195) Jobs endpoint returns duplicated jobs

2020-11-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240567#comment-17240567 ] Till Rohrmann commented on FLINK-20195: --- I think in the current master, it should

[jira] [Updated] (FLINK-20415) Parsed QueryOperation does not contain watermark in schema

2020-11-30 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-20415: - Affects Version/s: 1.12.0 > Parsed QueryOperation does not contain watermark in schema >

[jira] [Commented] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

2020-11-30 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240568#comment-17240568 ] Etienne Chauchot commented on FLINK-18685: -- Hi [~rmetzger] I'd like to take thi

[jira] [Created] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

2020-11-30 Thread Yang Wang (Jira)
Yang Wang created FLINK-20417: - Summary: Handle "Too old resource version" exception in Kubernetes watch more gracefully Key: FLINK-20417 URL: https://issues.apache.org/jira/browse/FLINK-20417 Project: Fl

[GitHub] [flink] tillrohrmann commented on a change in pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14238: URL: https://github.com/apache/flink/pull/14238#discussion_r532436860 ## File path: docs/deployment/index.zh.md ## @@ -25,47 +25,158 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] V1ncentzzZ commented on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-11-30 Thread GitBox
V1ncentzzZ commented on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-735654270 Hi @wuchong @godfreyhe , Could you review it again? This is an automated message from the Apache Git Service.

[GitHub] [flink] tillrohrmann commented on pull request #14251: [FLINK-20382][runtime] Fail hard when JobMaster cannot start scheduling of a job

2020-11-30 Thread GitBox
tillrohrmann commented on pull request #14251: URL: https://github.com/apache/flink/pull/14251#issuecomment-735655797 Thanks for the review @rmetzger. Merging this PR now. This is an automated message from the Apache Git Serv

[jira] [Commented] (FLINK-20375) Add a switch to control the operator name in SQL

2020-11-30 Thread Mulan Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240581#comment-17240581 ] Mulan Wong commented on FLINK-20375: TaskMetricGroup#METRICS_OPERATOR_NAME_MAX_LENGT

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * 6e7748ddea8ff84587d15a1c8050b14b51cf1fcb Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-20375) Add a switch to control the operator name in SQL

2020-11-30 Thread Mulan Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240581#comment-17240581 ] Mulan Wong edited comment on FLINK-20375 at 11/30/20, 9:08 AM: ---

[GitHub] [flink] wuchong commented on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-11-30 Thread GitBox
wuchong commented on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-735656640 Sure @V1ncentzzZ . I will have a look this PR tomorrow. This is an automated message from the Apache Git Servic

[jira] [Created] (FLINK-20418) NPE in IteratorSourceReader

2020-11-30 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-20418: - Summary: NPE in IteratorSourceReader Key: FLINK-20418 URL: https://issues.apache.org/jira/browse/FLINK-20418 Project: Flink Issue Type: Bug

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-11-30 Thread GitBox
zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r532444044 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ## @@ -917,15 +917,15 @@ private void resetAndStartScheduler

[jira] [Updated] (FLINK-20418) NPE in IteratorSourceReader

2020-11-30 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20418: -- Description: With the following job {code} @Test public void testNpe()

[GitHub] [flink] flinkbot commented on pull request #14260: [FLINK-20416][flink-table-api-java] Add Generic Cached Catalog

2020-11-30 Thread GitBox
flinkbot commented on pull request #14260: URL: https://github.com/apache/flink/pull/14260#issuecomment-735661396 ## CI report: * 99500326953b4a98c0646353e4681124dff9ebf1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] tillrohrmann closed pull request #14251: [FLINK-20382][runtime] Fail hard when JobMaster cannot start scheduling of a job

2020-11-30 Thread GitBox
tillrohrmann closed pull request #14251: URL: https://github.com/apache/flink/pull/14251 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 g

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-11-30 Thread GitBox
zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r532450806 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskManagerLocation.java ## @@ -256,7 +256,7 @@ public boolean equals(Obj

[GitHub] [flink] azagrebin edited a comment on pull request #14199: [FLINK-20118][file connector] Extend FileSourceTextLinesITCase with JM/TM failover tests

2020-11-30 Thread GitBox
azagrebin edited a comment on pull request #14199: URL: https://github.com/apache/flink/pull/14199#issuecomment-735617972 Thanks for the review @StephanEwen I addressed comments, the commits can be also just merged into one before merge. ---

[GitHub] [flink] tillrohrmann closed pull request #14252: [BP-1.12][FLINK-20382][runtime] Fail hard when JobMaster cannot start scheduling of a job

2020-11-30 Thread GitBox
tillrohrmann closed pull request #14252: URL: https://github.com/apache/flink/pull/14252 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 g

[GitHub] [flink] tillrohrmann commented on pull request #14252: [BP-1.12][FLINK-20382][runtime] Fail hard when JobMaster cannot start scheduling of a job

2020-11-30 Thread GitBox
tillrohrmann commented on pull request #14252: URL: https://github.com/apache/flink/pull/14252#issuecomment-735666099 Manually merged via c5188a1b36953c3cfb889c5866c4835cc3b5dcb5 This is an automated message from the Apache G

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-11-30 Thread GitBox
zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r532454865 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionTest.java ## @@ -361,11 +168,7 @@ public void testTaskRestore

[GitHub] [flink] tillrohrmann commented on pull request #14253: [BP-1.11][FLINK-20382][runtime] Fail hard when JobMaster cannot start scheduling of a job

2020-11-30 Thread GitBox
tillrohrmann commented on pull request #14253: URL: https://github.com/apache/flink/pull/14253#issuecomment-735668025 Manually merged via dfa13d8b75ead9ce60ae982b469f70943ad69d35 This is an automated message from the Apache G

[GitHub] [flink] tillrohrmann closed pull request #14253: [BP-1.11][FLINK-20382][runtime] Fail hard when JobMaster cannot start scheduling of a job

2020-11-30 Thread GitBox
tillrohrmann closed pull request #14253: URL: https://github.com/apache/flink/pull/14253 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 g

[jira] [Closed] (FLINK-20382) Exception thrown from JobMaster.startScheduling() may be ignored.

2020-11-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-20382. - Resolution: Fixed Fixed via master: f8e56226550f8fa1620b4650d83edc1993e210b8 1.12.0: c5188a1b36

[GitHub] [flink] tillrohrmann commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532455932 ## File path: docs/deployment/ha/kubernetes_ha.md ## @@ -23,77 +23,50 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] tillrohrmann commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532458768 ## File path: docs/deployment/ha/kubernetes_ha.md ## @@ -23,77 +23,50 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #14260: [FLINK-20416][flink-table-api-java] Add Generic Cached Catalog

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #14260: URL: https://github.com/apache/flink/pull/14260#issuecomment-735661396 ## CI report: * 99500326953b4a98c0646353e4681124dff9ebf1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-11-30 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240605#comment-17240605 ] Matthias commented on FLINK-20389: -- [~trohrm...@apache.org] and I investigated the issu

[jira] [Resolved] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-11-30 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias resolved FLINK-20389. -- Resolution: Fixed The issue is considered to be closed. The findings are documented in the comments a

[jira] [Comment Edited] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-11-30 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240605#comment-17240605 ] Matthias edited comment on FLINK-20389 at 11/30/20, 9:41 AM: -

[jira] [Assigned] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-11-30 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-19249: --- Assignee: Yuan Mei > Detect broken connections in case TCP Timeout takes too long. > --

[GitHub] [flink] tillrohrmann commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532461810 ## File path: docs/deployment/ha/kubernetes_ha.md ## @@ -2,7 +2,7 @@ title: "Kubernetes HA Services" nav-title: Kubernetes HA Services nav-parent_

[jira] [Updated] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-11-30 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20389: - Attachment: FLINK-20389-failure.log > UnalignedCheckpointITCase failure caused by NullPointerException >

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-11-30 Thread GitBox
zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r532462500 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphVariousFailuesTest.java ## @@ -20,86 +20,31 @@ import

[GitHub] [flink] tillrohrmann commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532462548 ## File path: docs/deployment/resource-providers/standalone/kubernetes.md ## @@ -162,6 +162,34 @@ with the `kubectl` command: kubectl delete -f

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-11-30 Thread GitBox
zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r532462500 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphVariousFailuesTest.java ## @@ -20,86 +20,31 @@ import

[GitHub] [flink] tillrohrmann commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532463633 ## File path: docs/deployment/ha/zookeeper_ha.md ## @@ -23,113 +23,104 @@ specific language governing permissions and limitations under the License.

[jira] [Updated] (FLINK-20419) Insert fails due to failure to generate execution plan

2020-11-30 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-20419: --- Priority: Critical (was: Major) > Insert fails due to failure to generate execution plan >

[jira] [Created] (FLINK-20419) Insert fails due to failure to generate execution plan

2020-11-30 Thread Rui Li (Jira)
Rui Li created FLINK-20419: -- Summary: Insert fails due to failure to generate execution plan Key: FLINK-20419 URL: https://issues.apache.org/jira/browse/FLINK-20419 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20419) Insert fails due to failure to generate execution plan

2020-11-30 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240611#comment-17240611 ] Rui Li commented on FLINK-20419: Detailed failure is: {noformat} org.apache.flink.table.

[GitHub] [flink] tillrohrmann commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532464322 ## File path: docs/deployment/ha/zookeeper_ha.md ## @@ -23,113 +23,104 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] tillrohrmann commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532465124 ## File path: docs/deployment/ha/kubernetes_ha.md ## @@ -23,77 +23,50 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] tillrohrmann commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532465329 ## File path: docs/deployment/ha/zookeeper_ha.md ## @@ -23,113 +23,104 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] tillrohrmann commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532466031 ## File path: docs/deployment/ha/zookeeper_ha.md ## @@ -23,113 +23,104 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] tillrohrmann commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532466578 ## File path: docs/deployment/ha/zookeeper_ha.zh.md ## @@ -23,113 +23,105 @@ specific language governing permissions and limitations under the Licen

[GitHub] [flink] tillrohrmann commented on pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
tillrohrmann commented on pull request #14254: URL: https://github.com/apache/flink/pull/14254#issuecomment-735681748 Thanks for your review @rmetzger and @wangyang0918. I've addressed your comments and resolved the merge conflict. -

[jira] [Commented] (FLINK-20418) NPE in IteratorSourceReader

2020-11-30 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240617#comment-17240617 ] Yuan Mei commented on FLINK-20418: -- with the default setting, I get the same exception:

[jira] [Commented] (FLINK-20418) NPE in IteratorSourceReader

2020-11-30 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240621#comment-17240621 ] Yuan Mei commented on FLINK-20418: -- change the sleep time to 50, get the same error:  

[jira] [Comment Edited] (FLINK-18726) Support INSERT INTO specific columns

2020-11-30 Thread silence (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240620#comment-17240620 ] silence edited comment on FLINK-18726 at 11/30/20, 9:59 AM:

[jira] [Commented] (FLINK-18726) Support INSERT INTO specific columns

2020-11-30 Thread silence (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240620#comment-17240620 ] silence commented on FLINK-18726: - [~atri] 我们迫切的需要此能力,期待您的任何进展 > Support INSERT INTO sp

[GitHub] [flink] tillrohrmann commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r532473677 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphVariousFailuesTest.java ## @@ -20,86 +20,31 @@ im

[GitHub] [flink] tillrohrmann commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-11-30 Thread GitBox
tillrohrmann commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r532473677 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphVariousFailuesTest.java ## @@ -20,86 +20,31 @@ im

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-11-30 Thread GitBox
zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r532479406 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphNotEnoughResourceTest.java ## @@ -113,29 +119,28 @@ publ

[GitHub] [flink] wangyang0918 commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
wangyang0918 commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532482080 ## File path: docs/_includes/generated/kubernetes_config_configuration.html ## @@ -18,7 +18,7 @@ kubernetes.cluster-id (non

[jira] [Created] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

2020-11-30 Thread Yun Tang (Jira)
Yun Tang created FLINK-20420: Summary: ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds Key: FLINK-20420 URL: https://issues.apache.org/jira/browse/FLINK-20420 Project: Flink

[GitHub] [flink] dawidwys commented on pull request #14235: [FLINK-20298][docs] Replace usage of {{ site.baseurl }} in documentation

2020-11-30 Thread GitBox
dawidwys commented on pull request #14235: URL: https://github.com/apache/flink/pull/14235#issuecomment-735692654 @Shawn-Hx I think that is fair. Could you please create corresponding JIRA issues so that we do not forget about it. I will review the current PR in the meantime. ---

[GitHub] [flink] azagrebin commented on a change in pull request #14256: [FLINK-20396][checkpointing] Add a 'subtaskReset()' method to the OperatorCoordinator.

2020-11-30 Thread GitBox
azagrebin commented on a change in pull request #14256: URL: https://github.com/apache/flink/pull/14256#discussion_r532437396 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/RecreateOnResetOperatorCoordinator.java ## @@ -366,12 +366,15

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * e7a4ae2ed2de185200b562bb882af275a49e972e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14248: [FLINK-20287][docs] Add documentation of how to switch memory allocator in Flink docker image

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #14248: URL: https://github.com/apache/flink/pull/14248#issuecomment-734771687 ## CI report: * 1e920d180c84789912d0b69b2d859467424ec7a9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #14254: URL: https://github.com/apache/flink/pull/14254#issuecomment-734942786 ## CI report: * 9f8f123a323372be3edd985c83d8af11528dec16 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] StephanEwen commented on pull request #14199: [FLINK-20118][file connector] Extend FileSourceTextLinesITCase with JM/TM failover tests

2020-11-30 Thread GitBox
StephanEwen commented on pull request #14199: URL: https://github.com/apache/flink/pull/14199#issuecomment-735697661 Thanks, @azagrebin. The test is really good, it helped uncover yet another issue during JM failover (race condition in the coordinator restore). --

[jira] [Created] (FLINK-20421) Support canal-protobuf format

2020-11-30 Thread Jark Wu (Jira)
Jark Wu created FLINK-20421: --- Summary: Support canal-protobuf format Key: FLINK-20421 URL: https://issues.apache.org/jira/browse/FLINK-20421 Project: Flink Issue Type: Sub-task Components

[GitHub] [flink] dawidwys opened a new pull request #14261: [FLINK-20410] Retry querying for schema in the schema registry e2e test.

2020-11-30 Thread GitBox
dawidwys opened a new pull request #14261: URL: https://github.com/apache/flink/pull/14261 ## What is the purpose of the change This PR aims at strengthening the E2E test. Submission of an `INSERT INTO` statement via sql-client is a non-blocking operation, therefore there is a s

[jira] [Updated] (FLINK-20410) SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401"

2020-11-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20410: --- Labels: pull-request-available test-stability (was: test-stability) > SQLClientSchemaRegist

[GitHub] [flink] flinkbot commented on pull request #14261: [FLINK-20410] Retry querying for schema in the schema registry e2e test.

2020-11-30 Thread GitBox
flinkbot commented on pull request #14261: URL: https://github.com/apache/flink/pull/14261#issuecomment-735705310 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #14254: URL: https://github.com/apache/flink/pull/14254#issuecomment-734942786 ## CI report: * 9f8f123a323372be3edd985c83d8af11528dec16 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14248: [FLINK-20287][docs] Add documentation of how to switch memory allocator in Flink docker image

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #14248: URL: https://github.com/apache/flink/pull/14248#issuecomment-734771687 ## CI report: * 1e920d180c84789912d0b69b2d859467424ec7a9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-20422) Remove {{ site.baseurl }} from .html files in flink documentation

2020-11-30 Thread Xiao Huang (Jira)
Xiao Huang created FLINK-20422: -- Summary: Remove {{ site.baseurl }} from .html files in flink documentation Key: FLINK-20422 URL: https://issues.apache.org/jira/browse/FLINK-20422 Project: Flink

[GitHub] [flink] Shawn-Hx commented on pull request #14235: [FLINK-20298][docs] Replace usage of {{ site.baseurl }} in documentation

2020-11-30 Thread GitBox
Shawn-Hx commented on pull request #14235: URL: https://github.com/apache/flink/pull/14235#issuecomment-735708730 Thanks @dawidwys I have created [FLINK-20422](https://issues.apache.org/jira/browse/FLINK-20422). Please take a look.

[jira] [Created] (FLINK-20423) Remove usage of {{site.baseurl}} from markdown files

2020-11-30 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20423: Summary: Remove usage of {{site.baseurl}} from markdown files Key: FLINK-20423 URL: https://issues.apache.org/jira/browse/FLINK-20423 Project: Flink

[jira] [Updated] (FLINK-20422) Remove {{ site.baseurl }} from .html files in flink documentation

2020-11-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20422: - Parent: FLINK-20298 Issue Type: Sub-task (was: Improvement) > Remove {{ site.ba

[jira] [Updated] (FLINK-20422) Remove {{ site.baseurl }} from .html files in flink documentation

2020-11-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20422: - Description: Remove the \{\{site.baseurl\}\} from .html files. E.g. {{_layouts/redirect

[GitHub] [flink] flinkbot edited a comment on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-723574143 ## CI report: * 0e851de8b2911475922422c569a1e28a065e37b6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14261: [FLINK-20410] Retry querying for schema in the schema registry e2e test.

2020-11-30 Thread GitBox
flinkbot commented on pull request #14261: URL: https://github.com/apache/flink/pull/14261#issuecomment-735720372 ## CI report: * d588be2d3c5c383035afeae9654b2af6f7414065 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-20195) Jobs endpoint returns duplicated jobs

2020-11-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240680#comment-17240680 ] Chesnay Schepler commented on FLINK-20195: -- Is there not a small window where t

[jira] [Updated] (FLINK-20424) The percent of acknowledged checkpoint seems incorrect

2020-11-30 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zlzhang0122 updated FLINK-20424: Description: As the picture below, the percent of acknowledged checkpoint seems incorrect.I think

[jira] [Created] (FLINK-20424) The percent of acknowledged checkpoint seems incorrect

2020-11-30 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-20424: --- Summary: The percent of acknowledged checkpoint seems incorrect Key: FLINK-20424 URL: https://issues.apache.org/jira/browse/FLINK-20424 Project: Flink Issue Ty

[GitHub] [flink] rmetzger commented on pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-11-30 Thread GitBox
rmetzger commented on pull request #14238: URL: https://github.com/apache/flink/pull/14238#issuecomment-735726060 Thanks a lot for your reviews! I'll merge the PR soon. This is an automated message from the Apache Git Service

[GitHub] [flink] flinkbot edited a comment on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2020-11-30 Thread GitBox
flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 46042bff26813c15199ebe6fc9a9d3c1dd4e5860 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-20375) Add a switch to control the operator name in SQL

2020-11-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240689#comment-17240689 ] Jark Wu commented on FLINK-20375: - [~gaoyunhaii], do you know about this? Is this on pur

[GitHub] [flink] rmetzger closed pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-11-30 Thread GitBox
rmetzger closed pull request #14238: URL: https://github.com/apache/flink/pull/14238 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

  1   2   3   4   >