[GitHub] [flink] WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#discussion_r286324516 ## File path: flink-python/pyflink/table/tests/test_descriptor.py

[GitHub] [flink] KurtYoung commented on a change in pull request #8492: [FLINK-12563][table-runtime-blink] Introduce vector data format in blink

2019-05-22 Thread GitBox
KurtYoung commented on a change in pull request #8492: [FLINK-12563][table-runtime-blink] Introduce vector data format in blink URL: https://github.com/apache/flink/pull/8492#discussion_r286328947 ## File path:

[jira] [Comment Edited] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

2019-05-22 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845585#comment-16845585 ] Yu Li edited comment on FLINK-8871 at 5/22/19 6:51 AM: --- bq. His solution (also

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

2019-05-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845624#comment-16845624 ] Robert Metzger commented on FLINK-10707: Okay, thanks for the update. > Improve Cluster

[GitHub] [flink] zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286372609 ## File path:

[jira] [Created] (FLINK-12588) Add TableSchema for Python Table API

2019-05-22 Thread Wei Zhong (JIRA)
Wei Zhong created FLINK-12588: - Summary: Add TableSchema for Python Table API Key: FLINK-12588 URL: https://issues.apache.org/jira/browse/FLINK-12588 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12587) Add pure-API Watermark class

2019-05-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12587: Summary: Add pure-API Watermark class Key: FLINK-12587 URL: https://issues.apache.org/jira/browse/FLINK-12587 Project: Flink Issue Type: Improvement

[GitHub] [flink] asfgit closed pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks

2019-05-22 Thread GitBox
asfgit closed pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks URL: https://github.com/apache/flink/pull/8442 This is an automated message from the

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#discussion_r286324342 ## File path: flink-python/pyflink/table/table_descriptor.py

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#discussion_r286324419 ## File path: flink-python/pyflink/table/tests/test_descriptor.py

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#discussion_r286324342 ## File path: flink-python/pyflink/table/table_descriptor.py

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
sunjincheng121 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#discussion_r286326566 ## File path: flink-python/pyflink/table/table_descriptor.py

[jira] [Updated] (FLINK-12458) Introduce PartitionConnectionException for unreachable producer

2019-05-22 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12458: - Description: If the consumer can not establish a connection to remote task executor, which might

[GitHub] [flink] lirui-apache commented on issue #8449: [FLINK-12235][hive] Support Hive partition in HiveCatalog

2019-05-22 Thread GitBox
lirui-apache commented on issue #8449: [FLINK-12235][hive] Support Hive partition in HiveCatalog URL: https://github.com/apache/flink/pull/8449#issuecomment-494675094 Rebased and addressed comments. @bowenli86 @xuefuz please take another look. Thanks.

[jira] [Updated] (FLINK-12458) Introduce PartitionConnectionException for unreachable producer

