[jira] [Commented] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse

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

[jira] [Commented] (FLINK-9629) Datadog metrics reporter does not have shaded dependencies

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

[jira] [Commented] (FLINK-9677) RestClient fails for large uploads

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

[GitHub] flink pull request #6217: [FLINK-9677][rest] Cleanup encoder after request h...

2018-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6217 ---

[GitHub] flink pull request #6179: [hotfix][docs] Removed duplicate line in windows d...

2018-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6179 ---

[GitHub] flink pull request #6166: [FLINK-9580] Potentially unclosed ByteBufInputStre...

2018-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6166 ---

[GitHub] flink pull request #6163: [hotfix][table] Fix a incorrect exception message.

2018-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6163 ---

[GitHub] flink pull request #6191: [FLINK-9629][metrics] Included datadog shaded depe...

2018-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6191 ---

[jira] [Commented] (FLINK-6222) YARN: setting environment variables in an easier fashion

2018-06-27 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525901#comment-16525901 ] Hequn Cheng commented on FLINK-6222: Hi, [~foscraig] Thanks for your patch. It is recommended to make

[jira] [Commented] (FLINK-9662) Task manager isolation for jobs

2018-06-27 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525864#comment-16525864 ] Renjie Liu commented on FLINK-9662: --- [~till.rohrmann] [~elevy] [~gzm55] I think it's quite tricky to

[jira] [Updated] (FLINK-9662) Task manager isolation for jobs

2018-06-27 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu updated FLINK-9662: -- Attachment: job isolation sequence.jpg > Task manager isolation for jobs >

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

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

[GitHub] flink pull request #6201: [FLINK-8866][Table API & SQL] Add support for unif...

2018-06-27 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/6201#discussion_r198678147 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/connector/TableSinkFactoryServiceTest.scala --- @@ -0,0 +1,84 @@ +/* +

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

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

[GitHub] flink pull request #6201: [FLINK-8866][Table API & SQL] Add support for unif...

2018-06-27 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/6201#discussion_r198677922 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala --- @@ -16,21 +16,18 @@ *

[GitHub] flink pull request #6201: [FLINK-8866][Table API & SQL] Add support for unif...

2018-06-27 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/6201#discussion_r198677762 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala --- @@ -16,21 +16,18 @@ *

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

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

[GitHub] flink pull request #6201: [FLINK-8866][Table API & SQL] Add support for unif...

2018-06-27 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/6201#discussion_r198677754 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala --- @@ -16,21 +16,18 @@ *

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

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

[jira] [Commented] (FLINK-6962) SQL DDL for input and output tables

2018-06-27 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525753#comment-16525753 ] Shuyi Chen commented on FLINK-6962: --- Hi [~shenyufeng], I am finalizing the DDL design doc and should

[jira] [Commented] (FLINK-9666) short-circuit logic should be used in boolean contexts

2018-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525694#comment-16525694 ] ASF GitHub Bot commented on FLINK-9666: --- Github user lamber-ken commented on the issue:

[GitHub] flink issue #6212: [FLINK-9666] short-circuit logic should be used in boolea...

2018-06-27 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/6212 hi, @StephanEwen, @tillrohrmann cc. ---

[jira] [Commented] (FLINK-9543) Expose JobMaster IDs to metric system

2018-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525692#comment-16525692 ] ASF GitHub Bot commented on FLINK-9543: --- Github user lamber-ken commented on the issue:

[GitHub] flink issue #6195: [FLINK-9543][METRICS] Expose JobMaster ID to metric syste...

2018-06-27 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/6195 @zentol , cc. ---

[jira] [Commented] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams

2018-06-27 Thread Ying Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525650#comment-16525650 ] Ying Xu commented on FLINK-4582: Hi:  [~tzulitai]  [~mingdaoy]   I'm following up on this JIRA as we

[jira] [Created] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal

