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

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:

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

[ 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] [Updated] (FLINK-12458) Introduce PartitionConnectionException for unreachable producer

[ 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

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

[ 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

[ 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] [Comment Edited] (FLINK-12573) ability to add suffix to part file created in Bucket (StreamingFileSink)

[ 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)

[ 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

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

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

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

[ 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] KurtYoung commented on a change in pull request #8492: [FLINK-12563][table-runtime-blink] Introduce vector data format in blink

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:

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

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] flinkbot commented on issue #8508: [FLINK-12533][table] Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

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

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

[ 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] hequn8128 opened a new pull request #8508: [FLINK-12533][table] Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

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] [Assigned] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

[ 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

[ 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

[ 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

[ 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] sunjincheng121 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

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] sunjincheng121 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

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

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

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

[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

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] WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

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

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

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] klion26 commented on a change in pull request #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file

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:

<    1   2   3   4