[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-6918:
Assignee: Till Rohrmann
> Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTes
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4129
[FLINK-6918] [tests] Harden AbstractOperatorRestoreTestBase by retrying
CancelWithSavepoint messages
The problem is that a StreamTask can be in state RUNNING without internally
being running.
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050077#comment-16050077
]
ASF GitHub Bot commented on FLINK-6918:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050072#comment-16050072
]
Till Rohrmann commented on FLINK-6918:
--
Once FLINK-4714 has been fixed, this issue sh
[
https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050068#comment-16050068
]
mingleizhang commented on FLINK-3387:
-
Hey, [~sbcd90] Are you still working on this ye
sunjincheng created FLINK-6924:
--
Summary: ADD LOG/LPAD/RPAD/BIN supported in TableAPI
Key: FLINK-6924
URL: https://issues.apache.org/jira/browse/FLINK-6924
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050066#comment-16050066
]
sunjincheng commented on FLINK-6895:
Hi, [~wheat9] I noticed that you had opened a nic
[
https://issues.apache.org/jira/browse/FLINK-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6893:
--
Assignee: sunjincheng
> Add BIN supported in SQL
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-6918:
-
Labels: test-stability (was: )
> Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTe
[
https://issues.apache.org/jira/browse/FLINK-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050058#comment-16050058
]
ASF GitHub Bot commented on FLINK-6893:
---
GitHub user sunjincheng121 opened a pull re
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050056#comment-16050056
]
mingleizhang commented on FLINK-4602:
-
[~Zentol] Oh. Thanks, I see. I will not do it u
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050057#comment-16050057
]
Till Rohrmann commented on FLINK-6918:
--
Another instance: This time for the {{KeyedCo
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-6918:
-
Priority: Critical (was: Major)
> Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseT
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4128
[FLINK-6893][table]Add BIN supported in SQL
In this PR. have Add BIN supported in SQL,e.g.:
```
BIN(12) -> "1100"
BIN(10)-> "1010"
```
- [x] General
- The pull reques
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050045#comment-16050045
]
Chesnay Schepler commented on FLINK-4602:
-
[~mingleizhang] This issue is marked fo
[
https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050038#comment-16050038
]
Zhe Li commented on FLINK-6602:
---
Fabian，
I understand what you mean.
So I modified the cod
[
https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhe Li updated FLINK-6602:
--
Attachment: getRowType.png
> Table source with defined time attributes allows empty string
> ---
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4127
[FLINK-6892][table]Add L/RPAD supported in SQL
In this PR. have Add L/RPAD supported in SQL,For Example:
```
LPAD('hi',4,'??') -> '??hi'
LPAD('hi',1,'??') -> 'h'
RPAD('hi',4,''
[
https://issues.apache.org/jira/browse/FLINK-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050011#comment-16050011
]
ASF GitHub Bot commented on FLINK-6892:
---
GitHub user sunjincheng121 opened a pull re
[
https://issues.apache.org/jira/browse/FLINK-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6892:
---
Description:
L/RPAD(str,len,padstr) Returns the string str, left/right-padded with the
string padstr
[
https://issues.apache.org/jira/browse/FLINK-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6892:
---
Summary: Add L/RPAD supported in SQL (was: Add LPAD supported in SQL)
> Add L/RPAD supported in SQL
>
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-4602:
---
Assignee: mingleizhang
> Move RocksDB backend to proper package
> ---
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049990#comment-16049990
]
mingleizhang commented on FLINK-4602:
-
What you mean that currently we needn't move Ro
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049980#comment-16049980
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user haoch commented on the issue:
Github user haoch commented on the issue:
https://github.com/apache/flink/pull/2487
@asdf2014 sorry for delayed response, will find some time to finalize this
PR and propose to Bahir project .
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6892:
--
Assignee: sunjincheng
> Add LPAD supported in SQL
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6810:
--
Assignee: (was: sunjincheng)
> Add Some built-in Scalar Function supported
> --
[
https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6810:
--
Assignee: sunjincheng
> Add Some built-in Scalar Function supported
> -
[
https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049937#comment-16049937
]
ASF GitHub Bot commented on FLINK-6498:
---
Github user zjureel commented on a diff in
Github user zjureel commented on a diff in the pull request:
https://github.com/apache/flink/pull/4123#discussion_r122110338
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java
---
@@ -100,6 +100,45 @@
.defaultValu
[
https://issues.apache.org/jira/browse/FLINK-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-6923:
Description:
We have a use case where we have our custom Fetcher implementation that extends
Abstra
Zhenzhong Xu created FLINK-6923:
---
Summary: Kafka connector needs to expose information about
in-flight record in AbstractFetcher base class
Key: FLINK-6923
URL: https://issues.apache.org/jira/browse/FLINK-6923
[
https://issues.apache.org/jira/browse/FLINK-6836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049339#comment-16049339
]
ASF GitHub Bot commented on FLINK-6836:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4120
Rebasing onto the latest master
---
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
Till Rohrmann created FLINK-6922:
Summary: Enum(Value)SerializerConfigSnapshot uses Java
serialization to store enum values
Key: FLINK-6922
URL: https://issues.apache.org/jira/browse/FLINK-6922
Projec
[
https://issues.apache.org/jira/browse/FLINK-6921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049311#comment-16049311
]
ASF GitHub Bot commented on FLINK-6921:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4126
[FLINK-6921] [serializer] Allow EnumValueSerializer to deal with appended
enum values
The problem was that we don't check the bounds of the array with the enum
names contained
in the Scala
[
https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049288#comment-16049288
]
ASF GitHub Bot commented on FLINK-6682:
---
GitHub user zhangminglei opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-6682:
---
Assignee: mingleizhang
> Improve error message in case parallelism exceeds maxParallelism
> -
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/4125
[FLINK-6682] [checkpoints] Improve error message in case parallelism â¦
â¦exceeds maxParallelism
Thanks for contributing to Apache Flink. Before you open your pull request,
please ta
[
https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049285#comment-16049285
]
mingleizhang commented on FLINK-6682:
-
Thanks for telling me. [~Zentol] and I have pu
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049259#comment-16049259
]
Chesnay Schepler commented on FLINK-6918:
-
So, i guess what happens is that the sa
Till Rohrmann created FLINK-6921:
Summary: EnumValueSerializer cannot properly handle appended enum
values
Key: FLINK-6921
URL: https://issues.apache.org/jira/browse/FLINK-6921
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-6913.
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.1
1.4.0:
https://github.com/ap
[
https://issues.apache.org/jira/browse/FLINK-6913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049248#comment-16049248
]
Till Rohrmann commented on FLINK-6913:
--
[~tzulitai] already fixed the test case. Will
[
https://issues.apache.org/jira/browse/FLINK-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-6914.
Resolution: Fixed
Fix Version/s: 1.3.1
1.4.0:
https://github.com/apache/flink/commit/3bad77c
[
https://issues.apache.org/jira/browse/FLINK-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049245#comment-16049245
]
Till Rohrmann commented on FLINK-6914:
--
Thanks for fixing the issue [~tzulitai].
> T
[
https://issues.apache.org/jira/browse/FLINK-6915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-6915.
Resolution: Fixed
1.4.0:
https://github.com/apache/flink/commit/3bad77c0ae932a926260b769efb151a89fc
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049218#comment-16049218
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4111
Thanks for your changes. @fhueske
---
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
en
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049207#comment-16049207
]
Chesnay Schepler commented on FLINK-6918:
-
oh, I just got it as well locally. Time
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049202#comment-16049202
]
Greg Hogan edited comment on FLINK-6918 at 6/14/17 1:58 PM:
Ye
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4121#discussion_r121953747
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -1905,6 +2147,275 @@ public boolean filter(Event value) thro
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049202#comment-16049202
]
Greg Hogan edited comment on FLINK-6918 at 6/14/17 1:57 PM:
Ye
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049205#comment-16049205
]
ASF GitHub Bot commented on FLINK-6904:
---
Github user dianfu commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049206#comment-16049206
]
ASF GitHub Bot commented on FLINK-6904:
---
Github user dianfu commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049203#comment-16049203
]
ASF GitHub Bot commented on FLINK-6904:
---
Github user dianfu commented on a diff in t
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4121#discussion_r121953691
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -1905,6 +2147,275 @@ public boolean filter(Event value) thro
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049202#comment-16049202
]
Greg Hogan commented on FLINK-6918:
---
Yes, also 1.3. I'm wondering if we aren't cleaning
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4121#discussion_r121953266
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -1905,6 +2147,275 @@ public boolean filter(Event value) thro
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049197#comment-16049197
]
ASF GitHub Bot commented on FLINK-6904:
---
Github user dianfu commented on a diff in t
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4121#discussion_r121952296
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -1391,6 +1391,248 @@ public boolean filter(Event value) thro
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049194#comment-16049194
]
Chesnay Schepler commented on FLINK-6918:
-
This test is run twice, once for 1.2 an
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049166#comment-16049166
]
Greg Hogan edited comment on FLINK-6918 at 6/14/17 1:32 PM:
@z
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049178#comment-16049178
]
Dian Fu commented on FLINK-4641:
Hi [~chermenin], are you still working on this JIRA? It s
[
https://issues.apache.org/jira/browse/FLINK-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049174#comment-16049174
]
Greg Hogan commented on FLINK-6738:
---
This is also a reliable failure for me when testing
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4124
[FLINK-6920] Remove minor guava usages
This PR removes undeclared usages of guava in the following modules
```
flink-connector-elasticsearch
flink-connector-filesystem
flink-gelly-exam
[
https://issues.apache.org/jira/browse/FLINK-6920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049173#comment-16049173
]
ASF GitHub Bot commented on FLINK-6920:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049170#comment-16049170
]
Aljoscha Krettek commented on FLINK-6913:
-
[~till.rohrmann] The link to the logs i
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049169#comment-16049169
]
ASF GitHub Bot commented on FLINK-6904:
---
Github user dawidwys commented on a diff in
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4121#discussion_r121943356
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -1905,6 +2147,275 @@ public boolean filter(Event value) th
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049168#comment-16049168
]
ASF GitHub Bot commented on FLINK-6904:
---
Github user dawidwys commented on a diff in
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4121#discussion_r121943417
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -1905,6 +2147,275 @@ public boolean filter(Event value) th
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049166#comment-16049166
]
Greg Hogan commented on FLINK-6918:
---
@zentol no, not a consistent error.
> Failing test
[
https://issues.apache.org/jira/browse/FLINK-6907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049164#comment-16049164
]
Aljoscha Krettek commented on FLINK-6907:
-
Maybe this was originated from some mer
Chesnay Schepler created FLINK-6920:
---
Summary: Remove minor guava usages in several modules
Key: FLINK-6920
URL: https://issues.apache.org/jira/browse/FLINK-6920
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049161#comment-16049161
]
ASF GitHub Bot commented on FLINK-6904:
---
Github user dawidwys commented on a diff in
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4121#discussion_r121942275
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -1905,6 +2147,275 @@ public boolean filter(Event value) th
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049151#comment-16049151
]
ASF GitHub Bot commented on FLINK-6904:
---
Github user dawidwys commented on a diff in
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4121#discussion_r121939394
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -1391,6 +1391,248 @@ public boolean filter(Event value) th
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049146#comment-16049146
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049148#comment-16049148
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049147#comment-16049147
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r121938446
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupWindowAggregationsITCase.scala
---
@@ -179,6 +180,36
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r121938625
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/utils/StreamTestData.scala
---
@@ -80,4 +83,28 @@ object Stream
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r121937961
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/utils/Pojos.java
---
@@ -0,0 +1,61 @@
+package org.apache.fli
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5541:
--
Description:
{code}
if (localJar == null) {
try {
for (final URL url : ((ContextEnvironm
[
https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16041664#comment-16041664
]
Ted Yu edited comment on FLINK-5488 at 6/14/17 1:00 PM:
Please als
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 6/14/17 12:59 PM:
-
Lock on
[
https://issues.apache.org/jira/browse/FLINK-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16035273#comment-16035273
]
Ted Yu edited comment on FLINK-6738 at 6/14/17 12:59 PM:
-
This fai
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049139#comment-16049139
]
Chesnay Schepler commented on FLINK-6918:
-
Does this happen all the time?
The che
Greg Hogan created FLINK-6918:
-
Summary: Failing tests: ChainLengthDecreaseTest and
ChainLengthIncreaseTest
Key: FLINK-6918
URL: https://issues.apache.org/jira/browse/FLINK-6918
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049098#comment-16049098
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user asdf2014 commented on the issue
Github user asdf2014 commented on the issue:
https://github.com/apache/flink/pull/2487
@rmetzger Alright. Thank you for your asking, but i think our company still
plan to use `Flink-CEP` and contributing `Bahir-Siddhi` feature is a huge job,
so... I'm so sorry.
---
If your project i
Tzu-Li (Gordon) Tai created FLINK-6917:
--
Summary: Introduce test base for end-to-end testing serializer
config snapshotting, restoring, and compatibility check roundtrips
Key: FLINK-6917
URL: https://issues.
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049065#comment-16049065
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user hustfxj commented on the issue:
Github user hustfxj commented on the issue:
https://github.com/apache/flink/pull/4111
Looks good to me.
+1 to merged.
---
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
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049046#comment-16049046
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user hustfxj commented on the issue:
Github user hustfxj commented on the issue:
https://github.com/apache/flink/pull/4111
@sunjincheng121 I get it. Thank you very much!
---
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 feat
1 - 100 of 198 matches
Mail list logo
