[GitHub] [flink] azagrebin opened a new pull request #12981: [FLINK-18581] Do not run GC phantom cleaners for Java < 8u72

2020-07-24 Thread GitBox
azagrebin opened a new pull request #12981: URL: https://github.com/apache/flink/pull/12981 The private JVM method `Reference.tryHandlePending` was introduced at Java 8u72. The explicit processing of queued phantom GC cleaners was exposed before 8u72, also is was not used while

[jira] [Comment Edited] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164263#comment-17164263 ] Dawid Wysakowicz edited comment on FLINK-18478 at 7/24/20, 8:55 AM:

[GitHub] [flink] flinkbot commented on pull request #12981: [FLINK-18581] Do not run GC phantom cleaners for Java < 8u72

2020-07-24 Thread GitBox
flinkbot commented on pull request #12981: URL: https://github.com/apache/flink/pull/12981#issuecomment-663425130 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

[jira] [Commented] (FLINK-18643) Migrate Jenkins jobs to ci-builds.apache.org

2020-07-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164287#comment-17164287 ] Chesnay Schepler commented on FLINK-18643: -- > But what's the problem with pushing it to Azure's

[GitHub] [flink] flinkbot edited a comment on pull request #12980: [FLINK-18646] Verify memory manager empty in a separate thread with l…

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12980: URL: https://github.com/apache/flink/pull/12980#issuecomment-663414110 ## CI report: * 6a8838f4c0262c0d1c63f74b1c538f93a4f6282c Azure:

[jira] [Updated] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

2020-07-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18695: - Description: in 4.1.43 netty made a change to their SslHandler to always use heap

[jira] [Commented] (FLINK-18640) Flink jdbc not support postgresql with schema

2020-07-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164298#comment-17164298 ] 毛宗良 commented on FLINK-18640: - Hi [~jark], as your saying, we don't need to think about the table name with

[jira] [Updated] (FLINK-18702) Flink elasticsearch connector leaks threads and classloaders thereof

2020-07-24 Thread Jun Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin updated FLINK-18702: Affects Version/s: 1.10.0 > Flink elasticsearch connector leaks threads and classloaders thereof >

[GitHub] [flink] pnowojski merged pull request #12974: [FLINK-18552][tests] Update migration tests in master to cover migration for 1.10

2020-07-24 Thread GitBox
pnowojski merged pull request #12974: URL: https://github.com/apache/flink/pull/12974 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

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

2020-07-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164381#comment-17164381 ] Robert Metzger commented on FLINK-11127: Thanks a lot for your quick comment. I believe Flink

[GitHub] [flink] flinkbot edited a comment on pull request #12984: [FLINK-18552][tests] Update migration tests in release-1.11 to cover migration for 1.11

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12984: URL: https://github.com/apache/flink/pull/12984#issuecomment-663488263 ## CI report: * ce9bcade4e123fea37f054be3d8229ecea5d8646 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12977: [FLINK-18697][table-api] Add the missing test scope to the flink-streaming-java_2.11:test-jar dependency

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12977: URL: https://github.com/apache/flink/pull/12977#issuecomment-663386671 ## CI report: * 3d8c3775bbe79258952d46ee97be639afc9eff06 Azure:

[jira] [Closed] (FLINK-11127) Make metrics query service establish connection to JobManager

2020-07-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-11127. -- Resolution: Won't Fix > Make metrics query service establish connection to JobManager >

[GitHub] [flink] flinkbot commented on pull request #12987: [FLINK-18703][table] Use new data structure converters when legacy types are not present

2020-07-24 Thread GitBox
flinkbot commented on pull request #12987: URL: https://github.com/apache/flink/pull/12987#issuecomment-663517173 ## CI report: * 03db38a2348a080c970f5f068e24caad704d5b61 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12952: [Hotfix] fix file event_driven.zh.md did't adding title anchor.

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12952: URL: https://github.com/apache/flink/pull/12952#issuecomment-662236222 ## CI report: * 30f8175e6c7e7057027e17c11d46baa6ed6f3d1c Azure:

[GitHub] [flink] flinkbot commented on pull request #12986: [FLINK-18706] fix sync-savepoint exactly-once semantic

2020-07-24 Thread GitBox
flinkbot commented on pull request #12986: URL: https://github.com/apache/flink/pull/12986#issuecomment-663517112 ## CI report: * 9834eb95c35dd119d42d147597979acc02c3839a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-24 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164456#comment-17164456 ] Seth Wiesman commented on FLINK-18478: -- [~georg.kf.hei...@gmail.com] I'm not sure you will find a

[jira] [Comment Edited] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-24 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164456#comment-17164456 ] Seth Wiesman edited comment on FLINK-18478 at 7/24/20, 1:50 PM:

[jira] [Closed] (FLINK-18521) Add release script for creating snapshot branches

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

[GitHub] [flink] maozl closed pull request #12979: [FLINK-18640][jdbc]Fix jdbc add property schema

2020-07-24 Thread GitBox
maozl closed pull request #12979: URL: https://github.com/apache/flink/pull/12979 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

[GitHub] [flink] maozl commented on pull request #12979: [FLINK-18640][jdbc]Fix jdbc add property schema

2020-07-24 Thread GitBox
maozl commented on pull request #12979: URL: https://github.com/apache/flink/pull/12979#issuecomment-663465618 add property schema is not suitable. Table name with '.' is much rare. This is an automated message from the

[jira] [Commented] (FLINK-18552) Update migration tests in master to cover migration from release-1.11

2020-07-24 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164332#comment-17164332 ] Piotr Nowojski commented on FLINK-18552: Backported to release-1.11 as 99604c6e93~7..99604c6e93

[jira] [Commented] (FLINK-18701) NOT NULL constraint is not guaranteed when aggregation split is enabled

2020-07-24 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164330#comment-17164330 ] Timo Walther commented on FLINK-18701: -- If we were using the new sink interfaces, the problem would

[GitHub] [flink] pnowojski merged pull request #12965: [FLINK-18552][tests] Update migration tests in master to cover migration till release-1.11

2020-07-24 Thread GitBox
pnowojski merged pull request #12965: URL: https://github.com/apache/flink/pull/12965 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

[GitHub] [flink] leonardBang commented on a change in pull request #12882: [FLINK-18579][FLINK-15728][jdbc] Introduce FieldNamedPreparedStatement to support fields are bound multiple times in update s

2020-07-24 Thread GitBox
leonardBang commented on a change in pull request #12882: URL: https://github.com/apache/flink/pull/12882#discussion_r459940712 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImplTest.java

[jira] [Commented] (FLINK-18552) Update migration tests in master to cover migration from release-1.11

2020-07-24 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164337#comment-17164337 ] Piotr Nowojski commented on FLINK-18552: Added missing tests for 1.10 to master branch as

[jira] [Created] (FLINK-18704) Support DECIMAL types in datagen Table source connector

2020-07-24 Thread Fabian Hueske (Jira)
Fabian Hueske created FLINK-18704: - Summary: Support DECIMAL types in datagen Table source connector Key: FLINK-18704 URL: https://issues.apache.org/jira/browse/FLINK-18704 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #12919: [FLINK-16048][avro] Support read/write confluent schema registry avro…

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12919: URL: https://github.com/apache/flink/pull/12919#issuecomment-659928275 ## CI report: * d1e4ba7690be134e21d193fbc1cb01aa51aaeb9b Azure:

[GitHub] [flink] flinkbot commented on pull request #12985: [FLINK-18682][orc][hive] Vector orc reader cannot read Hive 2.0.0 table

