[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] [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] [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 >

[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 {

[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

[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:

[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

[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 #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 #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 ---

[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 >

[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 ---

[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 #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 ---

[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:

[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:

[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

[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 #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-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=16531258#comment-16531258 ] ASF GitHub Bot commented on FLINK-9280: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #6188: [FLINK-6846][Table API] add timestampAdd tableApi

2018-07-03 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6188#discussion_r199783102 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala --- @@ -1029,6 +1029,29 @@ object

[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=16531270#comment-16531270 ] ASF GitHub Bot commented on FLINK-9513: --- Github user StefanRRichter commented on a diff in the pull

[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=16531285#comment-16531285 ] ASF GitHub Bot commented on FLINK-9513: --- Github user StefanRRichter commented on the issue:

[jira] [Commented] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions

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

[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=16531307#comment-16531307 ] 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_r199791671 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java --- @@ -201,71 +202,69 @@ private Object

[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:

[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. ---

[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() {

[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 #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

[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 #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_r199781443 --- Diff: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverterTest.java --- @@ -0,0 +1,71 @@ +/* +

[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_r199780422 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java --- @@ -201,71 +202,69 @@ private Object

[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=16531263#comment-16531263 ] ASF GitHub Bot commented on FLINK-9444: --- Github user pnowojski commented on a diff in the pull

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

2018-07-03 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/6196 Had a few more comments, but they all are basically optimizations. I leave it up to you if you still want to address all or some of them. Please let me know. Otherwise, we can merge this.

[GitHub] flink issue #6222: [FLINK-8785][rest] Handle JobSubmissionExceptions

2018-07-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6222 Merging, will create the issue once I'm done. ---

[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=16531314#comment-16531314 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on the issue:

[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

[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-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:

[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:

[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=16531177#comment-16531177 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

[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] [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] [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] [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 #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=16531242#comment-16531242 ] ASF GitHub Bot commented on FLINK-9091: --- Github user zentol commented on a diff in the pull

[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:

[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=16531277#comment-16531277 ] ASF GitHub Bot commented on FLINK-9513: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole

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

[GitHub] flink issue #6221: [FLINK-9686] [kinesis] Enable Kinesis authentication via ...

2018-07-03 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/6221 Thanks @fmthoma for addressing @tzulitai comments. Merging this PR now. ---

[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-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 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-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

[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:

[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

[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

[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:

[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=16531265#comment-16531265 ] ASF GitHub Bot commented on FLINK-9513: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #6196: [FLINK-9513] Implement TTL state wrappers factory ...

2018-07-03 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6196#discussion_r199782860 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java --- @@ -0,0 +1,275 @@ +/* + * Licensed to

[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=16531269#comment-16531269 ] 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 zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6218#discussion_r199792051 --- Diff: flink-formats/flink-avro/pom.xml --- @@ -51,6 +51,17 @@ under the License. + +

[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=16531310#comment-16531310 ] ASF GitHub Bot commented on FLINK-9444: --- Github user zentol commented on a diff in the pull

[jira] [Commented] (FLINK-9681) Make sure minRetentionTime not equal to maxRetentionTime

2018-07-03 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531322#comment-16531322 ] Hequn Cheng commented on FLINK-9681: Hi [~fhueske], thanks for your reply and suggestions. I will

[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:

[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

[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:

[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:

[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] [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_r199780706 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java --- @@ -105,7 +106,8 @@ protected void

[GitHub] flink issue #6206: [FLINK-9654] [core] Changed the check for anonymous class...

2018-07-03 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/6206 @zsolt-donca I actually added some test to my branch https://github.com/tillrohrmann/flink/commits/FLINK-9654. If this should cover your fix, then I could merge your PR with this test. What do

[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_r199782571 --- Diff: flink-formats/flink-avro/pom.xml --- @@ -51,6 +51,17 @@ under the License. + +

[jira] [Commented] (FLINK-9654) Internal error while deserializing custom Scala TypeSerializer instances

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

[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=16531264#comment-16531264 ] ASF GitHub Bot commented on FLINK-9444: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #6196: [FLINK-9513] Implement TTL state wrappers factory ...

2018-07-03 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6196#discussion_r199782303 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java --- @@ -0,0 +1,275 @@ +/* + * Licensed to

[GitHub] flink issue #6218: [FLINK-9444] [formats] Add full SQL support for Avro form...

2018-07-03 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6218 Thanks for the feedback @pnowojski and @zentol. I will merge this... ---

[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_r199794599 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java --- @@ -54,18 +69,89 @@ public JobSubmitHandler(

[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=16531319#comment-16531319 ] ASF GitHub Bot commented on FLINK-9280: --- Github user tillrohrmann commented on a diff in the pull

[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=16531320#comment-16531320 ] ASF GitHub Bot commented on FLINK-9280: --- Github user tillrohrmann commented on a diff in the pull

[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:

<    1   2   3   4   5   >