[GitHub] [flink] bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284861222 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/cata

[GitHub] [flink] bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284853529 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/tab

[GitHub] [flink] bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284860471 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/ca

[GitHub] [flink] bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284852577 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/tab

[GitHub] [flink] bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284863481 ## File path: flink-table/flink-table-api-java

[GitHub] [flink] bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284856201 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/tab

[GitHub] [flink] xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284859760 ## File path: flink-table/flink-table-api-java/sr

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

dawidwys 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_r284857074 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

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

dawidwys 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_r284855245 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

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

dawidwys 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_r284853604 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

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

dawidwys 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_r284853604 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

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

dawidwys 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_r284851991 ## File path: flink-table/flink-table-api-java/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_r284850723 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

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

dawidwys 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_r284830405 ## File path: flink-table/flink-table-api-java/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_r284844604 ## 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_r284844604 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284844282 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catal

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284841463 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catal

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284841463 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catal

[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_r284841076 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284840003 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/

[GitHub] [flink] bowenli86 commented on issue #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on issue #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#issuecomment-493180074 @xuefuz thanks for your review, can you take another look? --

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284833618 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284833522 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284832759 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284832440 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/

[GitHub] [flink] tweise commented on a change in pull request #8469: [FLINK-12539][Connectors / FileSystem] StreamingFileSink: Make the class customizable

tweise commented on a change in pull request #8469: [FLINK-12539][Connectors / FileSystem] StreamingFileSink: Make the class customizable URL: https://github.com/apache/flink/pull/8469#discussion_r284831310 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284831269 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284830863 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/

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

dawidwys 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_r284830405 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284829347 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/

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

dawidwys 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_r284825268 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

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

dawidwys 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_r284828531 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

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

dawidwys 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_r284828486 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

[GitHub] [flink] kailashhd commented on issue #8469: [FLINK-12539][Connectors / FileSystem] StreamingFileSink: Make the class customizable

kailashhd commented on issue #8469: [FLINK-12539][Connectors / FileSystem] StreamingFileSink: Make the class customizable URL: https://github.com/apache/flink/pull/8469#issuecomment-493169823 cc @tweise @tillrohrmann Looks like I don't have permission to add you as reviewers on the PR itse

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

dawidwys 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_r284825295 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

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

dawidwys 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_r284825326 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

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

dawidwys 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_r284825295 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

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

dawidwys 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_r284825326 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

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

dawidwys 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_r284825268 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

[jira] [Commented] (FLINK-10725) Support for Java 11 (LTS)

[ https://issues.apache.org/jira/browse/FLINK-10725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841579#comment-16841579 ] Eron Wright commented on FLINK-10725: -- Want to mention an interesting detail, JDK1

[GitHub] [flink] xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

xuefuz commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284822727 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/

[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_r284813682 ## 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_r284817808 ## 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_r284817261 ## 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_r284814717 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] kailashhd opened a new pull request #8469: [FLINK-12539][Connectors / FileSystem] StreamingFileSink: Make the class customizable

kailashhd opened a new pull request #8469: [FLINK-12539][Connectors / FileSystem] StreamingFileSink: Make the class customizable URL: https://github.com/apache/flink/pull/8469 ## What is the purpose of the change *Provide mechanisms to extend the StreamingFileSink class and make it cust

[jira] [Updated] (FLINK-12539) StreamingFileSink: Make the class extendable to customize for different usecases

[ https://issues.apache.org/jira/browse/FLINK-12539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12539: --- Labels: pull-request-available (was: ) > StreamingFileSink: Make the class extendable to cu

[GitHub] [flink] flinkbot commented on issue #8469: [FLINK-12539][Connectors / FileSystem] StreamingFileSink: Make the class customizable

flinkbot commented on issue #8469: [FLINK-12539][Connectors / FileSystem] StreamingFileSink: Make the class customizable URL: https://github.com/apache/flink/pull/8469#issuecomment-493156833 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] walterddr commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem

walterddr commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem URL: https://github.com/apache/flink/pull/8468#issuecomment-493154695 @flinkbot attention @KurtYoung @godfreyhe @beyond1920 please kindly take a

[GitHub] [flink] flinkbot commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem

flinkbot commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem URL: https://github.com/apache/flink/pull/8468#issuecomment-493155027 Thanks a lot for your contribution to the Apache Flink project. I'm the @f

[GitHub] [flink] flinkbot edited a comment on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem

flinkbot edited a comment on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem URL: https://github.com/apache/flink/pull/8468#issuecomment-493155027 Thanks a lot for your contribution to the Apache Flink project. I'm

[GitHub] [flink] walterddr opened a new pull request #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem

walterddr opened a new pull request #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem URL: https://github.com/apache/flink/pull/8468 ## What is the purpose of the change This PR fixes the problem: FilterableTableSour

[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_r284808011 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api

[jira] [Updated] (FLINK-11561) Translate "Flink Architecture" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11561: --- Labels: pull-request-available (was: ) > Translate "Flink Architecture" page into Chinese >

[jira] [Assigned] (FLINK-12381) W/o HA, upon a full restart, checkpointing crashes

[ https://issues.apache.org/jira/browse/FLINK-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-12381: Assignee: Konstantin Knauf > W/o HA, upon a full restart, checkpointing crashes >

[jira] [Commented] (FLINK-12381) W/o HA, upon a full restart, checkpointing crashes

[ https://issues.apache.org/jira/browse/FLINK-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841524#comment-16841524 ] Konstantin Knauf commented on FLINK-12381: -- [~till.rohrmann] I am happy to take

[jira] [Commented] (FLINK-10232) Add a SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841511#comment-16841511 ] Rong Rong commented on FLINK-10232: --- Thanks Danny for bringing this up.  I think we c

[jira] [Created] (FLINK-12539) StreamingFileSink: Make the class extendable to customize for different usecases

Kailash Hassan Dayanand created FLINK-12539: --- Summary: StreamingFileSink: Make the class extendable to customize for different usecases Key: FLINK-12539 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Commented] (FLINK-12537) Improve Documentation Build Time

[ https://issues.apache.org/jira/browse/FLINK-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841495#comment-16841495 ] Seth Wiesman commented on FLINK-12537: -- [~jark] I profiled the build and 99% of th

[jira] [Commented] (FLINK-12529) Release buffers of the record deserializer timely to improve the efficiency of heap memory usage on taskmanager

[ https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841470#comment-16841470 ] Haibo Sun commented on FLINK-12529: ---   [~pnowojski], do you think there is any proble

[jira] [Comment Edited] (FLINK-12529) Release buffers of the record deserializer timely to improve the efficiency of heap memory usage on taskmanager

[ https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841470#comment-16841470 ] Haibo Sun edited comment on FLINK-12529 at 5/16/19 3:35 PM:

[GitHub] [flink] walterddr commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19

walterddr commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19 URL: https://github.com/apache/flink/pull/8324#issuecomment-493116362 thanks for the pointer @danny0405 actually i agree with the guideline @twalthr setup previously to left the code commented out not removed,

[GitHub] [flink] pnowojski opened a new pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking

pnowojski opened a new pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking URL: https://github.com/apache/flink/pull/8467 This change makes `CheckpointBarrierHandler` a non blocking class with similar interface as `InputGate`. This is one step towards a ma

[jira] [Updated] (FLINK-12535) Make CheckpointBarrierHandler non-blocking

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

[GitHub] [flink] walterddr edited a comment on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19

walterddr edited a comment on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19 URL: https://github.com/apache/flink/pull/8324#issuecomment-493116362 thanks for the pointer @danny0405 actually i agree with the guideline @twalthr setup previously to left the code commented out not r

[GitHub] [flink] flinkbot commented on issue #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking

flinkbot commented on issue #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking URL: https://github.com/apache/flink/pull/8467#issuecomment-493117748 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review yo

[GitHub] [flink] sunhaibotb commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

sunhaibotb commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409#discussion_r284765841 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/ta

[GitHub] [flink] Aitozi edited a comment on issue #8455: [FLINK-12284]Fix the incorrect inputBufferUsage metric in credit-based netowork mode

Aitozi edited a comment on issue #8455: [FLINK-12284]Fix the incorrect inputBufferUsage metric in credit-based netowork mode URL: https://github.com/apache/flink/pull/8455#issuecomment-493109896 Thanks @zhijiangW for sharing your thoughts on this issue. Although the semantics of `inputB

[GitHub] [flink] Aitozi commented on issue #8455: [FLINK-12284]Fix the incorrect inputBufferUsage metric in credit-based netowork mode

Aitozi commented on issue #8455: [FLINK-12284]Fix the incorrect inputBufferUsage metric in credit-based netowork mode URL: https://github.com/apache/flink/pull/8455#issuecomment-493109896 Thanks @zhijiangW for sharing your thoughts on this issue. Although the semantics of `inputBufferUs

[jira] [Commented] (FLINK-12384) Rolling the etcd servers causes "Connected to an old server; r-o mode will be unavailable"

[ https://issues.apache.org/jira/browse/FLINK-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841444#comment-16841444 ] Gary Yao commented on FLINK-12384: -- [~haf]: Right, but from the client perspective it s

[GitHub] [flink] StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409#discussion_r284739589 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtim

[jira] [Commented] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841428#comment-16841428 ] Stefan Richter commented on FLINK-10855: @vinoyang i guess i cannot. I was just

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

azagrebin commented on issue #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757#issuecomment-493101669 @kisimple true, looks like Travis problem. Could you squash the empty commit to trigger it a

[jira] [Created] (FLINK-12538) Network notifyDataAvailable() only called after getting a new buffer

Nico Kruber created FLINK-12538: --- Summary: Network notifyDataAvailable() only called after getting a new buffer Key: FLINK-12538 URL: https://issues.apache.org/jira/browse/FLINK-12538 Project: Flink

[GitHub] [flink] yanghua commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure

yanghua commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure URL: https://github.com/apache/flink/pull/8322#discussion_r284740074 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/j

[jira] [Commented] (FLINK-12537) Improve Documentation Build Time

[ https://issues.apache.org/jira/browse/FLINK-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841422#comment-16841422 ] Jark Wu commented on FLINK-12537: - a big +1 Do you have some thoughts about this alread

[GitHub] [flink] StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409#discussion_r284738919 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtim

[GitHub] [flink] sunhaibotb commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

sunhaibotb commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409#discussion_r284733595 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/ta

[GitHub] [flink] StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409#discussion_r284739589 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtim

[GitHub] [flink] StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409#discussion_r284738035 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtim

[jira] [Commented] (FLINK-12303) Scala 2.12 lambdas does not work in event classes inside streams.

[ https://issues.apache.org/jira/browse/FLINK-12303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841408#comment-16841408 ] Matěj Novotný commented on FLINK-12303: --- [~aljoscha], thank you for showing me You

[GitHub] [flink] sunhaibotb commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

sunhaibotb commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409#discussion_r284733595 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/ta

[jira] [Commented] (FLINK-12537) Improve Documentation Build Time

[ https://issues.apache.org/jira/browse/FLINK-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841401#comment-16841401 ] Fabian Hueske commented on FLINK-12537: --- A BIG +1 for this issue. Thanks [~sjwies

[jira] [Updated] (FLINK-12451) [Bitwise Functions] Add BIT_XOR function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-12451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12451: --- Component/s: Table SQL / API > [Bitwise Functions] Add BIT_XOR function supported in Table A

[jira] [Commented] (FLINK-12395) Add more detailed javadoc for getDescription() and getDetailedDescription() in catalog object interfaces

[ https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841398#comment-16841398 ] Robert Metzger commented on FLINK-12395: Hey [~phoenixjiangnan], thanks a lot fo

[jira] [Updated] (FLINK-12450) [Bitwise Functions] Add BIT_LSHIFT, BIT_RSHIFT functions supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12450: --- Component/s: Table SQL / API > [Bitwise Functions] Add BIT_LSHIFT, BIT_RSHIFT functions supp

[jira] [Updated] (FLINK-12395) Add more detailed javadoc for getDescription() and getDetailedDescription() in catalog object interfaces

[ https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12395: --- Component/s: Table SQL / API > Add more detailed javadoc for getDescription() and getDetaile

[jira] [Updated] (FLINK-12520) Support to provide fully-qualified domain host name in TaskManagerMetricGroup

[ https://issues.apache.org/jira/browse/FLINK-12520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12520: --- Component/s: Runtime / Metrics > Support to provide fully-qualified domain host name in Task

[GitHub] [flink] StefanRRichter commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure

StefanRRichter commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure URL: https://github.com/apache/flink/pull/8322#discussion_r284732792 ## File path: flink-runtime/src/main/java/org/apache/flink/ru

[GitHub] [flink] StefanRRichter commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure

StefanRRichter commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure URL: https://github.com/apache/flink/pull/8322#discussion_r284732143 ## File path: flink-runtime/src/main/java/org/apache/flink/ru

[GitHub] [flink] StefanRRichter commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure

StefanRRichter commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure URL: https://github.com/apache/flink/pull/8322#discussion_r284729988 ## File path: flink-runtime/src/test/java/org/apache/flink/ru

[jira] [Commented] (FLINK-12384) Rolling the etcd servers causes "Connected to an old server; r-o mode will be unavailable"

[ https://issues.apache.org/jira/browse/FLINK-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841391#comment-16841391 ] Henrik commented on FLINK-12384: zetcd refers to the project by the name [https://githu

[GitHub] [flink] yanghua commented on issue #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure

yanghua commented on issue #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure URL: https://github.com/apache/flink/pull/8322#issuecomment-493080226 @StefanRRichter Have updated. What do you think about the new commit and the whole PR? --

[GitHub] [flink] yanghua commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure

yanghua commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure URL: https://github.com/apache/flink/pull/8322#discussion_r284720134 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/c

[GitHub] [flink] StefanRRichter commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure

StefanRRichter commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure URL: https://github.com/apache/flink/pull/8322#discussion_r284714678 ## File path: flink-runtime/src/main/java/org/apache/flink/ru

[GitHub] [flink] yanghua commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure

yanghua commented on a change in pull request #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure URL: https://github.com/apache/flink/pull/8322#discussion_r284711957 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/c

[GitHub] [flink] tillrohrmann commented on a change in pull request #8452: [FLINK-12432][runtime] Add SchedulerNG stub implementation

tillrohrmann commented on a change in pull request #8452: [FLINK-12432][runtime] Add SchedulerNG stub implementation URL: https://github.com/apache/flink/pull/8452#discussion_r284710612 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/SchedulerNGFactory

[GitHub] [flink] tillrohrmann commented on a change in pull request #8452: [FLINK-12432][runtime] Add SchedulerNG stub implementation

tillrohrmann commented on a change in pull request #8452: [FLINK-12432][runtime] Add SchedulerNG stub implementation URL: https://github.com/apache/flink/pull/8452#discussion_r284711321 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/SchedulerNGFactory

[GitHub] [flink] tillrohrmann commented on a change in pull request #8452: [FLINK-12432][runtime] Add SchedulerNG stub implementation

tillrohrmann commented on a change in pull request #8452: [FLINK-12432][runtime] Add SchedulerNG stub implementation URL: https://github.com/apache/flink/pull/8452#discussion_r284708583 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ##

<    1   2   3   4   5   >