[jira] [Updated] (FLINK-6637) Move registerFunction to TableEnvironment

2017-05-23 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-6637: - Component/s: Table API & SQL > Move registerFunction to TableEnvironment >

[jira] [Commented] (FLINK-6613) OOM during reading big messages from Kafka

2017-05-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022285#comment-16022285 ] Tzu-Li (Gordon) Tai commented on FLINK-6613: +1 to what [~rmetzger] mentioned. The Kafka

[jira] [Comment Edited] (FLINK-6613) OOM during reading big messages from Kafka

2017-05-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022285#comment-16022285 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6613 at 5/24/17 4:10 AM: -

[jira] [Comment Edited] (FLINK-6613) OOM during reading big messages from Kafka

2017-05-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022285#comment-16022285 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6613 at 5/24/17 4:12 AM: -

[jira] [Comment Edited] (FLINK-6613) OOM during reading big messages from Kafka

2017-05-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022285#comment-16022285 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6613 at 5/24/17 4:13 AM: -

[jira] [Comment Edited] (FLINK-6613) OOM during reading big messages from Kafka

2017-05-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022285#comment-16022285 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6613 at 5/24/17 4:11 AM: -

[jira] [Comment Edited] (FLINK-6613) OOM during reading big messages from Kafka

2017-05-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022285#comment-16022285 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6613 at 5/24/17 4:12 AM: -

[jira] [Comment Edited] (FLINK-6613) OOM during reading big messages from Kafka

2017-05-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022285#comment-16022285 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6613 at 5/24/17 4:12 AM: -

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

2017-05-23 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022231#comment-16022231 ] Fang Yong commented on FLINK-6494: -- If so, I think another two subtasks should be created to migrate

[jira] [Commented] (FLINK-6477) The first time to click Taskmanager cannot get the actual data

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022183#comment-16022183 ] ASF GitHub Bot commented on FLINK-6477: --- Github user chenzio commented on the issue:

[GitHub] flink issue #3971: [FLINK-6477][web] Waiting the metrics retrieved from the ...

2017-05-23 Thread chenzio
Github user chenzio commented on the issue: https://github.com/apache/flink/pull/3971 @zentol This is just an exception possible, in the normal scene will not happen, BTW, whether the update interval reduced to 1s will be better --- If your project is set up for it, you can reply

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

2017-05-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822346#comment-15822346 ] Ted Yu edited comment on FLINK-5486 at 5/24/17 12:14 AM: - Lock on

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

2017-05-23 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

[jira] [Commented] (FLINK-6693) Support DATE_FORMAT function in the SQL API

2017-05-23 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022107#comment-16022107 ] Zhenqiu Huang commented on FLINK-6693: -- I am interested with this task. If you haven't started work

[jira] [Created] (FLINK-6693) Support DATE_FORMAT function in the SQL API

2017-05-23 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-6693: - Summary: Support DATE_FORMAT function in the SQL API Key: FLINK-6693 URL: https://issues.apache.org/jira/browse/FLINK-6693 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-6672) Support CAST(timestamp AS BIGINT)

2017-05-23 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6672: - Assignee: Haohui Mai > Support CAST(timestamp AS BIGINT) > - > >

[jira] [Updated] (FLINK-6692) The flink-dist jar contains unshaded netty jar

