[jira] [Updated] (FLINK-6422) Unreachable code in FileInputFormat#createInputSplits

2017-06-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6422: -- Description: Here is related code: {code} if (minNumSplits < 1) { throw new

[jira] [Resolved] (FLINK-6467) Potential lack of synchronization w.r.t. newSstFiles in RocksDBKeyedStateBackend#releaseResources()

2017-06-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-6467. --- Resolution: Not A Problem > Potential lack of synchronization w.r.t. newSstFiles in >

[jira] [Commented] (FLINK-6858) Unbounded event time Over Window emits incorrect timestamps

2017-06-06 Thread hongyuhong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039959#comment-16039959 ] hongyuhong commented on FLINK-6858: --- Hi [~fhueske], the implemention of unbounded event-time now is emit

[jira] [Commented] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2017-06-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039960#comment-16039960 ] mingleizhang commented on FLINK-6857: - +1 :) > Add global default Kryo serializer configuration to

[GitHub] flink pull request #4082: TimeIndicators

2017-06-06 Thread sunjincheng121
Github user sunjincheng121 closed the pull request at: https://github.com/apache/flink/pull/4082 --- 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

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

2017-06-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038288#comment-16038288 ] Tzu-Li (Gordon) Tai commented on FLINK-6844: [~mingleizhang] I actually already have a fix

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

2017-06-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038324#comment-16038324 ] mingleizhang commented on FLINK-6844: - :P [~tzulitai] Yes. I will review that when the patch is

[jira] [Assigned] (FLINK-6511) JobClient does not properly clean up BlobCache resources

2017-06-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6511: Assignee: Fang Yong > JobClient does not properly clean up BlobCache resources >

[GitHub] flink issue #4044: [FLINK-6803] [tests] Add test for PojoSerializer state up...

2017-06-06 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4044 Thanks for the review and that you merge the PR @tzulitai. --- 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

[jira] [Assigned] (FLINK-6418) Support for dynamic state changes in CEP patterns

2017-06-06 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-6418: --- Assignee: Dawid Wysakowicz > Support for dynamic state changes in CEP patterns >

[jira] [Updated] (FLINK-6693) Support DATE_FORMAT function in the Table / SQL API

2017-06-06 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6693: -- Summary: Support DATE_FORMAT function in the Table / SQL API (was: Support DATE_FORMAT function in the

[GitHub] flink pull request #4078: [FLINK-6693] [table] Support DATE_FORMAT function ...

2017-06-06 Thread haohui
GitHub user haohui opened a pull request: https://github.com/apache/flink/pull/4078 [FLINK-6693] [table] Support DATE_FORMAT function in the Table / SQL API. You can merge this pull request into a Git repository by running: $ git pull https://github.com/haohui/flink

[jira] [Commented] (FLINK-6693) Support DATE_FORMAT function in the Table / SQL API

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038266#comment-16038266 ] ASF GitHub Bot commented on FLINK-6693: --- GitHub user haohui opened a pull request:

[jira] [Commented] (FLINK-6803) Add test for PojoSerializer when Pojo changes

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038326#comment-16038326 ] ASF GitHub Bot commented on FLINK-6803: --- Github user tillrohrmann commented on the issue:

[jira] [Assigned] (FLINK-6798) Remove/update documentation about network buffer tuning

2017-06-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-6798: -- Assignee: Nico Kruber > Remove/update documentation about network buffer tuning >

[jira] [Created] (FLINK-6853) Migrating from Flink 1.1 fails for FlinkCEP

2017-06-06 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6853: -- Summary: Migrating from Flink 1.1 fails for FlinkCEP Key: FLINK-6853 URL: https://issues.apache.org/jira/browse/FLINK-6853 Project: Flink Issue

[jira] [Commented] (FLINK-4014) Job blocked on read/write buffer requests

2017-06-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038379#comment-16038379 ] Nico Kruber commented on FLINK-4014: Hi [~bowen.zheng], is this still an issue with Flink 1.3?

[jira] [Updated] (FLINK-5973) check whether the direct memory size is always correctly calculated

2017-06-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5973: --- Description: A user on the mailing list ran into the problem that the {{directMemorySize}} was

[jira] [Commented] (FLINK-6853) Migrating from Flink 1.1 fails for FlinkCEP

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038397#comment-16038397 ] ASF GitHub Bot commented on FLINK-6853: --- GitHub user tzulitai opened a pull request:

[GitHub] flink pull request #4079: [FLINK-6853] [DataStream] Let StreamRecordSerializ...

2017-06-06 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4079 [FLINK-6853] [DataStream] Let StreamRecordSerializer be compatible with MultiplexingStreamRecordSerializer This PR lets `StreamRecordSerializer.ensureCompatibility` be tolerable for config

[GitHub] flink issue #4073: [FLINK-6804] [state] Consistent state migration behaviour...

2017-06-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4073 Some CEP migration tests are failing due to FLINK-6853. Rebasing this PR to include the fix for that. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-6804) Inconsistent state migration behaviour between different state backends

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

[jira] [Commented] (FLINK-6488) Remove 'start-local.sh' script

2017-06-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038409#comment-16038409 ] Nico Kruber commented on FLINK-6488: should we rather redirect to {{start-cluster.sh}} instead in

[jira] [Commented] (FLINK-6807) Elasticsearch 5 connector artifact not published to maven

2017-06-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038402#comment-16038402 ] Robert Metzger commented on FLINK-6807: --- I would recommend to use the 1.3-SNAPSHOT version from the

[jira] [Assigned] (FLINK-6498) Migrate Zookeeper configuration options

2017-06-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6498: Assignee: Fang Yong > Migrate Zookeeper configuration options >

[jira] [Commented] (FLINK-6833) Race condition: Asynchronous checkpointing task can fail completed StreamTask

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038356#comment-16038356 ] ASF GitHub Bot commented on FLINK-6833: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4058: [FLINK-6833] [task] Fail StreamTask only due to as...

2017-06-06 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4058#discussion_r120291185 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -824,11 +824,14 @@ public

[jira] [Commented] (FLINK-6816) Fix wrong usage of Scala string interpolation in Table API

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038355#comment-16038355 ] ASF GitHub Bot commented on FLINK-6816: --- Github user twalthr commented on the issue:

[GitHub] flink issue #4050: [FLINK-6816] [table] Fix wrong usage of Scala string inte...

2017-06-06 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4050 Thanks @wuchong. I will merge 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

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

2017-06-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6764: --- Labels: (was: flink-rel-1.3.1-blockers) > Deduplicate stateless TypeSerializers

[jira] [Commented] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format

2017-06-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038408#comment-16038408 ] Tzu-Li (Gordon) Tai commented on FLINK-6763: After an offline discussion with

[jira] [Updated] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format

2017-06-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6763: --- Labels: (was: flink-rel-1.3.1-blockers) > Inefficient PojoSerializerConfigSnapshot

[GitHub] flink pull request #4059: [FLINK-6830] Add StatefulJobSavepointFrom13Migrati...

2017-06-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4059#discussion_r120303440 --- Diff: flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/ChainBreakTest.java --- @@ -31,8 +36,22 @@ /** *

[GitHub] flink pull request #4041: [FLINK-6198] [cep] Update CEP documentation.

2017-06-06 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/4041#discussion_r120303532 --- Diff: docs/dev/libs/cep.md --- @@ -98,48 +128,105 @@ val result: DataStream[Alert] = patternStream.select(createAlert(_)) -Note that

[jira] [Commented] (FLINK-6810) Add Some built-in Scalar Function supported

2017-06-06 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038438#comment-16038438 ] sunjincheng commented on FLINK-6810: Hi, [~wheat9] We need to do this with calcite. So, frankly I

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

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038439#comment-16038439 ] ASF GitHub Bot commented on FLINK-6198: --- Github user kl0u commented on a diff in the pull request:

[jira] [Commented] (FLINK-6695) Activate strict checkstyle in flink-contrib

2017-06-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038449#comment-16038449 ] Chesnay Schepler commented on FLINK-6695: - 1.4: wikiedits:

[jira] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038461#comment-16038461 ] ASF GitHub Bot commented on FLINK-6830: --- Github user tzulitai commented on a diff in the pull

[jira] [Updated] (FLINK-6791) Using MemoryStateBackend as checkpoint stream back-end may block checkpoint/savepoint creation

2017-06-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6791: - Affects Version/s: 1.4.0 > Using MemoryStateBackend as checkpoint stream back-end may block >

[jira] [Commented] (FLINK-4716) Add trigger full recovery button to web UI

2017-06-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038476#comment-16038476 ] Chesnay Schepler commented on FLINK-4716: - Is a handler allowed to just call {{restart()}} on the

[jira] [Created] (FLINK-6854) flink-connector-elasticsearch5_2.10 artifact is not published to mvnrepository

2017-06-06 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-6854: --- Summary: flink-connector-elasticsearch5_2.10 artifact is not published to mvnrepository Key: FLINK-6854 URL: https://issues.apache.org/jira/browse/FLINK-6854

[jira] [Commented] (FLINK-6131) Add side inputs for DataStream API

2017-06-06 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038420#comment-16038420 ] Renjie Liu commented on FLINK-6131: --- Hi, we are facing the same issues and want to solve it with

[GitHub] flink issue #4075: [FLINK-6494] Migrate ResourceManager/Yarn/Mesos configura...

2017-06-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4075 Could you split the commits into one for yarn/mesos/RM each, and remove the merge commit? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink issue #4073: [FLINK-6804] [state] Consistent state migration behaviour...

2017-06-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4073 (the rebased commits appear to be displayed in the wrong order; Github uses chronological ordering after rebases. Please see description for a better overview of the changes). --- If your project

[jira] [Commented] (FLINK-6494) Migrate ResourceManager configuration options

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

[jira] [Commented] (FLINK-6511) JobClient does not properly clean up BlobCache resources

2017-06-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038469#comment-16038469 ] Fang Yong commented on FLINK-6511: -- [~till.rohrmann] In the {{retrieveClassLoader}} of {{JobClient}}, I

[jira] [Comment Edited] (FLINK-4716) Add trigger full recovery button to web UI

2017-06-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038476#comment-16038476 ] Chesnay Schepler edited comment on FLINK-4716 at 6/6/17 9:41 AM: - Is a

[GitHub] flink issue #4059: [FLINK-6830] Add StatefulJobSavepointFrom13MigrationITCas...

2017-06-06 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4059 Why are the CEP "from12" snapshots also changed? --- 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] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038497#comment-16038497 ] ASF GitHub Bot commented on FLINK-6830: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4059: [FLINK-6830] Add StatefulJobSavepointFrom13MigrationITCas...

