[GitHub] [flink] flinkbot commented on pull request #12264: [FLINK-17668][netty] Release partitions asynchronously

2020-05-20 Thread GitBox
flinkbot commented on pull request #12264: URL: https://github.com/apache/flink/pull/12264#issuecomment-631339639 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 pro

[jira] [Closed] (FLINK-16158) SqlClient showdown when executing update if not start cluster

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-16158. -- Resolution: Duplicate > SqlClient showdown when executing update if not start cluster > --

[jira] [Updated] (FLINK-16922) DecimalData.toUnscaledBytes should be consistent with BigDecimla.unscaledValue.toByteArray

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16922: --- Summary: DecimalData.toUnscaledBytes should be consistent with BigDecimla.unscaledValue.toByteArray

[jira] [Commented] (FLINK-15503) FileUploadHandlerTest.testMixedMultipart and FileUploadHandlerTest. testUploadCleanupOnUnknownAttribute failed on Azure

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111956#comment-17111956 ] Robert Metzger commented on FLINK-15503: Yes, I can do that. The reason why I ra

[jira] [Commented] (FLINK-16165) NestedLoopJoin fallback to HashJoin when build records number is very large

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111960#comment-17111960 ] Danny Chen commented on FLINK-16165: Discussed offline with [~lzljs3620320], we have

[jira] [Created] (FLINK-17828) AggregateReduceGroupingITCase fails on azure

2020-05-20 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-17828: Summary: AggregateReduceGroupingITCase fails on azure Key: FLINK-17828 URL: https://issues.apache.org/jira/browse/FLINK-17828 Project: Flink Issue Ty

[jira] [Updated] (FLINK-16165) NestedLoopJoin fallback to HashJoin when build records number is very large

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16165: --- Fix Version/s: (was: 1.11.0) 1.12.0 > NestedLoopJoin fallback to HashJoin whe

[jira] [Commented] (FLINK-17828) AggregateReduceGroupingITCase fails on azure

2020-05-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111962#comment-17111962 ] Dawid Wysakowicz commented on FLINK-17828: -- [~jark] [~twalthr] Could you have a

[jira] [Updated] (FLINK-17828) AggregateReduceGroupingITCase fails on azure

2020-05-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17828: - Description: failure: https://dev.azure.com/apache-flink/apache-flink/_build/results?bu

[jira] [Updated] (FLINK-16800) TypeMappingUtils#checkIfCompatible didn't deal with nested types

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16800: --- Fix Version/s: (was: 1.11.0) 1.12.0 > TypeMappingUtils#checkIfCompatible didn

[jira] [Updated] (FLINK-17828) AggregateReduceGroupingITCase fails on azure

2020-05-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17828: - Labels: test-stability (was: ) > AggregateReduceGroupingITCase fails on azure > ---

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

2020-05-20 Thread GitBox
fpompermaier commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427858133 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31 +12

[jira] [Closed] (FLINK-13651) Blink planner should parse char(n)/varchar(n)/decimal(p, s) inside a string to corresponding datatype

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-13651. -- Release Note: Expression DSL would be refactored, so this fix cancels. Resolution: Won't Fix > B

[jira] [Commented] (FLINK-17828) AggregateReduceGroupingITCase fails on azure

2020-05-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111963#comment-17111963 ] Dawid Wysakowicz commented on FLINK-17828: -- It also failed locally for me > Ag

[jira] [Commented] (FLINK-17817) CollectResultFetcher fails with EOFException in AggregateReduceGroupingITCase

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111965#comment-17111965 ] Robert Metzger commented on FLINK-17817: Is this test failure caused by the same

[GitHub] [flink] zhuzhurk commented on pull request #12181: [FLINK-17645][runtime] Reset SafetyNetCloseableRegistry#REAPER_THREAD if it fails to start

