[jira] [Commented] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351986#comment-16351986 ] Ted Yu commented on FLINK-5486: --- Can this get more review, please ? > Lack of synchronizati

[GitHub] flink issue #5205: [FLINK-8037] Fix integer multiplication or shift implicit...

Github user tedyu commented on the issue: https://github.com/apache/flink/pull/5205 +1 on @StephanEwen's suggestion. ---

[jira] [Commented] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort

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

[jira] [Commented] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint

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

[GitHub] flink pull request #5411: [FLINK-8556] [Kinesis Connector] Add proxy feature...

GitHub user pduveau opened a pull request: https://github.com/apache/flink/pull/5411 [FLINK-8556] [Kinesis Connector] Add proxy feature to the connector ## The purpose of the change The connector can not be configured to use a proxy to access Kinesis endpoint. This feat

[jira] [Updated] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint

[ https://issues.apache.org/jira/browse/FLINK-8556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ph.Duveau updated FLINK-8556: - Summary: Add proxy feature to Kinesis Connector to acces its endpoint (was: Add proxy usage to Kinesis Co

[jira] [Created] (FLINK-8556) Add proxy usage to Kinesis Connector to acces its endpoint

Ph.Duveau created FLINK-8556: Summary: Add proxy usage to Kinesis Connector to acces its endpoint Key: FLINK-8556 URL: https://issues.apache.org/jira/browse/FLINK-8556 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8514) move flink-connector-wikiedits to Apache Bahir

[ https://issues.apache.org/jira/browse/FLINK-8514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351870#comment-16351870 ] Robert Metzger commented on FLINK-8514: --- I think the Bahir community will happily ac

[jira] [Commented] (FLINK-8384) Session Window Assigner with Dynamic Gaps

[ https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351836#comment-16351836 ] ASF GitHub Bot commented on FLINK-8384: --- Github user dyanarose commented on the issu

[GitHub] flink issue #5295: [FLINK-8384] [streaming] Session Window Assigner with Dyn...

Github user dyanarose commented on the issue: https://github.com/apache/flink/pull/5295 the change to return Time has been backed out, so extract returns a long again. PublicEvolving annotations have been added to the new classes and methods. ---

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

GitHub user pduveau opened a pull request: https://github.com/apache/flink/pull/5410 [FLINK-8468] [RabbitMQ Connector] Take advantage of AMQP features ## The purpose of the change To extend the Sink Connector to take full advantage of AMQP features. The AMQP Message sent ca

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

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