[jira] [Commented] (FLINK-7475) support update() in ListState

[ https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249096#comment-16249096 ] ASF GitHub Bot commented on FLINK-7475: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #4963: [FLINK-7475] [core][DataStream API] support update() in L...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4963 @yunfan123 sorry I can't find where `PredefinedOptions` defines it. Isn't Flink using RocksDB's `StringAppendTESTOperator` in `RocksDBKeyedStateBackend`? Hi @aljoscha , do you have

[jira] [Commented] (FLINK-7475) support update() in ListState

[ https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249066#comment-16249066 ] ASF GitHub Bot commented on FLINK-7475: --- Github user yunfan123 commented on the issue:

[GitHub] flink issue #4963: [FLINK-7475] [core][DataStream API] support update() in L...

Github user yunfan123 commented on the issue: https://github.com/apache/flink/pull/4963 Flink use StringAppendOperator as merge operator. It used in org.apache.flink.contrib.streaming.state.PredefinedOptions. It use native java method. Can we use the native method to merge

[GitHub] flink pull request #5002: [hotfix][docs] Remove the caveat about Cassandra c...

GitHub user mcfongtw opened a pull request: https://github.com/apache/flink/pull/5002 [hotfix][docs] Remove the caveat about Cassandra connector. ## What is the purpose of the change Remove a caveat in Cassandra connector docs. ## Brief change log As

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249046#comment-16249046 ] ASF GitHub Bot commented on FLINK-4500: --- GitHub user mcfongtw opened a pull request:

[jira] [Commented] (FLINK-8006) flink-daemon.sh: line 103: binary operator expected

[ https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16248964#comment-16248964 ] ASF GitHub Bot commented on FLINK-8006: --- Github user elbaulp commented on the issue:

[GitHub] flink issue #4968: [FLINK-8006] [Startup Shell Scripts] Enclosing $pid in qu...

Github user elbaulp commented on the issue: https://github.com/apache/flink/pull/4968 Hi, Do I need to do something more in order to this PR be merged? ---

[jira] [Updated] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish

[ https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7049: -- Description: After integration tests finish, TestingApplicationMaster is still running. Toward the end of

[jira] [Updated] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

[ https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7775: -- Description: {code} public int getNumberOfCachedJobs() { return jobRefCounters.size(); } {code} The

[jira] [Updated] (FLINK-7877) Fix compilation against the Hadoop 3 beta1 release

[ https://issues.apache.org/jira/browse/FLINK-7877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7877: -- Labels: (was: build) > Fix compilation against the Hadoop 3 beta1 release >

[jira] [Commented] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

[ https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16248924#comment-16248924 ] ASF GitHub Bot commented on FLINK-8046: --- Github user juanmirocks commented on the issue:

[GitHub] flink issue #4997: [FLINK-8046] [flink-streaming-java] Have filter of timest...

Github user juanmirocks commented on the issue: https://github.com/apache/flink/pull/4997 Perhaps access time could be leveraged. However, as of Flink 1.3.2 `FileStatus#getAccessTime()` (at least for a local file system), always returns `0` ... ---

[jira] [Commented] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

[ https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16248913#comment-16248913 ] ASF GitHub Bot commented on FLINK-8046: --- Github user juanmirocks commented on the issue:

[GitHub] flink issue #4997: [FLINK-8046] [flink-streaming-java] Have filter of timest...

Github user juanmirocks commented on the issue: https://github.com/apache/flink/pull/4997 No. I don't think this is going to be a suitable solution, as if = is allowed in the comparison, the very same file will be triggered multiple times. Note that the older and deprecated

[jira] [Created] (FLINK-8049) RestClient#shutdown() ignores exceptions thrown when shutting down netty.

Kostas Kloudas created FLINK-8049: - Summary: RestClient#shutdown() ignores exceptions thrown when shutting down netty. Key: FLINK-8049 URL: https://issues.apache.org/jira/browse/FLINK-8049 Project:

[jira] [Created] (FLINK-8050) RestServer#shutdown() ignores exceptions thrown when shutting down netty.

Kostas Kloudas created FLINK-8050: - Summary: RestServer#shutdown() ignores exceptions thrown when shutting down netty. Key: FLINK-8050 URL: https://issues.apache.org/jira/browse/FLINK-8050 Project:

[jira] [Commented] (FLINK-4575) DataSet aggregate methods should support POJOs

[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16248874#comment-16248874 ] Gabor Gevay commented on FLINK-4575: [~vcycyv], I'm not sure how would {{getFlatFields}} help here.