[GitHub] twalthr commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

twalthr commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221580369 ## File path:

[GitHub] twalthr commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

twalthr commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221581884 ## File path:

[GitHub] twalthr commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

twalthr commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221579869 ## File path:

[GitHub] twalthr commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

twalthr commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221597635 ## File path:

[GitHub] twalthr commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

twalthr commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221583273 ## File path:

[jira] [Commented] (FLINK-9697) Provide connector for Kafka 2.0.0

[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633977#comment-16633977 ] ASF GitHub Bot commented on FLINK-9697: --- pnowojski commented on issue #6703: [FLINK-9697] Provide

[GitHub] pnowojski commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0

pnowojski commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0 URL: https://github.com/apache/flink/pull/6703#issuecomment-425903372 @yanghua I would assume that deadlocking/becoming unresponsive just proves that our `at-least-once` test is broken and should be

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633959#comment-16633959 ] Till Rohrmann commented on FLINK-10292: --- I see your point [~uce]. Conceptually, it would be

[jira] [Commented] (FLINK-10294) Split MiniClusterResource to be usable in runtime/streaming-java/clients

[ https://issues.apache.org/jira/browse/FLINK-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633949#comment-16633949 ] Till Rohrmann commented on FLINK-10294: --- Alright, this makes sense. Maybe we could offer for the

[jira] [Commented] (FLINK-10472) Add CBRT math function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633930#comment-16633930 ] Aleksei Izmalkin commented on FLINK-10472: -- I will work on this issue. Hello [~yanghua], please

[jira] [Created] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

Andrey Zagrebin created FLINK-10473: --- Summary: State TTL incremental cleanup using Heap backend key iterator Key: FLINK-10473 URL: https://issues.apache.org/jira/browse/FLINK-10473 Project: Flink

[jira] [Created] (FLINK-10472) Add CBRT math function supported in Table API and SQL

Aleksei Izmalkin created FLINK-10472: Summary: Add CBRT math function supported in Table API and SQL Key: FLINK-10472 URL: https://issues.apache.org/jira/browse/FLINK-10472 Project: Flink

[jira] [Updated] (FLINK-8033) Build Flink with JDK 9

[ https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8033: - Description: This is a JIRA to track all issues that found to make Flink compatible with Java 9.

[jira] [Created] (FLINK-10471) State TTL cleanup using RocksDb compaction filter

Andrey Zagrebin created FLINK-10471: --- Summary: State TTL cleanup using RocksDb compaction filter Key: FLINK-10471 URL: https://issues.apache.org/jira/browse/FLINK-10471 Project: Flink

[GitHub] azagrebin commented on issue #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

azagrebin commented on issue #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#issuecomment-425884580 Hi @bmeriaux, we can merge it after @zentol's comments are resolved. We usually merge new

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633912#comment-16633912 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on issue #6735: [FLINK-9126] New

[jira] [Updated] (FLINK-8033) Build Flink with JDK 9

[ https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tison updated FLINK-8033: - Description: colored textThis is a JIRA to track all issues that found to make Flink compatible with Java 9.

[jira] [Commented] (FLINK-10447) Create Bucketing Table Sink.

[ https://issues.apache.org/jira/browse/FLINK-10447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633902#comment-16633902 ] ASF GitHub Bot commented on FLINK-10447: SuXingLee closed pull request #6769: [FLINK-10447][HDFS

[jira] [Commented] (FLINK-10312) Wrong / missing exception when submitting job

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

[GitHub] SuXingLee closed pull request #6769: [FLINK-10447][HDFS Connector] Create Bucketing Table Sink

SuXingLee closed pull request #6769: [FLINK-10447][HDFS Connector] Create Bucketing Table Sink URL: https://github.com/apache/flink/pull/6769 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 provenance: As

[GitHub] zentol closed pull request #6731: [FLINK-10312] Propagate exception from server to client in REST API

zentol closed pull request #6731: [FLINK-10312] Propagate exception from server to client in REST API URL: https://github.com/apache/flink/pull/6731 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 provenance:

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

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

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

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

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

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

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

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

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

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

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

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

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

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

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

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

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

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

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

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

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221578491 ## File path:

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221574858 ## File path:

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221574858 ## File path:

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221577237 ## File path:

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221578896 ## File path:

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221576843 ## File path:

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221578715 ## File path:

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221575216 ## File path:

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221577251 ## File path:

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221575749 ## File path:

[jira] [Commented] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633879#comment-16633879 ] Nico Kruber commented on FLINK-10462: - Yes, you are right about the changes that credit-based flow

[jira] [Closed] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10291. - Resolution: Fixed Release Note: The {{StandaloneJobClusterEntrypoint}} now starts all jobs

[jira] [Commented] (FLINK-10470) Add method to check if pattern can produce empty matches

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

[jira] [Commented] (FLINK-10470) Add method to check if pattern can produce empty matches

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

[jira] [Reopened] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-10291: --- > Generate JobGraph with fixed/configurable JobID in > StandaloneJobClusterEntrypoint >

[jira] [Resolved] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10291. --- Resolution: Fixed Fixed via 1.7.0: c839b1a04c389db816fad0194eb63a5220ee5351 1.6.2:

[GitHub] pnowojski commented on a change in pull request #6781: [FLINK-10470] Add method to check if pattern can produce empty matches

pnowojski commented on a change in pull request #6781: [FLINK-10470] Add method to check if pattern can produce empty matches URL: https://github.com/apache/flink/pull/6781#discussion_r221577049 ## File path:

[GitHub] pnowojski commented on a change in pull request #6781: [FLINK-10470] Add method to check if pattern can produce empty matches

pnowojski commented on a change in pull request #6781: [FLINK-10470] Add method to check if pattern can produce empty matches URL: https://github.com/apache/flink/pull/6781#discussion_r221576741 ## File path:

[jira] [Commented] (FLINK-10135) The JobManager doesn't report the cluster-level metrics

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

[GitHub] zentol commented on a change in pull request #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics

zentol commented on a change in pull request #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics URL: https://github.com/apache/flink/pull/6702#discussion_r221573282 ## File path:

[GitHub] zentol commented on a change in pull request #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics

zentol commented on a change in pull request #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics URL: https://github.com/apache/flink/pull/6702#discussion_r221573282 ## File path:

[jira] [Commented] (FLINK-10135) The JobManager doesn't report the cluster-level metrics

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

[jira] [Commented] (FLINK-10470) Add method to check if pattern can produce empty matches

[ https://issues.apache.org/jira/browse/FLINK-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633854#comment-16633854 ] ASF GitHub Bot commented on FLINK-10470: dawidwys commented on issue #6781: [FLINK-10470] Add

[GitHub] dawidwys commented on issue #6781: [FLINK-10470] Add method to check if pattern can produce empty matches

dawidwys commented on issue #6781: [FLINK-10470] Add method to check if pattern can produce empty matches URL: https://github.com/apache/flink/pull/6781#issuecomment-425868325 cc @kl0u @pnowojski This is an automated

[jira] [Resolved] (FLINK-10339) SpillReadBufferPool cannot use off-heap memory

[ https://issues.apache.org/jira/browse/FLINK-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10339. - Resolution: Fixed Fix Version/s: 1.7.0 Fixed via: - master:

[jira] [Commented] (FLINK-10339) SpillReadBufferPool cannot use off-heap memory

[ https://issues.apache.org/jira/browse/FLINK-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633823#comment-16633823 ] ASF GitHub Bot commented on FLINK-10339: NicoK closed pull request #6762: [FLINK-10339][network]

[GitHub] NicoK closed pull request #6762: [FLINK-10339][network] Use off-heap memory for SpillReadBufferPool

NicoK closed pull request #6762: [FLINK-10339][network] Use off-heap memory for SpillReadBufferPool URL: https://github.com/apache/flink/pull/6762 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 provenance:

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

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

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221551766 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221553008 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221555894 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221549739 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221548569 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221551267 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221552259 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221549560 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r22149 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221550646 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221551094 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221550059 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221552131 ## File path:

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221553160 ## File path:

[GitHub] asfgit closed pull request #6766: [docs] Improve documentation of savepoints

asfgit closed pull request #6766: [docs] Improve documentation of savepoints URL: https://github.com/apache/flink/pull/6766 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 provenance: As this is a foreign

[jira] [Commented] (FLINK-10447) Create Bucketing Table Sink.

[ https://issues.apache.org/jira/browse/FLINK-10447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633786#comment-16633786 ] ASF GitHub Bot commented on FLINK-10447: fhueske commented on issue #6769: [FLINK-10447][HDFS

[GitHub] fhueske commented on issue #6769: [FLINK-10447][HDFS Connector] Create Bucketing Table Sink

fhueske commented on issue #6769: [FLINK-10447][HDFS Connector] Create Bucketing Table Sink URL: https://github.com/apache/flink/pull/6769#issuecomment-425851537 Please see also my comment on the Jira issue. Before adapting the PR, we should agree on the feature scope and design. Please

[GitHub] StefanRRichter commented on issue #6766: [docs] Improve documentation of savepoints

StefanRRichter commented on issue #6766: [docs] Improve documentation of savepoints URL: https://github.com/apache/flink/pull/6766#issuecomment-425851398 Thanks for the comments! Will merge. This is an automated message from

[jira] [Commented] (FLINK-10447) Create Bucketing Table Sink.

[ https://issues.apache.org/jira/browse/FLINK-10447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633782#comment-16633782 ] ASF GitHub Bot commented on FLINK-10447: twalthr commented on issue #6769: [FLINK-10447][HDFS

[GitHub] twalthr commented on issue #6769: [FLINK-10447][HDFS Connector] Create Bucketing Table Sink

twalthr commented on issue #6769: [FLINK-10447][HDFS Connector] Create Bucketing Table Sink URL: https://github.com/apache/flink/pull/6769#issuecomment-425850646 It requires much than just switching to `StreamingFileSink`. Every new sink should integrate with the new unified API. See also

[jira] [Commented] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

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

[GitHub] asfgit closed pull request #6733: [FLINK-10291] Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

asfgit closed pull request #6733: [FLINK-10291] Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/6733 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below

[jira] [Resolved] (FLINK-10414) Add skip to next strategy

[ https://issues.apache.org/jira/browse/FLINK-10414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-10414. -- Resolution: Done > Add skip to next strategy > - > >

[jira] [Commented] (FLINK-10414) Add skip to next strategy

[ https://issues.apache.org/jira/browse/FLINK-10414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633773#comment-16633773 ] ASF GitHub Bot commented on FLINK-10414: dawidwys closed pull request #6756: [FLINK-10414][cep]

[GitHub] dawidwys closed pull request #6756: [FLINK-10414][cep] Added skip to next strategy

dawidwys closed pull request #6756: [FLINK-10414][cep] Added skip to next strategy URL: https://github.com/apache/flink/pull/6756 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 provenance: As this is a

[jira] [Commented] (FLINK-10312) Wrong / missing exception when submitting job

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

[GitHub] zentol commented on a change in pull request #6731: [FLINK-10312] Propagate exception from server to client in REST API

zentol commented on a change in pull request #6731: [FLINK-10312] Propagate exception from server to client in REST API URL: https://github.com/apache/flink/pull/6731#discussion_r221546026 ## File path:

[jira] [Resolved] (FLINK-3875) Add a TableSink for Elasticsearch

[ https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-3875. - Resolution: Fixed Fix Version/s: 1.7.0 Fixed in 1.7.0:

<    1   2   3   >