[GitHub] [flink] flinkbot edited a comment on issue #11488: [FLINK-16717][k8s] Use headless service for rpc and blob port

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11488: [FLINK-16717][k8s] Use headless service for rpc and blob port URL: https://github.com/apache/flink/pull/11488#issuecomment-602505075 ## CI report: * 933f9c847bdc03642c261031c016d441fc327b0c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index.

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index. URL: https://github.com/apache/flink/pull/11466#issuecomment-601789375 ## CI report: * 9c890d0d2012e311f4e33733e695da3ae0118fe9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11467: [FLINK-16317][operators] Provide support for watermarks, key selector and latency marker in MultipleInputStreamOperator

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11467: [FLINK-16317][operators] Provide support for watermarks, key selector and latency marker in MultipleInputStreamOperator URL: https://github.com/apache/flink/pull/11467#issuecomment-601798473 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11487: [FLINK-16656] Introduce the DispatcherBootstrap.

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11487: [FLINK-16656] Introduce the DispatcherBootstrap. URL: https://github.com/apache/flink/pull/11487#issuecomment-602504532 ## CI report: * 8d31a75920164c244f4cc94cbcb8eaa284ff1b9d Travis:

[GitHub] [flink] flinkbot commented on issue #11489: [FLINK-15640][k8s] Support to set labels and node-selector for jobmanager and taskmanager pod

2020-03-23 Thread GitBox
flinkbot commented on issue #11489: [FLINK-15640][k8s] Support to set labels and node-selector for jobmanager and taskmanager pod URL: https://github.com/apache/flink/pull/11489#issuecomment-602514343 ## CI report: * bb02ce865fa48c9259500a8408897605534b35c2 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11444: [FLINK-16608][python] Support primitive data types for vectorized Python UDF

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11444: [FLINK-16608][python] Support primitive data types for vectorized Python UDF URL: https://github.com/apache/flink/pull/11444#issuecomment-600678571 ## CI report: * f2ef0c0c560faa93cc7663ae7080676488066a10 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458#issuecomment-601537757 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#issuecomment-598702521 ## CI report: * 6e60715d78ca865c3d687699124338afb1f6d1e2

[jira] [Commented] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

2020-03-23 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064710#comment-17064710 ] Zili Chen commented on FLINK-16715: --- > > Thanks for the work @zhengcanbin and for the review

[jira] [Updated] (FLINK-16302) add log list and read log by name for taskmanager

2020-03-23 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-16302: - Fix Version/s: 1.11.0 > add log list and read log by name for taskmanager >

[GitHub] [flink] GJL closed pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

2020-03-23 Thread GitBox
GJL closed pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink-statefun] igalshilman opened a new pull request #67: [FLINK-16723] Move K8s example into statefun-examples/

2020-03-23 Thread GitBox
igalshilman opened a new pull request #67: [FLINK-16723] Move K8s example into statefun-examples/ URL: https://github.com/apache/flink-statefun/pull/67 This PR moves the python k8s example into statefun-examples/ This is an

[jira] [Updated] (FLINK-16723) Move Python SDK example out of statefun-python-sdk

2020-03-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16723: --- Labels: pull-request-available (was: ) > Move Python SDK example out of

[jira] [Updated] (FLINK-9970) Add ASCII/CHR function for Table API

2020-03-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-9970: --- Summary: Add ASCII/CHR function for Table API (was: Add ASCII/CHR function for table/sql API) > Add

[GitHub] [flink] rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

2020-03-23 Thread GitBox
rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r396394005 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

2020-03-23 Thread GitBox
rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r396389898 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

2020-03-23 Thread GitBox
rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r396365770 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

2020-03-23 Thread GitBox
rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r396349962 ## File path:

[jira] [Commented] (FLINK-16092) Translate "Overview" page of "Functions" into Chinese

