[GitHub] flink pull request #6215: [FLINK-9217][kafka-tests] Disable testTimestamps f...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6215#discussion_r198748703 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java --- @@ -168,8 +168,8

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

[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526084#comment-16526084 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on the issue:

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

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6090 @xccui no problem. great to hear that you graduated :) The feature freeze is in approximately 3 weeks, we should be done by then. Let me know if you need support. ---

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

[ https://issues.apache.org/jira/browse/FLINK-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-9560. - Resolution: Unresolved Closing because of the way how S3 file systems are internally

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

[ https://issues.apache.org/jira/browse/FLINK-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526080#comment-16526080 ] ASF GitHub Bot commented on FLINK-9560: --- Github user pnowojski commented on the issue:

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

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/6149 @etiennecarriere that's a bad news. Nevertheless good that you have found that! Thanks for the contribution and making sure does (not :( ) work. ---

[jira] [Commented] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis

[ https://issues.apache.org/jira/browse/FLINK-9101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526059#comment-16526059 ] Till Rohrmann commented on FLINK-9101: -- [~kkl0u] could you take a look at this issue? >

[jira] [Commented] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526056#comment-16526056 ] Till Rohrmann commented on FLINK-9525: -- Ping, what is the current state of the PR [~yew1eb]? I see

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

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

[ https://issues.apache.org/jira/browse/FLINK-6222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-6222: Assignee: Craig Foster > YARN: setting environment variables in an easier fashion >

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

[ https://issues.apache.org/jira/browse/FLINK-9686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526035#comment-16526035 ] ASF GitHub Bot commented on FLINK-9686: --- GitHub user fmthoma opened a pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-9686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9686: -- Labels: pull-request-available (was: ) > Flink Kinesis Producer: Enable Kinesis

[GitHub] flink pull request #6221: [FLINK-9686] [kinesis] Enable Kinesis authenticati...

GitHub user fmthoma opened a pull request: https://github.com/apache/flink/pull/6221 [FLINK-9686] [kinesis] Enable Kinesis authentication via AssumeRole ## What is the purpose of the change Enable `FlinkKinesisProducer` to authenticate via assuming a role. ###

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

Franz Thoma created FLINK-9686: -- Summary: Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole Key: FLINK-9686 URL: https://issues.apache.org/jira/browse/FLINK-9686 Project: Flink

[jira] [Commented] (FLINK-9624) Move jar/artifact upload logic out of JobGraph

[ https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526007#comment-16526007 ] ASF GitHub Bot commented on FLINK-9624: --- Github user zentol commented on the issue:

[GitHub] flink issue #6199: [FLINK-9624][runtime] Move jar/artifact upload out of job...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6199 merging. ---

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

[ https://issues.apache.org/jira/browse/FLINK-9677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526002#comment-16526002 ] ASF GitHub Bot commented on FLINK-9677: --- Github user zentol commented on the issue:

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

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6220 Note that the whole resetting logic in the `FileUploadHandler` is rather funky anyways; the handler isn't shareable and thus a handler instance only processes a single request, but the handler is

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

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

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

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/6220 [FLINK-9677][rest] Cleanup encoder after request has been processed Backport of #6217. The `FileUploadHandler` may reject requests before they have been fully received, either due to an

<    1   2