[jira] [Commented] (FLINK-6397) MultipleProgramsTestBase does not reset ContextEnvironment

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

[GitHub] flink issue #3810: [FLINK-6397] MultipleProgramsTestBase does not reset Cont...

2017-05-08 Thread ifndef-SleePy
Github user ifndef-SleePy commented on the issue: https://github.com/apache/flink/pull/3810 Hi, I updated this review. I don't know why there is no reminding in jira and email. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Issue Comment Deleted] (FLINK-5967) Document AggregatingState

2017-05-08 Thread yanghua (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanghua updated FLINK-5967: --- Comment: was deleted (was: hi [~aljoscha] where to add the document?) > Document AggregatingState >

[jira] [Commented] (FLINK-6247) Build a jar-with-dependencies for flink-table and put it into ./opt

2017-05-08 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002083#comment-16002083 ] Xingcan Cui commented on FLINK-6247: Sorry for reawakening this. I know setting the dependencies with

[jira] [Commented] (FLINK-5758) Port-range for the web interface via YARN

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

[jira] [Created] (FLINK-6480) Add executor service parameter Snapshotable::snapshot(...)

2017-05-08 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6480: - Summary: Add executor service parameter Snapshotable::snapshot(...) Key: FLINK-6480 URL: https://issues.apache.org/jira/browse/FLINK-6480 Project: Flink

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

2017-05-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6479: --- Summary: Fix IndexOutOfBoundsException bug (was: Hot fix IndexOutOfBoundsException bug) > Fix

[jira] [Created] (FLINK-6481) Encapsulate different snapshot algorithms (full, incremental) slightly clearer into strategy pattern

2017-05-08 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6481: - Summary: Encapsulate different snapshot algorithms (full, incremental) slightly clearer into strategy pattern Key: FLINK-6481 URL:

[jira] [Created] (FLINK-6482) Add nested serializers into configuration snapshots of composite serializers

2017-05-08 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6482: -- Summary: Add nested serializers into configuration snapshots of composite serializers Key: FLINK-6482 URL: https://issues.apache.org/jira/browse/FLINK-6482

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

2017-05-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000418#comment-16000418 ] Fabian Hueske commented on FLINK-6476: -- Hi [~rtudoran], you are right, it should be possible convert

[jira] [Comment Edited] (FLINK-6434) There may be allocatedSlots leak in SlotPool

2017-05-08 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000232#comment-16000232 ] shuai.xu edited comment on FLINK-6434 at 5/8/17 7:11 AM: - [~till.rohrmann] This

[jira] [Updated] (FLINK-6479) Hot fix IndexOutOfBoundsException bug

2017-05-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6479: --- Summary: Hot fix IndexOutOfBoundsException bug (was: Hot fix FLINK-5906 bug) > Hot fix

[jira] [Commented] (FLINK-6434) There may be allocatedSlots leak in SlotPool

2017-05-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000369#comment-16000369 ] Till Rohrmann commented on FLINK-6434: -- You're right [~tiemsn]. The problem seems to be that the

[jira] [Created] (FLINK-6479) Hot fix FLINK-5906 bug

2017-05-08 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6479: -- Summary: Hot fix FLINK-5906 bug Key: FLINK-6479 URL: https://issues.apache.org/jira/browse/FLINK-6479 Project: Flink Issue Type: Bug Components: Table

[GitHub] flink issue #3391: [FLINK-5758] [yarn] support port range for web monitor

2017-05-08 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3391 @barcahead what is the status of this PR? --- 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-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token.

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

[GitHub] flink issue #3776: [FLINK-6376]when deploy flink cluster on the yarn, it is ...

2017-05-08 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3776 @Rucongzhang My understanding was that the Hadoop code should automatically renew delegation tokens when a Kerberos Keytab is present. @EronWright Can you comment on that assumption? --- If

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

2017-05-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000507#comment-16000507 ] Fabian Hueske commented on FLINK-6476: -- Yes, it does not work and should be supported. I just wanted

[jira] [Created] (FLINK-6484) Send only the registry keys for already registered files in incremental checkpointing

2017-05-08 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6484: - Summary: Send only the registry keys for already registered files in incremental checkpointing Key: FLINK-6484 URL: https://issues.apache.org/jira/browse/FLINK-6484

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

2017-05-08 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000512#comment-16000512 ] radu commented on FLINK-6476: - [~fhueske] Great. I will try to implement this. I will ping you after i have

[jira] [Commented] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

2017-05-08 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000526#comment-16000526 ] mingleizhang commented on FLINK-6343: - [~tzulitai] You are very welcome and I guess it would be better

[GitHub] flink pull request #3843: [FLINK-5892] Enable 1.2 keyed state test

2017-05-08 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3843 [FLINK-5892] Enable 1.2 keyed state test Backport of #3842 for the 1.3 branch. You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

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

[GitHub] flink pull request #3843: [FLINK-5892] Enable 1.2 keyed state test

2017-05-08 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3843 --- 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-5892) Recover job state at the granularity of operator

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

