[
https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695609#comment-16695609
]
vinoyang edited comment on FLINK-10966 at 11/22/18 6:58 AM:
[
https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695609#comment-16695609
]
vinoyang commented on FLINK-10966:
--
Hi [~zjwang] ,
answer your question:
1). For 1.5+
[
https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695585#comment-16695585
]
ASF GitHub Bot commented on FLINK-10820:
zhijiangW commented on issue #7051: [FL
zhijiangW commented on issue #7051: [FLINK-10820][network] Simplify the
RebalancePartitioner implementation
URL: https://github.com/apache/flink/pull/7051#issuecomment-440926347
@pnowojski , I squashed the commits to address the above comments which
introduce `setup` method in `ChannelSele
[
https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695584#comment-16695584
]
zhijiang commented on FLINK-10966:
--
I have some concerns about this issue:
# In credit
[
https://issues.apache.org/jira/browse/FLINK-10926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuqianjin closed FLINK-10926.
-
Resolution: Fixed
Fix Version/s: 1.7.0
> Fix the problem for function TIMESTAMPDIFF in Table
> --
sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep]
Pattern(Flat)SelectFunctions should support RichFunction interface
URL: https://github.com/apache/flink/pull/7110#discussion_r235608590
##
File path:
flink-libraries/flink-cep/src/main/java/org/apache/fl
[
https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695574#comment-16695574
]
ASF GitHub Bot commented on FLINK-8159:
---
sunjincheng121 commented on a change in pu
[
https://issues.apache.org/jira/browse/FLINK-10983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-10983:
Component/s: Queryable State
> NonHAQueryableStateFsBackendITCase failed when run mvn install
> --
Hequn Cheng created FLINK-10983:
---
Summary: NonHAQueryableStateFsBackendITCase failed when run mvn
install
Key: FLINK-10983
URL: https://issues.apache.org/jira/browse/FLINK-10983
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10980:
---
Labels: pull-request-available (was: )
> Wrong statement in CEP Scala part
> --
[
https://issues.apache.org/jira/browse/FLINK-10980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695551#comment-16695551
]
ASF GitHub Bot commented on FLINK-10980:
dubin555 opened a new pull request #715
dubin555 opened a new pull request #7158: [FLINK-10980][docs] Fix Iterable
Scala code in CEP part
URL: https://github.com/apache/flink/pull/7158
## What is the purpose of the change
This pull request fix some Iterable Scala code in the CEP part of the doc
## Brief change log
YUZHOU HONG created FLINK-10982:
---
Summary: Test DataStream to Table for Flink 1.6.2
Key: FLINK-10982
URL: https://issues.apache.org/jira/browse/FLINK-10982
Project: Flink
Issue Type: Test
Yun Gao created FLINK-10981:
---
Summary: Add or modify metrics to show the maximum usage of
InputBufferPool/OutputBufferPool to help debugging back pressure
Key: FLINK-10981
URL: https://issues.apache.org/jira/browse/FLIN
[
https://issues.apache.org/jira/browse/FLINK-10981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-10981:
Description:
Currently the network layer has provided two metrics items, namely
_InputBufferPoolUsageGaug
[
https://issues.apache.org/jira/browse/FLINK-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695521#comment-16695521
]
Jun Zhang edited comment on FLINK-9870 at 11/22/18 3:39 AM:
[
[
https://issues.apache.org/jira/browse/FLINK-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695521#comment-16695521
]
Jun Zhang commented on FLINK-9870:
--
[~twalthr] I assume time attributes are not relevant
DuBin created FLINK-10980:
-
Summary: Wrong statement in CEP Scala part
Key: FLINK-10980
URL: https://issues.apache.org/jira/browse/FLINK-10980
Project: Flink
Issue Type: Bug
Components: CEP
[
https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10834:
Issue Type: Sub-task (was: Bug)
Parent: FLINK-10972
> TableAPI flatten() calculated value
[
https://issues.apache.org/jira/browse/FLINK-10977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10977:
---
Assignee: Hequn Cheng
> Add UnBounded FlatAggregate operator to streaming Table API
> -
sunjincheng created FLINK-10978:
---
Summary: Add UnBounded FlatAggregate operator to batch Table API
Key: FLINK-10978
URL: https://issues.apache.org/jira/browse/FLINK-10978
Project: Flink
Issue T
sunjincheng created FLINK-10979:
---
Summary: Add support for group keys in Unbounded
Aggregate/FlatAggregate operator
Key: FLINK-10979
URL: https://issues.apache.org/jira/browse/FLINK-10979
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10978:
---
Assignee: Hequn Cheng
> Add UnBounded FlatAggregate operator to batch Table API
> -
sunjincheng created FLINK-10977:
---
Summary: Add UnBounded FlatAggregate operator to streaming Table
API
Key: FLINK-10977
URL: https://issues.apache.org/jira/browse/FLINK-10977
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-10976:
---
Assignee: Dian Fu (was: Hequn Cheng)
> Add Aggregate operator to Table API
> -
sunjincheng created FLINK-10976:
---
Summary: Add Aggregate operator to Table API
Key: FLINK-10976
URL: https://issues.apache.org/jira/browse/FLINK-10976
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10976:
---
Assignee: Hequn Cheng
> Add Aggregate operator to Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-10974:
---
Assignee: Dian Fu
> Add FlatMap to TableAPI
> ---
>
> Key: FLIN
sunjincheng created FLINK-10975:
---
Summary: Add support for TimeAttribute in Map/FlatMap operator
Key: FLINK-10975
URL: https://issues.apache.org/jira/browse/FLINK-10975
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10972:
Affects Version/s: (was: 1.8.0)
> Enhancements to Flink Table API
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10973:
Affects Version/s: (was: 1.8.0)
> Add Map operator to Table API
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10972:
Fix Version/s: 1.8.0
> Enhancements to Flink Table API
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10973:
Fix Version/s: 1.8.0
> Add Map operator to Table API
> -
>
> K
sunjincheng created FLINK-10974:
---
Summary: Add FlatMap to TableAPI
Key: FLINK-10974
URL: https://issues.apache.org/jira/browse/FLINK-10974
Project: Flink
Issue Type: Sub-task
Componen
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10972:
Affects Version/s: (was: 1.7.1)
1.8.0
> Enhancements to Flink Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-10973:
---
Assignee: Dian Fu
> Add Map operator to Table API
> -
>
>
sunjincheng created FLINK-10973:
---
Summary: Add Map operator to Table API
Key: FLINK-10973
URL: https://issues.apache.org/jira/browse/FLINK-10973
Project: Flink
Issue Type: Sub-task
Co
[
https://issues.apache.org/jira/browse/FLINK-10964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-10964:
-
Summary: sql-client throws exception when paging through finished batch
query (was: sql-client
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10972:
Description:
With the continuous efforts from the community, the Flink system has been
continuous
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10972:
Issue Type: New Feature (was: Improvement)
> Enhancements to Flink Table API
> --
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695482#comment-16695482
]
ASF GitHub Bot commented on FLINK-10134:
XuQianJin-Stars opened a new pull reque
XuQianJin-Stars opened a new pull request #7157: [FLINK-10134] UTF-16 support
for TextInputFormat bug
URL: https://github.com/apache/flink/pull/7157
## What is the purpose of the change
*(This PR is designed to solve the problem of `TextInputFormat` using UTF-16
encoding to parse fi
[
https://issues.apache.org/jira/browse/FLINK-10970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10970:
Assignee: vinoyang
> expose metric for total state size in terms of bytes
> -
[
https://issues.apache.org/jira/browse/FLINK-10969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10969:
Assignee: vinoyang
> expose API or metric for total number of keys stored in state backend
>
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10972:
Description:
With the continuous efforts from the community, the Flink system has been
continuous
[
https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695453#comment-16695453
]
ASF GitHub Bot commented on FLINK-10967:
yanghua commented on issue #7156: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695454#comment-16695454
]
ASF GitHub Bot commented on FLINK-10967:
yanghua commented on issue #7156: [FLIN
yanghua commented on issue #7156: [FLINK-10967] Update kafka dependency to 2.1.0
URL: https://github.com/apache/flink/pull/7156#issuecomment-440883805
cc @tillrohrmann @pnowojski
This is an automated message from the Apache G
[
https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10967:
-
Issue Type: Sub-task (was: Bug)
Parent: FLINK-10598
> Update kafka dependency to 2.1.0
> --
sunjincheng created FLINK-10972:
---
Summary: Enhancements to Flink Table API
Key: FLINK-10972
URL: https://issues.apache.org/jira/browse/FLINK-10972
Project: Flink
Issue Type: Improvement
yanghua commented on issue #7156: [FLINK-10967] Update kafka dependency to 2.1.0
URL: https://github.com/apache/flink/pull/7156#issuecomment-440881988
@ijuma Thanks for your contribution. Upgrading the dependent version of the
Kafka client requires more changes. Please refer to the
[PR](ht
[
https://issues.apache.org/jira/browse/FLINK-10965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695445#comment-16695445
]
Hequn Cheng commented on FLINK-10965:
-
{{getResultType}} has a higher priority than
[
https://issues.apache.org/jira/browse/FLINK-10964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10964:
Assignee: vinoyang
> sql-client throws exception when pagin through finished batch query
> -
[
https://issues.apache.org/jira/browse/FLINK-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695444#comment-16695444
]
ASF GitHub Bot commented on FLINK-10665:
TisonKun commented on issue #6917: [FLI
TisonKun commented on issue #6917: [FLINK-10665] [tests] Port
YARNSessionFIFOITCase#testJavaAPI to new c…
URL: https://github.com/apache/flink/pull/6917#issuecomment-440876707
cc @GJL @StefanRRichter
This is an automated mes
[
https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695332#comment-16695332
]
ASF GitHub Bot commented on FLINK-10887:
jgrier commented on a change in pull re
jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster]
Add source watermark tracking to the JobMaster
URL: https://github.com/apache/flink/pull/7099#discussion_r235559380
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/watermark/SourceWater
[
https://issues.apache.org/jira/browse/FLINK-10971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695304#comment-16695304
]
Ufuk Celebi commented on FLINK-10971:
-
*Note*: I verified that the actual RC binarie
Ufuk Celebi created FLINK-10971:
---
Summary: Dependency convergence issue when building
flink-s3-fs-presto
Key: FLINK-10971
URL: https://issues.apache.org/jira/browse/FLINK-10971
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-10971:
Attachment: FLINK-10971-build_output_flink-s3-fs-presto
FLINK-10971-build_output
>
Steven Zhen Wu created FLINK-10970:
--
Summary: expose metric for total state size in terms of bytes
Key: FLINK-10970
URL: https://issues.apache.org/jira/browse/FLINK-10970
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-10969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhen Wu updated FLINK-10969:
---
Description:
[~srichter] mentioned it might make sense to provide two versions: exact count
Steven Zhen Wu created FLINK-10969:
--
Summary: expose API or metric for total number of keys stored in
state backend
Key: FLINK-10969
URL: https://issues.apache.org/jira/browse/FLINK-10969
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-10946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695166#comment-16695166
]
ASF GitHub Bot commented on FLINK-10946:
azagrebin commented on issue #7154: [FL
azagrebin commented on issue #7154: [FLINK-10946] Silent checkpoint async
failures in task executor if job is not runnning
URL: https://github.com/apache/flink/pull/7154#issuecomment-440785486
passed in my CI:
https://travis-ci.org/azagrebin/flink/builds/458023830
--
[
https://issues.apache.org/jira/browse/FLINK-10959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695163#comment-16695163
]
Ken Krugler commented on FLINK-10959:
-
Hi [~luyee] - this is something that would be
JIN SUN created FLINK-10968:
---
Summary: Implement TaskManager Entrypoint
Key: FLINK-10968
URL: https://issues.apache.org/jira/browse/FLINK-10968
Project: Flink
Issue Type: Sub-task
Repor
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695089#comment-16695089
]
ASF GitHub Bot commented on FLINK-9083:
---
azagrebin commented on a change in pull re
azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra
Connector] Add async backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#discussion_r234920560
##
File path:
flink-connectors/flink-connector-cassandra/src/main/java
[
https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-5005:
--
> Remove Scala 2.10 support; add Scala 2.12 support
> -
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10355:
--
Summary: Counting of table columns should start with 1 instead of 0 (was:
The order of the co
[
https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-9126:
--
> Creation of the CassandraPojoInputFormat class to output data into a Custom
> Cassandra Annotate
[
https://issues.apache.org/jira/browse/FLINK-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10172:
--
Summary: Inconsistency in ExpressionParser and ExpressionDsl for order by
asc/desc (was: Inco
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10355.
-
Resolution: Fixed
> Counting of table columns should start with 1 instead of 0
> ---
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10355:
---
> The order of the column should start from 1.
>
>
[
https://issues.apache.org/jira/browse/FLINK-10056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10056:
--
Summary: Add test for JobMaster#requestNextInputSplit (was: Add
testRequestNextInputSplit)
>
[
https://issues.apache.org/jira/browse/FLINK-10073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10073:
---
> Allow setting a restart strategy in SQL Client
> -
[
https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10967:
---
Labels: pull-request-available (was: )
> Update kafka dependency to 2.1.0
> ---
[
https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9126.
Resolution: Fixed
> Creation of the CassandraPojoInputFormat class to output data into a Custom
>
[
https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694951#comment-16694951
]
ASF GitHub Bot commented on FLINK-10967:
ijuma opened a new pull request #7156:
[
https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10309:
--
Summary: Cancel with savepoint fails with java.net.ConnectException when
using the per job-mod
ijuma opened a new pull request #7156: [FLINK-10967] Update kafka dependency to
2.1.0
URL: https://github.com/apache/flink/pull/7156
## What is the purpose of the change
Apache Kafka 2.1.0 includes an important improvement with regards to producer
timeouts as described in KIP-91:
[
https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10309.
-
Resolution: Fixed
> Cancel with savepoint fails with java.net.ConnectException when using the pe
Ismael Juma created FLINK-10967:
---
Summary: Update kafka dependency to 2.1.0
Key: FLINK-10967
URL: https://issues.apache.org/jira/browse/FLINK-10967
Project: Flink
Issue Type: Bug
Re
[
https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10309:
---
> Cancel flink job occurs java.net.ConnectException
> --
[
https://issues.apache.org/jira/browse/FLINK-10371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10371.
-
Resolution: Fixed
> Allow to enable SSL mutual authentication on REST endpoints by configuration
[
https://issues.apache.org/jira/browse/FLINK-10371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10371:
---
> Allow to enable SSL mutual authentication on REST endpoints by configuration
> ---
[
https://issues.apache.org/jira/browse/FLINK-10371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10371:
--
Issue Type: New Feature (was: Improvement)
> Allow to enable SSL mutual authentication on RES
[
https://issues.apache.org/jira/browse/FLINK-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10172.
-
Resolution: Fixed
> Inconsistency in ExpressionParser and ExpressionDsl for order by asc/desc
>
[
https://issues.apache.org/jira/browse/FLINK-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10172:
---
> Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc
> -
[
https://issues.apache.org/jira/browse/FLINK-10073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10073:
--
Issue Type: New Feature (was: Improvement)
> Allow setting a restart strategy in SQL Client
>
[
https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10310:
---
> Cassandra Sink - Handling failing requests
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-10073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10073.
-
Resolution: Fixed
> Allow setting a restart strategy in SQL Client
> ---
[
https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10310.
---
Resolution: Implemented
> Cassandra Sink - Handling failing requests
> -
[
https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10310:
--
Issue Type: New Feature (was: Improvement)
> Cassandra Sink - Handling failing requests
> ---
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10050.
-
Resolution: Implemented
> Support 'allowedLateness' in CoGroupedStreams
> --
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10050:
---
> Support 'allowedLateness' in CoGroupedStreams
> -
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9697.
Resolution: Implemented
> Provide connector for modern Kafka
> --
>
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10050:
--
Issue Type: New Feature (was: Improvement)
> Support 'allowedLateness' in CoGroupedStreams
>
1 - 100 of 336 matches
Mail list logo
