[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976003#comment-15976003 ] tianyou commented on BEAM-1789: --- I change _Window.Bound> fixWindow = Window.> into(FixedWind

[jira] [Comment Edited] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976003#comment-15976003 ] tianyou edited comment on BEAM-1789 at 4/20/17 3:31 AM: I change _*

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: I change *Window.Bound> fixWindow = Window.> into(FixedWindows.of(size));* to *Windo

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976002#comment-15976002 ] tianyou commented on BEAM-1789: --- I change *Window.Bound> fixWindow = Window.> into(FixedWind

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: I change *Window.Bound> fixWindow = Window.> into( FixedWindows.of(size) );* to *Wind

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976000#comment-15976000 ] tianyou commented on BEAM-1789: --- I change *Window.Bound> fixWindow = Window.> into( FixedWin

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: I change _Window.Bound> fixWindow = Window.> into( FixedWindows.of(size) );_ to _Win

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975999#comment-15975999 ] tianyou commented on BEAM-1789: --- I change _Window.Bound> fixWindow = Window.> into( FixedWi

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975997#comment-15975997 ] tianyou commented on BEAM-1789: --- bq ttt bq > window can't not use in spark cluster module >

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975998#comment-15975998 ] tianyou commented on BEAM-1789: --- bq. Some block quoted text > window can't not use in spark

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: bq. Some block quoted text) > window can't not use in spark cluster module >

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: bq ttt bq) > window can't not use in spark cluster module >

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975996#comment-15975996 ] tianyou commented on BEAM-1789: --- ??ffdsafds?? > window can't not use in spark cluster module

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: ??ffdsafds??) > window can't not use in spark cluster module > --

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975992#comment-15975992 ] tianyou commented on BEAM-1789: --- *黑体* > window can't not use in spark cluster module > -

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: *黑体*) > window can't not use in spark cluster module > --

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975989#comment-15975989 ] tianyou commented on BEAM-1789: --- Test _emphasis_ ttt _emphasis_ > window can't not use in sp

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: Test _emphasis_ ttt _emphasis_) > window can't not use in spark cluster module >

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975988#comment-15975988 ] tianyou commented on BEAM-1789: --- I change *strong*Window.Bound> fixWindow = Window.> into(Fi

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: I change *strong*Window.Bound> fixWindow = Window.> into(FixedWindows.of(size));*stro

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15973907#comment-15973907 ] tianyou commented on BEAM-1789: --- [~amitsela] Today，I try this code with 0.5 version of Beam.

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966945#comment-15966945 ] tianyou commented on BEAM-1789: --- [~amitsela] Yes I can't find anything ERROR or WARNING messa

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: !attached-image.gif!) > window can't not use in spark cluster module > --

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965618#comment-15965618 ] tianyou commented on BEAM-1789: --- !attached-image.gif! > window can't not use in spark cluste

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965611#comment-15965611 ] tianyou commented on BEAM-1789: --- [~amitsela] Yes,I expect the log of System.out.println to sh

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965466#comment-15965466 ] tianyou commented on BEAM-1789: --- [~amitsela] Hello, Do you test the above code in cluster mo

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15939976#comment-15939976 ] tianyou commented on BEAM-1789: --- [~amitsela]Do you test the above code in cluster mode of spa

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938051#comment-15938051 ] tianyou commented on BEAM-1789: --- [~amitsela]Today,I Use WindowedWordCount example of Beam. an

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938039#comment-15938039 ] tianyou commented on BEAM-1789: --- [~amitsela] I see all logs of this job.I can't find it. > w

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938022#comment-15938022 ] tianyou commented on BEAM-1789: --- [~amitsela] I use spark local model,the code of above is wor

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938017#comment-15938017 ] tianyou commented on BEAM-1789: --- [~amitsela]　I use 0.7.0-SNAPSHOT version of Beam.I find logs

[jira] [Created] (BEAM-1789) window can't not use in spark cluster module

tianyou created BEAM-1789: - Summary: window can't not use in spark cluster module Key: BEAM-1789 URL: https://issues.apache.org/jira/browse/BEAM-1789 Project: Beam Issue Type: Bug Component