2017-06-06 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4059 @kl0u Could you please look into the CEP tests that failing to restore from 1.3 to 1.3? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038503#comment-16038503 ] ASF GitHub Bot commented on FLINK-6830: --- Github user aljoscha commented on the issue:

[GitHub] flink pull request #4050: [FLINK-6816] [table] Fix wrong usage of Scala stri...

2017-06-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4050 --- 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-6816) Fix wrong usage of Scala string interpolation in Table API

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

[GitHub] flink pull request #4059: [FLINK-6830] Add StatefulJobSavepointFrom13Migrati...

2017-06-06 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4059#discussion_r120317328 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java --- @@ -149,9 +169,16

[jira] [Commented] (FLINK-4650) Frequent task manager disconnects from JobManager

2017-06-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038381#comment-16038381 ] Nico Kruber commented on FLINK-4650: Hi [~nguraja], is this still an issue with Flink 1.3? Otherwise

[jira] [Updated] (FLINK-6852) Fix misuse of GCD

2017-06-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6852: -- Component/s: Machine Learning Library > Fix misuse of GCD > - > >

[jira] [Updated] (FLINK-6804) Inconsistent state migration behaviour between different state backends

2017-06-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6804: --- Labels: flink-rel-1.3.1-blockers (was: ) > Inconsistent state migration behaviour

