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

2018-03-12 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-8919: - Summary: Add KeyedProcessFunctionWIthCleanupState Key: FLINK-8919 URL: https://issues.apache.org/jira/browse/FLINK-8919 Project: Flink Issue Type: Improvement

[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=16394924#comment-16394924 ] ASF GitHub Bot commented on FLINK-8919: --- GitHub user liurenjie1024 opened a pull req

[GitHub] flink pull request #5680: [FLINK-8919] Add KeyedProcessFunctionWithCleanupSt...

2018-03-12 Thread liurenjie1024
GitHub user liurenjie1024 opened a pull request: https://github.com/apache/flink/pull/5680 [FLINK-8919] Add KeyedProcessFunctionWithCleanupState. ## What is the purpose of the change *Add ProcessFunctionWithCleanupState's counterpart for KeyedProcessFunction.* ## V

[jira] [Commented] (FLINK-4641) Support branching CEP patterns

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

[GitHub] flink issue #3105: [FLINK-4641] [cep] Support branching CEP patterns

2018-03-12 Thread chermenin
Github user chermenin commented on the issue: https://github.com/apache/flink/pull/3105 @Aitozi I just didn't have enough time to finish my work on this task and the Pattern API was changed at the same time. Now it's needed to rewrite the code to support all updates. ---

[GitHub] flink issue #5613: [FLINK-8274] [table] Split generated methods for preventi...

2018-03-12 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5613 Merging for now and opening more issue around this topic. ---

[jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

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

[jira] [Created] (FLINK-8920) Split code generated input unboxing code

2018-03-12 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8920: --- Summary: Split code generated input unboxing code Key: FLINK-8920 URL: https://issues.apache.org/jira/browse/FLINK-8920 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #5613: [FLINK-8274] [table] Split generated methods for p...

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

[jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

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

[GitHub] flink pull request #5174: [FLINK-8274][TableAPI & SQL] Fix Java 64K method c...

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

[jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

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

[jira] [Created] (FLINK-8921) Split code generated call expression

2018-03-12 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8921: --- Summary: Split code generated call expression Key: FLINK-8921 URL: https://issues.apache.org/jira/browse/FLINK-8921 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8903) Error calculation based on rolling window in table API and SQL API

2018-03-12 Thread lilizhao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394986#comment-16394986 ] lilizhao commented on FLINK-8903: - [~fhueske] But why the calculated variance is the same

[jira] [Commented] (FLINK-8903) Error calculation based on rolling window in table API and SQL API

2018-03-12 Thread lilizhao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394991#comment-16394991 ] lilizhao commented on FLINK-8903: - Hi, [~fhueske] In my appendix example, the sum of the c

[jira] [Reopened] (FLINK-8903) Error calculation based on rolling window in table API and SQL API

2018-03-12 Thread lilizhao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lilizhao reopened FLINK-8903: - > Error calculation based on rolling window in table API and SQL API > ---

[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=16394996#comment-16394996 ] ASF GitHub Bot commented on FLINK-8623: --- Github user zhangminglei commented on the i

[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 Thank you for your response, @StephanEwen You are very correct. We would not connect JM / RM / ZK if we use ```getByName("localhost")``` . I will give an example based I have known abou

[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 I will verify whether retry can hack this issue. Not sure about it. ---

[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=16394999#comment-16394999 ] ASF GitHub Bot commented on FLINK-8623: --- Github user zhangminglei commented on the i

[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 By the way, Although I have a Linux computer, I cannot access the Internet. :) I just use ```ifconfig``` check that. ---

[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=16395008#comment-16395008 ] ASF GitHub Bot commented on FLINK-8623: --- Github user zhangminglei commented on the i

[jira] [Issue Comment Deleted] (FLINK-8903) Error calculation based on rolling window in table API and SQL API

2018-03-12 Thread lilizhao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lilizhao updated FLINK-8903: Comment: was deleted (was: Hi, [~fhueske] In my appendix example, the sum of the calculations, the average

[jira] [Updated] (FLINK-8903) Error calculation based on rolling window in table API and SQL API

2018-03-12 Thread lilizhao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lilizhao updated FLINK-8903: Attachment: QQ图片20180312180143.jpg > Error calculation based on rolling window in table API and SQL API > --

[jira] [Commented] (FLINK-8903) Error calculation based on rolling window in table API and SQL API

2018-03-12 Thread lilizhao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395009#comment-16395009 ] lilizhao commented on FLINK-8903: - [~fhueske]  A new example: SQL = "SELECT VAR_POP (CCN

[GitHub] flink pull request #5679: [FLINK-8916] Checkpointing Mode is always shown to...

2018-03-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5679#discussion_r173742094 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java --- @@ -143,10 +152,66 @@ public int hashC

[GitHub] flink pull request #5679: [FLINK-8916] Checkpointing Mode is always shown to...

2018-03-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5679#discussion_r173741952 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java --- @@ -143,10 +152,66 @@ public int hashC

[GitHub] flink pull request #5679: [FLINK-8916] Checkpointing Mode is always shown to...

2018-03-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5679#discussion_r173742203 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java --- @@ -143,10 +152,66 @@ public int hashC

[jira] [Commented] (FLINK-8916) Checkpointing Mode is always shown to be "At Least Once" in Web UI

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

[jira] [Commented] (FLINK-8916) Checkpointing Mode is always shown to be "At Least Once" in Web UI

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

[jira] [Commented] (FLINK-8916) Checkpointing Mode is always shown to be "At Least Once" in Web UI

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

[GitHub] flink pull request #5665: [FLINK-8703][tests] Port WebFrontendITCase to Mini...

2018-03-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5665#discussion_r173743909 --- Diff: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/WebFrontendITCase.java --- @@ -66,40 +73,44 @@ private static final int

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[GitHub] flink issue #5639: [FLINK-8862] [HBase] Support HBase snapshot read

2018-03-12 Thread neoremind
Github user neoremind commented on the issue: https://github.com/apache/flink/pull/5639 @ramkrish86 @fhueske could you help to review this PR? Since I noticed that you guys contribute most of the code. This update enables HBase snapshot read and I refactor some of the code and test ca

[jira] [Commented] (FLINK-8862) Support HBase snapshot read

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

[GitHub] flink pull request #5670: [FLINK-8904][cli][tests] always restore the previo...

2018-03-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/5670#discussion_r173746711 --- Diff: flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendTestUtils.java --- @@ -65,9 +67,14 @@ public static String getInvalidConfigDir()

[jira] [Commented] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

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

[jira] [Created] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-8922: - Summary: Revert FLINK-8859 because it causes segfaults in testing Key: FLINK-8922 URL: https://issues.apache.org/jira/browse/FLINK-8922 Project: Flink Issu

[jira] [Closed] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8922. - Resolution: Fixed Release Note: Merged in a389b43581. > Revert FLINK-8859 because it causes

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395037#comment-16395037 ] Stefan Richter commented on FLINK-8922: --- FYI [~sihuazhou] > Revert FLINK-8859 becau

[jira] [Commented] (FLINK-6075) ORDER BY *time ASC

2018-03-12 Thread yinhua.dai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395038#comment-16395038 ] yinhua.dai commented on FLINK-6075: --- [~fhueske] Sorry to ask it here, but may I ask why

[jira] [Assigned] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8922: - Assignee: Stefan Richter > Revert FLINK-8859 because it causes segfaults in testing > ---

[jira] [Resolved] (FLINK-8882) flink-tests fails with core dump

2018-03-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter resolved FLINK-8882. --- Resolution: Fixed > flink-tests fails with core dump > > >

[jira] [Resolved] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

2018-03-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8274. - Resolution: Fixed Fix Version/s: 1.6.0 1.5.0 Fixed in 1.6.0: 1f55f730a65

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395050#comment-16395050 ] Sihua Zhou commented on FLINK-8922: --- [~srichter] Thanks for let me know, I will have a d

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395054#comment-16395054 ] Stefan Richter commented on FLINK-8922: --- Ok that sounds good. I also had a look and

[jira] [Assigned] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

2018-03-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8704: --- Assignee: Chesnay Schepler > Migrate tests from TestingCluster to MiniClusterResource

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

2018-03-12 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5449 Thanks @StephanEwen indeed - I also did not grasp the full intend of the change. Looking at the code again, basically `ConnectionUtils#findConnectingAddress()` tries to connect with a set of

[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=16395066#comment-16395066 ] ASF GitHub Bot commented on FLINK-8623: --- Github user NicoK commented on the issue:

[jira] [Assigned] (FLINK-8921) Split code generated call expression

2018-03-12 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li reassigned FLINK-8921: - Assignee: Ruidong Li > Split code generated call expression > --

[jira] [Assigned] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread.

2018-03-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4569: --- Assignee: Chesnay Schepler > JobRetrievalITCase.testJobRetrieval() does not forward e

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

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8917: --- Fix Version/s: (was: 1.4.2) 1.4.3 > FlinkMiniCluster default cr

[jira] [Updated] (FLINK-8202) Update queryable section on configuration page

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8202: --- Fix Version/s: (was: 1.4.2) 1.4.3 > Update queryable section on

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

2018-03-12 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7521: Labels: flip6 (was: ) > Remove the 10MB limit from the current REST implementation. > -

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

2018-03-12 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7521: Affects Version/s: 1.6.0 1.5.0 > Remove the 10MB limit from the current REST implemen

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

2018-03-12 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-7521: --- Assignee: Gary Yao (was: Fang Yong) > Remove the 10MB limit from the current REST implementation. >

[jira] [Created] (FLINK-8923) Set an uncaught exception handler for ForkJoinPool

2018-03-12 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8923: -- Summary: Set an uncaught exception handler for ForkJoinPool Key: FLINK-8923 URL: https://issues.apache.org/jira/browse/FLINK-8923 Project: Flink Issue Type: Impr

[GitHub] flink pull request #5681: [FLINK-4569][tests] Fix JobRetrievalITCase

2018-03-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5681 [FLINK-4569][tests] Fix JobRetrievalITCase ## What is the purpose of the change This PR contains 2 changes to the `JobRetrievalITCase`. 1) We now store exceptions that occur in the s

[jira] [Commented] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread.

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

[GitHub] flink issue #5679: [FLINK-8916] Checkpointing Mode is always shown to be "At...

2018-03-12 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5679 @zentol thank you for suggestion, please review again. ---

[jira] [Updated] (FLINK-8923) Set an uncaught exception handler for ForkJoinPool

2018-03-12 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8923: --- Component/s: Startup Shell Scripts > Set an uncaught exception handler for ForkJoinPool >

[jira] [Commented] (FLINK-8916) Checkpointing Mode is always shown to be "At Least Once" in Web UI

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

[jira] [Updated] (FLINK-8795) Scala shell broken for FLip6

2018-03-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8795: Summary: Scala shell broken for FLip6 (was: Failed to submit JobGraph Apache Flink on Githu

[jira] [Updated] (FLINK-8795) Scala shell broken for Flip6

2018-03-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8795: Summary: Scala shell broken for Flip6 (was: Scala shell broken for FLip6) > Scala shell bro

[jira] [Commented] (FLINK-8795) Scala shell broken for Flip6

2018-03-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395084#comment-16395084 ] Chesnay Schepler commented on FLINK-8795: - The given port is where the client expe

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

2018-03-12 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5449 We cannot fully guard against incorrect network configurations. Many systems (even HDFS,, AFAIK) simply use `InetAddress.getLocalHost()` and rely on correct network configs. Our current s

[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=16395097#comment-16395097 ] ASF GitHub Bot commented on FLINK-8623: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395099#comment-16395099 ] Stephan Ewen commented on FLINK-8922: - [~srichter] [~sihuazhou] It is still desirable

[jira] [Commented] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-12 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395102#comment-16395102 ] Stephan Ewen commented on FLINK-8907: - Did you run this on cygwin before? > Unable to

[jira] [Commented] (FLINK-8895) Job failed when one kafka broker shutdown

2018-03-12 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395106#comment-16395106 ] Stephan Ewen commented on FLINK-8895: - I think you don't need to add filtering code or

[GitHub] flink issue #5521: [FLINK-8599] Improve the failure behavior of the FileInpu...

2018-03-12 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5521 The approach here does not work (there is also no test, otherwise that would have been caught). Flink does not magically load configs like Hadoop, Flink passes configs explicitly. As

[jira] [Commented] (FLINK-8599) Improve the failure behavior of the FileInputFormat for bad files

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

[jira] [Commented] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-12 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395125#comment-16395125 ] mingleizhang commented on FLINK-8907: - Hmm, I just use git client (https://git-scm.com

[jira] [Created] (FLINK-8924) Add @Old junit category

2018-03-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8924: --- Summary: Add @Old junit category Key: FLINK-8924 URL: https://issues.apache.org/jira/browse/FLINK-8924 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8925) Activate flip6 on travis

2018-03-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8925: --- Summary: Activate flip6 on travis Key: FLINK-8925 URL: https://issues.apache.org/jira/browse/FLINK-8925 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395128#comment-16395128 ] Sihua Zhou commented on FLINK-8922: --- [~StephanEwen] I am not sure whether the failed tes

[jira] [Updated] (FLINK-8925) Activate flip6 on travis

2018-03-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8925: Priority: Blocker (was: Major) > Activate flip6 on travis > > >

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395164#comment-16395164 ] Stephan Ewen commented on FLINK-8922: - Would also be nice to know how much the WAL act

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395161#comment-16395161 ] Stephan Ewen commented on FLINK-8922: - I think [~srichter] tried that out, still segfa

[GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...

2018-03-12 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5662#discussion_r173784883 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala --- @@ -148,6 +148,13 @@ object SchemaValidator

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

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

[GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...

2018-03-12 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/5662#discussion_r173786510 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala --- @@ -148,6 +148,13 @@ object SchemaValidato

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

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

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395198#comment-16395198 ] Sihua Zhou commented on FLINK-8922: --- [~StephanEwen] About the costs with (or without) WA

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395205#comment-16395205 ] Stefan Richter commented on FLINK-8922: --- Yes, I tried out to create a dedicated \{{W

[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 Thanks @StephanEwen and @NicoK for the response and that let me know more about details about this issue. As refers to the first that return something we can bind to. Yes, As long as it

[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=16395208#comment-16395208 ] ASF GitHub Bot commented on FLINK-8623: --- Github user zhangminglei commented on the i

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-12 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395214#comment-16395214 ] Sihua Zhou commented on FLINK-8922: --- Agreed with [~srichter], and the statistics I poste

[GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...

2018-03-12 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5662#discussion_r173791129 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala --- @@ -148,6 +148,13 @@ object SchemaValidator

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

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

[GitHub] flink pull request #5681: [FLINK-4569][tests] Fix JobRetrievalITCase

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

[jira] [Commented] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread.

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

[jira] [Commented] (FLINK-8794) When using BucketingSink, it happens that one of the files is always in the [.in-progress] state

2018-03-12 Thread yanxiaobin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395286#comment-16395286 ] yanxiaobin commented on FLINK-8794: --- I will open a case with AWS for the root cause of t

[jira] [Commented] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart

2018-03-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395297#comment-16395297 ] Stefan Richter commented on FLINK-8042: --- [~till.rohrmann] and me came to the conclus

[jira] [Closed] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart

2018-03-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8042. - Resolution: Won't Fix This problem should be solved with FLIP-6 and is hard to support in the lega

[jira] [Created] (FLINK-8926) Shutdown client proxy on test end.

2018-03-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-8926: - Summary: Shutdown client proxy on test end. Key: FLINK-8926 URL: https://issues.apache.org/jira/browse/FLINK-8926 Project: Flink Issue Type: Bug

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

2018-03-12 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-8927: - Summary: Eagerly release the checkpoint object created from RocksDB Key: FLINK-8927 URL: https://issues.apache.org/jira/browse/FLINK-8927 Project: Flink Issue Type

[jira] [Updated] (FLINK-8926) Shutdown client proxy on test end.

2018-03-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-8926: -- Component/s: Tests > Shutdown client proxy on test end. > -- > >

[jira] [Created] (FLINK-8928) Improve error message on server binding error.

2018-03-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-8928: - Summary: Improve error message on server binding error. Key: FLINK-8928 URL: https://issues.apache.org/jira/browse/FLINK-8928 Project: Flink Issue Type: Bu

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

2018-03-12 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5682 [FLINK-8927][state] Eagerly release the checkpoint object created from RocksDB ## What is the purpose of the change This PR addresses [FLINK-8927](https://issues.apache.org/jira/browse/F

  1   2   3   4   >