2020-05-20 Thread GitBox
zhuzhurk commented on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-631348376 Thanks for opening the PR and addressing the comments. @wanglijie95 Will merge it once AZP gives green. Thi

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

2020-05-20 Thread GitBox
wuchong commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427859705 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31 +124,33

[jira] [Updated] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

2020-05-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17645: Affects Version/s: 1.12.0 > REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the > rep

[jira] [Updated] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

2020-05-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17645: Fix Version/s: 1.12.0 > REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the > repeate

[GitHub] [flink] flinkbot edited a comment on pull request #12254: [FLINK-17802][kafka] Set offset commit only if group id is configured for new Kafka Table source

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12254: URL: https://github.com/apache/flink/pull/12254#issuecomment-630911224 ## CI report: * acb41321f6856f6c87a2f85a7b3ddc065c41d46e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann commented on a change in pull request #12248: [FLINK-17725][tests] Disable OkHttpClient timeouts for FileUploadHandlerTest

2020-05-20 Thread GitBox
tillrohrmann commented on a change in pull request #12248: URL: https://github.com/apache/flink/pull/12248#discussion_r427860290 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java ## @@ -256,6 +257,14 @@ public void testUploadCle

[GitHub] [flink] flinkbot edited a comment on pull request #12252: [FLINK-17802][kafka] Set offset commit only if group id is configured for new Kafka Table source

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12252: URL: https://github.com/apache/flink/pull/12252#issuecomment-630874045 ## CI report: * 0e9d09047e051743a43c02130df4a5aedb75dc21 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630355116 ## CI report: * 6df9602ad51db30a39d5a8c6ed6e750025ff7429 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12264: [FLINK-17668][netty] Release partitions asynchronously

2020-05-20 Thread GitBox
flinkbot commented on pull request #12264: URL: https://github.com/apache/flink/pull/12264#issuecomment-631349883 ## CI report: * 19c5f57b94cc56b70002031618c32d9e6f68effb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] tillrohrmann commented on pull request #12248: [FLINK-17725][tests] Disable OkHttpClient timeouts for FileUploadHandlerTest

2020-05-20 Thread GitBox
tillrohrmann commented on pull request #12248: URL: https://github.com/apache/flink/pull/12248#issuecomment-631351576 Thanks for the review @rmetzger and @zentol. I've addressed your comments. Merging this PR now. This is an

[jira] [Assigned] (FLINK-17756) Drop table/view shouldn't take effect on each other

2020-05-20 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17756: -- Assignee: Danny Chen > Drop table/view shouldn't take effect on each other >

[jira] [Commented] (FLINK-17756) Drop table/view shouldn't take effect on each other

2020-05-20 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111970#comment-17111970 ] Kurt Young commented on FLINK-17756: assigned to you [~danny0405], thanks > Drop ta

[jira] [Reopened] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

2020-05-20 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reopened FLINK-15066: > Cannot run multiple `insert into csvTable values ()` > -

[jira] [Commented] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

2020-05-20 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111971#comment-17111971 ] Kurt Young commented on FLINK-15066: why this is marked as won't fix? > Cannot run

[GitHub] [flink] yangyichao-mango commented on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

2020-05-20 Thread GitBox
yangyichao-mango commented on pull request #12230: URL: https://github.com/apache/flink/pull/12230#issuecomment-631353997 @klion26 已经更新,辛苦review~ This is an automated message from the Apache Git Service. To respond to the mes

[jira] [Commented] (FLINK-17817) CollectResultFetcher fails with EOFException in AggregateReduceGroupingITCase

2020-05-20 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111975#comment-17111975 ] Caizhi Weng commented on FLINK-17817: - [~rmetzger] Yes. It says "Concurrent access t

[jira] [Updated] (FLINK-14361) Decorrelate subQuery fail when multi correlate in project

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-14361: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Decorrelate subQuery fail when multi co

[GitHub] [flink] tillrohrmann closed pull request #12248: [FLINK-17725][tests] Disable OkHttpClient timeouts for FileUploadHandlerTest