[jira] [Commented] (FLINK-6804) Inconsistent state migration behaviour between different state backends

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

[jira] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038436#comment-16038436 ] ASF GitHub Bot commented on FLINK-6830: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink issue #4059: [FLINK-6830] Add StatefulJobSavepointFrom13MigrationITCas...

2017-06-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4059 topology tests look good. --- 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

[jira] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

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

[GitHub] flink pull request #4059: [FLINK-6830] Add StatefulJobSavepointFrom13Migrati...

2017-06-06 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4059#discussion_r120305797 --- Diff: flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/ChainBreakTest.java --- @@ -31,8 +36,22 @@ /** *

[GitHub] flink pull request #4013: [FLINK-6745] [docs] Updated Table API / SQL docs: ...

2017-06-06 Thread fhueske
Github user fhueske closed the pull request at: https://github.com/apache/flink/pull/4013 --- 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

[GitHub] flink pull request #4059: [FLINK-6830] Add StatefulJobSavepointFrom13Migrati...

2017-06-06 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4059#discussion_r120365906 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java --- @@ -149,9 +169,16

[GitHub] flink issue #4059: [FLINK-6830] Add StatefulJobSavepointFrom13MigrationITCas...

2017-06-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4059 Thanks @kl0u, your suggestions fixes the problem. Would it also be possible to include document the contiguity semantic changes in #4041? --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-6745) Table API / SQL Docs: Overview Page

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038937#comment-16038937 ] ASF GitHub Bot commented on FLINK-6745: --- Github user fhueske closed the pull request at:

