[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121161#comment-16121161
]
ASF GitHub Bot commented on FLINK-7367:
---
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/4473#discussion_r132376112
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -165,17 +1
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121160#comment-16121160
]
ASF GitHub Bot commented on FLINK-7367:
---
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/4473#discussion_r132375356
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121157#comment-16121157
]
ASF GitHub Bot commented on FLINK-7367:
---
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/4473#discussion_r132375079
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121151#comment-16121151
]
ASF GitHub Bot commented on FLINK-7367:
---
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/4473#discussion_r132374210
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121148#comment-16121148
]
ASF GitHub Bot commented on FLINK-7367:
---
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/4473#discussion_r132373930
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121144#comment-16121144
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121147#comment-16121147
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user bowenli86 commented on a diff i
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4473
Thanks! Overall I think the changes are good.
I've left some minor cosmetic-related comments, and some more involved
comments on how we perform the deprecation.
---
If your project is set up fo
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4473#discussion_r132373651
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4473#discussion_r132373446
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -165,17 +16
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121143#comment-16121143
]
ASF GitHub Bot commented on FLINK-7367:
---
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/4473#discussion_r132373167
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121142#comment-16121142
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121139#comment-16121139
]
ASF GitHub Bot commented on FLINK-7367:
---
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/4473#discussion_r132373023
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121137#comment-16121137
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121136#comment-16121136
]
ASF GitHub Bot commented on FLINK-7367:
---
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/4473#discussion_r132372556
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@ -
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4473#discussion_r132372454
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121134#comment-16121134
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121135#comment-16121135
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121131#comment-16121131
]
ASF GitHub Bot commented on FLINK-7367:
---
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/4473#discussion_r132372254
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@ -
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4473#discussion_r132372291
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java
---
@@ -
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4473#discussion_r132372133
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -165,17 +16
[
https://issues.apache.org/jira/browse/FLINK-7172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yueting Chen closed FLINK-7172.
---
Resolution: Won't Do
> Add a event logical id field to ValueTimeWrapper
>
[
https://issues.apache.org/jira/browse/FLINK-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121120#comment-16121120
]
ASF GitHub Bot commented on FLINK-7124:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4510
R: @tillrohrmann
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or
[
https://issues.apache.org/jira/browse/FLINK-7172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121118#comment-16121118
]
Yueting Chen commented on FLINK-7172:
-
I think we don't need to resolve this any more.
[
https://issues.apache.org/jira/browse/FLINK-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121116#comment-16121116
]
ASF GitHub Bot commented on FLINK-7124:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/4510
[FLINK-7124] [flip-6] Add test to verify rescaling JobGraphs works correctly
## What is the purpose of the change
This pull request adds test to verify that rescaling `JobGraph`s to
arbitr
GitHub user zhijiangW opened a pull request:
https://github.com/apache/flink/pull/4509
[FLINK-7406][network] Implement Netty receiver incoming pipeline for
credit-based
## What is the purpose of the change
Currently `PartitionRequestClientHandler` receives and reads BufferR
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121106#comment-16121106
]
ASF GitHub Bot commented on FLINK-7406:
---
GitHub user zhijiangW opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Priority: Blocker (was: Critical)
> Assumption of partition id strict contiguity is t
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121099#comment-16121099
]
Tzu-Li (Gordon) Tai commented on FLINK-7407:
[~aljoscha] this information isn'
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121094#comment-16121094
]
Aljoscha Krettek commented on FLINK-7407:
-
[~tzulitai] Should we make this a block
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-7407:
--
Assignee: Tzu-Li (Gordon) Tai
> Assumption of partition id strict contiguity is
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Description:
In the Kafka Consumer's {{AbstractPartitionDiscoverer}}, for partition
d
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Priority: Critical (was: Major)
> Assumption of partition id strict contiguity is too
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Affects Version/s: 1.4.0
> Assumption of partition id strict contiguity is too naive i
Tzu-Li (Gordon) Tai created FLINK-7407:
--
Summary: Assumption of partition id strict contiguity is too naive
in Kafka consumer's AbstractPartitionDiscoverer
Key: FLINK-7407
URL: https://issues.apache.org/jira/
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16121011#comment-16121011
]
ASF GitHub Bot commented on FLINK-7368:
---
Github user asdf2014 commented on a diff in
Github user asdf2014 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4472#discussion_r132358492
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricStore.java
---
@@ -24,8 +24,8 @@
import org.slf4j.Logger;
zhijiang created FLINK-7406:
---
Summary: Implement Netty receiver incoming pipeline for
credit-based
Key: FLINK-7406
URL: https://issues.apache.org/jira/browse/FLINK-7406
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120997#comment-16120997
]
ASF GitHub Bot commented on FLINK-7009:
---
Github user dbrinegar commented on the issu
Github user dbrinegar commented on the issue:
https://github.com/apache/flink/pull/4188
Totally understand! Busy here too. Let me know what you decide to do and
I'll try to chip in.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
[
https://issues.apache.org/jira/browse/FLINK-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120955#comment-16120955
]
ASF GitHub Bot commented on FLINK-6787:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4500
@zentol I have created this PR to fix
[https://issues.apache.org/jira/browse/FLINK-6787](https://issues.apache.org/jira/browse/FLINK-6787),
could you please have a look when you're free, thanks :)
Github user yestinchen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132349108
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,276 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120938#comment-16120938
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on a diff
Github user yestinchen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132348950
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -150,6 +160,59 @@ long getWindowTime() {
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120936#comment-16120936
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120928#comment-16120928
]
Jark Wu edited comment on FLINK-7398 at 8/10/17 1:52 AM:
-
[~wheat9
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120928#comment-16120928
]
Jark Wu commented on FLINK-7398:
[~wheat9] how do you want to fix it?
> Table API operat
[
https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120885#comment-16120885
]
Michael Fong commented on FLINK-6805:
-
Thanks for your comment, [~Zentol],
I see the
[
https://issues.apache.org/jira/browse/FLINK-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120845#comment-16120845
]
Zhenzhong Xu commented on FLINK-7278:
-
[~trohrm...@apache.org] unfortunately, we don't
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120818#comment-16120818
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user rangadi commented on the issue:
Github user rangadi commented on the issue:
https://github.com/apache/flink/pull/4239
> Hmmm, are you sure about this thing? That would mean that Kafka doesn't
support transactional parallel writes from two different process, which would
be very strange. Could you point to a source of
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120713#comment-16120713
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user pnowojski commented on the issu
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4239
Writing records in state would be very costly. It is only a "last resort"
solution.
> That would imply exactly-once consumers can not read past that
transaction as long as it is open
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120703#comment-16120703
]
ASF GitHub Bot commented on FLINK-7405:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4508
Make sense
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if th
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120701#comment-16120701
]
ASF GitHub Bot commented on FLINK-7405:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4508
this way all exceptions are being cutoff, please add a separate catch block
for socket timeout exceptions.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7405:
Summary: Reduce spamming warning logging from DatadogHttpReporter (was:
Reduce excessive warning logging fr
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120664#comment-16120664
]
ASF GitHub Bot commented on FLINK-7405:
---
GitHub user bowenli86 opened a pull request
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4508
[FLINK-7405][metrics] Reduce excessive warning logging from
DatadogHttpReporter
## What is the purpose of the change
DatadogHttpReporter is logging too much when there's a connection time
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7405:
Component/s: Metrics
> Reduce excessive warning logging from DatadogHttpReporter
> -
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7405:
Description:
DatadogHttpReporter is logging too much when there's a connection timeout, and
we need to redu
[
https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120659#comment-16120659
]
ASF GitHub Bot commented on FLINK-6281:
---
Github user haohui commented on the issue:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3712
Thanks @fhueske ! Updated the PR to address the comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Bowen Li created FLINK-7405:
---
Summary: Reduce excessive warning logging from DatadogHttpReporter
Key: FLINK-7405
URL: https://issues.apache.org/jira/browse/FLINK-7405
Project: Flink
Issue Type: Imp
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-7357:
Assignee: Rong Rong (was: Haohui Mai)
> HOP_START() HOP_END() does not work when using HAVING clau
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120536#comment-16120536
]
Haohui Mai commented on FLINK-7398:
---
Good catch!
I think we can fix it for once but I'm
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-7398:
-
Assignee: Haohui Mai
> Table API operators/UDFs must not store Logger
> -
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120511#comment-16120511
]
Haohui Mai commented on FLINK-7357:
---
I haven't started yet. Please go ahead.
> HOP_STAR
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120483#comment-16120483
]
Rong Rong commented on FLINK-7357:
--
Seems like the logical plan generated from Having ins
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120319#comment-16120319
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4473
@tzulitai @aljoscha Let me know if this PR looks good. Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120249#comment-16120249
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user rangadi commented on the issue:
Github user rangadi commented on the issue:
https://github.com/apache/flink/pull/4239
May be an extra shuffle to make small batches could help. Another option is
to buffer all the records in state and write them all inside commit(). But not
sure how costly it is to save all the record
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120145#comment-16120145
]
Xingcan Cui commented on FLINK-7245:
I have made some minor changes, which can be foun
[
https://issues.apache.org/jira/browse/FLINK-7372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120143#comment-16120143
]
ASF GitHub Bot commented on FLINK-7372:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4483
+1, feel free to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
[
https://issues.apache.org/jira/browse/FLINK-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7395:
Priority: Major (was: Blocker)
> NumBytesOut metric in RecordWriter call synchronized metho
[
https://issues.apache.org/jira/browse/FLINK-7404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120102#comment-16120102
]
ASF GitHub Bot commented on FLINK-7404:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4507
[FLINK-7404] [table] Generate code for non-equi join conditions only.
## What is the purpose of the change
Generate code only for non-equi join conditions for Table API / SQL batch
joins.
[
https://issues.apache.org/jira/browse/FLINK-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120091#comment-16120091
]
ASF GitHub Bot commented on FLINK-7395:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4504
@twalthr noticed it and found it odd that we acquire a lock for doing
metrics stuff, and asked me whether it is correct.
Since we try to keep the overhead of metrics as low as possible not
ac
Fabian Hueske created FLINK-7404:
Summary: Table API batch join code-gen's equi-join conditions
Key: FLINK-7404
URL: https://issues.apache.org/jira/browse/FLINK-7404
Project: Flink
Issue Type
Timo Walther created FLINK-7403:
---
Summary: Remove expandLocalRef() before code generation
Key: FLINK-7403
URL: https://issues.apache.org/jira/browse/FLINK-7403
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6805:
Fix Version/s: 1.4.0
> Flink Cassandra connector dependency on Netty disagrees with Flink
>
[
https://issues.apache.org/jira/browse/FLINK-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120044#comment-16120044
]
ASF GitHub Bot commented on FLINK-7395:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4504
@zentol what is the root cause for this change? I see that this is marked
as a blocker bug. Was this reported or discussed on the mailing list?
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120018#comment-16120018
]
Chesnay Schepler commented on FLINK-6805:
-
Since the cassandra connector jar doesn
1 - 100 of 272 matches
Mail list logo
