yanghua opened a new pull request #6473: [FLINK-] Add ISNUMERIC supported
in Table API/SQL
URL: https://github.com/apache/flink/pull/6473
## What is the purpose of the change
*This pull request add ISNUMERIC supported in Table API/SQL*
## Brief change log
- *Add I
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566418#comment-16566418
]
ASF GitHub Bot commented on FLINK-:
---
yanghua opened a new pull request #6473: [
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-:
--
Labels: pull-request-available (was: )
> Add ISNUMERIC supported in Table API/SQL
> --
[
https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566394#comment-16566394
]
ASF GitHub Bot commented on FLINK-7205:
---
hequn8128 commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566393#comment-16566393
]
ASF GitHub Bot commented on FLINK-7205:
---
hequn8128 commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566395#comment-16566395
]
ASF GitHub Bot commented on FLINK-7205:
---
hequn8128 commented on a change in pull re
hequn8128 commented on a change in pull request #6381: [FLINK-7205] [table] Add
UUID supported in SQL and TableApi
URL: https://github.com/apache/flink/pull/6381#discussion_r207106244
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressi
hequn8128 commented on a change in pull request #6381: [FLINK-7205] [table] Add
UUID supported in SQL and TableApi
URL: https://github.com/apache/flink/pull/6381#discussion_r207106931
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/sql/Scal
hequn8128 commented on a change in pull request #6381: [FLINK-7205] [table] Add
UUID supported in SQL and TableApi
URL: https://github.com/apache/flink/pull/6381#discussion_r207106883
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/UUID
yanghua commented on a change in pull request #6471: [FLINK-10010][DataStream
API] Deprecate unused BaseAlignedWindowAssigner related components
URL: https://github.com/apache/flink/pull/6471#discussion_r207100012
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/st
[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566338#comment-16566338
]
ASF GitHub Bot commented on FLINK-10010:
yanghua commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566339#comment-16566339
]
ASF GitHub Bot commented on FLINK-10010:
yanghua commented on a change in pull r
yanghua commented on a change in pull request #6471: [FLINK-10010][DataStream
API] Deprecate unused BaseAlignedWindowAssigner related components
URL: https://github.com/apache/flink/pull/6471#discussion_r207100160
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/st
[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566337#comment-16566337
]
ASF GitHub Bot commented on FLINK-10010:
yanghua commented on a change in pull r
yanghua commented on a change in pull request #6471: [FLINK-10010][DataStream
API] Deprecate unused BaseAlignedWindowAssigner related components
URL: https://github.com/apache/flink/pull/6471#discussion_r207099935
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/st
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566330#comment-16566330
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on a change in pull requ
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r207099504
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/Func
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566318#comment-16566318
]
ASF GitHub Bot commented on FLINK-9970:
---
hequn8128 commented on a change in pull re
hequn8128 commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r207096222
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/Fu
walterddr opened a new pull request #6472: [Flink-9294][Table/SQL API] Improve
type inference for UDFs with composite parameter and/or result type
URL: https://github.com/apache/flink/pull/6472
## What is the purpose of the change
Support more strict type checks and type inference wh
[
https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-10019:
--
Issue Type: Bug (was: Sub-task)
Parent: (was: FLINK-9484)
> Fix Composite getResultType o
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-5315:
-
Description:
Support distinct aggregations in Table API in the following format:
For Expressions:
{code:
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-5315:
-
Description:
Support distinct aggregations in Table API in the following format:
For Expressions:
{code:
[
https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566032#comment-16566032
]
Elias Levy commented on FLINK-10011:
[~azagrebin] I don't think they are the same is
[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566023#comment-16566023
]
ASF GitHub Bot commented on FLINK-10010:
walterddr opened a new pull request #64
[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10010:
---
Labels: pull-request-available (was: )
> Deprecate unused BaseAlignedWindowAssigner related
walterddr opened a new pull request #6471: [FLINK-10010][DataStream API]
Deprecate unused BaseAlignedWindowAssigner related components
URL: https://github.com/apache/flink/pull/6471
## What is the purpose of the change
Deprecate unused AlignedWindow related components. the links in c
[
https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy updated FLINK-9575:
--
Description:
When we are removing the _JobGraph_ from _JobManager_ for example after
invoking _cancel(
[
https://issues.apache.org/jira/browse/FLINK-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566010#comment-16566010
]
Thomas Weise commented on FLINK-10020:
--
{code:java}
org.apache.flink.kinesis.shaded
Thomas Weise created FLINK-10020:
Summary: Kinesis Consumer listShards should support more
recoverable exceptions
Key: FLINK-10020
URL: https://issues.apache.org/jira/browse/FLINK-10020
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-10019:
--
Description:
If explicitly return a CompositeType in {{udf.getResultType}}, will result in
some failu
Rong Rong created FLINK-10019:
-
Summary: Fix Composite getResultType of UDF cannot be chained with
other operators
Key: FLINK-10019
URL: https://issues.apache.org/jira/browse/FLINK-10019
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565786#comment-16565786
]
ASF GitHub Bot commented on FLINK-9981:
---
azagrebin commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565788#comment-16565788
]
ASF GitHub Bot commented on FLINK-9981:
---
azagrebin commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565787#comment-16565787
]
ASF GitHub Bot commented on FLINK-9981:
---
azagrebin commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565785#comment-16565785
]
ASF GitHub Bot commented on FLINK-9981:
---
azagrebin commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565789#comment-16565789
]
ASF GitHub Bot commented on FLINK-9981:
---
azagrebin commented on a change in pull re
azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune
performance of RocksDB implementation
URL: https://github.com/apache/flink/pull/6438#discussion_r206982020
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/s
azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune
performance of RocksDB implementation
URL: https://github.com/apache/flink/pull/6438#discussion_r206983891
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/s
azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune
performance of RocksDB implementation
URL: https://github.com/apache/flink/pull/6438#discussion_r206966986
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/s
azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune
performance of RocksDB implementation
URL: https://github.com/apache/flink/pull/6438#discussion_r206962666
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/s
azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune
performance of RocksDB implementation
URL: https://github.com/apache/flink/pull/6438#discussion_r206960632
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/s
[
https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16507191#comment-16507191
]
Ted Yu edited comment on FLINK-9340 at 8/1/18 5:07 PM:
---
I wonder if
[
https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565607#comment-16565607
]
ASF GitHub Bot commented on FLINK-9936:
---
GJL commented on a change in pull request
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP
URL: https://github.com/apache/flink/pull/6464#discussion_r206951198
##
File path:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java
##
@@ -278,22 +2
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565599#comment-16565599
]
ASF GitHub Bot commented on FLINK-9682:
---
eliaslevy commented on issue #6266: [FLINK
eliaslevy commented on issue #6266: [FLINK-9682] Add setDescription to
execution environment and provide description field for the rest api
URL: https://github.com/apache/flink/pull/6266#issuecomment-409638948
@tillrohrmann those locations in the UI work for me
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565586#comment-16565586
]
Kostas Kloudas commented on FLINK-9962:
---
[~phoenixjiangnan] I agree that for *respo
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565586#comment-16565586
]
Kostas Kloudas edited comment on FLINK-9962 at 8/1/18 4:30 PM:
[
https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565583#comment-16565583
]
Andrey Zagrebin commented on FLINK-10011:
-
This problem might be related to the
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9963:
--
Description:
Sometimes it might be useful to just read or write a single value into Kafka or
other con
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9963:
--
Description:
Sometimes it might be useful to just read or write a single value into Kafka or
other con
[
https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565552#comment-16565552
]
Antoine Philippot commented on FLINK-7883:
--
Yes [~aljoscha], I'm agree, as long
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9963:
--
Summary: Add a single value table format factory (was: Add a string table
format factory)
> Add a sin
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565539#comment-16565539
]
ASF GitHub Bot commented on FLINK-9900:
---
yanghua commented on issue #6468: [FLINK-9
yanghua commented on issue #6468: [FLINK-9900][tests] Include more information
on timeout in Zookeeper HA ITCase
URL: https://github.com/apache/flink/pull/6468#issuecomment-409626058
+1
This is an automated message from the A
[
https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565516#comment-16565516
]
ASF GitHub Bot commented on FLINK-10006:
yanghua commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565517#comment-16565517
]
ASF GitHub Bot commented on FLINK-10006:
yanghua commented on a change in pull r
yanghua commented on a change in pull request #6470: [FLINK-10006][network]
improve logging in BarrierBuffer: prepend owning task name
URL: https://github.com/apache/flink/pull/6470#discussion_r206931865
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/
yanghua commented on a change in pull request #6470: [FLINK-10006][network]
improve logging in BarrierBuffer: prepend owning task name
URL: https://github.com/apache/flink/pull/6470#discussion_r206931425
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/
[
https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565504#comment-16565504
]
ASF GitHub Bot commented on FLINK-9679:
---
medcv commented on issue #6259: [FLINK-967
medcv commented on issue #6259: [FLINK-9679] Implement AvroSerializationSchema
URL: https://github.com/apache/flink/pull/6259#issuecomment-409619105
@tillrohrmann Thanks for the update!
This is an automated message from th
[
https://issues.apache.org/jira/browse/FLINK-10013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-10013.
Resolution: Fixed
Fixed on release-1.5 in
904a12b056c23079b32b2b99cc5df11d4bd2d0f8
> Fix
[
https://issues.apache.org/jira/browse/FLINK-10016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-10016.
Resolution: Fixed
Implemented on release-1.5 in
b075ad899a7f797f8583556cdb28eea870176c96
[
https://issues.apache.org/jira/browse/FLINK-9655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565487#comment-16565487
]
Chesnay Schepler commented on FLINK-9655:
-
The issue is that in FLINK-8993 the op
[
https://issues.apache.org/jira/browse/FLINK-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565485#comment-16565485
]
Timo Walther commented on FLINK-9984:
-
[~xueyu] sorry for not responding earlier. I g
[
https://issues.apache.org/jira/browse/FLINK-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565481#comment-16565481
]
Timo Walther commented on FLINK-9984:
-
[~RuidongLi] this issue might already be cover
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565459#comment-16565459
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull reque
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206919014
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/utils/SystemResourcesCounter.java
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565458#comment-16565458
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull reque
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206918739
##
File path: docs/monitoring/metrics.md
##
@@ -1370,6 +1370,147 @@ Thus, in order to infer the metric identif
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565450#comment-16565450
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull reque
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565452#comment-16565452
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull reque
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565456#comment-16565456
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on issue #4801: [FLINK-78
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565454#comment-16565454
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull reque
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565451#comment-16565451
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull reque
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565455#comment-16565455
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull reque
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565453#comment-16565453
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull reque
[
https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565446#comment-16565446
]
Aljoscha Krettek commented on FLINK-7883:
-
For a start, I renamed the issue. I ho
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206915837
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/utils/SystemResourcesCounter.java
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206915920
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/utils/SystemResourcesMetricsInitializer
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206916437
##
File path:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
##
@@ -1884
zentol commented on issue #4801: [FLINK-7812] Log system resources metrics
URL: https://github.com/apache/flink/pull/4801#issuecomment-409608732
Also needs a rebase.
This is an automated message from the Apache Git Service.
To
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206912468
##
File path: docs/monitoring/metrics.md
##
@@ -1370,6 +1370,147 @@ Thus, in order to infer the metric identif
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206916150
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/utils/SystemResourcesMetricsInitializer
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206915374
##
File path: docs/_includes/generated/task_manager_configuration.html
##
@@ -37,6 +37,16 @@
true
[
https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7883:
Summary: Make savepoints atomic with respect to state and side effects
(was: Stop fetching
[
https://issues.apache.org/jira/browse/FLINK-10018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565443#comment-16565443
]
Aljoscha Krettek commented on FLINK-10018:
--
In Flink, _cancel_ and _stop_ are u
[
https://issues.apache.org/jira/browse/FLINK-10018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-10018:
-
Priority: Major (was: Blocker)
> Want to have stop command with checkpointing
> -
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565436#comment-16565436
]
ASF GitHub Bot commented on FLINK-9963:
---
twalthr commented on a change in pull requ
twalthr commented on a change in pull request #6447: [FLINK-9963] [table] Add a
string table format factory
URL: https://github.com/apache/flink/pull/6447#discussion_r206907666
##
File path: flink-formats/flink-string/pom.xml
##
@@ -0,0 +1,112 @@
+
+
+http://maven.apache.o
Keshav Lodhi created FLINK-10018:
Summary: Want to have stop command with checkpointing
Key: FLINK-10018
URL: https://issues.apache.org/jira/browse/FLINK-10018
Project: Flink
Issue Type: Ne
[
https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565415#comment-16565415
]
ASF GitHub Bot commented on FLINK-9878:
---
NicoK commented on a change in pull reques
NicoK commented on a change in pull request #6355: [FLINK-9878][network][ssl]
add more low-level ssl options
URL: https://github.com/apache/flink/pull/6355#discussion_r206905353
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/NettyClientServerSsl
[
https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10006:
---
Labels: pull-request-available (was: )
> Improve logging in BarrierBuffer
> ---
[
https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565414#comment-16565414
]
ASF GitHub Bot commented on FLINK-10006:
NicoK opened a new pull request #6470:
NicoK opened a new pull request #6470: [FLINK-10006][network] improve logging
in BarrierBuffer: prepend owning task name
URL: https://github.com/apache/flink/pull/6470
## What is the purpose of the change
Almost all log messages of `BarrierBuffer` do not contain the task name and
ar
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-7812:
--
Labels: pull-request-available (was: )
> Log system resources as metrics
> ---
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565409#comment-16565409
]
ASF GitHub Bot commented on FLINK-7812:
---
aljoscha commented on a change in pull req
[
https://issues.apache.org/jira/browse/FLINK-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-9979.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed in 1.7.0: 628b71dfabe72a99eb6d54994fc870abed1
1 - 100 of 281 matches
Mail list logo
