[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

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

[GitHub] flink pull request #3338: [FLINK-5414] [table] Bump up Calcite version to 1....

2017-02-17 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/3338 [FLINK-5414] [table] Bump up Calcite version to 1.11 Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your

[jira] [Commented] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

2017-02-17 Thread Xiaowei Jiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871411#comment-15871411 ] Xiaowei Jiang commented on FLINK-5826: -- You can look at the signature when you do cod

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871428#comment-15871428 ] Dawid Wysakowicz commented on FLINK-5824: - I would be glad to help with this issue

[GitHub] flink issue #1962: [FLINK-3857][Streaming Connectors]Add reconnect attempt t...

2017-02-17 Thread sbcd90
Github user sbcd90 commented on the issue: https://github.com/apache/flink/pull/1962 Hello @tzulitai , I have rebased the changes. Can you please review? --- 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 pr

[jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host

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

[jira] [Assigned] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5824: -- Assignee: Dawid Wysakowicz > Fix String/byte conversions without explicit encoding > --

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871455#comment-15871455 ] Ufuk Celebi commented on FLINK-5824: [~dawidwys] I've just assigned it to you. [~Step

[jira] [Assigned] (FLINK-5586) Extend TableProgramsTestBase for object reuse modes

2017-02-17 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-5586: - Assignee: Kurt Young > Extend TableProgramsTestBase for object reuse modes >

[jira] [Commented] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts.

2017-02-17 Thread Wenlong Lyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871461#comment-15871461 ] Wenlong Lyu commented on FLINK-5817: [~shijinkui] I think the reason why you want to c

[jira] [Commented] (FLINK-5586) Extend TableProgramsTestBase for object reuse modes

2017-02-17 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871463#comment-15871463 ] Kurt Young commented on FLINK-5586: --- It looks like {{TableProgramsTestBase}} is only use

[jira] [Commented] (FLINK-5825) In yarn mode, a small pic can not be loaded

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

[GitHub] flink issue #3337: [FLINK-5825][UI]make the cite path relative to show it co...

2017-02-17 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3337 Thanks for the pull request. Let me try this out and merge it if everything works as expected. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[GitHub] flink pull request #3339: [FLINK-5586] [table] Extend TableProgramsClusterTe...

2017-02-17 Thread KurtYoung
GitHub user KurtYoung opened a pull request: https://github.com/apache/flink/pull/3339 [FLINK-5586] [table] Extend TableProgramsClusterTestBase for object reuse mode Make all cluster-based ITCases verified in object reuse mode. This only includes batch table tests now. You can mer

[jira] [Commented] (FLINK-5586) Extend TableProgramsTestBase for object reuse modes

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

[GitHub] flink pull request #3340: [FLINK-5703][runtime]Job manager failure recovery ...

2017-02-17 Thread wangzhijiang999
GitHub user wangzhijiang999 opened a pull request: https://github.com/apache/flink/pull/3340 [FLINK-5703][runtime]Job manager failure recovery via reconciliation with TaskManager reports This is part of [Non-disruptive JobManager Failures via Reconciliation ](https://issues.apache.

[jira] [Commented] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871499#comment-15871499 ] ASF GitHub Bot commented on FLINK-5703: --- GitHub user wangzhijiang999 opened a pull r

[GitHub] flink pull request #3341: [FLINK-5817]Fix test concurrent execution failure ...

2017-02-17 Thread wenlong88
GitHub user wenlong88 opened a pull request: https://github.com/apache/flink/pull/3341 [FLINK-5817]Fix test concurrent execution failure by test dir conflicts. use TemporaryFold to create temp files and folds for UT You can merge this pull request into a Git repository by running:

[jira] [Commented] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts.

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

[jira] [Created] (FLINK-5827) Compile error when do filter after join a udtf which returns a POJO type

2017-02-17 Thread kaibo.zhou (JIRA)
kaibo.zhou created FLINK-5827: - Summary: Compile error when do filter after join a udtf which returns a POJO type Key: FLINK-5827 URL: https://issues.apache.org/jira/browse/FLINK-5827 Project: Flink

[jira] [Created] (FLINK-5828) BlobServer create cache dir has concurrency safety problem

2017-02-17 Thread ZhengBowen (JIRA)
ZhengBowen created FLINK-5828: - Summary: BlobServer create cache dir has concurrency safety problem Key: FLINK-5828 URL: https://issues.apache.org/jira/browse/FLINK-5828 Project: Flink Issue Type

[jira] [Closed] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators

2017-02-17 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-3841. - Resolution: Not A Problem Fix Version/s: 1.2.0 Not a problem any more. Will close this beca

[jira] [Updated] (FLINK-5827) Compile error when do filter after join a udtf which returns a POJO type

2017-02-17 Thread kaibo.zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaibo.zhou updated FLINK-5827: -- Description: The test case: {code:title=testFilterUdtfOutputPojo} @Test def testFilterUdtfOutputPojo(

[jira] [Updated] (FLINK-5827) Compile error when do filter after join a udtf which returns a POJO type

2017-02-17 Thread kaibo.zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaibo.zhou updated FLINK-5827: -- Description: The test case: {code:title=testFilterUdtfOutputPojo} @Test def testFilterUdtfOutputPojo(

[jira] [Commented] (FLINK-5827) Compile error when do filter after join a udtf which returns a POJO type

2017-02-17 Thread kaibo.zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871530#comment-15871530 ] kaibo.zhou commented on FLINK-5827: --- Patch is ready but i have no permission assign to m

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

2017-02-17 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871538#comment-15871538 ] Stefan Richter commented on FLINK-2491: --- This seems still valid, but I assume it is

[jira] [Commented] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871544#comment-15871544 ] ASF GitHub Bot commented on FLINK-5703: --- Github user wangzhijiang999 commented on th

[GitHub] flink issue #3340: [FLINK-5703][runtime]Job manager failure recovery via rec...

2017-02-17 Thread wangzhijiang999
Github user wangzhijiang999 commented on the issue: https://github.com/apache/flink/pull/3340 @StephanEwen , wish your reviews. Thank you for any 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 your project d

[jira] [Updated] (FLINK-4856) Add MapState for keyed streams

2017-02-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4856: Component/s: DataStream API > Add MapState for keyed streams > -

[GitHub] flink pull request #3342: TO FLINK-5828

2017-02-17 Thread bwzheng2010
GitHub user bwzheng2010 opened a pull request: https://github.com/apache/flink/pull/3342 TO FLINK-5828 flip the logic to resolve currency safety problem [flink-runtime] https://issues.apache.org/jira/browse/FLINK-5828 fix currency safety problem for this issue

[jira] [Commented] (FLINK-5828) BlobServer create cache dir has concurrency safety problem

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871553#comment-15871553 ] ASF GitHub Bot commented on FLINK-5828: --- GitHub user bwzheng2010 opened a pull reque

[jira] [Updated] (FLINK-5827) Exception when do filter after join a udtf which returns a POJO type

2017-02-17 Thread kaibo.zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaibo.zhou updated FLINK-5827: -- Summary: Exception when do filter after join a udtf which returns a POJO type (was: Compile error when

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

2017-02-17 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871572#comment-15871572 ] Stefan Richter commented on FLINK-1725: --- I agree with you [~aljoscha]. While this wo

[jira] [Commented] (FLINK-5792) Improve “UDF/UDTF" to support constructor with parameter.

2017-02-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871584#comment-15871584 ] sunjincheng commented on FLINK-5792: HI,[~clarkyzl] Thanks for your attention to this

[jira] [Commented] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871600#comment-15871600 ] ASF GitHub Bot commented on FLINK-5795: --- Github user sunjincheng121 commented on a d

[GitHub] flink pull request #3330: [FLINK-5795][TableAPI&SQL] Improve UDTF to support...

2017-02-17 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3330#discussion_r101726090 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetUserDefinedFunctionITCase.scala --- @@ -0,0 +1,75

[GitHub] flink pull request #3338: [FLINK-5414] [table] Bump up Calcite version to 1....

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3338#discussion_r101728056 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/ExpressionReducer.scala --- @@ -106,8 +106,16 @@ class ExpressionReducer

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

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

[GitHub] flink issue #3338: [FLINK-5414] [table] Bump up Calcite version to 1.11

2017-02-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3338 @twalthr, you might want to have a look at the `FlinkTypeFactory` changes --- 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 proje

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

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

[jira] [Commented] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

2017-02-17 Thread Zhuoluo Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871634#comment-15871634 ] Zhuoluo Yang commented on FLINK-5826: - Thanks [~jiangxw]. After some investigation on

[jira] [Created] (FLINK-5829) Bump Calcite version to 1.12 once available

2017-02-17 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-5829: Summary: Bump Calcite version to 1.12 once available Key: FLINK-5829 URL: https://issues.apache.org/jira/browse/FLINK-5829 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-5830) OutOfMemoryError during notify final state in TaskExecutor may cause job stuck

2017-02-17 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5830: Summary: OutOfMemoryError during notify final state in TaskExecutor may cause job stuck Key: FLINK-5830 URL: https://issues.apache.org/jira/browse/FLINK-5830 Project:

[jira] [Updated] (FLINK-5545) remove FlinkAggregateExpandDistinctAggregatesRule when we upgrade calcite

2017-02-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5545: - Issue Type: Sub-task (was: Bug) Parent: FLINK-5829 > remove FlinkAggregateExpandDistinctA

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r101733431 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/AggregationsITCase.scala --- @@ -213,34 +213,45 @@ class Agg

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

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

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

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

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

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

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r101732154 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetAggregateWithNullValuesRule.scala --- @@ -51,7 +51,7 @

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

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

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r101735785 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/FlinkAggregateExpandDistinctAggregatesRule.java --- @@ -0,0 +

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r101733413 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/AggregationsITCase.scala --- @@ -213,34 +213,45 @@ class Agg

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

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

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r101732097 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetAggregateRule.scala --- @@ -45,7 +45,7 @@ class DataSe

[GitHub] flink issue #3107: [FLINK-5441] [table] Directly allow SQL queries on a Tabl...

2017-02-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3107 Hi, I like @twalthr's suggestion to use `env.sql("SELECT * FROM _ JOIN _", table, otherTable)`. I'd also be fine with slf4j syntax as @wuchong proposed. What do you think @KurtYoung? -

[jira] [Commented] (FLINK-5441) Directly allow SQL queries on a Table

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

[GitHub] flink pull request #3343: [FLINK-5402] Fails AkkaRpcServiceTest#testTerminat...

2017-02-17 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3343 [FLINK-5402] Fails AkkaRpcServiceTest#testTerminationFuture On macOS this test fails consistently as the actorSystem creation already causes timeout. Unfortunately the actorSystem and rpcServic

[jira] [Commented] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

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

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871722#comment-15871722 ] Stephan Ewen commented on FLINK-5824: - I think some names in checkpoints are serialize

[GitHub] flink issue #3342: TO FLINK-5828

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3342 Good fix, thank you! +1 to merge this --- 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 f

[jira] [Commented] (FLINK-5828) BlobServer create cache dir has concurrency safety problem

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871724#comment-15871724 ] ASF GitHub Bot commented on FLINK-5828: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871737#comment-15871737 ] Dawid Wysakowicz commented on FLINK-5824: - [~StephanEwen] Sure, will do it. We don

[jira] [Assigned] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2017-02-17 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5402: Assignee: Dawid Wysakowicz > Fails AkkaRpcServiceTest#testTerminationFuture > -

[jira] [Commented] (FLINK-4422) Convert all time interval measurements to System.nanoTime()

2017-02-17 Thread Jin Mingjian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871757#comment-15871757 ] Jin Mingjian commented on FLINK-4422: - This issue could be seen as a low hanging fruit

[jira] [Commented] (FLINK-5731) Split up CI builds

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

[GitHub] flink pull request #3344: FLINK-5731 Spilt up tests into three disjoint grou...

2017-02-17 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/3344 FLINK-5731 Spilt up tests into three disjoint groups We were running into build timeouts again recently on travis. That's why I've split the tests into three groups (instead of two). Th

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101739062 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -754,6 +759,139 @@ public void scheduleForExec

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101746547 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -754,6 +759,139 @@ public void scheduleForExec

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101739380 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -754,6 +759,139 @@ public void scheduleForExec

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101731399 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -88,4 +100,104 @@ public RetryException(Throwable cau

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101746831 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphUtils.java --- @@ -0,0 +1,108 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101747876 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/Flip6LocalStreamEnvironment.java --- @@ -41,7 +41,7 @@ *

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101747520 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FutureUtilsTest.java --- @@ -0,0 +1,190 @@ +/* + * Licensed to the Ap

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101737070 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -88,4 +100,104 @@ public RetryException(Throwable cau

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101737967 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -292,7 +305,8 @@ public ExecutionGraph(

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[jira] [Commented] (FLINK-5751) 404 in documentation

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

[GitHub] flink issue #3332: [FLINK-5751] [docs] Add link check script

2017-02-17 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3332 Thanks @patricklucas, I've addressed your comments and re-added the red formatting, which is nice indeed. ;-) I'm going to merge this with you as the author. Hope that's fine. --- If your project is s

[jira] [Commented] (FLINK-5751) 404 in documentation

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

[GitHub] flink pull request #3332: [FLINK-5751] [docs] Add link check script

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

[jira] [Commented] (FLINK-5782) Support GPU calculations

2017-02-17 Thread Kate Eri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871803#comment-15871803 ] Kate Eri commented on FLINK-5782: - I have checked out ND4J and Apache Mahout for their GPU

[jira] [Comment Edited] (FLINK-5782) Support GPU calculations

2017-02-17 Thread Kate Eri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871803#comment-15871803 ] Kate Eri edited comment on FLINK-5782 at 2/17/17 12:50 PM: --- I ha

[jira] [Comment Edited] (FLINK-5782) Support GPU calculations

2017-02-17 Thread Kate Eri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871803#comment-15871803 ] Kate Eri edited comment on FLINK-5782 at 2/17/17 12:50 PM: --- I ha

[jira] [Commented] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

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

[GitHub] flink issue #3327: [FLINK-5616] [tests] Harden YarnIntraNonHaMasterServicesT...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3327 Travis now passed :-) Merging this PR. --- 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

[GitHub] flink pull request #3327: [FLINK-5616] [tests] Harden YarnIntraNonHaMasterSe...

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

[jira] [Commented] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

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

[jira] [Updated] (FLINK-5782) Support GPU calculations

2017-02-17 Thread Kate Eri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kate Eri updated FLINK-5782: Description: This ticket was initiated as continuation of the dev discussion thread: [New Flink team member

[jira] [Resolved] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

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

[jira] [Updated] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

2017-02-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5616: - Affects Version/s: (was: 1.2.0) > YarnPreConfiguredMasterHaServicesTest fails sometimes >

[jira] [Comment Edited] (FLINK-5782) Support GPU calculations

2017-02-17 Thread Kate Eri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871803#comment-15871803 ] Kate Eri edited comment on FLINK-5782 at 2/17/17 12:55 PM: --- I ha

[GitHub] flink pull request #3338: [FLINK-5414] [table] Bump up Calcite version to 1....

2017-02-17 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3338#discussion_r101750708 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/ExpressionReducer.scala --- @@ -106,8 +106,16 @@ class ExpressionReducer

  1   2   3   4   >