2020-03-23 Thread zhule (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064755#comment-17064755 ] zhule commented on FLINK-16092: --- Hi [~jark], do you have time to take a look at my PR? > Translate

[jira] [Closed] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

2020-03-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14971. -- Resolution: Fixed Merged as 874310f68a..6936713b3b > Make all the non-IO operations in

[GitHub] [flink] zhijiangW commented on a change in pull request #11486: [FLINK-16712][task] Refactor StreamTask to construct final fields

2020-03-23 Thread GitBox
zhijiangW commented on a change in pull request #11486: [FLINK-16712][task] Refactor StreamTask to construct final fields URL: https://github.com/apache/flink/pull/11486#discussion_r396408716 ## File path:

[jira] [Updated] (FLINK-16721) getProcessCpuLoad seems to report a wrong cpu load

2020-03-23 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-16721: -- Attachment: cpu trend.png > getProcessCpuLoad seems to report a wrong cpu load >

[jira] [Created] (FLINK-16725) Support to parse various timestamp data format in JSON

2020-03-23 Thread Jark Wu (Jira)
Jark Wu created FLINK-16725: --- Summary: Support to parse various timestamp data format in JSON Key: FLINK-16725 URL: https://issues.apache.org/jira/browse/FLINK-16725 Project: Flink Issue Type: New

[jira] [Resolved] (FLINK-16092) Translate "Overview" page of "Functions" into Chinese

2020-03-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16092. - Fix Version/s: 1.11.0 Resolution: Fixed Fixed in master (1.11.0):

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

2020-03-23 Thread GitBox
pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r396444130 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11175: [FLINK-16197][hive] Failed to query partitioned table when partition …

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11175: [FLINK-16197][hive] Failed to query partitioned table when partition … URL: https://github.com/apache/flink/pull/11175#issuecomment-589671100 ## CI report: * 53fda3bf9cc936fee8c1925c76730df8d9ee6381 Travis:

[jira] [Commented] (FLINK-16717) Use headless service for rpc and blob port when flink on K8S

2020-03-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064689#comment-17064689 ] Canbin Zheng commented on FLINK-16717: -- Hi, [~wsfdl]! You are right. cc [~tison] > Use headless

[GitHub] [flink] tillrohrmann commented on a change in pull request #11408: [FLINK-15989][FLINK-16225] Improve direct and metaspace out-of-memory error handling

2020-03-23 Thread GitBox
tillrohrmann commented on a change in pull request #11408: [FLINK-15989][FLINK-16225] Improve direct and metaspace out-of-memory error handling URL: https://github.com/apache/flink/pull/11408#discussion_r396347458 ## File path:

[jira] [Comment Edited] (FLINK-16717) Use headless service for rpc and blob port when flink on K8S

2020-03-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064689#comment-17064689 ] Canbin Zheng edited comment on FLINK-16717 at 3/23/20, 10:26 AM: - Hi,

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#issuecomment-598702521 ## CI report: * 6e60715d78ca865c3d687699124338afb1f6d1e2

[jira] [Commented] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

2020-03-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064703#comment-17064703 ] Robert Metzger commented on FLINK-16720: FLINK-16411 could be a solution for the problem. I'm

[jira] [Closed] (FLINK-16302) add log list and read log by name for taskmanager

2020-03-23 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-16302. > add log list and read log by name for taskmanager > - > >

[jira] [Resolved] (FLINK-16302) add log list and read log by name for taskmanager

2020-03-23 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao resolved FLINK-16302. -- Resolution: Fixed master: c125c04185febca0a2bbf4fa04dee207208f1a5b

[jira] [Updated] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

2020-03-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16720: --- Fix Version/s: 1.11.0 > Maven gets stuck downloading artifacts on Azure >

[GitHub] [flink] pnowojski merged pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

2020-03-23 Thread GitBox
pnowojski merged pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347 This is an automated message from

[jira] [Updated] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

2020-03-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16720: --- Labels: test-stability (was: ) > Maven gets stuck downloading artifacts on Azure >

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

2020-03-23 Thread zhanglibing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064756#comment-17064756 ] zhanglibing commented on FLINK-16662: - Hi,[~chenxyz] I have also encountered this problem,I found

[jira] [Comment Edited] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets

2020-03-23 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064757#comment-17064757 ] Gary Yao edited comment on FLINK-16468 at 3/23/20, 12:04 PM: - {quote} I will

[jira] [Commented] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets

2020-03-23 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064757#comment-17064757 ] Gary Yao commented on FLINK-16468: -- {quote} I will happily update the user docs, but would appreciate

[jira] [Created] (FLINK-16726) ScalarFunction throws Given parameters of function 'func' do not match any signature.

2020-03-23 Thread Matrix42 (Jira)
Matrix42 created FLINK-16726: Summary: ScalarFunction throws Given parameters of function 'func' do not match any signature. Key: FLINK-16726 URL: https://issues.apache.org/jira/browse/FLINK-16726

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

2020-03-23 Thread GitBox
pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r396430496 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

2020-03-23 Thread GitBox
pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r396430496 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-23 Thread GitBox
wuchong commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r396441331 ## File path: flink-table/flink-table-planner-blink/pom.xml ## @@ -149,20 +135,28 @@

[GitHub] [flink] azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-03-23 Thread GitBox
azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#discussion_r396339439 ## File path: flink-runtime/pom.xml ## @@ -402,6 +402,59 @@ under the

[GitHub] [flink] flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#issuecomment-598702521 ## CI report: * 6e60715d78ca865c3d687699124338afb1f6d1e2

[GitHub] [flink] azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-03-23 Thread GitBox
azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#discussion_r396355481 ## File path: docs/ops/deployment/kubernetes.md ## @@ -112,8 +112,8 @@ An

[GitHub] [flink] azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-03-23 Thread GitBox
azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#discussion_r396338064 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-03-23 Thread GitBox
azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#discussion_r396343136 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-03-23 Thread GitBox
azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#discussion_r396342170 ## File path: flink-runtime/pom.xml ## @@ -475,6 +542,7 @@ under the

[GitHub] [flink] azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-03-23 Thread GitBox
azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#discussion_r396347004 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-03-23 Thread GitBox
azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#discussion_r396337589 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11487: [FLINK-16656] Introduce the DispatcherBootstrap.

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11487: [FLINK-16656] Introduce the DispatcherBootstrap. URL: https://github.com/apache/flink/pull/11487#issuecomment-602504532 ## CI report: * 8d31a75920164c244f4cc94cbcb8eaa284ff1b9d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11471: [FLINK-16692] flink joblistener can register from config

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#issuecomment-602012274 ## CI report: * 7f0c7e868fce22437c1b4b7a02fece52afb70f4a UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: *

[jira] [Commented] (FLINK-16544) Flink FileSystem for web.uploadDir

2020-03-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-16544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064688#comment-17064688 ] Angel Barragán commented on FLINK-16544: Hi, that could be a simpler way to do it, also, that

[GitHub] [flink] zhengcanbin commented on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

2020-03-23 Thread GitBox
zhengcanbin commented on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458#issuecomment-602517576 > @zhengcanbin please rebase on master. I think this PR itself is good

[jira] [Commented] (FLINK-15579) UpsertStreamTableSink should work on batch mode

2020-03-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064713#comment-17064713 ] Jingsong Lee commented on FLINK-15579: -- Change it to bug, because so many users treat it as a

[jira] [Updated] (FLINK-15579) UpsertStreamTableSink should work on batch mode

2020-03-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15579: - Issue Type: Bug (was: Improvement) > UpsertStreamTableSink should work on batch mode >

[jira] [Updated] (FLINK-15579) UpsertStreamTableSink should work on batch mode

2020-03-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15579: - Affects Version/s: (was: 1.9.1) (was: 1.9.0)

[GitHub] [flink] flinkbot edited a comment on issue #11489: [FLINK-15640][k8s] Support to set labels and node-selector for jobmanager and taskmanager pod

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11489: [FLINK-15640][k8s] Support to set labels and node-selector for jobmanager and taskmanager pod URL: https://github.com/apache/flink/pull/11489#issuecomment-602514343 ## CI report: * bb02ce865fa48c9259500a8408897605534b35c2 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index.

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index. URL: https://github.com/apache/flink/pull/11466#issuecomment-601789375 ## CI report: * 9c890d0d2012e311f4e33733e695da3ae0118fe9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11467: [FLINK-16317][operators] Provide support for watermarks, key selector and latency marker in MultipleInputStreamOperator

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11467: [FLINK-16317][operators] Provide support for watermarks, key selector and latency marker in MultipleInputStreamOperator URL: https://github.com/apache/flink/pull/11467#issuecomment-601798473 ## CI report: *

[jira] [Updated] (FLINK-15579) UpsertStreamTableSink should work on batch mode

2020-03-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15579: - Summary: UpsertStreamTableSink should work on batch mode (was: Support UpsertStreamTableSink

[jira] [Updated] (FLINK-16721) getProcessCpuLoad seems to report a wrong cpu load

2020-03-23 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-16721: -- Attachment: c (1).txt > getProcessCpuLoad seems to report a wrong cpu load >

[jira] [Updated] (FLINK-16721) getProcessCpuLoad seems to report a wrong cpu load

2020-03-23 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-16721: -- Attachment: (was: c (1).txt) > getProcessCpuLoad seems to report a wrong cpu load >

[jira] [Updated] (FLINK-16721) getProcessCpuLoad seems to report a wrong cpu load

2020-03-23 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-16721: -- Attachment: busythreads.txt > getProcessCpuLoad seems to report a wrong cpu load >

[jira] [Created] (FLINK-16721) getProcessCpuLoad seems to report a wrong cpu load

2020-03-23 Thread xiaogang zhou (Jira)
xiaogang zhou created FLINK-16721: - Summary: getProcessCpuLoad seems to report a wrong cpu load Key: FLINK-16721 URL: https://issues.apache.org/jira/browse/FLINK-16721 Project: Flink Issue

[jira] [Updated] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

2020-03-23 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16720: - Priority: Critical (was: Major) > Maven gets stuck downloading artifacts on Azure >

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2020-03-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064733#comment-17064733 ] Jark Wu commented on FLINK-9970: Hi [~tison], yes, it has been implemented in blink planner. I will close

[jira] [Assigned] (FLINK-16723) Move Python SDK example out of statefun-python-sdk

2020-03-23 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-16723: Assignee: Igal Shilman > Move Python SDK example out of statefun-python-sdk >

[jira] [Comment Edited] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

2020-03-23 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064732#comment-17064732 ] Zhijiang edited comment on FLINK-16720 at 3/23/20, 11:37 AM: - Another two

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11490: [FLINK-15579][table-planner-blink] UpsertStreamTableSink should work on batch mode

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11490: [FLINK-15579][table-planner-blink] UpsertStreamTableSink should work on batch mode URL: https://github.com/apache/flink/pull/11490#issuecomment-602532446 ## CI report: * d93b01c3f96fe9ed8638f7a054ded19e97677d60 UNKNOWN *

[jira] [Created] (FLINK-16723) Move Python SDK example out of statefun-python-sdk

2020-03-23 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16723: Summary: Move Python SDK example out of statefun-python-sdk Key: FLINK-16723 URL: https://issues.apache.org/jira/browse/FLINK-16723 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on issue #11486: [FLINK-16712][task] Refactor StreamTask to construct final fields

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11486: [FLINK-16712][task] Refactor StreamTask to construct final fields URL: https://github.com/apache/flink/pull/11486#issuecomment-602377929 ## CI report: * 9535112ff0782fd584600cc3fdbefe0457b1bcfb Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#issuecomment-601593052 ## CI report: * 83f691e3f8d3315ae063c5ae92b271164381f03c Travis:

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for Table API

2020-03-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064748#comment-17064748 ] Jark Wu commented on FLINK-9970: Hi [~tison], I found that these functions have not been supported for

[jira] [Created] (FLINK-16724) ListSerializer cannot serialize list which containers null

2020-03-23 Thread Chongchen Chen (Jira)
Chongchen Chen created FLINK-16724: -- Summary: ListSerializer cannot serialize list which containers null Key: FLINK-16724 URL: https://issues.apache.org/jira/browse/FLINK-16724 Project: Flink

[jira] [Closed] (FLINK-13698) Rework threading model of CheckpointCoordinator

2020-03-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-13698. -- Resolution: Fixed > Rework threading model of CheckpointCoordinator >

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

2020-03-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064766#comment-17064766 ] jackylau commented on FLINK-16692: -- [~kkl0u] ok .thanks  > flink joblistener can register from config

[jira] [Updated] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

2020-03-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16720: --- Issue Type: Bug (was: Task) > Maven gets stuck downloading artifacts on Azure >

[jira] [Commented] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

2020-03-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064693#comment-17064693 ] Robert Metzger commented on FLINK-16720: The issue seems to happen in the misc and connectors

[GitHub] [flink] tillrohrmann commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

2020-03-23 Thread GitBox
tillrohrmann commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r396349218 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java

[GitHub] [flink] tillrohrmann edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT.

2020-03-23 Thread GitBox
tillrohrmann edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#issuecomment-602514974 > @tillrohrmann, I have addressed your comments. > > However, I'm still trying to understand how the following is a

[GitHub] [flink] tillrohrmann commented on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT.

2020-03-23 Thread GitBox
tillrohrmann commented on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#issuecomment-602514974 > @tillrohrmann, I have addressed your comments. > > However, I'm still trying to understand how the following is a common

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#issuecomment-596323413 ## CI report: * 9f59db6be464318410e6ce165cb599233980b534 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11314: [FLINK-16411][AZP] Use google mvn mirror globally

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11314: [FLINK-16411][AZP] Use google mvn mirror globally URL: https://github.com/apache/flink/pull/11314#issuecomment-595093130 ## CI report: * 45fe1b3323935298e2152d4f620c91ce99b251af Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458#issuecomment-601537757 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11444: [FLINK-16608][python] Support primitive data types for vectorized Python UDF

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11444: [FLINK-16608][python] Support primitive data types for vectorized Python UDF URL: https://github.com/apache/flink/pull/11444#issuecomment-600678571 ## CI report: * f2ef0c0c560faa93cc7663ae7080676488066a10 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11314: [FLINK-16411][AZP] Use google mvn mirror globally

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11314: [FLINK-16411][AZP] Use google mvn mirror globally URL: https://github.com/apache/flink/pull/11314#issuecomment-595093130 ## CI report: * 45fe1b3323935298e2152d4f620c91ce99b251af Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#issuecomment-596323413 ## CI report: * 9f59db6be464318410e6ce165cb599233980b534 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11486: [FLINK-16712][task] Refactor StreamTask to construct final fields

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11486: [FLINK-16712][task] Refactor StreamTask to construct final fields URL: https://github.com/apache/flink/pull/11486#issuecomment-602377929 ## CI report: * 9535112ff0782fd584600cc3fdbefe0457b1bcfb Travis:

[jira] [Commented] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

2020-03-23 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064732#comment-17064732 ] Zhijiang commented on FLINK-16720: -- Another instance :

[jira] [Updated] (FLINK-16722) Add Python SDK walkthrough

2020-03-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16722: --- Labels: pull-request-available (was: ) > Add Python SDK walkthrough >

[GitHub] [flink-statefun] igalshilman opened a new pull request #66: [FLINK-16722] Add Python SDK Walkthrough

2020-03-23 Thread GitBox
igalshilman opened a new pull request #66: [FLINK-16722] Add Python SDK Walkthrough URL: https://github.com/apache/flink-statefun/pull/66 This PR adds a simple SDK concepts walkthrough as an example. This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #10973: [FLINK-15647][k8s] Support user-specified annotations for JM/TM Pods

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #10973: [FLINK-15647][k8s] Support user-specified annotations for JM/TM Pods URL: https://github.com/apache/flink/pull/10973#issuecomment-580223229 ## CI report: * 33776e6aa098656ddb2820bbac39b4b08f9fa3f8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11490: [FLINK-15579][table-planner-blink] UpsertStreamTableSink should work on batch mode

2020-03-23 Thread GitBox
flinkbot edited a comment on issue #11490: [FLINK-15579][table-planner-blink] UpsertStreamTableSink should work on batch mode URL: https://github.com/apache/flink/pull/11490#issuecomment-602532446 ## CI report: * d93b01c3f96fe9ed8638f7a054ded19e97677d60 UNKNOWN *

<    1   2   3   4   5   6   7   >