2020-05-20 Thread GitBox
tillrohrmann closed pull request #12248: URL: https://github.com/apache/flink/pull/12248 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to g

[jira] [Commented] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111976#comment-17111976 ] Danny Chen commented on FLINK-17553: cc [~godfreyhe], can you take a look for this P

[jira] [Resolved] (FLINK-17725) FileUploadHandlerTest.testUploadCleanupOnFailure fails with "SocketTimeout timeout"

2020-05-20 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-17725. --- Resolution: Fixed Fixed via master: e991de19337591cde444fbede010cb8bdc7f118f 1.11.0: 1b0d7f

[GitHub] [flink] zentol merged pull request #12138: [FLINK-16611] [datadog-metrics] Make number of metrics per request configurable

2020-05-20 Thread GitBox
zentol merged pull request #12138: URL: https://github.com/apache/flink/pull/12138 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Reset SafetyNetCloseableRegistry#REAPER_THREAD if it fails to start

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * bd9add8e480455265ca95b863601f6608918b334 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12254: [FLINK-17802][kafka] Set offset commit only if group id is configured for new Kafka Table source

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12254: URL: https://github.com/apache/flink/pull/12254#issuecomment-630911224 ## CI report: * acb41321f6856f6c87a2f85a7b3ddc065c41d46e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12230: URL: https://github.com/apache/flink/pull/12230#issuecomment-630205457 ## CI report: * 2f0ca570ff878cd12f999570590a08fa75efcc6b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12260: URL: https://github.com/apache/flink/pull/12260#issuecomment-631229314 ## CI report: * 7820729185644e576dc8d9c9204f2879a193cba0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-16611) Datadog reporter should chunk large reports

2020-05-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16611. Fix Version/s: 1.11.0 Resolution: Fixed master: df16e42a67aaba8e4ada34915d224e38019

[jira] [Assigned] (FLINK-15366) Dimension table do not support computed column

2020-05-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15366: --- Assignee: Leonard Xu > Dimension table do not support computed column > ---

[GitHub] [flink] wanglijie95 commented on pull request #12181: [FLINK-17645][runtime] Reset SafetyNetCloseableRegistry#REAPER_THREAD if it fails to start

2020-05-20 Thread GitBox
wanglijie95 commented on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-631363318 Thanks for review, @zhuzhurk This is an automated message from the Apache Git Service. To respond to the me

[jira] [Commented] (FLINK-17817) CollectResultFetcher fails with EOFException in AggregateReduceGroupingITCase

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111988#comment-17111988 ] Robert Metzger commented on FLINK-17817: ok > CollectResultFetcher fails with E

[jira] [Created] (FLINK-17829) Add documentation for the new JDBC connector

2020-05-20 Thread Jark Wu (Jira)
Jark Wu created FLINK-17829: --- Summary: Add documentation for the new JDBC connector Key: FLINK-17829 URL: https://issues.apache.org/jira/browse/FLINK-17829 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17830) Add documentation for the new HBase connector

2020-05-20 Thread Jark Wu (Jira)
Jark Wu created FLINK-17830: --- Summary: Add documentation for the new HBase connector Key: FLINK-17830 URL: https://issues.apache.org/jira/browse/FLINK-17830 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17832) Add documentation for the new Elasticsearch connector

2020-05-20 Thread Jark Wu (Jira)
Jark Wu created FLINK-17832: --- Summary: Add documentation for the new Elasticsearch connector Key: FLINK-17832 URL: https://issues.apache.org/jira/browse/FLINK-17832 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-17831) Add documentation for the new Kafka connector

2020-05-20 Thread Jark Wu (Jira)
Jark Wu created FLINK-17831: --- Summary: Add documentation for the new Kafka connector Key: FLINK-17831 URL: https://issues.apache.org/jira/browse/FLINK-17831 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-16795) End to end tests timeout on Azure

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111999#comment-17111999 ] Robert Metzger commented on FLINK-16795: bq. Reopening: https://dev.azure.com/a

