[GitHub] [flink] jiasheng55 commented on a change in pull request #8396: [FLINK-12468][yarn] Unregister application from the YARN Resource Man…

jiasheng55 commented on a change in pull request #8396: [FLINK-12468][yarn] Unregister application from the YARN Resource Man… URL: https://github.com/apache/flink/pull/8396#discussion_r283084838 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigO

[jira] [Created] (FLINK-12491) Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS

Kezhu Wang created FLINK-12491: -- Summary: Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS Key: FLINK-12491 URL: https://issues.apache.org/jira/browse/FLINK-12491 Project: Fl

[jira] [Commented] (FLINK-12380) Add thread name in the log4j.properties

[ https://issues.apache.org/jira/browse/FLINK-12380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837766#comment-16837766 ] Yun Tang commented on FLINK-12380: -- [~azagrebin] If so why current [logbak.xml|https:/

[GitHub] [flink] Myasuka commented on issue #8328: [FLINK-12380] Add thread name in the log4j.properties

Myasuka commented on issue #8328: [FLINK-12380] Add thread name in the log4j.properties URL: https://github.com/apache/flink/pull/8328#issuecomment-491482568 @StephanEwen As you are the founder of Flink and the most-contributed coder, I believe and respect your choice. However, your rep

[GitHub] [flink] XuQianJin-Stars commented on issue #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

XuQianJin-Stars commented on issue #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#issuecomment-491482291 hi @wuchong Thank you very much，Comments addressed. -

[GitHub] [flink] godfreyhe commented on issue #8317: [FLINK-12371] [table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to semi-join/anti-join, and generating optimized logical plan

godfreyhe commented on issue #8317: [FLINK-12371] [table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to semi-join/anti-join, and generating optimized logical plan URL: https://github.com/apache/flink/pull/8317#issuecomment-491481206 @KurtYoung I have fixed the failed t

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r283083182 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r283082959 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r283082955 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r283082635 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r283082502 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r283082509 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[jira] [Commented] (FLINK-8513) Add documentation for connecting to non-AWS S3 endpoints

[ https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837692#comment-16837692 ] Stephan Ewen commented on FLINK-8513: - Fixed in {{master}} in 4dae94d952958858af722c6

[jira] [Commented] (FLINK-10249) Document hadoop/presto s3 file system configuration forwarding

[ https://issues.apache.org/jira/browse/FLINK-10249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837691#comment-16837691 ] Stephan Ewen commented on FLINK-10249: -- Fixed in {{master}} in 7d45b756b8bccbbacf6b

[jira] [Commented] (FLINK-12388) Update the production readiness checklist

[ https://issues.apache.org/jira/browse/FLINK-12388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837690#comment-16837690 ] Stephan Ewen commented on FLINK-12388: -- Fixed in {{master}} in 754cd71dd92dfcfff3e1

[jira] [Closed] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-12070. > Make blocking result partitions consumable multiple times >

[jira] [Commented] (FLINK-12378) Consolidate FileSystem Documentation

[ https://issues.apache.org/jira/browse/FLINK-12378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837694#comment-16837694 ] Stephan Ewen commented on FLINK-12378: -- Fixed in {{master}} in b50896a55288b363fd36

[jira] [Updated] (FLINK-12378) Consolidate FileSystem Documentation

[ https://issues.apache.org/jira/browse/FLINK-12378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-12378: - Fix Version/s: 1.8.1 1.9.0 > Consolidate FileSystem Documentation > -

[jira] [Updated] (FLINK-8513) Add documentation for connecting to non-AWS S3 endpoints

[ https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-8513: Fix Version/s: 1.8.1 1.9.0 > Add documentation for connecting to non-AWS S3 endp

[jira] [Resolved] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-12070. -- Resolution: Implemented Assignee: Stephan Ewen (was: BoWang) Fix Version/s: 1.

[jira] [Updated] (FLINK-12378) Consolidate FileSystem Documentation

[ https://issues.apache.org/jira/browse/FLINK-12378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12378: --- Labels: pull-request-available (was: ) > Consolidate FileSystem Documentation > ---

[GitHub] [flink] asfgit closed pull request #8326: [FLINK-12378][docs] Consolidate FileSystem Documentation

asfgit closed pull request #8326: [FLINK-12378][docs] Consolidate FileSystem Documentation URL: https://github.com/apache/flink/pull/8326 This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink] StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#issuecomment-491457613 Manually merged in a7cf24383be9f310fb5ccc5a032721421fa45791 -

[GitHub] [flink] asfgit closed pull request #8330: [FLINK-12388][docs] Update the production readiness checklist

asfgit closed pull request #8330: [FLINK-12388][docs] Update the production readiness checklist URL: https://github.com/apache/flink/pull/8330 This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] StephanEwen closed pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen closed pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r283063574 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/cata

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r283062024 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/cata

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r283060689 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r283062301 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/cata

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r283062652 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/cata

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r283059466 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r283063171 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/cata

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r283061626 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/cata

[GitHub] [flink] bowenli86 commented on issue #8390: [FLINK-12469][table] Clean up catalog API on default/current database

bowenli86 commented on issue #8390: [FLINK-12469][table] Clean up catalog API on default/current database URL: https://github.com/apache/flink/pull/8390#issuecomment-491445937 +1 @dawidwys can you take another look? if you don't have other comments, I'll merge this once CI is green

[GitHub] [flink] bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive] Support table related operations in HiveCatalog

bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive] Support table related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8353#discussion_r283056348 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c

[GitHub] [flink] xuefuz commented on a change in pull request #8390: [FLINK-12469][table] Clean up catalog API on default/current database

xuefuz commented on a change in pull request #8390: [FLINK-12469][table] Clean up catalog API on default/current database URL: https://github.com/apache/flink/pull/8390#discussion_r283047530 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/ca

[GitHub] [flink] bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive] Support table related operations in HiveCatalog

bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive] Support table related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8353#discussion_r283039874 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c

[GitHub] [flink] bowenli86 commented on a change in pull request #8390: [FLINK-12469][table] Clean up catalog API on default/current database

bowenli86 commented on a change in pull request #8390: [FLINK-12469][table] Clean up catalog API on default/current database URL: https://github.com/apache/flink/pull/8390#discussion_r283037447 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table

[GitHub] [flink] bowenli86 commented on a change in pull request #8390: [FLINK-12469][table] Clean up catalog API on default/current database

bowenli86 commented on a change in pull request #8390: [FLINK-12469][table] Clean up catalog API on default/current database URL: https://github.com/apache/flink/pull/8390#discussion_r283036856 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

[GitHub] [flink] azagrebin commented on issue #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on issue #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#issuecomment-491418905 @flinkbot attention @zhijiangW --

[GitHub] [flink] flinkbot commented on issue #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

flinkbot commented on issue #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#issuecomment-491418683 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I h

[GitHub] [flink] azagrebin opened a new pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin opened a new pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416 ## What is the purpose of the change Introduce partition/gate setup to decouple task registrati

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r283025643 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/catalo

[jira] [Commented] (FLINK-10520) Job save points REST API fails unless parameters are specified

[ https://issues.apache.org/jira/browse/FLINK-10520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837525#comment-16837525 ] Tim commented on FLINK-10520: - Is there any update on this issue?    > Job save points REST

[jira] [Commented] (FLINK-7697) Add metrics for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837512#comment-16837512 ] Piyush Goyal commented on FLINK-7697: - +1 on adding metrics to ES Sink.  Few others

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r282981545 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] yuyang08 closed pull request #8067: [FLINK-11746][formats] Add thrift format support to Flink

yuyang08 closed pull request #8067: [FLINK-11746][formats] Add thrift format support to Flink URL: https://github.com/apache/flink/pull/8067 This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#issuecomment-491373523 @zhijiangW Our reasoning about the three options seems similar. My understanding is that even if CancelPart

[GitHub] [flink] StephanEwen commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r282978232 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition

[GitHub] [flink] StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#issuecomment-491372403 Thank you for the reviews. I refactored some code: - Pulled out the `MemoryMappedBuffers`) class to be

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r282976905 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r282967862 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r282961373 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Ta

[GitHub] [flink] xuefuz commented on a change in pull request #8390: [FLINK-12469][table] Clean up catalog API on default/current database

xuefuz commented on a change in pull request #8390: [FLINK-12469][table] Clean up catalog API on default/current database URL: https://github.com/apache/flink/pull/8390#discussion_r282954828 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#issuecomment-491335910 @zhijiangW Thanks for the detailed review and good comments.

[GitHub] [flink] StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#issuecomment-491336129 @eaglewatcherwb This implementation makes no assumption when a partition will be released. That is the responsibi

[GitHub] [flink] ambition119 commented on issue #8387: [FLINK-11982] [table] File System Connector's support JSON Format and JSON file BatchTableSource

ambition119 commented on issue #8387: [FLINK-11982] [table] File System Connector's support JSON Format and JSON file BatchTableSource URL: https://github.com/apache/flink/pull/8387#issuecomment-491337056 > Ad. 1 Once again we aim to separate connector and formats => JsonFile = Json + File

[GitHub] [flink] ambition119 closed pull request #8387: [FLINK-11982] [table] File System Connector's support JSON Format and JSON file BatchTableSource

ambition119 closed pull request #8387: [FLINK-11982] [table] File System Connector's support JSON Format and JSON file BatchTableSource URL: https://github.com/apache/flink/pull/8387 This is an automated message from the Apa

[GitHub] [flink] StephanEwen commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r282938868 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition

[GitHub] [flink] StephanEwen commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r282938255 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition

[GitHub] [flink] StephanEwen commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r282938159 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition

[GitHub] [flink] StephanEwen commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r282938334 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition

[GitHub] [flink] sjwiesman commented on a change in pull request #8330: [FLINK-12388][docs] Update the production readiness checklist

sjwiesman commented on a change in pull request #8330: [FLINK-12388][docs] Update the production readiness checklist URL: https://github.com/apache/flink/pull/8330#discussion_r282937987 ## File path: docs/ops/production_ready.md ## @@ -22,79 +22,54 @@ specific language gov

[GitHub] [flink] fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update the production readiness checklist

fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update the production readiness checklist URL: https://github.com/apache/flink/pull/8330#discussion_r282917921 ## File path: docs/ops/production_ready.md ## @@ -22,79 +22,54 @@ specific language gover

[GitHub] [flink] fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update the production readiness checklist

fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update the production readiness checklist URL: https://github.com/apache/flink/pull/8330#discussion_r282921904 ## File path: docs/ops/production_ready.md ## @@ -22,79 +22,54 @@ specific language gover

[GitHub] [flink] fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update the production readiness checklist

fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update the production readiness checklist URL: https://github.com/apache/flink/pull/8330#discussion_r282919635 ## File path: docs/ops/production_ready.md ## @@ -22,79 +22,54 @@ specific language gover

[GitHub] [flink] fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update the production readiness checklist

fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update the production readiness checklist URL: https://github.com/apache/flink/pull/8330#discussion_r282920531 ## File path: docs/ops/production_ready.md ## @@ -22,79 +22,54 @@ specific language gover

[GitHub] [flink] yanghua commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore

yanghua commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore URL: https://github.com/apache/flink/pull/8410#discussion_r282921569 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/C

[GitHub] [flink] yanghua commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore

yanghua commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore URL: https://github.com/apache/flink/pull/8410#discussion_r282921234 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api

[GitHub] [flink] yanghua commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore

yanghua commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore URL: https://github.com/apache/flink/pull/8410#discussion_r282919368 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/C

[GitHub] [flink] gyfora commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore

gyfora commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore URL: https://github.com/apache/flink/pull/8410#discussion_r282908128 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Ch

[GitHub] [flink] gyfora commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore

gyfora commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore URL: https://github.com/apache/flink/pull/8410#discussion_r282907507 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Ch

[GitHub] [flink] gyfora commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore

gyfora commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore URL: https://github.com/apache/flink/pull/8410#discussion_r282909021 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/

[GitHub] [flink] azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757#discussion_r282897244 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757#discussion_r282884262 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757#discussion_r282882662 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757#discussion_r282888225 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757#discussion_r282882465 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757#discussion_r282884777 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757#discussion_r282896944 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] dawidwys commented on issue #8387: [FLINK-11982] [table] File System Connector's support JSON Format and JSON file BatchTableSource

dawidwys commented on issue #8387: [FLINK-11982] [table] File System Connector's support JSON Format and JSON file BatchTableSource URL: https://github.com/apache/flink/pull/8387#issuecomment-491308505 Ad. 1 Once again we aim to separate connector and formats => JsonFile = Json + File A

[GitHub] [flink] hequn8128 commented on issue #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

hequn8128 commented on issue #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#issuecomment-491306744 @sunjincheng121 Thank you very much for your suggestions and meticulous review. I have addressed all your comments

[GitHub] [flink] dawidwys commented on a change in pull request #8390: [FLINK-12469][table] Clean up catalog API on default/current database

dawidwys commented on a change in pull request #8390: [FLINK-12469][table] Clean up catalog API on default/current database URL: https://github.com/apache/flink/pull/8390#discussion_r282904007 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catal

[GitHub] [flink] ambition119 edited a comment on issue #8387: [FLINK-11982] [table] File System Connector's support JSON Format and JSON file BatchTableSource

ambition119 edited a comment on issue #8387: [FLINK-11982] [table] File System Connector's support JSON Format and JSON file BatchTableSource URL: https://github.com/apache/flink/pull/8387#issuecomment-491298616 > Hi @ambition119 > I agree with @StephanEwen that this PR mixes the concept

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r282898836 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS

[GitHub] [flink] yanghua commented on issue #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore

yanghua commented on issue #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore URL: https://github.com/apache/flink/pull/8410#issuecomment-491302415 @gyfora If you have time, can you review this PR for me? thanks.

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r282898836 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS

[jira] [Assigned] (FLINK-12473) Add the interface of ML pipeline and ML lib

[ https://issues.apache.org/jira/browse/FLINK-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-12473: - Assignee: Luo Gen > Add the interface of ML pipeline and ML lib > -

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r282892019 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/StrategyT

[GitHub] [flink] ambition119 commented on issue #8387: [FLINK-11982] [table] File System Connector's support JSON Format and JSON file BatchTableSource

ambition119 commented on issue #8387: [FLINK-11982] [table] File System Connector's support JSON Format and JSON file BatchTableSource URL: https://github.com/apache/flink/pull/8387#issuecomment-491298616 > Hi @ambition119 > I agree with @StephanEwen that this PR mixes the concepts of `

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r282893011 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Ta

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r282892019 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/StrategyT

[jira] [Commented] (FLINK-12428) Translate the "Event Time" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837302#comment-16837302 ] jack commented on FLINK-12428: -- Have you finished the task? > Translate the "Event Time" p

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r282887147 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS

[GitHub] [flink] flinkbot commented on issue #8414: [FLINK-12477][Build] Enforce maven version 3.1.1

flinkbot commented on issue #8414: [FLINK-12477][Build] Enforce maven version 3.1.1 URL: https://github.com/apache/flink/pull/8414#issuecomment-491294860 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[jira] [Updated] (FLINK-12477) Change threading-model in StreamTask to a mailbox-based approach

[ https://issues.apache.org/jira/browse/FLINK-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12477: --- Labels: pull-request-available (was: ) > Change threading-model in StreamTask to a mailbox-

[GitHub] [flink] rmetzger opened a new pull request #8414: [FLINK-12477][Build] Enforce maven version 3.1.1

rmetzger opened a new pull request #8414: [FLINK-12477][Build] Enforce maven version 3.1.1 URL: https://github.com/apache/flink/pull/8414 ## Contribution Checklist ## What is the purpose of the change The `frontend-maven-plugin` introduced in https://github.com/apache/flink/p

[GitHub] [flink] fhueske commented on a change in pull request #8354: [FLINK-12421][docs-zh] Synchronize the latest documentation changes (commits to 7b46f604) into Chinese documents

fhueske commented on a change in pull request #8354: [FLINK-12421][docs-zh] Synchronize the latest documentation changes (commits to 7b46f604) into Chinese documents URL: https://github.com/apache/flink/pull/8354#discussion_r282885332 ## File path: docs/dev/connectors/kafka.zh.md

[jira] [Assigned] (FLINK-12428) Translate the "Event Time" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jack reassigned FLINK-12428: Assignee: jack (was: YangFei) > Translate the "Event Time" page into Chinese > -

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r282887147 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS

  1   2   3   4   >