[jira] [Assigned] (FLINK-8331) FieldParsers do not correctly set EMPT_COLUMN error state

2017-12-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-8331: -- Assignee: sunjincheng > FieldParsers do not correctly set EMPT_COLUMN error state > ---

[jira] [Created] (FLINK-8331) FieldParsers do not correctly set EMPT_COLUMN error state

2017-12-29 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8331: Summary: FieldParsers do not correctly set EMPT_COLUMN error state Key: FLINK-8331 URL: https://issues.apache.org/jira/browse/FLINK-8331 Project: Flink Issue

[jira] [Assigned] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2017-12-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-3655: Assignee: Fabian Hueske > Allow comma-separated or multiple directories to be specified for

[jira] [Updated] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2017-12-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-3655: - Fix Version/s: 1.5.0 > Allow comma-separated or multiple directories to be specified for > FileIn

[jira] [Updated] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2017-12-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-3655: - Priority: Major (was: Minor) > Allow comma-separated or multiple directories to be specified for

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2017-12-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16306527#comment-16306527 ] Fabian Hueske commented on FLINK-3655: -- Hi [~sjwiesman], sorry for the delay. I just

[jira] [Commented] (FLINK-8171) Remove work arounds in Flip6LocalStreamEnvironment

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

[GitHub] flink issue #5101: [FLINK-8171] [flip6] Remove work arounds from Flip6LocalS...

2017-12-29 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5101 Thanks for the review @zentol. I've rebased this PR and once Travis gives green light, I'll merge it. ---

[jira] [Commented] (FLINK-8330) Remove FlinkYarnCLI

2017-12-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16306402#comment-16306402 ] ASF GitHub Bot commented on FLINK-8330: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5217: [FLINK-8330] [flip6] Remove FlinkYarnCLI

2017-12-29 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5217 [FLINK-8330] [flip6] Remove FlinkYarnCLI ## What is the purpose of the change The `FlinkYarnCLI` is not needed and is, thus, being removed. ## Does this pull request potentiall

[jira] [Created] (FLINK-8330) Remove FlinkYarnCLI

2017-12-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8330: Summary: Remove FlinkYarnCLI Key: FLINK-8330 URL: https://issues.apache.org/jira/browse/FLINK-8330 Project: Flink Issue Type: Improvement Component

[jira] [Commented] (FLINK-8329) Move YarnClient out of YarnClusterClient

2017-12-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16306398#comment-16306398 ] ASF GitHub Bot commented on FLINK-8329: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5216: [FLINK-8329] [flip6] Move YarnClient to AbstractYa...

2017-12-29 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5216 [FLINK-8329] [flip6] Move YarnClient to AbstractYarnClusterDescriptor ## What is the purpose of the change Moves the YarnClient from the YarnClusterClient to the AbstractYarnClusterDes

[jira] [Created] (FLINK-8329) Move YarnClient out of YarnClusterClient

2017-12-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8329: Summary: Move YarnClient out of YarnClusterClient Key: FLINK-8329 URL: https://issues.apache.org/jira/browse/FLINK-8329 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient

2017-12-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16306391#comment-16306391 ] ASF GitHub Bot commented on FLINK-8328: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p...

2017-12-29 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5215 [FLINK-8328] [flip6] Move Yarn ApplicationStatus polling out of YarnClusterClient ## What is the purpose of the change Introduce YarnApplicationStatusMonitor which does the Yarn Appli

[jira] [Created] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient

2017-12-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8328: Summary: Pull Yarn ApplicationStatus polling out of YarnClusterClient Key: FLINK-8328 URL: https://issues.apache.org/jira/browse/FLINK-8328 Project: Flink I

[jira] [Commented] (FLINK-7797) Add support for windowed outer joins for streaming tables

2017-12-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16306321#comment-16306321 ] ASF GitHub Bot commented on FLINK-7797: --- Github user xccui commented on a diff in th

[GitHub] flink pull request #5140: [FLINK-7797] [table] Add support for windowed oute...

2017-12-29 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5140#discussion_r159069304 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala --- @@ -182,16 +196,64 @@ abstract class

[jira] [Commented] (FLINK-7797) Add support for windowed outer joins for streaming tables

2017-12-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16306318#comment-16306318 ] ASF GitHub Bot commented on FLINK-7797: --- Github user xccui commented on a diff in th

[GitHub] flink pull request #5140: [FLINK-7797] [table] Add support for windowed oute...

2017-12-29 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5140#discussion_r159069074 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinAwareCollector.scala --- @@ -0,0 +1,68 @@ +/* + * License

[jira] [Commented] (FLINK-8227) Optimize the performance of SharedBufferSerializer

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

[jira] [Commented] (FLINK-8227) Optimize the performance of SharedBufferSerializer

2017-12-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16306256#comment-16306256 ] ASF GitHub Bot commented on FLINK-8227: --- Github user asfgit closed the pull request

[GitHub] flink issue #5142: [FLINK-8227] Optimize the performance of SharedBufferSeri...

2017-12-29 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/5142 Merged it. Thanks for the contribution! ---

[GitHub] flink pull request #5142: [FLINK-8227] Optimize the performance of SharedBuf...

2017-12-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5142 ---

[jira] [Commented] (FLINK-8226) Dangling reference generated after NFA clean up timed out SharedBufferEntry

2017-12-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16306254#comment-16306254 ] ASF GitHub Bot commented on FLINK-8226: --- Github user dawidwys commented on a diff in

[GitHub] flink pull request #5141: [FLINK-8226] [cep] Dangling reference generated af...

2017-12-29 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5141#discussion_r159057128 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java --- @@ -191,22 +191,28 @@ public boolean isEmpty() {

[jira] [Closed] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL

2017-12-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-8312. -- Resolution: Fixed Fixed in 91f00ec91b55b28a59114e88127af2f85f279eb5 > Fix ScalarFunction varargs lengt

[jira] [Commented] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL

2017-12-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16306220#comment-16306220 ] ASF GitHub Bot commented on FLINK-8312: --- Github user asfgit closed the pull request

[GitHub] flink pull request #5206: [FLINK-8312][TableAPI && SQL] Fix ScalarFunction v...

2017-12-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5206 ---