[jira] [Commented] (FLINK-16795) End to end tests timeout on Azure

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112003#comment-17112003 ] Robert Metzger commented on FLINK-16795: bq. Another case: https://dev.azure.co

[jira] [Assigned] (FLINK-17829) Add documentation for the new JDBC connector

2020-05-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17829: --- Assignee: Leonard Xu > Add documentation for the new JDBC connector > -

[jira] [Assigned] (FLINK-17831) Add documentation for the new Kafka connector

2020-05-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17831: --- Assignee: Danny Chen > Add documentation for the new Kafka connector >

[jira] [Assigned] (FLINK-17830) Add documentation for the new HBase connector

2020-05-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17830: --- Assignee: Jark Wu > Add documentation for the new HBase connector > ---

[jira] [Created] (FLINK-17833) Add document for 1.11 SQL

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17833: -- Summary: Add document for 1.11 SQL Key: FLINK-17833 URL: https://issues.apache.org/jira/browse/FLINK-17833 Project: Flink Issue Type: Task Components:

[jira] [Updated] (FLINK-16922) DecimalData.toUnscaledBytes should be consistent with BigDecimla.unscaledValue.toByteArray

2020-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16922: --- Labels: pull-request-available (was: ) > DecimalData.toUnscaledBytes should be consistent w

[GitHub] [flink] wuchong opened a new pull request #12265: [FLINK-16922][table-common] Fix DecimalData.toUnscaledBytes() should be consistent with BigDecimla.unscaledValue.toByteArray()

2020-05-20 Thread GitBox
wuchong opened a new pull request #12265: URL: https://github.com/apache/flink/pull/12265 ## What is the purpose of the change When precision is compact, the returned `DecimalData.toUnscaledBytes()` is a 8-bytes length byte array which is incompatible with `BigDecimla.un

[jira] [Created] (FLINK-17834) Add document for Hive streaming source

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17834: -- Summary: Add document for Hive streaming source Key: FLINK-17834 URL: https://issues.apache.org/jira/browse/FLINK-17834 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17835) Add document for Hive streaming sink

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17835: -- Summary: Add document for Hive streaming sink Key: FLINK-17835 URL: https://issues.apache.org/jira/browse/FLINK-17835 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17836) Add document for Hive dim join

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17836: -- Summary: Add document for Hive dim join Key: FLINK-17836 URL: https://issues.apache.org/jira/browse/FLINK-17836 Project: Flink Issue Type: Sub-task R

[jira] [Created] (FLINK-17837) Add document for Hive DDL and DML

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17837: -- Summary: Add document for Hive DDL and DML Key: FLINK-17837 URL: https://issues.apache.org/jira/browse/FLINK-17837 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-17837) Add document for Hive DDL and DML

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-17837. -- Resolution: Duplicate > Add document for Hive DDL and DML > - > >

[GitHub] [flink] flinkbot commented on pull request #12265: [FLINK-16922][table-common] Fix DecimalData.toUnscaledBytes() should be consistent with BigDecimla.unscaledValue.toByteArray()

2020-05-20 Thread GitBox
flinkbot commented on pull request #12265: URL: https://github.com/apache/flink/pull/12265#issuecomment-631377402 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 2e339ca93fcf4461ddb3502b49ab34083fc96cf6 UNKNOWN * 0e1a42d1f6f38f2e1e92db036b55a5f54a49402f Azure: [CANCELED](https://dev.azure.com/apache-f

