[jira] [Commented] (FLINK-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000299#comment-16000299 ] ASF GitHub Bot commented on FLINK-6448: --- Github user yanghua closed the pull request

[jira] [Assigned] (FLINK-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

2017-05-07 Thread yanghua (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanghua reassigned FLINK-6448: -- Assignee: (was: yanghua) > Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap' > --

[GitHub] flink pull request #3840: [FLINK-6448] Web UI TaskManager view: Rename 'Free...

2017-05-07 Thread yanghua
Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/3840 --- 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 ena

[jira] [Assigned] (FLINK-6451) Web UI: Rename 'Metrics' view to 'Task Metrics'

2017-05-07 Thread yanghua (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanghua reassigned FLINK-6451: -- Assignee: (was: yanghua) > Web UI: Rename 'Metrics' view to 'Task Metrics' > --

[jira] [Commented] (FLINK-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

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

[GitHub] flink pull request #3840: [FLINK-6448] Web UI TaskManager view: Rename 'Free...

2017-05-07 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/3840 [FLINK-6448] Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap' Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into conside

[jira] [Created] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6478: -- Summary: Add documentation on how to upgrade serializers for managed state Key: FLINK-6478 URL: https://issues.apache.org/jira/browse/FLINK-6478 Project:

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

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

[jira] [Commented] (FLINK-6178) Allow upgrades to state serializers

2017-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000235#comment-16000235 ] Ted Yu commented on FLINK-6178: --- Alright. Thanks, Gordon. > Allow upgrades to state serial

[GitHub] flink pull request #3810: [FLINK-6397] MultipleProgramsTestBase does not res...

2017-05-07 Thread ifndef-SleePy
Github user ifndef-SleePy commented on a diff in the pull request: https://github.com/apache/flink/pull/3810#discussion_r115170542 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MultipleProgramsTestBase.java --- @@ -80,29 +80,36 @@

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

2017-05-07 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000232#comment-16000232 ] shuai.xu commented on FLINK-6434: - [~till.rohrmann] This seems can not fix the bug totally

[jira] [Commented] (FLINK-6178) Allow upgrades to state serializers

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000231#comment-16000231 ] Tzu-Li (Gordon) Tai commented on FLINK-6178: [~te...@apache.org] regarding the

[jira] [Updated] (FLINK-6462) Add requiresOver interface for AggregateFunction

2017-05-07 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6462: --- Summary: Add requiresOver interface for AggregateFunction (was: Add requires over indicators for OV

[jira] [Commented] (FLINK-6178) Allow upgrades to state serializers

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000228#comment-16000228 ] Tzu-Li (Gordon) Tai commented on FLINK-6178: [~te...@apache.org] the version o

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

2017-05-07 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/3736 @zentol cool! Let me know how to get this into 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 t

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

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

[GitHub] flink issue #3802: Add Evenly Graph Generator to Flink Gelly

2017-05-07 Thread fanzhidongyzby
Github user fanzhidongyzby commented on the issue: https://github.com/apache/flink/pull/3802 @greghogan , ok, thanks! --- 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-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token.

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

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

2017-05-07 Thread Rucongzhang
Github user Rucongzhang commented on the issue: https://github.com/apache/flink/pull/3776 After resolving this problem, we find another problem, when we configure the keytab 、principal, and add the HDFS delegation token, the JM 、TM also use this token, but not keytab when commun

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

2017-05-07 Thread zhihao chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhihao chen updated FLINK-6477: --- Attachment: errDisplay.jpg > The first time to click Taskmanager cannot get the actual data >

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

2017-05-07 Thread zhihao chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhihao chen updated FLINK-6477: --- Affects Version/s: 1.2.0 Component/s: Web Client > The first time to click Taskmanager canno

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

2017-05-07 Thread zhihao chen (JIRA)
zhihao chen created FLINK-6477: -- Summary: The first time to click Taskmanager cannot get the actual data Key: FLINK-6477 URL: https://issues.apache.org/jira/browse/FLINK-6477 Project: Flink Iss

[jira] [Commented] (FLINK-6178) Allow upgrades to state serializers

2017-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000141#comment-16000141 ] Ted Yu commented on FLINK-6178: --- For EnumSerializerConfigSnapshot : {code} + public boolea

[jira] [Commented] (FLINK-6178) Allow upgrades to state serializers

2017-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000127#comment-16000127 ] Ted Yu commented on FLINK-6178: --- WritableSerializerConfigSnapshot#getVersion() returns an in

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

2017-05-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3736 No, I think we addressed all issues :) --- 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 enable

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

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

[jira] [Commented] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1669#comment-1669 ] ASF GitHub Bot commented on FLINK-6474: --- Github user tedyu closed the pull request a

[jira] [Resolved] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-6474. --- Resolution: Fixed Assignee: Ted Yu > Potential loss of precision in 32 bit integer multiplication >

[GitHub] flink pull request #3839: FLINK-6474 Potential loss of precision in 32 bit i...

2017-05-07 Thread tedyu
Github user tedyu closed the pull request at: https://github.com/apache/flink/pull/3839 --- 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 enabl

[jira] [Commented] (FLINK-6471) RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1662#comment-1662 ] ASF GitHub Bot commented on FLINK-6471: --- Github user StefanRRichter closed the pull

[GitHub] flink issue #3837: [FLINK-6471] [checkpoint] Fix RocksDBStateBackendTest

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3837 Merged. --- 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-6471) RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1661#comment-1661 ] ASF GitHub Bot commented on FLINK-6471: --- Github user StefanRRichter commented on the

[GitHub] flink pull request #3837: [FLINK-6471] [checkpoint] Fix RocksDBStateBackendT...

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

[jira] [Commented] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1658#comment-1658 ] ASF GitHub Bot commented on FLINK-6474: --- Github user StefanRRichter commented on the

[GitHub] flink issue #3839: FLINK-6474 Potential loss of precision in 32 bit integer ...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3839 Merged manually in 38003c2829. Please close this PR and the jira. --- 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 projec

[GitHub] flink issue #3839: FLINK-6474 Potential loss of precision in 32 bit integer ...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3839 LGTM +1, will 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 wish

[jira] [Commented] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1650#comment-1650 ] ASF GitHub Bot commented on FLINK-6474: --- Github user StefanRRichter commented on the

[jira] [Commented] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1644#comment-1644 ] ASF GitHub Bot commented on FLINK-6474: --- Github user tedyu commented on the issue:

[GitHub] flink issue #3839: FLINK-6474 Potential loss of precision in 32 bit integer ...

2017-05-07 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/3839 @StefanRRichter Can you take a look ? --- 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 enab

[jira] [Closed] (FLINK-6475) Incremental snapshots in RocksDB hold lock during async file upload

2017-05-07 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-6475. - Resolution: Fixed Fixed in 38003c2829. > Incremental snapshots in RocksDB hold lock during async

[jira] [Closed] (FLINK-6471) RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails

2017-05-07 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-6471. - Resolution: Fixed Assignee: Stefan Richter Fix Version/s: 1.3.0 Fixed in b8ffacb1b

[jira] [Closed] (FLINK-6178) Allow upgrades to state serializers

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6178. -- > Allow upgrades to state serializers > --- > >

[jira] [Closed] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6191. -- > Make non-primitive, internal built-in serializers reconfigurable > ---

[jira] [Updated] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6425: --- Fix Version/s: 1.3.0 > Integrate serializer reconfiguration into state restore flow to

[jira] [Updated] (FLINK-6190) Write "Serializer Configurations" metainfo along with state

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6190: --- Fix Version/s: 1.3.0 > Write "Serializer Configurations" metainfo along with state > -

[jira] [Closed] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6425. -- > Integrate serializer reconfiguration into state restore flow to activate > serializer upg

[jira] [Updated] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6191: --- Fix Version/s: 1.3.0 > Make non-primitive, internal built-in serializers reconfigurabl

[jira] [Closed] (FLINK-6190) Write "Serializer Configurations" metainfo along with state

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6190. -- > Write "Serializer Configurations" metainfo along with state >

[jira] [Resolved] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6191. Resolution: Fixed Merged for 1.3.0 with https://git-wip-us.apache.org/repos/asf/fli

[jira] [Resolved] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6425. Resolution: Fixed Merged for 1.3.0 with https://git-wip-us.apache.org/repos/asf/fli

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

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

[jira] [Resolved] (FLINK-6178) Allow upgrades to state serializers

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6178. Resolution: Fixed Merged for 1.3.0 with https://git-wip-us.apache.org/repos/asf/fli

[jira] [Resolved] (FLINK-6190) Write "Serializer Configurations" metainfo along with state

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6190. Resolution: Fixed Merged for 1.3.0 with https://git-wip-us.apache.org/repos/asf/fli

[jira] [Commented] (FLINK-6190) Write "Serializer Configurations" metainfo along with state

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

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

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

[GitHub] flink pull request #3804: [FLINK-6190] [core] Reconfigurable TypeSerializers

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

[jira] [Commented] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

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

[GitHub] flink pull request #3839: FLINK-6474 Potential loss of precision in 32 bit i...

2017-05-07 Thread tedyu
GitHub user tedyu opened a pull request: https://github.com/apache/flink/pull/3839 FLINK-6474 Potential loss of precision in 32 bit integer multiplication Cast numNetworkBuffers to long before multiplication. You can merge this pull request into a Git repository by running: $ g

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

2017-05-07 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1591#comment-1591 ] radu commented on FLINK-6476: - [~fhueske] [~sunjincheng121] [~shijinkui] [~stefano.bortoli] [~

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

2017-05-07 Thread radu (JIRA)
radu created FLINK-6476: --- Summary: Table environment register row data stream Key: FLINK-6476 URL: https://issues.apache.org/jira/browse/FLINK-6476 Project: Flink Issue Type: Improvement Comp

[jira] [Created] (FLINK-6475) Incremental snapshots in RocksDB hold lock during async file upload

2017-05-07 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6475: - Summary: Incremental snapshots in RocksDB hold lock during async file upload Key: FLINK-6475 URL: https://issues.apache.org/jira/browse/FLINK-6475 Project: Flink

[jira] [Created] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-07 Thread Ted Yu (JIRA)
Ted Yu created FLINK-6474: - Summary: Potential loss of precision in 32 bit integer multiplication Key: FLINK-6474 URL: https://issues.apache.org/jira/browse/FLINK-6474 Project: Flink Issue Type: Bug

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

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999873#comment-15999873 ] ASF GitHub Bot commented on FLINK-5886: --- GitHub user zohar-mizrahi opened a pull req

[GitHub] flink pull request #3838: [FLINK-5886] Python API for streaming applications

2017-05-07 Thread zohar-mizrahi
GitHub user zohar-mizrahi opened a pull request: https://github.com/apache/flink/pull/3838 [FLINK-5886] Python API for streaming applications Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If y

[jira] [Created] (FLINK-6473) Add OVER window support for batch tables

2017-05-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-6473: Summary: Add OVER window support for batch tables Key: FLINK-6473 URL: https://issues.apache.org/jira/browse/FLINK-6473 Project: Flink Issue Type: New Featur

[jira] [Commented] (FLINK-6471) RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999854#comment-15999854 ] ASF GitHub Bot commented on FLINK-6471: --- Github user tedyu commented on the issue:

[GitHub] flink issue #3837: [FLINK-6471] [checkpoint] Fix RocksDBStateBackendTest

2017-05-07 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/3837 lgtm --- 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

[jira] [Closed] (FLINK-4681) Add SessionRow row-windows for batch tables.

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4681. Resolution: Won't Do > Add SessionRow row-windows for batch tables. > --

[jira] [Closed] (FLINK-4679) Add TumbleRow row-windows to Table API

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4679. Resolution: Won't Do > Add TumbleRow row-windows to Table API >

[jira] [Closed] (FLINK-4678) Add SessionRow row-windows to Table API

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4678. Resolution: Won't Do > Add SessionRow row-windows to Table API > ---

[jira] [Updated] (FLINK-5047) Add sliding group-windows for batch tables

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5047: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-4557) > Add sliding group

[jira] [Closed] (FLINK-4683) Add SlideRow row-windows for batch tables

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4683. Resolution: Won't Do > Add SlideRow row-windows for batch tables > -

[jira] [Closed] (FLINK-4682) Add TumbleRow row-windows for batch tables.

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4682. Resolution: Won't Do > Add TumbleRow row-windows for batch tables. > ---

[jira] [Closed] (FLINK-6033) Support UNNEST query in the stream SQL API

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

[jira] [Closed] (FLINK-6257) Post-pass OVER windows

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6257. Resolution: Done Fix Version/s: 1.3.0 Done with 9f2293cfdab960246fe1aea1d705eea18a011761 > P

[GitHub] flink pull request #3836: [FLINK-6448] Web UI TaskManager view: Rename 'Free...

2017-05-07 Thread yanghua
Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/3836 --- 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 ena

[jira] [Commented] (FLINK-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999849#comment-15999849 ] ASF GitHub Bot commented on FLINK-6448: --- Github user yanghua closed the pull request

[jira] [Commented] (FLINK-6471) RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999839#comment-15999839 ] ASF GitHub Bot commented on FLINK-6471: --- GitHub user StefanRRichter opened a pull re

[GitHub] flink pull request #3837: [FLINK-6471] [checkpoint] Fix RocksDBStateBackendT...

2017-05-07 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/3837 [FLINK-6471] [checkpoint] Fix RocksDBStateBackendTest `RocksDBStateBackendTest::testCancelRunningSnapshot` sometimes failes. This is cause by a problem that I fixed in `BlockerCheckpointStrea

[jira] [Commented] (FLINK-6471) RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails

2017-05-07 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999837#comment-15999837 ] Stefan Richter commented on FLINK-6471: --- Thanks for reporting this problem. This is

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

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

[GitHub] flink issue #3834: [FLINK-6425] [runtime] Activate serializer upgrades in st...

2017-05-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3834 Thanks a lot @StefanRRichter for the review, especially on the weekends :) I'll proceed to merge this after addressing also the comment on the priority flow between the serialized old serial

[GitHub] flink issue #3834: [FLINK-6425] [runtime] Activate serializer upgrades in st...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3834 I was already familiar with the high level design of this PR from my discussions with @tzulitai. As the feature freeze is already tomorrow, I had to focus my review on the functionality of the

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999832#comment-15999832 ] ASF GitHub Bot commented on FLINK-6425: --- Github user StefanRRichter commented on the

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999826#comment-15999826 ] ASF GitHub Bot commented on FLINK-6425: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999827#comment-15999827 ] ASF GitHub Bot commented on FLINK-5823: --- Github user StefanRRichter commented on the

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999828#comment-15999828 ] ASF GitHub Bot commented on FLINK-6425: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115141585 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializer.java --- @@ -161,7 +162,93 @@ public abstract int has

[GitHub] flink issue #3522: [FLINK-5823] [checkpoints] State Backends also handle Che...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3522 I agree that we can change the Strings to some proper types later. Besides what I mentioned before, I just thought that even if a string is the underlying data type for the moment, having it w

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999824#comment-15999824 ] ASF GitHub Bot commented on FLINK-6425: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115141563 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializer.java --- @@ -161,7 +162,93 @@ public abstract int has

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999823#comment-15999823 ] ASF GitHub Bot commented on FLINK-6425: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115141548 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1473,22 +14

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115141541 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1473,22 +14

[jira] [Commented] (FLINK-6257) Post-pass OVER windows

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

[GitHub] flink pull request #3697: [FLINK-6257][table]Optimize test cases

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

[GitHub] flink pull request #3793: flink-6033 Support UNNEST query in the stream SQL ...

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

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[GitHub] flink issue #3522: [FLINK-5823] [checkpoints] State Backends also handle Che...

2017-05-07 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3522 Here is a summary of why I picked a String initially for the metadata persistence location: > The idea of the pointer is to have a state-backend independent string that indicates a check

[GitHub] flink issue #3522: [FLINK-5823] [checkpoints] State Backends also handle Che...

2017-05-07 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3522 I would like to merge this for 1.3 with a slightly reduced scope. I would include the refactoring to make the State Backends also responsible for storing the Metadata. I would NO

  1   2   >