[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683695#comment-16683695 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683690#comment-16683690 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636122 ## File path: docs/dev/connectors/pubsub.md ##

[jira] [Commented] (FLINK-10753) Propagate and log snapshotting exceptions

[ https://issues.apache.org/jira/browse/FLINK-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683687#comment-16683687 ] ASF GitHub Bot commented on FLINK-10753: StefanRRichter commented on issue #7064: [FLINK-10753]

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636183 ## File path: docs/dev/connectors/pubsub.md ##

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636084 ## File path: docs/dev/connectors/pubsub.md ##

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232635986 ## File path:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636206 ## File path:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636055 ## File path:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636103 ## File path: docs/dev/connectors/pubsub.md ##

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636021 ## File path:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636179 ## File path: docs/dev/connectors/pubsub.md ##

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636196 ## File path: docs/dev/connectors/pubsub.md ##

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636212 ## File path:

[GitHub] tzulitai commented on issue #7048: [FLINK-10809][state] Include keyed state that is not from head operat…

tzulitai commented on issue #7048: [FLINK-10809][state] Include keyed state that is not from head operat… URL: https://github.com/apache/flink/pull/7048#issuecomment-437860559 @StefanRRichter I only have one final comment about the while loop. Other than that, this LGTM 

[jira] [Commented] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683716#comment-16683716 ] ASF GitHub Bot commented on FLINK-10809: tzulitai commented on a change in pull request #7048:

[GitHub] tzulitai commented on a change in pull request #7048: [FLINK-10809][state] Include keyed state that is not from head operat…

tzulitai commented on a change in pull request #7048: [FLINK-10809][state] Include keyed state that is not from head operat… URL: https://github.com/apache/flink/pull/7048#discussion_r232637615 ## File path:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683626#comment-16683626 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10821) Resuming Externalized Checkpoint E2E test does not resume from Externalized Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683664#comment-16683664 ] ASF GitHub Bot commented on FLINK-10821: tillrohrmann closed pull request #7072: [FLINK-10821]

[GitHub] tillrohrmann closed pull request #7072: [FLINK-10821] Fix resume from externalized checkpoints E2E Test

tillrohrmann closed pull request #7072: [FLINK-10821] Fix resume from externalized checkpoints E2E Test URL: https://github.com/apache/flink/pull/7072 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[GitHub] StefanRRichter commented on issue #7064: [FLINK-10753] Improve propagation and logging of snapshot exceptions

StefanRRichter commented on issue #7064: [FLINK-10753] Improve propagation and logging of snapshot exceptions URL: https://github.com/apache/flink/pull/7064#issuecomment-437858640 Comments addressed. This is an automated

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683683#comment-16683683 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683711#comment-16683711 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232637001 ## File path:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232597283 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232623515 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232608080 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232599246 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232595772 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232602260 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232621932 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232604689 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232607491 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232619065 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232595474 ## File path: docs/dev/table/sql.md ## @@ -756,6 +796,51 @@ Group windows are defined in the

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683610#comment-16683610 ] ASF GitHub Bot commented on FLINK-10827: StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683630#comment-16683630 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683617#comment-16683617 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683632#comment-16683632 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683622#comment-16683622 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683629#comment-16683629 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683615#comment-16683615 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683612#comment-16683612 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683635#comment-16683635 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683637#comment-16683637 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683618#comment-16683618 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683620#comment-16683620 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232605051 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232617901 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232618583 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#issuecomment-437853763 @pnowojski Hi, would be great if you can take a look when you are free. Thank you.

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683663#comment-16683663 ] ASF GitHub Bot commented on FLINK-8577: --- hequn8128 commented on issue #6787: [FLINK-8577][table]

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683702#comment-16683702 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[jira] [Resolved] (FLINK-10821) Resuming Externalized Checkpoint E2E test does not resume from Externalized Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10821. --- Resolution: Fixed Fix Version/s: 1.6.3 1.5.6 Fixed via master:

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683713#comment-16683713 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683747#comment-16683747 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on issue #6594: [FLINK-9311]

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232626013 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#discussion_r232572989 ## File path:

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683642#comment-16683642 ] ASF GitHub Bot commented on FLINK-10827: StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683628#comment-16683628 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683685#comment-16683685 ] Till Rohrmann commented on FLINK-10818: --- Could you share the logs of the cluster entrypoint with

[jira] [Commented] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

[ https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683706#comment-16683706 ] vinoyang commented on FLINK-10791: -- [~till.rohrmann] thanks for your reply, I'd like to provide these

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683704#comment-16683704 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683707#comment-16683707 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636943 ## File path: docs/dev/connectors/pubsub.md ##

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683708#comment-16683708 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683712#comment-16683712 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683705#comment-16683705 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636963 ## File path:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636831 ## File path:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232636872 ## File path:

[jira] [Created] (FLINK-10854) Provide end-to-end test for Kafka 0.8 connector

vinoyang created FLINK-10854: Summary: Provide end-to-end test for Kafka 0.8 connector Key: FLINK-10854 URL: https://issues.apache.org/jira/browse/FLINK-10854 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-10853) Provide end-to-end test for Kafka 0.9 connector

vinoyang created FLINK-10853: Summary: Provide end-to-end test for Kafka 0.9 connector Key: FLINK-10853 URL: https://issues.apache.org/jira/browse/FLINK-10853 Project: Flink Issue Type: Test

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683699#comment-16683699 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[jira] [Commented] (FLINK-10851) sqlUpdate support complex insert grammar

[ https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683743#comment-16683743 ] Hequn Cheng commented on FLINK-10851: - [~frank wang] Hi, thanks for creating this jira and bring up

[jira] [Commented] (FLINK-10851) sqlUpdate support complex insert grammar

[ https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683800#comment-16683800 ] frank wang commented on FLINK-10851: i don't think so tableEnv.sqlUpdate("insert into

[jira] [Commented] (FLINK-10603) Reduce kafka test duration

[ https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683595#comment-16683595 ] vinoyang commented on FLINK-10603: -- [~pnowojski] I tried to [provide a

[GitHub] StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#discussion_r232623087 ## File path:

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683643#comment-16683643 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[GitHub] StefanRRichter commented on issue #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

StefanRRichter commented on issue #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#issuecomment-437854190 @tillrohrmann I addressed the comments, please have another look. I think the duplicate code is correct as it

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683667#comment-16683667 ] ASF GitHub Bot commented on FLINK-10827: StefanRRichter commented on issue #7061:

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683674#comment-16683674 ] ASF GitHub Bot commented on FLINK-10820: pnowojski commented on a change in pull request #7051:

[GitHub] pnowojski commented on a change in pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

pnowojski commented on a change in pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#discussion_r232605133 ## File path:

[GitHub] nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r232634494 ## File path:

[jira] [Commented] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683717#comment-16683717 ] ASF GitHub Bot commented on FLINK-10809: tzulitai commented on issue #7048: [FLINK-10809][state]

[GitHub] nielsbasjes commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-437867011 I have fixed a subset of the review comments and rebased against the current

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683619#comment-16683619 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683633#comment-16683633 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683611#comment-16683611 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683616#comment-16683616 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683614#comment-16683614 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683621#comment-16683621 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683634#comment-16683634 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683623#comment-16683623 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683625#comment-16683625 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683631#comment-16683631 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683636#comment-16683636 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683624#comment-16683624 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683627#comment-16683627 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

[ https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683680#comment-16683680 ] Till Rohrmann commented on FLINK-10791: --- [~yanghua] would be good to have but not super critical

<    1   2   3   >