[GitHub] flink pull request #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAP...

2018-03-12 Thread buptljy
Github user buptljy commented on a diff in the pull request: https://github.com/apache/flink/pull/5638#discussion_r173897783 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala --- @@ -1130,4 +1130,13 @@ object concat_ws {

[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395641#comment-16395641 ] ASF GitHub Bot commented on FLINK-6924: --- Github user buptljy commented on a diff in

[jira] [Comment Edited] (FLINK-7588) Document RocksDB tuning for spinning disks

2018-03-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16258309#comment-16258309 ] Ted Yu edited comment on FLINK-7588 at 3/12/18 7:26 PM: bq. Be car

[jira] [Created] (FLINK-8931) TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled

2018-03-12 Thread Ted Yu (JIRA)
Ted Yu created FLINK-8931: - Summary: TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled Key: FLINK-8931 URL: https://issues.apache.org/jira/browse/FLINK-8931 Project: Flink Issue Type

[jira] [Created] (FLINK-8932) Mesos taskmanager should reserve port for query server

2018-03-12 Thread Jared Stehler (JIRA)
Jared Stehler created FLINK-8932: Summary: Mesos taskmanager should reserve port for query server Key: FLINK-8932 URL: https://issues.apache.org/jira/browse/FLINK-8932 Project: Flink Issue Ty

[jira] [Updated] (FLINK-8932) Mesos taskmanager should reserve port for query server

2018-03-12 Thread Jared Stehler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jared Stehler updated FLINK-8932: - Description: Currently the LaunchableMesosWorker doesn't reserve a port for the query server, mak

[GitHub] flink issue #5680: [FLINK-8919] Add KeyedProcessFunctionWithCleanupState.

2018-03-12 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5680 shall we add a unit test? ---

[jira] [Commented] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395867#comment-16395867 ] ASF GitHub Bot commented on FLINK-8919: --- Github user bowenli86 commented on the issu

[GitHub] flink pull request #5682: [FLINK-8927][state] Eagerly release the checkpoint...

2018-03-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5682 ---

[jira] [Commented] (FLINK-8927) Eagerly release the checkpoint object created from RocksDB

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

[jira] [Closed] (FLINK-8927) Eagerly release the checkpoint object created from RocksDB

2018-03-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8927. - Resolution: Fixed Merged in 3debf47e5d. > Eagerly release the checkpoint object created from Rock

[GitHub] flink pull request #5685: [FLINK-7521][flip6]

2018-03-12 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5685 [FLINK-7521][flip6] ## What is the purpose of the change *Make HTTP request and response limits configurable. A relatively high default value is chosen (100 mb) because Netty does not allocate

[jira] [Commented] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396188#comment-16396188 ] ASF GitHub Bot commented on FLINK-7521: --- GitHub user GJL opened a pull request:

[GitHub] flink issue #5685: [FLINK-7521][flip6] Remove the 10MB limit from the curren...

2018-03-12 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5685 Maybe docs should be updated. ---

[jira] [Commented] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396194#comment-16396194 ] ASF GitHub Bot commented on FLINK-7521: --- Github user GJL commented on the issue:

[jira] [Updated] (FLINK-8708) Unintended integer division in StandaloneThreadedGenerator

2018-03-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8708: -- Description: In flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/state

[jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes

2018-03-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16345955#comment-16345955 ] Ted Yu edited comment on FLINK-7795 at 3/13/18 1:27 AM: error-pron

[GitHub] flink pull request #5686: [FLINK-8917] [Job-Submission] FlinkMiniCluster def...

2018-03-12 Thread jianran
GitHub user jianran opened a pull request: https://github.com/apache/flink/pull/5686 [FLINK-8917] [Job-Submission] FlinkMiniCluster default createHighAvailabilityServices is not same as ClusterClient ## What is the purpose of the change the FlinkMiniCluster used Hi

[jira] [Commented] (FLINK-8917) FlinkMiniCluster default createHighAvailabilityServices is not same as ClusterClient

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396373#comment-16396373 ] ASF GitHub Bot commented on FLINK-8917: --- GitHub user jianran opened a pull request:

[GitHub] flink issue #5449: [FLINK-8623] ConnectionUtilsTest.testReturnLocalHostAddre...

2018-03-12 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5449 Hi, @NicoK . I think ```InetAddress.getAllByName("localhost")``` wont work since we still give the specific hostname for that. And it will return a loopback address. ---

[jira] [Commented] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396383#comment-16396383 ] ASF GitHub Bot commented on FLINK-8623: --- Github user zhangminglei commented on the i

[jira] [Created] (FLINK-8933) Avoid calling Class#newInstance

2018-03-12 Thread Ted Yu (JIRA)
Ted Yu created FLINK-8933: - Summary: Avoid calling Class#newInstance Key: FLINK-8933 URL: https://issues.apache.org/jira/browse/FLINK-8933 Project: Flink Issue Type: Task Reporter: Ted Yu

[GitHub] flink issue #5680: [FLINK-8919] Add KeyedProcessFunctionWithCleanupState.

2018-03-12 Thread liurenjie1024
Github user liurenjie1024 commented on the issue: https://github.com/apache/flink/pull/5680 @bowenli86 This is a trivial change and most the code is copied from the non keyed counterpart, so I don't think we need a test. ---

[jira] [Commented] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396491#comment-16396491 ] ASF GitHub Bot commented on FLINK-8919: --- Github user liurenjie1024 commented on the

[jira] [Commented] (FLINK-8914) CEP's greedy() modifier doesn't work

2018-03-12 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396500#comment-16396500 ] aitozi commented on FLINK-8914: --- Yes, i run into this bug too, greedy only works when it has

[jira] [Assigned] (FLINK-4817) Checkpoint Coordinator should be called to restore state with a specific checkpoint ID

2018-03-12 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei reassigned FLINK-4817: -- Assignee: (was: Wei-Che Wei) > Checkpoint Coordinator should be called to restore state wit

<    1   2   3   4