[jira] [Commented] (FLINK-4796) Add new Sink interface with access to more meta data

2017-09-10 Thread Erik van Oosten (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16160810#comment-16160810 ] Erik van Oosten commented on FLINK-4796: A workaround is to override {{setRuntimeC

[jira] [Updated] (FLINK-7610) xerces lib conflict

2017-09-10 Thread Domenico Campagnolo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Domenico Campagnolo updated FLINK-7610: --- Description: Flink job fails when I try to use the method validate((new StAXSource(rea

[jira] [Updated] (FLINK-7610) xerces lib conflict

2017-09-10 Thread Domenico Campagnolo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Domenico Campagnolo updated FLINK-7610: --- Description: Flink job fails when I try to use the method validate((new StAXSource(rea

[jira] [Updated] (FLINK-7610) xerces lib conflict

2017-09-10 Thread Domenico Campagnolo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Domenico Campagnolo updated FLINK-7610: --- Description: Flink job fails when I try to use the method validate((new StAXSource(rea

[jira] [Updated] (FLINK-7610) xerces lib conflict

2017-09-10 Thread Domenico Campagnolo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Domenico Campagnolo updated FLINK-7610: --- Description: Flink job fails when I try to use the method validate((new StAXSource(rea

[jira] [Created] (FLINK-7610) xerces lib conflict

2017-09-10 Thread Domenico Campagnolo (JIRA)
Domenico Campagnolo created FLINK-7610: -- Summary: xerces lib conflict Key: FLINK-7610 URL: https://issues.apache.org/jira/browse/FLINK-7610 Project: Flink Issue Type: Bug Compo

[jira] [Resolved] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536)

2017-09-10 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li resolved FLINK-7589. - Resolution: Not A Bug > org.apache.http.ConnectionClosedException: Premature end of Content-Length > deli

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

2017-09-10 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16160671#comment-16160671 ] Jark Wu commented on FLINK-7446: Hi [~fhueske] , feel free to take this, I didn't start ye

[jira] [Assigned] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

2017-09-10 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-7446: -- Assignee: (was: Jark Wu) > Support to define an existing field as the rowtime field for TableSource

[jira] [Commented] (FLINK-5720) Deprecate "Folding" in all of DataStream API

2017-09-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16160619#comment-16160619 ] ASF GitHub Bot commented on FLINK-5720: --- Github user iduanyingjie commented on the i

[GitHub] flink issue #3816: [FLINK-5720] Deprecate DataStream#fold()

2017-09-10 Thread iduanyingjie
Github user iduanyingjie commented on the issue: https://github.com/apache/flink/pull/3816 In this document [https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/operators/index.html#datastream-transformations](url) `keyedStream.fold("start")((str, i) => { str

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

2017-09-10 Thread Ashish Pokharel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16160596#comment-16160596 ] Ashish Pokharel commented on FLINK-4319: Hi All, We currently have a few Flink app

[jira] [Commented] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

2017-09-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16160581#comment-16160581 ] ASF GitHub Bot commented on FLINK-7521: --- Github user zjureel commented on the issue:

[GitHub] flink issue #4654: [FLINK-7521] Add config option to set the content length ...

2017-09-10 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4654 @kl0u @zentol Thank you for your suggestions. So remove the code `.addLast(new HttpObjectAggregator(100*1024*1024)` will be a temporary fix? In fact it surprises me that the client sends the