[jira] [Created] (FLINK-6855) Add handler for taking a savepoint

2017-06-06 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6855: --- Summary: Add handler for taking a savepoint Key: FLINK-6855 URL: https://issues.apache.org/jira/browse/FLINK-6855 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6697) Add batch multi-window support

2017-06-06 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038949#comment-16038949 ] Timo Walther commented on FLINK-6697: - I think it is no problem to support it, but the question is if

[jira] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038953#comment-16038953 ] ASF GitHub Bot commented on FLINK-6830: --- Github user kl0u commented on the issue:

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038982#comment-16038982 ] ASF GitHub Bot commented on FLINK-6746: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038918#comment-16038918 ] ASF GitHub Bot commented on FLINK-6830: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

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

[jira] [Resolved] (FLINK-6746) Table API / SQL Docs: Common Page

2017-06-06 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6746. - Resolution: Fixed Fix Version/s: 1.4.0 Fixed in tableDocs branch:

[GitHub] flink issue #4059: [FLINK-6830] Add StatefulJobSavepointFrom13MigrationITCas...

2017-06-06 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4059 @tzulitai yes I will ;) --- 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,

[jira] [Commented] (FLINK-6602) Table source with defined time attributes allows empty string

2017-06-06 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038973#comment-16038973 ] Timo Walther commented on FLINK-6602: - Yes, I would also check for null and change the message to "The

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038977#comment-16038977 ] ASF GitHub Bot commented on FLINK-6746: --- Github user fhueske closed the pull request at:

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-06-06 Thread fhueske
Github user fhueske closed the pull request at: https://github.com/apache/flink/pull/4012 --- 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-6746) Table API / SQL Docs: Common Page

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038976#comment-16038976 ] ASF GitHub Bot commented on FLINK-6746: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: Common ...

2017-06-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4012 Thanks for merging @twalthr --- 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

[GitHub] flink issue #4061: [FLINK-6841][table]Using TableSourceTable for both Stream...

2017-06-06 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4061 I'm not sure about this change. A batch table source would be able to create a time attribute if it implements `DefinedProctimeAttribute`, right? --- If your project is set up for it, you can reply

