Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4921
LGTM +1
---
[
https://issues.apache.org/jira/browse/FLINK-7943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253001#comment-16253001
]
ASF GitHub Bot commented on FLINK-7943:
---
Github user bowenli86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252985#comment-16252985
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4893
@tillrohrmann Thank you for your review, I have fixed the problems of this
PR, thanks
---
[
https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252931#comment-16252931
]
ASF GitHub Bot commented on FLINK-8069:
---
GitHub user xccui opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252932#comment-16252932
]
ASF GitHub Bot commented on FLINK-8076:
---
GitHub user bowenli86 opened a pull request:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/5016
[FLINK-8069] [table] Support empty watermark strategy for TableSources
## What is the purpose of the change
This PR enables an empty watermark strategy for
`RowtimeAttributeDescriptor`.
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5017
[FLINK-8076] Upgrade KinesisProducer to 0.10.6 to set properties
approperiately
## What is the purpose of the change
https://github.com/awslabs/amazon-kinesis-producer/issues/124 has
Bowen Li created FLINK-8076:
---
Summary: Upgrade KinesisProducer to 0.10.6 to set properties
approperiately
Key: FLINK-8076
URL: https://issues.apache.org/jira/browse/FLINK-8076
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252876#comment-16252876
]
Shuyi Chen commented on FLINK-7923:
---
Already sent out PR for Calcite-2016 to modify the Calcite parser.
[
https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-7923:
-
Assignee: Shuyi Chen
> SQL parser exception when accessing subfields of a Composite element in
[
https://issues.apache.org/jira/browse/FLINK-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-7934:
-
Assignee: Shuyi Chen
> Upgrade Calcite dependency to 1.15
> --
>
[
https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252867#comment-16252867
]
ASF GitHub Bot commented on FLINK-7962:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4936
@wuchong Thanks a lot for your review.
@fhueske It would be great if you can also give some feedback.
---
[
https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252789#comment-16252789
]
Colin Williams edited comment on FLINK-7490 at 11/15/17 1:44 AM:
-
I'm
[
https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252794#comment-16252794
]
Xingcan Cui commented on FLINK-8069:
Thanks for the explanation [~twalthr]
> Support empty watermark
[
https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252789#comment-16252789
]
Colin Williams commented on FLINK-7490:
---
I'm effected by this also:
java.io.IOException: Exception
[
https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7795:
--
Description:
http://errorprone.info/ is a tool which detects common coding mistakes.
We should incorporate
[
https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7917:
--
Description:
Currently:
{code}
}
return taskInformationOrBlobKey;
{code}
The return should be placed
[
https://issues.apache.org/jira/browse/FLINK-8075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8075:
--
Summary: Lack of synchronization calling clone() in Configuration ctor
(was: Redundant clone() in
Ted Yu created FLINK-8075:
-
Summary: Redundant clone() in Configuration ctor
Key: FLINK-8075
URL: https://issues.apache.org/jira/browse/FLINK-8075
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252190#comment-16252190
]
ASF GitHub Bot commented on FLINK-7475:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4963
@yunfan123 @aljoscha @StefanRRichter I chose the "shallow" simulation.
What do you guys think?
The build failure seems to be because one build profile timed out.
---
[
https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8071.
---
Resolution: Fixed
1.4: 195e3da8a78b80116ef00e65d771daa5a0a1d7a3
1.5:
[
https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7419.
---
Resolution: Fixed
1.4: 5c6eaabfcd541ffb35d911c6d9d2f6f12f207cd8
1.5:
[
https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252082#comment-16252082
]
ASF GitHub Bot commented on FLINK-7419:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252083#comment-16252083
]
ASF GitHub Bot commented on FLINK-8071:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4981
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5014
---
[
https://issues.apache.org/jira/browse/FLINK-8038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251994#comment-16251994
]
ASF GitHub Bot commented on FLINK-8038:
---
GitHub user walterddr opened a pull request:
GitHub user walterddr opened a pull request:
https://github.com/apache/flink/pull/5015
[FLINK-8038][Table API] Support MAP value constructor
## What is the purpose of the change
This pull request makes creates Map value constructor support for Table and
SQL API.
This
Ron Crocker created FLINK-8074:
--
Summary: Launch Flink jobs using Maven coordinates
Key: FLINK-8074
URL: https://issues.apache.org/jira/browse/FLINK-8074
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251816#comment-16251816
]
Aljoscha Krettek commented on FLINK-8072:
-
[~Zentol] There is this snipped in the log:
{code}
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251749#comment-16251749
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251751#comment-16251751
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150890435
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -208,9 +239,15
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150899000
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -419,20 +472,31
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150893389
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/server/KvStateServerImpl.java
---
@@ -106,6
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251750#comment-16251750
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user aljoscha commented on a diff in the pull
Kostas Kloudas created FLINK-8073:
-
Summary: Test instability
FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint()
Key: FLINK-8073
URL: https://issues.apache.org/jira/browse/FLINK-8073
[
https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251707#comment-16251707
]
ASF GitHub Bot commented on FLINK-7419:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4981
I've rebased the PR on top of #5014. Once travis gives a green light I will
merge this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8071:
Description:
On 2 separate occasions on separate machines I hit the exception below when
[
https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-7419:
-
jackson is currently not relocated
> Shade jackson dependency in flink-avro
>
[
https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251697#comment-16251697
]
ASF GitHub Bot commented on FLINK-8071:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5014
Will rebase the PR and merge it once travis is green.
---
[
https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251693#comment-16251693
]
ASF GitHub Bot commented on FLINK-8071:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5014
Some more info that i just stumbled on:
This doesn't actually happen on master, or on release-1.4 for that matter.
For FLINK-7419 we're adding another relocation pass to flink-dist
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251613#comment-16251613
]
ASF GitHub Bot commented on FLINK-7974:
---
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/4993#discussion_r150878782
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@ -260,25
[
https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8071:
Description:
On 2 separate occasions on separate machines I hit the exception below when
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251569#comment-16251569
]
Kostas Kloudas commented on FLINK-8063:
---
I am not sure about this, as also in the 1.3 we had this:
[
https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251564#comment-16251564
]
ASF GitHub Bot commented on FLINK-7973:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5013
This would be difficult to test - the most reasonable test would be to put
the Hadoop JNI into the classpath and then run the end-to-end test on that but
we don't want to include the
[
https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251546#comment-16251546
]
ASF GitHub Bot commented on FLINK-8071:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5014
I don't think we have a choice other than trusting your analysis and
loop-testing. Looks good to merge! ð
---
[
https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251544#comment-16251544
]
ASF GitHub Bot commented on FLINK-7973:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5013
Changes look reasonable to me. I supposed we can't guard this with a test?
---
[
https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251532#comment-16251532
]
ASF GitHub Bot commented on FLINK-8071:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5014
[FLINK-8071][build] Bump shade-plugin asm version to 5.1
## What is the purpose of the change
This PR bumps the ASM dependency of the `maven-shade-plugin` to 5.1 as a
workaround to a bug in
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251521#comment-16251521
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4993
Thanks for the comments @tillrohrmann . I addressed them.
---
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251503#comment-16251503
]
ASF GitHub Bot commented on FLINK-7845:
---
Github user pnowojski commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5007
Thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251497#comment-16251497
]
ASF GitHub Bot commented on FLINK-7974:
---
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/4993#discussion_r150856825
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -483,27 +511,31 @@
[
https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251492#comment-16251492
]
ASF GitHub Bot commented on FLINK-7998:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7998.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.4: 2774335983bf83b68ff061388d0bd69d4346bb07
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4959
---
[
https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-7998:
-
> Make case classes in TPCHQuery3.java public to allow dynamic instantiation
>
[
https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251486#comment-16251486
]
ASF GitHub Bot commented on FLINK-7973:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5013
[FLINK-7973] disable JNI bridge for relocated hadoop classes in s3-fs-*
## What is the purpose of the change
If some Hadoop's JNI library is in the classpath, it will be loaded by our
[
https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251483#comment-16251483
]
ASF GitHub Bot commented on FLINK-7998:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4959
Thank you for fixing this, merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8056.
---
Resolution: Fixed
1.4: 7c7f24ec84dc73b59c8523b4c7af8d89f1a17eb5
1.5:
[
https://issues.apache.org/jira/browse/FLINK-8056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251476#comment-16251476
]
ASF GitHub Bot commented on FLINK-8056:
---
Github user zentol closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251475#comment-16251475
]
Timo Walther commented on FLINK-8069:
-
Given you have a TableSource like this:
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/5010
---
[
https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7652:
Fix Version/s: (was: 1.4.0)
1.5.0
> Port CurrentJobIdsHandler to new
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7608:
Fix Version/s: (was: 1.4.0)
1.5.0
> LatencyGauge change to
[
https://issues.apache.org/jira/browse/FLINK-7727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7727:
Fix Version/s: (was: 1.4.0)
1.5.0
> Extend logging in file server
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7692:
Fix Version/s: (was: 1.4.0)
1.5.0
> Support user-defined variables
[
https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4812:
Fix Version/s: (was: 1.4.0)
1.5.0
> Report Watermark metrics in all
[
https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251458#comment-16251458
]
Xingcan Cui commented on FLINK-8069:
Hi [~twalthr], could you give a little more explanations about
[
https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8006.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.4: fcc79c0ed76818e147381117ea735f5796be6066
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251433#comment-16251433
]
ASF GitHub Bot commented on FLINK-7845:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251435#comment-16251435
]
ASF GitHub Bot commented on FLINK-7811:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251437#comment-16251437
]
ASF GitHub Bot commented on FLINK-8006:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7845.
---
Resolution: Fixed
1.4: 6f9ab7217266f5458263fdd976214c1b4c552576
1.5:
[
https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251434#comment-16251434
]
ASF GitHub Bot commented on FLINK-4500:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251436#comment-16251436
]
ASF GitHub Bot commented on FLINK-8011:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8011.
---
Resolution: Fixed
1.4: 8d8c52f876b79524393d2604b5bedc54c0764ae7
1.5:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5002
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4973
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5007
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5000
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4995
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4968
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4999
---
Chesnay Schepler created FLINK-8072:
---
Summary: Travis job mark as failed for no apparent reason
Key: FLINK-8072
URL: https://issues.apache.org/jira/browse/FLINK-8072
Project: Flink
Issue
1 - 100 of 166 matches
Mail list logo
