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

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

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

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

[GitHub] [flink] dawidwys commented on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

dawidwys commented on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-631324483 Thank you all for joining the discussion! Thanks @twalthr for the review. I'll run the tests and after that I will merge that change.

[jira] [Assigned] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-17800: - Fix Version/s: 1.11.0 Assignee: Yun Tang Priority: Critical (was: Major) > RocksDB

[jira] [Commented] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111922#comment-17111922 ] Danny Chen commented on FLINK-17625: Hi, [~lsy], are you working on this ? > Fix

[GitHub] [flink] wanglijie95 commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

wanglijie95 commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427831205 ## File path: flink-core/src/test/java/org/apache/flink/core/fs/SafetyNetCloseableRegistryTest.java ## @@ -198,4 +198,29 @@ public void

[jira] [Updated] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17073: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Slow checkpoint cleanup

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

flinkbot edited a comment on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630355116 ## CI report: * 5925ef19171dea0dd42cd7f13875b7b05598f4b0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * edab8aef00bcac9a530501fa64165f344d7c74e7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

flinkbot edited a comment on pull request #12096: URL: https://github.com/apache/flink/pull/12096#issuecomment-627237312 ## CI report: * b414987409b6b4e072ac41798e53ab30d326675a Azure:

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

flinkbot edited a comment on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631274882 ## CI report: * 5e0f9df0a404a5d88b8762238ec37b903b9f0e4b Azure:

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

flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 2e339ca93fcf4461ddb3502b49ab34083fc96cf6 UNKNOWN * 0e1a42d1f6f38f2e1e92db036b55a5f54a49402f Azure:

[jira] [Commented] (FLINK-17657) jdbc not support read BIGINT UNSIGNED field