[GitHub] flink issue #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: Common ...

2017-06-06 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4012 @fhueske can you close this PR? --- 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-6841) using TableSourceTable for both Stream and Batch OR remove useless import

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038981#comment-16038981 ] ASF GitHub Bot commented on FLINK-6841: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-6602) Table source with defined time attributes allows empty string

2017-06-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038991#comment-16038991 ] Fabian Hueske commented on FLINK-6602: -- I think we should allow {{null}} to indicate that no time

[jira] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

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

[GitHub] flink issue #4059: [FLINK-6830] Add StatefulJobSavepointFrom13MigrationITCas...

2017-06-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4059 Addressed @aljoscha @kl0u @zentol's comments. Also rebased on `master` for another Travis run. If green, will merge by the end of today to `master` and `release-1.3` if there's no other

[jira] [Resolved] (FLINK-6745) Table API / SQL Docs: Overview Page

2017-06-06 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6745. - Resolution: Fixed Fixed in tableDocs branch: ca58e6d357eeeb6f34423ec3b576213015940d2f > Table

[jira] [Updated] (FLINK-6745) Table API / SQL Docs: Overview Page

2017-06-06 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-6745: Fix Version/s: 1.4.0 > Table API / SQL Docs: Overview Page > --- >

[GitHub] flink issue #4013: [FLINK-6745] [docs] Updated Table API / SQL docs: Overvie...

2017-06-06 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4013 I merged it into the `tableDocs` branch. @fhueske can you close this PR? --- 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

[jira] [Commented] (FLINK-6745) Table API / SQL Docs: Overview Page

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038849#comment-16038849 ] ASF GitHub Bot commented on FLINK-6745: --- Github user twalthr commented on the issue:

[GitHub] flink issue #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: Common ...

2017-06-06 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4012 I will read this one more time and merge it. --- 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

[GitHub] flink pull request #4081: [FLINK-6844] [scala] Implement compatibility metho...

2017-06-06 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4081 [FLINK-6844] [scala] Implement compatibility methods for TraversableSerializer The `TraversableSerializer` is used for Scala collections, and therefore may take part in checkpointing and should

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039071#comment-16039071 ] ASF GitHub Bot commented on FLINK-6844: --- GitHub user tzulitai opened a pull request:

[jira] [Commented] (FLINK-6807) Elasticsearch 5 connector artifact not published to maven

2017-06-06 Thread Francisco Rosa (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039077#comment-16039077 ] Francisco Rosa commented on FLINK-6807: --- Thanks Robert. I am behind an environment blocking access

[GitHub] flink issue #4055: [FLINK-6817] [table] Fix NPE when preceding is not set in...

2017-06-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4055 Yes, looks good to me as well. +1 for merging and including in 1.3.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

[jira] [Commented] (FLINK-6817) Fix NPE when preceding is not set in OVER window

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039086#comment-16039086 ] ASF GitHub Bot commented on FLINK-6817: --- Github user fhueske commented on the issue:

[jira] [Created] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

2017-06-06 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6856: -- Summary: Eagerly check if serializer config snapshots are deserializable when snapshotting Key: FLINK-6856 URL: https://issues.apache.org/jira/browse/FLINK-6856

[jira] [Commented] (FLINK-6850) Links on "Powered by Flink" page not rendered correctly

2017-06-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039105#comment-16039105 ] Greg Hogan commented on FLINK-6850: --- [~yew1eb] the website code is at

[GitHub] flink issue #4077: [FLINK-6852] Fix misuse of GCD

2017-06-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4077 thanks for the PR @Xpray +1 to 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

[jira] [Commented] (FLINK-6852) Fix misuse of GCD

2017-06-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039116#comment-16039116 ] ASF GitHub Bot commented on FLINK-6852: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4077: [FLINK-6852] Fix misuse of GCD

2017-06-06 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4077 +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

  1   2   3   >