2017-05-23 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6692: -- Summary: The flink-dist jar contains unshaded netty jar (was: The flink-dist jar contains unshaded

[jira] [Created] (FLINK-6692) The flink-dist jar contains unshaded nettyjar

2017-05-23 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-6692: - Summary: The flink-dist jar contains unshaded nettyjar Key: FLINK-6692 URL: https://issues.apache.org/jira/browse/FLINK-6692 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-6692) The flink-dist jar contains unshaded nettyjar

2017-05-23 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6692: -- Component/s: Build System > The flink-dist jar contains unshaded nettyjar >

[jira] [Commented] (FLINK-6613) OOM during reading big messages from Kafka

2017-05-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021747#comment-16021747 ] Robert Metzger commented on FLINK-6613: --- There are some options in the Kafka consumer (that you can

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021708#comment-16021708 ] ASF GitHub Bot commented on FLINK-6687: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3973: [FLINK-6687] [web] Activate strict checkstyle for flink-r...

2017-05-23 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3973 +1 --- 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

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021701#comment-16021701 ] ASF GitHub Bot commented on FLINK-6687: --- Github user zentol commented on the issue:

[GitHub] flink issue #3973: [FLINK-6687] [web] Activate strict checkstyle for flink-r...

2017-05-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3973 @greghogan I've added a separate import block for scala and addressed all comments. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-6690) Rescaling broken

2017-05-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021694#comment-16021694 ] Stefan Richter commented on FLINK-6690: --- I have found the cause in a bug that was introduced as part

[jira] [Created] (FLINK-6691) Add checkstyle import block rule for scala imports

2017-05-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6691: --- Summary: Add checkstyle import block rule for scala imports Key: FLINK-6691 URL: https://issues.apache.org/jira/browse/FLINK-6691 Project: Flink Issue

[jira] [Created] (FLINK-6690) Rescaling broken

2017-05-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6690: --- Summary: Rescaling broken Key: FLINK-6690 URL: https://issues.apache.org/jira/browse/FLINK-6690 Project: Flink Issue Type: Bug Components:

[jira] [Issue Comment Deleted] (FLINK-4719) KryoSerializer random exception

2017-05-23 Thread Joshua Griffith (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joshua Griffith updated FLINK-4719: --- Comment: was deleted (was: I'm also experiencing this issue when using the distinct

[jira] [Commented] (FLINK-4719) KryoSerializer random exception

2017-05-23 Thread Joshua Griffith (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021656#comment-16021656 ] Joshua Griffith commented on FLINK-4719: I'm also experiencing this issue when using the distinct

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021653#comment-16021653 ] ASF GitHub Bot commented on FLINK-6687: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021650#comment-16021650 ] ASF GitHub Bot commented on FLINK-6687: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #3973: [FLINK-6687] [web] Activate strict checkstyle for ...

2017-05-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3973#discussion_r118075328 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/RequestHandler.java --- @@ -36,13 +37,15 @@ * respond with a

[GitHub] flink pull request #3973: [FLINK-6687] [web] Activate strict checkstyle for ...

2017-05-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3973#discussion_r118075403 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/RuntimeMonitorHandler.java --- @@ -29,15 +34,8 @@ import

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021621#comment-16021621 ] ASF GitHub Bot commented on FLINK-6687: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021619#comment-16021619 ] ASF GitHub Bot commented on FLINK-6687: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021618#comment-16021618 ] ASF GitHub Bot commented on FLINK-6687: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021623#comment-16021623 ] ASF GitHub Bot commented on FLINK-6687: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021622#comment-16021622 ] ASF GitHub Bot commented on FLINK-6687: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021620#comment-16021620 ] ASF GitHub Bot commented on FLINK-6687: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request #3973: [FLINK-6687] [web] Activate strict checkstyle for ...

2017-05-23 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3973#discussion_r118071367 --- Diff: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/checkpoints/CheckpointStatsSubtaskDetailsHandlerTest.java --- @@

[GitHub] flink pull request #3973: [FLINK-6687] [web] Activate strict checkstyle for ...

2017-05-23 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3973#discussion_r118060440 --- Diff: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/metrics/MetricStoreTest.java --- @@ -15,17 +15,22 @@ * See the

[GitHub] flink pull request #3973: [FLINK-6687] [web] Activate strict checkstyle for ...

2017-05-23 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3973#discussion_r118071671 --- Diff: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/metrics/TaskManagerMetricsHandlerTest.java --- @@ -33,6 +34,9 @@

[GitHub] flink pull request #3973: [FLINK-6687] [web] Activate strict checkstyle for ...

2017-05-23 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3973#discussion_r118058165 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -100,26 +101,27 @@

[GitHub] flink pull request #3973: [FLINK-6687] [web] Activate strict checkstyle for ...

2017-05-23 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3973#discussion_r118056115 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/RuntimeMonitorHandler.java --- @@ -29,15 +34,8 @@ import

[GitHub] flink pull request #3973: [FLINK-6687] [web] Activate strict checkstyle for ...

2017-05-23 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3973#discussion_r118057623 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/RequestHandler.java --- @@ -36,13 +37,15 @@ * respond

[jira] [Resolved] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6662. -- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.4.0:

[jira] [Commented] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021599#comment-16021599 ] ASF GitHub Bot commented on FLINK-6662: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3972: [FLINK-6662] [errMsg] Improve error message if rec...

2017-05-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3972 --- 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

[jira] [Commented] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021589#comment-16021589 ] ASF GitHub Bot commented on FLINK-6662: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021591#comment-16021591 ] ASF GitHub Bot commented on FLINK-6662: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #3972: [FLINK-6662] [errMsg] Improve error message if recovery f...

2017-05-23 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3972 Thanks for the review @zentol. --- 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

[GitHub] flink pull request #3972: [FLINK-6662] [errMsg] Improve error message if rec...

2017-05-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3972#discussion_r118068470 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java --- @@ -376,8 +377,14 @@ private

[jira] [Commented] (FLINK-6658) Use scala Collections in scala CEP API

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021514#comment-16021514 ] ASF GitHub Bot commented on FLINK-6658: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #3963: [FLINK-6658][cep] Use scala Collections in scala C...

2017-05-23 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/3963#discussion_r118055738 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala --- @@ -296,25 +294,94 @@ class

[jira] [Commented] (FLINK-6658) Use scala Collections in scala CEP API

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021497#comment-16021497 ] ASF GitHub Bot commented on FLINK-6658: --- Github user kl0u commented on a diff in the pull request:

[GitHub] flink pull request #3963: [FLINK-6658][cep] Use scala Collections in scala C...

2017-05-23 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/3963#discussion_r118051044 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala --- @@ -296,25 +294,94 @@ class

[jira] [Commented] (FLINK-6658) Use scala Collections in scala CEP API

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021495#comment-16021495 ] ASF GitHub Bot commented on FLINK-6658: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #3963: [FLINK-6658][cep] Use scala Collections in scala C...

2017-05-23 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/3963#discussion_r118050667 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala --- @@ -296,25 +294,94 @@ class

[jira] [Created] (FLINK-6689) Remote StreamExecutionEnvironment fails to submit jobs against LocalFlinkMiniCluster

2017-05-23 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-6689: -- Summary: Remote StreamExecutionEnvironment fails to submit jobs against LocalFlinkMiniCluster Key: FLINK-6689 URL: https://issues.apache.org/jira/browse/FLINK-6689

[jira] [Commented] (FLINK-6038) Add deep links to Apache Bahir Flink streaming connector documentations

2017-05-23 Thread David Anderson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021471#comment-16021471 ] David Anderson commented on FLINK-6038: --- I'm thinking of linking to the github READMEs rather than

[jira] [Created] (FLINK-6688) Activate strict checkstyle in flink-test-utils

2017-05-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6688: --- Summary: Activate strict checkstyle in flink-test-utils Key: FLINK-6688 URL: https://issues.apache.org/jira/browse/FLINK-6688 Project: Flink Issue

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021433#comment-16021433 ] ASF GitHub Bot commented on FLINK-6687: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3973: [FLINK-6687] [web] Activate strict checkstyle for ...

2017-05-23 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3973 [FLINK-6687] [web] Activate strict checkstyle for flink-runtime-web Lot's of missing javadocs, trailing spaces in javadocs, trailing tabs and missing dots. Very little code is affected.

[jira] [Created] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6687: --- Summary: Activate strict checkstyle for flink-runtime-web Key: FLINK-6687 URL: https://issues.apache.org/jira/browse/FLINK-6687 Project: Flink Issue

[jira] [Commented] (FLINK-6650) Fix Non-windowed group-aggregate error when using append-table mode.

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021414#comment-16021414 ] ASF GitHub Bot commented on FLINK-6650: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #3958: [FLINK-6650][table] Improve the error message for toAppen...

2017-05-23 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3958 Hi @twalthr Thanks for review the PR. I have updated the PR. According your comment. Best, SunJincheng --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-6650) Fix Non-windowed group-aggregate error when using append-table mode.

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021408#comment-16021408 ] ASF GitHub Bot commented on FLINK-6650: --- Github user sunjincheng121 commented on a diff in the pull

[GitHub] flink pull request #3958: [FLINK-6650][table] Improve the error message for ...

2017-05-23 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3958#discussion_r118038355 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala --- @@ -629,8 +629,7 @@ abstract class

[jira] [Created] (FLINK-6686) Improve UDXF(UDF,UDTF,UDAF) test case

2017-05-23 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6686: -- Summary: Improve UDXF(UDF,UDTF,UDAF) test case Key: FLINK-6686 URL: https://issues.apache.org/jira/browse/FLINK-6686 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-6617) Improve JAVA and SCALA logical plans consistent test

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021398#comment-16021398 ] ASF GitHub Bot commented on FLINK-6617: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #3943: [FLINK-6617][table] Improve JAVA and SCALA logical plans ...

2017-05-23 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3943 Hi @twalthr Thanks a log for your reviewing. I completely agree with your suggestions. I petty want refactoring the test structure. I have updated the PR. according your comments.

[jira] [Commented] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

2017-05-23 Thread Yassine Marzougui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021344#comment-16021344 ] Yassine Marzougui commented on FLINK-6515: -- Yes, I used flink.version=1.4-SNAPSHOT in the user

[jira] [Commented] (FLINK-6432) Activate strict checkstyle for flink-python

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021341#comment-16021341 ] ASF GitHub Bot commented on FLINK-6432: --- Github user greghogan commented on the issue:

[jira] [Commented] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021337#comment-16021337 ] ASF GitHub Bot commented on FLINK-6662: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink issue #3969: [FLINK-6432] [py] Activate strict checkstyle for flink-py...

2017-05-23 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3969 +1 to merge after Travis gives the green light. --- 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

[GitHub] flink pull request #3972: [FLINK-6662] [errMsg] Improve error message if rec...

2017-05-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3972#discussion_r118026253 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java --- @@ -376,8 +377,14 @@ private static

[jira] [Commented] (FLINK-6675) Activate strict checkstyle for flink-annotations

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021327#comment-16021327 ] ASF GitHub Bot commented on FLINK-6675: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3970: [FLINK-6675] Activate strict checkstyle for flink-annotat...

2017-05-23 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3970 +1 to merge after Travis gives the green light. --- 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

[GitHub] flink issue #3968: [FLINK-6431] [metrics] Activate strict checkstyle in flin...

2017-05-23 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3968 +1 to merge after Travis gives the green light. --- 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

[jira] [Commented] (FLINK-6431) Activate strict checkstyle for flink-metrics

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021326#comment-16021326 ] ASF GitHub Bot commented on FLINK-6431: --- Github user greghogan commented on the issue:

[jira] [Commented] (FLINK-6654) missing maven dependency on "flink-shaded-hadoop2-uber" in flink-dist

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021323#comment-16021323 ] ASF GitHub Bot commented on FLINK-6654: --- Github user NicoK commented on the issue:

[GitHub] flink issue #3960: [FLINK-6654][build] let 'flink-dist' properly depend on '...

2017-05-23 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/3960 you probably need to clean up your whole source with `mvn clean` and try from there - I'm not quite sure, my initial command will clean up everything that is not in the dependencies of the flink-dist

[jira] [Commented] (FLINK-6431) Activate strict checkstyle for flink-metrics

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021318#comment-16021318 ] ASF GitHub Bot commented on FLINK-6431: --- Github user zentol commented on the issue:

[GitHub] flink issue #3968: [FLINK-6431] [metrics] Activate strict checkstyle in flin...

2017-05-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3968 I've included the sources, change the path and added the removed comment. Moving on to the other 2 checkstyle PRs... --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-6431) Activate strict checkstyle for flink-metrics

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021291#comment-16021291 ] ASF GitHub Bot commented on FLINK-6431: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #3968: [FLINK-6431] [metrics] Activate strict checkstyle ...

2017-05-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3968#discussion_r118016840 --- Diff: flink-metrics/pom.xml --- @@ -60,4 +60,42 @@ under the License. + + +

[jira] [Commented] (FLINK-6654) missing maven dependency on "flink-shaded-hadoop2-uber" in flink-dist

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021287#comment-16021287 ] ASF GitHub Bot commented on FLINK-6654: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #3960: [FLINK-6654][build] let 'flink-dist' properly depend on '...

2017-05-23 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3960 Not sure about the initial issue. For me the command worked (without yoru changes on the 1.3 branch) ``` [INFO]

[jira] [Commented] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

2017-05-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021275#comment-16021275 ] Robert Metzger commented on FLINK-6515: --- Are you sure that you've re-build your user code using he

[jira] [Resolved] (FLINK-6660) expand the streaming connectors overview page

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

[jira] [Resolved] (FLINK-6492) Unclosed DataOutputViewStream in GenericArraySerializerConfigSnapshot#write()

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

[jira] [Commented] (FLINK-6492) Unclosed DataOutputViewStream in GenericArraySerializerConfigSnapshot#write()

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021252#comment-16021252 ] ASF GitHub Bot commented on FLINK-6492: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6660) expand the streaming connectors overview page

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021253#comment-16021253 ] ASF GitHub Bot commented on FLINK-6660: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3898: [FLINK-6492] Fix unclosed DataOutputViewStream usa...

2017-05-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3898 --- 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

[GitHub] flink pull request #3964: [FLINK-6660][docs] expand the connectors overview ...

2017-05-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3964 --- 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

[jira] [Commented] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

2017-05-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021248#comment-16021248 ] Stefan Richter commented on FLINK-6537: --- So this is not strictly related to incremental checkpoints,

[jira] [Commented] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021206#comment-16021206 ] ASF GitHub Bot commented on FLINK-6662: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #3972: [FLINK-6662] [errMsg] Improve error message if rec...

2017-05-23 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3972 [FLINK-6662] [errMsg] Improve error message if recovery from RetrievableStateHandles fails When recovering state from a ZooKeeperStateHandleStore it can happen that the deserialization

[jira] [Commented] (FLINK-6660) expand the streaming connectors overview page

2017-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021198#comment-16021198 ] ASF GitHub Bot commented on FLINK-6660: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #3964: [FLINK-6660][docs] expand the connectors overview page

2017-05-23 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3964 "3rd party connectors" doesn't seem suitable. There are also some self hosted connectors, AFAIK. Perhaps simply "Connectors in Apache Bahir"? Either way, I'll proceed to merge this. The naming

  1   2   3   >