[
https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-9398:
Description:
See:
https://github.com/apache/flink/blob/4922ced71a307a26b9f5070b41f72fd5d93b0ac8/flink-clien
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480250#comment-16480250
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480251#comment-16480251
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/6021
@tzulitai adding docs to educate users on tuning KPL performance would be
good. I has quite some experience on it (as you may have know :) Ping me if
you start working on it before I do, and I'll
[
https://issues.apache.org/jira/browse/FLINK-9337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480248#comment-16480248
]
ASF GitHub Bot commented on FLINK-9337:
---
Github user dawidwys commented on the issue
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189177308
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6 +342
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/5995
@StephanEwen could you have another look?
---
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480244#comment-16480244
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480246#comment-16480246
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480245#comment-16480245
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480243#comment-16480243
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189174902
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6 +34
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189175770
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6 +34
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189176708
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6 +34
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189176320
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6 +34
[
https://issues.apache.org/jira/browse/FLINK-9326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480228#comment-16480228
]
ASF GitHub Bot commented on FLINK-9326:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6041
[FLINK-9326] TaskManagerOptions.NUM_TASK_SLOTS does not work for
local/embedded mode
## What is the purpose of the change
*This pull request fixed the num slot config value override error.*
[
https://issues.apache.org/jira/browse/FLINK-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480216#comment-16480216
]
Sergey Nuyanzin edited comment on FLINK-8161 at 5/18/18 6:21 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-8161:
---
Attachment: api.travis-ci.org_v3_job_380488917_log.tar.xz
> Flakey YARNSessionCapacitySchedule
[
https://issues.apache.org/jira/browse/FLINK-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-8161:
---
Attachment: 24547.10.tar.gz
> Flakey YARNSessionCapacitySchedulerITCase on Travis
> --
[
https://issues.apache.org/jira/browse/FLINK-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reopened FLINK-8161:
Looks like it happened again
Also I downloaded logs mentioned in failed travis job
{quote}
Upl
[
https://issues.apache.org/jira/browse/FLINK-8267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-8267.
---
Resolution: Later
> update Kinesis Producer example for setting Region key
> -
[
https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480215#comment-16480215
]
ASF GitHub Bot commented on FLINK-8554:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5978
@StephanEwen here is test error in the [build
job](https://travis-ci.org/apache/flink/jobs/380523257), and it seems the aws
sdk is under license "Apache 2.0", so should I do the second item you aske
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480207#comment-16480207
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user snuyanzin commented on the issu
Github user snuyanzin commented on the issue:
https://github.com/apache/flink/pull/6040
@tzulitai, @tedyu thnk you for your review, comments and contribution tips
I did updates which includes moving test into AbstractFetcherTest and
making it kafka connector version independent
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480198#comment-16480198
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user snuyanzin commented on a diff i
Github user snuyanzin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r189168596
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/Flink9349Test.java
---
@@ -0,0 +1,
[
https://issues.apache.org/jira/browse/FLINK-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480195#comment-16480195
]
ASF GitHub Bot commented on FLINK-8838:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189167881
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala
---
@@ -18,74 +18,244 @@
package
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5941
I think it is safe to merge this change.
Will merge this now ..
---
[
https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480179#comment-16480179
]
ASF GitHub Bot commented on FLINK-8971:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5955
@kl0u yes, lets do that as a separate commit then.
+1, this looks good to me.
One final comment for the merge:
When merging to `master`, we should have test savepoints for both `
[
https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480177#comment-16480177
]
ASF GitHub Bot commented on FLINK-8659:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480174#comment-16480174
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480173#comment-16480173
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189163394
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -218,6 +232
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r189164871
--- 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-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480114#comment-16480114
]
ASF GitHub Bot commented on FLINK-8838:
---
Github user lincoln-lil commented on a diff
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189159027
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala
---
@@ -18,74 +18,244 @@
pack
[
https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480101#comment-16480101
]
ASF GitHub Bot commented on FLINK-8554:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5978
version: 1.11.319:
```
[INFO] org.apache.flink:flink-connector-kinesis_2.11:jar:1.6-SNAPSHOT
[INFO] +- com.amazonaws:aws-java-sdk-kinesis:jar:1.11.319:compile
[INFO] | +- com.amaz
[
https://issues.apache.org/jira/browse/FLINK-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480100#comment-16480100
]
ASF GitHub Bot commented on FLINK-8838:
---
Github user lincoln-lil commented on a diff
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189156884
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala
---
@@ -18,74 +18,244 @@
pack
[
https://issues.apache.org/jira/browse/FLINK-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480081#comment-16480081
]
vinoyang commented on FLINK-9375:
-
[~sihuazhou] agree with you, it's duplicate of FLINK-88
[
https://issues.apache.org/jira/browse/FLINK-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480081#comment-16480081
]
vinoyang edited comment on FLINK-9375 at 5/18/18 3:18 AM:
--
[~sihu
[
https://issues.apache.org/jira/browse/FLINK-9393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480079#comment-16480079
]
vinoyang commented on FLINK-9393:
-
the reason and opinion provided by [~yuzhih...@gmail.co
[
https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9398:
---
Assignee: vinoyang
> Flink CLI list running job returns all jobs except in CREATE state
> ---
[
https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480054#comment-16480054
]
ASF GitHub Bot commented on FLINK-9182:
---
Github user makeyang commented on the issue
Github user makeyang commented on the issue:
https://github.com/apache/flink/pull/5908
@StefanRRichter should jira be close too?
---
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6038
Oh this is great! @StefanRRichter Is this means that flink plan to make
checkpoint support rescaling officially in the near future?
---
[
https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480049#comment-16480049
]
ASF GitHub Bot commented on FLINK-9182:
---
Github user makeyang closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-9394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480051#comment-16480051
]
ASF GitHub Bot commented on FLINK-9394:
---
Github user sihuazhou commented on the issu
Github user makeyang closed the pull request at:
https://github.com/apache/flink/pull/5908
---
[
https://issues.apache.org/jira/browse/FLINK-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480041#comment-16480041
]
Sihua Zhou commented on FLINK-9375:
---
Hi [~srichter][~yanghua]I think this is a bit looks
[
https://issues.apache.org/jira/browse/FLINK-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480001#comment-16480001
]
ASF GitHub Bot commented on FLINK-8838:
---
Github user suez1224 commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1647#comment-1647
]
ASF GitHub Bot commented on FLINK-8838:
---
Github user suez1224 commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479998#comment-16479998
]
ASF GitHub Bot commented on FLINK-8838:
---
Github user suez1224 commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1648#comment-1648
]
ASF GitHub Bot commented on FLINK-8838:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189144224
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala
---
@@ -18,74 +18,244 @@
package
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189144701
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala
---
@@ -18,74 +18,244 @@
package
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189144263
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala
---
@@ -18,74 +18,244 @@
package
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189145367
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/AggregateITCase.scala
---
@@ -367,6 +367,36 @@ class Aggregat
[
https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9398:
-
Description:
See:
https://github.com/apache/flink/blob/master/flink-clients/src/main/java/org/apache/flin
Rong Rong created FLINK-9398:
Summary: Flink CLI list running job returns all jobs except in
CREATE state
Key: FLINK-9398
URL: https://issues.apache.org/jira/browse/FLINK-9398
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-8873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479905#comment-16479905
]
ASF GitHub Bot commented on FLINK-8873:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5649
Hi @kl0u , can you pls take a look at this PR?
---
[
https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479855#comment-16479855
]
ASF GitHub Bot commented on FLINK-6160:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-6160.
Resolution: Fixed
Fixed via
master: c832f52a9ca489b72e3eddcb51c288d23d66b571
1.5.0: ba379ec0ee451fe
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6035
---
[
https://issues.apache.org/jira/browse/FLINK-9387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479674#comment-16479674
]
ASF GitHub Bot commented on FLINK-9387:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6029#discussion_r188936871
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
---
@@ -30
[
https://issues.apache.org/jira/browse/FLINK-9393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479565#comment-16479565
]
Ted Yu commented on FLINK-9393:
---
The tricky part is about the hostnames member which has an
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9292.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed in c8fa8d025684c2225824c54a7285bbfdec7cfddc an
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9292.
---
> Remove TypeInfoParser
> -
>
> Key: FLINK-9292
> URL:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/c8fa8d025684c2225824c54a7285bbfdec7cfddc#commitcomment-29021995
In
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeInfoParser.java:
In
flink-core/src/main/java/org/apach
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9299.
---
> ProcessWindowFunction documentation Java examples have errors
>
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9299.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in
- 1.5.0 via 94391d89a49abda9e1b82cc2bc44d
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479515#comment-16479515
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user ctamisier commented on a diff i
Github user ctamisier commented on a diff in the pull request:
https://github.com/apache/flink/pull/5964#discussion_r189056714
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@ -4
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479509#comment-16479509
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user ctamisier commented on the issu
Github user ctamisier commented on the issue:
https://github.com/apache/flink/pull/5964
Okay, I've pushed the changes.
---
Stephan Ewen created FLINK-9397:
---
Summary: Individual Buffer Timeout of 0 incorrectly leads to
default timeout
Key: FLINK-9397
URL: https://issues.apache.org/jira/browse/FLINK-9397
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479472#comment-16479472
]
Stephan Ewen commented on FLINK-9388:
-
When a task's status is canceled, any exception
[
https://issues.apache.org/jira/browse/FLINK-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479465#comment-16479465
]
Stephan Ewen commented on FLINK-9390:
-
When closing due to cancellation, the thread wi
[
https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479462#comment-16479462
]
Sihua Zhou commented on FLINK-9373:
---
[~srichter] FYI [3558|https://github.com/facebook/r
[
https://issues.apache.org/jira/browse/FLINK-9393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479459#comment-16479459
]
Stephan Ewen commented on FLINK-9393:
-
This is not a bug, right?
hashCode() is allowe
Josh Lemer created FLINK-9396:
-
Summary: Allow streaming sources (especially Files, Kafka) to set
max queued input elements
Key: FLINK-9396
URL: https://issues.apache.org/jira/browse/FLINK-9396
Project: F
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479426#comment-16479426
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user snuyanzin commented on a diff i
Github user snuyanzin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r189038623
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/Flink9349Test.java
---
@@ -0,0 +1,
[
https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479422#comment-16479422
]
Ken Geis commented on FLINK-9395:
-
It appears that the faulty logic is in {{DataSetJoin.pa
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6039
Very nice, very helpful for users.
+1 to merge this
---
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479414#comment-16479414
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tedyu commented on a diff in th
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r189036753
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java
---
@@ -507,7 +
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479404#comment-16479404
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user snuyanzin commented on a diff i
Github user snuyanzin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r189035401
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java
---
@@ -507
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479391#comment-16479391
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6040
Thanks for the PR @snuyanzin!
I had some comments, please let me know what you think.
Also, some general contribution tips:
1. I would suggest the title of the PR to be something alon
Ken Geis created FLINK-9395:
---
Summary: multiple left outer joins to subqueries with array values
fail
Key: FLINK-9395
URL: https://issues.apache.org/jira/browse/FLINK-9395
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479386#comment-16479386
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tzulitai commented on a diff in
1 - 100 of 351 matches
Mail list logo