2018-06-27 Thread Ethan Li (JIRA)
Ethan Li created FLINK-9685: --- Summary: Flink should support hostname-substitution for security.kerberos.login.principal Key: FLINK-9685 URL: https://issues.apache.org/jira/browse/FLINK-9685 Project: Flink

[jira] [Created] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster

2018-06-27 Thread Ethan Li (JIRA)
Ethan Li created FLINK-9684: --- Summary: HistoryServerArchiveFetcher not working properly with secure hdfs cluster Key: FLINK-9684 URL: https://issues.apache.org/jira/browse/FLINK-9684 Project: Flink

[jira] [Commented] (FLINK-9560) RateLimiting for FileSystem

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

[GitHub] flink issue #6149: [FLINK-9560] Add RateLimiting for FileSystem

2018-06-27 Thread etiennecarriere
Github user etiennecarriere commented on the issue: https://github.com/apache/flink/pull/6149 Hi @pnowojski, Unfortunately, this patch is not working because : * The implementation of FileSystem is using a temporary file to store it ** s3 : it is mandatory to know

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

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

[GitHub] flink issue #6083: [FLINK-8983] End-to-end test: Confluent schema registry

2018-06-27 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6083 @tillrohrmann PR has been updated! I had to do some changes: - map `User` object to `String` in `TestAvroConsumerConfluent` class - use `read_messages_from_kafka` instead of

[jira] [Created] (FLINK-9683) inconsistent behaviors when setting historyserver.archive.fs.dir

2018-06-27 Thread Ethan Li (JIRA)
Ethan Li created FLINK-9683: --- Summary: inconsistent behaviors when setting historyserver.archive.fs.dir Key: FLINK-9683 URL: https://issues.apache.org/jira/browse/FLINK-9683 Project: Flink Issue

[jira] [Closed] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9524. Resolution: Fixed Fix Version/s: 1.5.1 1.4.3 1.6.0

[jira] [Commented] (FLINK-9662) Task manager isolation for jobs

2018-06-27 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525331#comment-16525331 ] Elias Levy commented on FLINK-9662: --- I like the direction of this.  And as I mentioned in the other

[jira] [Commented] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

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

[jira] [Commented] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

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

[GitHub] flink issue #6180: [FLINK-9524][Table API & SQL] check whether a clean-up ti...

2018-06-27 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/6180 Thanks for the update @yzandrew. Merging ---

[GitHub] flink pull request #6180: [FLINK-9524][Table API & SQL] check whether a clea...

2018-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6180 ---

[jira] [Created] (FLINK-9682) Add setDescription to execution environment and display it in the UI

2018-06-27 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9682: - Summary: Add setDescription to execution environment and display it in the UI Key: FLINK-9682 URL: https://issues.apache.org/jira/browse/FLINK-9682 Project: Flink

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

2018-06-27 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-9681: -- Summary: Make sure minRetentionTime not equal to maxRetentionTime Key: FLINK-9681 URL: https://issues.apache.org/jira/browse/FLINK-9681 Project: Flink Issue

[jira] [Created] (FLINK-9680) Reduce heartbeat timeout for E2E tests

2018-06-27 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9680: --- Summary: Reduce heartbeat timeout for E2E tests Key: FLINK-9680 URL: https://issues.apache.org/jira/browse/FLINK-9680 Project: Flink Issue Type:

[GitHub] flink pull request #6219: [hotfix] Fixed typo in docs

2018-06-27 Thread elbaulp
GitHub user elbaulp opened a pull request: https://github.com/apache/flink/pull/6219 [hotfix] Fixed typo in docs You can merge this pull request into a Git repository by running: $ git pull https://github.com/elbaulp/flink patch-1 Alternatively you can review and apply these

[jira] [Commented] (FLINK-4542) Add MULTISET operations

2018-06-27 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525242#comment-16525242 ] Sergey Nuyanzin commented on FLINK-4542: You are right, just pushed test in

[jira] [Commented] (FLINK-9677) RestClient fails for large uploads

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

[GitHub] flink issue #6217: [FLINK-9677][rest] Cleanup encoder after request has been...

2018-06-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6217 merging. ---

