[
https://issues.apache.org/jira/browse/FLINK-6672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028074#comment-16028074
]
sunjincheng commented on FLINK-6672:
Hi, [~twalthr] [~wheat9] I found a situation in
[
https://issues.apache.org/jira/browse/FLINK-6737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028073#comment-16028073
]
sunjincheng commented on FLINK-6737:
Hi [~fhueske]I think in this JIRA. only improve `
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028069#comment-16028069
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2332
I can take this up and come up with a design doc. Reading thro the comments
here and the final decision points I think only puts/deletes can be considered
idempotent. But increments/decrements can
[
https://issues.apache.org/jira/browse/FLINK-6389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6389:
--
Description:
hbase 1.3.1 has been released.
It fixes compatibility issue in 1.3.0 release, among other bug fixe
[
https://issues.apache.org/jira/browse/FLINK-6433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027957#comment-16027957
]
Ted Yu commented on FLINK-6433:
---
http://search-hadoop.com/m/Calcite/FR3K9Rk8b2wH4lO1?subj=Re
[
https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6422:
--
Description:
Here is related code:
{code}
if (minNumSplits < 1) {
throw new IllegalArgumentException("
[
https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027955#comment-16027955
]
ASF GitHub Bot commented on FLINK-6695:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027954#comment-16027954
]
ASF GitHub Bot commented on FLINK-6695:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027956#comment-16027956
]
ASF GitHub Bot commented on FLINK-6695:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4004#discussion_r118850077
--- Diff:
flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/split/SplitBoltTopology.java
---
@@ -28,7 +28,7 @@
import org.apach
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4004#discussion_r118850085
--- Diff:
flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/FiniteRandomSpout.java
---
@@ -32,8 +32,8 @@
import
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4004#discussion_r118850095
--- Diff:
flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/split/operators/VerifyAndEnrichBolt.java
---
@@ -30,7 +30,7 @@
[
https://issues.apache.org/jira/browse/FLINK-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027950#comment-16027950
]
ASF GitHub Bot commented on FLINK-6699:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4005
+1 failing test is unrelated. Thanks for correcting this @zentol!
---
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 doe
Chesnay Schepler created FLINK-6753:
---
Summary: Flaky SqlITCase
Key: FLINK-6753
URL: https://issues.apache.org/jira/browse/FLINK-6753
Project: Flink
Issue Type: Bug
Components: Tab
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4004
@greghogan fixed.
---
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 and wishes so, or i
[
https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027897#comment-16027897
]
ASF GitHub Bot commented on FLINK-6695:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027895#comment-16027895
]
ASF GitHub Bot commented on FLINK-6699:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4005
[FLINK-6699] Add checkstyle plugin to flink-yarn-tests pom
Adds the checkstyle plugin to the `flink-yarn-tests` pom and fixes
remaining issues.
You can merge this pull request into a Git repository
[
https://issues.apache.org/jira/browse/FLINK-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-6699:
-
[~greghogan] You are correct, reopening the issue.
> Activate strict-checkstyle in flink-yarn
[
https://issues.apache.org/jira/browse/FLINK-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027882#comment-16027882
]
Greg Hogan commented on FLINK-6699:
---
[~Zentol] it looks like we forgot to activate the c
[
https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027878#comment-16027878
]
ASF GitHub Bot commented on FLINK-6695:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027879#comment-16027879
]
ASF GitHub Bot commented on FLINK-6695:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027880#comment-16027880
]
ASF GitHub Bot commented on FLINK-6695:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4004#discussion_r118845656
--- Diff:
flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/VerifyMetaDataBolt.java
---
@@ -28,6 +27,11 @@
impo
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4004#discussion_r118845592
--- Diff:
flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/split/operators/VerifyAndEnrichBolt.java
---
@@ -27,6 +26,12 @@
imp
[
https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027877#comment-16027877
]
ASF GitHub Bot commented on FLINK-6695:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4004#discussion_r118845646
--- Diff:
flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/FiniteRandomSpout.java
---
@@ -30,6 +28,13 @@
impor
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4004#discussion_r118845633
--- Diff:
flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/split/SplitBoltTopology.java
---
@@ -15,23 +15,28 @@
* See the Lic
[
https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027842#comment-16027842
]
Shaoxuan Wang commented on FLINK-5354:
--
[~fhueske], thanks for kicking off this. I wo
[
https://issues.apache.org/jira/browse/FLINK-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang reassigned FLINK-6751:
Assignee: Shaoxuan Wang
> Table API / SQL Docs: UDFs Page
> ---
[
https://issues.apache.org/jira/browse/FLINK-6752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6752:
Description:
Long term issue for incrementally introducing the strict checkstyle to
flink-c
Chesnay Schepler created FLINK-6752:
---
Summary: Activate strict checkstyle for flink-core
Key: FLINK-6752
URL: https://issues.apache.org/jira/browse/FLINK-6752
Project: Flink
Issue Type: Sub
[
https://issues.apache.org/jira/browse/FLINK-6752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-6752:
---
Assignee: (was: Chesnay Schepler)
> Activate strict checkstyle for flink-core
> -
[
https://issues.apache.org/jira/browse/FLINK-6743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6743.
---
Resolution: Duplicate
Please see FLINK-6214 for a workaround.
> .window(TumblingEventTimeWind
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027819#comment-16027819
]
ASF GitHub Bot commented on FLINK-6075:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4003
Thanks for the update @rtudoran.
I'm traveling for another week before I return in the office. I hope I'll
find time to have a look at #3889 in the next days. I think we should try to
get that i
Fabian Hueske created FLINK-6751:
Summary: Table API / SQL Docs: UDFs Page
Key: FLINK-6751
URL: https://issues.apache.org/jira/browse/FLINK-6751
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-6750:
Summary: Table API / SQL Docs: Table Sources & Sinks Page
Key: FLINK-6750
URL: https://issues.apache.org/jira/browse/FLINK-6750
Project: Flink
Issue Type: Su
Fabian Hueske created FLINK-6748:
Summary: Table API / SQL Docs: Table API Page
Key: FLINK-6748
URL: https://issues.apache.org/jira/browse/FLINK-6748
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-6747:
Summary: Table API / SQL Docs: Streaming Page
Key: FLINK-6747
URL: https://issues.apache.org/jira/browse/FLINK-6747
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-6749:
Summary: Table API / SQL Docs: SQL Page
Key: FLINK-6749
URL: https://issues.apache.org/jira/browse/FLINK-6749
Project: Flink
Issue Type: Sub-task
C
Fabian Hueske created FLINK-6745:
Summary: Table API / SQL Docs: Overview Page
Key: FLINK-6745
URL: https://issues.apache.org/jira/browse/FLINK-6745
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-6746:
Summary: Table API / SQL Docs: Common Page
Key: FLINK-6746
URL: https://issues.apache.org/jira/browse/FLINK-6746
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027815#comment-16027815
]
Fabian Hueske commented on FLINK-5354:
--
I created a proposal for a new structure base
[
https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027813#comment-16027813
]
ASF GitHub Bot commented on FLINK-6695:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4004
[FLINK-6695 Activate strict checkstyle in flink-contrib
This PR activates the strict checkstyle for most modules in flink-contrib;
`flink-tweet-inputformat` is not included due to proposal to remove
[
https://issues.apache.org/jira/browse/FLINK-6737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027811#comment-16027811
]
Fabian Hueske commented on FLINK-6737:
--
I'm not sure if this should be supported. Eit
[
https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027810#comment-16027810
]
Fabian Hueske commented on FLINK-6736:
--
Yes, this looks like a bug that needs to be f
[
https://issues.apache.org/jira/browse/FLINK-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027808#comment-16027808
]
ASF GitHub Bot commented on FLINK-6725:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3993
Hi @shaoxuan-wang and @sunjincheng121,
Ad 2) I think it is OK to have this as a method with a default
implementation. If we choose the contract function design, we have the same
default beha
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027801#comment-16027801
]
ASF GitHub Bot commented on FLINK-6075:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/4003
@shijinkui @hongyuhong @stefanobortoli
I add you to the issue to track the progress
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/4003
@fhueske
I have implemented meanwhile also the support for offset and fetch for both
rowtime and proctime. This PR includes all the modifications and reviews you
made for #3889.
You can eit
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027800#comment-16027800
]
ASF GitHub Bot commented on FLINK-6075:
---
Github user rtudoran commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-6743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lix updated FLINK-6743:
---
Description:
The tutorial on the official website says that we can use
{quote}
// daily tumbling event-time windows o
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027799#comment-16027799
]
ASF GitHub Bot commented on FLINK-6075:
---
GitHub user rtudoran opened a pull request:
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/4003
[FLINK-6075] - Support Limit/Top(Sort) for Stream SQL
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If you
Chesnay Schepler created FLINK-6744:
---
Summary: Flaky ExecutionGraphSchedulingTest
Key: FLINK-6744
URL: https://issues.apache.org/jira/browse/FLINK-6744
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lix updated FLINK-6743:
---
Affects Version/s: 1.2.0
Environment: Flink 1.2.0. (was: Flink 1.2.0 and above.)
> .window(TumblingEventTim
Lix created FLINK-6743:
--
Summary: .window(TumblingEventTimeWindows.of(Time.days(1),
Time.hours(-8))) doesn't work
Key: FLINK-6743
URL: https://issues.apache.org/jira/browse/FLINK-6743
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-6137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6137.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.4: c9e574bf3206c16bd7e1be8a5672073d8846d7d7
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3976
---
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 and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-6137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027749#comment-16027749
]
ASF GitHub Bot commented on FLINK-6137:
---
Github user asfgit closed the pull request
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4002
[6730] Apply non-invasive checkstyle rules to flink-optimizer
This PR applys3 non-invasive checkstyle rules to flink-optimizer. It
reorders imports, adds an empty line before the package declaration
[
https://issues.apache.org/jira/browse/FLINK-6740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-6740.
--
Resolution: Duplicate
> Fix "parameterTypeEquals" method error.
> --
[
https://issues.apache.org/jira/browse/FLINK-6740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027732#comment-16027732
]
sunjincheng commented on FLINK-6740:
I think this JIRA. is not very important for rele
[
https://issues.apache.org/jira/browse/FLINK-6740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6740:
---
Description:
When we define UDTF as follows:
{code}
class TableFuncPojo extends TableFunction[TPojo] {
[
https://issues.apache.org/jira/browse/FLINK-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-6730:
---
Assignee: (was: Chesnay Schepler)
> Activate strict checkstyle for flink-optimize
[
https://issues.apache.org/jira/browse/FLINK-6740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6740:
---
Description:
When we define UDTF as follows:
{code}
class TableFuncPojo extends TableFunction[TPojo] {
[
https://issues.apache.org/jira/browse/FLINK-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-6730:
---
Assignee: Chesnay Schepler
> Activate strict checkstyle for flink-optimizer
> ---
72 matches
Mail list logo
