Return-Path: X-Original-To: apmail-flink-issues-archive@minotaur.apache.org Delivered-To: apmail-flink-issues-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E6AFC10A61 for ; Thu, 27 Aug 2015 13:09:45 +0000 (UTC) Received: (qmail 70867 invoked by uid 500); 27 Aug 2015 13:09:45 -0000 Delivered-To: apmail-flink-issues-archive@flink.apache.org Received: (qmail 70818 invoked by uid 500); 27 Aug 2015 13:09:45 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 70808 invoked by uid 99); 27 Aug 2015 13:09:45 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Aug 2015 13:09:45 +0000 Date: Thu, 27 Aug 2015 13:09:45 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716622#comment-14716622 ] ASF GitHub Bot commented on FLINK-2490: --------------------------------------- Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/992#issuecomment-135419765 @mxm Hi, my test just do the same thing that first pass the Socket when it calls SocketTextStreamFunction.open. Then close the Socket that means send nothing(EOF) to the SocketTextStreamFunction. And after this it will retry. And first time the retry happens immediately since SocketTextStreamFunction receives the end of the sent message. Then it will get retry second, third... times since I do not open the socket which means a ConnectionError occur. So can you describe more in detail? Thank you. > Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket > ----------------------------------------------------------------------------------- > > Key: FLINK-2490 > URL: https://issues.apache.org/jira/browse/FLINK-2490 > Project: Flink > Issue Type: Bug > Components: Streaming > Affects Versions: 0.10 > Reporter: Huang Wei > Priority: Minor > Fix For: 0.10 > > Original Estimate: 168h > Remaining Estimate: 168h > -- This message was sent by Atlassian JIRA (v6.3.4#6332)