[GitHub] flink pull request #3844: [FLINK-5892] Enable 1.2 keyed state test

2017-05-08 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3844 [FLINK-5892] Enable 1.2 keyed state test Backport of #3842 for the 1.3 branch. You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

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

[GitHub] flink pull request #3842: [FLINK-5892] Enable 1.2 keyed state test

2017-05-08 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3842 [FLINK-5892] Enable 1.2 keyed state test This PR enables the 1.2 keyed state restore test added in FLINK-5892. It was temporarily disabled due to a general issue with backwards compatibility.

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

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

[jira] [Commented] (FLINK-6434) There may be allocatedSlots leak in SlotPool

2017-05-08 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000435#comment-16000435 ] shuai.xu commented on FLINK-6434: - Yes, add a request id can solve the problem. > There may be

[GitHub] flink issue #3826: [FLINK-5886] Python API for streaming applications

2017-05-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3826 Please close this pull request. --- 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

[jira] [Commented] (FLINK-5886) Python API for streaming applications

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

[jira] [Created] (FLINK-6483) Support time materialization

2017-05-08 Thread Timo Walther (JIRA)
Timo Walther created FLINK-6483: --- Summary: Support time materialization Key: FLINK-6483 URL: https://issues.apache.org/jira/browse/FLINK-6483 Project: Flink Issue Type: New Feature

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

2017-05-08 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/3841 [FLINK-6479][table]Fix IndexOutOfBoundsException bug Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

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

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

[jira] [Commented] (FLINK-5778) Split FileStateHandle into fileName and basePath

2017-05-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000443#comment-16000443 ] Ufuk Celebi commented on FLINK-5778: No, I don't think so. I was waiting for FLINK-5823

[jira] [Updated] (FLINK-6397) MultipleProgramsTestBase does not reset ContextEnvironment

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6397: Priority: Critical (was: Major) > MultipleProgramsTestBase does not reset

[jira] [Updated] (FLINK-6461) Deprecate web-related configuration defaults in ConfigConstants

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6461: Affects Version/s: 1.4.0 > Deprecate web-related configuration defaults in ConfigConstants

[jira] [Updated] (FLINK-6397) MultipleProgramsTestBase does not reset ContextEnvironment

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6397: Affects Version/s: 1.4.0 > MultipleProgramsTestBase does not reset ContextEnvironment >

[jira] [Updated] (FLINK-6314) Allow setting CassandraSink mapper options

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6314: Fix Version/s: (was: 1.3.0) 1.4.0 > Allow setting CassandraSink

[jira] [Updated] (FLINK-6314) Allow setting CassandraSink mapper options

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6314: Affects Version/s: (was: 1.3.0) > Allow setting CassandraSink mapper options >

[jira] [Updated] (FLINK-6396) FsSavepointStreamFactoryTest fails on Windows

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6396: Affects Version/s: 1.4.0 > FsSavepointStreamFactoryTest fails on Windows >

[jira] [Updated] (FLINK-5469) build_docs.sh -p fails on Windows Subsystem for Linux

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5469: Affects Version/s: 1.4.0 > build_docs.sh -p fails on Windows Subsystem for Linux >

[jira] [Updated] (FLINK-5659) FileBaseUtils#deleteFileOrDirectory not thread-safe on Windows

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5659: Affects Version/s: 1.4.0 > FileBaseUtils#deleteFileOrDirectory not thread-safe on Windows >

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

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5978: Affects Version/s: 1.4.0 > JM WebFrontend address ConfigOption is defined in

[jira] [Updated] (FLINK-5970) Job-/TaskManagerStartupTest may run indefinitely

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5970: Affects Version/s: 1.4.0 > Job-/TaskManagerStartupTest may run indefinitely >

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

2017-05-08 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000450#comment-16000450 ] radu commented on FLINK-6476: - [~fhueske] I actually tried also to set the type of the datastream manually

[jira] [Updated] (FLINK-5453) REST API request reference incomplete

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5453: Affects Version/s: 1.4.0 > REST API request reference incomplete >

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

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6477: Component/s: (was: Web Client) Webfrontend > The first time to click

[jira] [Updated] (FLINK-6459) Move ACCESS_CONTROL_ALLOW_ORIGIN to JobManagerOptions

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6459: Affects Version/s: 1.4.0 > Move ACCESS_CONTROL_ALLOW_ORIGIN to JobManagerOptions >

[jira] [Commented] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

