[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698092#comment-16698092 ] Amit commented on FLINK-10918: -- Un-related streaming test cases are failing, while the fork

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698071#comment-16698071 ] ASF GitHub Bot commented on FLINK-10918: imamitsehgal commented on issue #7171:

[GitHub] imamitsehgal commented on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock …

imamitsehgal commented on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock … URL: https://github.com/apache/flink/pull/7171#issuecomment-441417072 The build is passing on the forked branch, the failure here is unrelated https://travis-ci.org/imamitsehgal/

[GitHub] xueyumusic commented on issue #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common

xueyumusic commented on issue #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7059#issuecomment-441416404 Thanks for review, @twalthr , I updated the codes. -

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698067#comment-16698067 ] ASF GitHub Bot commented on FLINK-10689: xueyumusic commented on issue #7059: [F

[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698043#comment-16698043 ] wgcn commented on FLINK-10884: -- I think the  memory assigned to  jvm  not only contains  "

[jira] [Commented] (FLINK-7883) Make savepoints atomic with respect to state and side effects

[ https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697931#comment-16697931 ] Steven Zhen Wu commented on FLINK-7883: --- We would love to see this happening. it is

[jira] [Comment Edited] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697677#comment-16697677 ] Zhenqiu Huang edited comment on FLINK-10868 at 11/24/18 5:48 PM: -

[jira] [Updated] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-10868: -- Summary: Flink's JobCluster ResourceManager doesn't use yarn.maximum-failed-containers as limi

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697871#comment-16697871 ] ASF GitHub Bot commented on FLINK-10918: imamitsehgal commented on issue #7171:

[GitHub] imamitsehgal commented on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock …

imamitsehgal commented on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock … URL: https://github.com/apache/flink/pull/7171#issuecomment-441378109 What is the purpose of the change? To fix the issue with creating directory while running on windows with ke

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697868#comment-16697868 ] ASF GitHub Bot commented on FLINK-10918: imamitsehgal opened a new pull request

[GitHub] imamitsehgal opened a new pull request #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock …

imamitsehgal opened a new pull request #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock … URL: https://github.com/apache/flink/pull/7171 …db backend ## What is the purpose of the change *(For example: This pull request makes task deployment g

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697867#comment-16697867 ] ASF GitHub Bot commented on FLINK-10918: imamitsehgal closed pull request #7153:

[GitHub] imamitsehgal closed pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state

imamitsehgal closed pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state URL: https://github.com/apache/flink/pull/7153 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for th

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697807#comment-16697807 ] ASF GitHub Bot commented on FLINK-10918: imamitsehgal commented on a change in p

[GitHub] imamitsehgal commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state

imamitsehgal commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state URL: https://github.com/apache/flink/pull/7153#discussion_r236042030 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697806#comment-16697806 ] ASF GitHub Bot commented on FLINK-10918: imamitsehgal commented on a change in p

[GitHub] imamitsehgal commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state

imamitsehgal commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state URL: https://github.com/apache/flink/pull/7153#discussion_r236042001 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/

[GitHub] imamitsehgal commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state

imamitsehgal commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state URL: https://github.com/apache/flink/pull/7153#discussion_r236041049 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697781#comment-16697781 ] ASF GitHub Bot commented on FLINK-10918: imamitsehgal commented on a change in p

[jira] [Commented] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697745#comment-16697745 ] ideal-hp commented on FLINK-10999: -- Thank you for your help! I updated the update in de

[jira] [Commented] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697743#comment-16697743 ] xuqianjin commented on FLINK-10999: --- [~harbby] I understand your description. Thank yo

[jira] [Created] (FLINK-11001) Window rowtime attribute can't be renamed in Java

Hequn Cheng created FLINK-11001: --- Summary: Window rowtime attribute can't be renamed in Java Key: FLINK-11001 URL: https://issues.apache.org/jira/browse/FLINK-11001 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697730#comment-16697730 ] ideal-hp commented on FLINK-10999: -- [~x1q1j1]: Hi, I am very sorry, my expression is no

[jira] [Commented] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697701#comment-16697701 ] xuqianjin commented on FLINK-10999: --- [~harbby]It is not easy to understand your questi