[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

Github user hongyuhong commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r115919604 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala --- @@ -0,0 +1,323 @@ +/* + * Li

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

Github user hongyuhong commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r115919578 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala --- @@ -0,0 +1,323 @@ +/* + * Li

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

Github user hongyuhong commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r115919570 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala --- @@ -0,0 +1,323 @@ +/* + * Li

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006003#comment-16006003 ] ASF GitHub Bot commented on FLINK-6232: --- Github user hongyuhong commented on a diff

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006002#comment-16006002 ] ASF GitHub Bot commented on FLINK-6232: --- Github user hongyuhong commented on a diff

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006004#comment-16006004 ] ASF GitHub Bot commented on FLINK-6232: --- Github user hongyuhong commented on a diff

[GitHub] flink issue #3715: [FLINK-6232][Table&SQL]Support proctime inner equi-join b...

Github user hongyuhong commented on the issue: https://github.com/apache/flink/pull/3715 Hi @fhueske , Thanks very much for the review! I have update the pr use JoinFunction instead of FilterFunction, and i will add more test later. Thanks very much. Yuhong --- If your

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006016#comment-16006016 ] ASF GitHub Bot commented on FLINK-6232: --- Github user hongyuhong commented on the iss

[jira] [Commented] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006033#comment-16006033 ] mingleizhang commented on FLINK-6381: - [~kkl0u] Thanks. I guess sometimes it is a tric

[jira] [Comment Edited] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006033#comment-16006033 ] mingleizhang edited comment on FLINK-6381 at 5/11/17 7:47 AM: --

[jira] [Commented] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006045#comment-16006045 ] ASF GitHub Bot commented on FLINK-6414: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3800: [FLINK-6414] [build] Use scala.binary.version in place of...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3800 @greghogan I think we should keep the `force-shading` approach to have every project pass through the shade plugin, for various reasons. Resolving variables (as required here) is one of them, but

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

Github user haohui commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r115927398 --- Diff: flink-connectors/flink-connector-cassandra/pom.xml --- @@ -176,5 +176,23 @@ under the License.

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006053#comment-16006053 ] ASF GitHub Bot commented on FLINK-6225: --- Github user haohui commented on a diff in t

[jira] [Reopened] (FLINK-6514) Cannot start Flink Cluster in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-6514: - [~Zentol] You're right, re-opening. > Cannot start Flink Cluster in standalone mode > ---

[jira] [Created] (FLINK-6533) Duplicated registration of new shared state when checkpoint confirmations are still pending

Stefan Richter created FLINK-6533: - Summary: Duplicated registration of new shared state when checkpoint confirmations are still pending Key: FLINK-6533 URL: https://issues.apache.org/jira/browse/FLINK-6533

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r115934327 --- Diff: flink-connectors/flink-connector-cassandra/pom.xml --- @@ -176,5 +176,23 @@ under the License.

[jira] [Updated] (FLINK-6527) OperatorSubtaskState has empty implementations of (un)/registerSharedStates

[ https://issues.apache.org/jira/browse/FLINK-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6527: Priority: Blocker (was: Major) > OperatorSubtaskState has empty implementations of (un)/reg

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006101#comment-16006101 ] ASF GitHub Bot commented on FLINK-6225: --- Github user zentol commented on a diff in t

[jira] [Created] (FLINK-6534) SharedStateRegistry is disposing state handles from main thread

Stefan Richter created FLINK-6534: - Summary: SharedStateRegistry is disposing state handles from main thread Key: FLINK-6534 URL: https://issues.apache.org/jira/browse/FLINK-6534 Project: Flink

[jira] [Updated] (FLINK-6527) OperatorSubtaskState has empty implementations of (un)/registerSharedStates

[ https://issues.apache.org/jira/browse/FLINK-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6527: Fix Version/s: 1.3.0 > OperatorSubtaskState has empty implementations of (un)/registerShared

[jira] [Commented] (FLINK-6527) OperatorSubtaskState has empty implementations of (un)/registerSharedStates

[ https://issues.apache.org/jira/browse/FLINK-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006102#comment-16006102 ] Aljoscha Krettek commented on FLINK-6527: - [~srichter] I imagine this should be bl

[jira] [Updated] (FLINK-6533) Duplicated registration of new shared state when checkpoint confirmations are still pending

[ https://issues.apache.org/jira/browse/FLINK-6533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6533: Fix Version/s: 1.3.0 > Duplicated registration of new shared state when checkpoint confirmat

[jira] [Updated] (FLINK-6284) Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6284: Fix Version/s: 1.3.0 > Incorrect sorting of completed checkpoints in > ZooKeeperCompletedCh

[jira] [Updated] (FLINK-6508) Include license files of packaged dependencies

[ https://issues.apache.org/jira/browse/FLINK-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6508: Fix Version/s: 1.3.0 > Include license files of packaged dependencies >

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006106#comment-16006106 ] Robert Metzger commented on FLINK-6514: --- We could use the maven enforcer plugin to e

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

Github user haohui commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r115935549 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@ -438,

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006108#comment-16006108 ] ASF GitHub Bot commented on FLINK-6225: --- Github user haohui commented on a diff in t

[jira] [Created] (FLINK-6535) JobID should not be part of the registration key to the SharedStateRegistry

Stefan Richter created FLINK-6535: - Summary: JobID should not be part of the registration key to the SharedStateRegistry Key: FLINK-6535 URL: https://issues.apache.org/jira/browse/FLINK-6535 Project:

[GitHub] flink issue #3856: [FLINK-5998] Fix shaded Hadoop Jar

Github user gyfora commented on the issue: https://github.com/apache/flink/pull/3856 @aljoscha Yes, that might work although I prefer this fix compared to having to mess with the maven versions on deploy servers. --- If your project is set up for it, you can reply to this email and h

[jira] [Commented] (FLINK-5998) Un-fat Hadoop from Flink fat jar

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

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006137#comment-16006137 ] Kostas Kloudas commented on FLINK-6321: --- Hi [~shashank734], I am trying to reproduce

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006145#comment-16006145 ] ASF GitHub Bot commented on FLINK-6225: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r115944431 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@ -438,

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

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

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

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/3495 I do like you code, only thing missing I had in mind yesterday was an idea of defaultGroup, which is an easy way to group options with not overlapping prefixes e.g. right now in documentation (in do

[jira] [Created] (FLINK-6536) Improve error message in SharedBuffer::put()

Kostas Kloudas created FLINK-6536: - Summary: Improve error message in SharedBuffer::put() Key: FLINK-6536 URL: https://issues.apache.org/jira/browse/FLINK-6536 Project: Flink Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/FLINK-6255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6255: -- Description: We cannot currently use the result of {{select()/flatSelect()}} to get the side out

[jira] [Created] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

Stefan Richter created FLINK-6537: - Summary: Umbrella issue for fixes to incremental snapshots Key: FLINK-6537 URL: https://issues.apache.org/jira/browse/FLINK-6537 Project: Flink Issue Type:

[jira] [Updated] (FLINK-6535) JobID should not be part of the registration key to the SharedStateRegistry

[ https://issues.apache.org/jira/browse/FLINK-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6535: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-6537 > JobID should not be part o

[jira] [Updated] (FLINK-6534) SharedStateRegistry is disposing state handles from main thread

[ https://issues.apache.org/jira/browse/FLINK-6534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6534: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-6537 > SharedStateRegistry is dis

[jira] [Created] (FLINK-6538) Emit late elements as Side Outputs

Kostas Kloudas created FLINK-6538: - Summary: Emit late elements as Side Outputs Key: FLINK-6538 URL: https://issues.apache.org/jira/browse/FLINK-6538 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-6533) Duplicated registration of new shared state when checkpoint confirmations are still pending

[ https://issues.apache.org/jira/browse/FLINK-6533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6533: -- Issue Type: Sub-task (was: Bug) Parent: FLINK-6537 > Duplicated registration of new sha

[jira] [Updated] (FLINK-6527) OperatorSubtaskState has empty implementations of (un)/registerSharedStates

[ https://issues.apache.org/jira/browse/FLINK-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6527: -- Issue Type: Sub-task (was: Bug) Parent: FLINK-6537 > OperatorSubtaskState has empty imp

[jira] [Updated] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6505: -- Issue Type: Sub-task (was: Bug) Parent: FLINK-6537 > Proactively cleanup local FS for R

[jira] [Updated] (FLINK-6504) Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6504: -- Issue Type: Sub-task (was: Bug) Parent: FLINK-6537 > Lack of synchronization on materia

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

[ https://issues.apache.org/jira/browse/FLINK-6475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6475: -- Issue Type: Sub-task (was: Bug) Parent: FLINK-6537 > Incremental snapshots in RocksDB h

[jira] [Created] (FLINK-6539) Add automated end-to-end tests

Aljoscha Krettek created FLINK-6539: --- Summary: Add automated end-to-end tests Key: FLINK-6539 URL: https://issues.apache.org/jira/browse/FLINK-6539 Project: Flink Issue Type: Improvement

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

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3495 Couldn't we create the default group implicitly by taking all options that aren't part of any ConfigGroup? As in having ConfigGroup only describing sub-groups that should be excluded from the default

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

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

[jira] [Created] (FLINK-6540) Create tests that cover all the issues

Stefan Richter created FLINK-6540: - Summary: Create tests that cover all the issues Key: FLINK-6540 URL: https://issues.apache.org/jira/browse/FLINK-6540 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up

[ https://issues.apache.org/jira/browse/FLINK-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006194#comment-16006194 ] Stephan Ewen commented on FLINK-5679: - I have a refactoring for {{PartitionedStateChec

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

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/3495 It works exactly as you describe. The role of `defaultGroup` in `ConfigGroups` is setting a name of the defaultGroup. I agree using `ConfigGroup` for the `defaultGroup` may be counter intuitive.

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

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

[jira] [Updated] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6537: Fix Version/s: 1.3.0 > Umbrella issue for fixes to incremental snapshots > -

[jira] [Updated] (FLINK-6540) Add more thorough tests for RocksDB and incremental checkpointing

[ https://issues.apache.org/jira/browse/FLINK-6540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6540: Summary: Add more thorough tests for RocksDB and incremental checkpointing (was: Create tes

[GitHub] flink issue #2568: [FLINK-4636] Add boundary check for priorityqueue for cep...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2568 Hi @jaxbihani ! As you may have noticed, the `CEP` library has gone through a major refactoring and now the JIRA that this PR addresses is obsolete. Could you please close this PR? --- If your project

[jira] [Commented] (FLINK-4636) AbstractCEPPatternOperator fails to restore state

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

[jira] [Closed] (FLINK-4636) AbstractCEPPatternOperator fails to restore state

[ https://issues.apache.org/jira/browse/FLINK-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-4636. - Resolution: Fixed > AbstractCEPPatternOperator fails to restore state > --

[jira] [Commented] (FLINK-5853) Add consecutive event based filters

[ https://issues.apache.org/jira/browse/FLINK-5853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006217#comment-16006217 ] Kostas Kloudas commented on FLINK-5853: --- Hi [~dawidwys]! Isn't the same functionalit

[GitHub] flink pull request #3870: [Flink 6537] Fixes and improvements for incrementa...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/3870 [Flink 6537] Fixes and improvements for incremental checkpoints in RocksDB This PR bundles several fixes and improvements for incremental checkpoints in RocksDB. In particular, this

[jira] [Commented] (FLINK-6535) JobID should not be part of the registration key to the SharedStateRegistry

[ https://issues.apache.org/jira/browse/FLINK-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006218#comment-16006218 ] ASF GitHub Bot commented on FLINK-6535: --- GitHub user StefanRRichter opened a pull re

[GitHub] flink issue #3870: [Flink 6537] Fixes and improvements for incremental check...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3870 CC @shixiaogang @StephanEwen --- 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

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

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3495 I would use the class name, as otherwise we add an additional source of mistakes. When introducing the `ConfigGroups` annotation the first time; if the configured default name doesn't match the class

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

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

[jira] [Updated] (FLINK-6535) JobID should not be part of the registration key to the SharedStateRegistry

[ https://issues.apache.org/jira/browse/FLINK-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6535: Priority: Blocker (was: Major) > JobID should not be part of the registration key to the Sh

[jira] [Updated] (FLINK-6535) JobID should not be part of the registration key to the SharedStateRegistry

[ https://issues.apache.org/jira/browse/FLINK-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6535: Fix Version/s: 1.3.0 > JobID should not be part of the registration key to the SharedStateRe

[jira] [Commented] (FLINK-6332) Upgrade Scala version to 2.11.11

[ https://issues.apache.org/jira/browse/FLINK-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006228#comment-16006228 ] Greg Hogan commented on FLINK-6332: --- [2.11.11 concludes the 2.11 series|https://www.sca

[jira] [Updated] (FLINK-6534) SharedStateRegistry is disposing state handles from main thread

[ https://issues.apache.org/jira/browse/FLINK-6534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6534: Fix Version/s: 1.3.0 > SharedStateRegistry is disposing state handles from main thread > ---

[jira] [Updated] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6505: Fix Version/s: 1.3.0 > Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

[jira] [Updated] (FLINK-6540) Add more thorough tests for RocksDB and incremental checkpointing

[ https://issues.apache.org/jira/browse/FLINK-6540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6540: Priority: Blocker (was: Major) > Add more thorough tests for RocksDB and incremental checkp

[jira] [Updated] (FLINK-6504) Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6504: Priority: Blocker (was: Major) > Lack of synchronization on materializedSstFiles in RocksDB

[jira] [Updated] (FLINK-6504) Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6504: Fix Version/s: 1.3.0 > Lack of synchronization on materializedSstFiles in RocksDBKEyedStateB

[jira] [Updated] (FLINK-6540) Add more thorough tests for RocksDB and incremental checkpointing

[ https://issues.apache.org/jira/browse/FLINK-6540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6540: Fix Version/s: 1.3.0 > Add more thorough tests for RocksDB and incremental checkpointing > -

[jira] [Updated] (FLINK-6534) SharedStateRegistry is disposing state handles from main thread

[ https://issues.apache.org/jira/browse/FLINK-6534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6534: Priority: Blocker (was: Major) > SharedStateRegistry is disposing state handles from main t

[jira] [Updated] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6505: Priority: Blocker (was: Major) > Proactively cleanup local FS for RocksDBKeyedStateBackend

[GitHub] flink issue #3755: [FLINK-6351] [YARN] Refactoring YarnFlinkApplicationMaste...

Github user shuai-xu commented on the issue: https://github.com/apache/flink/pull/3755 There will soon be a YarnFlinkAppMaster extends AbstractYarnFlinkApplicationMasterRunner for flink yarn cluster mode, so need not combine them to one class. --- If your project is set up for it, y

[jira] [Commented] (FLINK-6351) Refactor YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006237#comment-16006237 ] ASF GitHub Bot commented on FLINK-6351: --- Github user shuai-xu commented on the issue

[GitHub] flink issue #3783: [FLINK-6388] Add support for DISTINCT into Code Generated...

Github user huawei-flink commented on the issue: https://github.com/apache/flink/pull/3783 @fhueske , this is the PR with the code generated distinct aggregation for OVER. You mentioned that the value of the aggregation should be a Row, but what is kept in the distinct state is just t

[jira] [Commented] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations

[ https://issues.apache.org/jira/browse/FLINK-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006254#comment-16006254 ] ASF GitHub Bot commented on FLINK-6388: --- Github user huawei-flink commented on the i

[jira] [Commented] (FLINK-5853) Add consecutive event based filters

[ https://issues.apache.org/jira/browse/FLINK-5853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006272#comment-16006272 ] Dawid Wysakowicz commented on FLINK-5853: - Hi [~kkl0u], Yes it is. I agree [FLINK-

[jira] [Closed] (FLINK-5853) Add consecutive event based filters

[ https://issues.apache.org/jira/browse/FLINK-5853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-5853. --- Resolution: Duplicate > Add consecutive event based filters >

[GitHub] flink pull request #3495: [FLINK-5781][config] Generation HTML from ConfigOp...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3495#discussion_r115971869 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigOptionsDocGenerator.java --- @@ -0,0 +1,279 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #3495: [FLINK-5781][config] Generation HTML from ConfigOp...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3495#discussion_r115971032 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigOptionsDocGenerator.java --- @@ -0,0 +1,279 @@ +/* + * Licensed to the Apache

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

[ https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006304#comment-16006304 ] ASF GitHub Bot commented on FLINK-5781: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #3495: [FLINK-5781][config] Generation HTML from ConfigOp...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3495#discussion_r115971425 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigOptionsDocGenerator.java --- @@ -0,0 +1,279 @@ +/* + * Licensed to the Apache

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

[ https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006303#comment-16006303 ] ASF GitHub Bot commented on FLINK-5781: --- Github user zentol commented on a diff in t

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

[ https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006305#comment-16006305 ] ASF GitHub Bot commented on FLINK-5781: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #3495: [FLINK-5781][config] Generation HTML from ConfigOp...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3495#discussion_r115972341 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigGroup.java --- @@ -0,0 +1,37 @@ +/* + * Licensed to the Apache Software Founda

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

[ https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006307#comment-16006307 ] ASF GitHub Bot commented on FLINK-5781: --- Github user zentol commented on a diff in t

[jira] [Closed] (FLINK-3703) Add sequence matching semantics to discard matched events

[ https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-3703. - Resolution: Implemented Fix Version/s: 1.3.0 This was covered by other issues including the

[GitHub] flink pull request #3495: [FLINK-5781][config] Generation HTML from ConfigOp...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3495#discussion_r115972689 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigOptionsDocGenerator.java --- @@ -0,0 +1,279 @@ +/* + * Licensed to the Apache

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

[ https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006311#comment-16006311 ] ASF GitHub Bot commented on FLINK-5781: --- Github user zentol commented on a diff in t

[GitHub] flink issue #2367: [FLINK-3703][cep] Add sequence matching semantics to disc...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2367 Hi @mushketyk . I am trying to clean up a bit the open PRs for the CEP library and the related JIRAs. The issue that this PR covers was already implemented as part of multiple other featu

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

[GitHub] flink pull request #3495: [FLINK-5781][config] Generation HTML from ConfigOp...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3495#discussion_r115973034 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigOptionsDocGenerator.java --- @@ -0,0 +1,279 @@ +/* + * Licensed to the Apache

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

[ https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006316#comment-16006316 ] ASF GitHub Bot commented on FLINK-5781: --- Github user zentol commented on a diff in t

[jira] [Created] (FLINK-6541) Jar upload directory not created

Andrey created FLINK-6541: - Summary: Jar upload directory not created Key: FLINK-6541 URL: https://issues.apache.org/jira/browse/FLINK-6541 Project: Flink Issue Type: Bug Affects Versions: 1.2.0

[jira] [Created] (FLINK-6542) Non-keyed, non-windowed aggregation fails

Timo Walther created FLINK-6542: --- Summary: Non-keyed, non-windowed aggregation fails Key: FLINK-6542 URL: https://issues.apache.org/jira/browse/FLINK-6542 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-6542) Non-keyed, non-windowed aggregation fails

[ https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-6542: Affects Version/s: 1.3.0 > Non-keyed, non-windowed aggregation fails > -

  1   2   3   >