2020-07-24 Thread GitBox
flinkbot commented on pull request #12985: URL: https://github.com/apache/flink/pull/12985#issuecomment-663499515 ## CI report: * d5db2be542e04d592c05711ebd4a8b4c971ceed5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-07-24 Thread Yumeng Zhang (Jira)
Yumeng Zhang created FLINK-18706: Summary: Stop with savepoint cannot guarantee exactly-once for kafka source Key: FLINK-18706 URL: https://issues.apache.org/jira/browse/FLINK-18706 Project: Flink

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2020-07-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164395#comment-17164395 ] Robert Metzger commented on FLINK-18634: Different test, same error message: {code}

[GitHub] [flink] flinkbot edited a comment on pull request #12985: [FLINK-18682][orc][hive] Vector orc reader cannot read Hive 2.0.0 table

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12985: URL: https://github.com/apache/flink/pull/12985#issuecomment-663499515 ## CI report: * d5db2be542e04d592c05711ebd4a8b4c971ceed5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12983: [FLINK-18640][jdbc]Fix jdbc table name with schema error

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12983: URL: https://github.com/apache/flink/pull/12983#issuecomment-663473914 ## CI report: * 997b8e234bbde329cc60a3153827b1b39aa5eed9 Azure:

[GitHub] [flink] twentyworld commented on a change in pull request #12952: [Hotfix] fix file event_driven.zh.md did't adding title anchor.

2020-07-24 Thread GitBox
twentyworld commented on a change in pull request #12952: URL: https://github.com/apache/flink/pull/12952#discussion_r460020675 ## File path: docs/learn-flink/event_driven.zh.md ## @@ -183,7 +183,7 @@ public void processElement( * 本例使用一个 `MapState`,其中 keys

[GitHub] [flink] flinkbot commented on pull request #12988: [FLINK-18678][hive][doc] Update doc about setting hive version

2020-07-24 Thread GitBox
flinkbot commented on pull request #12988: URL: https://github.com/apache/flink/pull/12988#issuecomment-663524445 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

[jira] [Assigned] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector

2020-07-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-18566: -- Assignee: (was: Robert Metzger) > Add Support for Azure Cognitive Search

[GitHub] [flink] rmetzger commented on pull request #12847: [FLINK-18521][release] Add script for creating snapshot branch

2020-07-24 Thread GitBox
rmetzger commented on pull request #12847: URL: https://github.com/apache/flink/pull/12847#issuecomment-663426399 Okay, you are right. I assumed this script was also setting the version in the pom file. However, it doesn't (I should check the code I'm reviewing closer). Sorry for the

[GitHub] [flink] flinkbot edited a comment on pull request #12979: [FLINK-18640][jdbc]Fix jdbc add property schema

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12979: URL: https://github.com/apache/flink/pull/12979#issuecomment-663399823 ## CI report: * 997b8e234bbde329cc60a3153827b1b39aa5eed9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12982: Flink 18661 efo de registration

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12982: URL: https://github.com/apache/flink/pull/12982#issuecomment-663437185 ## CI report: * 87754ab6accacf3839bed9d0739756afc3e4ce99 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12981: [FLINK-18581] Do not run GC phantom cleaners for Java < 8u72

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12981: URL: https://github.com/apache/flink/pull/12981#issuecomment-663437091 ## CI report: * 1f972a523b8fa984ed2b629cf00aeabb16a5ecf5 Azure:

[jira] [Commented] (FLINK-18640) Flink jdbc not support postgresql with schema

2020-07-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164322#comment-17164322 ] Jark Wu commented on FLINK-18640: - If all the people participated in the discussion have an agreement,

[GitHub] [flink] zentol merged pull request #12847: [FLINK-18521][release] Add script for creating snapshot branch

2020-07-24 Thread GitBox
zentol merged pull request #12847: URL: https://github.com/apache/flink/pull/12847 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

[GitHub] [flink] flinkbot commented on pull request #12983: [FLINK-18640][jdbc]Fix jdbc table name with schema error

2020-07-24 Thread GitBox
flinkbot commented on pull request #12983: URL: https://github.com/apache/flink/pull/12983#issuecomment-663470969 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

[jira] [Commented] (FLINK-18640) Flink jdbc not support postgresql with schema