[jira] [Commented] (FLINK-4542) Add MULTISET operations

2018-06-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525207#comment-16525207 ] Timo Walther commented on FLINK-4542: - I checked out your branch but I could not find the failing

[jira] [Commented] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties)

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

[GitHub] flink pull request #5410: [FLINK-8468] [RabbitMQ Connector] Take advantage o...

2018-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5410 ---

[jira] [Resolved] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties)

2018-06-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8468. -- Resolution: Fixed Fix Version/s: 1.6.0 Fixed via

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

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

[GitHub] flink issue #6083: [FLINK-8983] End-to-end test: Confluent schema registry

2018-06-27 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6083 @tillrohrmann make sense. I created this ticket https://issues.apache.org/jira/browse/FLINK-9679 for implementing `AvroSerializationConfluentSchema`. I will make a PR for it shortly. Mean

[jira] [Created] (FLINK-9679) Implement AvroSerializationSchema

2018-06-27 Thread Yazdan Shirvany (JIRA)
Yazdan Shirvany created FLINK-9679: -- Summary: Implement AvroSerializationSchema Key: FLINK-9679 URL: https://issues.apache.org/jira/browse/FLINK-9679 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

2018-06-27 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei updated FLINK-9609: Description: Currently, BucketingSink only support {{notifyCheckpointComplete}}. Users want to do

[jira] [Updated] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

2018-06-27 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei updated FLINK-9609: Description: Currently, BucketingSink only support {{notifyCheckpointComplete}}. However, users

[jira] [Updated] (FLINK-9474) Add runtime support of distinct filter using ElasticBloomFilter

2018-06-27 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9474: -- Description: We can implement an approximate version of "distinct filter" base on the "Elastic Bloom

[jira] [Updated] (FLINK-9474) Add runtime support of distinct filter using ElasticBloomFilter

