[jira] [Updated] (FLINK-8311) Flink needs documentation for network access control

2017-12-22 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-8311: Description: There is a need for better documentation on what connects to what over which ports in

[jira] [Created] (FLINK-8311) Flink needs documentation for network access control

2017-12-22 Thread Elias Levy (JIRA)
Elias Levy created FLINK-8311: - Summary: Flink needs documentation for network access control Key: FLINK-8311 URL: https://issues.apache.org/jira/browse/FLINK-8311 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-8310) Flink 1.4 Column 'rowtime' not found in any table

2017-12-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-8310. -- Resolution: Not A Problem I've answered [your question on Stack

[jira] [Created] (FLINK-8310) Flink 1.4 Column 'rowtime' not found in any table

2017-12-22 Thread Xuan Nguyen (JIRA)
Xuan Nguyen created FLINK-8310: -- Summary: Flink 1.4 Column 'rowtime' not found in any table Key: FLINK-8310 URL: https://issues.apache.org/jira/browse/FLINK-8310 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-8309) JVM sigsegv crash when enabling async checkpoints

2017-12-22 Thread Kevin Pullin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Pullin closed FLINK-8309. --- Resolution: Resolved > JVM sigsegv crash when enabling async checkpoints >

[jira] [Commented] (FLINK-8309) JVM sigsegv crash when enabling async checkpoints

2017-12-22 Thread Kevin Pullin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16301856#comment-16301856 ] Kevin Pullin commented on FLINK-8309: - Thanks Stefan. I had run across that, but didn't try running

[jira] [Commented] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress

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

[jira] [Closed] (FLINK-8222) Update Scala version

2017-12-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-8222. - Resolution: Implemented master: 8987de3b241d23bbcc6ca5640e3cb77972a60be4 > Update Scala version >

[jira] [Closed] (FLINK-8223) Update Hadoop versions

2017-12-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-8223. - Resolution: Fixed master: d3cd51a3f9fbb3ffbe6d23a57ff3884733eb47fa > Update Hadoop versions >

[GitHub] flink pull request #5190: [FLINK-8289] [runtime] set the rest.address to the...

2017-12-22 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/5190#discussion_r158545462 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java --- @@ -155,6 +156,7 @@ protected void

[jira] [Updated] (FLINK-8223) Update Hadoop versions

2017-12-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-8223: -- Description: Update 2.7.3 to 2.7.5 and 2.8.0 to 2.8.3. See http://hadoop.apache.org/releases.html

[jira] [Updated] (FLINK-8223) Update Hadoop versions

2017-12-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-8223: -- Fix Version/s: 1.5.0 > Update Hadoop versions > -- > > Key:

[jira] [Updated] (FLINK-8222) Update Scala version

2017-12-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-8222: -- Fix Version/s: 1.5.0 > Update Scala version > > > Key: FLINK-8222

[jira] [Commented] (FLINK-8223) Update Hadoop versions

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

[jira] [Commented] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress

2017-12-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16301831#comment-16301831 ] ASF GitHub Bot commented on FLINK-8289: --- Github user EronWright commented on the issue:

[jira] [Commented] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

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

[jira] [Commented] (FLINK-8222) Update Scala version

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

[GitHub] flink issue #5190: [FLINK-8289] [runtime] set the rest.address to the host o...

2017-12-22 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/5190 The configuration option `REST_ADDRESS` seems destined to cause pain. Surveying the code, it seems to variously represent a bind address, a server address, and an advertised address. We should

[GitHub] flink pull request #5195: [hotfix] [build] Always include Kafka 0.11 connect...

2017-12-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5195 ---

[GitHub] flink pull request #5136: [FLINK-8222] [build] Update Scala version

2017-12-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5136 ---

[GitHub] flink pull request #5137: [FLINK-8223] [build] Update Hadoop versions

2017-12-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5137 ---

[GitHub] flink pull request #5126: [FLINK-5506] [gelly] Fix CommunityDetection NullPo...

