Renjie Liu created FLINK-8919:
-
Summary: Add KeyedProcessFunctionWIthCleanupState
Key: FLINK-8919
URL: https://issues.apache.org/jira/browse/FLINK-8919
Project: Flink
Issue Type: Improvement
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5613
Merging for now and opening more issue around this topic.
---
Timo Walther created FLINK-8921:
---
Summary: Split code generated call expression
Key: FLINK-8921
URL: https://issues.apache.org/jira/browse/FLINK-8921
Project: Flink
Issue Type: Improvement
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5449
Thank you for your response, @StephanEwen You are very correct. We would
not connect JM / RM / ZK if we use ```getByName("localhost")``` .
I will give an example based I have known
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394996#comment-16394996
]
ASF GitHub Bot commented on FLINK-8623:
---
Github user zhangminglei commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lilizhao updated FLINK-8903:
Comment: was deleted
(was: Hi， [~fhueske] In my appendix example, the sum of the calculations, the
average
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5665#discussion_r173743909
--- Diff:
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/WebFrontendITCase.java
---
@@ -66,40 +73,44 @@
private static final
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394852#comment-16394852
]
ASF GitHub Bot commented on FLINK-8335:
---
Github user zhangminglei commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394856#comment-16394856
]
Piotr Nowojski commented on FLINK-8794:
---
Thanks for the update and good to hear that.
> When using
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395021#comment-16395021
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394873#comment-16394873
]
ASF GitHub Bot commented on FLINK-4641:
---
Github user Aitozi commented on the issue:
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/3105
why it is closed ? Is it has been merged in?
---
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394935#comment-16394935
]
ASF GitHub Bot commented on FLINK-4641:
---
Github user chermenin commented on the issue:
Github user chermenin commented on the issue:
https://github.com/apache/flink/pull/3105
@Aitozi I just didn't have enough time to finish my work on this task and
the Pattern API was changed at the same time. Now it's needed to rewrite the
code to support all updates.
---
Github user neoremind commented on the issue:
https://github.com/apache/flink/pull/5639
@ramkrish86 @fhueske could you help to review this PR? Since I noticed that
you guys contribute most of the code. This update enables HBase snapshot read
and I refactor some of the code and test
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394986#comment-16394986
]
lilizhao commented on FLINK-8903:
-
[~fhueske] But why the calculated variance is the same as that of the
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lilizhao updated FLINK-8903:
Attachment: QQ图片20180312180143.jpg
> Error calculation based on rolling window in table API and SQL API
>
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395009#comment-16395009
]
lilizhao commented on FLINK-8903:
-
[~fhueske]
A new example:
SQL = "SELECT VAR_POP (CCNT), COLLECT
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5679#discussion_r173742094
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java
---
@@ -143,10 +152,66 @@ public int
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5679#discussion_r173741952
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java
---
@@ -143,10 +152,66 @@ public int
Timo Walther created FLINK-8920:
---
Summary: Split code generated input unboxing code
Key: FLINK-8920
URL: https://issues.apache.org/jira/browse/FLINK-8920
Project: Flink
Issue Type: Improvement
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5488
I paste the the 1.3.1 and 1.4.1 ```flink-hbase``` pom dependency tree
respectively below.
I watched the difference between the two dependencies. But I would hope
@StephanEwen can see
[
https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394924#comment-16394924
]
ASF GitHub Bot commented on FLINK-8919:
---
GitHub user liurenjie1024 opened a pull request:
GitHub user liurenjie1024 opened a pull request:
https://github.com/apache/flink/pull/5680
[FLINK-8919] Add KeyedProcessFunctionWithCleanupState.
## What is the purpose of the change
*Add ProcessFunctionWithCleanupState's counterpart for
KeyedProcessFunction.*
##
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394973#comment-16394973
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5174
---
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394974#comment-16394974
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5613
---
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394955#comment-16394955
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lilizhao reopened FLINK-8903:
-
> Error calculation based on rolling window in table API and SQL API
>
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394991#comment-16394991
]
lilizhao commented on FLINK-8903:
-
Hi， [~fhueske] In my appendix example, the sum of the calculations, the
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394999#comment-16394999
]
ASF GitHub Bot commented on FLINK-8623:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5449
I will verify whether retry can hack this issue. Not sure about it.
---
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395008#comment-16395008
]
ASF GitHub Bot commented on FLINK-8623:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5449
By the way, Although I have a Linux computer, I cannot access the Internet.
:) I just use ```ifconfig``` check that.
---
[
https://issues.apache.org/jira/browse/FLINK-8916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395013#comment-16395013
]
ASF GitHub Bot commented on FLINK-8916:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395011#comment-16395011
]
ASF GitHub Bot commented on FLINK-8916:
---
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/5679#discussion_r173742203
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java
---
@@ -143,10 +152,66 @@ public int
[
https://issues.apache.org/jira/browse/FLINK-8916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395012#comment-16395012
]
ASF GitHub Bot commented on FLINK-8916:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-8922.
-
Resolution: Fixed
Release Note: Merged in a389b43581.
> Revert FLINK-8859 because it causes
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395050#comment-16395050
]
Sihua Zhou commented on FLINK-8922:
---
[~srichter] Thanks for let me know, I will have a deeper look into
[
https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-8921:
-
Assignee: Ruidong Li
> Split code generated call expression
>
[
https://issues.apache.org/jira/browse/FLINK-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-4569:
---
Assignee: Chesnay Schepler
> JobRetrievalITCase.testJobRetrieval() does not forward
[
https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-7521:
Labels: flip6 (was: )
> Remove the 10MB limit from the current REST implementation.
>
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5449
We cannot fully guard against incorrect network configurations.
Many systems (even HDFS,, AFAIK) simply use `InetAddress.getLocalHost()`
and rely on correct network configs. Our current
Chesnay Schepler created FLINK-8925:
---
Summary: Activate flip6 on travis
Key: FLINK-8925
URL: https://issues.apache.org/jira/browse/FLINK-8925
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395128#comment-16395128
]
Sihua Zhou commented on FLINK-8922:
---
[~StephanEwen] I am not sure whether the failed tests on trivial is
[
https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8704:
---
Assignee: Chesnay Schepler
> Migrate tests from TestingCluster to
[
https://issues.apache.org/jira/browse/FLINK-8202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-8202:
---
Fix Version/s: (was: 1.4.2)
1.4.3
> Update queryable section
[
https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-8917:
---
Fix Version/s: (was: 1.4.2)
1.4.3
> FlinkMiniCluster default
[
https://issues.apache.org/jira/browse/FLINK-8923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-8923:
---
Component/s: Startup Shell Scripts
> Set an uncaught exception handler for ForkJoinPool
>
[
https://issues.apache.org/jira/browse/FLINK-8916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395082#comment-16395082
]
ASF GitHub Bot commented on FLINK-8916:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5679
@zentol thank you for suggestion, please review again.
---
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395099#comment-16395099
]
Stephan Ewen commented on FLINK-8922:
-
[~srichter] [~sihuazhou] It is still desirable to deactivate
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5521
The approach here does not work (there is also no test, otherwise that
would have been caught).
Flink does not magically load configs like Hadoop, Flink passes configs
explicitly.
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173784883
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala
---
@@ -148,6 +148,13 @@ object SchemaValidator
[
https://issues.apache.org/jira/browse/FLINK-8904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395028#comment-16395028
]
ASF GitHub Bot commented on FLINK-8904:
---
Github user NicoK commented on a diff in the pull request:
Nico Kruber created FLINK-8923:
--
Summary: Set an uncaught exception handler for ForkJoinPool
Key: FLINK-8923
URL: https://issues.apache.org/jira/browse/FLINK-8923
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-7521:
Affects Version/s: 1.6.0
1.5.0
> Remove the 10MB limit from the current REST
[
https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-7521:
---
Assignee: Gary Yao (was: Fang Yong)
> Remove the 10MB limit from the current REST implementation.
>
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395097#comment-16395097
]
ASF GitHub Bot commented on FLINK-8623:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395106#comment-16395106
]
Stephan Ewen commented on FLINK-8895:
-
I think you don't need to add filtering code or anything, all
Chesnay Schepler created FLINK-8924:
---
Summary: Add @Old junit category
Key: FLINK-8924
URL: https://issues.apache.org/jira/browse/FLINK-8924
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395161#comment-16395161
]
Stephan Ewen commented on FLINK-8922:
-
I think [~srichter] tried that out, still segfaulted. Maybe you
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395164#comment-16395164
]
Stephan Ewen commented on FLINK-8922:
-
Would also be nice to know how much the WAL actually costs on
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173786510
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala
---
@@ -148,6 +148,13 @@ object
[
https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395195#comment-16395195
]
ASF GitHub Bot commented on FLINK-8854:
---
Github user twalthr commented on a diff in the pull
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5670#discussion_r173746711
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendTestUtils.java
---
@@ -65,9 +67,14 @@ public static String getInvalidConfigDir()
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395038#comment-16395038
]
yinhua.dai commented on FLINK-6075:
---
[~fhueske]
Sorry to ask it here, but may I ask why streaming SQL
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-8922:
-
Assignee: Stefan Richter
> Revert FLINK-8859 because it causes segfaults in testing
>
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395054#comment-16395054
]
Stefan Richter commented on FLINK-8922:
---
Ok that sounds good. I also had a look and it looks strange
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395125#comment-16395125
]
mingleizhang commented on FLINK-8907:
-
Hmm, I just use git client (https://git-scm.com/downloads) to
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395208#comment-16395208
]
ASF GitHub Bot commented on FLINK-8623:
---
Github user zhangminglei commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395214#comment-16395214
]
Sihua Zhou commented on FLINK-8922:
---
Agreed with [~srichter], and the statistics I posted above is only
[
https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395220#comment-16395220
]
ASF GitHub Bot commented on FLINK-8854:
---
Github user xccui commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173791129
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala
---
@@ -148,6 +148,13 @@ object SchemaValidator
[
https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395187#comment-16395187
]
ASF GitHub Bot commented on FLINK-8854:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395205#comment-16395205
]
Stefan Richter commented on FLINK-8922:
---
Yes, I tried out to create a dedicated \{{WriteOptions}}
[
https://issues.apache.org/jira/browse/FLINK-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395024#comment-16395024
]
ASF GitHub Bot commented on FLINK-8862:
---
Github user neoremind commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter resolved FLINK-8882.
---
Resolution: Fixed
> flink-tests fails with core dump
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8274.
-
Resolution: Fixed
Fix Version/s: 1.6.0
1.5.0
Fixed in 1.6.0:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5449
Thanks @StephanEwen indeed - I also did not grasp the full intend of the
change.
Looking at the code again, basically
`ConnectionUtils#findConnectingAddress()` tries to connect with a set of
[
https://issues.apache.org/jira/browse/FLINK-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395079#comment-16395079
]
ASF GitHub Bot commented on FLINK-4569:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5681
[FLINK-4569][tests] Fix JobRetrievalITCase
## What is the purpose of the change
This PR contains 2 changes to the `JobRetrievalITCase`.
1) We now store exceptions that occur in the
[
https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8795:
Summary: Scala shell broken for FLip6 (was: Failed to submit JobGraph
Apache Flink on
[
https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8795:
Summary: Scala shell broken for Flip6 (was: Scala shell broken for FLip6)
> Scala shell
[
https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395084#comment-16395084
]
Chesnay Schepler commented on FLINK-8795:
-
The given port is where the client expected the
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395102#comment-16395102
]
Stephan Ewen commented on FLINK-8907:
-
Did you run this on cygwin before?
> Unable to start the
[
https://issues.apache.org/jira/browse/FLINK-8925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8925:
Priority: Blocker (was: Major)
> Activate flip6 on travis
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395198#comment-16395198
]
Sihua Zhou commented on FLINK-8922:
---
[~StephanEwen] About the costs with (or without) WAL, I did have
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5449
Thanks @StephanEwen and @NicoK for the response and that let me know more
about details about this issue.
As refers to the first that return something we can bind to. Yes, As long
as
[
https://issues.apache.org/jira/browse/FLINK-7413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7413:
---
Fix Version/s: (was: 1.3.3)
1.3.4
> Release Hadoop 2.8.x
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reopened FLINK-7398:
> Table API operators/UDFs must not store Logger
>
[
https://issues.apache.org/jira/browse/FLINK-7413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reopened FLINK-7413:
> Release Hadoop 2.8.x convenience binaries for 1.3.x
>
[
https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reopened FLINK-7429:
> Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer
>
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-7368.
--
Resolution: Fixed
Fix Version/s: (was: 1.3.3)
1.3.4
>
[
https://issues.apache.org/jira/browse/FLINK-7396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reopened FLINK-7396:
> Don't put multiple directories in HADOOP_CONF_DIR in config.sh
>
[
https://issues.apache.org/jira/browse/FLINK-7413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-7413.
--
Resolution: Fixed
> Release Hadoop 2.8.x convenience binaries for 1.3.x
>
[
https://issues.apache.org/jira/browse/FLINK-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reopened FLINK-7728:
> StatusWatermarkValve has different min watermark advancement behavior
> depending on
[
https://issues.apache.org/jira/browse/FLINK-7721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-7721.
--
Resolution: Fixed
Fix Version/s: (was: 1.3.3)
1.3.4
>
1 - 100 of 330 matches
Mail list logo
