[jira] [Commented] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042304#comment-16042304 ] ASF GitHub Bot commented on FLINK-6868: --- GitHub user asdf2014 opened a pull request:

[GitHub] flink pull request #4087: [FLINK-6868][build] Using `scala.binary.version` f...

2017-06-07 Thread asdf2014
GitHub user asdf2014 opened a pull request: https://github.com/apache/flink/pull/4087 [FLINK-6868][build] Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector` Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector` You can mer

[jira] [Created] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-07 Thread Benedict Jin (JIRA)
Benedict Jin created FLINK-6868: --- Summary: Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector` Key: FLINK-6868 URL: https://issues.apache.org/jira/browse/FLINK-6868 Project

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-07 Thread Benedict Jin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benedict Jin updated FLINK-6868: Issue Type: Improvement (was: Bug) > Using `scala.binary.version` for `flink-streaming-scala` in `C

[jira] [Updated] (FLINK-6867) Elasticsearch 1.x IT test still instable due to embedded node instability

2017-06-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6867: --- Description: The integration tests for Elasticsearch 1.x seems to still be instable, b

[jira] [Updated] (FLINK-6867) Elasticsearch 1.x ITCase still instable due to embedded node instability

2017-06-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6867: --- Summary: Elasticsearch 1.x ITCase still instable due to embedded node instability (wa

[jira] [Created] (FLINK-6867) Elasticsearch 1.x IT test still instable due to embedded node instability

2017-06-07 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6867: -- Summary: Elasticsearch 1.x IT test still instable due to embedded node instability Key: FLINK-6867 URL: https://issues.apache.org/jira/browse/FLINK-6867 P

[jira] [Commented] (FLINK-6494) Migrate ResourceManager configuration options

2017-06-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042149#comment-16042149 ] ASF GitHub Bot commented on FLINK-6494: --- GitHub user zjureel reopened a pull request

[GitHub] flink pull request #4075: [FLINK-6494] Migrate ResourceManager/Yarn/Mesos co...

2017-06-07 Thread zjureel
GitHub user zjureel reopened a pull request: https://github.com/apache/flink/pull/4075 [FLINK-6494] Migrate ResourceManager/Yarn/Mesos configuration options Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consider

[jira] [Updated] (FLINK-6488) Mark deprecated for 'start-local.sh' script

2017-06-07 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6488: Summary: Mark deprecated for 'start-local.sh' script (was: Remove 'start-local.sh' script) > Mark

[jira] [Commented] (FLINK-6488) Remove 'start-local.sh' script

2017-06-07 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042060#comment-16042060 ] mingleizhang commented on FLINK-6488: - Hey, [~Zentol] Here is the sample code for this

[jira] [Comment Edited] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

2017-06-07 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042036#comment-16042036 ] mingleizhang edited comment on FLINK-6643 at 6/8/17 1:06 AM: -

[jira] [Commented] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

2017-06-07 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042036#comment-16042036 ] mingleizhang commented on FLINK-6643: - Thanks for review [~till.rohrmann]. Just since

[jira] [Closed] (FLINK-6850) Links on "Powered by Flink" page not rendered correctly

2017-06-07 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-6850. --- Resolution: Won't Do > Links on "Powered by Flink" page not rendered correctly >

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

2017-06-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16041825#comment-16041825 ] ASF GitHub Bot commented on FLINK-6281: --- Github user haohui commented on a diff in t

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-06-07 Thread haohui
Github user haohui commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r120765156 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java --- @@ -202,14 +202,20 @@ public void writeRecord

[jira] [Commented] (FLINK-6833) Race condition: Asynchronous checkpointing task can fail completed StreamTask

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

[GitHub] flink issue #4058: [FLINK-6833] [task] Fail StreamTask only due to async exc...

2017-06-07 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4058 I would like to merge this PR if I could clarify all concerns and there are no further objections. --- If your project is set up for it, you can reply to this email and have your reply appear o

[jira] [Commented] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

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

[GitHub] flink issue #4049: [FLINK-6643] [JobManager] Flink restarts job in HA even i...

2017-06-07 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4049 Thanks for your contribution @zhangminglei. I fear, though, that we cannot merge your PR like it is since it prevents the job submission for all jobs which have `NoRestartStrategy` set. Furtherm

[jira] [Commented] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

2017-06-07 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16041775#comment-16041775 ] Till Rohrmann commented on FLINK-6643: -- I'm not sure whether this is actually a valid

[jira] [Commented] (FLINK-6833) Race condition: Asynchronous checkpointing task can fail completed StreamTask

2017-06-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16041755#comment-16041755 ] ASF GitHub Bot commented on FLINK-6833: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #4058: [FLINK-6833] [task] Fail StreamTask only due to as...

2017-06-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4058#discussion_r120757786 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -824,11 +824,14 @@ public ProcessingTimeSe

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120749951 --- Diff: docs/dev/table/sql.md --- @@ -22,20 +22,22 @@ specific language governing permissions and limitations under the License. --> -SQ

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120750870 --- Diff: docs/dev/table/sql.md --- @@ -22,20 +22,22 @@ specific language governing permissions and limitations under the License. --> -SQ

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120755990 --- Diff: docs/dev/table/sql.md --- @@ -217,7 +444,7 @@ Group windows are defined in the `GROUP BY` clause of a SQL query. Just like que

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120754779 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120755168 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120756834 --- Diff: docs/dev/table/sql.md --- @@ -340,18 +567,14 @@ val result4 = tableEnv.sql( {% top %} -### Limitations - -**TODO: Integ

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120754991 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120753514 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

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

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120755459 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120749760 --- Diff: docs/dev/table/sql.md --- @@ -22,20 +22,22 @@ specific language governing permissions and limitations under the License. --> -SQ

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120752386 --- Diff: docs/dev/table/sql.md --- @@ -82,14 +84,12 @@ val result2 = tableEnv.sql( -**TODO: Add some intro.** - {% top %}

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120752941 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120754137 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120750248 --- Diff: docs/dev/table/sql.md --- @@ -22,20 +22,22 @@ specific language governing permissions and limitations under the License. --> -SQ

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120753703 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120753745 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120754480 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120752761 --- Diff: docs/dev/table/sql.md --- @@ -163,31 +164,257 @@ For a better definition of SQL queries within a Java String, Flink SQL uses a le {% top

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4046#discussion_r120751070 --- Diff: docs/dev/table/sql.md --- @@ -22,20 +22,22 @@ specific language governing permissions and limitations under the License. --> -SQ

[jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2017-06-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822346#comment-15822346 ] Ted Yu edited comment on FLINK-5486 at 6/7/17 9:47 PM: --- Lock on Stat

[jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

2017-06-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4534: -- Description: Iteration over state.bucketStates is protected by synchronization in other methods, except for the

[jira] [Commented] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

2017-06-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16041664#comment-16041664 ] Ted Yu commented on FLINK-5488: --- Please also fix the following in deployInternal(): {code}

[jira] [Commented] (FLINK-6848) Extend the managed state docs with a Scala example

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

[GitHub] flink issue #4072: [FLINK-6848] Update managed state docs

2017-06-07 Thread Fokko
Github user Fokko commented on the issue: https://github.com/apache/flink/pull/4072 Hi @tzulitai, I fully agree. Give me some time to work on the other Scala examples, I need to make sure that they are working properly. I'll wrap it up this week. I'll update the commit and re

[jira] [Commented] (FLINK-6865) Expand checkstyle docs to include import in intellij

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

[GitHub] flink issue #4086: [FLINK-6865] Update checkstyle documentation

2017-06-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4086 Apart from the ImportOrder and AvoidStartImport modules everything that we could configure via IntelliJ Code Style seems to be covered. --- If your project is set up for it, you can reply to this ema

[jira] [Commented] (FLINK-6865) Expand checkstyle docs to include import in intellij

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

[GitHub] flink issue #4086: [FLINK-6865] Update checkstyle documentation

2017-06-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4086 Here's a list of the currently supported modules btw.: ``` EmptyLineSeparator FileTabCharacter Indentation LeftCurly LineLength NeedBraces NoWhitespacesBefore Whitesp

[jira] [Commented] (FLINK-6865) Expand checkstyle docs to include import in intellij

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

[GitHub] flink issue #4086: [FLINK-6865] Update checkstyle documentation

2017-06-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4086 I don't know a lot about the intellij code style config; can we only define subset that is imported without affecting the rest? Btw., I'm looking into contributing to the checkstyle plugin to

[jira] [Commented] (FLINK-6865) Expand checkstyle docs to include import in intellij

2017-06-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16041533#comment-16041533 ] ASF GitHub Bot commented on FLINK-6865: --- Github user greghogan commented on the issu

[GitHub] flink issue #4086: [FLINK-6865] Update checkstyle documentation

2017-06-07 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4086 Okay, second best may be to create an IntelliJ Code Style configuration for developers to import. --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

[jira] [Commented] (FLINK-6865) Expand checkstyle docs to include import in intellij

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

[GitHub] flink issue #4086: [FLINK-6865] Update checkstyle documentation

2017-06-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4086 Only a (small) subset of checkstyle modules can be moduled, which sadly doesn't include the `ImportOrder` module. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Updated] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

2017-06-07 Thread SmedbergM (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] SmedbergM updated FLINK-6866: - Description: MWE: ``` import scala.collection.JavaConverters._ import org.apache.flink.api.java.ClosureCl

[jira] [Updated] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

2017-06-07 Thread SmedbergM (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] SmedbergM updated FLINK-6866: - Description: MWE: ``` import scala.collection.JavaConverters._ import org.apache.flink.api.java.ClosureCl

[jira] [Created] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

2017-06-07 Thread SmedbergM (JIRA)
SmedbergM created FLINK-6866: Summary: ClosureCleaner.clean fails for scala's JavaConverters wrapper classes Key: FLINK-6866 URL: https://issues.apache.org/jira/browse/FLINK-6866 Project: Flink

[jira] [Resolved] (FLINK-6815) Javadocs don't work anymore in Flink 1.4-SNAPSHOT

2017-06-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-6815. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.1 1.4: http://git-wip-us.

[jira] [Commented] (FLINK-6865) Expand checkstyle docs to include import in intellij

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

[GitHub] flink issue #4086: [FLINK-6865] Update checkstyle documentation

2017-06-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4086 Something the import did in fact set was spaces around operators. It may be that not all checkstyle rules are properly imported. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-6865) Expand checkstyle docs to include import in intellij

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

[GitHub] flink issue #4086: [FLINK-6865] Update checkstyle documentation

2017-06-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4086 hmmi just retried it and it didn't work this time. Let me investigate a bit. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If you

[GitHub] flink issue #4086: [FLINK-6865] Update checkstyle documentation

2017-06-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4086 yes, it's a good idea to "flip" the checkstyle names. I only checked a few things, but importing the checkstyle configuration, with the Checkstyle-IDEA plugin enabled, at the very least correc

[jira] [Commented] (FLINK-6865) Expand checkstyle docs to include import in intellij

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

[jira] [Resolved] (FLINK-6830) Add ITTests for savepoint migration from 1.3

2017-06-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6830. Resolution: Fixed Fix Version/s: 1.4.0 Fixed for master via 3792be4b5f80826d5

[jira] [Closed] (FLINK-6830) Add ITTests for savepoint migration from 1.3

2017-06-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6830. -- > Add ITTests for savepoint migration from 1.3 > ---

[jira] [Resolved] (FLINK-6853) Migrating from Flink 1.1 fails for FlinkCEP

2017-06-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6853. Resolution: Fixed Fix Version/s: 1.4.0 1.3.1 Fixed for mas

[jira] [Resolved] (FLINK-6808) Stream join fails when checkpointing is enabled

2017-06-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6808. Resolution: Fixed Fixed for 1.3.1 via f74caf7062b1cc23a704f8f8b8171be430b60807. Fixe

[jira] [Closed] (FLINK-6853) Migrating from Flink 1.1 fails for FlinkCEP

2017-06-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6853. -- > Migrating from Flink 1.1 fails for FlinkCEP > ---

[jira] [Closed] (FLINK-6844) TraversableSerializer should implement compatibility methods

2017-06-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6844. -- > TraversableSerializer should implement compatibility methods > ---

[jira] [Resolved] (FLINK-6844) TraversableSerializer should implement compatibility methods

2017-06-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6844. Resolution: Fixed Fix Version/s: 1.4.0 Fixed for 1.3 via e1e207c898ed436df656

[jira] [Commented] (FLINK-6841) using TableSourceTable for both Stream and Batch OR remove useless import

2017-06-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16041179#comment-16041179 ] ASF GitHub Bot commented on FLINK-6841: --- Github user sunjincheng121 commented on the

[GitHub] flink issue #4061: [FLINK-6841][table]Using TableSourceTable for both Stream...

2017-06-07 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4061 Hi @twalthr I think `DefinedProctimeAttribute` can be implemented by a batch table source. If we do not want a batch table source can implements `DefinedProctimeAttribute `, we should add move

[jira] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

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

[jira] [Commented] (FLINK-6808) Stream join fails when checkpointing is enabled

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

[jira] [Commented] (FLINK-6853) Migrating from Flink 1.1 fails for FlinkCEP

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

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

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

[GitHub] flink pull request #4081: [FLINK-6844] [scala] Implement compatibility metho...

2017-06-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4081 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

  1   2   3   >