2020-07-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164344#comment-17164344 ] 毛宗良 commented on FLINK-18640: - [~jark], I made another pull [https://github.com/apache/flink/pull/12983].

[GitHub] [flink] gaoyunhaii opened a new pull request #12984: [FLINK-18552][tests] Update migration tests in release-1.11 to cover migration for 1.11

2020-07-24 Thread GitBox
gaoyunhaii opened a new pull request #12984: URL: https://github.com/apache/flink/pull/12984 **This PR picks the #12972 to the release-1.11 branch** ## What is the purpose of the change This PR updates the remaining tests to cover migration relative to **1.11** to **1.11**

[jira] [Commented] (FLINK-16510) Task manager safeguard shutdown may not be reliable

2020-07-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164366#comment-17164366 ] Till Rohrmann commented on FLINK-16510: --- I'm posting this for reference: There seems to be a

[GitHub] [flink] lirui-apache opened a new pull request #12988: [FLINK-18678][hive][doc] Update doc about setting hive version

2020-07-24 Thread GitBox
lirui-apache opened a new pull request #12988: URL: https://github.com/apache/flink/pull/12988 ## What is the purpose of the change Update doc and suggest not to manually set Hive version for HiveCatalog. Strange errors can happen if user sets an incorrect version.

[jira] [Updated] (FLINK-18678) Hive connector fails to create vector orc reader if user specifies incorrect hive version

2020-07-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18678: --- Labels: pull-request-available (was: ) > Hive connector fails to create vector orc reader

[GitHub] [flink] flinkbot edited a comment on pull request #12981: [FLINK-18581] Do not run GC phantom cleaners for Java < 8u72

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12981: URL: https://github.com/apache/flink/pull/12981#issuecomment-663437091 ## CI report: * 1f972a523b8fa984ed2b629cf00aeabb16a5ecf5 Azure:

[GitHub] [flink] flinkbot commented on pull request #12988: [FLINK-18678][hive][doc] Update doc about setting hive version

2020-07-24 Thread GitBox
flinkbot commented on pull request #12988: URL: https://github.com/apache/flink/pull/12988#issuecomment-663533121 ## CI report: * 47ecfdd6725845ff0f78050fec2002ca4093d6b4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-18707) Calling remove() for RockDB ListState iterator does nothing

2020-07-24 Thread Kenneth William Krugler (Jira)
Kenneth William Krugler created FLINK-18707: --- Summary: Calling remove() for RockDB ListState iterator does nothing Key: FLINK-18707 URL: https://issues.apache.org/jira/browse/FLINK-18707

[jira] [Assigned] (FLINK-18702) Flink elasticsearch connector leaks threads and classloaders thereof

2020-07-24 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18702: Assignee: Jun Qin > Flink elasticsearch connector leaks threads and classloaders

[GitHub] [flink] flinkbot edited a comment on pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #11896: URL: https://github.com/apache/flink/pull/11896#issuecomment-618808279 ## CI report: * 55b53dce83eeb0b20bf2a2f09d76e55911d0a2a1 Azure:

[jira] [Commented] (FLINK-15803) Expose the new type inference for aggregate functions

2020-07-24 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164369#comment-17164369 ] Timo Walther commented on FLINK-15803: -- Fixed in 1.12.0: {code}

[GitHub] [flink] twalthr closed pull request #12967: [FLINK-15803][table] Use AggregateInfo as the single source of types

2020-07-24 Thread GitBox
twalthr closed pull request #12967: URL: https://github.com/apache/flink/pull/12967 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

[jira] [Commented] (FLINK-18704) Support DECIMAL types in datagen Table source connector

2020-07-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164378#comment-17164378 ] Jark Wu commented on FLINK-18704: - +1 > Support DECIMAL types in datagen Table source connector >

[GitHub] [flink] flinkbot edited a comment on pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #11896: URL: https://github.com/apache/flink/pull/11896#issuecomment-618808279 ## CI report: * 7f4dee3368be4c841c1664a1d2d32bbd0a37763b Azure:

[jira] [Updated] (FLINK-18682) Vector orc reader cannot read Hive 2.0.0 table

2020-07-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18682: --- Labels: pull-request-available (was: ) > Vector orc reader cannot read Hive 2.0.0 table >

[GitHub] [flink] lirui-apache opened a new pull request #12985: [FLINK-18682][orc][hive] Vector orc reader cannot read Hive 2.0.0 table

2020-07-24 Thread GitBox
lirui-apache opened a new pull request #12985: URL: https://github.com/apache/flink/pull/12985 ## What is the purpose of the change Fix the issue that vector orc reader doesn't support Hive 2.0.0. Need to solve two problems: 1.

[jira] [Commented] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-24 Thread Georg Heiler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164392#comment-17164392 ] Georg Heiler commented on FLINK-18478: -- Could you recommend a tool where compatibility is fine, and

[jira] [Commented] (FLINK-16260) Add docker images based on Java 11

2020-07-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164403#comment-17164403 ] Chesnay Schepler commented on FLINK-16260: -- Fair enough, it is a good idea to extract the

[jira] [Assigned] (FLINK-18656) Start Delay metric is always zero for unaligned checkpoints

2020-07-24 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-18656: -- Assignee: Piotr Nowojski > Start Delay metric is always zero for unaligned

[jira] [Comment Edited] (FLINK-7129) Support dynamically changing CEP patterns

2020-07-24 Thread Lucas Senn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164441#comment-17164441 ] Lucas Senn edited comment on FLINK-7129 at 7/24/20, 1:28 PM: - [~knaufk] 

[jira] [Commented] (FLINK-7129) Support dynamically changing CEP patterns

2020-07-24 Thread Lucas Senn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164441#comment-17164441 ] Lucas Senn commented on FLINK-7129: --- [~knaufk] you're sure this approach will work? Based on this

[jira] [Commented] (FLINK-16510) Task manager safeguard shutdown may not be reliable

2020-07-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164313#comment-17164313 ] Chesnay Schepler commented on FLINK-16510: -- Maybe we can store all shutdown hook threads that

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

2020-07-24 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164310#comment-17164310 ] Benchao Li edited comment on FLINK-18202 at 7/24/20, 9:30 AM: -- {noformat}

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

2020-07-24 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164310#comment-17164310 ] Benchao Li edited comment on FLINK-18202 at 7/24/20, 9:29 AM: -- Hi all,

[GitHub] [flink] godfreyhe commented on a change in pull request #12964: [FLINK-17426][blink plannger] Dynamic Source supportsLimit pushdown

2020-07-24 Thread GitBox
godfreyhe commented on a change in pull request #12964: URL: https://github.com/apache/flink/pull/12964#discussion_r459959326 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushLimitIntoTableSourceScanRule.java

[jira] [Updated] (FLINK-18701) NOT NULL constraint is not guaranteed when aggregation split is enabled

2020-07-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18701: Affects Version/s: 1.11.1 > NOT NULL constraint is not guaranteed when aggregation split is enabled >

[jira] [Updated] (FLINK-18701) NOT NULL constraint is not guaranteed when aggregation split is enabled

2020-07-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18701: Fix Version/s: 1.11.2 1.12.0 > NOT NULL constraint is not guaranteed when aggregation

[jira] [Comment Edited] (FLINK-16510) Task manager safeguard shutdown may not be reliable

2020-07-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164358#comment-17164358 ] Till Rohrmann edited comment on FLINK-16510 at 7/24/20, 10:42 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #11896: URL: https://github.com/apache/flink/pull/11896#issuecomment-618808279 ## CI report: * 55b53dce83eeb0b20bf2a2f09d76e55911d0a2a1 Azure:

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

2020-07-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164368#comment-17164368 ] Jark Wu commented on FLINK-18202: - Regarding to Schema derivation, I think this is an orthogonal big

