[GitHub] flink pull request #6203: [FLINK-9280][rest] Rework JobSubmitHandler to acce...

2018-07-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6203#discussion_r199780706 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java --- @@ -105,7 +106,8 @@ protected void

[jira] [Commented] (FLINK-9711) Flink CLI --running option does not show RUNNING only jobs

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531254#comment-16531254 ] ASF GitHub Bot commented on FLINK-9711: --- Github user satybald commented on the issue:

[jira] [Commented] (FLINK-9280) Extend JobSubmitHandler to accept jar files

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531256#comment-16531256 ] ASF GitHub Bot commented on FLINK-9280: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9711) Flink CLI --running option does not show RUNNING only jobs

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531255#comment-16531255 ] ASF GitHub Bot commented on FLINK-9711: --- Github user satybald closed the pull request at:

[GitHub] flink pull request #6203: [FLINK-9280][rest] Rework JobSubmitHandler to acce...

2018-07-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6203#discussion_r199780490 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java --- @@ -79,6 +79,7 @@ protected void

[GitHub] flink issue #6242: [FLINK-9711][CLI] Filter only RUNNING jobs when --running...

2018-07-03 Thread satybald
Github user satybald commented on the issue: https://github.com/apache/flink/pull/6242 yep, it's flink 1.5.0. I'm closing PR then. ---

[GitHub] flink pull request #6242: [FLINK-9711][CLI] Filter only RUNNING jobs when --...

2018-07-03 Thread satybald
Github user satybald closed the pull request at: https://github.com/apache/flink/pull/6242 ---

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531251#comment-16531251 ] ASF GitHub Bot commented on FLINK-9444: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #6218: [FLINK-9444] [formats] Add full SQL support for Av...

2018-07-03 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6218#discussion_r199780249 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java --- @@ -17,154 +17,338 @@

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531252#comment-16531252 ] ASF GitHub Bot commented on FLINK-9444: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #6218: [FLINK-9444] [formats] Add full SQL support for Av...

2018-07-03 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6218#discussion_r199778602 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java --- @@ -148,25 +148,26 @@ public

[jira] [Updated] (FLINK-9578) Allow to define an auto watermark interval in SQL Client

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9578: -- Labels: pull-request-available (was: ) > Allow to define an auto watermark interval in SQL

[jira] [Commented] (FLINK-9578) Allow to define an auto watermark interval in SQL Client

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

[GitHub] flink pull request #6160: [FLINK-9578] [sql-client] Allow to define an auto ...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6160 ---

[jira] [Resolved] (FLINK-9578) Allow to define an auto watermark interval in SQL Client

2018-07-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-9578. - Resolution: Fixed Fix Version/s: 1.6.0 Fixed in 1.6.0:

[jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module

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

[GitHub] flink pull request #6102: [FLINK-9091][build] Dependency convergence run aga...

2018-07-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6102#discussion_r199776816 --- Diff: tools/check_dependency_convergence.sh --- @@ -0,0 +1,67 @@ +#!/usr/bin/env bash

[jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module

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

[jira] [Commented] (FLINK-9622) DistributedCacheDfsTest failed on travis

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531240#comment-16531240 ] ASF GitHub Bot commented on FLINK-9622: --- GitHub user tillrohrmann opened a pull request:

[jira] [Updated] (FLINK-9622) DistributedCacheDfsTest failed on travis

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9622: -- Labels: pull-request-available (was: ) > DistributedCacheDfsTest failed on travis >

[GitHub] flink pull request #6244: [FLINK-9622] Do not swallow exceptions in FileUtil...

2018-07-03 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6244 [FLINK-9622] Do not swallow exceptions in FileUtils#copy ## What is the purpose of the change This commit lets `IOExceptions` originating from `FileUtil#copy` bubble up instead of

[GitHub] flink pull request #6102: [FLINK-9091][build] Dependency convergence run aga...

2018-07-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6102#discussion_r199776329 --- Diff: tools/check_dependency_convergence.sh --- @@ -0,0 +1,67 @@ +#!/usr/bin/env bash

[jira] [Commented] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks

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

[GitHub] flink issue #6201: [FLINK-8866][Table API & SQL] Add support for unified tab...

2018-07-03 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6201 I agree with @fhueske. Let's do the `from-source` in a follow-up issue. I will open a PR soon for FLINK-8558 which separates connector and format. For this I also introduced a method

[jira] [Updated] (FLINK-9707) LocalFileSystem does not support concurrent directory creations

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9707: -- Labels: pull-request-available (was: ) > LocalFileSystem does not support concurrent

[jira] [Commented] (FLINK-9707) LocalFileSystem does not support concurrent directory creations

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531233#comment-16531233 ] ASF GitHub Bot commented on FLINK-9707: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #6243: [FLINK-9707] Support concurrent directory creation...

2018-07-03 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6243 [FLINK-9707] Support concurrent directory creations in LocalFileSystem ## What is the purpose of the change Support concurrent directory creations by accepting directories which have

[jira] [Closed] (FLINK-8654) Extend quickstart docs on how to submit jobs

2018-07-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8654. --- Resolution: Fixed Fix Version/s: 1.5.1 1.4.3

[jira] [Commented] (FLINK-8654) Extend quickstart docs on how to submit jobs

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

[jira] [Updated] (FLINK-8160) Extend OperatorHarness to expose metrics

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8160: -- Labels: pull-request-available (was: ) > Extend OperatorHarness to expose metrics >

[jira] [Commented] (FLINK-8160) Extend OperatorHarness to expose metrics

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

[GitHub] flink pull request #6084: [FLINK-8654][Docs] Extend quickstart docs on how t...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6084 ---

[GitHub] flink pull request #6047: [FLINK-8160]Extend OperatorHarness to expose...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6047 ---

[jira] [Updated] (FLINK-8654) Extend quickstart docs on how to submit jobs

2018-07-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8654: Affects Version/s: 1.6.0 1.4.2 > Extend quickstart docs on how to

[jira] [Commented] (FLINK-8654) Extend quickstart docs on how to submit jobs

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

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531189#comment-16531189 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6084: [FLINK-8654][Docs] Extend quickstart docs on how t...

2018-07-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6084#discussion_r199761621 --- Diff: docs/quickstart/java_api_quickstart.md --- @@ -111,7 +111,7 @@ In IntelliJ IDEA recommended way to change JVM options is from the `Help | Edit

[GitHub] flink pull request #6218: [FLINK-9444] [formats] Add full SQL support for Av...

2018-07-03 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6218#discussion_r199761646 --- Diff: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverterTest.java --- @@ -0,0 +1,71 @@ +/* + *

[jira] [Commented] (FLINK-9554) flink scala shell doesn't work in yarn mode

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

[GitHub] flink pull request #6140: [FLINK-9554] flink scala shell doesn't work in yar...

2018-07-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6140#discussion_r199760246 --- Diff: flink-scala-shell/start-script/start-scala-shell.sh --- @@ -19,6 +19,9 @@ # from scala-lang 2.10.4 +# Uncomment the following

[jira] [Commented] (FLINK-9554) flink scala shell doesn't work in yarn mode

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

[GitHub] flink pull request #6140: [FLINK-9554] flink scala shell doesn't work in yar...

2018-07-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6140#discussion_r199760506 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java --- @@ -166,6 +166,10 @@ public Configuration getConfiguration() {

[GitHub] flink pull request #6218: [FLINK-9444] [formats] Add full SQL support for Av...

2018-07-03 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6218#discussion_r199759847 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java --- @@ -17,154 +17,338 @@

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531178#comment-16531178 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531177#comment-16531177 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6218: [FLINK-9444] [formats] Add full SQL support for Av...

2018-07-03 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6218#discussion_r199759148 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java --- @@ -17,154 +17,338 @@

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531176#comment-16531176 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6218: [FLINK-9444] [formats] Add full SQL support for Av...

2018-07-03 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6218#discussion_r199758405 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java --- @@ -17,154 +17,338 @@

[jira] [Commented] (FLINK-9711) Flink CLI --running option does not show RUNNING only jobs

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

[jira] [Commented] (FLINK-9717) Flush state of one side of the join if other side is bounded

2018-07-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531172#comment-16531172 ] Fabian Hueske commented on FLINK-9717: -- There is another aspect to consider when improving the

[GitHub] flink issue #6242: [FLINK-9711][CLI] Filter only RUNNING jobs when --running...

2018-07-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6242 see https://issues.apache.org/jira/browse/FLINK-9398 ---

[GitHub] flink issue #6242: [FLINK-9711][CLI] Filter only RUNNING jobs when --running...

2018-07-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6242 I take it that happens in 1.5.0? If so, this was already fixed for master and 1.5.1. ---

[jira] [Commented] (FLINK-9711) Flink CLI --running option does not show RUNNING only jobs

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

[jira] [Commented] (FLINK-9711) Flink CLI --running option does not show RUNNING only jobs

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531165#comment-16531165 ] ASF GitHub Bot commented on FLINK-9711: --- Github user satybald commented on the issue:

[GitHub] flink issue #6242: [FLINK-9711][CLI] Filter only RUNNING jobs when --running...

2018-07-03 Thread satybald
Github user satybald commented on the issue: https://github.com/apache/flink/pull/6242 I'd agree with you that CREATED, RESTARTING and RUNNING is part of the definition of the running job. However, CLI does include CANCELED jobs as RUNNING one if --running options is

[jira] [Commented] (FLINK-9513) Wrap state binder with TTL logic

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531159#comment-16531159 ] ASF GitHub Bot commented on FLINK-9513: --- Github user azagrebin commented on the issue:

[GitHub] flink issue #6196: [FLINK-9513] Implement TTL state wrappers factory and ser...

2018-07-03 Thread azagrebin
Github user azagrebin commented on the issue: https://github.com/apache/flink/pull/6196 @StefanRRichter I added more precomputed fields to `CompositeSerializer` constructor and included `TtlStateFactory` in TTL tests. ---

[jira] [Commented] (FLINK-9554) flink scala shell doesn't work in yarn mode

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

[jira] [Updated] (FLINK-9707) LocalFileSystem does not support concurrent directory creations

2018-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9707: - Description: The {{LocalFileSystem}} does not support concurrent directory creations. The

[jira] [Updated] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9194: -- Labels: flip-6 pull-request-available (was: flip-6) > Finished jobs are not archived to

[jira] [Commented] (FLINK-8434) The new yarn resource manager should take over the running task managers after failover

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

[jira] [Commented] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

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

[GitHub] flink pull request #6140: [FLINK-9554] flink scala shell doesn't work in yar...

2018-07-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6140#discussion_r199752165 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java --- @@ -166,6 +166,10 @@ public Configuration getConfiguration() {

[jira] [Updated] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9235: -- Labels: pull-request-available (was: ) > Add Integration test for Flink-Yarn-Kerberos

[jira] [Commented] (FLINK-9665) PrometheusReporter does not properly unregister metrics

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

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

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

[jira] [Commented] (FLINK-9674) Remove 65s sleep in QueryableState E2E test

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

[GitHub] flink pull request #6211: [FLINK-9665] PrometheusReporter does not properly ...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6211 ---

[GitHub] flink pull request #5901: [FLINK-9235][Security] Add integration tests for Y...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5901 ---

[GitHub] flink pull request #5888: [FLINK-9194] [histroyserver] Finished jobs are not...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5888 ---

[GitHub] flink pull request #6025: Release 1.4

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6025 ---

[GitHub] flink pull request #6216: [FLINK-9674][tests] Replace hard-coded sleeps in Q...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6216 ---

[GitHub] flink pull request #5297: [FLINK-8434] Take over the running task manager af...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5297 ---

[GitHub] flink pull request #5899: Klink

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5899 ---

[jira] [Updated] (FLINK-9674) Remove 65s sleep in QueryableState E2E test

2018-07-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9674: Affects Version/s: (was: 1.5.0) > Remove 65s sleep in QueryableState E2E test >

[jira] [Closed] (FLINK-9674) Remove 65s sleep in QueryableState E2E test

2018-07-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9674. --- Resolution: Fixed Fix Version/s: 1.6.0 master:

[jira] [Commented] (FLINK-9554) flink scala shell doesn't work in yarn mode

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531138#comment-16531138 ] ASF GitHub Bot commented on FLINK-9554: --- Github user zjffdu commented on a diff in the pull

[jira] [Commented] (FLINK-9711) Flink CLI --running option does not show RUNNING only jobs

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

[GitHub] flink issue #6242: [FLINK-9711][CLI] Filter only RUNNING jobs when --running...

2018-07-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6242 -1 The PR description is outdated, the CLI only lists jobs in non-terminal states as running, i.e. CANCELED, FAILED and FINISHED jobs are not included. For all intents and purposes this is

[GitHub] flink pull request #6140: [FLINK-9554] flink scala shell doesn't work in yar...

2018-07-03 Thread zjffdu
Github user zjffdu commented on a diff in the pull request: https://github.com/apache/flink/pull/6140#discussion_r199750956 --- Diff: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala --- @@ -255,14 +257,25 @@ object FlinkShell {

[jira] [Assigned] (FLINK-9713) Support versioned joins in planning phase

2018-07-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-9713: - Assignee: Piotr Nowojski > Support versioned joins in planning phase >

[jira] [Assigned] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

2018-07-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-9712: - Assignee: Piotr Nowojski > Support enrichment joins in Flink SQL/Table API >

[jira] [Created] (FLINK-9717) Flush state of one side of the join if other side is bounded

2018-07-03 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-9717: - Summary: Flush state of one side of the join if other side is bounded Key: FLINK-9717 URL: https://issues.apache.org/jira/browse/FLINK-9717 Project: Flink

[jira] [Updated] (FLINK-9715) Support versioned joins with event time

2018-07-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9715: -- Description: Queries like: {code:java} SELECT o.amount * r.rate FROM Orders AS o,

[jira] [Updated] (FLINK-9713) Support versioned joins in planning phase

2018-07-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9713: -- Description: Queries like: {code:java} SELECT o.amount * r.rate FROM Orders AS o,

[GitHub] flink pull request #6218: [FLINK-9444] [formats] Add full SQL support for Av...

2018-07-03 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6218#discussion_r199748214 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java --- @@ -17,154 +17,338 @@

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531128#comment-16531128 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

[jira] [Updated] (FLINK-9713) Support versioned joins in planning phase

2018-07-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9713: -- Description: Queries like: {code:java} SELECT o.amount * r.rate FROM Orders AS o,

[jira] [Updated] (FLINK-9714) Support versioned joins with processing time

2018-07-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9714: -- Description: Queries like: {code:java} SELECT o.amount * r.rate FROM Orders AS o,

[jira] [Commented] (FLINK-9711) Flink CLI --running option does not show RUNNING only jobs

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531124#comment-16531124 ] ASF GitHub Bot commented on FLINK-9711: --- GitHub user satybald opened a pull request:

[jira] [Created] (FLINK-9716) Support scans from table version function

2018-07-03 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-9716: - Summary: Support scans from table version function Key: FLINK-9716 URL: https://issues.apache.org/jira/browse/FLINK-9716 Project: Flink Issue Type:

[GitHub] flink pull request #6242: [FLINK-9711][CLI] Filter only RUNNING jobs when --...

2018-07-03 Thread satybald
GitHub user satybald opened a pull request: https://github.com/apache/flink/pull/6242 [FLINK-9711][CLI] Filter only RUNNING jobs when --running option provided in CLI ## What is the purpose of the change In Flink CLI there's a command list with option --running that

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531123#comment-16531123 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6218: [FLINK-9444] [formats] Add full SQL support for Av...

2018-07-03 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6218#discussion_r199747223 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java --- @@ -17,154 +17,338 @@

[jira] [Updated] (FLINK-9715) Support versioned joins with event time

2018-07-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9715: -- Affects Version/s: 1.5.0 > Support versioned joins with event time >

[jira] [Updated] (FLINK-9715) Support versioned joins with event time

2018-07-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9715: -- Component/s: Table API & SQL > Support versioned joins with event time >

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531120#comment-16531120 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

[jira] [Created] (FLINK-9715) Support versioned joins with event time

2018-07-03 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-9715: - Summary: Support versioned joins with event time Key: FLINK-9715 URL: https://issues.apache.org/jira/browse/FLINK-9715 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531117#comment-16531117 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

[jira] [Updated] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

2018-07-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9712: -- Description: As described here:

<    1   2   3   4   5   >