2017-12-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5126 ---

[GitHub] flink pull request #5199: [hotfix] [javadoc] Fix typos in MemorySegment clas...

2017-12-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5199 ---

[jira] [Commented] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress

2017-12-22 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16301817#comment-16301817 ] Eron Wright commented on FLINK-8289: - I guess we should be clear about who is being advertised to.

[jira] [Comment Edited] (FLINK-7860) Support YARN proxy user in Flink (impersonation)

2017-12-22 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16301806#comment-16301806 ] Eron Wright edited comment on FLINK-7860 at 12/22/17 6:54 PM: --- Regarding

[jira] [Commented] (FLINK-7860) Support YARN proxy user in Flink (impersonation)

2017-12-22 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16301806#comment-16301806 ] Eron Wright commented on FLINK-7860: - Regarding how a proxy user would be configured, the goal is to

[jira] [Commented] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort

2017-12-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16301773#comment-16301773 ] ASF GitHub Bot commented on FLINK-8037: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #5205: [FLINK-8037] Fix integer multiplication or shift i...

2017-12-22 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/5205 [FLINK-8037] Fix integer multiplication or shift implicitly cast to long ## What is the purpose of the change Fixes potential overflow flagged by the IntelliJ inspection "Integer

[jira] [Commented] (FLINK-8309) JVM sigsegv crash when enabling async checkpoints

2017-12-22 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16301756#comment-16301756 ] Stefan Richter commented on FLINK-8309: --- Looks like this is very likely related to this Java

[jira] [Created] (FLINK-8309) JVM sigsegv crash when enabling async checkpoints

2017-12-22 Thread Kevin Pullin (JIRA)
Kevin Pullin created FLINK-8309: --- Summary: JVM sigsegv crash when enabling async checkpoints Key: FLINK-8309 URL: https://issues.apache.org/jira/browse/FLINK-8309 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min

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

[GitHub] flink issue #5201: [FLINK-8283] [kafka] Stabalize FlinkKafkaConsumerBaseTest...

2017-12-22 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5201 The following 10 local Travis runs suggests that the stalling tests on the `connectors` build no longer remains after this change: - https://travis-ci.org/tzulitai/flink/builds/319936358

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

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

[GitHub] flink pull request #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' mil...

2017-12-22 Thread casidiablo
Github user casidiablo commented on a diff in the pull request: https://github.com/apache/flink/pull/5182#discussion_r158496021 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

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

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

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

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

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

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

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

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

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

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

2017-12-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158489057 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,207 @@ +/*

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

2017-12-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158489047 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -116,14 +135,100 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

2017-12-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158489017 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,285 @@ +/* + *

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

2017-12-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158489035 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala --- @@ -116,14 +135,100 @@ object

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

2017-12-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158488989 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/JoinITCase.scala --- @@ -0,0 +1,262 @@ +/* + *

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

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

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

2017-12-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r158489025 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala --- @@ -0,0 +1,285 @@ +/* + *

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

2017-12-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16301376#comment-16301376 ] ASF GitHub Bot commented on FLINK-6094: --- Github user hequn8128 commented on the issue:

[GitHub] flink issue #4471: [FLINK-6094] [table] Implement stream-stream proctime non...

2017-12-22 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/4471 Hi, @twalthr , thanks for your review. The pr has been updated according to your comments. It mainly contains the following changes: - Do some minor refactors in `UpdatingPlanChecker`,

[jira] [Assigned] (FLINK-8277) Optimize code generation by using local references

2017-12-22 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li reassigned FLINK-8277: - Assignee: Ruidong Li > Optimize code generation by using local references >

[jira] [Created] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher

2017-12-22 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8308: Summary: Update yajl-ruby dependency to 1.3.1 or higher Key: FLINK-8308 URL: https://issues.apache.org/jira/browse/FLINK-8308 Project: Flink Issue Type:

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-12-22 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-7756: Fix Version/s: 1.4.1 1.5.0 > RocksDB state backend Checkpointing (Async