[jira] [Assigned] (FLINK-6749) Table API / SQL Docs: SQL Page

[ https://issues.apache.org/jira/browse/FLINK-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6749: - Assignee: Haohui Mai > Table API / SQL Docs: SQL Page > -- > >

[jira] [Commented] (FLINK-5354) Split up Table API documentation into multiple pages

[ https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030740#comment-16030740 ] Fabian Hueske commented on FLINK-5354: -- Thanks [~twalthr] and [~wheat9]! > Split up Table API

[jira] [Commented] (FLINK-5354) Split up Table API documentation into multiple pages

[ https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030728#comment-16030728 ] Haohui Mai commented on FLINK-5354: --- Thanks [~fhueske]. I will work on the SQL page. > Split up Table

[jira] [Assigned] (FLINK-6775) StateDescriptor cannot be shared by multiple subtasks

[ https://issues.apache.org/jira/browse/FLINK-6775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-6775: Assignee: Till Rohrmann > StateDescriptor cannot be shared by multiple subtasks >

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

Github user twalthr closed the pull request at: https://github.com/apache/flink/pull/4020 --- 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-6747) Table API / SQL Docs: Streaming Page

[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030864#comment-16030864 ] ASF GitHub Bot commented on FLINK-6747: --- Github user twalthr closed the pull request at:

[jira] [Commented] (FLINK-6617) Improve JAVA and SCALA logical plans consistent test

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

[GitHub] flink issue #3943: [FLINK-6617][table] Improve JAVA and SCALA logical plans ...

Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3943 **I once again seriously consider the Refactoring work, according to the following principles updated the PR.**    **First, the test type and purpose(4 types):** * Unit Test:

[jira] [Commented] (FLINK-6747) Table API / SQL Docs: Streaming Page

[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030829#comment-16030829 ] ASF GitHub Bot commented on FLINK-6747: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4020#discussion_r119297963 --- Diff: docs/dev/table/streaming.md --- @@ -39,17 +39,293 @@ Dynamic table Time Attributes --- -### Event-time +Flink

[jira] [Updated] (FLINK-6780) ExternalTableSource fails to add the processing time and the event time attribute in the row type

[ https://issues.apache.org/jira/browse/FLINK-6780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6780: -- Component/s: Table API & SQL > ExternalTableSource fails to add the processing time and the

[jira] [Created] (FLINK-6781) Make fetch size configurable in JDBCInputFormat

Maximilian Bode created FLINK-6781: -- Summary: Make fetch size configurable in JDBCInputFormat Key: FLINK-6781 URL: https://issues.apache.org/jira/browse/FLINK-6781 Project: Flink Issue

[jira] [Commented] (FLINK-6747) Table API / SQL Docs: Streaming Page

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

[GitHub] flink issue #4020: [FLINK-6747] [table] [docs] Time attributes section added

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4020 Thanks for the feedback @alpinegizmo and @fhueske. I hope I addressed all your comments. I will merge it. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030861#comment-16030861 ] Kostas Kloudas commented on FLINK-6772: --- I agree with [~rmetzger] that this can wait till 1.3.1.

[jira] [Commented] (FLINK-6747) Table API / SQL Docs: Streaming Page

[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030866#comment-16030866 ] Timo Walther commented on FLINK-6747: - Time attributes docs merged in tableDocs feature branch with

[jira] [Updated] (FLINK-6780) ExternalTableSource should add time attributes in the row type

[ https://issues.apache.org/jira/browse/FLINK-6780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6780: -- Summary: ExternalTableSource should add time attributes in the row type (was: ExternalTableSource

[jira] [Commented] (FLINK-6780) ExternalTableSource should add time attributes in the row type

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

[GitHub] flink pull request #4023: [FLINK-6780] [table] ExternalTableSource should ad...

GitHub user haohui opened a pull request: https://github.com/apache/flink/pull/4023 [FLINK-6780] [table] ExternalTableSource should add time attributes in the row type You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (FLINK-6782) Update savepoint documentation

Nico Kruber created FLINK-6782: -- Summary: Update savepoint documentation Key: FLINK-6782 URL: https://issues.apache.org/jira/browse/FLINK-6782 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-6741) In yarn cluster model with high available， the HDFS file is not deleted when cluster is shot down

[ https://issues.apache.org/jira/browse/FLINK-6741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030885#comment-16030885 ] zhangrucong1982 commented on FLINK-6741: Hi Tzu-LI, I pull the code of FLINK-6646 and verify the

[GitHub] flink pull request #4011: [FLINK-6766] Update documentation about async back...

Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4011#discussion_r119344251 --- Diff: docs/monitoring/large_state_tuning.md --- @@ -138,6 +138,22 @@ Unfortunately, RocksDB's performance can vary with configuration, and there is

[GitHub] flink pull request #4011: [FLINK-6766] Update documentation about async back...

Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4011#discussion_r119344563 --- Diff: docs/ops/state_backends.md --- @@ -88,6 +102,13 @@ that is (per default) stored in the TaskManager data directories. Upon checkpoin

[jira] [Updated] (FLINK-6674) Update release 1.3 docs

[ https://issues.apache.org/jira/browse/FLINK-6674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6674: -- Fix Version/s: (was: 1.4.0) 1.3.0 > Update release 1.3 docs >

[jira] [Updated] (FLINK-6766) Update documentation with async backends and incremental checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6766: -- Fix Version/s: (was: 1.4.0) 1.3.0 > Update documentation with async

[jira] [Updated] (FLINK-6680) App & Flink migration guide: updates for the 1.3 release

[ https://issues.apache.org/jira/browse/FLINK-6680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6680: -- Fix Version/s: (was: 1.4.0) 1.3.0 > App & Flink migration guide: updates

[jira] [Updated] (FLINK-6679) Document HeapStatebackend

[ https://issues.apache.org/jira/browse/FLINK-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6679: -- Fix Version/s: (was: 1.4.0) 1.3.0 > Document HeapStatebackend >

[jira] [Commented] (FLINK-6570) QueryableStateClient constructor in documentation doesn't match actual signature

[ https://issues.apache.org/jira/browse/FLINK-6570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031090#comment-16031090 ] Robert Metzger commented on FLINK-6570: --- Can you open a pull request to fix it? >

[jira] [Updated] (FLINK-6677) API Migration guide: add Table API changes

[ https://issues.apache.org/jira/browse/FLINK-6677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6677: -- Fix Version/s: (was: 1.4.0) 1.3.0 > API Migration guide: add Table API

[jira] [Updated] (FLINK-6678) API Migration guide: add note about removed log4j default logger from core artefacts

[ https://issues.apache.org/jira/browse/FLINK-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6678: -- Fix Version/s: (was: 1.4.0) 1.3.0 > API Migration guide: add note about

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

[ https://issues.apache.org/jira/browse/FLINK-6478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6478: -- Fix Version/s: (was: 1.4.0) 1.3.0 > Add documentation on how to upgrade

[jira] [Updated] (FLINK-6676) API Migration guide: add QueryableStateClient changes

[ https://issues.apache.org/jira/browse/FLINK-6676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6676: -- Fix Version/s: (was: 1.4.0) 1.3.0 > API Migration guide: add

[jira] [Updated] (FLINK-6683) building with Scala 2.11 no longer uses change-scala-version.sh

[ https://issues.apache.org/jira/browse/FLINK-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6683: -- Fix Version/s: (was: 1.4.0) 1.3.0 > building with Scala 2.11 no longer

[jira] [Updated] (FLINK-6383) Add versioning for AbstractStreamOperator state

[ https://issues.apache.org/jira/browse/FLINK-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6383: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Add versioning for

[jira] [Updated] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-6783: Component/s: (was: DataStream API) (was: Type Serialization System)

[jira] [Commented] (FLINK-6752) Activate strict checkstyle for flink-core

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

[GitHub] flink issue #4027: [FLINK-6752] Apply non-invasive checkstyle rules to flink...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4027 How much value is there in keeping the checkstyle changes to a single commit per module? It would mean fewer rebase conflicts for outstanding PRs and WIPs. The long-running tickets for large

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1603#comment-1603 ] Aljoscha Krettek commented on FLINK-6783: - [~dawidwys] I think you could also change the

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031115#comment-16031115 ] Dawid Wysakowicz commented on FLINK-6783: - Sure [~aljoscha], will do! > Wrongly extracted

[jira] [Commented] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers

[ https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031117#comment-16031117 ] ASF GitHub Bot commented on FLINK-6764: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Updated] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6783: Affects Version/s: 1.3.1 > Wrongly extracted TypeInformations for WindowedStream::aggregate

[jira] [Commented] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers

[ https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031116#comment-16031116 ] ASF GitHub Bot commented on FLINK-6764: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4026: [FLINK-6764] Deduplicate stateless serializers in ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4026#discussion_r119348073 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializerTest.java --- @@ -606,6 +665,45 @@ public void

[GitHub] flink issue #4004: [FLINK-6695] Activate strict checkstyle in flink-contrib

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4004 +1! --- 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

[GitHub] flink issue #4004: [FLINK-6695] Activate strict checkstyle in flink-contrib

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4004 @greghogan did another attempt at fixing the 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

[jira] [Assigned] (FLINK-6730) Activate strict checkstyle for flink-optimizer

[ https://issues.apache.org/jira/browse/FLINK-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6730: --- Assignee: Chesnay Schepler > Activate strict checkstyle for flink-optimizer >

[GitHub] flink issue #4010: [FLINK-6753] [table] Fix flaky SqlITCase due to Janino bu...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4010 Merging this... --- 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

[jira] [Commented] (FLINK-6753) Flaky SqlITCase

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

[jira] [Commented] (FLINK-6782) Update savepoint documentation

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

[GitHub] flink pull request #4026: [FLINK-6764] Deduplicate stateless serializers in ...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4026 [FLINK-6764] Deduplicate stateless serializers in checkpoints This PR is based on #4014, so only the last commit 39ffe7e is relevant. Prior to this PR, we would write multiple instances of

[jira] [Commented] (FLINK-6775) StateDescriptor cannot be shared by multiple subtasks

[ https://issues.apache.org/jira/browse/FLINK-6775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031059#comment-16031059 ] ASF GitHub Bot commented on FLINK-6775: --- Github user aljoscha commented on a diff in the pull

[jira] [Updated] (FLINK-6678) API Migration guide: add note about removed log4j default logger from core artefacts

[ https://issues.apache.org/jira/browse/FLINK-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6678: -- Fix Version/s: (was: 1.3.0) 1.4.0 > API Migration guide: add note about

[jira] [Updated] (FLINK-6654) missing maven dependency on "flink-shaded-hadoop2-uber" in flink-dist

[ https://issues.apache.org/jira/browse/FLINK-6654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6654: -- Fix Version/s: (was: 1.3.0) 1.4.0 > missing maven dependency on

[jira] [Commented] (FLINK-6766) Update documentation with async backends and incremental checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031085#comment-16031085 ] ASF GitHub Bot commented on FLINK-6766: --- Github user alpinegizmo commented on a diff in the pull

[jira] [Updated] (FLINK-5491) Document default settings for yarn cluster mode

[ https://issues.apache.org/jira/browse/FLINK-5491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5491: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Document default settings for yarn

[jira] [Updated] (FLINK-6049) Parallelize execution of (async) snapshots in AsyncCheckpointRunnable

[ https://issues.apache.org/jira/browse/FLINK-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6049: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Parallelize execution of (async)

[jira] [Updated] (FLINK-6163) Document per-window state in ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-6163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6163: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Document per-window state in

[jira] [Updated] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6569: -- Fix Version/s: (was: 1.3.0) 1.4.0 > flink-table KafkaJsonTableSource

[jira] [Created] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

Dawid Wysakowicz created FLINK-6783: --- Summary: Wrongly extracted TypeInformations for WindowedStream::aggregate Key: FLINK-6783 URL: https://issues.apache.org/jira/browse/FLINK-6783 Project: Flink

[jira] [Updated] (FLINK-6546) Fix dependencies of flink-mesos

[ https://issues.apache.org/jira/browse/FLINK-6546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6546: -- Fix Version/s: (was: 1.3.0) > Fix dependencies of flink-mesos >

[jira] [Updated] (FLINK-5455) Create documentation how to upgrade jobs and Flink framework versions

[ https://issues.apache.org/jira/browse/FLINK-5455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5455: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Create documentation how to upgrade

[jira] [Updated] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

[ https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5479: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Per-partition watermarks in

[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 ] Robert Metzger updated FLINK-6505: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Proactively cleanup local FS for

[jira] [Updated] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6301: -- Fix Version/s: (was: 1.3.0) > Flink KafkaConnector09 leaks memory on reading compressed

[jira] [Updated] (FLINK-6244) Emit timeouted Patterns as Side Output

[ https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6244: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Emit timeouted Patterns as Side

[jira] [Updated] (FLINK-6198) Update the documentation of the CEP library to include all the new features.

[ https://issues.apache.org/jira/browse/FLINK-6198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6198: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Update the documentation of the CEP

[jira] [Updated] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout

[ https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6160: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Retry JobManager/ResourceManager

[jira] [Updated] (FLINK-5919) port range support for config taskmanager.data.port

[ https://issues.apache.org/jira/browse/FLINK-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5919: -- Fix Version/s: (was: 1.3.0) 1.4.0 > port range support for config

[jira] [Updated] (FLINK-5851) Renaming AsyncCollector into ResultPromise/ResultFuture

[ https://issues.apache.org/jira/browse/FLINK-5851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5851: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Renaming AsyncCollector into

[jira] [Updated] (FLINK-6692) The flink-dist jar contains unshaded netty jar

[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6692: -- Fix Version/s: (was: 1.3.0) 1.4.0 > The flink-dist jar contains unshaded

[jira] [Updated] (FLINK-6215) Make the StatefulSequenceSource scalable.

[ https://issues.apache.org/jira/browse/FLINK-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6215: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Make the StatefulSequenceSource

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

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6225: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Support Row Stream for CassandraSink

[jira] [Updated] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations

[ https://issues.apache.org/jira/browse/FLINK-5127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5127: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Reduce the amount of intermediate

[GitHub] flink pull request #4011: [FLINK-6766] Update documentation about async back...

Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4011#discussion_r119344615 --- Diff: docs/ops/state_backends.md --- @@ -88,6 +102,13 @@ that is (per default) stored in the TaskManager data directories. Upon checkpoin

[jira] [Updated] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4022: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Partition discovery / regex topic

[jira] [Updated] (FLINK-5513) Remove relocation of internal API classes

[ https://issues.apache.org/jira/browse/FLINK-5513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5513: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Remove relocation of internal API

[jira] [Updated] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSysten

[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5789: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Make Bucketing Sink independent of

[jira] [Updated] (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:all-tabpanel ] Robert Metzger updated FLINK-6321: -- Fix Version/s: (was: 1.3.0) 1.4.0 > RocksDB state backend Checkpointing

[jira] [Updated] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6273: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Client can't connect to jobmanager

[jira] [Updated] (FLINK-6437) Move history server configuration to a separate file

[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6437: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Move history server configuration to

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

[ https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5823: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Store Checkpoint Root Metadata in

[jira] [Commented] (FLINK-6766) Update documentation with async backends and incremental checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031087#comment-16031087 ] ASF GitHub Bot commented on FLINK-6766: --- Github user alpinegizmo commented on a diff in the pull

[jira] [Updated] (FLINK-5340) Add a metric exposing jobs uptimes

[ https://issues.apache.org/jira/browse/FLINK-5340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5340: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Add a metric exposing jobs uptimes >

[jira] [Updated] (FLINK-5472) WebUI endpoint not advertised correctly to Mesos

[ https://issues.apache.org/jira/browse/FLINK-5472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5472: -- Fix Version/s: (was: 1.3.0) 1.4.0 > WebUI endpoint not advertised

[jira] [Updated] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6352: -- Fix Version/s: (was: 1.3.0) 1.4.0 > FlinkKafkaConsumer should support to

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

[ https://issues.apache.org/jira/browse/FLINK-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6538: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Emit late elements as Side Outputs >

[jira] [Commented] (FLINK-6766) Update documentation with async backends and incremental checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031086#comment-16031086 ] ASF GitHub Bot commented on FLINK-6766: --- Github user alpinegizmo commented on a diff in the pull

[jira] [Updated] (FLINK-5564) User Defined Aggregates

[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5564: -- Fix Version/s: (was: 1.3.0) 1.4.0 > User Defined Aggregates >

[jira] [Updated] (FLINK-5918) port range support for config taskmanager.rpc.port

[ https://issues.apache.org/jira/browse/FLINK-5918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5918: -- Fix Version/s: (was: 1.3.0) 1.4.0 > port range support for config

[jira] [Updated] (FLINK-5967) Document AggregatingState

[ https://issues.apache.org/jira/browse/FLINK-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5967: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Document AggregatingState >

[jira] [Updated] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks

[ https://issues.apache.org/jira/browse/FLINK-5015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5015: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Add Tests/ITCase for Kafka

[jira] [Updated] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6665: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Pass a ScheduledExecutorService to

[jira] [Updated] (FLINK-6605) Allow users to specify a default name for processing time

[ https://issues.apache.org/jira/browse/FLINK-6605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6605: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Allow users to specify a default

[jira] [Updated] (FLINK-4944) Replace Akka's death watch with own heartbeat on the TM side

[ https://issues.apache.org/jira/browse/FLINK-4944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4944: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Replace Akka's death watch with own

[jira] [Updated] (FLINK-5763) Make savepoints self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5763: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Make savepoints self-contained and

[jira] [Updated] (FLINK-6100) Add documentation for Projectable and Filterable TableSource

[ https://issues.apache.org/jira/browse/FLINK-6100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6100: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Add documentation for Projectable

[jira] [Updated] (FLINK-6180) Remove TestingSerialRpcService

[ https://issues.apache.org/jira/browse/FLINK-6180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6180: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Remove TestingSerialRpcService >

[jira] [Updated] (FLINK-2910) Reorganize / Combine Gelly tests

[ https://issues.apache.org/jira/browse/FLINK-2910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2910: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Reorganize / Combine Gelly tests >

[jira] [Updated] (FLINK-6683) building with Scala 2.11 no longer uses change-scala-version.sh

[ https://issues.apache.org/jira/browse/FLINK-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6683: -- Fix Version/s: (was: 1.3.0) 1.4.0 > building with Scala 2.11 no longer

[jira] [Updated] (FLINK-6782) Update savepoint documentation

[ https://issues.apache.org/jira/browse/FLINK-6782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6782: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Update savepoint documentation >

  1   2   3   4   >