2017-05-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000463#comment-16000463 ] Tzu-Li (Gordon) Tai commented on FLINK-6343: Hi [~fangyong] [~minglei], thanks a lot for

[jira] [Updated] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

2017-05-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6343: --- Fix Version/s: 1.4.0 > Migrate from discouraged Java serialization for all sources /

[jira] [Commented] (FLINK-6345) Migrate from Java serialization for ContinuousFileReaderOperator's state

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

[GitHub] flink issue #3750: [FLINK-6345] [Streaming] Migrate from Java serialization ...

2017-05-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3750 Hi, sorry for the late response here. I've left a comment on the umbrella JIRA on how we proceed with this. Could you take a look? Thanks :-D --- If your project is set up for it, you can

[GitHub] flink issue #3750: [FLINK-6345] [Streaming] Migrate from Java serialization ...

2017-05-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3750 Hi, sorry for the late response here. I've left a comment on the umbrella JIRA on how we proceed with this. Could you take a look? Thanks :-D --- If your project is set up for it, you can

[jira] [Commented] (FLINK-6345) Migrate from Java serialization for ContinuousFileReaderOperator's state

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

[GitHub] flink issue #3812: [FLINK-6346] Migrate from Java serialization for GenericW...

2017-05-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3812 Hi, sorry for the late response here @fanyon. I've left a comment on the umbrella JIRA on how we proceed with this. Could you take a look? Thanks :-D --- If your project is set up for it, you

[jira] [Commented] (FLINK-6346) Migrate from Java serialization for GenericWriteAheadSink's state

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

[jira] [Created] (FLINK-6485) Use buffering to avoid frequent memtable flushes for short intervals in RockdDB incremental checkpoints

2017-05-08 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6485: - Summary: Use buffering to avoid frequent memtable flushes for short intervals in RockdDB incremental checkpoints Key: FLINK-6485 URL:

[jira] [Assigned] (FLINK-6255) Remove PatternStream.getSideOutput()

2017-05-08 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6255: - Assignee: Kostas Kloudas > Remove PatternStream.getSideOutput() >

[GitHub] flink issue #3495: [FLINK-5781][config] Generation HTML from ConfigOption

2017-05-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3495 I'll check this out again today. I will try to integrate the generated tables into the respective documentation to see if there isn't some edge case we haven't considered. If I don't find

[jira] [Commented] (FLINK-5781) Generation HTML from ConfigOption

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

[GitHub] flink issue #3776: [FLINK-6376]when deploy flink cluster on the yarn, it is ...

2017-05-08 Thread Rucongzhang
Github user Rucongzhang commented on the issue: https://github.com/apache/flink/pull/3776 @StephanEwen , yes, when configuration keytab, the hadoop code automatically renew delegation tokens .But when token and keytab are available, the hadoop use the token first, but the keytab.

[jira] [Commented] (FLINK-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token.

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

[GitHub] flink issue #3766: [FLINK-6288] fix FlinkKafkaProducer's custom Partitioner ...

2017-05-08 Thread gyfora
Github user gyfora commented on the issue: https://github.com/apache/flink/pull/3766 @tzulitai should we try to get this in the release? --- 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-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

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

[GitHub] flink issue #3803: [FLINK-6394] [runtime] Respect object reuse configuration...

2017-05-08 Thread KurtYoung
Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3803 Sorry i wasn't available in the last couple days, it seems the 1.3 branch has been created, should i merge this PR in to 1.3 branch too? --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-6394) GroupCombine reuses instances even though object reuse is disabled

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

[GitHub] flink pull request #3803: [FLINK-6394] [runtime] Respect object reuse config...

2017-05-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3803 --- 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-6394) GroupCombine reuses instances even though object reuse is disabled

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

[GitHub] flink issue #3803: [FLINK-6394] [runtime] Respect object reuse configuration...

2017-05-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3803 Yes, 1.3 and 1.2 as well. Thank you! --- 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

[jira] [Commented] (FLINK-6394) GroupCombine reuses instances even though object reuse is disabled

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

[GitHub] flink issue #3803: [FLINK-6394] [runtime] Respect object reuse configuration...

2017-05-08 Thread KurtYoung
Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3803 Ok, do it right way. --- 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

[jira] [Commented] (FLINK-6394) GroupCombine reuses instances even though object reuse is disabled

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

[jira] [Closed] (FLINK-6394) GroupCombine reuses instances even though object reuse is disabled

2017-05-08 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6394. - Resolution: Fixed Fix Version/s: 1.2.2 1.3.0 > GroupCombine reuses instances

[jira] [Created] (FLINK-6492) Unclosed DataOutputViewStream in GenericArraySerializerConfigSnapshot#write()

