[
https://issues.apache.org/jira/browse/FLINK-8811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383313#comment-16383313
]
ASF GitHub Bot commented on FLINK-8811:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383312#comment-16383312
]
ASF GitHub Bot commented on FLINK-8808:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5599
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5600
---
[
https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383295#comment-16383295
]
Piotr Nowojski commented on FLINK-8794:
---
[~Backlight]
3.What kind of downstream pr
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&focusedCommentId=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 RoundRobinPartitioner
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=16383268#comment-16383268
]
Tzu-Li (Gordon) Tai commented on FLINK-8191:
Yes, moving to 1.6.0.
> Add a Ro
[
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 defau
[
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 TypeS
[
https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383266#comment-16383266
]
Tzu-Li (Gordon) Tai commented on FLINK-6764:
Yes, moving to 1.6.0.
> Deduplic
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383267#comment-16383267
]
Tzu-Li (Gordon) Tai commented on FLINK-7913:
Yes, moving to 1.6.0.
> Add supp
[
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 impleme
[
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 PojoSerializerC
[
https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383265#comment-16383265
]
Tzu-Li (Gordon) Tai commented on FLINK-6944:
Yes, moving to 1.6.0.
> Introduc
[
https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383264#comment-16383264
]
Tzu-Li (Gordon) Tai commented on FLINK-6763:
[~aljoscha] yes, moving to 1.6.0.
[
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 to
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383258#comment-16383258
]
Tzu-Li (Gordon) Tai commented on FLINK-6352:
Merged.
1.6.0: f8ca273549aded00c
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383255#comment-16383255
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user asfgit closed the pull request
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 Ty
[
https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383209#comment-16383209
]
yanxiaobin commented on FLINK-8794:
---
hi, [~aljoscha] Thank you for your reply！
There a
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 o
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 st
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383180#comment-16383180
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user bowenli86 commented on the issu
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&focusedCommentId=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 non-te
[
https://issues.apache.org/jira/browse/FLINK-8822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383090#comment-16383090
]
ASF GitHub Bot commented on FLINK-8822:
---
Github user BigOneLiu commented on the issu
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&focusedCommentId=16383075#comment-16383075
]
ASF GitHub Bot commented on FLINK-8790:
---
Github user sihuazhou commented on the issu
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&focusedCommentId=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 fail
[
https://issues.apache.org/jira/browse/FLINK-8811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383071#comment-16383071
]
ASF GitHub Bot commented on FLINK-8811:
---
Github user zhangminglei commented on a dif
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 'getClassName(
[
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
{{getClassName()}
[
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 Cons
[
https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7488:
--
Description:
{code}
compareNetworkBufShellScriptWithJava(org.apache.flink.dist.TaskManagerHeapSizeCalculationJav
[
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 taskmanager
[
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 ot
[
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();
expectedRecord.complete
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&focusedCommentId=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://www.gnu.or
[
https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16382609#comment-16382609
]
Chesnay Schepler commented on FLINK-8819:
-
A nearly finished prototype can be foun
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 KafkaJsonTableSources
[
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
taskmanager.heap.mb
[
https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=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 fie
[
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 limi
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16382187#comment-16382187
]
ASF GitHub Bot commented on FLINK-8814:
---
Github user jelmerk closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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
Issue
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-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16382140#comment-16382140
]
Aljoscha Krettek commented on FLINK-6764:
-
[~tzulitai] Did we decide to move this
[
https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16382142#comment-16382142
]
Aljoscha Krettek commented on FLINK-6763:
-
[~tzulitai] Did we decide to move this
[
https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16382139#comment-16382139
]
Aljoscha Krettek commented on FLINK-6944:
-
[~tzulitai] Did we decide to move this
[
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 this
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16382134#comment-16382134
]
Aljoscha Krettek commented on FLINK-8191:
-
[~tzulitai] Did we decide to move this
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16382135#comment-16382135
]
Aljoscha Krettek commented on FLINK-7913:
-
[~tzulitai] Did we decide to move this
[
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 consumer
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: Flin
[
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
Impl
[
https://issues.apache.org/jira/browse/FLINK-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16382111#comment-16382111
]
ASF GitHub Bot commented on FLINK-8810:
---
Github user aljoscha closed the pull reques
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&focusedCommentId=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
06b05cd204bd9a1288
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=16382064#comment-16382064
]
ASF GitHub Bot commented on FLINK-8458:
---
Github user zhijiangW commented on a diff i
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 ConfigOpti
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&focusedCommentId=16382054#comment-16382054
]
ASF GitHub Bot commented on FLINK-8810:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16382053#comment-16382053
]
ASF GitHub Bot commented on FLINK-8810:
---
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/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&focusedCommentId=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&focusedCommentId=16382032#comment-16382032
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user kl0u commented on a diff in the
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, K](javaStream:
[
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
