[
https://issues.apache.org/jira/browse/FLINK-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569752#comment-16569752
]
ASF GitHub Bot commented on FLINK-9859:
---
TisonKun commented on issue #6339: [FLINK-
TisonKun commented on issue #6339: [FLINK-9859] [runtime] distinguish JM akka
config
URL: https://github.com/apache/flink/pull/6339#issuecomment-410592966
ping @tillrohrmann
This is an automated message from the Apache Git S
[
https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16345955#comment-16345955
]
Ted Yu edited comment on FLINK-7795 at 8/6/18 4:54 AM:
---
error-prone
[
https://issues.apache.org/jira/browse/FLINK-10056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569674#comment-16569674
]
ASF GitHub Bot commented on FLINK-10056:
TisonKun commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569677#comment-16569677
]
ASF GitHub Bot commented on FLINK-10056:
TisonKun commented on issue #6490: [FLI
TisonKun commented on issue #6490: [FLINK-10056] [test] Add
JobMasterTest#testRequestNextInputSplit
URL: https://github.com/apache/flink/pull/6490#issuecomment-410574707
cc @twalthr @tzulitai
This is an automated message fro
TisonKun commented on a change in pull request #6490: [FLINK-10056] [test] Add
JobMasterTest#testRequestNextInputSplit
URL: https://github.com/apache/flink/pull/6490#discussion_r207763974
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGra
[
https://issues.apache.org/jira/browse/FLINK-10047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569669#comment-16569669
]
zhijiang commented on FLINK-10047:
--
let's trace it together. :)
> Checkpointing takes
[
https://issues.apache.org/jira/browse/FLINK-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569661#comment-16569661
]
ASF GitHub Bot commented on FLINK-10020:
tweise commented on a change in pull re
tweise commented on a change in pull request #6482: [FLINK-10020] [kinesis]
Support recoverable exceptions in listShards.
URL: https://github.com/apache/flink/pull/6482#discussion_r207761087
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/strea
[
https://issues.apache.org/jira/browse/FLINK-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569660#comment-16569660
]
ASF GitHub Bot commented on FLINK-10020:
tweise commented on a change in pull re
tweise commented on a change in pull request #6482: [FLINK-10020] [kinesis]
Support recoverable exceptions in listShards.
URL: https://github.com/apache/flink/pull/6482#discussion_r207760823
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/strea
[
https://issues.apache.org/jira/browse/FLINK-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569652#comment-16569652
]
ASF GitHub Bot commented on FLINK-10020:
tweise commented on a change in pull re
tweise commented on a change in pull request #6482: [FLINK-10020] [kinesis]
Support recoverable exceptions in listShards.
URL: https://github.com/apache/flink/pull/6482#discussion_r207760644
##
File path:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/strea
[
https://issues.apache.org/jira/browse/FLINK-9720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renjie Liu updated FLINK-9720:
--
Fix Version/s: (was: 1.6.0)
1.7.0
> Introduce ResourceTag class for tag support
[
https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renjie Liu updated FLINK-9662:
--
Fix Version/s: (was: 1.6.0)
1.7.0
> Task manager isolation for jobs
> --
[
https://issues.apache.org/jira/browse/FLINK-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10064:
---
Labels: pull-request-available (was: )
> Fix a typo in ExternalCatalogTable
> -
[
https://issues.apache.org/jira/browse/FLINK-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569518#comment-16569518
]
ASF GitHub Bot commented on FLINK-10064:
tragicjun opened a new pull request #64
tragicjun opened a new pull request #6497: [FLINK-10064] [table] Fix a typo in
ExternalCatalogTable
URL: https://github.com/apache/flink/pull/6497
## What is the purpose of the change
Function **ExternalCatalogTable.IsTableSink** should return **isSink** not
**isSource**, I guess it
[
https://issues.apache.org/jira/browse/FLINK-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-10064:
--
Description:
Function *ExternalCatalogTable.IsTableSink* should return *isSink* not
*isSource*, I gue
[
https://issues.apache.org/jira/browse/FLINK-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-10064:
--
Description:
Function *IsTableSink* should return *isSink* not *isSource*, I guess it was a
small typ
[
https://issues.apache.org/jira/browse/FLINK-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-10064:
--
Summary: Fix a typo in ExternalCatalogTable (was: Fixed a typo in
ExternalCatalogTable)
> Fix a typo
[
https://issues.apache.org/jira/browse/FLINK-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-10064:
--
Description:
IsTableSink should return isSink not isSource, I guess it was a small typo:
{code:java}
d
Jun Zhang created FLINK-10064:
-
Summary: Fixed a typo in ExternalCatalogTable
Key: FLINK-10064
URL: https://issues.apache.org/jira/browse/FLINK-10064
Project: Flink
Issue Type: Bug
Comp
[
https://issues.apache.org/jira/browse/FLINK-10033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-10033.
> Let Task release reference to Invokable on shutdown
> --
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569470#comment-16569470
]
ASF GitHub Bot commented on FLINK-9794:
---
jrthe42 commented on a change in pull requ
jrthe42 commented on a change in pull request #6301: [FLINK-9794] [jdbc]
JDBCOutputFormat does not consider idle connection and multithreads
synchronization
URL: https://github.com/apache/flink/pull/6301#discussion_r207736877
##
File path:
flink-connectors/flink-jdbc/src/main/java
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569468#comment-16569468
]
ASF GitHub Bot commented on FLINK-9794:
---
jrthe42 commented on a change in pull requ
jrthe42 commented on a change in pull request #6301: [FLINK-9794] [jdbc]
JDBCOutputFormat does not consider idle connection and multithreads
synchronization
URL: https://github.com/apache/flink/pull/6301#discussion_r207736804
##
File path:
flink-connectors/flink-jdbc/src/main/java
[
https://issues.apache.org/jira/browse/FLINK-9853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569466#comment-16569466
]
ASF GitHub Bot commented on FLINK-9853:
---
xueyumusic commented on a change in pull r
xueyumusic commented on a change in pull request #6337: [FLINK-9853] [table]
Add HEX support
URL: https://github.com/apache/flink/pull/6337#discussion_r207736696
##
File path: docs/dev/table/sql.md
##
@@ -1664,6 +1664,17 @@ BIN(numeric)
+
+
+{% h
[
https://issues.apache.org/jira/browse/FLINK-10063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10063:
---
Labels: pull-request-available (was: )
> Jepsen: Automatically restart Mesos Processes
> --
[
https://issues.apache.org/jira/browse/FLINK-10063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569458#comment-16569458
]
ASF GitHub Bot commented on FLINK-10063:
GJL opened a new pull request #6496: [F
GJL opened a new pull request #6496: [FLINK-10063][tests] Use runit to
supervise mesos processes.
URL: https://github.com/apache/flink/pull/6496
## What is the purpose of the change
*Use a process supervisor to automatically restart Mesos processes. This is
needed because Mesos uses
[
https://issues.apache.org/jira/browse/FLINK-10063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-10063:
-
Description: Use a process supervisor to automatically restart Mesos
processes. This is needed because M
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569453#comment-16569453
]
ASF GitHub Bot commented on FLINK-6847:
---
xueyumusic commented on issue #6282: [FLIN
Gary Yao created FLINK-10063:
Summary: Jepsen: Automatically restart Mesos Processes
Key: FLINK-10063
URL: https://issues.apache.org/jira/browse/FLINK-10063
Project: Flink
Issue Type: Bug
xueyumusic commented on issue #6282: [FLINK-6847][FLINK-6813] [table]
TimestampDiff table api and sql support
URL: https://github.com/apache/flink/pull/6282#issuecomment-410518086
@twalthr @hequn8128 I updated with the following
1. using `-` arithmetic to compute diff of two timestamps o
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569442#comment-16569442
]
ASF GitHub Bot commented on FLINK-6847:
---
xueyumusic edited a comment on issue #6282
xueyumusic edited a comment on issue #6282: [FLINK-6847][FLINK-6813] [table]
TimestampDiff table api and sql support
URL: https://github.com/apache/flink/pull/6282#issuecomment-410450506
@twalthr I am not sure how to express the `unit` parameter when using `-`
arithmetic.
How about `('
[
https://issues.apache.org/jira/browse/FLINK-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569439#comment-16569439
]
ASF GitHub Bot commented on FLINK-10012:
yanghua commented on issue #6475: [FLIN
yanghua commented on issue #6475: [FLINK-10012] Add
setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API
URL: https://github.com/apache/flink/pull/6475#issuecomment-410514508
@zentol added python test case, can you review this PR again?
---
[
https://issues.apache.org/jira/browse/FLINK-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-10062:
Assignee: Chesnay Schepler
> Docs are not built due to git-commit-id-plugin
> ---
[
https://issues.apache.org/jira/browse/FLINK-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10062:
-
Description:
The recent changes in FLINK-9986 causes errors during the building of the docs.
{c
Timo Walther created FLINK-10062:
Summary: Docs are not built due to git-commit-id-plugin
Key: FLINK-10062
URL: https://issues.apache.org/jira/browse/FLINK-10062
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-10061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-10061:
--
Summary: Fix unsupported reconfiguration in KafkaTableSink (was: Fix
unsupported configuration in Kaf
[
https://issues.apache.org/jira/browse/FLINK-10061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10061:
---
Labels: pull-request-available (was: )
> Fix unsupported configuration in KafkaTableSink
>
[
https://issues.apache.org/jira/browse/FLINK-10061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569434#comment-16569434
]
ASF GitHub Bot commented on FLINK-10061:
tragicjun opened a new pull request #64
tragicjun opened a new pull request #6495: [FLINK-10061] [kafka] Fix
unsupported configuration in KafkaTableSink
URL: https://github.com/apache/flink/pull/6495
## What is the purpose of the change
When using KafkaTableSink in "Table.writeToSink(), the following exception
is thrown:
[
https://issues.apache.org/jira/browse/FLINK-10061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-10061:
--
Description:
When using KafkaTableSink in "table.writeToSink(), the following exception is
thrown:
{q
Jun Zhang created FLINK-10061:
-
Summary: Fix unsupported configuration in KafkaTableSink
Key: FLINK-10061
URL: https://issues.apache.org/jira/browse/FLINK-10061
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-10059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569410#comment-16569410
]
ASF GitHub Bot commented on FLINK-10059:
yanghua opened a new pull request #6494
[
https://issues.apache.org/jira/browse/FLINK-10059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10059:
---
Labels: pull-request-available (was: )
> Add LTRIM supported in Table API and SQL
> ---
yanghua opened a new pull request #6494: [FLINK-10059] Add LTRIM supported in
Table API and SQL
URL: https://github.com/apache/flink/pull/6494
## What is the purpose of the change
*This pull request add LTRIM supported in Table API and SQL*
## Brief change log
- *
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569404#comment-16569404
]
ASF GitHub Bot commented on FLINK-9962:
---
kl0u commented on a change in pull request
kl0u commented on a change in pull request #6492: [FLINK-9962] [FS connector]
allow users to specify TimeZone in DateTimeBucketer
URL: https://github.com/apache/flink/pull/6492#discussion_r207728642
##
File path:
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/
vinoyang created FLINK-10060:
Summary: Add RTRIM supported in Table API and SQL
Key: FLINK-10060
URL: https://issues.apache.org/jira/browse/FLINK-10060
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-10059:
Summary: Add LTRIM supported in Table API and SQL
Key: FLINK-10059
URL: https://issues.apache.org/jira/browse/FLINK-10059
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569402#comment-16569402
]
ASF GitHub Bot commented on FLINK-9962:
---
kl0u commented on a change in pull request
kl0u commented on a change in pull request #6492: [FLINK-9962] [FS connector]
allow users to specify TimeZone in DateTimeBucketer
URL: https://github.com/apache/flink/pull/6492#discussion_r207728642
##
File path:
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/
yanghua opened a new pull request #6493: [FLINK-10058] Add
getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment
URL: https://github.com/apache/flink/pull/6493
## What is the purpose of the change
*This pull request adds getStateBackend/setStateBackend API for
Pyt
[
https://issues.apache.org/jira/browse/FLINK-10058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10058:
---
Labels: pull-request-available (was: )
> Add getStateBackend/setStateBackend API for Python
[
https://issues.apache.org/jira/browse/FLINK-10058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16569403#comment-16569403
]
ASF GitHub Bot commented on FLINK-10058:
yanghua opened a new pull request #6493
vinoyang created FLINK-10058:
Summary: Add getStateBackend/setStateBackend API for
PythonStreamExecutionEnvironment
Key: FLINK-10058
URL: https://issues.apache.org/jira/browse/FLINK-10058
Project: Flink
64 matches
Mail list logo
