[jira] [Commented] (FLINK-5960) Make CheckpointCoordinator less blocking

2017-05-09 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16004100#comment-16004100 ] ramkrishna.s.vasudevan commented on FLINK-5960: --- I can work on this too, if no one else is

[GitHub] flink issue #3746: [FLINK-4022] [kafka] Partition and topic discovery for Fl...

2017-05-09 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3746 @haohui you should be able to the PR now, would be great to hear feedback on this. As of now I'm not quite sure whether this will make it into 1.3 though; I think we'll have to see about the

[jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

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

[jira] [Commented] (FLINK-6284) Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore

2017-05-09 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16004090#comment-16004090 ] ramkrishna.s.vasudevan commented on FLINK-6284: --- Can I take this up, if some one is not

[jira] [Commented] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

2017-05-09 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16004086#comment-16004086 ] ramkrishna.s.vasudevan commented on FLINK-4810: --- [~StephanEwen] Can I rebase this PR with

[jira] [Commented] (FLINK-6516) using real row count instead of dummy row count when optimizing plan

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003965#comment-16003965 ] ASF GitHub Bot commented on FLINK-6516: --- GitHub user godfreyhe opened a pull request:

[jira] [Comment Edited] (FLINK-5901) DAG can not show properly in IE

2017-05-09 Thread zhihao chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003962#comment-16003962 ] zhihao chen edited comment on FLINK-5901 at 5/10/17 3:10 AM: -

[jira] [Created] (FLINK-6516) using real row count instead of dummy row count when optimizing plan

2017-05-09 Thread godfrey he (JIRA)
godfrey he created FLINK-6516: - Summary: using real row count instead of dummy row count when optimizing plan Key: FLINK-6516 URL: https://issues.apache.org/jira/browse/FLINK-6516 Project: Flink

[jira] [Assigned] (FLINK-6516) using real row count instead of dummy row count when optimizing plan

2017-05-09 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-6516: - Assignee: godfrey he > using real row count instead of dummy row count when optimizing plan >

[jira] [Commented] (FLINK-5901) DAG can not show properly in IE

2017-05-09 Thread zhihao chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003962#comment-16003962 ] zhihao chen commented on FLINK-5901: [~StephanEwen][~WangTao] Encountered the same problem, and

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

2017-05-09 Thread hongyuhong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003957#comment-16003957 ] hongyuhong commented on FLINK-6232: --- Hi [~fhueske], I have merge the flink-5884 time indicators and

[jira] [Commented] (FLINK-6477) The first time to click Taskmanager cannot get the actual data

2017-05-09 Thread zhihao chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003951#comment-16003951 ] zhihao chen commented on FLINK-6477: hi Chesnay Schepler: yes, this problem only visible on the

[jira] [Commented] (FLINK-6504) Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003925#comment-16003925 ] ASF GitHub Bot commented on FLINK-6504: --- GitHub user shixiaogang opened a pull request:

[GitHub] flink pull request #3859: [FLINK-6504] [FLINK-6467] [checkpoints] Add needed...

2017-05-09 Thread shixiaogang
GitHub user shixiaogang opened a pull request: https://github.com/apache/flink/pull/3859 [FLINK-6504] [FLINK-6467] [checkpoints] Add needed synchronization for RocksDBIncrementalSnapshotOperation This pull request adds missing synchronization for the access to the following

[jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003796#comment-16003796 ] ASF GitHub Bot commented on FLINK-4022: --- Github user haohui commented on the issue:

[GitHub] flink issue #3746: [FLINK-4022] [kafka] Partition and topic discovery for Fl...

2017-05-09 Thread haohui
Github user haohui commented on the issue: https://github.com/apache/flink/pull/3746 Any updates on this? Would love to try this out :-) --- 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

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

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

[jira] [Commented] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode

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

[jira] [Commented] (FLINK-5069) Pending checkpoint statistics gauge

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

[jira] [Commented] (FLINK-5392) flink-dist build failed when change scala version to 2.11

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

[GitHub] flink pull request #2029: [FLINK-2814] Fix for DualInputPlanNode cannot be c...

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

[GitHub] flink pull request #2809: [FLINK-5069] [Metrics] Pending checkpoint statisti...

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

[GitHub] flink pull request #3043: [FLINK-5392] flink-dist build failed when change s...

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

[GitHub] flink pull request #1979: [FLINK-3758] Add possibility to register accumulat...

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

[GitHub] flink pull request #1944: Timer coalescing across keys and cleanup of unused...

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

[GitHub] flink pull request #1033: Add Scala version of GraphAlgorithm

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

[GitHub] flink pull request #3627: Release 0.4 alpha.0

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

[jira] [Commented] (FLINK-6303) Documentation support build in docker on OSX

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

[GitHub] flink pull request #3719: [FLINK-6303] Documentation support build in docker...

2017-05-09 Thread mtunique
Github user mtunique closed the pull request at: https://github.com/apache/flink/pull/3719 --- 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

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003301#comment-16003301 ] ASF GitHub Bot commented on FLINK-6013: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics reporter

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3736 @zentol @StephanEwen why not also merge this into 1.3? There are literally no modified or removed lines of code. --- If your project is set up for it, you can reply to this email and have your

[jira] [Updated] (FLINK-6157) Make TypeInformation fully serializable

2017-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6157: -- Fix Version/s: 1.4.0 1.3.0 > Make TypeInformation fully serializable >

[jira] [Closed] (FLINK-6157) Make TypeInformation fully serializable

2017-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6157. - Resolution: Implemented master: 6cf4a93ebbf36f6c1dd4cc2c9b17dd58880c17c2 release-1.3:

[jira] [Closed] (FLINK-5070) Unable to use Scala's BeanProperty with classes

2017-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-5070. - Resolution: Fixed master: c90b6da5ff845e55c52150a3c6f0b7192959a40e release-1.3:

[jira] [Updated] (FLINK-5070) Unable to use Scala's BeanProperty with classes

2017-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-5070: -- Fix Version/s: 1.4.0 1.3.0 > Unable to use Scala's BeanProperty with classes >

[jira] [Commented] (FLINK-6157) Make TypeInformation fully serializable

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

[jira] [Commented] (FLINK-5070) Unable to use Scala's BeanProperty with classes

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

[GitHub] flink pull request #3318: [FLINK-5070] [types] Unable to use Scala's BeanPro...

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

[GitHub] flink pull request #3619: [FLINK-6157] [core] Make TypeInformation fully ser...

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

[jira] [Closed] (FLINK-5069) Pending checkpoint statistics gauge

2017-05-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5069. --- Resolution: Fixed > Pending checkpoint statistics gauge > ---

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003274#comment-16003274 ] ASF GitHub Bot commented on FLINK-4499: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2422: FLINK-4499: [WIP] Introduce findbugs maven plugin

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2422 @smarthi are you still able to work on this PR? We could enable in a profile when `TRAVIS_EVENT_TYPE=cron` is set in the [environment](https://docs.travis-ci.com/user/environment-variables/).

[jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003250#comment-16003250 ] ASF GitHub Bot commented on FLINK-2597: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2705: [FLINK-2597][FLINK-4050] Add wrappers for Kafka serialize...

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2705 @rmetzger is this feature still desired for a rebase and 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 project

[jira] [Commented] (FLINK-4944) Replace Akka's death watch with own heartbeat on the TM side

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003241#comment-16003241 ] ASF GitHub Bot commented on FLINK-4944: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2742: [FLINK-4944] Replace Akka's death watch with own heartbea...

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2742 @StephanEwen @tillrohrmann is this ready for 1.3? --- 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

[jira] [Commented] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003125#comment-16003125 ] ASF GitHub Bot commented on FLINK-6273: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3688: [FLINK-6273] [core] don't convert hostname to lower cases...

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3688 @barcahead would it be safer to also normalize the value of `jobmanager.rpc.address`? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-6215) Make the StatefulSequenceSource scalable.

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003111#comment-16003111 ] ASF GitHub Bot commented on FLINK-6215: --- Github user kl0u commented on the issue:

[GitHub] flink issue #3669: [FLINK-6215] Make the StatefulSequenceSource scalable.

2017-05-09 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3669 @greghogan Not sure. In my understanding that was made for testing (this is why the old implementation was not efficient) but there may be also some more serious users. Any comments @aljoscha ? ---

[jira] [Commented] (FLINK-6215) Make the StatefulSequenceSource scalable.

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003105#comment-16003105 ] ASF GitHub Bot commented on FLINK-6215: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3669: [FLINK-6215] Make the StatefulSequenceSource scalable.

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3669 @kl0u how important is this for 1.3? --- 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 issue #3719: [FLINK-6303] Documentation support build in docker on OSX

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3719 @mtunique please manually close this PR since it is subsumed by #3751. --- 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

[jira] [Commented] (FLINK-6303) Documentation support build in docker on OSX

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003092#comment-16003092 ] ASF GitHub Bot commented on FLINK-6303: --- Github user greghogan commented on the issue:

[jira] [Commented] (FLINK-6513) various typos and grammatical flaws

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

[jira] [Commented] (FLINK-6513) various typos and grammatical flaws

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

[jira] [Commented] (FLINK-6513) various typos and grammatical flaws

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

[jira] [Commented] (FLINK-6513) various typos and grammatical flaws

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

[GitHub] flink pull request #3858: [FLINK-6513][docs] cleaned up some typos and gramm...

2017-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3858#discussion_r115543214 --- Diff: docs/dev/best_practices.md --- @@ -284,30 +284,30 @@ Change your projects `pom.xml` file like this: The following changes were done in

[GitHub] flink pull request #3858: [FLINK-6513][docs] cleaned up some typos and gramm...

2017-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3858#discussion_r115544603 --- Diff: docs/dev/stream/checkpointing.md --- @@ -124,8 +124,8 @@ env.getCheckpointConfig.setMaxConcurrentCheckpoints(1) ## Selecting a State

[GitHub] flink pull request #3858: [FLINK-6513][docs] cleaned up some typos and gramm...

2017-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3858#discussion_r115538538 --- Diff: docs/dev/best_practices.md --- @@ -31,13 +31,13 @@ This page contains a collection of best practices for Flink programmers on how t ##

[GitHub] flink pull request #3858: [FLINK-6513][docs] cleaned up some typos and gramm...

2017-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3858#discussion_r115541319 --- Diff: docs/dev/best_practices.md --- @@ -31,13 +31,13 @@ This page contains a collection of best practices for Flink programmers on how t ##

[jira] [Closed] (FLINK-6436) Bug in CommonCorrelate's generateCollector method when using udtf with udf

2017-05-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6436. Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed for 1.3 with

[jira] [Closed] (FLINK-6479) Fix IndexOutOfBoundsException bug

2017-05-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6479. Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed for 1.3.0 with

[jira] [Closed] (FLINK-6486) Pass RowTypeInfo to CodeGenerator instead of CRowTypeInfo

2017-05-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6486. Resolution: Done Fix Version/s: 1.4.0 1.3.0 Done for 1.3

[jira] [Closed] (FLINK-6476) Table environment register row data stream

2017-05-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6476. Resolution: Implemented Fix Version/s: 1.4.0 1.3.0 Implemented for 1.3

[jira] [Commented] (FLINK-6479) Fix IndexOutOfBoundsException bug

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

[jira] [Commented] (FLINK-6486) Pass RowTypeInfo to CodeGenerator instead of CRowTypeInfo

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

[jira] [Commented] (FLINK-6436) Bug in CommonCorrelate's generateCollector method when using udtf with udf

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

[jira] [Commented] (FLINK-6476) Table environment register row data stream

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

[GitHub] flink pull request #3841: [FLINK-6479][table]Fix IndexOutOfBoundsException b...

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

[GitHub] flink pull request #3849: [FLINK-6476] - Table environment register row data...

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

[GitHub] flink pull request #3850: [FLINK-6486] [table] (bugfix) Pass RowTypeInfo to ...

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

[GitHub] flink pull request #3815: [FLINK-6436] [table] Bug in CommonCorrelate's gene...

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

[jira] [Commented] (FLINK-6512) some code examples are poorly formatted

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003024#comment-16003024 ] ASF GitHub Bot commented on FLINK-6512: --- Github user greghogan commented on the issue:

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3673#discussion_r115536343 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSingleRowJoin.scala --- @@ -138,33 +144,60 @@ class

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3673#discussion_r115536596 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/DataSetSingleRowJoinTest.scala --- @@ -187,9 +187,155 @@

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3673#discussion_r115536870 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/DataSetSingleRowJoinTest.scala --- @@ -187,9 +187,155 @@

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3673#discussion_r115535989 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/MapJoinLeftRunner.scala --- @@ -31,7 +32,19 @@ class

[jira] [Commented] (FLINK-6513) various typos and grammatical flaws

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002998#comment-16002998 ] ASF GitHub Bot commented on FLINK-6513: --- Github user zentol commented on the issue:

[GitHub] flink issue #3858: [FLINK-6513][docs] cleaned up some typos and grammatical ...

2017-05-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3858 +1 to merge. --- 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

[jira] [Commented] (FLINK-5978) JM WebFrontend address ConfigOption is defined in ConfigConstants

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002989#comment-16002989 ] ASF GitHub Bot commented on FLINK-5978: --- Github user zentol commented on the issue:

[GitHub] flink issue #3831: [FLINK-5978][FLINK-6459][FLINK-6461] Move web-related con...

2017-05-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3831 I guess this also means i now have to worry about hte order in which i merge things to the branches, urgh. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-5978) JM WebFrontend address ConfigOption is defined in ConfigConstants

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002988#comment-16002988 ] ASF GitHub Bot commented on FLINK-5978: --- Github user zentol commented on the issue:

[GitHub] flink issue #3831: [FLINK-5978][FLINK-6459][FLINK-6461] Move web-related con...

2017-05-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3831 Good point, Ill merge the access-control-origin commit to 1.3 as well. --- 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

[jira] [Created] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

2017-05-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6515: --- Summary: KafkaConsumer checkpointing fails because of ClassLoader issues Key: FLINK-6515 URL: https://issues.apache.org/jira/browse/FLINK-6515 Project: Flink

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002964#comment-16002964 ] Greg Hogan commented on FLINK-6514: --- [~aljoscha] are you running a newer version of Maven? I was seeing

[jira] [Commented] (FLINK-6472) BoundedOutOfOrdernessTimestampExtractor does not bound out of orderliness

2017-05-09 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002961#comment-16002961 ] Elias Levy commented on FLINK-6472: --- Ideally Flink would make available an abstract class similar to

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002949#comment-16002949 ] Aljoscha Krettek commented on FLINK-6514: - Proposed solution (that has other possible

[jira] [Created] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6514: --- Summary: Cannot start Flink Cluster in standalone mode Key: FLINK-6514 URL: https://issues.apache.org/jira/browse/FLINK-6514 Project: Flink Issue

[jira] [Commented] (FLINK-6330) Improve Docker documentation

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002944#comment-16002944 ] ASF GitHub Bot commented on FLINK-6330: --- Github user patricklucas commented on the issue:

[GitHub] flink issue #3751: [FLINK-6330] [docs] Add basic Docker, K8s docs

2017-05-09 Thread patricklucas
Github user patricklucas commented on the issue: https://github.com/apache/flink/pull/3751 @greghogan we're waiting patiently for @tianon to complete his review of docker-library/official-images#2895. :) As far as I know, we've done everything we need to do to get the images

[jira] [Commented] (FLINK-6330) Improve Docker documentation

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002940#comment-16002940 ] ASF GitHub Bot commented on FLINK-6330: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3751: [FLINK-6330] [docs] Add basic Docker, K8s docs

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3751 @patricklucas when will the link be available? It would be great to have this merged for 1.3. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-6513) various typos and grammatical flaws

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002920#comment-16002920 ] ASF GitHub Bot commented on FLINK-6513: --- GitHub user alpinegizmo opened a pull request:

[GitHub] flink pull request #3858: [FLINK-6513][docs] cleaned up some typos and gramm...

2017-05-09 Thread alpinegizmo
GitHub user alpinegizmo opened a pull request: https://github.com/apache/flink/pull/3858 [FLINK-6513][docs] cleaned up some typos and grammatical flaws Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

  1   2   3   >