[
https://issues.apache.org/jira/browse/FLINK-8160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481709#comment-16481709
]
ASF GitHub Bot commented on FLINK-8160:
---
GitHub user wangtuo21 opened a pull request
GitHub user wangtuo21 opened a pull request:
https://github.com/apache/flink/pull/6047
[FLINK-8160]Extend OperatorHarness to expose...
...metricsGroup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/wangtuo21/flink master
Alterna
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481693#comment-16481693
]
Xingcan Cui commented on FLINK-8863:
Hi [~twalthr], I got two questions during the imp
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481693#comment-16481693
]
Xingcan Cui edited comment on FLINK-8863 at 5/19/18 5:04 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yazdan Shirvany reassigned FLINK-8983:
--
Assignee: Yazdan Shirvany
> End-to-end test: Confluent schema registry
> --
[
https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481664#comment-16481664
]
ASF GitHub Bot commented on FLINK-9384:
---
Github user tragicjun commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481665#comment-16481665
]
ASF GitHub Bot commented on FLINK-9384:
---
Github user tragicjun commented on a diff i
Github user tragicjun commented on a diff in the pull request:
https://github.com/apache/flink/pull/6026#discussion_r189437091
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -110,6 +116,8 @@ private void writ
Github user tragicjun commented on a diff in the pull request:
https://github.com/apache/flink/pull/6026#discussion_r189437087
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSource.java
---
@@ -81,7 +85
[
https://issues.apache.org/jira/browse/FLINK-8551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lynch Lee closed FLINK-8551.
Resolution: Won't Do
> Should BIGINT in Flink SQL will be enchanced
> --
[
https://issues.apache.org/jira/browse/FLINK-8551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481616#comment-16481616
]
Lynch Lee commented on FLINK-8551:
--
Just a suggestion.
> Should BIGINT in Flink SQL wil
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189432802
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6 +342,
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481612#comment-16481612
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481609#comment-16481609
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189433306
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6 +342,
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189432726
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6 +342,
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481611#comment-16481611
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189432920
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6 +342,
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481614#comment-16481614
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481610#comment-16481610
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481613#comment-16481613
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189432794
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6 +342,
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189432840
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -218,6 +232,
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481606#comment-16481606
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on the issue:
Github user fmthoma commented on the issue:
https://github.com/apache/flink/pull/6021
@tzulitai I agree on adding additional docs, where do you suggest I should
put them? In the Javadoc on `setQueueLimit()`?
My current suggestion is to look at the size of your individual recor
[
https://issues.apache.org/jira/browse/FLINK-8429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481602#comment-16481602
]
ASF GitHub Bot commented on FLINK-8429:
---
GitHub user hequn8128 opened a pull request
GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/6046
[FLINK-8429] Implement stream-stream non-window right outer join
## What is the purpose of the change
Implement stream-stream non-window right outer join. Most of the work has
been d
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481515#comment-16481515
]
Fred Teunissen commented on FLINK-8500:
---
I agree that 'separation of concerns' is a
[
https://issues.apache.org/jira/browse/FLINK-9402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481499#comment-16481499
]
ASF GitHub Bot commented on FLINK-9402:
---
GitHub user tweise opened a pull request:
GitHub user tweise opened a pull request:
https://github.com/apache/flink/pull/6045
[FLINK-9402] [kinesis] Kinesis consumer configuration requires either
region or endpoint.
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us impr
[
https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481498#comment-16481498
]
ASF GitHub Bot commented on FLINK-9384:
---
Github user tragicjun commented on the issu
Github user tragicjun commented on the issue:
https://github.com/apache/flink/pull/6026
Hi @suez1224, I've added some checks in the unit
tests(KafkaAvroTableSourceTestBase), which would fail before the fix.
Meanwhile, I found an issue in the previous version (specifically, the
produ
Thomas Weise created FLINK-9402:
---
Summary: Kinesis consumer validation incorrectly requires
aws.region property
Key: FLINK-9402
URL: https://issues.apache.org/jira/browse/FLINK-9402
Project: Flink
33 matches
Mail list logo
