[jira] [Commented] (FLINK-14269) The close method does not work for Python UserDefinedFunction

2019-12-03 Thread Dian Fu (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986778#comment-16986778
 ] 

Dian Fu commented on FLINK-14269:
-

This issue has been solved in Beam 1.18.0 and so we could revisit this issue 
after bump Beam to 1.18.0. I will change the fix version to 1.11.0 for now.

> The close method does not work for Python UserDefinedFunction
> -
>
> Key: FLINK-14269
> URL: https://issues.apache.org/jira/browse/FLINK-14269
> Project: Flink
>  Issue Type: Sub-task
>  Components: API / Python
>Reporter: Dian Fu
>Assignee: Dian Fu
>Priority: Major
> Fix For: 1.10.0
>
>
> As discussed in [https://github.com/apache/flink/pull/9766], the close method 
> of UserDefinedFunction does not work for now as it's not called due to issues 
> of Beam's portability framework, i.e., the {{SdkHarness}} in sdk_worker.py 
> need to call the stop method of {{SdkWorker}} so that the close method of 
> UserDefinedFunction will be called. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Commented] (FLINK-14269) The close method does not work for Python UserDefinedFunction

2019-10-08 Thread Dian Fu (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946607#comment-16946607
 ] 

Dian Fu commented on FLINK-14269:
-

[~sunjincheng121] Thanks for creating the ticket at Beam side. 

> The close method does not work for Python UserDefinedFunction
> -
>
> Key: FLINK-14269
> URL: https://issues.apache.org/jira/browse/FLINK-14269
> Project: Flink
>  Issue Type: Sub-task
>  Components: API / Python
>Reporter: Dian Fu
>Assignee: Dian Fu
>Priority: Major
> Fix For: 1.10.0
>
>
> As discussed in [https://github.com/apache/flink/pull/9766], the close method 
> of UserDefinedFunction does not work for now as it's not called due to issues 
> of Beam's portability framework, i.e., the {{SdkHarness}} in sdk_worker.py 
> need to call the stop method of {{SdkWorker}} so that the close method of 
> UserDefinedFunction will be called. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Commented] (FLINK-14269) The close method does not work for Python UserDefinedFunction

2019-10-08 Thread sunjincheng (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946584#comment-16946584
 ] 

sunjincheng commented on FLINK-14269:
-

Thanks Dian I have create the Jira in beam for this issue. 
https://issues.apache.org/jira/browse/BEAM-8325

> The close method does not work for Python UserDefinedFunction
> -
>
> Key: FLINK-14269
> URL: https://issues.apache.org/jira/browse/FLINK-14269
> Project: Flink
>  Issue Type: Sub-task
>  Components: API / Python
>Reporter: Dian Fu
>Assignee: Dian Fu
>Priority: Major
> Fix For: 1.10.0
>
>
> As discussed in [https://github.com/apache/flink/pull/9766], the close method 
> of UserDefinedFunction does not work for now as it's not called due to issues 
> of Beam's portability framework, i.e., the {{SdkHarness}} in sdk_worker.py 
> need to call the stop method of {{SdkWorker}} so that the close method of 
> UserDefinedFunction will be called. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Commented] (FLINK-14269) The close method does not work for Python UserDefinedFunction

2019-09-29 Thread Dian Fu (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940303#comment-16940303
 ] 

Dian Fu commented on FLINK-14269:
-

[~jark] Thanks for correction the title. The new title makes sense to me.

> The close method does not work for Python UserDefinedFunction
> -
>
> Key: FLINK-14269
> URL: https://issues.apache.org/jira/browse/FLINK-14269
> Project: Flink
>  Issue Type: Sub-task
>  Components: API / Python
>Reporter: Dian Fu
>Priority: Major
> Fix For: 1.10.0
>
>
> As discussed in [https://github.com/apache/flink/pull/9766], the close method 
> of UserDefinedFunction does not work for now as it's not called due to issues 
> of Beam's portability framework, i.e., the {{SdkHarness}} in sdk_worker.py 
> need to call the stop method of {{SdkWorker}} so that the close method of 
> UserDefinedFunction will be called. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Commented] (FLINK-14269) The close method does not work for Python UserDefinedFunction

2019-09-29 Thread Jark Wu (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940291#comment-16940291
 ] 

Jark Wu commented on FLINK-14269:
-

I add a "Python" word in the title to make it more explicitly. Please correct 
me if I'm wrong. 

> The close method does not work for Python UserDefinedFunction
> -
>
> Key: FLINK-14269
> URL: https://issues.apache.org/jira/browse/FLINK-14269
> Project: Flink
>  Issue Type: Sub-task
>  Components: API / Python
>Reporter: Dian Fu
>Priority: Major
> Fix For: 1.10.0
>
>
> As discussed in [https://github.com/apache/flink/pull/9766], the close method 
> of UserDefinedFunction does not work for now as it's not called due to issues 
> of Beam's portability framework, i.e., the {{SdkHarness}} in sdk_worker.py 
> need to call the stop method of {{SdkWorker}} so that the close method of 
> UserDefinedFunction will be called. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)