2019-05-22 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12458: - Summary: Introduce PartitionConnectionException for unreachable producer (was: Throw

[jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

2019-05-22 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845631#comment-16845631 ] vinoyang commented on FLINK-8871: - [~carp84] Please pay attention to your words, I think you are close to

[GitHub] [flink] sunjincheng121 commented on issue #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
sunjincheng121 commented on issue #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#issuecomment-494705623 Thanks for the update @WeiZhong94 LGTM. +1 to merged. @flinkbot approve all

[GitHub] [flink] zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286368931 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286368588 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286374621 ## File path:

[GitHub] [flink] klion26 commented on a change in pull request #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file

2019-05-22 Thread GitBox
klion26 commented on a change in pull request #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file URL: https://github.com/apache/flink/pull/8479#discussion_r286323947 ## File path:

[jira] [Assigned] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-05-22 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12319: Assignee: Liya Fan > StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer >

[jira] [Assigned] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-05-22 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12319: Assignee: (was: Liya Fan) > StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer >

[jira] [Assigned] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-05-22 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12319: Assignee: Liya Fan > StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer >

[jira] [Commented] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-05-22 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845566#comment-16845566 ] Liya Fan commented on FLINK-12319: -- Hi [~mpf], thank you for your feedback. I am looking at this issue.

[GitHub] [flink] c4emmmm commented on issue #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

2019-05-22 Thread GitBox
c4e commented on issue #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#issuecomment-494682592 > Thanks for contributing this PR, and great to see new machine learning effort arriving at Flink! > > We also need

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

2019-05-22 Thread Fabian Wollert (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845601#comment-16845601 ] Fabian Wollert commented on FLINK-10707: [~rmetzger] unfortunately not. June looks more

[GitHub] [flink] tillrohrmann commented on issue #8509: [FLINK-12458][network] Introduce PartitionConnectionException for unreachable producer

2019-05-22 Thread GitBox
tillrohrmann commented on issue #8509: [FLINK-12458][network] Introduce PartitionConnectionException for unreachable producer URL: https://github.com/apache/flink/pull/8509#issuecomment-494696364 The PR does not compile @zhijiangW.

[GitHub] [flink] flinkbot edited a comment on issue #8509: [FLINK-12458][network] Introduce PartitionConnectionException for unreachable producer

2019-05-22 Thread GitBox
flinkbot edited a comment on issue #8509: [FLINK-12458][network] Introduce PartitionConnectionException for unreachable producer URL: https://github.com/apache/flink/pull/8509#issuecomment-494679383 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] JingsongLi commented on a change in pull request #8492: [FLINK-12563][table-runtime-blink] Introduce vector data format in blink

2019-05-22 Thread GitBox
JingsongLi commented on a change in pull request #8492: [FLINK-12563][table-runtime-blink] Introduce vector data format in blink URL: https://github.com/apache/flink/pull/8492#discussion_r286361709 ## File path:

[jira] [Closed] (FLINK-12579) Influx Metric exporter throws a lot of negative infinity errors

2019-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12579. Resolution: Duplicate > Influx Metric exporter throws a lot of negative infinity errors >

[jira] [Updated] (FLINK-12579) Influx Metric exporter throws a lot of negative infinity errors

2019-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12579: - Component/s: Runtime / Metrics > Influx Metric exporter throws a lot of negative

[GitHub] [flink] asfgit closed pull request #8431: [FLINK-12480] Introduce mailbox to StreamTask main-loop

2019-05-22 Thread GitBox
asfgit closed pull request #8431: [FLINK-12480] Introduce mailbox to StreamTask main-loop URL: https://github.com/apache/flink/pull/8431 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] asfgit closed pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

2019-05-22 Thread GitBox
asfgit closed pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
sunjincheng121 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#discussion_r286326763 ## File path:

[GitHub] [flink] flinkbot commented on issue #8509: [FLINK-12458][network] Introduce PartitionConnectionException for unreachable producer

2019-05-22 Thread GitBox
flinkbot commented on issue #8509: [FLINK-12458][network] Introduce PartitionConnectionException for unreachable producer URL: https://github.com/apache/flink/pull/8509#issuecomment-494679383 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-12458) Introduce PartitionConnectionException for unreachable producer

2019-05-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12458: --- Labels: pull-request-available (was: ) > Introduce PartitionConnectionException for

[GitHub] [flink] JingsongLi edited a comment on issue #8435: [FLINK-12443][table-planner-blink] Replace InternalType with LogicalType in blink

2019-05-22 Thread GitBox
JingsongLi edited a comment on issue #8435: [FLINK-12443][table-planner-blink] Replace InternalType with LogicalType in blink URL: https://github.com/apache/flink/pull/8435#issuecomment-494625782 > I try to start reviewing from runtime package, and noticed that the old internal types

[GitHub] [flink] StefanRRichter commented on issue #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks

2019-05-22 Thread GitBox
StefanRRichter commented on issue #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks URL: https://github.com/apache/flink/pull/8442#issuecomment-494707360 Thanks for the reviews @pnowojski @Aitozi - merging.

[jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

2019-05-22 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845585#comment-16845585 ] Yu Li commented on FLINK-8871: -- bq. His solution (also proposed by us) is now meaningless, I just gave my

[jira] [Updated] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

2019-05-22 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-6227: Description: It is part of FLIP-1.   We define a new abstract special exception called

[GitHub] [flink] zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286366466 ## File path:

[GitHub] [flink] WeiZhong94 commented on issue #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
WeiZhong94 commented on issue #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#issuecomment-494665375 @sunjincheng121 Thanks for your review! I have addressed your comments and remove the

[jira] [Assigned] (FLINK-6962) Add a table SQL DDL

2019-05-22 Thread Danny Chan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chan reassigned FLINK-6962: - Assignee: Danny Chan (was: Shuyi Chen) > Add a table SQL DDL > --- > >

[GitHub] [flink] c4emmmm commented on issue #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

2019-05-22 Thread GitBox
c4e commented on issue #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#issuecomment-494672243 As mentioned in the mail "[DISCUSS] FLIP-39: Flink ML pipeline and ML libs" in flink-dev, we have to add a TableEnvironment

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

2019-05-22 Thread GitBox
c4e 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_r286336701 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
sunjincheng121 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#discussion_r286367535 ## File path: flink-python/pyflink/table/table_descriptor.py

[GitHub] [flink] zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286368082 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #8508: [FLINK-12533][table] Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

2019-05-22 Thread GitBox
twalthr commented on a change in pull request #8508: [FLINK-12533][table] Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type URL: https://github.com/apache/flink/pull/8508#discussion_r286367280 ## File path:

[jira] [Created] (FLINK-12589) SQL end-to-end test fails on Travis

2019-05-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12589: Summary: SQL end-to-end test fails on Travis Key: FLINK-12589 URL: https://issues.apache.org/jira/browse/FLINK-12589 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-12588) Add TableSchema for Python Table API

2019-05-22 Thread Wei Zhong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-12588: -- Description: As discussed in the PR of FLINK-12439, we need to add TableSchema to Python Table API

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#discussion_r286345003 ## File path: flink-python/pyflink/table/table_descriptor.py

[jira] [Updated] (FLINK-12533) Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

2019-05-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12533: --- Labels: pull-request-available (was: ) > Introduce TABLE_AGGREGATE_FUNCTION

[GitHub] [flink] flinkbot commented on issue #8508: [FLINK-12533][table] Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

2019-05-22 Thread GitBox
flinkbot commented on issue #8508: [FLINK-12533][table] Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type URL: https://github.com/apache/flink/pull/8508#issuecomment-494669031 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] KurtYoung commented on a change in pull request #8492: [FLINK-12563][table-runtime-blink] Introduce vector data format in blink

2019-05-22 Thread GitBox
KurtYoung commented on a change in pull request #8492: [FLINK-12563][table-runtime-blink] Introduce vector data format in blink URL: https://github.com/apache/flink/pull/8492#discussion_r286328269 ## File path:

[GitHub] [flink] hequn8128 opened a new pull request #8508: [FLINK-12533][table] Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

2019-05-22 Thread GitBox
hequn8128 opened a new pull request #8508: [FLINK-12533][table] Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type URL: https://github.com/apache/flink/pull/8508 ## What is the purpose of the change This pull request adds TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type.

[jira] [Comment Edited] (FLINK-12573) ability to add suffix to part file created in Bucket (StreamingFileSink)

2019-05-22 Thread yitzchak lieberman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845581#comment-16845581 ] yitzchak lieberman edited comment on FLINK-12573 at 5/22/19 6:43 AM: -

[jira] [Commented] (FLINK-12573) ability to add suffix to part file created in Bucket (StreamingFileSink)

2019-05-22 Thread yitzchak lieberman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845581#comment-16845581 ] yitzchak lieberman commented on FLINK-12573: Hi Louis. I think it could help if it will be

[jira] [Updated] (FLINK-6227) Introduce the abstract PartitionException for downstream task failure

2019-05-22 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-6227: Summary: Introduce the abstract PartitionException for downstream task failure (was: Introduce the

[GitHub] [flink] zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286369679 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
flinkbot edited a comment on issue #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#issuecomment-493961877 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

2019-05-22 Thread GitBox
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API URL: https://github.com/apache/flink/pull/8488#discussion_r286375884 ## File path: flink-python/pyflink/table/table_descriptor.py

[GitHub] [flink] twalthr commented on a change in pull request #8349: [FLINK-12411][table-planner][tests] Workaround limited support of not nullable fields in window aggregation

2019-05-22 Thread GitBox
twalthr commented on a change in pull request #8349: [FLINK-12411][table-planner][tests] Workaround limited support of not nullable fields in window aggregation URL: https://github.com/apache/flink/pull/8349#discussion_r286377273 ## File path:

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

2019-05-22 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-12477: Assignee: Alex > Change threading-model in StreamTask to a mailbox-based approach >

[jira] [Commented] (FLINK-12401) Support incremental emit for non-window streaming FlatAggregate on Table API

2019-05-22 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845700#comment-16845700 ] Hequn Cheng commented on FLINK-12401: - Hi [~sunjincheng121] [~jark], I'm going to support

[jira] [Closed] (FLINK-12589) SQL end-to-end test fails on Travis

2019-05-22 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-12589. Resolution: Fixed > SQL end-to-end test fails on Travis >

[jira] [Updated] (FLINK-12411) Fix failling e2e test test_streaming_sql.sh

2019-05-22 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-12411: - Description: https://travis-ci.org/apache/flink/jobs/535231108 {code}

[GitHub] [flink] twalthr opened a new pull request #8510: [FLINK-12254][table] Update cast() and TypeLiteralExpression to new type system

2019-05-22 Thread GitBox
twalthr opened a new pull request #8510: [FLINK-12254][table] Update cast() and TypeLiteralExpression to new type system URL: https://github.com/apache/flink/pull/8510 ## What is the purpose of the change This PR updates `ImplicitExpressionOperations#cast` and

[jira] [Created] (FLINK-12590) Replace http links in documentation

2019-05-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12590: Summary: Replace http links in documentation Key: FLINK-12590 URL: https://issues.apache.org/jira/browse/FLINK-12590 Project: Flink Issue Type:

[jira] [Commented] (FLINK-12578) Use secure URLs for Maven repositories

2019-05-22 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845792#comment-16845792 ] Jungtaek Lim commented on FLINK-12578: -- Yes, I explained that changing scheme in MapR repo URL

[GitHub] [flink] dawidwys commented on issue #8500: [FLINK-12254][table-common] More preparation for using the new type system

2019-05-22 Thread GitBox
dawidwys commented on issue #8500: [FLINK-12254][table-common] More preparation for using the new type system URL: https://github.com/apache/flink/pull/8500#issuecomment-494774411 @flinkbot approve until consensus This is an

[GitHub] [flink] flinkbot commented on issue #8513: [FLINK-12147] [metrics] Error for monitor kafka metrics when Use influxDB metr…

2019-05-22 Thread GitBox
flinkbot commented on issue #8513: [FLINK-12147] [metrics] Error for monitor kafka metrics when Use influxDB metr… URL: https://github.com/apache/flink/pull/8513#issuecomment-494781909 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Assigned] (FLINK-12481) Make processing time timer trigger run via the mailbox

2019-05-22 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-12481: Assignee: Alex > Make processing time timer trigger run via the mailbox >

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

2019-05-22 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-12477: Assignee: (was: Alex) > Change threading-model in StreamTask to a mailbox-based approach >

[GitHub] [flink] Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286377261 ## File path:

[GitHub] [flink] Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286377381 ## File path:

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-05-22 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845683#comment-16845683 ] Nico Kruber commented on FLINK-12122: - Since every subtask gets its own thread (not every slot /

[jira] [Updated] (FLINK-12568) Implement TableSink and OutputFormat to write Hive tables

2019-05-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12568: --- Component/s: Connectors / Hive > Implement TableSink and OutputFormat to write Hive tables

[GitHub] [flink] zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286389776 ## File path:

[jira] [Commented] (FLINK-11634) Translate "State Backends" page into Chinese

2019-05-22 Thread Congxian Qiu(klion26) (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845702#comment-16845702 ] Congxian Qiu(klion26) commented on FLINK-11634: --- [~zxhe] I can't find your id for 

[jira] [Updated] (FLINK-5544) Implement Internal Timer Service in RocksDB

2019-05-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5544: -- Labels: pull-request-available (was: ) > Implement Internal Timer Service in RocksDB >

[GitHub] [flink] pnowojski commented on issue #3359: [FLINK-5544][streaming] Add InternalTimerService implemented in RocksDB

2019-05-22 Thread GitBox
pnowojski commented on issue #3359: [FLINK-5544][streaming] Add InternalTimerService implemented in RocksDB URL: https://github.com/apache/flink/pull/3359#issuecomment-494731669 This was superseded by @StefanRRichter work, so closing.

[GitHub] [flink] Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-05-22 Thread GitBox
Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r286410853 ## File path:

[GitHub] [flink] zentol merged pull request #8502: [FLINK-12578] Use secure URLs for Maven repositories

2019-05-22 Thread GitBox
zentol merged pull request #8502: [FLINK-12578] Use secure URLs for Maven repositories URL: https://github.com/apache/flink/pull/8502 This is an automated message from the Apache Git Service. To respond to the message,

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

2019-05-22 Thread GitBox
sunjincheng121 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_r286391030 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation

2019-05-22 Thread GitBox
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation URL: https://github.com/apache/flink/pull/8495#discussion_r286358387 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation

2019-05-22 Thread GitBox
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation URL: https://github.com/apache/flink/pull/8495#discussion_r286447515 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation

2019-05-22 Thread GitBox
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation URL: https://github.com/apache/flink/pull/8495#discussion_r286446063 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation

2019-05-22 Thread GitBox
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation URL: https://github.com/apache/flink/pull/8495#discussion_r286449211 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation

2019-05-22 Thread GitBox
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation URL: https://github.com/apache/flink/pull/8495#discussion_r286357388 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation

2019-05-22 Thread GitBox
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation URL: https://github.com/apache/flink/pull/8495#discussion_r286448379 ## File path:

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

2019-05-22 Thread GitBox
rmetzger commented on issue #8414: [FLINK-12447][Build] Enforce maven version 3.1.1 URL: https://github.com/apache/flink/pull/8414#issuecomment-494777349 You are right @Myasuka, I've updated the ticket and commit. Thank you @zentol for checking my PR. I opened a PR for the

[GitHub] [flink] pnowojski closed pull request #3359: [FLINK-5544][streaming] Add InternalTimerService implemented in RocksDB

2019-05-22 Thread GitBox
pnowojski closed pull request #3359: [FLINK-5544][streaming] Add InternalTimerService implemented in RocksDB URL: https://github.com/apache/flink/pull/3359 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-05-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845716#comment-16845716 ] Till Rohrmann commented on FLINK-12122: --- Thanks for reporting this issue [~mstar_benl]. I think

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

2019-05-22 Thread GitBox
sunjincheng121 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_r286391030 ## File path:

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

2019-05-22 Thread GitBox
sunjincheng121 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_r286380439 ## File path:

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

2019-05-22 Thread GitBox
sunjincheng121 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_r286397482 ## File path:

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

2019-05-22 Thread GitBox
sunjincheng121 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_r286399770 ## File path:

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

2019-05-22 Thread GitBox
sunjincheng121 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_r286394165 ## File path:

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

2019-05-22 Thread GitBox
sunjincheng121 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_r286405362 ## File path:

  1   2   3   4   >