[jira] [Assigned] (FLINK-7642) Upgrade maven surefire plugin to 2.21.0

[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-7642: --- Assignee: vinoyang > Upgrade maven surefire plugin to 2.21.0 >

[jira] [Comment Edited] (FLINK-8971) Create general purpose testing job

[ https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16421148#comment-16421148 ] mingleizhang edited comment on FLINK-8971 at 3/31/18 2:44 AM: -- Page not found

[jira] [Commented] (FLINK-8971) Create general purpose testing job

[ https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16421148#comment-16421148 ] mingleizhang commented on FLINK-8971: - Page not found [heavily misbehaved

[jira] [Comment Edited] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420885#comment-16420885 ] Jamie Grier edited comment on FLINK-9061 at 3/31/18 1:32 AM: - Maybe we should

[jira] [Created] (FLINK-9118) Support a time based rollover of part file in Bucketing Sink

Lakshmi Rao created FLINK-9118: -- Summary: Support a time based rollover of part file in Bucketing Sink Key: FLINK-9118 URL: https://issues.apache.org/jira/browse/FLINK-9118 Project: Flink

[jira] [Commented] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420885#comment-16420885 ] Jamie Grier commented on FLINK-9061: Maybe we should keep this super simple and make a change at the

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

[ https://issues.apache.org/jira/browse/FLINK-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420750#comment-16420750 ] ASF GitHub Bot commented on FLINK-9059: --- Github user walterddr commented on a diff in the pull

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

[ https://issues.apache.org/jira/browse/FLINK-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420749#comment-16420749 ] ASF GitHub Bot commented on FLINK-9059: --- Github user walterddr commented on a diff in the pull

[GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri...

Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5758#discussion_r178334028 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java --- @@ -29,38 +30,47 @@ /**

[GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri...

Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5758#discussion_r178334057 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala --- @@ -0,0 +1,75 @@ +/* + *

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420721#comment-16420721 ] ASF GitHub Bot commented on FLINK-6968: --- Github user suez1224 commented on the issue:

[GitHub] flink issue #5688: [FLINK-6968][Table API & SQL] Add Queryable table sink.

Github user suez1224 commented on the issue: https://github.com/apache/flink/pull/5688 Could you please rebase your pr to resolve conflict? Thanks. ---

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

[ https://issues.apache.org/jira/browse/FLINK-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420715#comment-16420715 ] ASF GitHub Bot commented on FLINK-9059: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5758#discussion_r178330131 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala --- @@ -0,0 +1,75 @@ +/* + *

[jira] [Commented] (FLINK-9069) Fix some double semicolons to single semicolons, and update checkstyle

[ https://issues.apache.org/jira/browse/FLINK-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420705#comment-16420705 ] ASF GitHub Bot commented on FLINK-9069: --- Github user jparkie commented on the issue:

[GitHub] flink issue #5769: [FLINK-9069] Add checkstyle rule to detect multiple conse...

Github user jparkie commented on the issue: https://github.com/apache/flink/pull/5769 @zentol Bump. Just wondering if this got lost. :) ---

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420649#comment-16420649 ] Josep Rubió commented on FLINK-1707: Is someone still interested on adding AP to Flink? Thanks! >

[jira] [Commented] (FLINK-9108) invalid ProcessWindowFunction link in Document

[ https://issues.apache.org/jira/browse/FLINK-9108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420628#comment-16420628 ] ASF GitHub Bot commented on FLINK-9108: --- Github user alpinegizmo commented on the issue:

[GitHub] flink issue #5785: [FLINK-9108][docs] Fix invalid link

Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/5785 +1 ---

[jira] [Assigned] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-9087: --- Assignee: mingleizhang > Return value of broadcastEvent should be closed in >

[jira] [Commented] (FLINK-9112) Let end-to-end tests upload the components logs in case of a failure

[ https://issues.apache.org/jira/browse/FLINK-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420582#comment-16420582 ] mingleizhang commented on FLINK-9112: - Hi, [~till.rohrmann] I would like to ask, where to upload the

[jira] [Updated] (FLINK-7642) Upgrade maven surefire plugin to 2.21.0

[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7642: -- Description: Surefire 2.19 release introduced more useful test filters which would let us run a subset of the

[jira] [Updated] (FLINK-7642) Upgrade maven surefire plugin to 2.21.0

[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7642: -- Summary: Upgrade maven surefire plugin to 2.21.0 (was: Upgrade maven surefire plugin to 2.19.1) > Upgrade

[GitHub] flink pull request #5795: [hotfix] [docs] fix mistake about Sample code in C...

GitHub user mayyamus opened a pull request: https://github.com/apache/flink/pull/5795 [hotfix] [docs] fix mistake about Sample code in Concepts & Common API ## Brief change log fix mistake about Sample code in Concepts & Common API ## Verifying this change

[GitHub] flink issue #5761: [FLINK-8989] [e2eTests] Elasticsearch1&2&5 end to end tes...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5761 I think I found how to solve this issue. I will fix it as soon as possible. ---

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420461#comment-16420461 ] ASF GitHub Bot commented on FLINK-8989: --- Github user zhangminglei commented on the issue:

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420460#comment-16420460 ] ASF GitHub Bot commented on FLINK-8989: --- Github user zhangminglei commented on the issue:

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420463#comment-16420463 ] ASF GitHub Bot commented on FLINK-8989: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #5761: [FLINK-8989] [e2eTests] Elasticsearch1&2&5 end to end tes...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5761 I think I found how to solve this issue. I will fix it as soon as possible. ---

[GitHub] flink issue #5761: [FLINK-8989] [e2eTests] Elasticsearch1&2&5 end to end tes...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5761 I think I found how to solve this issue. I will fix it as soon as possible. ---

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420326#comment-16420326 ] ASF GitHub Bot commented on FLINK-8989: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #5761: [FLINK-8989] [e2eTests] Elasticsearch1&2&5 end to end tes...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5761 I found an issue, I tried find it out but it seems useless. For elasticsearch5sink, I can run directly with the following command with flink cluster setup and elasticsearch5 cluster set

[jira] [Created] (FLINK-9117) Disable artifact download in mesos container environment.

Renjie Liu created FLINK-9117: - Summary: Disable artifact download in mesos container environment. Key: FLINK-9117 URL: https://issues.apache.org/jira/browse/FLINK-9117 Project: Flink Issue

[jira] [Assigned] (FLINK-9116) Introduce getAll and removeAll for MapState

[ https://issues.apache.org/jira/browse/FLINK-9116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou reassigned FLINK-9116: - Assignee: Sihua Zhou > Introduce getAll and removeAll for MapState >

[jira] [Commented] (FLINK-8880) Validate configurations for SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420256#comment-16420256 ] Xingcan Cui commented on FLINK-8880: Hi [~walterddr], sorry for the late replay. I've been quite busy

[jira] [Created] (FLINK-9116) Introduce getAll and removeAll for MapState

Sihua Zhou created FLINK-9116: - Summary: Introduce getAll and removeAll for MapState Key: FLINK-9116 URL: https://issues.apache.org/jira/browse/FLINK-9116 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

[ https://issues.apache.org/jira/browse/FLINK-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420249#comment-16420249 ] ASF GitHub Bot commented on FLINK-9059: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5758#discussion_r178244750 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java --- @@ -102,10 +112,10 @@ public static

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

[ https://issues.apache.org/jira/browse/FLINK-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420247#comment-16420247 ] ASF GitHub Bot commented on FLINK-9059: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5758#discussion_r178244473 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java --- @@ -29,38 +30,47 @@ /**

[jira] [Resolved] (FLINK-9105) Table program compiles failed

[ https://issues.apache.org/jira/browse/FLINK-9105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Lau resolved FLINK-9105. Resolution: Fixed Fix Version/s: 1.5.0 Release Note: Flink 1.5-SNAPSHOT commons-compiler needs