[GitHub] [flink] hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry

hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry URL: https://github.com/apache/flink/pull/8429#discussion_r285117654 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry

hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry URL: https://github.com/apache/flink/pull/8429#discussion_r285117690 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry

hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry URL: https://github.com/apache/flink/pull/8429#discussion_r285126535 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry

hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry URL: https://github.com/apache/flink/pull/8429#discussion_r285117667 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry

hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry URL: https://github.com/apache/flink/pull/8429#discussion_r285117628 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry

hequn8128 commented on a change in pull request #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry URL: https://github.com/apache/flink/pull/8429#discussion_r285117681 ## File path:

[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_r285325598 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

walterddr commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r285317219 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

walterddr commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r285317993 ## File path: flink-ml/pom.xml ## @@ -0,0 +1,39 @@ + +

[GitHub] [flink] walterddr commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

walterddr commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r285317554 ## File path:

[jira] [Closed] (FLINK-12549) include exceptions thrown by Hive metastore client in CatalogException in HiveCatalogBase

[ https://issues.apache.org/jira/browse/FLINK-12549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12549. Resolution: Fixed merged in 1.9.0: bd85d25b4684d4f9c6c277b2d34ac61ddc24b454 > include exceptions thrown

[jira] [Updated] (FLINK-12549) include exceptions thrown by Hive metastore client in CatalogException in HiveCatalogBase

[ https://issues.apache.org/jira/browse/FLINK-12549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12549: - Summary: include exceptions thrown by Hive metastore client in CatalogException in HiveCatalogBase

[jira] [Created] (FLINK-12549) include exceptions thrown by HMS client in CatalogException in HiveCatalogBase

Bowen Li created FLINK-12549: Summary: include exceptions thrown by HMS client in CatalogException in HiveCatalogBase Key: FLINK-12549 URL: https://issues.apache.org/jira/browse/FLINK-12549 Project:

[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_r285313772 ## File path:

[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_r285313720 ## File path:

[GitHub] [flink] flinkbot commented on issue #8477: [FLINK-12241][hive] Support function related operations in GenericHiveMetastoreCatalog

flinkbot commented on issue #8477: [FLINK-12241][hive] Support function related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8477#issuecomment-493624632 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-12241) Support function related operations in GenericHiveMetastoreCatalog

[ https://issues.apache.org/jira/browse/FLINK-12241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12241: --- Labels: pull-request-available (was: ) > Support function related operations in

[GitHub] [flink] bowenli86 opened a new pull request #8477: [FLINK-12241][hive] Support function related operations in GenericHiveMetastoreCatalog

bowenli86 opened a new pull request #8477: [FLINK-12241][hive] Support function related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8477 ## What is the purpose of the change This PR implements function related in `GenericHiveMetastoreCatalog`.

[GitHub] [flink] dawidwys merged pull request #8475: [FLINK-12512][table-planner] Create a new instance of CostFactory, FlinkTypeSystem & FlinkTypeFactory per TableEnvironment

dawidwys merged pull request #8475: [FLINK-12512][table-planner] Create a new instance of CostFactory, FlinkTypeSystem & FlinkTypeFactory per TableEnvironment URL: https://github.com/apache/flink/pull/8475 This is an

[jira] [Created] (FLINK-12548) FlinkKafkaConsumer issues configuring underlying KafkaConsumer

Leonid Ilyevsky created FLINK-12548: --- Summary: FlinkKafkaConsumer issues configuring underlying KafkaConsumer Key: FLINK-12548 URL: https://issues.apache.org/jira/browse/FLINK-12548 Project: Flink

[GitHub] [flink] bowenli86 commented on issue #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on issue #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#issuecomment-493536557 Just passed it with another round. LGTM +1 to merge

[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_r285215791 ## File path:

[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_r285218377 ## File path:

[jira] [Comment Edited] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842336#comment-16842336 ] Manish Bellani edited comment on FLINK-10114 at 5/17/19 5:33 PM: - Hello,

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842336#comment-16842336 ] Manish Bellani commented on FLINK-10114: Hello, is this still planned to be supported for

[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_r285218377 ## File path:

[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_r285218377 ## File path:

[GitHub] [flink] zzchun edited a comment on issue #8372: [FLINK-12354] [table] Add REVERSE function for table/sql API

zzchun edited a comment on issue #8372: [FLINK-12354] [table] Add REVERSE function for table/sql API URL: https://github.com/apache/flink/pull/8372#issuecomment-492262212 cc @xccui @twalthr @fhueske @dawidwys @zentol , can you help me to review this MR, thank you.

[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_r285215791 ## File path:

[GitHub] [flink] AjaxXu commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking

AjaxXu commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking URL: https://github.com/apache/flink/pull/8467#discussion_r285191329 ## File path:

[GitHub] [flink] AjaxXu commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking

AjaxXu commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking URL: https://github.com/apache/flink/pull/8467#discussion_r285191329 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285178042 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8462: [FLINK-12496][table-planner-blink] Support translation from StreamExecGroupWindowAggregate to StreamTransformation.

wuchong commented on a change in pull request #8462: [FLINK-12496][table-planner-blink] Support translation from StreamExecGroupWindowAggregate to StreamTransformation. URL: https://github.com/apache/flink/pull/8462#discussion_r285172572 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8462: [FLINK-12496][table-planner-blink] Support translation from StreamExecGroupWindowAggregate to StreamTransformation.

wuchong commented on a change in pull request #8462: [FLINK-12496][table-planner-blink] Support translation from StreamExecGroupWindowAggregate to StreamTransformation. URL: https://github.com/apache/flink/pull/8462#discussion_r285171305 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8462: [FLINK-12496][table-planner-blink] Support translation from StreamExecGroupWindowAggregate to StreamTransformation.

wuchong commented on a change in pull request #8462: [FLINK-12496][table-planner-blink] Support translation from StreamExecGroupWindowAggregate to StreamTransformation. URL: https://github.com/apache/flink/pull/8462#discussion_r285169940 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8462: [FLINK-12496][table-planner-blink] Support translation from StreamExecGroupWindowAggregate to StreamTransformation.

wuchong commented on a change in pull request #8462: [FLINK-12496][table-planner-blink] Support translation from StreamExecGroupWindowAggregate to StreamTransformation. URL: https://github.com/apache/flink/pull/8462#discussion_r285169795 ## File path:

[GitHub] [flink] hxbks2ks commented on a change in pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend

hxbks2ks commented on a change in pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend URL: https://github.com/apache/flink/pull/8472#discussion_r285173938 ## File path: flink-python/pyflink/java_gateway.py ## @@ -28,7 +28,6

[GitHub] [flink] hxbks2ks commented on a change in pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend

hxbks2ks commented on a change in pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend URL: https://github.com/apache/flink/pull/8472#discussion_r285173257 ## File path: flink-dist/src/main/flink-bin/bin/flink ## @@ -51,5

[GitHub] [flink] zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285172794 ## File path:

[GitHub] [flink] hxbks2ks commented on a change in pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend

hxbks2ks commented on a change in pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend URL: https://github.com/apache/flink/pull/8472#discussion_r285170191 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8445: [FLINK-12127][network, config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptio

zhijiangW commented on a change in pull request #8445: [FLINK-12127][network,config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptions URL: https://github.com/apache/flink/pull/8445#discussion_r285169365 ## File path:

[jira] [Resolved] (FLINK-12508) Expand Documentation on Testing DataStream API programs

[ https://issues.apache.org/jira/browse/FLINK-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-12508. Resolution: Fixed Fix Version/s: 1.9.0 Merged in

[GitHub] [flink] zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285165800 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285164289 ## File path:

[jira] [Closed] (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:all-tabpanel ] Gary Yao closed FLINK-12384. Resolution: Not A Problem I am closing this issue because the log message you are seeing does not pose a

[GitHub] [flink] rmetzger merged pull request #8437: [FLINK-12508] Expand Testing Documentation

rmetzger merged pull request #8437: [FLINK-12508] Expand Testing Documentation URL: https://github.com/apache/flink/pull/8437 This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on issue #8437: [FLINK-12508] Expand Testing Documentation

flinkbot edited a comment on issue #8437: [FLINK-12508] Expand Testing Documentation URL: https://github.com/apache/flink/pull/8437#issuecomment-492166310 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[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=16842232#comment-16842232 ] Gary Yao commented on FLINK-12384: -- We cannot remove this warning, as it is logged by the ZK client

[GitHub] [flink] tillrohrmann commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

tillrohrmann commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r285160885 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8445: [FLINK-12127][network, config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptio

zhijiangW commented on a change in pull request #8445: [FLINK-12127][network,config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptions URL: https://github.com/apache/flink/pull/8445#discussion_r285159088 ## File path:

[jira] [Comment Edited] (FLINK-6755) Allow triggering Checkpoints through command line client

[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842210#comment-16842210 ] Stefan Richter edited comment on FLINK-6755 at 5/17/19 2:30 PM: IMO, this

[jira] [Comment Edited] (FLINK-6755) Allow triggering Checkpoints through command line client

[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842210#comment-16842210 ] Stefan Richter edited comment on FLINK-6755 at 5/17/19 2:24 PM: IMO, this

[jira] [Comment Edited] (FLINK-6755) Allow triggering Checkpoints through command line client

[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842210#comment-16842210 ] Stefan Richter edited comment on FLINK-6755 at 5/17/19 2:25 PM: IMO, this

[jira] [Commented] (FLINK-6755) Allow triggering Checkpoints through command line client

[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842210#comment-16842210 ] Stefan Richter commented on FLINK-6755: --- IMO, this somehow leads to the more general question about

[jira] [Updated] (FLINK-12547) Deadlock when the task thread downloads jars using BlobClient

[ https://issues.apache.org/jira/browse/FLINK-12547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun updated FLINK-12547: -- Description: The jstack is as follows (this jstack is from an old Flink version, but the master

[jira] [Created] (FLINK-12547) Deadlock when the task thread downloads jars using BlobClient

Haibo Sun created FLINK-12547: - Summary: Deadlock when the task thread downloads jars using BlobClient Key: FLINK-12547 URL: https://issues.apache.org/jira/browse/FLINK-12547 Project: Flink

[jira] [Commented] (FLINK-6755) Allow triggering Checkpoints through command line client

[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842201#comment-16842201 ] Gyula Fora commented on FLINK-6755: --- Would be great to have a consensus on this feature wether we see

[jira] [Updated] (FLINK-12490) Introduce NetworkInput class

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

[GitHub] [flink] flinkbot commented on issue #8476: [FLINK-12490][network] Introduce Input and NetworkInput interfaces

flinkbot commented on issue #8476: [FLINK-12490][network] Introduce Input and NetworkInput interfaces URL: https://github.com/apache/flink/pull/8476#issuecomment-493450024 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] pnowojski opened a new pull request #8476: [FLINK-12490][network] Introduce Input and NetworkInput interfaces

pnowojski opened a new pull request #8476: [FLINK-12490][network] Introduce Input and NetworkInput interfaces URL: https://github.com/apache/flink/pull/8476 This PR depends on https://github.com/apache/flink/pull/8467 It introduces `Input` interface, it's implementation

[jira] [Created] (FLINK-12546) Base Docker images on `library/flink`

Konstantin Knauf created FLINK-12546: Summary: Base Docker images on `library/flink` Key: FLINK-12546 URL: https://issues.apache.org/jira/browse/FLINK-12546 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842160#comment-16842160 ] Robert Metzger commented on FLINK-10707: [~wolli] Were you able to start working on this? >

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16839243#comment-16839243 ] Gary Yao edited comment on FLINK-12302 at 5/17/19 1:05 PM: --- [~lamber-ken] I am

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

pnowojski commented on issue #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking URL: https://github.com/apache/flink/pull/8467#issuecomment-493445264 Test failure is unrelated and caused by: https://issues.apache.org/jira/browse/FLINK-12512

[GitHub] [flink] liyafan82 edited a comment on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp…

liyafan82 edited a comment on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp… URL: https://github.com/apache/flink/pull/8397#issuecomment-493441719 > > I think JMH benchmark component is a further thing. It's under discussion. > > For this PR, I

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285106547 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285106383 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285103874 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285103288 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285105964 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285104610 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285113017 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285102469 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285103598 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285111640 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

tillrohrmann commented on a change in pull request #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r285107062 ## File path:

[GitHub] [flink] yanghua commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

yanghua commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#discussion_r285112408 ## File path:

[GitHub] [flink] liyafan82 commented on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp…

liyafan82 commented on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp… URL: https://github.com/apache/flink/pull/8397#issuecomment-493441719 > > I think JMH benchmark component is a further thing. It's under discussion. > > For this PR, I think you

[GitHub] [flink] liyafan82 commented on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp…

liyafan82 commented on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp… URL: https://github.com/apache/flink/pull/8397#issuecomment-493441491 > I think JMH benchmark component is a further thing. It's under discussion. > For this PR, I think you can do

[GitHub] [flink] zentol commented on a change in pull request #8445: [FLINK-12127][network, config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptions

zentol commented on a change in pull request #8445: [FLINK-12127][network,config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptions URL: https://github.com/apache/flink/pull/8445#discussion_r285096724 ## File path:

[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=16842151#comment-16842151 ] Seth Wiesman commented on FLINK-12537: -- [~alpinegizmo] Yes > Improve Documentation Build Time >

[GitHub] [flink] klion26 commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

klion26 commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#discussion_r285098205 ## File path:

[GitHub] [flink] zentol merged pull request #8352: [hotfix][docs] mention kryo in serialization and link to page

zentol merged pull request #8352: [hotfix][docs] mention kryo in serialization and link to page URL: https://github.com/apache/flink/pull/8352 This is an automated message from the Apache Git Service. To respond to the

[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_r285105148 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8445: [FLINK-12127][network, config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptio

azagrebin commented on a change in pull request #8445: [FLINK-12127][network,config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptions URL: https://github.com/apache/flink/pull/8445#discussion_r285104973 ## File path:

[jira] [Closed] (FLINK-12545) TableSourceTest.testNestedProject failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12545. Resolution: Duplicate > TableSourceTest.testNestedProject failed on Travis >

[GitHub] [flink] yanghua commented on issue #8461: [FLINK-12422] Remove IN_TESTS for make test code and production code consistent

yanghua commented on issue #8461: [FLINK-12422] Remove IN_TESTS for make test code and production code consistent URL: https://github.com/apache/flink/pull/8461#issuecomment-493434758 Hi @tillrohrmann Thanks for your suggestion, actually, I have found the error log from Travis, it can not

[jira] [Created] (FLINK-12545) TableSourceTest.testNestedProject failed on Travis

Till Rohrmann created FLINK-12545: - Summary: TableSourceTest.testNestedProject failed on Travis Key: FLINK-12545 URL: https://issues.apache.org/jira/browse/FLINK-12545 Project: Flink Issue

[GitHub] [flink] zentol commented on a change in pull request #8445: [FLINK-12127][network, config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptions

zentol commented on a change in pull request #8445: [FLINK-12127][network,config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptions URL: https://github.com/apache/flink/pull/8445#discussion_r285096724 ## File path:

[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=16842131#comment-16842131 ] Till Rohrmann commented on FLINK-12381: --- Thanks for tackling this problem [~knaufk]. 1) In order

[GitHub] [flink] zentol commented on a change in pull request #8445: [FLINK-12127][network, config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptions

zentol commented on a change in pull request #8445: [FLINK-12127][network,config] Move network related options form TaskManagerOptions and NettyConfig into NetworkEnvironmentOptions URL: https://github.com/apache/flink/pull/8445#discussion_r285097169 ## File path:

[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_r285099175 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8437: [FLINK-12508] Expand Testing Documentation

flinkbot edited a comment on issue #8437: [FLINK-12508] Expand Testing Documentation URL: https://github.com/apache/flink/pull/8437#issuecomment-492166310 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] rmetzger commented on issue #8437: [FLINK-12508] Expand Testing Documentation

rmetzger commented on issue #8437: [FLINK-12508] Expand Testing Documentation URL: https://github.com/apache/flink/pull/8437#issuecomment-493429446 @flinkbot approve description This is an automated message from the Apache

[GitHub] [flink] flinkbot commented on issue #8475: [FLINK-12512][table-planner] Create a new instance of CostFactory, FlinkTypeSystem & FlinkTypeFactory per TableEnvironment

flinkbot commented on issue #8475: [FLINK-12512][table-planner] Create a new instance of CostFactory, FlinkTypeSystem & FlinkTypeFactory per TableEnvironment URL: https://github.com/apache/flink/pull/8475#issuecomment-493429293 Thanks a lot for your contribution to the Apache Flink

[GitHub] [flink] dawidwys opened a new pull request #8475: [FLINK-12512][table-planner] Create a new instance of CostFactory, FlinkTypeSystem & FlinkTypeFactory per TableEnvironment

dawidwys opened a new pull request #8475: [FLINK-12512][table-planner] Create a new instance of CostFactory, FlinkTypeSystem & FlinkTypeFactory per TableEnvironment URL: https://github.com/apache/flink/pull/8475 ## What is the purpose of the change `CostFactory`, `FlinkTypeSystem`

[jira] [Updated] (FLINK-12512) TableSourceTest#testNestedProject test failed

[ https://issues.apache.org/jira/browse/FLINK-12512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12512: --- Labels: pull-request-available (was: ) > TableSourceTest#testNestedProject test failed >

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

yanghua edited a comment on issue #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure URL: https://github.com/apache/flink/pull/8322#issuecomment-493402537 For a clearer analysis, I plan to do three steps: * Squash unrelated commits

[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_r285095516 ## File path:

[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_r285094373 ## File path:

  1   2   3   >