[jira] [Created] (FLINK-17840) Add document for new Kafka connector

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17840: -- Summary: Add document for new Kafka connector Key: FLINK-17840 URL: https://issues.apache.org/jira/browse/FLINK-17840 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17838) Add document for new JDBC connector

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17838: -- Summary: Add document for new JDBC connector Key: FLINK-17838 URL: https://issues.apache.org/jira/browse/FLINK-17838 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17839) Add document for new Hbase connector

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17839: -- Summary: Add document for new Hbase connector Key: FLINK-17839 URL: https://issues.apache.org/jira/browse/FLINK-17839 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17841) Add document for new ElasticSearch connector

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17841: -- Summary: Add document for new ElasticSearch connector Key: FLINK-17841 URL: https://issues.apache.org/jira/browse/FLINK-17841 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12264: URL: https://github.com/apache/flink/pull/12264#issuecomment-631349883 ## CI report: * 19c5f57b94cc56b70002031618c32d9e6f68effb UNKNOWN * 9dbaf3094c0942b96a01060aba9d4ffbad9d1857 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot edited a comment on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12230: URL: https://github.com/apache/flink/pull/12230#issuecomment-630205457 ## CI report: * 2f0ca570ff878cd12f999570590a08fa75efcc6b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12260: URL: https://github.com/apache/flink/pull/12260#issuecomment-631229314 ## CI report: * 7820729185644e576dc8d9c9204f2879a193cba0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630355116 ## CI report: * 6df9602ad51db30a39d5a8c6ed6e750025ff7429 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12252: [FLINK-17802][kafka] Set offset commit only if group id is configured for new Kafka Table source

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12252: URL: https://github.com/apache/flink/pull/12252#issuecomment-630874045 ## CI report: * 0e9d09047e051743a43c02130df4a5aedb75dc21 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-17558) Partitions are released in TaskExecutor Main Thread

2020-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17558: --- Labels: pull-request-available (was: ) > Partitions are released in TaskExecutor Main Threa

[jira] [Closed] (FLINK-17839) Add document for new Hbase connector

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-17839. -- Resolution: Duplicate > Add document for new Hbase connector > >

[jira] [Closed] (FLINK-17840) Add document for new Kafka connector

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-17840. -- Resolution: Duplicate > Add document for new Kafka connector > >

[jira] [Closed] (FLINK-17838) Add document for new JDBC connector

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-17838. -- Resolution: Duplicate > Add document for new JDBC connector > --- > >

[jira] [Closed] (FLINK-17841) Add document for new ElasticSearch connector

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-17841. -- Resolution: Duplicate > Add document for new ElasticSearch connector > ---

[jira] [Updated] (FLINK-17837) Add document for Hive DDL and DML

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17837: --- Parent: (was: FLINK-17833) Issue Type: Task (was: Sub-task) > Add document for Hive DDL

[jira] [Updated] (FLINK-17839) Add document for new Hbase connector

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17839: --- Parent: (was: FLINK-17833) Issue Type: Task (was: Sub-task) > Add document for new Hbas

[jira] [Updated] (FLINK-17838) Add document for new JDBC connector

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17838: --- Parent: (was: FLINK-17833) Issue Type: Task (was: Sub-task) > Add document for new JDBC

[jira] [Updated] (FLINK-17840) Add document for new Kafka connector

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17840: --- Parent: (was: FLINK-17833) Issue Type: Task (was: Sub-task) > Add document for new Kafk

[jira] [Updated] (FLINK-17841) Add document for new ElasticSearch connector

2020-05-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17841: --- Parent: (was: FLINK-17833) Issue Type: Task (was: Sub-task) > Add document for new Elas

[GitHub] [flink] twalthr commented on pull request #12263: [FLINK-16998][core] Support backwards compatibility for upgraded RowSerializer

2020-05-20 Thread GitBox
twalthr commented on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631385082 Thanks for the feedback @tzulitai. After some offline discussion, the tests were partially incorrect. I hope the PR is in a better shape now. --

[GitHub] [flink-web] klion26 commented on a change in pull request #247: [FLINK-13683] Translate "Code Style - Component Guide" page into Chinese

