Sihua Zhou created FLINK-6980:
-
Summary: TypeExtractor.getForObject can't get typeinfo correctly.
Key: FLINK-6980
URL: https://issues.apache.org/jira/browse/FLINK-6980
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058798#comment-16058798
]
ASF GitHub Bot commented on FLINK-5488:
---
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/4022#discussion_r123425557
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientV2.java ---
@@ -146,7 +146,9 @@ public ApplicationStatus getApplicationStatus() {
[
https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058795#comment-16058795
]
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_r123424835
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java
---
@@ -370,11 +370,11 @@ public static String generateZookeeperPath
[
https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058726#comment-16058726
]
zjuwangg commented on FLINK-6924:
-
This subtask can be assigned to me if possible, :)
> A
[
https://issues.apache.org/jira/browse/FLINK-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058708#comment-16058708
]
Erik van Oosten commented on FLINK-1390:
See
https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058706#comment-16058706
]
Erik van Oosten commented on FLINK-5633:
In case you need throughput (like we do),
[
https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6810:
---
Labels: (was: starter)
> 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 updated FLINK-6810:
---
Description:
In this JIRA, will create some sub-task for add specific scalar function, such
as mathem
[
https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6810:
---
Description:
In this JIRA, will create some sub-task for add specific scalar function, such
as mathem
[
https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6810:
---
Description:
In this JIRA, will create some sub-task for add specific scalar function, such
as mathem
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058694#comment-16058694
]
Jark Wu commented on FLINK-6966:
The key problem is how to generate a deterministic UID fo
[
https://issues.apache.org/jira/browse/FLINK-6887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-6887:
--
Assignee: Jark Wu
> Split up CodeGenerator into several specific CodeGenerator
> --
[
https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6810:
---
Description:
In this JIRA, will create some sub-task for add specific scalar function, such
as mathem
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058676#comment-16058676
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4153
@dawidwys @kl0u It will be great if you could take a look at this PR.
---
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 do
sunjincheng created FLINK-6979:
--
Summary: Add documentation for Aggregation Functions
Key: FLINK-6979
URL: https://issues.apache.org/jira/browse/FLINK-6979
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-6978:
--
Summary: Add documentation for Register User-Defined Functions.
Key: FLINK-6978
URL: https://issues.apache.org/jira/browse/FLINK-6978
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-6810:
---
Labels: starter (was: )
> Add Some built-in Scalar Function supported
> -
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058660#comment-16058660
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/4145
@dianfu I agree with you. I think we can improve that in another JIRA.
@dawidwys I have addressed all the comments.
@kl0u It'll be great if you can have a look.
Cheers,
Jark
---
[
https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-6857:
---
Assignee: mingleizhang
> Add global default Kryo serializer configuration to StreamExecutionE
[
https://issues.apache.org/jira/browse/FLINK-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6976:
---
Labels: starter (was: )
> Add STR_TO_DATE supported in TableAPI
> ---
[
https://issues.apache.org/jira/browse/FLINK-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6977:
---
Description: See FLINK-6926 for detail. (was: See FLINK-6895 for detail.)
> Add MD5/SHA1/SHA2 support
[
https://issues.apache.org/jira/browse/FLINK-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6977:
---
Labels: starter (was: )
> Add MD5/SHA1/SHA2 supported in TableAPI
> -
[
https://issues.apache.org/jira/browse/FLINK-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6975:
---
Labels: starter (was: )
> Add CONCAT/CONCAT_WS supported in TableAPI
> --
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6846:
---
Description: See FLINK-6811 for detail. (was: See FLINK-6811)
> Add TIMESTAMPADD supported in TableAP
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6960:
---
Summary: Add E() supported in SQL (was: Add
E(2.7182818284590452354),PI(3.14159265358979323846) suppo
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6960:
---
Description:
E=Math.E
was:
E=Math.E
PI=Math.PI
> Add E() supported in SQL
> --
[
https://issues.apache.org/jira/browse/FLINK-6942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6942:
---
Description: See FLINK-6960 for detail. (was: Add a document for the
FLINK-6810 related scalar functi
[
https://issues.apache.org/jira/browse/FLINK-6942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6942:
---
Summary: Add E() supported in TableAPI (was: Add a document for the
FLINK-6810 related scalar functio
sunjincheng created FLINK-6977:
--
Summary: Add MD5/SHA1/SHA2 supported in TableAPI
Key: FLINK-6977
URL: https://issues.apache.org/jira/browse/FLINK-6977
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6975:
--
Summary: Add CONCAT/CONCAT_WS supported in TableAPI
Key: FLINK-6975
URL: https://issues.apache.org/jira/browse/FLINK-6975
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6976:
--
Summary: Add STR_TO_DATE supported in TableAPI
Key: FLINK-6976
URL: https://issues.apache.org/jira/browse/FLINK-6976
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-6974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6974:
---
Labels: starter (was: )
> Add BIN supported in TableAPI
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-6973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6973:
---
Labels: starter (was: )
> Add L/RPAD supported in TableAPI
>
>
>
sunjincheng created FLINK-6974:
--
Summary: Add BIN supported in TableAPI
Key: FLINK-6974
URL: https://issues.apache.org/jira/browse/FLINK-6974
Project: Flink
Issue Type: Sub-task
Compon
sunjincheng created FLINK-6973:
--
Summary: Add L/RPAD supported in TableAPI
Key: FLINK-6973
URL: https://issues.apache.org/jira/browse/FLINK-6973
Project: Flink
Issue Type: Sub-task
Com
Praveen Kanamarlapudi created FLINK-6972:
Summary: Flink REPL api
Key: FLINK-6972
URL: https://issues.apache.org/jira/browse/FLINK-6972
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6924:
---
Labels: starter (was: )
> ADD LOG(X) supported in TableAPI
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6924:
---
Summary: ADD LOG(X) supported in TableAPI (was: ADD LOG supported in
TableAPI)
> ADD LOG(X) supporte
[
https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6924:
---
Summary: ADD LOG supported in TableAPI (was: ADD LOG/LPAD/RPAD/BIN
supported in TableAPI)
> ADD LOG
[
https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6924:
---
Description: See FLINK-6891 for detail. (was: See FLINK-6891/ FLINK-6892/
FLINK-6893 for detail.)
>
[
https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6810:
---
Description:
In this JIRA, will create some sub-task for add specific scalar function, such
as mathem
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4161
Hot fix a description of over Table API document.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If y
Bin Fan created FLINK-6971:
--
Summary: Add Alluxio Filesystem in Flink Ecosystem page
Key: FLINK-6971
URL: https://issues.apache.org/jira/browse/FLINK-6971
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bin Fan updated FLINK-6971:
---
Description:
Flink Ecosystem page (http://flink.apache.org/ecosystem.html) lists a set of
third-party project
[
https://issues.apache.org/jira/browse/FLINK-6379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058431#comment-16058431
]
ASF GitHub Bot commented on FLINK-6379:
---
Github user EronWright commented on the iss
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/3942
@tillrohrmann thoughts on this? I'm open to anything.
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6966:
--
Assignee: sunjincheng
> Add maxParallelism and UIDs to all operators generated by the Table API
[
https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058284#comment-16058284
]
Fabian Hueske commented on FLINK-6962:
--
Can you add some pseudo code for the DDL to s
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6649:
-
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-6961
> Improve Non-window group agg
Fabian Hueske created FLINK-6970:
Summary: Add support for late data updates to group window
aggregates
Key: FLINK-6970
URL: https://issues.apache.org/jira/browse/FLINK-6970
Project: Flink
I
Fabian Hueske created FLINK-6969:
Summary: Add support for deferred computation for group window
aggregates
Key: FLINK-6969
URL: https://issues.apache.org/jira/browse/FLINK-6969
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian reassigned FLINK-992:
-
Assignee: Neelesh Srinivas Salian (was: niraj rai)
> Create CollectionDat
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058224#comment-16058224
]
niraj rai commented on FLINK-992:
-
Please go ahead
On Jun 21, 2017 2:00 PM, "Neelesh Srini
[
https://issues.apache.org/jira/browse/FLINK-5595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058223#comment-16058223
]
Neelesh Srinivas Salian commented on FLINK-5595:
[~wints], if you are not
[
https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian reassigned FLINK-1890:
--
Assignee: Neelesh Srinivas Salian
> Add note to docs that ReadFields an
[
https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058219#comment-16058219
]
Neelesh Srinivas Salian commented on FLINK-1890:
[~fhueske], i can pick it
Fabian Hueske created FLINK-6968:
Summary: Store streaming, updating tables with unique key in
queryable state
Key: FLINK-6968
URL: https://issues.apache.org/jira/browse/FLINK-6968
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058218#comment-16058218
]
Neelesh Srinivas Salian commented on FLINK-992:
---
[~nrai], if you are not work
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058204#comment-16058204
]
Fabian Hueske commented on FLINK-6966:
--
Actually, this is not directly related to {{t
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6966:
-
Summary: Add maxParallelism and UIDs to all operators generated by the
Table API / SQL (was: Add
[
https://issues.apache.org/jira/browse/FLINK-6633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058158#comment-16058158
]
Cliff Resnick commented on FLINK-6633:
--
Thanks [~srichter], I'll give this a try tomo
[
https://issues.apache.org/jira/browse/FLINK-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058147#comment-16058147
]
ASF GitHub Bot commented on FLINK-6617:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3943
I think that is a very good idea. A review of a +6k -4k LOC PR takes a lot
of time and has a good chance to be interrupted by other issues. Several
smaller PRs would be much easier to review and merg
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058138#comment-16058138
]
ASF GitHub Bot commented on FLINK-6960:
---
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/4152#discussion_r12335
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/scalarSqlFunctions/MathSqlFunctions.scala
---
@@ -0,0 +1,35 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058056#comment-16058056
]
ASF GitHub Bot commented on FLINK-6965:
---
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/4160#discussion_r123341447
--- Diff: flink-core/pom.xml ---
@@ -79,13 +79,12 @@ under the License.
org.apache.avro
avro
[
https://issues.apache.org/jira/browse/FLINK-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058032#comment-16058032
]
ASF GitHub Bot commented on FLINK-6923:
---
Github user zhenzhongxu commented on the is
Github user zhenzhongxu commented on the issue:
https://github.com/apache/flink/pull/4149
Hi @tzulitai. Yes, we do have a use case where we need to disable Flink
checkpointing because the time interval checkpointing model does not work with
our constraints. We had to trigger Kafka com
[
https://issues.apache.org/jira/browse/FLINK-6633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057939#comment-16057939
]
Stefan Richter commented on FLINK-6633:
---
[~cre...@gmail.com] I think I have a fix fo
[
https://issues.apache.org/jira/browse/FLINK-6967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057894#comment-16057894
]
ASF GitHub Bot commented on FLINK-6967:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4159
+1
---
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 featur
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4136#discussion_r123306543
--- Diff: docs/ops/state_backends.md ---
@@ -124,7 +124,7 @@ RocksDBStateBackend is currently the only backend that
offers incremental checkp
## Confi
[
https://issues.apache.org/jira/browse/FLINK-6940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057845#comment-16057845
]
ASF GitHub Bot commented on FLINK-6940:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057789#comment-16057789
]
ASF GitHub Bot commented on FLINK-6965:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4160#discussion_r123298637
--- Diff: flink-core/pom.xml ---
@@ -79,13 +79,12 @@ under the License.
org.apache.avro
avro
[
https://issues.apache.org/jira/browse/FLINK-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057698#comment-16057698
]
ASF GitHub Bot commented on FLINK-6617:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3943
May be I need split this PR into a couple of small PRs. What do you think?
or have any other suggestions @fhueske @wuchong @twalthr
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057656#comment-16057656
]
sunjincheng edited comment on FLINK-6966 at 6/21/17 3:19 PM:
-
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4160
{FLINK-6965] Include snappy-java in flink-dist
This PR adds removes the snappy dependency exclusion from flink-core.
Without this dependency Flink components that work with avro, and thus
po
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4159
[FLINK-6967] Remove batch-examples dependency from storm examples
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zentol/flink 6967
Alternativel
[
https://issues.apache.org/jira/browse/FLINK-6967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057660#comment-16057660
]
ASF GitHub Bot commented on FLINK-6967:
---
GitHub user zentol opened a pull request:
Chesnay Schepler created FLINK-6967:
---
Summary: Fully separate batch and storm examples
Key: FLINK-6967
URL: https://issues.apache.org/jira/browse/FLINK-6967
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057665#comment-16057665
]
ASF GitHub Bot commented on FLINK-6965:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057640#comment-16057640
]
ASF GitHub Bot commented on FLINK-6426:
---
Github user sunjincheng121 closed the pull
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057656#comment-16057656
]
sunjincheng commented on FLINK-6966:
Hi, [~fhueske] do you meant that we need call {{u
[
https://issues.apache.org/jira/browse/FLINK-6967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057655#comment-16057655
]
Chesnay Schepler commented on FLINK-6967:
-
As a bonus this will also resolve FLINK
Github user sunjincheng121 closed the pull request at:
https://github.com/apache/flink/pull/3806
---
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
[
https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057634#comment-16057634
]
ASF GitHub Bot commented on FLINK-6498:
---
Github user zentol commented on a diff in t
Github user sunjincheng121 closed the pull request at:
https://github.com/apache/flink/pull/4061
---
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
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4123#discussion_r123271284
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java
---
@@ -370,11 +370,11 @@ public static String generateZookeeperPath(
[
https://issues.apache.org/jira/browse/FLINK-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057638#comment-16057638
]
sunjincheng commented on FLINK-6426:
Yes, when you restructuring the Table API docs, I
[
https://issues.apache.org/jira/browse/FLINK-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057635#comment-16057635
]
ASF GitHub Bot commented on FLINK-6841:
---
Github user sunjincheng121 closed the pull
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4061
Thanks @fhueske, I noticed your description on the JIRA. issue. I think
it's make sense to me. Because at the current time between
`StreamTableSourceTable` and `(Batch)TableSourceTable` reall
Fabian Hueske created FLINK-6966:
Summary: Add maxParallelism and UIDs to all operators generated by
the Table API
Key: FLINK-6966
URL: https://issues.apache.org/jira/browse/FLINK-6966
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-6841.
--
Resolution: Won't Fix
> using TableSourceTable for both Stream and Batch OR remove useless import
>
1 - 100 of 269 matches
Mail list logo