2017-05-08 Thread Ted Yu (JIRA)
Ted Yu created FLINK-6492: - Summary: Unclosed DataOutputViewStream in GenericArraySerializerConfigSnapshot#write() Key: FLINK-6492 URL: https://issues.apache.org/jira/browse/FLINK-6492 Project: Flink

[jira] [Created] (FLINK-6494) Migrate ResourceManager configuration options

2017-05-08 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6494: --- Summary: Migrate ResourceManager configuration options Key: FLINK-6494 URL: https://issues.apache.org/jira/browse/FLINK-6494 Project: Flink Issue

[jira] [Created] (FLINK-6496) Migrate SSL configuration options

2017-05-08 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6496: --- Summary: Migrate SSL configuration options Key: FLINK-6496 URL: https://issues.apache.org/jira/browse/FLINK-6496 Project: Flink Issue Type: Sub-task

[GitHub] flink issue #3849: [FLINK-6476] - Table environment register row data stream

2017-05-08 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/3849 @fhueske Please have a look. I inserted tests in scala and java to check the registration of the stream. For scala - it seemed to work directly if the implicit value is set (i did not

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

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

[jira] [Commented] (FLINK-6500) RowSerialization problem

2017-05-08 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001304#comment-16001304 ] radu commented on FLINK-6500: - [~fhueske] While testing various ways of using the sql i found the above

[GitHub] flink issue #3599: [FLINK-6174][HA]introduce a SMARTER leader latch to make ...

2017-05-08 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3599 Thanks for adding this! I have a few questions: - From the formatting, the code looks like might be adapted from some other project. If yes, can you share from where and add a

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

2017-05-08 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/3736 Sure. BTW, that reminds me of one thing - I need to update the project version in my code from 1.3-SNAPSHOT to 1.4-SNAPSHOT. --- If your project is set up for it, you can reply to this

[jira] [Created] (FLINK-6497) Deprecate High Availability options in ConfigConstants

2017-05-08 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6497: --- Summary: Deprecate High Availability options in ConfigConstants Key: FLINK-6497 URL: https://issues.apache.org/jira/browse/FLINK-6497 Project: Flink

[GitHub] flink issue #3495: [FLINK-5781][config] Generation HTML from ConfigOption

2017-05-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3495 I'm also thinking that we should hide ConfigOptions that are marked as deprecated, which should be rather easy to fix since we're already employing reflection. --- If your project is set up for it,

[jira] [Commented] (FLINK-5781) Generation HTML from ConfigOption

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

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

2017-05-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3736 I can merge it sometime this week, once i found a few more things to merge alongside it. --- 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-6013) Add Datadog HTTP metrics reporter

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

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

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

[jira] [Commented] (FLINK-4767) Migrate JobManager configuration options

2017-05-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001234#comment-16001234 ] Chesnay Schepler commented on FLINK-4767: - Are the blob server options part fo this, or should

[jira] [Created] (FLINK-6499) Migrate state configuration options

2017-05-08 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6499: --- Summary: Migrate state configuration options Key: FLINK-6499 URL: https://issues.apache.org/jira/browse/FLINK-6499 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-6487) Remove JobManager local mode

2017-05-08 Thread Patrick Lucas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001269#comment-16001269 ] Patrick Lucas commented on FLINK-6487: -- This appears to work: {code} #!/bin/bash JM_PID= TM_PID=

[jira] [Updated] (FLINK-6500) RowSerialization problem

2017-05-08 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6500: Description: Relying on implicit types in scala can lead to errors when the arity of the input is different than

[jira] [Updated] (FLINK-6464) Metric name is not stable

2017-05-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6464: -- Component/s: Metrics > Metric name is not stable > - > >

[jira] [Updated] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

2017-05-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6493: -- Component/s: State Backends, Checkpointing > Ineffective null check in

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

2017-05-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3736 This won't make it into 1.3. For one the feature freeze is in effect since today, so it is too late to merge it now. That said it may be possible to merge it for 1.4 and maintain a separate

[jira] [Created] (FLINK-6501) Make sure NOTICE files are bundled into shaded JAR files

2017-05-08 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-6501: --- Summary: Make sure NOTICE files are bundled into shaded JAR files Key: FLINK-6501 URL: https://issues.apache.org/jira/browse/FLINK-6501 Project: Flink Issue

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

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

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

2017-05-08 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3736 @bowenli86 Th good thing is that should be able to use the reporter version 1.4-SNAPSHOT also with a Flink 1.3 release, because the reporter API is quite stable by now. --- If your project is

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

2017-05-08 Thread rtudoran
GitHub user rtudoran opened a pull request: https://github.com/apache/flink/pull/3845 [FLINK-6476] - Table environment register row data stream Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

  1   2   >