2018-06-27 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9474: -- Summary: Add runtime support of distinct filter using ElasticBloomFilter (was: Introduce an

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

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

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

2018-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9444: -- Labels: patch pull-request-available (was: patch) > KafkaAvroTableSource failed to work for

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

2018-06-27 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/6218 [FLINK-9444] [formats] Add full SQL support for Avro formats ## What is the purpose of the change This PR adds full support of Apache Avro records for the Table API & SQL. It adds

[jira] [Commented] (FLINK-4542) Add MULTISET operations

2018-06-27 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525031#comment-16525031 ] Sergey Nuyanzin commented on FLINK-4542: Hello [~twalthr]. Thank you for your comment yes Calcite

[jira] [Commented] (FLINK-9634) Deactivate previous location based scheduling if local recovery is disabled

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

[jira] [Closed] (FLINK-9634) Deactivate previous location based scheduling if local recovery is disabled

2018-06-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9634. Resolution: Fixed Fixed via 1.6.0: d5919d9c1d4054dbfa182e482e082940b4e2f24d 1.5.1:

[GitHub] flink pull request #6208: [FLINK-9634] Disable local recovery scheduling if ...

2018-06-27 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/6208 ---

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

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

[GitHub] flink issue #6090: [FLINK-8863] [SQL] Add user-defined function support in S...

2018-06-27 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/6090 Hi @twalthr, sorry for the delay. I've been quite busy with my graduation these weeks. Everything's finished now and I'll put these tasks back on track. ---

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

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

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-27 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r198485307 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/PrimitiveTypeDescriptor.scala --- @@ -0,0 +1,56 @@ +/* + *

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

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

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

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

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-27 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r198484614 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java --- @@ -187,6 +206,7 @@ private

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

2018-06-27 Thread jelmerk
Github user jelmerk commented on a diff in the pull request: https://github.com/apache/flink/pull/6211#discussion_r198484545 --- Diff: flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTest.java --- @@ -159,6 +162,27 @@

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

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

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-27 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r198482931 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/UDFDescriptor.java --- @@ -0,0 +1,153 @@ +/* + *

[jira] [Assigned] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties)

2018-06-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-8468: Assignee: Ph.Duveau > Make the connector to take advantage of AMQP features (routing key,

[jira] [Updated] (FLINK-9647) Files uploaded to blobservice during job submission aren't removed on failure

2018-06-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9647: Description: During the job-submission clients upload jars, and in 1.6+ also distributed

[jira] [Updated] (FLINK-9647) Files uploaded to blobservice during job submission aren't removed on failure

2018-06-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9647: Description: During the job-submission clients upload jars, and in 1.6+ also distributed

[jira] [Updated] (FLINK-9647) Files uploaded to blobservice during job submission aren't removed on failure

2018-06-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9647: - Summary: Files uploaded to blobservice during job submission aren't removed on failure (was:

[jira] [Commented] (FLINK-9662) Task manager isolation for jobs

2018-06-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524989#comment-16524989 ] Till Rohrmann commented on FLINK-9662: -- This is correct [~gzm55]. I think that this is quite easy to

[jira] [Commented] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE

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

[jira] [Updated] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE

2018-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9593: -- Labels: pull-request-available (was: ) > Unify AfterMatch semantics with SQL MATCH_RECOGNIZE

[jira] [Commented] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE

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

[GitHub] flink pull request #6171: [FLINK-9593] Unified After Match semantics with SQ...

2018-06-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6171#discussion_r198474417 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -330,77 +328,85 @@ private boolean isStateTimedOut(final

[GitHub] flink pull request #6171: [FLINK-9593] Unified After Match semantics with SQ...

2018-06-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6171#discussion_r198473426 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/AfterMatchSkipStrategy.java --- @@ -0,0 +1,155 @@ +/* + *

[GitHub] flink pull request #6171: [FLINK-9593] Unified After Match semantics with SQ...

2018-06-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6171#discussion_r198472975 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java --- @@ -79,18 +98,18 @@ public boolean equals(Object o) {

[GitHub] flink pull request #6171: [FLINK-9593] Unified After Match semantics with SQ...

2018-06-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6171#discussion_r198472927 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java --- @@ -79,18 +98,18 @@ public boolean equals(Object o) {

[GitHub] flink pull request #6171: [FLINK-9593] Unified After Match semantics with SQ...

2018-06-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6171#discussion_r198473858 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -330,77 +328,85 @@ private boolean isStateTimedOut(final

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

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

[GitHub] flink issue #6083: [FLINK-8983] End-to-end test: Confluent schema registry

2018-06-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/6083 This is a good point @medcv. However, I think we should tackle adding a `AvroSerializationConfluentSchema` as an orthogonal step. What about removing it from this PR which covers the existing

[jira] [Created] (FLINK-9678) Remove hard-coded sleeps in HA E2E test

2018-06-27 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9678: --- Summary: Remove hard-coded sleeps in HA E2E test Key: FLINK-9678 URL: https://issues.apache.org/jira/browse/FLINK-9678 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9677) RestClient fails for large uploads

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

[jira] [Updated] (FLINK-9677) RestClient fails for large uploads

2018-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9677: -- Labels: pull-request-available (was: ) > RestClient fails for large uploads >

[GitHub] flink pull request #6217: [FLINK-9677][rest] Cleanup encoder after request h...

2018-06-27 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/6217 [FLINK-9677][rest] Cleanup encoder after request has been processed ## What is the purpose of the change This PR fixes an issue in the `RestClient` where the `HttpPostRequestEncoder` would

[jira] [Created] (FLINK-9677) RestClient fails for large uploads

2018-06-27 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9677: --- Summary: RestClient fails for large uploads Key: FLINK-9677 URL: https://issues.apache.org/jira/browse/FLINK-9677 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-9677) RestClient fails for large uploads

2018-06-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9677: --- Assignee: Chesnay Schepler > RestClient fails for large uploads >

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

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

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

2018-06-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6211#discussion_r198460116 --- Diff: flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTest.java --- @@ -159,6 +162,27 @@

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

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

  1   2   3   >