[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111920#comment-17111920 ] Danny Chen commented on FLINK-17657: Hi [~zhanglun], would you plan to fix this in release 1.11.0 ?

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

[ https://issues.apache.org/jira/browse/FLINK-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111916#comment-17111916 ] Danny Chen commented on FLINK-17756: Hi, [~ykt836], i would like to take this issue ~ > Drop

[jira] [Commented] (FLINK-17651) DecomposeGroupingSetsRule generates wrong plan when there exist distinct agg and simple agg with same filter

[ https://issues.apache.org/jira/browse/FLINK-17651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111913#comment-17111913 ] Danny Chen commented on FLINK-17651: cc [~godfreyhe], can you help to review this PR, thanks ~ >

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

fpompermaier commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427826635 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31

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

fpompermaier commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427825676 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31

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

fpompermaier commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427825676 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31

[jira] [Commented] (FLINK-17174) Conversion to relational algebra failed to preserve datatypes when using Table API but succeed when using SQL query

[ https://issues.apache.org/jira/browse/FLINK-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111907#comment-17111907 ] Danny Chen commented on FLINK-17174: This is an duplicate issue of FLINK-16160, so i would close it,

[jira] [Closed] (FLINK-17174) Conversion to relational algebra failed to preserve datatypes when using Table API but succeed when using SQL query

[ https://issues.apache.org/jira/browse/FLINK-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-17174. -- Resolution: Duplicate > Conversion to relational algebra failed to preserve datatypes when using >

[jira] [Updated] (FLINK-17820) Memory threshold is ignored for channel state

[ https://issues.apache.org/jira/browse/FLINK-17820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17820: --- Priority: Critical (was: Major) > Memory threshold is ignored for channel state >

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111903#comment-17111903 ] Kostas Kloudas commented on FLINK-17745: [~Echo Lee] Is it ok if we open a discussion in the ML

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

fpompermaier commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427823029 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31

[GitHub] [flink] flinkbot edited a comment on pull request #12258: [FLINK-17820][task][checkpointing] Don't flush channel state to disk explicitly

flinkbot edited a comment on pull request #12258: URL: https://github.com/apache/flink/pull/12258#issuecomment-631108764 ## CI report: * 8d01ba80d36c07517d7493cef13d6ab634c01e18 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12261: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

flinkbot edited a comment on pull request #12261: URL: https://github.com/apache/flink/pull/12261#issuecomment-631229356 ## CI report: * 26afeb03aa30f84994a8aa85ca2d223d44672067 Azure:

[jira] [Assigned] (FLINK-17819) Yarn error unhelpful when forgetting HADOOP_CLASSPATH

[ https://issues.apache.org/jira/browse/FLINK-17819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17819: -- Assignee: Kostas Kloudas > Yarn error unhelpful when forgetting HADOOP_CLASSPATH >

[jira] [Assigned] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17826: --- Assignee: Flavio Pompermaier > Add missing custom query support on new jdbc connector >

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111895#comment-17111895 ] Flavio Pompermaier commented on FLINK-17826: Ok, it should not be too complicated. Assign

[jira] [Updated] (FLINK-17795) Add an example to show how to leverage GPU resources

[ https://issues.apache.org/jira/browse/FLINK-17795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17795: --- Priority: Critical (was: Major) > Add an example to show how to leverage GPU resources >

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111894#comment-17111894 ] Jark Wu commented on FLINK-17826: - Hi [~f.pompermaier], the options and validation should be added in

[jira] [Commented] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111891#comment-17111891 ] Stephan Ewen commented on FLINK-17470: -- What JVM version are you using? Maybe there is different

[jira] [Assigned] (FLINK-17774) supports all kinds of changes for select result

[ https://issues.apache.org/jira/browse/FLINK-17774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17774: --- Assignee: godfrey he > supports all kinds of changes for select result >

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111889#comment-17111889 ] Flavio Pompermaier commented on FLINK-17826: I hope to find the time within the end of this

[GitHub] [flink] dawidwys commented on a change in pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

dawidwys commented on a change in pull request #12232: URL: https://github.com/apache/flink/pull/12232#discussion_r427812311 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/package.scala ## @@ -21,8 +21,8 @@

[jira] [Assigned] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17018: --- Assignee: Zhu Zhu > DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing >

[GitHub] [flink] twalthr commented on a change in pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

twalthr commented on a change in pull request #12232: URL: https://github.com/apache/flink/pull/12232#discussion_r427791839 ## File path: flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/package.scala ## @@ -39,7 +37,7 @@ import

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111881#comment-17111881 ] Kostas Kloudas commented on FLINK-17745: [~Echo Lee] I also think that we can close this issue

[jira] [Assigned] (FLINK-17721) AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry fails with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17721: -- Assignee: Xintong Song > AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry

[GitHub] [flink] kl0u commented on pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

kl0u commented on pull request #12233: URL: https://github.com/apache/flink/pull/12233#issuecomment-631300927 This PR is closed unmerged. For details see the discussion on the JIRA issue. This is an automated message from

[GitHub] [flink] kl0u closed pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

kl0u closed pull request #12233: URL: https://github.com/apache/flink/pull/12233 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] [Assigned] (FLINK-17351) CheckpointCoordinator and CheckpointFailureManager ignores checkpoint timeouts

[ https://issues.apache.org/jira/browse/FLINK-17351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17351: -- Assignee: Yuan Mei > CheckpointCoordinator and CheckpointFailureManager ignores

[jira] [Updated] (FLINK-17827) scala-shell.sh should fail early if no mode is specified, or have default logging settings

[ https://issues.apache.org/jira/browse/FLINK-17827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17827: - Priority: Critical (was: Major) > scala-shell.sh should fail early if no mode is

[jira] [Created] (FLINK-17827) scala-shell.sh should fail early if no mode is specified, or have default logging settings

Chesnay Schepler created FLINK-17827: Summary: scala-shell.sh should fail early if no mode is specified, or have default logging settings Key: FLINK-17827 URL:

[jira] [Updated] (FLINK-17096) Minibatch Group Agg support state ttl

[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17096: --- Affects Version/s: 1.11.0 > Minibatch Group Agg support state ttl >

[jira] [Updated] (FLINK-17096) Minibatch Group Agg support state ttl

[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17096: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Minibatch Group Agg support

[jira] [Updated] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16931: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Large _metadata file lead to

[jira] [Updated] (FLINK-16975) Add docs for FileSystem connector

[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16975: - Fix Version/s: 1.11.0 > Add docs for FileSystem connector > - >

[jira] [Commented] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111869#comment-17111869 ] Yu Li commented on FLINK-15507: --- Thanks for volunteering [~Zakelly], just assigned to you. > Activate

[jira] [Updated] (FLINK-16245) Use a delegating classloader as the user code classloader to prevent class leaks.

[ https://issues.apache.org/jira/browse/FLINK-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16245: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Use a delegating classloader

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

[ https://issues.apache.org/jira/browse/FLINK-16165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-16165: -- Assignee: Jingsong Lee > NestedLoopJoin fallback to HashJoin when build records

[jira] [Assigned] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-15507: - Assignee: Zakelly Lan > Activate local recovery for RocksDB backends by default >

[jira] [Commented] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111865#comment-17111865 ] Zakelly Lan commented on FLINK-15507: - I would like to take this ticket. > Activate local recovery

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

tzulitai commented on a change in pull request #12263: URL: https://github.com/apache/flink/pull/12263#discussion_r427782378 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java ## @@ -367,36 +367,42 @@ public int getVersion()

[jira] [Commented] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111864#comment-17111864 ] Yordan Pavlov commented on FLINK-17800: --- [~yunta] Yes the attachment reproduces the problem, it

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-10241: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Reduce performance/stability

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

flinkbot edited a comment on pull request #12230: URL: https://github.com/apache/flink/pull/12230#issuecomment-630205457 ## CI report: * 2f0ca570ff878cd12f999570590a08fa75efcc6b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * 265fa7767926382824b2894b2662d3a93a76b176 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12258: [FLINK-17820][task][checkpointing] Don't flush channel state to disk explicitly

flinkbot edited a comment on pull request #12258: URL: https://github.com/apache/flink/pull/12258#issuecomment-631108764 ## CI report: * cf629e225bc323888017be5d5a86c7c89a2b76bd Azure:

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

flinkbot edited a comment on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631274882 ## CI report: * 5e0f9df0a404a5d88b8762238ec37b903b9f0e4b Azure:

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

flinkbot edited a comment on pull request #12090: URL: https://github.com/apache/flink/pull/12090#issuecomment-626999634 ## CI report: * c6f506b50b8728300915c3353e606a807ac1c0c5 Azure:

[GitHub] [flink] zhuzhurk commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

zhuzhurk commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427794339 ## File path: flink-core/src/test/java/org/apache/flink/core/fs/SafetyNetCloseableRegistryTest.java ## @@ -198,4 +198,29 @@ public void

[jira] [Assigned] (FLINK-16986) Enhance the OperatorEvent handling guarantee during checkpointing.

[ https://issues.apache.org/jira/browse/FLINK-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-16986: Assignee: Stephan Ewen (was: Jiangjie Qin) > Enhance the OperatorEvent handling

[GitHub] [flink] zhuzhurk commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

zhuzhurk commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427792440 ## File path: flink-core/src/test/java/org/apache/flink/core/fs/SafetyNetCloseableRegistryTest.java ## @@ -198,4 +198,29 @@ public void

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

[ https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111829#comment-17111829 ] Caizhi Weng edited comment on FLINK-17817 at 5/20/20, 7:17 AM: --- I

[jira] [Assigned] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

[ https://issues.apache.org/jira/browse/FLINK-17822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-17822: --- Assignee: Andrey Zagrebin > Nightly Flink CLI end-to-end test failed with >

[jira] [Updated] (FLINK-16986) Enhance the OperatorEvent handling guarantee during checkpointing.

[ https://issues.apache.org/jira/browse/FLINK-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-16986: - Fix Version/s: 1.11.0 > Enhance the OperatorEvent handling guarantee during checkpointing. >

[jira] [Updated] (FLINK-16986) Enhance the OperatorEvent handling guarantee during checkpointing.

[ https://issues.apache.org/jira/browse/FLINK-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-16986: - Priority: Blocker (was: Major) > Enhance the OperatorEvent handling guarantee during

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

flinkbot edited a comment on pull request #12090: URL: https://github.com/apache/flink/pull/12090#issuecomment-626999634 ## CI report: * c6f506b50b8728300915c3353e606a807ac1c0c5 Azure:

[jira] [Closed] (FLINK-17541) Support inline structured types

[ https://issues.apache.org/jira/browse/FLINK-17541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-17541. Fix Version/s: 1.11.0 Resolution: Fixed Fixed in 1.12.0:

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * 265fa7767926382824b2894b2662d3a93a76b176 Azure:

[GitHub] [flink] TsReaper commented on pull request #12262: [FLINK-17817][hotfix] Fix serializer thread safe problem in CollectSinkFunction

TsReaper commented on pull request #12262: URL: https://github.com/apache/flink/pull/12262#issuecomment-631280841 Closing because #12199 also solves this problem. This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111840#comment-17111840 ] Jark Wu commented on FLINK-17826: - Hi [~zjwang], I would like to treat this one as a bug fix and should

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111837#comment-17111837 ] Jark Wu commented on FLINK-17826: - Would you like to take this? [~f.pompermaier] > Add missing custom

[GitHub] [flink] gyfora commented on pull request #12250: [FLINK-17619] Backport to 1.11

gyfora commented on pull request #12250: URL: https://github.com/apache/flink/pull/12250#issuecomment-631279205 merged This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Created] (FLINK-17826) Add missing custom query support on new jdbc connector

Jark Wu created FLINK-17826: --- Summary: Add missing custom query support on new jdbc connector Key: FLINK-17826 URL: https://issues.apache.org/jira/browse/FLINK-17826 Project: Flink Issue Type:

[GitHub] [flink] gyfora closed pull request #12250: [FLINK-17619] Backport to 1.11

gyfora closed pull request #12250: URL: https://github.com/apache/flink/pull/12250 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-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111832#comment-17111832 ] Robert Metzger commented on FLINK-16572:

[GitHub] [flink] flinkbot edited a comment on pull request #12258: [FLINK-17820][task][checkpointing] Don't flush channel state to disk explicitly

flinkbot edited a comment on pull request #12258: URL: https://github.com/apache/flink/pull/12258#issuecomment-631108764 ## CI report: * cf629e225bc323888017be5d5a86c7c89a2b76bd Azure:

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

flinkbot commented on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631274882 ## CI report: * 5e0f9df0a404a5d88b8762238ec37b903b9f0e4b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-17622) Remove useless switch for decimal in PostresCatalog

[ https://issues.apache.org/jira/browse/FLINK-17622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17622: --- Assignee: Flavio Pompermaier > Remove useless switch for decimal in PostresCatalog >

[GitHub] [flink] wuchong commented on pull request #12250: [FLINK-17619] Backport to 1.11

wuchong commented on pull request #12250: URL: https://github.com/apache/flink/pull/12250#issuecomment-631274912 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-17825) HA end-to-end gets killed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111831#comment-17111831 ] Robert Metzger commented on FLINK-17825: Looks like the timeout mechanism I introduced in

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

[ https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111829#comment-17111829 ] Caizhi Weng commented on FLINK-17817: - I remembered that FLINK-17774 actually solves this problem.

[jira] [Created] (FLINK-17825) HA end-to-end gets killed due to timeout

Robert Metzger created FLINK-17825: -- Summary: HA end-to-end gets killed due to timeout Key: FLINK-17825 URL: https://issues.apache.org/jira/browse/FLINK-17825 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * bd9add8e480455265ca95b863601f6608918b334 Azure:

[GitHub] [flink] twalthr closed pull request #12228: [FLINK-17541][table] Support inline structured types

twalthr closed pull request #12228: URL: https://github.com/apache/flink/pull/12228 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] TsReaper closed pull request #12262: [FLINK-17817][hotfix] Fix serializer thread safe problem in CollectSinkFunction

TsReaper closed pull request #12262: URL: https://github.com/apache/flink/pull/12262 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] [Updated] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15792: -- Fix Version/s: (was: 1.10.2) > Make Flink logs accessible via kubectl logs per default >

[jira] [Updated] (FLINK-15793) Move kubernetes-entry.sh out of FLINK_HOME/bin

[ https://issues.apache.org/jira/browse/FLINK-15793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15793: -- Fix Version/s: (was: 1.10.2) (was: 1.11.0) > Move kubernetes-entry.sh out

[GitHub] [flink] TsReaper commented on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

TsReaper commented on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-631271255 Azure for latest commit already passed in https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=1861=results

[GitHub] [flink] dawidwys commented on a change in pull request #12075: [FLINK-17004] Document the LIKE clause of CREATE TABLE statement.

dawidwys commented on a change in pull request #12075: URL: https://github.com/apache/flink/pull/12075#discussion_r427775248 ## File path: docs/dev/table/sql/create.md ## @@ -208,6 +215,101 @@ The key and value of expression `key1=val1` should both be string literal. See d

[GitHub] [flink] twalthr commented on a change in pull request #11986: [FLINK-17361] [jdbc] Added custom query on JDBC tables

twalthr commented on a change in pull request #11986: URL: https://github.com/apache/flink/pull/11986#discussion_r427773573 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTableSourceITCase.java ## @@ -143,20 +149,19

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

flinkbot commented on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631267389 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] twalthr opened a new pull request #12263: [FLINK-16998][core] Support backwards compatibility for upgraded RowSerializer

twalthr opened a new pull request #12263: URL: https://github.com/apache/flink/pull/12263 ## What is the purpose of the change Allows schema migration of the old serialization format for `RowSerializer`. The PR also updates the row serializer tests to the new

[GitHub] [flink] flinkbot edited a comment on pull request #12262: [FLINK-17817][hotfix] Fix serializer thread safe problem in CollectSinkFunction

flinkbot edited a comment on pull request #12262: URL: https://github.com/apache/flink/pull/12262#issuecomment-631257430 ## CI report: * 62091aabab937a2a802259aface1629fdac676b1 Azure:

[GitHub] [flink] flinkbot commented on pull request #12262: [FLINK-17817][hotfix] Fix serializer thread safe problem in CollectSinkFunction

flinkbot commented on pull request #12262: URL: https://github.com/apache/flink/pull/12262#issuecomment-631257430 ## CI report: * 62091aabab937a2a802259aface1629fdac676b1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * 0bf2aa2f54e22e76fed071e3c614139d4d187fc4 Azure:

<    1   2   3   4   5