Suneel Marthi smarthi
smarthi
/ Code Profiler Javaagent 0.3.1 (and also with 0.2.0)
Created
May 24, 2020 17:44
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| May 24, 2020 1:41:46 PM software.amazon.codeguruprofilerjavaagent.ProfilingCommand runProfiler | |
| INFO: An unexpected issue caused the profiling command to terminate | |
| java.lang.BootstrapMethodError: call site initialization exception | |
| at java.lang.invoke.CallSite.makeSite(CallSite.java:341) | |
| at java.lang.invoke.MethodHandleNatives.linkCallSiteImpl(MethodHandleNatives.java:307) | |
| at java.lang.invoke.MethodHandleNatives.linkCallSite(MethodHandleNatives.java:297) | |
| at software.amazon.awssdk.http.apache.ApacheHttpClient.transformHeaders(ApacheHttpClient.java:276) | |
| at software.amazon.awssdk.http.apache.ApacheHttpClient.createResponse(ApacheHttpClient.java:261) | |
| at software.amazon.awssdk.http.apache.ApacheHttpClient.execute(ApacheHttpClient.java:241) | |
| at software.amazon.awssdk.http.apache.ApacheHttpClient.access$500(ApacheHttpClient.java:106) |
smarthi
/ Global Windows Example invoking TimeoutTrigger
Last active
August 26, 2016 04:25
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| private void executeJob(final ParameterTool parameters) throws Exception { | |
| StreamExecutionEnvironment execEnv = StreamExecutionEnvironment.getExecutionEnvironment(); | |
| KeyedStream<Tuple3<String, String, Long>, Tuple> keyedDS = ....; | |
| WindowedStream<Tuple3<String, String, Long>, Tuple, GlobalWindow> windowedStream = | |
| keyedDS.window(GlobalWindows.create()); | |
| windowedStream.trigger(TimeoutTrigger.of(CountTrigger.of(3), 10)); |
smarthi
/ gist:ac1b5058f05ab17d2f84862940ec4eba
Last active
August 25, 2016 01:52
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <settings> | |
| <profiles> | |
| <profile> | |
| <id>signed_release</id> | |
| <properties> | |
| <mavenExecutorId>forked-path</mavenExecutorId> | |
| <gpg.keyname>D3541808</gpg.keyname> | |
| <gpg.passphrase>xxx</gpg.passphrase> | |
| <deploy.altRepository>incubator-pirk.releases::default::https://dist.apache.org/repos/dist/dev/incubator/pirk/</deploy.altRepository> | |
| <username>apacheId</username> |
smarthi
/ System ML snippet
Created
November 24, 2015 14:48
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| if ( et == ExecType.CP ) | |
| { | |
| Lop agg1 = null; | |
| if( isTernaryAggregateRewriteApplicable() ) { | |
| agg1 = constructLopsTernaryAggregateRewrite(et); | |
| } | |
| else if( isUnaryAggregateOuterCPRewriteApplicable() ) | |
| { | |
| OperationTypes op = HopsAgg2Lops.get(_op); | |
| DirectionTypes dir = HopsDirection2Lops.get(_direction); |