[GitHub] [flink] flinkbot commented on pull request #12984: [FLINK-18552][tests] Update migration tests in release-1.11 to cover migration for 1.11

2020-07-24 Thread GitBox
flinkbot commented on pull request #12984: URL: https://github.com/apache/flink/pull/12984#issuecomment-663478937 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

[jira] [Commented] (FLINK-16510) Task manager safeguard shutdown may not be reliable

2020-07-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164375#comment-17164375 ] Chesnay Schepler commented on FLINK-16510: -- The GC one can't be fixed in any case though,

[jira] [Commented] (FLINK-16260) Add docker images based on Java 11

2020-07-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164374#comment-17164374 ] Robert Metzger commented on FLINK-16260: Thanks a lot for posting your concerns with the current

[GitHub] [flink] rmetzger commented on pull request #12916: [FLINK-11547][flink-connector-kinesis] Fix JsonMappingException in DynamoDBStreamsSchema

2020-07-24 Thread GitBox
rmetzger commented on pull request #12916: URL: https://github.com/apache/flink/pull/12916#issuecomment-663490609 The problem is probably just a side-effect of a bug in the CI bot (it was triggering the same build multiple times, and we can not distinguish the builds properly from the

[jira] [Assigned] (FLINK-11127) Make metrics query service establish connection to JobManager

2020-07-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-11127: -- Assignee: (was: Robert Metzger) > Make metrics query service establish

[jira] [Updated] (FLINK-18705) Debezium-JSON throws NPE when tombstone message is received

2020-07-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18705: Affects Version/s: 1.11.0 > Debezium-JSON throws NPE when tombstone message is received >

[jira] [Created] (FLINK-18705) Debezium-JSON throws NPE when tombstone message is received

2020-07-24 Thread Jark Wu (Jira)
Jark Wu created FLINK-18705: --- Summary: Debezium-JSON throws NPE when tombstone message is received Key: FLINK-18705 URL: https://issues.apache.org/jira/browse/FLINK-18705 Project: Flink Issue

[GitHub] [flink] wuchong merged pull request #12977: [FLINK-18697][table-api] Add the missing test scope to the flink-streaming-java_2.11:test-jar dependency

2020-07-24 Thread GitBox
wuchong merged pull request #12977: URL: https://github.com/apache/flink/pull/12977 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

[GitHub] [flink] flinkbot commented on pull request #12985: [FLINK-18682][orc][hive] Vector orc reader cannot read Hive 2.0.0 table

2020-07-24 Thread GitBox
flinkbot commented on pull request #12985: URL: https://github.com/apache/flink/pull/12985#issuecomment-663498049 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

[jira] [Assigned] (FLINK-18705) Debezium-JSON throws NPE when tombstone message is received

2020-07-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18705: --- Assignee: Jark Wu > Debezium-JSON throws NPE when tombstone message is received >

[GitHub] [flink] flinkbot commented on pull request #12986: [FLINK-18706] fix sync-savepoint exactly-once semantic

2020-07-24 Thread GitBox
flinkbot commented on pull request #12986: URL: https://github.com/apache/flink/pull/12986#issuecomment-663509919 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] twentyworld commented on pull request #12952: [Hotfix] fix file event_driven.zh.md did't adding title anchor.

2020-07-24 Thread GitBox
twentyworld commented on pull request #12952: URL: https://github.com/apache/flink/pull/12952#issuecomment-663514542 @klion26 如果符合合并条件了, merge工作是你们做还是提交者来做(你们只负责approve)?如果是你们做的话,那rebase呢? This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #12988: [FLINK-18678][hive][doc] Update doc about setting hive version

2020-07-24 Thread GitBox
flinkbot edited a comment on pull request #12988: URL: https://github.com/apache/flink/pull/12988#issuecomment-663533121 ## CI report: * 47ecfdd6725845ff0f78050fec2002ca4093d6b4 Azure:

[jira] [Commented] (FLINK-18701) NOT NULL constraint is not guaranteed when aggregation split is enabled

