[jira] [Created] (FLINK-11115) Port some flink.ml algorithms to table based

Weihua Jiang created FLINK-5: Summary: Port some flink.ml algorithms to table based Key: FLINK-5 URL: https://issues.apache.org/jira/browse/FLINK-5 Project: Flink Issue Type:

[jira] [Created] (FLINK-11114) Support wrapping inference pipeline as a UDF function in SQL

Weihua Jiang created FLINK-4: Summary: Support wrapping inference pipeline as a UDF function in SQL Key: FLINK-4 URL: https://issues.apache.org/jira/browse/FLINK-4 Project: Flink

[jira] [Created] (FLINK-11113) Support periodically update models when inferencing

Weihua Jiang created FLINK-3: Summary: Support periodically update models when inferencing Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3 Project: Flink Issue

[jira] [Created] (FLINK-11112) Support pipeline import/export

Weihua Jiang created FLINK-2: Summary: Support pipeline import/export Key: FLINK-2 URL: https://issues.apache.org/jira/browse/FLINK-2 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11111) Create a new set of parameters

Weihua Jiang created FLINK-1: Summary: Create a new set of parameters Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11109) Create Table based optimizers

Weihua Jiang created FLINK-11109: Summary: Create Table based optimizers Key: FLINK-11109 URL: https://issues.apache.org/jira/browse/FLINK-11109 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11110) Support pipeline stage type inference

Weihua Jiang created FLINK-0: Summary: Support pipeline stage type inference Key: FLINK-0 URL: https://issues.apache.org/jira/browse/FLINK-0 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11108) Create a new set of table based ML Pipeline classes

Weihua Jiang created FLINK-11108: Summary: Create a new set of table based ML Pipeline classes Key: FLINK-11108 URL: https://issues.apache.org/jira/browse/FLINK-11108 Project: Flink Issue

[jira] [Created] (FLINK-11096) Create a new table based flink ML package

Weihua Jiang created FLINK-11096: Summary: Create a new table based flink ML package Key: FLINK-11096 URL: https://issues.apache.org/jira/browse/FLINK-11096 Project: Flink Issue Type:

[jira] [Created] (FLINK-11095) Table based ML Pipeline

Weihua Jiang created FLINK-11095: Summary: Table based ML Pipeline Key: FLINK-11095 URL: https://issues.apache.org/jira/browse/FLINK-11095 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-8020) Deadlock found in Flink Streaming job

[ https://issues.apache.org/jira/browse/FLINK-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Jiang updated FLINK-8020: Attachment: jstack53009(2).out Attach a new jstack file. After removing our collector.collect()

[jira] [Commented] (FLINK-8020) Deadlock found in Flink Streaming job

[ https://issues.apache.org/jira/browse/FLINK-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243538#comment-16243538 ] Weihua Jiang commented on FLINK-8020: - Sorry, after further analyzing, it seems the deadlock is caused

[jira] [Updated] (FLINK-8020) Deadlock found in Flink Streaming job

[ https://issues.apache.org/jira/browse/FLINK-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Jiang updated FLINK-8020: Attachment: jstack67976-2.log > Deadlock found in Flink Streaming job >

[jira] [Created] (FLINK-8020) Deadlock found in Flink Streaming job

Weihua Jiang created FLINK-8020: --- Summary: Deadlock found in Flink Streaming job Key: FLINK-8020 URL: https://issues.apache.org/jira/browse/FLINK-8020 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8020) Deadlock found in Flink Streaming job

[ https://issues.apache.org/jira/browse/FLINK-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Jiang updated FLINK-8020: Description: Our streaming job run into trouble in these days after a long time smooth running.

[jira] [Created] (FLINK-8019) Flink streaming job stopped at consuming Kafka data

Weihua Jiang created FLINK-8019: --- Summary: Flink streaming job stopped at consuming Kafka data Key: FLINK-8019 URL: https://issues.apache.org/jira/browse/FLINK-8019 Project: Flink Issue Type:

[jira] [Updated] (FLINK-8019) Flink streaming job stopped at consuming Kafka data

[ https://issues.apache.org/jira/browse/FLINK-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Jiang updated FLINK-8019: Attachment: jstack-20171108-2.log > Flink streaming job stopped at consuming Kafka data >