[
https://issues.apache.org/jira/browse/FLINK-8811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383313#comment-16383313
]
ASF GitHub Bot commented on FLINK-8811:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383312#comment-16383312
]
ASF GitHub Bot commented on FLINK-8808:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5600
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5599
---
[
https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383295#comment-16383295
]
Piotr Nowojski commented on FLINK-8794:
---
[~Backlight]
3.What kind of downstream processor? Can not
Aleksandr Filichkin created FLINK-8829:
--
Summary: Flink in EMR(YARN) is down due to Akka communication issue
Key: FLINK-8829
URL: https://issues.apache.org/jira/browse/FLINK-8829
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Filichkin updated FLINK-8829:
---
Description:
Hi,
We have running Flink 1.3.2 app in Amazon EMR with YARN. Every week
[
https://issues.apache.org/jira/browse/FLINK-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383293#comment-16383293
]
ASF GitHub Bot commented on FLINK-8821:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5608
Yes, I agree that division is a special in this case. Thank you @Xpray. The
changes look good. Will merge...
---
[
https://issues.apache.org/jira/browse/FLINK-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jelmer Kuperus updated FLINK-8828:
--
Description:
A collect function is a method that takes a Partial Function as its parameter
and
[
https://issues.apache.org/jira/browse/FLINK-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jelmer Kuperus updated FLINK-8828:
--
Description:
A collect function is a method that takes a Partial Function as its parameter
and
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-8191:
---
Fix Version/s: (was: 1.5.0)
1.6.0
> Add a
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383268#comment-16383268
]
Tzu-Li (Gordon) Tai edited comment on FLINK-8191 at 3/2/18 6:53 AM:
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383268#comment-16383268
]
Tzu-Li (Gordon) Tai commented on FLINK-8191:
Yes, moving to 1.6.0.
> Add a
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7913:
---
Fix Version/s: (was: 1.5.0)
1.6.0
> Add support for Kafka
[
https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6764:
---
Fix Version/s: (was: 1.5.0)
1.6.0
> Deduplicate stateless
[
https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383266#comment-16383266
]
Tzu-Li (Gordon) Tai commented on FLINK-6764:
Yes, moving to 1.6.0.
> Deduplicate stateless
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383267#comment-16383267
]
Tzu-Li (Gordon) Tai commented on FLINK-7913:
Yes, moving to 1.6.0.
> Add support for Kafka
[
https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6944:
---
Fix Version/s: 1.6.0
> Introduce DefaultTypeSerializerConfigSnapshot as a base
[
https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6763:
---
Fix Version/s: (was: 1.5.0)
1.6.0
> Inefficient
[
https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383265#comment-16383265
]
Tzu-Li (Gordon) Tai commented on FLINK-6944:
Yes, moving to 1.6.0.
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383264#comment-16383264
]
Tzu-Li (Gordon) Tai commented on FLINK-6763:
[~aljoscha] yes, moving to 1.6.0.
> Inefficient
[
https://issues.apache.org/jira/browse/FLINK-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jelmer Kuperus updated FLINK-8828:
--
Description:
A collect function is a method that takes a Partial Function as its parameter
and
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6352.
Resolution: Fixed
Fix Version/s: 1.6.0
> FlinkKafkaConsumer should support
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383258#comment-16383258
]
Tzu-Li (Gordon) Tai commented on FLINK-6352:
Merged.
1.6.0:
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383255#comment-16383255
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5282
---
Jelmer Kuperus created FLINK-8828:
-
Summary: Add collect method to DataStream / DataSet scala api
Key: FLINK-8828
URL: https://issues.apache.org/jira/browse/FLINK-8828
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383209#comment-16383209
]
yanxiaobin commented on FLINK-8794:
---
hi, [~aljoscha] Thank you for your reply！
There are the following
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383200#comment-16383200
]
ASF GitHub Bot commented on FLINK-6895:
---
Github user buptljy commented on the issue:
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5615
Actually I am not sure if it is appropriate to return "string" because it
should be the inverse of the "DATE_FORMAT()". However, If I return
DATE/TIME/DATETIME as the jira issue described, the type
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383197#comment-16383197
]
ASF GitHub Bot commented on FLINK-6895:
---
GitHub user buptljy opened a pull request:
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/5615
[FLINK-6895][table]Add STR_TO_DATE supported in SQL
## What is the purpose of the change
Add STR_TO_DATE Function supported in SQL
## Brief change log
* STR_TO_DATE(str string, format
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383180#comment-16383180
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5481
@kl0u I added the comments for `@deprecated` in the javadoc. Let me know if
you can merge the two related PRs. Thanks
---
[
https://issues.apache.org/jira/browse/FLINK-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383147#comment-16383147
]
ASF GitHub Bot commented on FLINK-8821:
---
Github user Xpray commented on the issue:
Github user Xpray commented on the issue:
https://github.com/apache/flink/pull/5608
@twalthr I've updated the PR, I think the new configuration in
`TableConfig` shall only be responsible for decimal division, other decimal
operations should have `UNLIMITED` context.
---
[
https://issues.apache.org/jira/browse/FLINK-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-8821:
--
Summary: Fix non-terminating decimal error (was: Fix BigDecimal divide in
AvgAggFunction)
> Fix
[
https://issues.apache.org/jira/browse/FLINK-8822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383090#comment-16383090
]
ASF GitHub Bot commented on FLINK-8822:
---
Github user BigOneLiu commented on the issue:
Github user BigOneLiu commented on the issue:
https://github.com/apache/flink/pull/5609
@zentol thx for comment.
I checked my system SUSE 11 SP4(which is a wildly used version),sed version
is 4.1.5,and it do not support '-E'. I don't konw how many linux version use
sed 4.1.5.
[
https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383075#comment-16383075
]
ASF GitHub Bot commented on FLINK-8790:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5582
Thanks, looking forward.
---
[
https://issues.apache.org/jira/browse/FLINK-8827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383072#comment-16383072
]
ASF GitHub Bot commented on FLINK-8827:
---
GitHub user davidxdh opened a pull request:
GitHub user davidxdh opened a pull request:
https://github.com/apache/flink/pull/5614
[FLINK-8827] When FLINK_CONF_DIR contains spaces, execute zookeeper râ¦
â¦elated scripts failed
When the path of FLINK_CONF_DIR including spaces, executing zookeeper
related scripts
[
https://issues.apache.org/jira/browse/FLINK-8811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383071#comment-16383071
]
ASF GitHub Bot commented on FLINK-8811:
---
Github user zhangminglei commented on a diff in the pull
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5600#discussion_r171754724
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
---
@@ -178,6 +181,13 @@ public URI getRestAddress() {
Donghui Xu created FLINK-8827:
-
Summary: When FLINK_CONF_DIR contains spaces, execute zookeeper
related scripts failed
Key: FLINK-8827
URL: https://issues.apache.org/jira/browse/FLINK-8827
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8824:
---
Assignee: mingleizhang
> In Kafka Consumers, replace 'getCanonicalName()' with
[
https://issues.apache.org/jira/browse/FLINK-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8824:
Description:
The connector uses {{getCanonicalName()}} in all places, gather than
[
https://issues.apache.org/jira/browse/FLINK-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8824:
Summary: In Kafka Consumers, replace 'getCanonicalName()' with
'getClassName()' (was: In Kafka
[
https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7488:
--
Description:
{code}
[
https://issues.apache.org/jira/browse/FLINK-8826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8826:
Assignee: Till Rohrmann
> In Flip6 mode, when starting yarn cluster, configured
[
https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8415:
--
Description:
{code}
public void shutdown() {
running = false;
recordsToSend.complete(0L);
{code}
In
[
https://issues.apache.org/jira/browse/FLINK-8394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8394:
--
Description:
{code}
public void shutdown() {
running = false;
interrupt();
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5607
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382631#comment-16382631
]
ASF GitHub Bot commented on FLINK-8822:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5609
Not sure about this one, after all `4.2` is already _9 years old_.
According to
https://stackoverflow.com/questions/3139126/whats-the-difference-between-sed-e-and-sed-e
and
[
https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382609#comment-16382609
]
Chesnay Schepler commented on FLINK-8819:
-
A nearly finished prototype can be found
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382427#comment-16382427
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5613
@Xpray what do you think about this approach?
---
[
https://issues.apache.org/jira/browse/FLINK-5281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-5281.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in FLINK-8630.
> Extend
[
https://issues.apache.org/jira/browse/FLINK-8826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-8826:
--
Description:
When I tried running some job on the cluster, despite setting
[
https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382230#comment-16382230
]
ASF GitHub Bot commented on FLINK-8537:
---
Github user xccui commented on the issue:
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/5610
Hi @twalthr @fhueske, I wonder if you could help review this PR when you
are convenient.
Thanks, Xingcan
---
Piotr Nowojski created FLINK-8826:
-
Summary: In Flip6 mode, when starting yarn cluster, configured
taskmanager.heap.mb is ignored
Key: FLINK-8826
URL: https://issues.apache.org/jira/browse/FLINK-8826
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382229#comment-16382229
]
ASF GitHub Bot commented on FLINK-8274:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/5613
[FLINK-8274] [table] Split generated methods for preventing compiler
exceptions
## What is the purpose of the change
This PR splits a result record into multiple methods that evaluate a
[
https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8771:
--
Description:
scalastyle 1.0.0 fixes issue with import order, explicit type for public
methods, line length
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382187#comment-16382187
]
ASF GitHub Bot commented on FLINK-8814:
---
Github user jelmerk closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382188#comment-16382188
]
ASF GitHub Bot commented on FLINK-8814:
---
Github user jelmerk commented on the issue:
Aljoscha Krettek created FLINK-8825:
---
Summary: Disallow new String() without charset in checkstyle
Key: FLINK-8825
URL: https://issues.apache.org/jira/browse/FLINK-8825
Project: Flink
Github user jelmerk commented on the issue:
https://github.com/apache/flink/pull/5603
Thanks!
---
Github user jelmerk closed the pull request at:
https://github.com/apache/flink/pull/5603
---
[
https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382142#comment-16382142
]
Aljoscha Krettek commented on FLINK-6763:
-
[~tzulitai] Did we decide to move this to 1.6.0? Or at
[
https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382140#comment-16382140
]
Aljoscha Krettek commented on FLINK-6764:
-
[~tzulitai] Did we decide to move this to 1.6.0? Or at
[
https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382139#comment-16382139
]
Aljoscha Krettek commented on FLINK-6944:
-
[~tzulitai] Did we decide to move this to 1.6.0? Or at
[
https://issues.apache.org/jira/browse/FLINK-7733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7733.
---
Resolution: Cannot Reproduce
Fix Version/s: (was: 1.5.0)
Closing for now since
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382134#comment-16382134
]
Aljoscha Krettek commented on FLINK-8191:
-
[~tzulitai] Did we decide to move this to 1.6.0? Or at
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382135#comment-16382135
]
Aljoscha Krettek commented on FLINK-7913:
-
[~tzulitai] Did we decide to move this to 1.6.0? Or at
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8500:
Priority: Major (was: Blocker)
> Get the timestamp of the Kafka message from kafka
Stephan Ewen created FLINK-8824:
---
Summary: In Kafka Consumers, replace 'getCanonicalClassName()'
with 'getClassName()'
Key: FLINK-8824
URL: https://issues.apache.org/jira/browse/FLINK-8824
Project:
[
https://issues.apache.org/jira/browse/FLINK-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-8810.
---
Resolution: Fixed
Implemented on release-1.5 in
122e2eb4606afd0cdf20ab3bf82bb524bb9c3673
[
https://issues.apache.org/jira/browse/FLINK-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382111#comment-16382111
]
ASF GitHub Bot commented on FLINK-8810:
---
Github user aljoscha closed the pull request at:
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/5612
---
[
https://issues.apache.org/jira/browse/FLINK-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382105#comment-16382105
]
ASF GitHub Bot commented on FLINK-8810:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5612
Thanks @zentol! I'm fixing the indentation and merging.
Btw, I'm using spaces in `run-pre-commit-tests.sh` because all other shell
scripts in that folder also use spaces. Inconsistent, yes,
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-8814.
---
Resolution: Fixed
Fix Version/s: 1.5.0
Implemented on release-1.5 in
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382089#comment-16382089
]
ASF GitHub Bot commented on FLINK-8814:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5603
Merged. ð Could you please close the PR?
---
[
https://issues.apache.org/jira/browse/FLINK-8458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382064#comment-16382064
]
ASF GitHub Bot commented on FLINK-8458:
---
Github user zhijiangW commented on a diff in the pull
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/5317#discussion_r171575083
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
---
@@ -269,15 +269,21 @@
public static final
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5612#discussion_r171571281
--- Diff: tools/travis_mvn_watchdog.sh ---
@@ -576,61 +576,9 @@ case $TEST in
printf "Running end-to-end tests\n"
[
https://issues.apache.org/jira/browse/FLINK-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382054#comment-16382054
]
ASF GitHub Bot commented on FLINK-8810:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382053#comment-16382053
]
ASF GitHub Bot commented on FLINK-8810:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5612#discussion_r171572132
--- Diff: flink-end-to-end-tests/run-pre-commit-tests.sh ---
@@ -0,0 +1,98 @@
+#!/usr/bin/env bash
[
https://issues.apache.org/jira/browse/FLINK-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382043#comment-16382043
]
ASF GitHub Bot commented on FLINK-8667:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5500
LGTM! Thanks for the work @bowenli86 !
---
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382032#comment-16382032
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5481#discussion_r171566773
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala
---
@@ -66,9 +66,9 @@ class KeyedStream[T,
[
https://issues.apache.org/jira/browse/FLINK-8820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8820:
Priority: Blocker (was: Critical)
> FlinkKafkaConsumer010 reads too many bytes
>
1 - 100 of 203 matches
Mail list logo