2020-05-20 Thread GitBox
klion26 commented on a change in pull request #247: URL: https://github.com/apache/flink-web/pull/247#discussion_r427758065 ## File path: contributing/code-style-and-quality-components.zh.md ## @@ -48,96 +48,96 @@ How to name config keys: } ``` -* The resulting config k

[jira] [Commented] (FLINK-17351) CheckpointCoordinator and CheckpointFailureManager ignores checkpoint timeouts

2020-05-20 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112026#comment-17112026 ] Roman Khachatryan commented on FLINK-17351: --- I think we need to increment the

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Reset SafetyNetCloseableRegistry#REAPER_THREAD if it fails to start

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * 05e0b2b0379e0b05c62631147b82711c32f11fcb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12252: [FLINK-17802][kafka] Set offset commit only if group id is configured for new Kafka Table source

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12252: URL: https://github.com/apache/flink/pull/12252#issuecomment-630874045 ## CI report: * 446be48d8b11fc0ae4a6d996a58e4558000900fc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630355116 ## CI report: * 6df9602ad51db30a39d5a8c6ed6e750025ff7429 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12263: [FLINK-16998][core] Support backwards compatibility for upgraded RowSerializer

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631274882 ## CI report: * 5e0f9df0a404a5d88b8762238ec37b903b9f0e4b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12265: [FLINK-16922][table-common] Fix DecimalData.toUnscaledBytes() should be consistent with BigDecimla.unscaledValue.toByteArray()

2020-05-20 Thread GitBox
flinkbot commented on pull request #12265: URL: https://github.com/apache/flink/pull/12265#issuecomment-631389712 ## CI report: * 4f4662a0211a334a8033d317b57cd8755677c744 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 2e339ca93fcf4461ddb3502b49ab34083fc96cf6 UNKNOWN * 0e1a42d1f6f38f2e1e92db036b55a5f54a49402f Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #12090: [FLINK-17622][connectors / jdbc] Remove useless switch for decimal in PostgresCatalog

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12090: URL: https://github.com/apache/flink/pull/12090#issuecomment-626999634 ## CI report: * 29252f270a654406deb02ed0f0e552605c476b68 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12265: [FLINK-16922][table-common] Fix DecimalData.toUnscaledBytes() should be consistent with BigDecimla.unscaledValue.toByteArray()

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12265: URL: https://github.com/apache/flink/pull/12265#issuecomment-631389712 ## CI report: * 4f4662a0211a334a8033d317b57cd8755677c744 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630355116 ## CI report: * efc125913ce29720089ebc8ef13131da3c2fab8a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-17842) Performance regression on 19.05.2020

2020-05-20 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-17842: -- Summary: Performance regression on 19.05.2020 Key: FLINK-17842 URL: https://issues.apache.org/jira/browse/FLINK-17842 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-17842) Performance regression on 19.05.2020

2020-05-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17842: --- Description: There is a noticeable performance regression in many benchmarks: http://codespe

[jira] [Assigned] (FLINK-17842) Performance regression on 19.05.2020

2020-05-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17842: -- Assignee: Piotr Nowojski > Performance regression on 19.05.2020 > ---

[jira] [Commented] (FLINK-17842) Performance regression on 19.05.2020

2020-05-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112056#comment-17112056 ] Piotr Nowojski commented on FLINK-17842: Those are the commits in suspected rang

[GitHub] [flink] flinkbot edited a comment on pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12264: URL: https://github.com/apache/flink/pull/12264#issuecomment-631349883 ## CI report: * 19c5f57b94cc56b70002031618c32d9e6f68effb UNKNOWN * 9dbaf3094c0942b96a01060aba9d4ffbad9d1857 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12263: [FLINK-16998][core] Support backwards compatibility for upgraded RowSerializer

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631274882 ## CI report: * 5e0f9df0a404a5d88b8762238ec37b903b9f0e4b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

<    1   2   3   4   5   6   >