[
https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058798#comment-16058798
]
ASF GitHub Bot commented on FLINK-5488:
---
Github user zjureel commented on a diff in the pull
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=16058795#comment-16058795
]
ASF GitHub Bot commented on FLINK-6498:
---
Github user zjureel commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058726#comment-16058726
]
zjuwangg commented on FLINK-6924:
-
This subtask can be assigned to me if possible, :)
> ADD LOG(X)
[
https://issues.apache.org/jira/browse/FLINK-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058708#comment-16058708
]
Erik van Oosten commented on FLINK-1390:
See
[
https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058706#comment-16058706
]
Erik van Oosten commented on FLINK-5633:
In case you need throughput (like we do), the caching is
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058694#comment-16058694
]
Jark Wu commented on FLINK-6966:
The key problem is how to generate a deterministic UID for the same
[
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
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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:
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=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
[
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
[
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
[
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)
[
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
[
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
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
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
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)
[
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-6379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058431#comment-16058431
]
ASF GitHub Bot commented on FLINK-6379:
---
Github user EronWright commented on the issue:
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058284#comment-16058284
]
Fabian Hueske commented on FLINK-6962:
--
Can you add some pseudo code for the DDL to sketch the
[
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058224#comment-16058224
]
niraj rai commented on FLINK-992:
-
Please go ahead
On Jun 21, 2017 2:00 PM, "Neelesh Srinivas Salian
[
https://issues.apache.org/jira/browse/FLINK-5595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058223#comment-16058223
]
Neelesh Srinivas Salian commented on FLINK-5595:
[~wints], if you are not working on this
[
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
[
https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058219#comment-16058219
]
Neelesh Srinivas Salian commented on FLINK-1890:
[~fhueske], i can pick it up.
> Add note
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=16058218#comment-16058218
]
Neelesh Srinivas Salian commented on FLINK-992:
---
[~nrai], if you are not working on this at
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058204#comment-16058204
]
Fabian Hueske commented on FLINK-6966:
--
Actually, this is not directly related to {{table.scala}} but
[
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=16058158#comment-16058158
]
Cliff Resnick commented on FLINK-6633:
--
Thanks [~srichter], I'll give this a try tomorrow morning
[
https://issues.apache.org/jira/browse/FLINK-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058138#comment-16058138
]
ASF GitHub Bot commented on FLINK-6960:
---
Github user fhueske commented on a diff in the pull
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=16058056#comment-16058056
]
ASF GitHub Bot commented on FLINK-6965:
---
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/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=16058032#comment-16058032
]
ASF GitHub Bot commented on FLINK-6923:
---
Github user zhenzhongxu commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-6633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057939#comment-16057939
]
Stefan Richter commented on FLINK-6633:
---
[~cre...@gmail.com] I think I have a fix for your problem
[
https://issues.apache.org/jira/browse/FLINK-6967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057894#comment-16057894
]
ASF GitHub Bot commented on FLINK-6967:
---
Github user greghogan commented on the issue:
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
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
##
[
https://issues.apache.org/jira/browse/FLINK-6940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057845#comment-16057845
]
ASF GitHub Bot commented on FLINK-6940:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057789#comment-16057789
]
ASF GitHub Bot commented on FLINK-6965:
---
Github user tzulitai commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057698#comment-16057698
]
ASF GitHub Bot commented on FLINK-6617:
---
Github user sunjincheng121 commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057656#comment-16057656
]
sunjincheng edited comment on FLINK-6966 at 6/21/17 3:19 PM:
-
Hi, [~fhueske]
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
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
[
https://issues.apache.org/jira/browse/FLINK-6967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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:
[
https://issues.apache.org/jira/browse/FLINK-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16057640#comment-16057640
]
ASF GitHub Bot commented on FLINK-6426:
---
Github user sunjincheng121 closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057656#comment-16057656
]
sunjincheng commented on FLINK-6966:
Hi, [~fhueske] do you meant that we need call {{uid/setUidHash}}
[
https://issues.apache.org/jira/browse/FLINK-6967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057655#comment-16057655
]
Chesnay Schepler commented on FLINK-6967:
-
As a bonus this will also resolve FLINK-6759.
> Fully
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
[
https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057634#comment-16057634
]
ASF GitHub Bot commented on FLINK-6498:
---
Github user zentol commented on a diff in the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057638#comment-16057638
]
sunjincheng commented on FLINK-6426:
Yes, when you restructuring the Table API docs, I closed this
[
https://issues.apache.org/jira/browse/FLINK-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057635#comment-16057635
]
ASF GitHub Bot commented on FLINK-6841:
---
Github user sunjincheng121 closed the pull request at:
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`
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
>
[
https://issues.apache.org/jira/browse/FLINK-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057630#comment-16057630
]
ASF GitHub Bot commented on FLINK-6841:
---
Github user sunjincheng121 commented on the issue:
1 - 100 of 270 matches
Mail list logo
