[jira] [Created] (FLINK-17455) Move FileSystemFormatFactory to table common

2020-04-29 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17455: Summary: Move FileSystemFormatFactory to table common Key: FLINK-17455 URL: https://issues.apache.org/jira/browse/FLINK-17455 Project: Flink Issue Type:

[jira] [Updated] (FLINK-17455) Move FileSystemFormatFactory to table common

2020-04-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17455: - Component/s: (was: Table SQL / API) Connectors / FileSystem > Move

[jira] [Commented] (FLINK-17454) test_configuration.py ConfigurationTests::test_add_all failed on travis

2020-04-29 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095126#comment-17095126 ] Wei Zhong commented on FLINK-17454: --- Hi [~dian.fu], the root cause of the test failure is "Address

[jira] [Closed] (FLINK-16645) Limit the maximum backlogs in subpartitions for data skew case

2020-04-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-16645. -- Release Note: Added new config parameter

[jira] [Closed] (FLINK-16996) Refactor planner and connectors to use new data structures

2020-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16996. --- Fix Version/s: 1.11.0 Resolution: Fixed [hive] Refactor Hive connector to use new data structures -

[jira] [Commented] (FLINK-17454) test_configuration.py ConfigurationTests::test_add_all failed on travis

2020-04-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095112#comment-17095112 ] Dian Fu commented on FLINK-17454: - cc [~zhongwei] > test_configuration.py

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

2020-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095458#comment-17095458 ] Jark Wu commented on FLINK-17459: - We suggest to use {{JDBCUpsertTableSink}} in Table API & SQL which

[jira] [Comment Edited] (FLINK-17443) Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

