Re: Becoming a contributor JIRA

2017-01-13 Thread Fabian Hueske
Hi Haohui, welcome to the Flink community! Just added you as a contributor. Best, Fabian 2017-01-14 6:17 GMT+01:00 Haohui Mai : > Hi, > > I'm interested in contributing to Flink. I wonder, is it possible that > someone can add me as a contributor in the Flink project so that I can > assign jir

Becoming a contributor JIRA

2017-01-13 Thread Haohui Mai
Hi, I'm interested in contributing to Flink. I wonder, is it possible that someone can add me as a contributor in the Flink project so that I can assign jiras to myself? Your help is highly appreciated. Regards, Haohui

re: some questions about submit flink job on flink-yarn

2017-01-13 Thread huangwei (G)
Hi Till, The "9-96-101-177" is just the hostname. I rerun the flink on yarn and here is the jobmanager.log, and sorry for I blocked some sensitive log. By the way , the port(another questions in my earlier mail) seems to be a random value(this time is 38785 and 35699). I used flink-1.2.0, it wor

[jira] [Created] (FLINK-5489) maven release:prepare fails due to invalid JDOM comments in pom.xml

2017-01-13 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-5489: - Summary: maven release:prepare fails due to invalid JDOM comments in pom.xml Key: FLINK-5489 URL: https://issues.apache.org/jira/browse/FLINK-5489 Project: Flink

[jira] [Created] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

2017-01-13 Thread Ted Yu (JIRA)
Ted Yu created FLINK-5488: - Summary: yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions Key: FLINK-5488 URL: https://issues.apache.org/jira/browse/FLINK-5488 Project: Flink

[jira] [Created] (FLINK-5487) Proper at-least-once support for ElasticsearchSink

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-5487: -- Summary: Proper at-least-once support for ElasticsearchSink Key: FLINK-5487 URL: https://issues.apache.org/jira/browse/FLINK-5487 Project: Flink

[jira] [Created] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2017-01-13 Thread Ted Yu (JIRA)
Ted Yu created FLINK-5486: - Summary: Lack of synchronization in BucketingSink#handleRestoredBucketState() Key: FLINK-5486 URL: https://issues.apache.org/jira/browse/FLINK-5486 Project: Flink Issue T

[jira] [Created] (FLINK-5485) Mark compiled web frontend files as binary when processed by git diff

2017-01-13 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-5485: - Summary: Mark compiled web frontend files as binary when processed by git diff Key: FLINK-5485 URL: https://issues.apache.org/jira/browse/FLINK-5485 Project: Flink

[jira] [Created] (FLINK-5484) Kryo serialization changed between 1.1 and 1.2

2017-01-13 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5484: -- Summary: Kryo serialization changed between 1.1 and 1.2 Key: FLINK-5484 URL: https://issues.apache.org/jira/browse/FLINK-5484 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5482) QueryableStateClient does not recover from a failed lookup due to a non-running job

2017-01-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5482: -- Summary: QueryableStateClient does not recover from a failed lookup due to a non-running job Key: FLINK-5482 URL: https://issues.apache.org/jira/browse/FLINK-5482 Project

[jira] [Created] (FLINK-5483) Link to "linking modules not contained in binary distribution" broken in all connector documentations

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-5483: -- Summary: Link to "linking modules not contained in binary distribution" broken in all connector documentations Key: FLINK-5483 URL: https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-5481) Cannot create Collection of Row

2017-01-13 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5481: Summary: Cannot create Collection of Row Key: FLINK-5481 URL: https://issues.apache.org/jira/browse/FLINK-5481 Project: Flink Issue Type: Bug Re

Re: Flink CEP development is stalling

2017-01-13 Thread Ivan Mushketyk
Hi Till, Thank you for your reply. I wonder if the following will work. What if you can find a Flink committer/committers that will review and iterate on CEP PRs before you review them. They don't need to know all CEP internals, but they will help to eradicate most of the issues. Then you will ha

[jira] [Created] (FLINK-5480) User-provided hashes for operators

2017-01-13 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-5480: - Summary: User-provided hashes for operators Key: FLINK-5480 URL: https://issues.apache.org/jira/browse/FLINK-5480 Project: Flink Issue Type: Improvement

Re: Flink CEP development is stalling

2017-01-13 Thread Till Rohrmann
Hi Ivan, first of all let me apologise for the bad experience you've had with opening CEP PRs in the past. The general problem as you've said is that there is nobody who reviews the open PRs. I used to do this in the but at the moment I hardly find time due to other commitments. I think the way

[jira] [Created] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-5479: -- Summary: Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions Key: FLINK-5479 URL: https://issues.apache.org/jira/browse/FLINK-5479

Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate)

2017-01-13 Thread Fabian Hueske
I tested the Table API / SQL a bit. I implemented a windowed aggregation with the streaming Table API and it produced the same results as a DataStream API implementation. Joining a stream with a TableFunction also seemed to work well. Moreover, I checked the results of a bunch of TPC-H queries (ba

[jira] [Created] (FLINK-5478) Redis Sink Connector should allow update of command without reinstatiation

2017-01-13 Thread Atharva Inamdar (JIRA)
Atharva Inamdar created FLINK-5478: -- Summary: Redis Sink Connector should allow update of command without reinstatiation Key: FLINK-5478 URL: https://issues.apache.org/jira/browse/FLINK-5478 Project:

Re: some questions about submit flink job on flink-yarn

2017-01-13 Thread Till Rohrmann
Hi Huang, this seems to be very strange, because the JobManager’s actor system has bound to the address 9-96-101-177 instead of 9.96.101.177. It seems a if the . have been replaced by -. Could you maybe tell me which version of Flink you’re running and also share the complete JobManager log with

[jira] [Created] (FLINK-5477) Summary columns not aligned correctly

2017-01-13 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5477: -- Summary: Summary columns not aligned correctly Key: FLINK-5477 URL: https://issues.apache.org/jira/browse/FLINK-5477 Project: Flink Issue Type: Bug Com

some questions about submit flink job on flink-yarn

2017-01-13 Thread huangwei (G)
Dear All, I get an error in jobmanage.log following when I submit a flink job (batch/WordCount.jar) by using command : "./bin/flink run -m 9.96.101.177:39180 ./examples/batch/WordCount.jar". And the flink is on yarn cluster. Error in jobmanage.log : 2017-01-13 15:28:27,402 ERROR akka.remote.E