2020-07-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164293#comment-17164293 ] Jark Wu commented on FLINK-18701: - The root cause is that we have an StreamExecExpand node when

[jira] [Commented] (FLINK-18701) NOT NULL constraint is not guaranteed when aggregation split is enabled

2020-07-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164294#comment-17164294 ] Jark Wu commented on FLINK-18701: - cc [~godfreyhe] > NOT NULL constraint is not guaranteed when

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

2020-07-24 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164310#comment-17164310 ] Benchao Li commented on FLINK-18202: Hi all, Sorry about the late reply, I would like to resume the

[GitHub] [flink] wuchong commented on a change in pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

2020-07-24 Thread GitBox
wuchong commented on a change in pull request #11896: URL: https://github.com/apache/flink/pull/11896#discussion_r459947202 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/format/single/SingleValueRowDataDeserialization.java ## @@ -0,0

[jira] [Created] (FLINK-18703) Use new data structure converters when legacy types are not present

2020-07-24 Thread Timo Walther (Jira)
Timo Walther created FLINK-18703: Summary: Use new data structure converters when legacy types are not present Key: FLINK-18703 URL: https://issues.apache.org/jira/browse/FLINK-18703 Project: Flink

[GitHub] [flink] godfreyhe commented on a change in pull request #12964: [FLINK-17426][blink plannger] Dynamic Source supportsLimit pushdown

2020-07-24 Thread GitBox
godfreyhe commented on a change in pull request #12964: URL: https://github.com/apache/flink/pull/12964#discussion_r459961065 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushLimitIntoTableSourceScanRule.java

[GitHub] [flink] godfreyhe commented on a change in pull request #12964: [FLINK-17426][blink plannger] Dynamic Source supportsLimit pushdown

2020-07-24 Thread GitBox
godfreyhe commented on a change in pull request #12964: URL: https://github.com/apache/flink/pull/12964#discussion_r459961065 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushLimitIntoTableSourceScanRule.java

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

2020-07-24 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164373#comment-17164373 ] Rafi Aroch commented on FLINK-11127: [~rmetzger] At the time, I did not use K8S, I used AWS ECS. In

[GitHub] [flink] zentol commented on a change in pull request #12981: [FLINK-18581] Do not run GC phantom cleaners for Java < 8u72

2020-07-24 Thread GitBox
zentol commented on a change in pull request #12981: URL: https://github.com/apache/flink/pull/12981#discussion_r459982395 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/UnsafeMemoryBudget.java ## @@ -37,9 +37,10 @@ class UnsafeMemoryBudget {

[GitHub] [flink] yumengz5 opened a new pull request #12986: [FLINK-18706] fix sync-savepoint exactly-once semantic

2020-07-24 Thread GitBox
yumengz5 opened a new pull request #12986: URL: https://github.com/apache/flink/pull/12986 ## What is the purpose of the change *This pull request is trying to solve stop with savepoint exactly-once semantic for Kafka source* ## Brief change log *(for

[jira] [Updated] (FLINK-18703) Use new data structure converters when legacy types are not present

2020-07-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18703: --- Labels: pull-request-available (was: ) > Use new data structure converters when legacy

[GitHub] [flink] twalthr opened a new pull request #12987: [FLINK-18703][table] Use new data structure converters when legacy types are not present

2020-07-24 Thread GitBox
twalthr opened a new pull request #12987: URL: https://github.com/apache/flink/pull/12987 ## What is the purpose of the change FLINK-16999 introduce the new data structure converters that are already in place for the new sources/sinks and new scalar/table functions. This can

[jira] [Assigned] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector

2020-07-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-18566: -- Assignee: Robert Metzger > Add Support for Azure Cognitive Search DataStream

[jira] [Comment Edited] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164263#comment-17164263 ] Dawid Wysakowicz edited comment on FLINK-18478 at 7/24/20, 8:54 AM:

  1   2   3   4   >