2020-04-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095457#comment-17095457 ] Chesnay Schepler edited comment on FLINK-17443 at 4/29/20, 1:36 PM:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
rkhachatryan commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r417358710 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java ## @@ -969,15 +969,17 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
rkhachatryan commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r417378953 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -0,0 +1,156 @@ +/* + * Licensed

[jira] [Created] (FLINK-17467) Implement aligned savepoint in UC mode

2020-04-29 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-17467: - Summary: Implement aligned savepoint in UC mode Key: FLINK-17467 URL: https://issues.apache.org/jira/browse/FLINK-17467 Project: Flink Issue Type:

[jira] [Commented] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

2020-04-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095579#comment-17095579 ] Gyula Fora commented on FLINK-17466: I think I am running on a branch that already has this fix in,

[jira] [Commented] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

2020-04-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095580#comment-17095580 ] Gyula Fora commented on FLINK-17466: But I need to double check and verify this on the release-1.10

[GitHub] [flink] flinkbot commented on pull request #11947: [FLINK-16946] Update user documentation for job manager memory model

2020-04-29 Thread GitBox
flinkbot commented on pull request #11947: URL: https://github.com/apache/flink/pull/11947#issuecomment-621305246 ## CI report: * ffdc90b4f5ec67ab0622f783646f5528c1a49c4d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095450#comment-17095450 ] Robert Metzger commented on FLINK-17404: I now added the logging. Let's see if it happens again.

[jira] [Assigned] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-17404: -- Assignee: Robert Metzger > Running HA per-job cluster (rocks, non-incremental) gets

[GitHub] [flink] dianfu commented on pull request #11832: [FLINK-17148][python] Support converting pandas DataFrame to Flink Table

2020-04-29 Thread GitBox
dianfu commented on pull request #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-621200089 @hequn8128 Thanks for the review. Updated. This is an automated message from the Apache Git Service. To respond

[jira] [Assigned] (FLINK-16955) Bump Zookeeper 3.4.X to 3.4.14

2020-04-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-16955: Assignee: Piyush Narang (was: Chesnay Schepler) > Bump Zookeeper 3.4.X to

[jira] [Commented] (FLINK-17443) Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

2020-04-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095457#comment-17095457 ] Chesnay Schepler commented on FLINK-17443: -- I'm not actively working on it; I can assign it to

[jira] [Comment Edited] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

2020-04-29 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094595#comment-17094595 ] Rong Rong edited comment on FLINK-17386 at 4/29/20, 2:15 PM: - I just create

[GitHub] [flink] flinkbot edited a comment on pull request #11592: [FLINK-16871][runtime] Make more build time information available at runtime

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11592: URL: https://github.com/apache/flink/pull/11592#issuecomment-607128863 ## CI report: * 347da3e6e6a4728ad972b39b58b3946675dd990b UNKNOWN * 1569b0fb708871f14638cec612d272bb8ea53cd1 Travis:

[jira] [Created] (FLINK-17465) Update Chinese user documentation for job manager memory model

2020-04-29 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-17465: --- Summary: Update Chinese user documentation for job manager memory model Key: FLINK-17465 URL: https://issues.apache.org/jira/browse/FLINK-17465 Project: Flink

[GitHub] [flink] rmetzger commented on pull request #11921: [FLINK-17374] Remove travis-related files

2020-04-29 Thread GitBox
rmetzger commented on pull request #11921: URL: https://github.com/apache/flink/pull/11921#issuecomment-621206211 Reported unstable test from CI run: https://issues.apache.org/jira/browse/FLINK-17463 This is an automated

[jira] [Created] (FLINK-17463) BlobCacheCleanupTest.testPermanentBlobCleanup:133->verifyJobCleanup:432 » FileAlreadyExists

2020-04-29 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17463: -- Summary: BlobCacheCleanupTest.testPermanentBlobCleanup:133->verifyJobCleanup:432 » FileAlreadyExists Key: FLINK-17463 URL: https://issues.apache.org/jira/browse/FLINK-17463

[GitHub] [flink] flinkbot commented on pull request #11946: [FLINK-17460][orc][parquet] Create sql-jars for parquet and orc

2020-04-29 Thread GitBox
flinkbot commented on pull request #11946: URL: https://github.com/apache/flink/pull/11946#issuecomment-621227437 ## CI report: * 3330a210cce782d40effb148131061190fcbe216 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] rmetzger commented on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

2020-04-29 Thread GitBox
rmetzger commented on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-621233310 Chesnay has deployed a (hopefully) fixed version of the bot. This is an automated message from the Apache Git

[GitHub] [flink] XBaith commented on pull request #11937: [FLINK-16097][docs-zh] Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-29 Thread GitBox
XBaith commented on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-621252482 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 7f9ea6e4f4a506644e8c79d54eea8cad98b0a6a3 UNKNOWN * 75f0fcc317aa9a1f27a44f321cf4c9428c615017 UNKNOWN *

[jira] [Created] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

2020-04-29 Thread John Lonergan (Jira)
John Lonergan created FLINK-17464: - Summary: Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service Key: FLINK-17464 URL:

[jira] [Created] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time

2020-04-29 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-17468: -- Summary: Provide more detailed metrics why asynchronous part of checkpoint is taking long time Key: FLINK-17468 URL: https://issues.apache.org/jira/browse/FLINK-17468

[jira] [Commented] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

2020-04-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095581#comment-17095581 ] Gyula Fora commented on FLINK-17466: Also we do not get a planner error as in the linked issue, this

[GitHub] [flink] flinkbot commented on pull request #11948: [FLINK-17467] Align channels on savepoint in UC mode

2020-04-29 Thread GitBox
flinkbot commented on pull request #11948: URL: https://github.com/apache/flink/pull/11948#issuecomment-621321811 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] walterddr commented on a change in pull request #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader

2020-04-29 Thread GitBox
walterddr commented on a change in pull request #10836: URL: https://github.com/apache/flink/pull/10836#discussion_r417347722 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java ## @@ -56,42 +55,52 @@ public static SecurityContext

[GitHub] [flink] rkhachatryan commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
rkhachatryan commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r417355737 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -0,0 +1,156 @@ +/* + * Licensed

[GitHub] [flink] rkhachatryan commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
rkhachatryan commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r417355098 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java ## @@ -248,6 +248,15 @@ public String

[GitHub] [flink] KurtYoung commented on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

2020-04-29 Thread GitBox
KurtYoung commented on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-621245147 @rmetzger Thanks! This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 7f9ea6e4f4a506644e8c79d54eea8cad98b0a6a3 UNKNOWN * 75f0fcc317aa9a1f27a44f321cf4c9428c615017 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11899: URL: https://github.com/apache/flink/pull/11899#issuecomment-618868456 ## CI report: * 4ffaa5da88576abdbfb2e221faa8823313559c99 UNKNOWN * 7067eb4808877bf2a001e14dae1c09714c051d5f Travis:

[jira] [Issue Comment Deleted] (FLINK-16108) StreamSQLExample is failed if running in blink planner

2020-04-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-16108: --- Comment: was deleted (was: I think I am running on a branch that already has this fix :/ But I need

[jira] [Commented] (FLINK-16108) StreamSQLExample is failed if running in blink planner

2020-04-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095577#comment-17095577 ] Gyula Fora commented on FLINK-16108: I think I am running on a branch that already has this fix :/

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * a2d006dd6d8084ccd6ad6b68046d1e037088b2ad Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11913: [FLINK-17328][rest]Expose network metric for job vertex in rest api

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11913: URL: https://github.com/apache/flink/pull/11913#issuecomment-619511945 ## CI report: * 0c722f3e3cb9e4c5b6e173b46e4c6c53429c7bdc UNKNOWN * a613eea5e61e3374a1a61dd3ae8385b2e3821994 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11899: URL: https://github.com/apache/flink/pull/11899#issuecomment-618868456 ## CI report: * 4ffaa5da88576abdbfb2e221faa8823313559c99 UNKNOWN * 7067eb4808877bf2a001e14dae1c09714c051d5f Travis:

[GitHub] [flink] KurtYoung commented on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

2020-04-29 Thread GitBox
KurtYoung commented on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-621196151 @docete can you do a rebase and force push to trigger the tests? This is an automated message from the Apache

[GitHub] [flink] rmetzger commented on pull request #11921: [FLINK-17374] Remove travis-related files

2020-04-29 Thread GitBox
rmetzger commented on pull request #11921: URL: https://github.com/apache/flink/pull/11921#issuecomment-621206987 I don't know if it is a good idea or not, but I wanted to do a first quick PR to disable travis, and then do a bigger PR where I split things like `travis_watchdog.sh` into

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

2020-04-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095459#comment-17095459 ] Piotr Nowojski commented on FLINK-17012: I'm not sure, I think I don't have a specific problem

[GitHub] [flink] pnowojski commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

2020-04-29 Thread GitBox
pnowojski commented on a change in pull request #11541: URL: https://github.com/apache/flink/pull/11541#discussion_r413884448 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java ## @@ -81,16 +92,12 @@

[jira] [Updated] (FLINK-17460) Create sql-jars for parquet and orc

2020-04-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17460: --- Labels: pull-request-available (was: ) > Create sql-jars for parquet and orc >

[GitHub] [flink] flinkbot commented on pull request #11946: [FLINK-17460][orc][parquet] Create sql-jars for parquet and orc

2020-04-29 Thread GitBox
flinkbot commented on pull request #11946: URL: https://github.com/apache/flink/pull/11946#issuecomment-621216945 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] JingsongLi opened a new pull request #11946: [FLINK-17460][orc][parquet] Create sql-jars for parquet and orc

2020-04-29 Thread GitBox
JingsongLi opened a new pull request #11946: URL: https://github.com/apache/flink/pull/11946 ## What is the purpose of the change Create bundled jar for orc and parquet, for better use for sql users. ## Brief change log - exclude useless jars for orc - exclude

[jira] [Commented] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

2020-04-29 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095487#comment-17095487 ] Aljoscha Krettek commented on FLINK-17453: -- What's stored in the {{PriorityQueue}}? I mean the

[GitHub] [flink] rkhachatryan commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
rkhachatryan commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r417364836 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -0,0 +1,156 @@ +/* + * Licensed

[GitHub] [flink] rkhachatryan commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
rkhachatryan commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r417386876 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -0,0 +1,156 @@ +/* + * Licensed

[jira] [Updated] (FLINK-16946) Update user documentation for job manager memory model

2020-04-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16946: --- Labels: pull-request-available (was: ) > Update user documentation for job manager memory

[jira] [Created] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

2020-04-29 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-17466: -- Summary: toRetractStream doesn't work correctly with Pojo conversion class Key: FLINK-17466 URL: https://issues.apache.org/jira/browse/FLINK-17466 Project: Flink

[jira] [Commented] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

2020-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095562#comment-17095562 ] Jark Wu commented on FLINK-17466: - A duplicate issue of FLINK-16108 ? > toRetractStream doesn't work

[GitHub] [flink] flinkbot edited a comment on pull request #11592: [FLINK-16871][runtime] Make more build time information available at runtime

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11592: URL: https://github.com/apache/flink/pull/11592#issuecomment-607128863 ## CI report: * 347da3e6e6a4728ad972b39b58b3946675dd990b UNKNOWN * 1569b0fb708871f14638cec612d272bb8ea53cd1 Travis:

[jira] [Updated] (FLINK-17467) Implement aligned savepoint in UC mode

2020-04-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17467: --- Labels: pull-request-available (was: ) > Implement aligned savepoint in UC mode >

[GitHub] [flink] zjffdu edited a comment on pull request #11895: [FLINK-10911][scala-shell] Enable flink-scala-shell with Scala 2.12

2020-04-29 Thread GitBox
zjffdu edited a comment on pull request #11895: URL: https://github.com/apache/flink/pull/11895#issuecomment-621102592 @aljoscha Right, spark use `repl-class-based`. Regarding how spark support case classes, I need further investigation.

[GitHub] [flink] rkhachatryan commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
rkhachatryan commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r417363465 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -0,0 +1,156 @@ +/* + * Licensed

[GitHub] [flink] wuchong commented on a change in pull request #11944: [FLINK-17461][formats][json] Support JSON serialization and deseriazation schema for RowData type

2020-04-29 Thread GitBox
wuchong commented on a change in pull request #11944: URL: https://github.com/apache/flink/pull/11944#discussion_r417375698 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java ## @@ -0,0 +1,492 @@ +/* + *

[GitHub] [flink] wuchong commented on a change in pull request #11944: [FLINK-17461][formats][json] Support JSON serialization and deseriazation schema for RowData type

2020-04-29 Thread GitBox
wuchong commented on a change in pull request #11944: URL: https://github.com/apache/flink/pull/11944#discussion_r417375958 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java ## @@ -0,0 +1,492 @@ +/* + *

[GitHub] [flink] wuchong commented on pull request #11944: [FLINK-17461][formats][json] Support JSON serialization and deseriazation schema for RowData type

2020-04-29 Thread GitBox
wuchong commented on pull request #11944: URL: https://github.com/apache/flink/pull/11944#issuecomment-621261271 Thanks for the reviewing @KurtYoung . I have addressed the comments. This is an automated message from the

[GitHub] [flink] rkhachatryan commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
rkhachatryan commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r417376006 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -0,0 +1,156 @@ +/* + * Licensed

[GitHub] [flink] wuchong commented on a change in pull request #11944: [FLINK-17461][formats][json] Support JSON serialization and deseriazation schema for RowData type

2020-04-29 Thread GitBox
wuchong commented on a change in pull request #11944: URL: https://github.com/apache/flink/pull/11944#discussion_r417376335 ## File path: flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDataSerDeSchemaTest.java ## @@ -0,0 +1,437 @@ +package

[GitHub] [flink] flinkbot commented on pull request #11948: [FLINK-17467] Align channels on savepoint in UC mode

2020-04-29 Thread GitBox
flinkbot commented on pull request #11948: URL: https://github.com/apache/flink/pull/11948#issuecomment-621327009 ## CI report: * e1d9c5cffe6d375dc1bdf42472692f2756e7e58a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #11935: [FLINK-17431][sql-parser-hive][hive] Implement table DDLs for Hive di…

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11935: URL: https://github.com/apache/flink/pull/11935#issuecomment-620608086 ## CI report: * 8348c1d588578ca5fa79cc35576325dc5faa45d4 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162714221) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11942: [FLINK-17325][orc] Integrate orc to file system connector

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11942: URL: https://github.com/apache/flink/pull/11942#issuecomment-621092297 ## CI report: * 2e41f637638178e4ebd8efbdc6a1a20764658eca Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162709907) Azure:

[GitHub] [flink] rmetzger edited a comment on pull request #11921: [FLINK-17374] Remove travis-related files

2020-04-29 Thread GitBox
rmetzger edited a comment on pull request #11921: URL: https://github.com/apache/flink/pull/11921#issuecomment-621206987 I don't know if it is a good idea or not, but I wanted to do a first quick PR to disable travis, and then do a bigger PR where I split things like `travis_watchdog.sh`

[GitHub] [flink] flinkbot edited a comment on pull request #11592: [FLINK-16871][runtime] Make more build time information available at runtime

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11592: URL: https://github.com/apache/flink/pull/11592#issuecomment-607128863 ## CI report: * 347da3e6e6a4728ad972b39b58b3946675dd990b UNKNOWN * 168bea66ba7a153d2ada13622b63a5cfffaaf88a Travis:

[jira] [Commented] (FLINK-17443) Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

2020-04-29 Thread Piyush Narang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095453#comment-17095453 ] Piyush Narang commented on FLINK-17443: --- Thanks for getting back [~chesnay]. Are you / someone

[GitHub] [flink] flinkbot edited a comment on pull request #11937: [FLINK-16097][docs-zh] Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620730732 ## CI report: * cd3f40950ee89ff32ac45f166f03a32bf60241b1 UNKNOWN * d161289a8ae7e94074b60b2f7e80164b3c76197b Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11935: [FLINK-17431][sql-parser-hive][hive] Implement table DDLs for Hive di…

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11935: URL: https://github.com/apache/flink/pull/11935#issuecomment-620608086 ## CI report: * 062114a456dffdef8b5226105037c398c012a56d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162660242) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11942: [FLINK-17325][orc] Integrate orc to file system connector

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11942: URL: https://github.com/apache/flink/pull/11942#issuecomment-621092297 ## CI report: * 5e6e5057f05147c8eed38a148d54ad0f0022a5b9 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162660283) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11832: [FLINK-17148][python] Support converting pandas DataFrame to Flink Table

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-616617636 ## CI report: * c2105e0170d56fb95b849c4b830ca7a7b9d48fd3 UNKNOWN * a30c4d84d218a3ab91a232c648f0a586df75eaa9 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11945: [FLINK-17254][python][docs] Improve the PyFlink documentation and exa…

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11945: URL: https://github.com/apache/flink/pull/11945#issuecomment-621147045 ## CI report: * 1a6ff16c84e65d7a7582b82dcafee9bf039112be Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162686850) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11942: [FLINK-17325][orc] Integrate orc to file system connector

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11942: URL: https://github.com/apache/flink/pull/11942#issuecomment-621092297 ## CI report: * 2e41f637638178e4ebd8efbdc6a1a20764658eca Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162709907) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11946: [FLINK-17460][orc][parquet] Create sql-jars for parquet and orc

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11946: URL: https://github.com/apache/flink/pull/11946#issuecomment-621227437 ## CI report: * 3330a210cce782d40effb148131061190fcbe216 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162723935) Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
rkhachatryan commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r417394178 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -535,20 +540,16 @@ private void

[jira] [Updated] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

2020-04-29 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17464: -- Description: When recovering job graphs after a failover of the JobManager, or after a

[GitHub] [flink] flinkbot edited a comment on pull request #11937: [FLINK-16097][docs-zh] Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620730732 ## CI report: * cd3f40950ee89ff32ac45f166f03a32bf60241b1 UNKNOWN * d161289a8ae7e94074b60b2f7e80164b3c76197b Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11913: [FLINK-17328][rest]Expose network metric for job vertex in rest api

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11913: URL: https://github.com/apache/flink/pull/11913#issuecomment-619511945 ## CI report: * 0c722f3e3cb9e4c5b6e173b46e4c6c53429c7bdc UNKNOWN * a613eea5e61e3374a1a61dd3ae8385b2e3821994 Travis:

[GitHub] [flink] azagrebin opened a new pull request #11947: [FLINK-16946] Update user documentation for job manager memory model

2020-04-29 Thread GitBox
azagrebin opened a new pull request #11947: URL: https://github.com/apache/flink/pull/11947 ## What is the purpose of the change Update user documentation according to the changes in the JM memory configuration after

[GitHub] [flink] rkhachatryan opened a new pull request #11948: Uc aligned savepoints

2020-04-29 Thread GitBox
rkhachatryan opened a new pull request #11948: URL: https://github.com/apache/flink/pull/11948 ## What is the purpose of the change Perform alignment for savepoints even if UnalignedCheckpoints are enabled. ## Verifying this change Added unit tests: -

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 7f9ea6e4f4a506644e8c79d54eea8cad98b0a6a3 UNKNOWN * 75f0fcc317aa9a1f27a44f321cf4c9428c615017 UNKNOWN *

[jira] [Assigned] (FLINK-17460) Create sql-jars for parquet and orc

2020-04-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17460: Assignee: Jingsong Lee > Create sql-jars for parquet and orc >

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 7f9ea6e4f4a506644e8c79d54eea8cad98b0a6a3 UNKNOWN * 75f0fcc317aa9a1f27a44f321cf4c9428c615017 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11942: [FLINK-17325][orc] Integrate orc to file system connector

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11942: URL: https://github.com/apache/flink/pull/11942#issuecomment-621092297 ## CI report: * 5e6e5057f05147c8eed38a148d54ad0f0022a5b9 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162660283) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11934: [FLINK-17403][test] Fix invalid classpath in BashJavaUtilsITCase

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11934: URL: https://github.com/apache/flink/pull/11934#issuecomment-620607964 ## CI report: * e1be455034c22ae67943cb5ecda2e4a70f5a844a Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162686718) Bot

[GitHub] [flink] flinkbot edited a comment on pull request #11935: [FLINK-17431][sql-parser-hive][hive] Implement table DDLs for Hive di…

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11935: URL: https://github.com/apache/flink/pull/11935#issuecomment-620608086 ## CI report: * 062114a456dffdef8b5226105037c398c012a56d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162660242) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11832: [FLINK-17148][python] Support converting pandas DataFrame to Flink Table

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-616617636 ## CI report: * c2105e0170d56fb95b849c4b830ca7a7b9d48fd3 UNKNOWN * a30c4d84d218a3ab91a232c648f0a586df75eaa9 Travis:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-29 Thread GitBox
rkhachatryan commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r417368572 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -0,0 +1,156 @@ +/* + * Licensed

[GitHub] [flink] fpompermaier commented on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

2020-04-29 Thread GitBox
fpompermaier commented on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-621282562 What about moving getUniqueConstraints() and getPrimaryKey() in a more general class? They can probably be reused by other catalogs..of course we have to decide if

[GitHub] [flink] flinkbot edited a comment on pull request #11937: [FLINK-16097][docs-zh] Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620730732 ## CI report: * cd3f40950ee89ff32ac45f166f03a32bf60241b1 UNKNOWN * d161289a8ae7e94074b60b2f7e80164b3c76197b Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11944: [FLINK-17461][formats][json] Support JSON serialization and deseriazation schema for RowData type

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11944: URL: https://github.com/apache/flink/pull/11944#issuecomment-621136570 ## CI report: * de28bae2536983745bdf14f1b15b1929d7ff0956 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162682893) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11832: [FLINK-17148][python] Support converting pandas DataFrame to Flink Table

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-616617636 ## CI report: * c2105e0170d56fb95b849c4b830ca7a7b9d48fd3 UNKNOWN * 0a37369514bce10618debc2947cf852e6d188b2f Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 0118f76b444e2347aa3b5f30d2e1800962a42427 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11947: [FLINK-16946] Update user documentation for job manager memory model

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11947: URL: https://github.com/apache/flink/pull/11947#issuecomment-621305246 ## CI report: * ffdc90b4f5ec67ab0622f783646f5528c1a49c4d Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162750649) Azure:

[jira] [Updated] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time

2020-04-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17468: --- Description: As [reported by

[jira] [Commented] (FLINK-17445) Allow OperatorTransformation to bootstrapWith a Scala DataSet

2020-04-29 Thread Brandon Bevans (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095693#comment-17095693 ] Brandon Bevans commented on FLINK-17445: Thanks for the response, Seth. I will begin working on

  1   2   3   4   >